Documentation ¶
Index ¶
- Variables
- type Binder
- func (b *Binder) AsyncEventPoll(mid int32, eid uint32) (xtypes.LazyData, error)
- func (b *Binder) AsyncEventWait(mid int32, eid uint32) (xtypes.LazyData, error)
- func (b *Binder) AsyncLinkExec(name, method string, data xtypes.LazyData) (uint32, error)
- func (b *Binder) AsyncModuleExec(mid int32, method string, data xtypes.LazyData) (uint32, error)
- func (b *Binder) AttachJob(j *job.Job)
- func (b *Binder) Clone() bindx.Core
- func (b *Binder) ExecMethod(method string, data xtypes.LazyData) (xtypes.LazyData, error)
- func (b *Binder) Execute() (*event.Response, error)
- func (b *Binder) ForkExec(method string, data []byte) error
- func (b *Binder) GetApp() any
- func (b *Binder) GetFileWithMeta(file string) ([]byte, int64, error)
- func (b *Binder) GetInvoker() bindx.Invoker
- func (b *Binder) GetResource(name string) (*bindx.Resource, error)
- func (b *Binder) HttpFetch(req *bindx.HttpRequest) *bindx.HttpResponse
- func (b *Binder) InLinks() ([]bindx.Link, error)
- func (b *Binder) LazyLog(msgs []string)
- func (b *Binder) LinkExec(name, method string, data xtypes.LazyData) (xtypes.LazyData, error)
- func (b *Binder) LinkExecEmit(name, method string, data xtypes.LazyData) error
- func (b *Binder) ListResources() ([]*bindx.Resource, error)
- func (b *Binder) Log(msg string)
- func (b *Binder) ModuleExec(mid int32, method string, data xtypes.LazyData) (xtypes.LazyData, error)
- func (b *Binder) ModuleTicket(name string, opts xtypes.LazyData) (string, error)
- func (b *Binder) Name() string
- func (b *Binder) NewModule(name string, data xtypes.LazyData) (int32, error)
- func (b *Binder) OutLinks() ([]bindx.Link, error)
- func (b *Binder) SetExec(exec etypes.Executor)
- func (b *Binder) Sleep(msec int32)
- func (b *Binder) UserContext() *claim.UserContext
- func (b *Binder) UserInfo() (*entities.UserInfo, error)
- func (b *Binder) UserMessage(opts *bindx.UserMessage) error
- type BinderOptions
- type CabinetFolder
- type DataGroup
- type Factory
- type FactoryOptions
- type PlugState
- type SockdRoom
Constants ¶
This section is empty.
Variables ¶
View Source
var NoPanicWrap = true
Functions ¶
This section is empty.
Types ¶
type Binder ¶
type Binder struct { Deps *Factory Namespace string PlugId string AgentId string BprintId string EventId string Context context.Context Executor etypes.Executor Logger zerolog.Logger Job *job.Job Resp []byte ReuseCounter int32 Epoch int64 // contains filtered or unexported fields }
func (*Binder) AsyncEventPoll ¶
func (*Binder) AsyncEventWait ¶
func (*Binder) AsyncLinkExec ¶
func (*Binder) AsyncModuleExec ¶
func (*Binder) ExecMethod ¶
func (*Binder) GetFileWithMeta ¶
func (*Binder) GetInvoker ¶
func (*Binder) HttpFetch ¶
func (b *Binder) HttpFetch(req *bindx.HttpRequest) *bindx.HttpResponse
func (*Binder) LinkExecEmit ¶
func (*Binder) ModuleExec ¶
func (*Binder) ModuleTicket ¶
func (*Binder) UserContext ¶
func (b *Binder) UserContext() *claim.UserContext
func (*Binder) UserMessage ¶
func (b *Binder) UserMessage(opts *bindx.UserMessage) error
type BinderOptions ¶
type CabinetFolder ¶
type Factory ¶
type Factory struct { App xtypes.App Corehub store.CoreHub CabinetHub store.CabinetHub Sockd sockdx.SockdCore Pacman repox.Hub LoggerBase zerolog.Logger NodeCache service.NodeCache PlugKV store.PlugStateKV Runtime etypes.Runtime ModuleBuilders map[string]etypes.ModuleBuilder ExecBuilders map[string]etypes.ExecutorBuilder Signer service.Signer }
func NewFactory ¶
func NewFactory(opts FactoryOptions) Factory
func (*Factory) New ¶
func (bf *Factory) New(opts BinderOptions) *Binder
type FactoryOptions ¶
Source Files ¶
Click to show internal directories.
Click to hide internal directories.