requester

type ApproveJobRequest struct {
	ClientID string
	JobID    string
	Response bidstrategy.BidStrategyResponse
}

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

type BaseEndpointParams struct {
	ID                         string
	PublicKey                  []byte
	Scheduler                  Scheduler
	Selector                   bidstrategy.BidStrategy
	Store                      jobstore.Store
	Verifiers                  verifier.VerifierProvider
	StorageProviders           storage.StorageProvider
	MinJobExecutionTimeout     time.Duration
	DefaultJobExecutionTimeout time.Duration
}

type CancelJobRequest struct {
	JobID         string
	Reason        string
	UserTriggered bool
}

type CancelJobResult struct{}

type Endpoint interface {
	// SubmitJob submits a new job to the network.
	SubmitJob(context.Context, model.JobCreatePayload) (*model.Job, error)
	// ApproveJob approves or rejects the running of a job.
	ApproveJob(context.Context, ApproveJobRequest) error
	// CancelJob cancels an existing job.
	CancelJob(context.Context, CancelJobRequest) (CancelJobResult, error)
}

type ErrJobAlreadyTerminal struct {
	JobID string
}

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

type ErrNotEnoughNodes struct {
	RequestedNodes int
	AvailableNodes int
}

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

type EventEmitterParams struct {
	EventConsumer eventhandler.JobEventHandler
}

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

type HousekeepingParams struct {
	Endpoint Endpoint
	JobStore jobstore.Store
	NodeID   string
	Interval time.Duration
}

type NodeDiscoverer interface {
	FindNodes(ctx context.Context, job model.Job) ([]model.NodeInfo, error)
}

type NodeRank struct {
	NodeInfo model.NodeInfo
	Rank     int
}

type NodeRanker interface {
	RankNodes(ctx context.Context, job model.Job, nodes []model.NodeInfo) ([]NodeRank, error)
}

type Queue interface {
	Scheduler

	EnqueueJob(context.Context, model.Job) error
}

type Scheduler interface {
	StartJob(context.Context, StartJobRequest) error
	CancelJob(context.Context, CancelJobRequest) (CancelJobResult, error)
}

type SchedulerParams struct {
	ID               string
	Host             host.Host
	JobStore         jobstore.Store
	NodeDiscoverer   NodeDiscoverer
	NodeRanker       NodeRanker
	ComputeEndpoint  compute.Endpoint
	Verifiers        verifier.VerifierProvider
	StorageProviders storage.StorageProvider
	EventEmitter     EventEmitter
}

type StartJobRequest struct {
	Job model.Job
}