pulsar

Documentation

Index

• Constants
• func NewClient(url string, connectionTimeoutSecond int64, operationTimeoutSecond int64, ...) mq.IClient
• type Message
• type PulsarClient
  • func (pc *PulsarClient) Close()
  • func (pc *PulsarClient) Send(topic string, msg string) error
  • func (pc *PulsarClient) SendAsync(topic string, msg string) error
  • func (pc *PulsarClient) SendDelay(topic string, msg string, delay time.Duration) error
  • func (pc *PulsarClient) SendDelayAsync(topic string, msg string, delay time.Duration) error
  • func (pc *PulsarClient) SendDelayAt(topic string, msg string, delayAt time.Time) error
  • func (pc *PulsarClient) SendDelayAtAsync(topic string, msg string, delayAt time.Time) error
  • func (pc *PulsarClient) Subscribe(opts mq.ConsumerOptions)
  • func (pc *PulsarClient) Subscribes(opts ...mq.ConsumerOptions)

Constants

const (
	SERVER_URL_KEY         = "pulsar.service-url"
	CONNECTION_TIMEOUT_KEY = "pulsar.connectionTimeout"
	OPERATION_TIMEOUT_KEY  = "pulsar.operationTimeout"
)

const (
	MAX_RETRY_TIMES = 50
)

Functions

func NewClient

func NewClient(url string, connectionTimeoutSecond int64, operationTimeoutSecond int64, appName string) mq.IClient

Types

type Message

type Message struct {
	Msg pulsar.Message
}

type PulsarClient

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

func (*PulsarClient) Close

func (pc *PulsarClient) Close()

func (*PulsarClient) Send

func (pc *PulsarClient) Send(topic string, msg string) error

func (*PulsarClient) SendAsync

func (pc *PulsarClient) SendAsync(topic string, msg string) error

func (*PulsarClient) SendDelay

func (pc *PulsarClient) SendDelay(topic string, msg string, delay time.Duration) error

func (*PulsarClient) SendDelayAsync

func (pc *PulsarClient) SendDelayAsync(topic string, msg string, delay time.Duration) error

func (*PulsarClient) SendDelayAt

func (pc *PulsarClient) SendDelayAt(topic string, msg string, delayAt time.Time) error

func (*PulsarClient) SendDelayAtAsync

func (pc *PulsarClient) SendDelayAtAsync(topic string, msg string, delayAt time.Time) error

func (*PulsarClient) Subscribe

func (pc *PulsarClient) Subscribe(opts mq.ConsumerOptions)

func (*PulsarClient) Subscribes

func (pc *PulsarClient) Subscribes(opts ...mq.ConsumerOptions)