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.