aliyun

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
  • func NewConsumerMessageCarrier(msg *aliyun.ConsumeMessageEntry) ConsumerMessageCarrier
  • func (c ConsumerMessageCarrier) Get(key string) string
  • func (c ConsumerMessageCarrier) Keys() []string
  • func (c ConsumerMessageCarrier) Set(key, val string)
• type ProducerMessageCarrier
  • func NewProducerMessageCarrier(msg *aliyun.PublishMessageRequest) ProducerMessageCarrier
  • func (c ProducerMessageCarrier) Get(key string) string
  • func (c ProducerMessageCarrier) Keys() []string
  • func (c ProducerMessageCarrier) Set(key, val string)
• type Publication
  • func (p *Publication) Ack() error
  • func (p *Publication) Error() error
  • func (p *Publication) Message() *broker.Message
  • func (p *Publication) RawMessage() interface{}
  • func (p *Publication) Topic() string
• type Subscriber
  • func (s *Subscriber) Options() broker.SubscribeOptions
  • func (s *Subscriber) Topic() string
  • func (s *Subscriber) Unsubscribe() error

Functions

func LogDebug

func LogDebug(args ...interface{})

func LogDebugf

func LogDebugf(format string, args ...interface{})

func LogError

func LogError(args ...interface{})

func LogErrorf

func LogErrorf(format string, args ...interface{})

func LogFatal

func LogFatal(args ...interface{})

func LogFatalf

func LogFatalf(format string, args ...interface{})

func LogInfo

func LogInfo(args ...interface{})

func LogInfof

func LogInfof(format string, args ...interface{})

func LogWarn

func LogWarn(args ...interface{})

func LogWarnf

func LogWarnf(format string, args ...interface{})

func NewBroker

func NewBroker(opts ...broker.Option) broker.Broker

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

type Subscriber struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*Subscriber) Options

func (s *Subscriber) Options() broker.SubscribeOptions

func (*Subscriber) Topic

func (s *Subscriber) Topic() string

func (*Subscriber) Unsubscribe

func (s *Subscriber) Unsubscribe() error