Documentation
¶
Index ¶
- func LogDebug(args ...interface{})
- func LogDebugf(format string, args ...interface{})
- func LogError(args ...interface{})
- func LogErrorf(format string, args ...interface{})
- func LogFatal(args ...interface{})
- func LogFatalf(format string, args ...interface{})
- func LogInfo(args ...interface{})
- func LogInfof(format string, args ...interface{})
- func LogWarn(args ...interface{})
- func LogWarnf(format string, args ...interface{})
- func NewBroker(opts ...broker.Option) broker.Broker
- type ConsumerMessageCarrier
- type ProducerMessageCarrier
- type Publication
- type Subscriber
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type ConsumerMessageCarrier ¶
type ConsumerMessageCarrier struct {
// contains filtered or unexported fields
}
func NewConsumerMessageCarrier ¶
func NewConsumerMessageCarrier(msg *aliyun.ConsumeMessageEntry) ConsumerMessageCarrier
func (ConsumerMessageCarrier) Get ¶
func (c ConsumerMessageCarrier) Get(key string) string
func (ConsumerMessageCarrier) Keys ¶
func (c ConsumerMessageCarrier) Keys() []string
func (ConsumerMessageCarrier) Set ¶
func (c ConsumerMessageCarrier) Set(key, val string)
type ProducerMessageCarrier ¶
type ProducerMessageCarrier struct {
// contains filtered or unexported fields
}
func NewProducerMessageCarrier ¶
func NewProducerMessageCarrier(msg *aliyun.PublishMessageRequest) ProducerMessageCarrier
func (ProducerMessageCarrier) Get ¶
func (c ProducerMessageCarrier) Get(key string) string
func (ProducerMessageCarrier) Keys ¶
func (c ProducerMessageCarrier) Keys() []string
func (ProducerMessageCarrier) Set ¶
func (c ProducerMessageCarrier) Set(key, val string)
type Publication ¶
type Publication struct {
// contains filtered or unexported fields
}
func (*Publication) Ack ¶
func (p *Publication) Ack() error
func (*Publication) Error ¶
func (p *Publication) Error() error
func (*Publication) Message ¶
func (p *Publication) Message() *broker.Message
func (*Publication) RawMessage ¶
func (p *Publication) RawMessage() interface{}
func (*Publication) Topic ¶
func (p *Publication) Topic() string
type Subscriber ¶
func (*Subscriber) Options ¶
func (s *Subscriber) Options() broker.SubscribeOptions
func (*Subscriber) Topic ¶
func (s *Subscriber) Topic() string
func (*Subscriber) Unsubscribe ¶
func (s *Subscriber) Unsubscribe(removeFromManager bool) error
Source Files
Click to show internal directories.
Click to hide internal directories.