api

type FunctionContext interface {
	PutState(key string, value []byte) error
	GetState(key string) ([]byte, error)
}

type FunctionInstance interface {
	Context() context.Context
	FunctionContext() FunctionContext
	Definition() *model.Function
	Index() int32
	Stop()
	Run(factory FunctionRuntimeFactory)
	WaitForReady() <-chan error
	Logger() *slog.Logger
}

type FunctionInstanceFactory interface {
	NewFunctionInstance(f *model.Function, funcCtx FunctionContext, sourceFactory contube.SourceTubeFactory, sinkFactory contube.SinkTubeFactory, i int32, logger *slog.Logger) FunctionInstance
}

type FunctionRuntime interface {
	WaitForReady() <-chan error
	Call(e contube.Record) (contube.Record, error)
	Stop()
}

type FunctionRuntimeFactory interface {
	NewFunctionRuntime(instance FunctionInstance) (FunctionRuntime, error)
}

type StateStore interface {
	PutState(key string, value []byte) error
	GetState(key string) ([]byte, error)
	Close() error
}