pubsub

Documentation

Index

• type Listener
  • func NewListener(ctx context.Context, logger *zap.Logger, pubsubProject string, ...) (*Listener, error)
  • func (l *Listener) Start() error
• type Message

Types

type Listener

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

Listener is a pubsub server that pipes messages off to its events.Processor

func NewListener

func NewListener(ctx context.Context, logger *zap.Logger, pubsubProject string, subscriptionName string,
	credentials []byte, clusterData *core.ClusterData, processor *events.Processor) (*Listener, error)

NewListener is a constructor for Listener with field validation

func (*Listener) Start

func (l *Listener) Start() error

Start starts up the pubsub server and pipes incoming messages to the Listener's events.Processor

type Message

type Message struct {
	Digest string `json:"digest"`
	Tag    string `json:"tag"`
}

Message json deserialization target for pubsub messages