servicemanager2

Documentation

Index

• Constants
• func DeleteConfig(runtimeInfo *response.RuntimeInfo, keyspaceInfo application.KeyspaceInfo) error
• func DeleteFromMetakv(runtimeInfo *response.RuntimeInfo, appLocation application.AppLocation)
• func WriteConfig(runtimeInfo *response.RuntimeInfo, keyspaceInfo application.KeyspaceInfo, ...) error
• func WriteToMetakv(runtimeInfo *response.RuntimeInfo, serverConfig *serverConfig.Config, ...)
• type Config
• type CursorRegister
• type ServiceManager
  • func NewServiceManager(config *common.ClusterSettings, observer notifier.Observer, ...) (ServiceManager, error)
• type Supervisor2

Constants

const (
	APPROX_METRIC_COUNT = 27
	APPROX_METRIC_SIZE  = 50
	METRICS_PREFIX      = "eventing_"
)

Functions

func DeleteConfig

func DeleteConfig(runtimeInfo *response.RuntimeInfo, keyspaceInfo application.KeyspaceInfo) error

func DeleteFromMetakv

func DeleteFromMetakv(runtimeInfo *response.RuntimeInfo, appLocation application.AppLocation)

func WriteConfig

func WriteConfig(runtimeInfo *response.RuntimeInfo, keyspaceInfo application.KeyspaceInfo, configBytes []byte) error

func WriteToMetakv

func WriteToMetakv(runtimeInfo *response.RuntimeInfo, serverConfig *serverConfig.Config, funcDetails *application.FunctionDetails)

Types

type Config

type Config struct {
}

type CursorRegister

type CursorRegister interface {
	IsRegisterPossible(k application.Keyspace, funcId string) bool
	Register(k application.Keyspace, funcId string) bool
	Unregister(k application.Keyspace, funcId string)
}

type ServiceManager

type ServiceManager interface {
}

func NewServiceManager

func NewServiceManager(config *common.ClusterSettings, observer notifier.Observer,
	appManager appManager.AppManager, superSup Supervisor2,
	appState stateMachine.StateMachine, bucketGraph appGraph.AppGraph, cursorRegistry CursorRegister, broadcaster common.Broadcaster,
	serverConfig serverConfig.ServerConfig, globalStatsCounter *common.GlobalStatsCounter) (ServiceManager, error)

type Supervisor2

type Supervisor2 interface {
	GetStats(application.AppLocation) (*common.Stats, error)
	ClearStats(application.AppLocation) error
	CreateInitCheckpoint(funcDetails *application.FunctionDetails) (bool, 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
	GetGlobalRebalanceProgress(changeId string) (float64, error)
	GetOwnershipDetails() string

	PopulateID(keyspace application.Keyspace) (keyID application.KeyspaceInfo, err error)
	LifeCycleOperationAllowed() bool
	AssignOwnership(funcDetails *application.FunctionDetails) error
	GetLeaderNode() string

	GetCollectionObject(keyspace application.Keyspace) (*gocb.Collection, error)
	DeleteOnDeployCheckpoint(funcDetails *application.FunctionDetails, forceDelete bool) error
}