plugins

type RequestProvider int

type SignalProvider int

type StatefunAddress struct {
	Typename string
	ID       string
}

type StatefunContextProcessor struct {
	GlobalCache        *cache.Store
	GetFunctionContext func() *easyjson.JSON
	SetFunctionContext func(*easyjson.JSON)
	GetObjectContext   func() *easyjson.JSON
	SetObjectContext   func(*easyjson.JSON)
	// TODO: DownstreamSignal(<function type>, <links filters>, <payload>, <options>)
	Signal           func(SignalProvider, string, string, *easyjson.JSON, *easyjson.JSON) error
	Request          func(RequestProvider, string, string, *easyjson.JSON, *easyjson.JSON) (*easyjson.JSON, error)
	Self             StatefunAddress
	Caller           StatefunAddress
	Payload          *easyjson.JSON
	Options          *easyjson.JSON
	RequestReplyData *easyjson.JSON // when requested in function: nil - function was signaled, !nil - function was requested
}

type StatefunExecutor interface {
	Run(contextProcessor *StatefunContextProcessor) error
	BuildError() error
}

type StatefunExecutorConstructor func(alias string, source string) StatefunExecutor

type TypenameExecutorPlugin struct {
	// contains filtered or unexported fields
}