emqcli

Documentation

Index

• Variables
• type Conn
  • func NewConn(addr string, msgChan chan *Message, delegate Delegate) *Conn
  • func (c *Conn) Command(cmd *command.Command) error
  • func (c *Conn) Connect() error
  • func (c *Conn) Stop()
• type Consumer
  • func NewConsumer(topic, channel string) *Consumer
  • func (co *Consumer) AddHandler(handler Handler)
  • func (co *Consumer) ConnectToEMQD(addr string) error
  • func (co *Consumer) ConnectToLookupd(addr string) error
  • func (co *Consumer) Existing() bool
  • func (co *Consumer) GetConns() []*Conn
  • func (co *Consumer) OnClose(conn *Conn)
  • func (co *Consumer) OnRequeue(msg *Message)
  • func (co *Consumer) Stop()
• type Delegate
• type Handler
• type Message
  • func (m *Message) Requeue()
• type Producer
  • func NewProducer(addr string) (*Producer, error)
  • func (p *Producer) OnClose(conn *Conn)
  • func (p *Producer) OnRequeue(msg *Message)
  • func (p *Producer) Publish(topic string, body string) error

Variables

var ErrAlreadyConnected = errors.New("already connected")

Types

type Conn

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

func NewConn

func NewConn(addr string, msgChan chan *Message, delegate Delegate) *Conn

func (*Conn) Command

func (c *Conn) Command(cmd *command.Command) error

func (*Conn) Connect

func (c *Conn) Connect() error

func (*Conn) Stop

func (c *Conn) Stop()

主动停止

type Consumer

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

func NewConsumer

func NewConsumer(topic, channel string) *Consumer

func (*Consumer) AddHandler

func (co *Consumer) AddHandler(handler Handler)

func (*Consumer) ConnectToEMQD

func (co *Consumer) ConnectToEMQD(addr string) error

func (*Consumer) ConnectToLookupd

func (co *Consumer) ConnectToLookupd(addr string) error

func (*Consumer) Existing

func (co *Consumer) Existing() bool

func (*Consumer) GetConns

func (co *Consumer) GetConns() []*Conn

func (*Consumer) OnClose

func (co *Consumer) OnClose(conn *Conn)

func (*Consumer) OnRequeue

func (co *Consumer) OnRequeue(msg *Message)

func (*Consumer) Stop

func (co *Consumer) Stop()

type Delegate

type Delegate interface {
	OnClose(*Conn)

	OnRequeue(*Message)
}

type Handler

type Handler interface {
	HandleMessage(message *Message) error
}

type Message

type Message struct {
	*protocol.Message
	// contains filtered or unexported fields
}

func (*Message) Requeue

func (m *Message) Requeue()

type Producer

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

func NewProducer

func NewProducer(addr string) (*Producer, error)

func (*Producer) OnClose

func (p *Producer) OnClose(conn *Conn)

func (*Producer) OnRequeue

func (p *Producer) OnRequeue(msg *Message)

func (*Producer) Publish

func (p *Producer) Publish(topic string, body string) error