builder

type ActiveBuild struct {
	RequestHash string    `json:"RequestHash"`
	StartTime   time.Time `json:"StartTime"`
}

type BuildManBuilder struct {
	ABFSBin  string
	Receiver Receiver
	Store    entities.CASStore
	// should only be used for testing or similar situations
	SkipHealthCheck bool
	// should be used in an environment where requests should be processed but not stored at a ref
	SkipRefPrefix bool
	// extra flags and values to the root `abfs` command
	AbfsFlags []string
	Tracker   *StatusTracker
}

type BuilderStatus struct {
	StartTime       time.Time     `json:"StartTime"`
	Jobs            int           `json:"Jobs"`
	ActiveJobsCount int           `json:"ActiveJobsCount"`
	TotalRequests   int64         `json:"TotalRequests"`
	SuccessRequests int64         `json:"SuccessRequests"`
	ErrorRequests   int64         `json:"ErrorRequests"`
	MemoryUsage     uint64        `json:"MemoryUsage"`
	Subscription    string        `json:"Subscription"`
	ActiveBuilds    []ActiveBuild `json:"ActiveBuilds"`
}

type Hash = entities.Hash

type Receiver interface {
	// Receive calls f with outstanding messages and blocks until the ctx is cancelled or a non-retryable
	// error occurs. f can be called concurrently if the provider was configured for it.
	Receive(ctx context.Context, f func(context.Context, entities.Hash) error) error
}

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