supervisor2

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

type DoneCallback func(err error, cancel <-chan struct{})

type ProgressCallback func(progress float64, cancel <-chan struct{})

type Service interface {
	InitServiceManagerWithSup(sup Supervisor)

	GetNodeInfo() (*service.NodeInfo, error)
	Shutdown() error

	GetTaskList(rev service.Revision, cancel service.Cancel) (*service.TaskList, error)
	CancelTask(id string, rev service.Revision) error

	GetCurrentTopology(rev service.Revision, cancel service.Cancel) (*service.Topology, error)

	PrepareTopologyChange(change service.TopologyChange) error
	StartTopologyChange(change service.TopologyChange) error
	AddBalancedInfo(changeID string, knownNodes []string)
}

type Supervisor interface {
	GetGlobalRebalanceProgress(version string) (float64, error)
	SyncPhaseDone() bool
}

type Supervisor2 interface {
	GetStats(application.AppLocation, common.StatsType) (*common.Stats, error)
	ClearStats(application.AppLocation) error

	CompileHandler(*application.FunctionDetails) (*common.CompileStatus, error)
	DebuggerOp(op common.DebuggerOp, funcDetails *application.FunctionDetails, value interface{}) (string, error)

	GetApplicationLog(appLocation application.AppLocation, size int64) ([]string, error)
	GetInsights(appLocation application.AppLocation) *common.Insight
	RebalanceProgress(vbMapVersion string, appLocation application.AppLocation) *common.AppRebalanceProgress
	GetOwnershipDetails() string

	StateChangeInterupt(seq uint32, appLocation application.AppLocation)
	StopCalledInterupt(seq uint32, msg common.LifecycleMsg)

	LifeCycleOperationAllowed() bool

	MemRequiredPerThread(application.KeyspaceInfo) float64
	GetCollectionObject(funcDetails application.Keyspace) (*gocb.Collection, error)

	CreateInitCheckpoint(*response.RuntimeInfo, *application.FunctionDetails)
	PopulateID(response *response.RuntimeInfo, keyspace application.Keyspace) application.KeyspaceInfo
}