mq

Documentation

Overview

Package mq is a generated protocol buffer package.

It is generated from these files:

github.com/asim/mq/proto/mq.proto

It has these top-level messages:

PubRequest
PubResponse
SubRequest
SubResponse

Index

• func RegisterMQServer(s *grpc.Server, srv MQServer)
• type MQClient
  • func NewMQClient(cc *grpc.ClientConn) MQClient
• type MQServer
• type MQ_SubClient
• type MQ_SubServer
• type PubRequest
  • func (*PubRequest) Descriptor() ([]byte, []int)
  • func (*PubRequest) ProtoMessage()
  • func (m *PubRequest) Reset()
  • func (m *PubRequest) String() string
• type PubResponse
  • func (*PubResponse) Descriptor() ([]byte, []int)
  • func (*PubResponse) ProtoMessage()
  • func (m *PubResponse) Reset()
  • func (m *PubResponse) String() string
• type SubRequest
  • func (*SubRequest) Descriptor() ([]byte, []int)
  • func (*SubRequest) ProtoMessage()
  • func (m *SubRequest) Reset()
  • func (m *SubRequest) String() string
• type SubResponse
  • func (*SubResponse) Descriptor() ([]byte, []int)
  • func (*SubResponse) ProtoMessage()
  • func (m *SubResponse) Reset()
  • func (m *SubResponse) String() string

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)
}

func NewMQClient

func NewMQClient(cc *grpc.ClientConn) MQClient

type MQServer

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

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" json:"topic,omitempty"`
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
}

func (*PubRequest) Descriptor

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

func (*PubRequest) ProtoMessage

func (*PubRequest) ProtoMessage()

func (*PubRequest) Reset

func (m *PubRequest) Reset()

func (*PubRequest) String

func (m *PubRequest) String() string

type PubResponse

type PubResponse struct {
}

func (*PubResponse) Descriptor

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

func (*PubResponse) ProtoMessage

func (*PubResponse) ProtoMessage()

func (*PubResponse) Reset

func (m *PubResponse) Reset()

func (*PubResponse) String

func (m *PubResponse) String() string

type SubRequest

type SubRequest struct {
	Topic string `protobuf:"bytes,1,opt,name=topic" json:"topic,omitempty"`
}

func (*SubRequest) Descriptor

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

func (*SubRequest) ProtoMessage

func (*SubRequest) ProtoMessage()

func (*SubRequest) Reset

func (m *SubRequest) Reset()

func (*SubRequest) String

func (m *SubRequest) String() string

type SubResponse

type SubResponse struct {
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
}

func (*SubResponse) Descriptor

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

func (*SubResponse) ProtoMessage

func (*SubResponse) ProtoMessage()

func (*SubResponse) Reset

func (m *SubResponse) Reset()

func (*SubResponse) String

func (m *SubResponse) String() string