queue

Documentation

Index

• Constants
• func NewGenerator() *uuidGenerator
• func NewPubSubSubscriber(logger lager.Logger, subscription *pubsub.Subscription, ...) ifrit.Runner
• func NewPushEventProcessor(changeFetcher ChangeFetcher, emitter metrics.Emitter, clock clock.Clock, ...) *pushEventProcessor
• type ChangeFetcher
• type Enqueuer
  • func NewPubSubEnqueuer(logger lager.Logger, topic Topic, signer crypto.Signer) Enqueuer
• type Plan
• type PubSubProcessor
  • func NewSignatureCheck(verify crypto.Verifier, emitter metrics.Emitter, processor PubSubProcessor) PubSubProcessor
• type PushEventPlan
  • func (p PushEventPlan) Task(id string) Task
• type Task
• type Topic
• type UUIDGenerator

Constants

const TaskTypePushEvent = "push-event"

Functions

func NewGenerator

func NewGenerator() *uuidGenerator

func NewPubSubSubscriber

func NewPubSubSubscriber(
	logger lager.Logger,
	subscription *pubsub.Subscription,
	processor PubSubProcessor,
	emitter metrics.Emitter,
) ifrit.Runner

func NewPushEventProcessor

func NewPushEventProcessor(
	changeFetcher ChangeFetcher,
	emitter metrics.Emitter,
	clock clock.Clock,
	traceClient *trace.Client,
) *pushEventProcessor

Types

type ChangeFetcher

type ChangeFetcher interface {
	Fetch(ctx context.Context, logger lager.Logger, owner, name string, reenable bool) error
}

type Enqueuer

type Enqueuer interface {
	Enqueue(Task) error
}

func NewPubSubEnqueuer

func NewPubSubEnqueuer(logger lager.Logger, topic Topic, signer crypto.Signer) Enqueuer

type Plan

type Plan interface {
	Task(string) Task
}

type PubSubProcessor

type PubSubProcessor interface {
	Process(context.Context, *pubsub.Message) (bool, error)
}

func NewSignatureCheck

func NewSignatureCheck(verify crypto.Verifier, emitter metrics.Emitter, processor PubSubProcessor) PubSubProcessor

type PushEventPlan

type PushEventPlan struct {
	Owner      string    `json:"owner"`
	Repository string    `json:"repository"`
	PushTime   time.Time `json:"pushTime"`
}

func (PushEventPlan) Task

func (p PushEventPlan) Task(id string) Task

type Task

type Task interface {
	ID() string
	Type() string
	Payload() string
}

type Topic

type Topic interface {
	Publish(context.Context, *pubsub.Message) *pubsub.PublishResult
}

type UUIDGenerator

type UUIDGenerator interface {
	Generate() string
}