Versions in this module Expand all Collapse all v0 v0.1.0 Oct 12, 2020 Changes in this version + const LogName + func GetMatchingSourceRegistries(manifests []reg.Manifest, gcrPayload reg.GCRPubSubPayload) ([]reg.RegistryContext, error) + func ParsePubSubMessage(body io.Reader) (*reg.GCRPubSubPayload, error) + func ParsePubSubMessageBody(body []byte) (*reg.GCRPubSubPayload, error) + func ValidatePayload(gcrPayload *reg.GCRPubSubPayload) error + type GcrReadingFacility struct + ReadManifestList func(*reg.SyncContext, reg.GCRManifestListContext) stream.Producer + ReadRepo func(*reg.SyncContext, reg.RegistryContext) stream.Producer + type PubSubMessage struct + Message PubSubMessageInner + Subscription string + type PubSubMessageInner struct + Data []byte + ID string + type ServerContext struct + ErrorReportingFacility report.ReportingFacility + GcrReadingFacility GcrReadingFacility + ID string + LoggingFacility logclient.LoggingFacility + RemoteManifestFacility remotemanifest.Facility + func InitRealServerContext(gcpProjectID, repoURLStr, branch, path, uuid string) (*ServerContext, error) + func (s *ServerContext) Audit(w http.ResponseWriter, r *http.Request) + func (s *ServerContext) RunAuditor()