domains

Documentation

Index

• Constants
• type Broker
  • func NewBroker(lenOfMessageQueue int, defaultTopic string) *Broker
  • func (b *Broker) CreateTopic(topic string) error
  • func (b *Broker) DeleteTopic(topicName string)
  • func (b *Broker) PerformanceStat() string
  • func (b *Broker) Producer(topicName string, message []byte) error
  • func (b *Broker) Subscribe(url string, topic string) error
  • func (b *Broker) Unsubscribe(url string, topic string)

Constants

const EmptyQueue = -1

Types

type Broker

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

func NewBroker

func NewBroker(lenOfMessageQueue int, defaultTopic string) *Broker

func (*Broker) CreateTopic

func (b *Broker) CreateTopic(topic string) error

func (*Broker) DeleteTopic

func (b *Broker) DeleteTopic(topicName string)

func (*Broker) PerformanceStat

func (b *Broker) PerformanceStat() string

func (*Broker) Producer

func (b *Broker) Producer(topicName string, message []byte) error

func (*Broker) Subscribe

func (b *Broker) Subscribe(url string, topic string) error

func (*Broker) Unsubscribe

func (b *Broker) Unsubscribe(url string, topic string)