jobcontent

type AdmissionResources interface {
	Prepare(context.Context, jobcontract.JobSpec) (PreparedResources, error)
}

type AssetResolver interface {
	Open(context.Context, string) (AssetStream, error)
}

type AssetStream interface {
	io.ReadCloser
	Identity() jobcontract.ContentIdentity
	MediaType() string
}

type Claim struct {
	Ref       string
	Object    ObjectIdentity
	MediaType string
}

type Dependencies struct {
	Physical PhysicalStore
	Ledger   Ledger
	Limits   Limits
}

type Entry struct {
	ID                string
	JobID             string
	Role              jobcontract.ContentRole
	Ref               string
	RunID             *string
	StoreID           string
	SHA256            string
	Size              int64
	MediaType         string
	Generation        *uint64
	State             EntryState
	FailureCode       *string
	LinkedAt          time.Time
	ReleasedByCommand *string
}

type EntryState string

type Generation struct {
	Object    ObjectIdentity
	Number    uint64
	CreatedAt time.Time
}

type Inventory struct {
	JobID                string
	Revision             uint64
	SealedManifestSHA256 *string
	Entries              []Entry
}

type JobResources interface {
	Resolver() AssetResolver
	Close() error
}

type Ledger interface {
	RegisterContentStore(context.Context, Store) error
	// The bool identifies a new publication generation, not a new physical file.
	PublishContent(context.Context, Publication) (Generation, bool, error)
	ContentPublication(context.Context, string, string) (Generation, error)
	JobContent(context.Context, string) (Inventory, error)
}

type Limits struct {
	Operations int
	Pins       int
	Borrowed   int
	Resources  int
}

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

type ObjectIdentity struct {
	StoreID       string
	Content       jobcontract.ContentIdentity
	IncarnationID string
	WitnessSHA256 string
	ChangeToken   string
}

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

type PhysicalStore interface {
	Store() Store
	Ready(context.Context) error
	PutContent(context.Context, jobcontract.ContentIdentity, io.Reader) (bool, error)
	OpenPinned(context.Context, jobcontract.ContentIdentity) (PinnedContent, error)
}

type PinnedContent interface {
	io.ReadSeekCloser
	Object() ObjectIdentity
	Check() error
}

type PreparedResources interface {
	Claims() []Claim
	Permit() *Permit
	BindJob(string) (JobResources, error)
	Close() error
}

type Publication struct {
	Object ObjectIdentity
	At     time.Time
}

type Status struct {
	Operations int
	Pins       int
	Borrowed   int
	Resources  int
	Hashes     int
}

type Store struct {
	ID             string
	Kind           StoreKind
	InstallationID string
	CreatedAt      time.Time
}

type StoreKind string

type UploadResult struct {
	PhysicalCreated bool
	Generation      Generation
}