pubsub

Documentation

Index

• type Listener
  • func (l *Listener) Boot(ctx context.Context, channel channel.Channel, ...) error
  • func (l *Listener) Listen() error
  • func (l *Listener) SetPubsubClient(client *pubsub.Client)
  • func (l *Listener) Stop() error

Types

type Listener

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

func (*Listener) Boot

func (l *Listener) Boot(ctx context.Context, channel channel.Channel, prioritizer *prioritizer.Prioritizer) error

func (*Listener) Listen

func (l *Listener) Listen() error

func (*Listener) SetPubsubClient

func (l *Listener) SetPubsubClient(client *pubsub.Client)

func (*Listener) Stop

func (l *Listener) Stop() error