Documentation ¶
Index ¶
- Constants
- func NewGenerator() *uuidGenerator
- func NewPubSubSubscriber(logger lager.Logger, subscription *pubsub.Subscription, ...) ifrit.Runner
- func NewPushEventProcessor(changeFetcher revok.ChangeFetcher, emitter metrics.Emitter, clock clock.Clock, ...) *pushEventProcessor
- type Enqueuer
- type Plan
- type PubSubProcessor
- type PushEventPlan
- type Task
- type Topic
- type UUIDGenerator
Constants ¶
View Source
const TaskTypePushEvent = "push-event"
Variables ¶
This section is empty.
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 ¶
Types ¶
type PubSubProcessor ¶
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 UUIDGenerator ¶
type UUIDGenerator interface {
Generate() string
}
Source Files ¶
Directories ¶
Path | Synopsis |
---|---|
This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter
|
This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter |
Click to show internal directories.
Click to hide internal directories.