pulsarsdk

Documentation

Index

• func Closed()
• func GetSrcConsumer(con *Consumer) pulsar.Consumer
• func Init(option pulsar.ClientOptions, subscribePoolSize int) (err error)
• func SubscribeMsg(ctx context.Context, topic string, callBack SubscribeCallBack)
• type Client
  • func GetClient() *Client
• type Consumer
  • func NewConsumer(topic string) (con *Consumer, err error)
• type Producer
  • func NewProducer(topic string, sendTimeout int) (prod *Producer, err error)
  • func (p *Producer) ProductMsg(ctx context.Context, msg []byte, callBack ProductCallBack)
• type ProductCallBack
• type SubscribeCallBack

Functions

func Closed

func Closed()

func GetSrcConsumer

func GetSrcConsumer(con *Consumer) pulsar.Consumer

func Init

func Init(option pulsar.ClientOptions, subscribePoolSize int) (err error)

func SubscribeMsg

func SubscribeMsg(ctx context.Context, topic string, callBack SubscribeCallBack)

Types

type Client

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

func GetClient

func GetClient() *Client

type Consumer

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

func NewConsumer

func NewConsumer(topic string) (con *Consumer, err error)

type Producer

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

func NewProducer

func NewProducer(topic string, sendTimeout int) (prod *Producer, err error)

func (*Producer) ProductMsg

func (p *Producer) ProductMsg(ctx context.Context, msg []byte, callBack ProductCallBack)

生产消息

type ProductCallBack

type ProductCallBack func(id pulsar.MessageID, message *pulsar.ProducerMessage, callBackErr error)

type SubscribeCallBack

type SubscribeCallBack func(message pulsar.Message, err error)