Documentation
¶
Index ¶
- Constants
- func NewFuncRuntimeDetails(id uint16, funcSet functionSet) *funcRuntimeDetails
- func NewFunctionManager(id string, cluster *gocb.Cluster, clusterSettings *common.ClusterSettings, ...) *functionManager
- func NewFunctionNameCache(ctx context.Context, id string, observer notifier.Observer, ...) funcCache
- func NewFunctionSet(instanceID string, fType funcSetType, id string, funcSetConfig config, ...) functionSet
- func NewIdealFunctionSet(id uint16, interruptHandler functionHandler.InterruptHandler, ...) functionSet
- func NewKeyspaceObserverWithContext(ctx context.Context, id string, observer notifier.Observer, ...) *keyspaceObserver
- type FunctionManager
- type InterruptHandler
- type SystemResourceDetails
Constants ¶
View Source
const ( // FunctionSetType is the type of function set GroupOfFunctions funcSetType = iota SingleFunction IdealFunction )
Variables ¶
This section is empty.
Functions ¶
func NewFuncRuntimeDetails ¶
func NewFuncRuntimeDetails(id uint16, funcSet functionSet) *funcRuntimeDetails
func NewFunctionManager ¶
func NewFunctionManager(id string, cluster *gocb.Cluster, clusterSettings *common.ClusterSettings, observer notifier.Observer, interrupt InterruptHandler, systemResourceDetails SystemResourceDetails, ownershipRoutine common.OwnershipRoutine, serverConfig serverConfig.ServerConfig, systemConfig serverConfig.SystemConfig, cursorCheckpointHandler functionHandler.CursorCheckpointHandler, broadcaster common.Broadcaster) *functionManager
func NewFunctionNameCache ¶
func NewFunctionSet ¶
func NewFunctionSet(instanceID string, fType funcSetType, id string, funcSetConfig config, clusterSettings *common.ClusterSettings, appCallback processManager.AppLogFunction, systemConfig serverConfig.SystemConfig) functionSet
func NewIdealFunctionSet ¶
func NewIdealFunctionSet(id uint16, interruptHandler functionHandler.InterruptHandler, funcHandler functionHandler.FunctionHandler) functionSet
Types ¶
type FunctionManager ¶
type FunctionManager interface {
// Stats operation
GetStats(appLocation application.AppLocation, statsType common.StatsType) *common.Stats
GetInsight(appLocation application.AppLocation) *common.Insight
GetApplicationLog(appLocation application.AppLocation, size int64) ([]string, error)
RebalanceProgress(version string, appLocation application.AppLocation, rebalanceProgress *common.AppRebalanceProgress)
ResetStats(appLocation application.AppLocation)
// Lifecycle operations
DeployFunction(fd *application.FunctionDetails)
PauseFunction(fd *application.FunctionDetails)
StopFunction(fd *application.FunctionDetails)
RemoveFunction(fd *application.FunctionDetails) int
// Notification for changes
NotifyOwnershipChange(version string)
NotifyGlobalConfigChange()
NotifyTlsChanges(cluster *gocb.Cluster)
// For debugger
TrapEventOp(trapEvent functionHandler.TrapEventOp, appLocation application.AppLocation, value interface{}) error
// Close the function manager
CloseFunctionManager()
}
type InterruptHandler ¶
type InterruptHandler interface {
// Interrupt called when state changed request done
StateChangeInterupt(seq uint32, appLocation application.AppLocation)
// Undeploy due to internal changes
StopCalledInterupt(seq uint32, msg common.LifecycleMsg)
}
type SystemResourceDetails ¶
type SystemResourceDetails interface {
MemRequiredPerThread(application.KeyspaceInfo) float64
}
Source Files
¶
Click to show internal directories.
Click to hide internal directories.