rpc

Documentation

Index

• type BrokerRpcServer
  • func (b *BrokerRpcServer) GetMessages(req *models.GetMessageRequest) ([]*models.Message, error)
  • func (b *BrokerRpcServer) PublishMessage(msg *models.Message) error
  • func (b *BrokerRpcServer) Start() error
• type Server
  • func NewRpcServer(br *BrokerRpcServer) *Server
  • func (r *Server) GetMessages(req *models.GetMessageRequest, reply *models.MessageList) error
  • func (r *Server) Publish(msg *models.Message, reply *string) error
  • func (r *Server) Register() error

Types

type BrokerRpcServer

type BrokerRpcServer struct {
	Config            *models.BrokerConfig
	Storage           storage.Storage
	SubscriberOffsets models.SubscriberOffsets
	Mutex             sync.Mutex
	Server            *Server
}

func (*BrokerRpcServer) GetMessages

func (b *BrokerRpcServer) GetMessages(req *models.GetMessageRequest) ([]*models.Message, error)

func (*BrokerRpcServer) PublishMessage

func (b *BrokerRpcServer) PublishMessage(msg *models.Message) error

PublishMessage publishes a message to a topic

func (*BrokerRpcServer) Start

func (b *BrokerRpcServer) Start() error

Start runs the broker server

type Server

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

func NewRpcServer

func NewRpcServer(br *BrokerRpcServer) *Server

func (*Server) GetMessages

func (r *Server) GetMessages(req *models.GetMessageRequest, reply *models.MessageList) error

func (*Server) Publish

func (r *Server) Publish(msg *models.Message, reply *string) error

func (*Server) Register

func (r *Server) Register() error