emitter

Documentation

Index

• func NewJetStream(url string, creds string, nKeyFile string) *jetStream
• type DataFunc
• type EmitterPubSub
  • func NewEmitterPubSub(_ context.Context, serviceURL string) *EmitterPubSub
  • func (e *EmitterPubSub) Publish(ctx context.Context, data []byte) error
  • func (e *EmitterPubSub) Subscribe(ctx context.Context) (*subscriber, error)

Functions

func NewJetStream

func NewJetStream(url string, creds string, nKeyFile string) *jetStream

NewJetStream initializes jetStream to connect to NATS

Types

type DataFunc

type DataFunc func(*pubsub.Message) error

DataFunc determines how the data return from the pubsub is transformed based on implementation per module

type EmitterPubSub

type EmitterPubSub struct {
	ServiceURL string
}

EmitterPubSub stores the serviceURL such that the topic and subscription can be reopened

func NewEmitterPubSub

func NewEmitterPubSub(_ context.Context, serviceURL string) *EmitterPubSub

NewEmitterPubSub initializes the blob store based on the url. utilizing gocloud (https://gocloud.dev/howto/pubsub/publish/) various pubsub providers such as sqs, google pubsub, azure service bus, NATS and Kafka can be used. Authentication is setup via environment variables. Please refer to for full documentation https://gocloud.dev/howto/pubsub/

func (*EmitterPubSub) Publish

func (e *EmitterPubSub) Publish(ctx context.Context, data []byte) error

Publish publishes the data onto the pubsub stream for consumption by upstream services

func (*EmitterPubSub) Subscribe

func (e *EmitterPubSub) Subscribe(ctx context.Context) (*subscriber, error)

Subscribe subscribes to the pubsub stream and receives events as they flow through