observe

type Config struct {
	Conn       *grpc.ClientConn
	RPCCreds   credentials.PerRPCCredentials
	StateStore StateStore
	Processor  Processor
	Registries []string
	Refs       []string
	Prefixes   []string
	Hosts      []string
}

type FileStateStore struct {
	// contains filtered or unexported fields
}

type Logger interface {
	Infow(msg string, kv ...interface{})
	Warnw(msg string, kv ...interface{})
	Errorw(msg string, kv ...interface{})
}

type Observer struct {
	// contains filtered or unexported fields
}

type Processor interface {
	// `Process()` should handle most processing errors.  It may return
	// errors that are likely due to a shutdown, like `context.Canceled` or
	// termination of a child due to a signal.
	ProcessRepo(ctx context.Context, repo *execute.Repo) error
}

type StateStore interface {
	// `LoadULID()` loads the journal position for `name` from permanent
	// storage.  If successful, it returns either a valid ULID or
	// `ulid.Nil` to indicate that there is no stored state.  It may return
	// errors, such as file I/O problems.
	LoadULID(name string) (ulid.I, error)
	SaveULID(name string, id ulid.I) error
}

type VolatileStateStore struct {
	// contains filtered or unexported fields
}