statemanager

Documentation

Index

• type Manager
  • func New(ctx context.Context, configSource config.Source, connPool *supervisor.ConnPool) (Manager, error)

Types

type Manager

type Manager interface {
	GetRegions(ctx context.Context) ([]vm.Region, error)
	RegisterNodes(ctx context.Context, nodes []vm.NodeCapacityInfo) error
	DeleteNodes(ctx context.Context, nodeIds []vm.NodeId) error
	ClearNodes(ctx context.Context) error
	CreateVM(ctx context.Context, vmId vm.Id, region vm.Region) (vm.Info, error)
	RegisterVM(ctx context.Context, info vm.Info) error
	DeleteVMs(ctx context.Context, vms []vm.Info) error
	GetVMs(ctx context.Context, ids []vm.Id) ([]vm.Info, error)
	HasVM(ctx context.Context, id vm.Id) (bool, error)
	Heartbeat(ctx context.Context, id vm.Id) error
	GetExpiredVMs(ctx context.Context) ([]vm.Id, error)
	OnCapacityIncrease(fn func(region vm.Region))
	SetVersion(ctx context.Context, version interface{}) error
	GetVersion(ctx context.Context) (string, error)
}

func New

func New(ctx context.Context, configSource config.Source, connPool *supervisor.ConnPool) (Manager, error)