pulsar

README

pulsar

盘古框架Pulsar集成，提供最简单的API以及丰富的功能，包括

• 更友好的API
• 序列化和反序列化
  • JSON
  • Protobuf
  • Msgpack
  • XML
• 一切皆可配置
• 多集群

感谢

Documentation

Index

• func Default() *optionLabel
• func Label(label string) *optionLabel
• func Property(key string, value string) *optionProperty
• type Client
  • func (c *Client) Producer(topic string, opts ...producerOption) (producer *Producer, err error)
  • func (c *Client) Subscribe(topic string, opts ...subscribeOption) (consumer *Consumer, err error)
• type Consumer
• type Producer

Functions

func Default

func Default() *optionLabel

Default 配置使用默认客户端

func Label

func Label(label string) *optionLabel

Label 配置使用哪一个客户端

func Property

func Property(key string, value string) *optionProperty

Property 属性

Types

type Client

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

Client 客户端

func (*Client) Producer

func (c *Client) Producer(topic string, opts ...producerOption) (producer *Producer, err error)

func (*Client) Subscribe

func (c *Client) Subscribe(topic string, opts ...subscribeOption) (consumer *Consumer, err error)

type Consumer

type Consumer struct {
	pulsar.Consumer
}

Consumer 消费者封装

type Producer

type Producer struct {
	pulsar.Producer
}

Producer 生产者