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)
	ObjectMutexLock    func(errorOnLocked bool) error
	ObjectMutexUnlock  func() error
	// 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
	Reply   *SyncReply // 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 SyncReply struct {
	With          func(*easyjson.JSON)
	CancelDefault func()
}

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