bus

Documentation

Index

• func TopicMatch(topic []byte, topicFilter []byte) bool
• type Bus
  • func NewBus() Bus
• type RPSCounter
  • func (c *RPSCounter) Inc()
  • func (c *RPSCounter) Stop()
  • func (c *RPSCounter) Value() float64
• type StatItem
• type Statistic
  • func NewStatistic() *Statistic
• type Stats
  • func (s Stats) Len() int
  • func (s Stats) Less(i, j int) bool
  • func (s Stats) Swap(i, j int)
• type Topic
  • func NewTopic(name string) *Topic
  • func (t *Topic) Close()
  • func (t *Topic) Publish(args ...interface{})
  • func (t *Topic) Stat() *StatItem
  • func (t *Topic) Subscribe(fn interface{}, options ...interface{}) error
  • func (t *Topic) Unsubscribe(fn interface{}) (empty bool, err error)

Functions

func TopicMatch

func TopicMatch(topic []byte, topicFilter []byte) bool

TopicMatch 返回topic和topic filter是否

TopicMatch returns whether the topic and topic filter is matched.

Types

type Bus

type Bus interface {
	// Publish publishes arguments to the given topic subscribers
	// Publish block only when the buffer of one of the subscribers is full.
	Publish(topic string, args ...interface{})
	// CloseTopic unsubscribe all subscribers from given topic
	CloseTopic(topic string)
	// Subscribe subscribes to the given topic
	Subscribe(topic string, fn interface{}, options ...interface{}) error
	// Unsubscribe handler from the given topic
	Unsubscribe(topic string, fn interface{}) error
	// Stat ...
	Stat(ctx context.Context, limit, offset int64, orderBy, sort string) (stats Stats, total int64, err error)
	// Purge ...
	Purge()
}

Bus implements publish/subscribe messaging paradigm

func NewBus

func NewBus() Bus

NewBus ...

type RPSCounter

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

func (*RPSCounter) Inc

func (c *RPSCounter) Inc()

func (*RPSCounter) Stop

func (c *RPSCounter) Stop()

func (*RPSCounter) Value

func (c *RPSCounter) Value() float64

type StatItem

type StatItem struct {
	Topic       string
	Subscribers int
	Min         time.Duration
	Max         time.Duration
	Avg         time.Duration
	Rps         float64
}

StatItem ...

type Statistic

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

func NewStatistic

func NewStatistic() *Statistic

type Stats

type Stats []*StatItem

Stats ...

func (Stats) Len

func (s Stats) Len() int

func (Stats) Less

func (s Stats) Less(i, j int) bool

func (Stats) Swap

func (s Stats) Swap(i, j int)

type Topic

type Topic struct {
	*Statistic
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewTopic

func NewTopic(name string) *Topic

func (*Topic) Close

func (t *Topic) Close()

func (*Topic) Publish

func (t *Topic) Publish(args ...interface{})

func (*Topic) Stat

func (t *Topic) Stat() *StatItem

func (*Topic) Subscribe

func (t *Topic) Subscribe(fn interface{}, options ...interface{}) error

func (*Topic) Unsubscribe

func (t *Topic) Unsubscribe(fn interface{}) (empty bool, err error)