Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

pulsar

package module

Go to main page

Versions in this module

v0

v0.1.3

Jun 26, 2024

Changes in this version

+ var ErrClientClosing = errors.New("client is closing connections")

+ var ErrConsumerOfMessageNotFound = errors.New("consumer of message not found")

type ConsumerConfig

+ InitialPositionCallback InitialPositionCallback

+ type InitialPositionCallback func(topic string) (position InitialPosition, StartMessageID []byte, err error)

type Logger

+ Debugf func(format string, args ...interface{})

+ Errorf func(format string, args ...interface{})

v0.1.2

Oct 2, 2021

v0.1.1

Aug 15, 2020

Changes in this version

+ const DefaultNamespace

type Client

+ func (c *Client) Topics(namespace string) ([]*Topic, error)

type Message

+ Topic string

type ProducerConfig

+ BatchSize int

+ BatchTimeout time.Duration

+ QueueCapacity int

+ type Topic struct

+ CompleteName string

+ Domain string

+ LocalName string

+ Namespace string

+ Tenant string

+ func NewTopic(name string) (*Topic, error)

v0.1.0

Jun 2, 2020

Changes in this version

+ const EarliestPosition

+ const ExclusiveSubscription

+ const FailoverSubscription

+ const KeySharedSubscription

+ const LatestPosition

+ const SharedSubscription

+ var ErrNetClosing = errors.New("use of closed network connection")

+ type Client struct

+ func NewClient(serverURL string, opts ...ClientOption) (*Client, error)

+ func (c *Client) Close() error

+ func (c *Client) CloseConsumer(consumerID uint64) error

+ func (c *Client) CloseProducer(producerID uint64) error

+ func (c *Client) Dial(ctx context.Context) error

+ func (c *Client) NewConsumer(ctx context.Context, config ConsumerConfig) (Consumer, error)

+ func (c *Client) NewProducer(ctx context.Context, config ProducerConfig) (*Producer, error)

+ type ClientOption func(*clientConfig)

+ func WithLogger(logger Logger) ClientOption

+ type Consumer interface

+ AckMessage func(*Message) error

+ Close func() error

+ HasNext func() bool

+ LastMessageID func() (*MessageID, error)

+ ReadMessage func(context.Context) (*Message, error)

+ SeekMessage func(*Message) error

+ type ConsumerConfig struct

+ Durable bool

+ ForceTopicCreation bool

+ InitialPosition InitialPosition

+ MessageChannel chan *Message

+ Name string

+ StartMessageID []byte

+ StartMessageIDInclusive bool

+ Subscription string

+ Topic string

+ TopicPattern string

+ TopicPatternDiscoveryInterval int

+ Type SubscriptionType

+ func (config *ConsumerConfig) Validate() error

+ type InitialPosition pb.CommandSubscribe_InitialPosition

+ type Logger interface

+ Printf func(format string, v ...interface{})

+ type Message struct

+ Body []byte

+ ID *MessageID

+ type MessageID pb.MessageIdData

+ func (id *MessageID) Marshal() ([]byte, error)

+ func (id *MessageID) Unmarshal(b []byte) error

+ type Producer struct

+ func (p *Producer) Close() error

+ func (p *Producer) WriteMessage(ctx context.Context, msg []byte) (*MessageID, error)

+ func (p *Producer) WriteMessageAsync(ctx context.Context, msg []byte) error

+ type ProducerConfig struct

+ Name string

+ Topic string

+ func (config *ProducerConfig) Validate() error

+ type SubscriptionType pb.CommandSubscribe_SubType