Versions in this module Expand all Collapse all v0 v0.5.0 Feb 5, 2016 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 *schema1.SignedManifest) error + ManifestPulled func(repo string, sm *schema1.SignedManifest) error + ManifestPushed func(repo string, sm *schema1.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)