notifications

Sep 16, 2015

Changes in this version

+ const EventActionDelete

+ const EventActionPull

+ const EventActionPush

+ const EventsMediaType

+ var ErrSinkClosed = fmt.Errorf("sink: closed")

+ func Listen(repo distribution.Repository, listener Listener) distribution.Repository

+ type ActorRecord struct

+ Name string

+ type BlobListener interface

+ BlobDeleted func(repo string, desc distribution.Descriptor) error

+ BlobPulled func(repo string, desc distribution.Descriptor) error

+ BlobPushed func(repo string, desc distribution.Descriptor) error

+ type Broadcaster struct

+ func NewBroadcaster(sinks ...Sink) *Broadcaster

+ func (b *Broadcaster) Close() error

+ func (b *Broadcaster) Write(events ...Event) error

+ type Endpoint struct

+ func NewEndpoint(name, url string, config EndpointConfig) *Endpoint

+ func (e *Endpoint) Name() string

+ func (e *Endpoint) ReadMetrics(em *EndpointMetrics)

+ func (e *Endpoint) URL() string

+ type EndpointConfig struct

+ Backoff time.Duration

+ Headers http.Header

+ Threshold int

+ Timeout time.Duration

+ type EndpointMetrics struct

+ Errors int

+ Events int

+ Failures int

+ Pending int

+ Statuses map[string]int

+ Successes int

+ type Envelope struct

+ Events []Event

+ type Event struct

+ Action string

+ Actor ActorRecord

+ ID string

+ Request RequestRecord

+ Source SourceRecord

+ Target struct{ ... }

+ Timestamp time.Time

+ type Listener interface

+ func NewBridge(ub URLBuilder, source SourceRecord, actor ActorRecord, request RequestRecord, ...) Listener

+ type ManifestListener interface

+ ManifestDeleted func(repo string, sm *manifest.SignedManifest) error

+ ManifestPulled func(repo string, sm *manifest.SignedManifest) error

+ ManifestPushed func(repo string, sm *manifest.SignedManifest) error

+ type RequestRecord struct

+ Addr string

+ Host string

+ ID string

+ Method string

+ UserAgent string

+ func NewRequestRecord(id string, r *http.Request) RequestRecord

+ type Sink interface

+ Close func() error

+ Write func(events ...Event) error

+ type SourceRecord struct

+ Addr string

+ InstanceID string

+ type URLBuilder interface

+ BuildBlobURL func(name string, dgst digest.Digest) (string, error)

+ BuildManifestURL func(name, tag string) (string, error)