functionHandler

type Config struct {
	LeaderHandler bool
}

type CursorCheckpointHandler interface {
	GetCursors(keyspace application.Keyspace) (map[string]struct{}, bool)
}

type FunctionHandler interface {
	AddFunctionDetails(funcDetails *application.FunctionDetails)

	// ChangeState will changes the state of an app
	// It can be called for spawn/pause/undeploy/RuntimeEnvironment crash
	ChangeState(re RuntimeEnvironment, state funcHandlerState)
	TrapEvent(trapEvent TrapEventOp, value interface{}) error

	// ReceiveMessage is when msg is received from the c++ side
	ReceiveMessage(msg *processManager.ResponseMessage)

	// Stats gives the stats back for the app
	Stats(statsType common.StatsType) *common.Stats
	GetInsight() *common.Insight

	GetApplicationLog(size int64) ([]string, error)

	// ResetStats will reset all the stats
	ResetStats()

	// ApplicationLog will write the message to the application log
	ApplicationLog(msg string)

	// NotifyOwnershipChange will be called when new vbs need to be acquired or givenup
	NotifyOwnershipChange(version string)

	// NotifyGlobalConfigChange will be called when global config is changed
	NotifyGlobalConfigChange()

	// GetRebalanceProgress how many vbs need to be claimed
	GetRebalanceProgress(version string, appProgress *common.AppRebalanceProgress) bool

	CloseFunctionHandler()
}

type InterruptHandler func(id uint16, seq uint32, appLocation application.AppLocation, err error)

type LogWriter interface {
	Write(p []byte) (n int, err error)
	Tail(sz int64) ([]byte, error)
	Flush()
	Close() error
}

type RuntimeEnvironment interface {
	InitEvent(version uint32, opcode uint8, handlerID []byte, value interface{})
	LifeCycleOp(version uint32, opcode uint8, handlerID []byte)
	SendControlMessage(version uint32, cmd processManager.Command, opcode uint8, handlerID []byte, key, value interface{})
	GetStats(version uint32, opcode uint8, handlerName []byte)

	WriteDcpMessage(version uint32, buffer *bytes.Buffer, opcode uint8, workerID uint8,
		instanceID []byte, msg *dcpMessage.DcpEvent, internalInfo *checkpointManager.ParsedInternalDetails) int32

	FlushMessage(version uint32, buffer *bytes.Buffer)
	VbSettings(version uint32, opcode uint8, handlerID []byte, key interface{}, value interface{})

	GetProcessDetails() processManager.ProcessDetails
	GetRuntimeStats() common.StatsInterface
}

type TrapEventOp uint8

type UtilityWorker interface {
	CreateUtilityWorker(id string, md processManager.MessageDeliver) processManager.ProcessManager
	GetUtilityWorker() processManager.ProcessManager
	DoneUtilityWorker(id string)
}