provision

type Callback func(twin uint32, contract uint64, delete bool)

type DescriptionField struct {
	Description string
}

type Engine interface {
	// Provision pushes a workload to engine queue. on success
	// means that workload has been committed to storage (accepts)
	// and will be processes later
	Provision(ctx context.Context, wl gridtypes.Deployment) error
	Deprovision(ctx context.Context, twin uint32, id uint64, reason string) error
	Pause(ctx context.Context, twin uint32, id uint64) error
	Resume(ctx context.Context, twin uint32, id uint64) error
	Update(ctx context.Context, update gridtypes.Deployment) error
	Storage() Storage
	Twins() Twins
	Admins() Twins
}

type EngineOption interface {
	// contains filtered or unexported methods
}

type Exclude = func(dl *gridtypes.Deployment, wl *gridtypes.Workload) bool

type Field interface{}

type Initializer interface {
	Initialize(ctx context.Context) error
}

type Janitor interface {
	Cleanup(ctx context.Context) error
}

type Manager interface {
	Provision(ctx context.Context, wl *gridtypes.WorkloadWithID) (interface{}, error)
	Deprovision(ctx context.Context, wl *gridtypes.WorkloadWithID) error
}

type MetadataField struct {
	Metadata string
}

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

type Pauser interface {
	Pause(ctx context.Context, wl *gridtypes.WorkloadWithID) error
	Resume(ctx context.Context, wl *gridtypes.WorkloadWithID) error
}

type Provisioner interface {
	// Initialize is called before the provision engine is started
	Initialize(ctx context.Context) error
	// Provision a workload
	Provision(ctx context.Context, wl *gridtypes.WorkloadWithID) (gridtypes.Result, error)
	// Deprovision a workload
	Deprovision(ctx context.Context, wl *gridtypes.WorkloadWithID) error
	// Pause a workload
	Pause(ctx context.Context, wl *gridtypes.WorkloadWithID) (gridtypes.Result, error)
	// Resume a workload
	Resume(ctx context.Context, wl *gridtypes.WorkloadWithID) (gridtypes.Result, error)
	// Update a workload
	Update(ctx context.Context, wl *gridtypes.WorkloadWithID) (gridtypes.Result, error)
	// CanUpdate checks if this workload can be updated on the fly
	CanUpdate(ctx context.Context, typ gridtypes.WorkloadType) bool
}

type ResourceUnits string

type Response interface {
	error
	// contains filtered or unexported methods
}

type SignatureRequirementField struct {
	SignatureRequirement gridtypes.SignatureRequirement
}

type Storage interface {
	// Create a new deployment in storage, it sets the initial transactions
	// for all workloads to "init" and the correct creation time.
	Create(deployment gridtypes.Deployment) error
	// Update updates a deployment fields
	Update(twin uint32, deployment uint64, fields ...Field) error
	// Delete deletes a deployment from storage.
	Delete(twin uint32, deployment uint64) error
	// Get gets the current state of a deployment from storage
	Get(twin uint32, deployment uint64) (gridtypes.Deployment, error)
	// Error sets global deployment error
	Error(twin uint32, deployment uint64, err error) error
	// Add workload to deployment, if no active deployment exists with same name
	Add(twin uint32, deployment uint64, workload gridtypes.Workload) error
	// Remove a workload from deployment.
	Remove(twin uint32, deployment uint64, name gridtypes.Name) error
	// Transaction append a transaction to deployment transactions logs
	Transaction(twin uint32, deployment uint64, workload gridtypes.Workload) error
	// Changes return all the historic transactions of a deployment
	Changes(twin uint32, deployment uint64) (changes []gridtypes.Workload, err error)
	// Current gets last state of a workload by name
	Current(twin uint32, deployment uint64, name gridtypes.Name) (gridtypes.Workload, error)
	// Twins list twins in storage
	Twins() ([]uint32, error)
	// ByTwin return list of deployments for a twin
	ByTwin(twin uint32) ([]uint64, error)
	// return total capacity and active deployments
	Capacity(exclude ...Exclude) (StorageCapacity, error)
}

type StorageCapacity struct {
	// Cap is total reserved capacity as per all active workloads
	Cap gridtypes.Capacity
	// Deployments is a list with all deployments that are active
	Deployments []gridtypes.Deployment
	// Workloads the total number of all workloads
	Workloads int
	// LastDeploymentTimestamp last deployment timestamp
	LastDeploymentTimestamp gridtypes.Timestamp
}

type Twins interface {
	GetKey(id uint32) ([]byte, error)
}

type Updater interface {
	Update(ctx context.Context, wl *gridtypes.WorkloadWithID) (interface{}, error)
}

type VersionField struct {
	Version uint32
}