mq

Documentation

Index

• Variables
• func RegisterMQServer(s *grpc.Server, srv MQServer)
• type MQClient
  • func NewMQClient(cc grpc.ClientConnInterface) MQClient
• type MQServer
• type MQ_SubClient
• type MQ_SubServer
• type PubRequest
  • func (*PubRequest) Descriptor() ([]byte, []int)
  • func (x *PubRequest) GetPayload() []byte
  • func (x *PubRequest) GetTopic() string
  • func (*PubRequest) ProtoMessage()
  • func (x *PubRequest) ProtoReflect() protoreflect.Message
  • func (x *PubRequest) Reset()
  • func (x *PubRequest) String() string
• type PubResponse
  • func (*PubResponse) Descriptor() ([]byte, []int)
  • func (*PubResponse) ProtoMessage()
  • func (x *PubResponse) ProtoReflect() protoreflect.Message
  • func (x *PubResponse) Reset()
  • func (x *PubResponse) String() string
• type SubRequest
  • func (*SubRequest) Descriptor() ([]byte, []int)
  • func (x *SubRequest) GetTopic() string
  • func (*SubRequest) ProtoMessage()
  • func (x *SubRequest) ProtoReflect() protoreflect.Message
  • func (x *SubRequest) Reset()
  • func (x *SubRequest) String() string
• type SubResponse
  • func (*SubResponse) Descriptor() ([]byte, []int)
  • func (x *SubResponse) GetPayload() []byte
  • func (*SubResponse) ProtoMessage()
  • func (x *SubResponse) ProtoReflect() protoreflect.Message
  • func (x *SubResponse) Reset()
  • func (x *SubResponse) String() string
• type UnimplementedMQServer
  • func (*UnimplementedMQServer) Pub(context.Context, *PubRequest) (*PubResponse, error)
  • func (*UnimplementedMQServer) Sub(*SubRequest, MQ_SubServer) error

Variables

var File_proto_mq_proto protoreflect.FileDescriptor

Functions

func RegisterMQServer

func RegisterMQServer(s *grpc.Server, srv MQServer)

Types

type MQClient

type MQClient interface {
	Pub(ctx context.Context, in *PubRequest, opts ...grpc.CallOption) (*PubResponse, error)
	Sub(ctx context.Context, in *SubRequest, opts ...grpc.CallOption) (MQ_SubClient, error)
}

MQClient is the client API for MQ service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMQClient

func NewMQClient(cc grpc.ClientConnInterface) MQClient

type MQServer

type MQServer interface {
	Pub(context.Context, *PubRequest) (*PubResponse, error)
	Sub(*SubRequest, MQ_SubServer) error
}

MQServer is the server API for MQ service.

type MQ_SubClient

type MQ_SubClient interface {
	Recv() (*SubResponse, error)
	grpc.ClientStream
}

type MQ_SubServer

type MQ_SubServer interface {
	Send(*SubResponse) error
	grpc.ServerStream
}

type PubRequest

type PubRequest struct {
	Topic   string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*PubRequest) Descriptor

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

Deprecated: Use PubRequest.ProtoReflect.Descriptor instead.

func (*PubRequest) GetPayload

func (x *PubRequest) GetPayload() []byte

func (*PubRequest) GetTopic

func (x *PubRequest) GetTopic() string

func (*PubRequest) ProtoMessage

func (*PubRequest) ProtoMessage()

func (*PubRequest) ProtoReflect

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

func (*PubRequest) Reset

func (x *PubRequest) Reset()

func (*PubRequest) String

func (x *PubRequest) String() string

type PubResponse

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

func (*PubResponse) Descriptor

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

Deprecated: Use PubResponse.ProtoReflect.Descriptor instead.

func (*PubResponse) ProtoMessage

func (*PubResponse) ProtoMessage()

func (*PubResponse) ProtoReflect

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

func (*PubResponse) Reset

func (x *PubResponse) Reset()

func (*PubResponse) String

func (x *PubResponse) String() string

type SubRequest

type SubRequest struct {
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

func (*SubRequest) Descriptor

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

Deprecated: Use SubRequest.ProtoReflect.Descriptor instead.

func (*SubRequest) GetTopic

func (x *SubRequest) GetTopic() string

func (*SubRequest) ProtoMessage

func (*SubRequest) ProtoMessage()

func (*SubRequest) ProtoReflect

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

func (*SubRequest) Reset

func (x *SubRequest) Reset()

func (*SubRequest) String

func (x *SubRequest) String() string

type SubResponse

type SubResponse struct {
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*SubResponse) Descriptor

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

Deprecated: Use SubResponse.ProtoReflect.Descriptor instead.

func (*SubResponse) GetPayload

func (x *SubResponse) GetPayload() []byte

func (*SubResponse) ProtoMessage

func (*SubResponse) ProtoMessage()

func (*SubResponse) ProtoReflect

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

func (*SubResponse) Reset

func (x *SubResponse) Reset()

func (*SubResponse) String

func (x *SubResponse) String() string

type UnimplementedMQServer

type UnimplementedMQServer struct {
}

UnimplementedMQServer can be embedded to have forward compatible implementations.

func (*UnimplementedMQServer) Pub

func (*UnimplementedMQServer) Pub(context.Context, *PubRequest) (*PubResponse, error)

func (*UnimplementedMQServer) Sub

func (*UnimplementedMQServer) Sub(*SubRequest, MQ_SubServer) error