plugins

type Domain interface {
	HubDomainName() string
	Name() string
	Cache() *cache.Store
	GetDomainFromObjectID(objectID string) string
	GetObjectIDWithoutDomain(objectID string) string
	CreateObjectIDWithDomain(domain string, objectID string, domainReplace bool) string
	CreateObjectIDWithThisDomain(objectID string, domainReplace bool) string
	CreateObjectIDWithHubDomain(objectID string, domainReplace bool) string
	// Get all domains in weak cluster including this one
	GetWeakClusterDomains() []string
	// Set all domains in weak cluster (this domain name will also be included automatically if not defined)
	SetWeakClusterDomains(weakClusterDomains []string)
	/*
	* otherDomainName/ObjectId -> thisDomainName/otherDomainName#ObjectId
	* thisDomainName/ObjectId -> thisDomainName/ObjectId
	 */
	GetShadowObjectShadowId(objectIdWithAnyDomainName string) string
	/*
	* domainName1/domainName2#ObjectId -> domainName2, ObjectId
	 */
	GetShadowObjectDomainAndID(shadowObjectId string) (domainName, objectIdWithoutDomain string, err error)
	/*
	* domainName1/domainName2#ObjectId -> true
	* domainName1/ObjectId  -> false
	 */
	IsShadowObject(idWithDomain string) bool

	GetValidObjectId(objectId string) string

	CreateCustomShadowId(storeDomain, targetDomain, uuid string) string
}

type EgressProvider int

type PluginError interface {
	Error() string
	GetLocation() string
	GetStackTrace() string
}

type RequestProvider int

type SFEgressFunc func(egressProvider EgressProvider, payload *easyjson.JSON, customId ...string) error

type SFRequestFunc func(requestProvider RequestProvider, typename string, id string, payload *easyjson.JSON, options *easyjson.JSON, timeout ...time.Duration) (*easyjson.JSON, error)

type SFSignalFunc func(signalProvider SignalProvider, typename string, id string, payload *easyjson.JSON, options *easyjson.JSON) error

type SignalProvider int

type StatefunAddress struct {
	Typename string
	ID       string
}

type StatefunContextProcessor struct {
	GetFunctionContext        func() *easyjson.JSON
	SetFunctionContext        func(*easyjson.JSON)
	SetContextExpirationAfter func(time.Duration)
	GetObjectContext          func() *easyjson.JSON
	SetObjectContext          func(*easyjson.JSON)
	ObjectMutexLock           func(objectId string, errorOnLocked bool) error
	ObjectMutexUnlock         func(objectId string) error
	Domain                    Domain
	// TODO: DownstreamSignal(<function type>, <links filters>, <payload>, <options>)
	Signal  SFSignalFunc
	Request SFRequestFunc
	Egress  SFEgressFunc
	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(ctx *StatefunContextProcessor) error
	BuildError() error
}

type StatefunExecutorConstructor func(alias string, source string) StatefunExecutor

type SyncReply struct {
	With                    func(*easyjson.JSON)
	CancelDefaultReply      func()
	OverrideRequestCallback func() *SyncReply
}

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