mq

Documentation

Index

• Variables
• func NewMqEndpoints() []*api.Endpoint
• func RegisterMqHandler(s server.Server, hdlr MqHandler, opts ...server.HandlerOption) error
• type MqHandler
• type MqService
  • func NewMqService(name string, c client.Client) MqService
• type Mq_SubscribeService
• type Mq_SubscribeStream
• type PublishRequest
  • func (*PublishRequest) Descriptor() ([]byte, []int)
  • func (x *PublishRequest) GetMessage() *structpb.Struct
  • func (x *PublishRequest) GetTopic() string
  • func (*PublishRequest) ProtoMessage()
  • func (x *PublishRequest) ProtoReflect() protoreflect.Message
  • func (x *PublishRequest) Reset()
  • func (x *PublishRequest) String() string
• type PublishResponse
  • func (*PublishResponse) Descriptor() ([]byte, []int)
  • func (*PublishResponse) ProtoMessage()
  • func (x *PublishResponse) ProtoReflect() protoreflect.Message
  • func (x *PublishResponse) Reset()
  • func (x *PublishResponse) String() string
• type SubscribeRequest
  • func (*SubscribeRequest) Descriptor() ([]byte, []int)
  • func (x *SubscribeRequest) GetTopic() string
  • func (*SubscribeRequest) ProtoMessage()
  • func (x *SubscribeRequest) ProtoReflect() protoreflect.Message
  • func (x *SubscribeRequest) Reset()
  • func (x *SubscribeRequest) String() string
• type SubscribeResponse
  • func (*SubscribeResponse) Descriptor() ([]byte, []int)
  • func (x *SubscribeResponse) GetMessage() *structpb.Struct
  • func (x *SubscribeResponse) GetTopic() string
  • func (*SubscribeResponse) ProtoMessage()
  • func (x *SubscribeResponse) ProtoReflect() protoreflect.Message
  • func (x *SubscribeResponse) Reset()
  • func (x *SubscribeResponse) String() string

Variables

var File_proto_mq_proto protoreflect.FileDescriptor

Functions

func NewMqEndpoints

func NewMqEndpoints() []*api.Endpoint

func RegisterMqHandler

func RegisterMqHandler(s server.Server, hdlr MqHandler, opts ...server.HandlerOption) error

Types

type MqHandler

type MqHandler interface {
	Publish(context.Context, *PublishRequest, *PublishResponse) error
	Subscribe(context.Context, *SubscribeRequest, Mq_SubscribeStream) error
}

type MqService

type MqService interface {
	Publish(ctx context.Context, in *PublishRequest, opts ...client.CallOption) (*PublishResponse, error)
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...client.CallOption) (Mq_SubscribeService, error)
}

func NewMqService

func NewMqService(name string, c client.Client) MqService

type Mq_SubscribeService

type Mq_SubscribeService interface {
	Context() context.Context
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Recv() (*SubscribeResponse, error)
}

type Mq_SubscribeStream

type Mq_SubscribeStream interface {
	Context() context.Context
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*SubscribeResponse) error
}

type PublishRequest

type PublishRequest struct {

	// The topic to publish to
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// The json message to publish
	Message *structpb.Struct `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

Publish a message. Specify a topic to group messages for a specific topic.

func (*PublishRequest) Descriptor

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

Deprecated: Use PublishRequest.ProtoReflect.Descriptor instead.

func (*PublishRequest) GetMessage

func (x *PublishRequest) GetMessage() *structpb.Struct

func (*PublishRequest) GetTopic

func (x *PublishRequest) GetTopic() string

func (*PublishRequest) ProtoMessage

func (*PublishRequest) ProtoMessage()

func (*PublishRequest) ProtoReflect

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

func (*PublishRequest) Reset

func (x *PublishRequest) Reset()

func (*PublishRequest) String

func (x *PublishRequest) String() string

type PublishResponse

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

func (*PublishResponse) Descriptor

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

Deprecated: Use PublishResponse.ProtoReflect.Descriptor instead.

func (*PublishResponse) ProtoMessage

func (*PublishResponse) ProtoMessage()

func (*PublishResponse) ProtoReflect

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

func (*PublishResponse) Reset

func (x *PublishResponse) Reset()

func (*PublishResponse) String

func (x *PublishResponse) String() string

type SubscribeRequest

type SubscribeRequest struct {

	// The topic to subscribe to
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

Subscribe to messages for a given topic.

func (*SubscribeRequest) Descriptor

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

Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.

func (*SubscribeRequest) GetTopic

func (x *SubscribeRequest) GetTopic() string

func (*SubscribeRequest) ProtoMessage

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) ProtoReflect

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

func (*SubscribeRequest) Reset

func (x *SubscribeRequest) Reset()

func (*SubscribeRequest) String

func (x *SubscribeRequest) String() string

type SubscribeResponse

type SubscribeResponse struct {

	// The topic subscribed to
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// The next json message on the topic
	Message *structpb.Struct `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeResponse) Descriptor

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

Deprecated: Use SubscribeResponse.ProtoReflect.Descriptor instead.

func (*SubscribeResponse) GetMessage

func (x *SubscribeResponse) GetMessage() *structpb.Struct

func (*SubscribeResponse) GetTopic

func (x *SubscribeResponse) GetTopic() string

func (*SubscribeResponse) ProtoMessage

func (*SubscribeResponse) ProtoMessage()

func (*SubscribeResponse) ProtoReflect

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

func (*SubscribeResponse) Reset

func (x *SubscribeResponse) Reset()

func (*SubscribeResponse) String

func (x *SubscribeResponse) String() string