mq

Documentation

Index

• Constants
• type Broker
• type BrokerImpl
  • func NewBroker() *BrokerImpl
• type Client
  • func NewClient() *Client
  • func (c *Client) Close()
  • func (c *Client) GetPayLoad(sub <-chan interface{}) interface{}
  • func (c *Client) Publish(topic string, msg interface{}) error
  • func (c *Client) SetConditions(capacity int)
  • func (c *Client) Subscribe(topic string) (<-chan interface{}, error)
  • func (c *Client) Unsubscribe(topic string, sub <-chan interface{}) error

Constants

const (
	BrokerClosed = "broker closed"
)

Types

type Broker

type Broker interface {
	// contains filtered or unexported methods
}

type BrokerImpl

type BrokerImpl struct {
	sync.RWMutex // 同步锁
	// contains filtered or unexported fields
}

func NewBroker

func NewBroker() *BrokerImpl

type Client

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

func NewClient

func NewClient() *Client

func (*Client) Close

func (c *Client) Close()

func (*Client) GetPayLoad

func (c *Client) GetPayLoad(sub <-chan interface{}) interface{}

func (*Client) Publish

func (c *Client) Publish(topic string, msg interface{}) error

func (*Client) SetConditions

func (c *Client) SetConditions(capacity int)

func (*Client) Subscribe

func (c *Client) Subscribe(topic string) (<-chan interface{}, error)

func (*Client) Unsubscribe

func (c *Client) Unsubscribe(topic string, sub <-chan interface{}) error