pulsar

Documentation

Index

• type Pulsar
  • func New(url, topicPrefix string, token string) (*Pulsar, error)
  • func (s *Pulsar) SendDelayMsg(ctx context.Context, topic string, orderingKey string, data []byte, ...) error
  • func (s *Pulsar) SendMsg(ctx context.Context, topic string, orderingKey string, data []byte) error
  • func (s *Pulsar) Stop() error

Types

type Pulsar

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

Pulsar is a type of connector

func New

func New(url, topicPrefix string, token string) (*Pulsar, error)

New creates a new pulsar connector

func (*Pulsar) SendDelayMsg

func (s *Pulsar) SendDelayMsg(ctx context.Context, topic string, orderingKey string, data []byte, delay time.Duration) error

SendDelayMsg is the stores that send delay events

func (*Pulsar) SendMsg

func (s *Pulsar) SendMsg(ctx context.Context, topic string, orderingKey string, data []byte) error

SendMsg is the stores that send real-time events

func (*Pulsar) Stop

func (s *Pulsar) Stop() error

Stop stops the pulsar connector gracefully.