Files
lone-services/services/message/messageclient/message.go
T
gjs 7939917ba0
CI / changes (push) Successful in 39s
CI / ad (push) Successful in 1s
CI / admin (push) Successful in 0s
CI / bff (push) Successful in 48s
CI / chore (push) Successful in 0s
CI / equipment (push) Failing after 10s
CI / express (push) Successful in 0s
CI / factory (push) Successful in 0s
CI / payment (push) Successful in 1s
CI / product (push) Successful in 0s
CI / record (push) Successful in 0s
CI / sale (push) Successful in 1s
CI / task (push) Successful in 0s
CI / user (push) Successful in 0s
CI / wecom (push) Successful in 1s
message
2026-09-21 15:50:44 +08:00

60 lines
1.9 KiB
Go

// Code generated by goctl. DO NOT EDIT.
// goctl 1.10.2
// Source: message.proto
package messageClient
import (
"context"
"lone-services/rpc/message/pb"
"github.com/zeromicro/go-zero/zrpc"
"google.golang.org/grpc"
)
type (
AddRequest = message.AddRequest
AddResponse = message.AddResponse
ApiMessageNumberRequest = message.ApiMessageNumberRequest
ItemsRequest = message.ItemsRequest
Response = message.Response
Message interface {
AdminMessage(ctx context.Context, in *ItemsRequest, opts ...grpc.CallOption) (*Response, error)
ApiMessage(ctx context.Context, in *ItemsRequest, opts ...grpc.CallOption) (*Response, error)
ApiMessageNumber(ctx context.Context, in *ApiMessageNumberRequest, opts ...grpc.CallOption) (*Response, error)
MessageAdd(ctx context.Context, in *AddRequest, opts ...grpc.CallOption) (*AddResponse, error)
}
defaultMessage struct {
cli zrpc.Client
}
)
func NewMessage(cli zrpc.Client) Message {
return &defaultMessage{
cli: cli,
}
}
func (m *defaultMessage) AdminMessage(ctx context.Context, in *ItemsRequest, opts ...grpc.CallOption) (*Response, error) {
client := message.NewMessageClient(m.cli.Conn())
return client.AdminMessage(ctx, in, opts...)
}
func (m *defaultMessage) ApiMessage(ctx context.Context, in *ItemsRequest, opts ...grpc.CallOption) (*Response, error) {
client := message.NewMessageClient(m.cli.Conn())
return client.ApiMessage(ctx, in, opts...)
}
func (m *defaultMessage) ApiMessageNumber(ctx context.Context, in *ApiMessageNumberRequest, opts ...grpc.CallOption) (*Response, error) {
client := message.NewMessageClient(m.cli.Conn())
return client.ApiMessageNumber(ctx, in, opts...)
}
func (m *defaultMessage) MessageAdd(ctx context.Context, in *AddRequest, opts ...grpc.CallOption) (*AddResponse, error) {
client := message.NewMessageClient(m.cli.Conn())
return client.MessageAdd(ctx, in, opts...)
}