services

Documentation

Index

• type BrokerService
  • func NewBrokerService(config *models.BrokerConfig) *BrokerService
  • func (b *BrokerService) GetMessages(request *models.GetMessageRequest, reply *models.MessageList) error
  • func (b *BrokerService) Publish(msg *models.Message, reply *string) error
  • func (b *BrokerService) Start()

Types

type BrokerService

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

func NewBrokerService

func NewBrokerService(config *models.BrokerConfig) *BrokerService

func (*BrokerService) GetMessages

func (b *BrokerService) GetMessages(request *models.GetMessageRequest, reply *models.MessageList) error

GetMessages retrieves messages for subscriber

func (*BrokerService) Publish

func (b *BrokerService) Publish(msg *models.Message, reply *string) error

Publish stores message in a storage

func (*BrokerService) Start

func (b *BrokerService) Start()