api

Documentation

Index

• Variables
• type FunctionContext
• type FunctionInstance
• type FunctionInstanceFactory
• type FunctionRuntime
• type FunctionRuntimeFactory
• type StateStore

Variables

var ErrNotFound = errors.New("key not found")

Types

type FunctionContext

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

type FunctionInstance

type FunctionInstance interface {
	Context() context.Context
	FunctionContext() FunctionContext
	Definition() *model.Function
	Index() int32
	Stop()
	Run(runtime FunctionRuntime, sources []<-chan contube.Record, sink chan<- contube.Record)
	Logger() *common.Logger
}

type FunctionInstanceFactory

type FunctionInstanceFactory interface {
	NewFunctionInstance(f *model.Function, funcCtx FunctionContext, i int32, logger *common.Logger) FunctionInstance
}

type FunctionRuntime

type FunctionRuntime interface {
	Call(e contube.Record) (contube.Record, error)
	Stop()
}

type FunctionRuntimeFactory

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

type StateStore

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