events

Documentation

Index

• type Event
  • func NewEvent(logger *zap.Logger, digest string, tag string) *Event
• type Message
• type Processor
  • func NewProcessor(ctx context.Context, logger *zap.Logger, db *core.DB, creds []byte, ...) *Processor
  • func (p Processor) ProcessMessage(event *Event)
  • func (p Processor) ReleaseApp(event *Event, app *model.TuberApp)
  • func (p Processor) StartRelease(event *Event, app *model.TuberApp)

Types

type Event

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

func NewEvent

func NewEvent(logger *zap.Logger, digest string, tag string) *Event

type Message

type Message struct {
	AppName   string `json:"appName"`
	CommitSha string `json:"commitSha"`
	Repo      string `json:"repo"`
	Branch    string `json:"branch"`
}

type Processor

type Processor struct {
	ClusterData *core.ClusterData
	// contains filtered or unexported fields
}

Processor processes events

func NewProcessor

func NewProcessor(ctx context.Context, logger *zap.Logger, db *core.DB, creds []byte, clusterData *core.ClusterData, reviewAppsEnabled bool, slackClient *slack.Client, sentryBearerToken string, tuberEventsProject string, tuberEventsTopic string) *Processor

NewProcessor constructs a Processor

func (Processor) ProcessMessage

func (p Processor) ProcessMessage(event *Event)

ProcessMessage receives a pubsub message, filters it against TuberApps, and triggers releases for matching apps

func (Processor) ReleaseApp

func (p Processor) ReleaseApp(event *Event, app *model.TuberApp)

func (Processor) StartRelease

func (p Processor) StartRelease(event *Event, app *model.TuberApp)