Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
Source Files
Click to show internal directories.
Click to hide internal directories.