backend

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

type Backend interface {
	Destroy()

	CreateOrUpdateTrials(ctx context.Context, trialsParams []*TrialParams) error
	RetrieveTrials(ctx context.Context, filter []string, fromTrialIdx int, count int) (TrialsInfoResult, error)
	ObserveTrials(ctx context.Context, filter []string, fromTrialIdx int, count int, out chan<- TrialsInfoResult) error
	DeleteTrials(ctx context.Context, trialIDs []string) error

	GetTrialParams(ctx context.Context, trialIDs []string) ([]*TrialParams, error)

	AddSamples(ctx context.Context, samples []*grpcapi.StoredTrialSample) error
	ObserveSamples(ctx context.Context, filter TrialSampleFilter, out chan<- *grpcapi.StoredTrialSample) error
}

type TrialInfo struct {
	TrialID            string
	UserID             string
	State              grpcapi.TrialState
	SamplesCount       int
	StoredSamplesCount int
}

type TrialParams struct {
	TrialID string
	UserID  string
	Params  *grpcapi.TrialParams
}

type TrialSampleFilter struct {
	TrialIDs             []string
	ActorNames           []string
	ActorClasses         []string
	ActorImplementations []string
	Fields               []grpcapi.StoredTrialSampleField
}

type TrialSampleObserver chan *grpcapi.StoredTrialSample

type TrialsInfoObserver chan TrialsInfoResult

type TrialsInfoResult struct {
	TrialInfos   []*TrialInfo
	NextTrialIdx int
}

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

type UnknownTrialError struct {
	TrialID string
}