metascheduler

type AlreadyDone struct{}

type ArrayLengthMismatch struct{}

type Banned struct{}

type Client struct {
	bind.DeployBackend
	// contains filtered or unexported fields
}

type CustomerMetaSchedulerProviderOnly struct{}

type CustomerOnly struct {
	Current  common.Address
	Expected common.Address
}

type DoubleEndedQueueEmpty struct{}

type DoubleEndedQueueOutOfBounds struct{}

type InsufficientFunds struct {
	Available *big.Int
	Required  *big.Int
}

type InvalidJob struct{}

type InvalidJobDefinition struct{}

type InvalidNodesCount struct{}

type InvalidTotalCpus struct{}

type InvalidTotalMem struct{}

type InvalidTransition struct {
	From JobStatus
	To   JobStatus
}

type Job struct {
	JobID            [32]byte
	Status           JobStatus
	CustomerAddr     common.Address
	ProviderAddr     common.Address
	Definition       metaschedulerabi.JobDefinition
	Cost             metaschedulerabi.JobCost
	Time             metaschedulerabi.JobTime
	JobName          [32]byte
	HasCancelRequest bool
	LastError        string
}

type JobHotStatusOnly struct {
	Current JobStatus
}

type JobProviderOnly struct {
	Current  common.Address
	Expected common.Address
}

type JobStatus uint8

type MetaScheduledScheduledStatusOnly struct {
	Current JobStatus
}

type MetaScheduler interface {
	IsRequestNewJobEnabled(ctx context.Context) (bool, error)
	// Claim a job for scheduling.
	Claim(ctx context.Context) error
	// Claim cancelling calls.
	ClaimCancelling(ctx context.Context) error
	// Claim top up calls.
	ClaimTopUp(ctx context.Context) error
	// Refuse a job for metascheduling.
	RefuseJob(ctx context.Context, jobID [32]byte) error
	// WatchEvents observes the incoming ClaimNextTopUpJobEvent, ClaimNextCancellingJobEvent and ClaimJobEvent.
	WatchEvents(
		ctx context.Context,
		claimNextTopUpJobEvents chan<- *metaschedulerabi.MetaSchedulerClaimNextTopUpJobEvent,
		claimNextCancellingJobEvents chan<- *metaschedulerabi.MetaSchedulerClaimNextCancellingJobEvent,
		claimJobEvents chan<- *metaschedulerabi.MetaSchedulerClaimJobEvent,
	) (event.Subscription, error)
	// GetProviderAddress fetches the provider public address.
	GetProviderAddress() common.Address
	// GetOldInfo fetches the last registration provider information.
	GetOldInfo(ctx context.Context) (*metaschedulerabi.Provider, error)
	// GetJobStatus fetches the job status.
	GetJobStatus(ctx context.Context, jobID [32]byte) (JobStatus, error)
	SetJobStatus(
		ctx context.Context,
		jobID [32]byte,
		status JobStatus,
		jobDurationMinute uint64,
		opts ...SetJobStatusOption,
	) error
	Register(
		ctx context.Context,
		hardware metaschedulerabi.ProviderHardware,
		prices metaschedulerabi.ProviderPrices,
		labels []metaschedulerabi.Label,
	) error
	// GetJob fetches a job.
	GetJob(ctx context.Context, jobID [32]byte) (*Job, error)
	// GetJobs fetches the jobs of the provider.
	GetJobs(ctx context.Context) (*ProviderJobIterator, error)
}

type NewJobRequestDisabled struct{}

type NoJob struct{}

type NoProvider struct{}

type NoSpendingAuthority struct{}

type PanicError byte

type ProviderJobIterator struct {
	Job *Job
	*metaschedulerabi.MetaSchedulerClaimJobEventIterator
	// contains filtered or unexported fields
}

type ProviderNotJoined struct{}

type RemainingTimeAboveLimit struct {
	Remaining *big.Int
	Limit     *big.Int
}

type RunningColdStatusOnly struct {
	Current JobStatus
}

type RunningScheduledStatusOnly struct {
	Current JobStatus
}

type SameStatusError struct{}

type SetJobStatusOption func(*setJobStatusOptions)

type WaitingApprovalOnly struct{}