listener

Documentation

Overview

Package listener listens to Gerrit events.

Index

• type Listener
  • func NewListener(psClient *pubsub.Client, sch scheduler) *Listener
  • func (l *Listener) Run(ctx context.Context)

Types

type Listener

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

Listener fetches and process messages from the subscriptions configured in the settings.

func NewListener

func NewListener(psClient *pubsub.Client, sch scheduler) *Listener

NewListener constructs a Listener.

func (*Listener) Run

func (l *Listener) Run(ctx context.Context)

Run continuously evaluates the listener settings and manages workers for each of the subscriptions configured.