pulsar

package

v1.10.0-rc.8 Latest Latest Go to latest Published: Feb 14, 2023 License: Apache-2.0 Imports: 12 Imported by: 4

Details

This section is empty.

This section is empty.

func NewPulsar(l logger.Logger) pubsub.PubSub

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

func (p *Pulsar) Close() error

func (p *Pulsar) Features() []pubsub.Feature

func (p *Pulsar) Init(metadata pubsub.Metadata) error

func (p *Pulsar) Publish(ctx context.Context, req *pubsub.PublishRequest) error

func (p *Pulsar) Subscribe(ctx context.Context, req pubsub.SubscribeRequest, handler pubsub.Handler) error