queue

Documentation

Index

• Constants
• func NewGenerator() *uuidGenerator
• func NewPubSubSubscriber(logger lager.Logger, subscription *pubsub.Subscription, ...) ifrit.Runner
• func NewPushEventProcessor(changeFetcher revok.ChangeFetcher, verifier crypto.Verifier, ...) *pushEventProcessor
• type Enqueuer
  • func NewPubSubEnqueuer(logger lager.Logger, topic Topic, signer crypto.Signer) Enqueuer
• type Plan
• type 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 revok.ChangeFetcher,
	verifier crypto.Verifier,
	emitter metrics.Emitter,
	clock clock.Clock,
) *pushEventProcessor

Types

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(lager.Logger, *pubsub.Message) (bool, error)
}

type PushEventPlan

type PushEventPlan struct {
	Owner      string    `json:"owner"`
	Repository string    `json:"repository"`
	From       string    `json:"from"`
	To         string    `json:"to"`
	Private    bool      `json:"private"`
	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) ([]string, error)
}

type UUIDGenerator

type UUIDGenerator interface {
	Generate() string
}