mq

Documentation

Index

• Variables
• func MQService_TestMQAdd_Handler(svr interface{}, ctx context.Context, f server.FilterFunc) (interface{}, error)
• func RegisterMQService(s server.Service, svr MQService)
• type MQClientProxy
• type MQClientProxyImpl
  • func (c *MQClientProxyImpl) TestMQAdd(ctx context.Context, req *TestMQAddRequest, opts ...client.Option) (*TestMQAddResponse, error)
• type MQService
• type TestMQAddRequest
  • func (*TestMQAddRequest) Descriptor() ([]byte, []int)
  • func (x *TestMQAddRequest) GetCount() int32
  • func (x *TestMQAddRequest) GetMetadata() *common.Metadata
  • func (x *TestMQAddRequest) GetType() string
  • func (*TestMQAddRequest) ProtoMessage()
  • func (x *TestMQAddRequest) ProtoReflect() protoreflect.Message
  • func (x *TestMQAddRequest) Reset()
  • func (x *TestMQAddRequest) String() string
• type TestMQAddResponse
  • func (*TestMQAddResponse) Descriptor() ([]byte, []int)
  • func (x *TestMQAddResponse) GetErrCode() int32
  • func (x *TestMQAddResponse) GetErrMsg() string
  • func (*TestMQAddResponse) ProtoMessage()
  • func (x *TestMQAddResponse) ProtoReflect() protoreflect.Message
  • func (x *TestMQAddResponse) Reset()
  • func (x *TestMQAddResponse) String() string
• type UnimplementedMQ
  • func (s *UnimplementedMQ) TestMQAdd(ctx context.Context, req *TestMQAddRequest) (*TestMQAddResponse, error)

Variables

var File_mq_proto protoreflect.FileDescriptor

var MQServer_ServiceDesc = server.ServiceDesc{
	ServiceName: "demo.mq.MQ",
	HandlerType: ((*MQService)(nil)),
	Methods: []server.Method{
		{
			Name: "/demo/mq/add",
			Func: MQService_TestMQAdd_Handler,
		},
		{
			Name: "/demo.mq.MQ/TestMQAdd",
			Func: MQService_TestMQAdd_Handler,
		},
	},
}

MQServer_ServiceDesc descriptor for server.RegisterService.

var NewMQClientProxy = func(opts ...client.Option) MQClientProxy {
	return &MQClientProxyImpl{client: client.DefaultClient, opts: opts}
}

Functions

func MQService_TestMQAdd_Handler

func MQService_TestMQAdd_Handler(svr interface{}, ctx context.Context, f server.FilterFunc) (interface{}, error)

func RegisterMQService

func RegisterMQService(s server.Service, svr MQService)

RegisterMQService registers service.

Types

type MQClientProxy

type MQClientProxy interface {
	TestMQAdd(ctx context.Context, req *TestMQAddRequest, opts ...client.Option) (rsp *TestMQAddResponse, err error) // @alias=/demo/mq/add
}

MQClientProxy defines service client proxy

type MQClientProxyImpl

type MQClientProxyImpl struct {
	// contains filtered or unexported fields
}

func (*MQClientProxyImpl) TestMQAdd

func (c *MQClientProxyImpl) TestMQAdd(ctx context.Context, req *TestMQAddRequest, opts ...client.Option) (*TestMQAddResponse, error)

type MQService

type MQService interface {
	TestMQAdd(ctx context.Context, req *TestMQAddRequest) (*TestMQAddResponse, error) // @alias=/demo/mq/add
}

MQService defines service.

type TestMQAddRequest

type TestMQAddRequest struct {
	Metadata *common.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Count    int32            `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	Type     string           `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"` // json 或 string
	// contains filtered or unexported fields
}

func (*TestMQAddRequest) Descriptor

func (*TestMQAddRequest) Descriptor() ([]byte, []int)

Deprecated: Use TestMQAddRequest.ProtoReflect.Descriptor instead.

func (*TestMQAddRequest) GetCount

func (x *TestMQAddRequest) GetCount() int32

func (*TestMQAddRequest) GetMetadata

func (x *TestMQAddRequest) GetMetadata() *common.Metadata

func (*TestMQAddRequest) GetType

func (x *TestMQAddRequest) GetType() string

func (*TestMQAddRequest) ProtoMessage

func (*TestMQAddRequest) ProtoMessage()

func (*TestMQAddRequest) ProtoReflect

func (x *TestMQAddRequest) ProtoReflect() protoreflect.Message

func (*TestMQAddRequest) Reset

func (x *TestMQAddRequest) Reset()

func (*TestMQAddRequest) String

func (x *TestMQAddRequest) String() string

type TestMQAddResponse

type TestMQAddResponse struct {
	ErrCode int32  `protobuf:"varint,1,opt,name=err_code,json=errCode,proto3" json:"err_code"`
	ErrMsg  string `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	// contains filtered or unexported fields
}

func (*TestMQAddResponse) Descriptor

func (*TestMQAddResponse) Descriptor() ([]byte, []int)

Deprecated: Use TestMQAddResponse.ProtoReflect.Descriptor instead.

func (*TestMQAddResponse) GetErrCode

func (x *TestMQAddResponse) GetErrCode() int32

func (*TestMQAddResponse) GetErrMsg

func (x *TestMQAddResponse) GetErrMsg() string

func (*TestMQAddResponse) ProtoMessage

func (*TestMQAddResponse) ProtoMessage()

func (*TestMQAddResponse) ProtoReflect

func (x *TestMQAddResponse) ProtoReflect() protoreflect.Message

func (*TestMQAddResponse) Reset

func (x *TestMQAddResponse) Reset()

func (*TestMQAddResponse) String

func (x *TestMQAddResponse) String() string

type UnimplementedMQ

type UnimplementedMQ struct{}

func (*UnimplementedMQ) TestMQAdd

func (s *UnimplementedMQ) TestMQAdd(ctx context.Context, req *TestMQAddRequest) (*TestMQAddResponse, error)