oc

Mar 26, 2024

Changes in this version

type ComponentBehavior

+ func (c *ComponentBehavior) CliRPC(method string, args ...any) runtime.AsyncRet

+ func (c *ComponentBehavior) CliRPCToEntity(entityId uid.Id, method string, args ...any) runtime.AsyncRet

+ func (c *ComponentBehavior) OneWayCliRPC(method string, args ...any) error

+ func (c *ComponentBehavior) OneWayCliRPCToEntity(entityId uid.Id, method string, args ...any) error

Mar 18, 2024

Changes in this version

type ComponentBehavior

+ func (c *ComponentBehavior) CRPC(method string, args ...any) runtime.AsyncRet

+ func (c *ComponentBehavior) OneWayCRPC(method string, args ...any) error

type EntityProxied

+ func (ep EntityProxied) CRPC(method string, args ...any) runtime.AsyncRet

+ func (ep EntityProxied) OneWayCRPC(method string, args ...any) error

+ type GroupProxied struct

+ Context service.Context

+ Id uid.Id

+ func ProxyGroup(servCtx service.Context, id uid.Id) GroupProxied

+ func (gp GroupProxied) OneWayCRPC(entityId uid.Id, method string, args ...any) error

Mar 10, 2024

Changes in this version

type RuntimeCtx

+ func (ctx RuntimeCtx) CreateEntity() core.EntityCreator

type ServiceCtx

+ func (ctx ServiceCtx) CreateEntityPT() core.EntityPTCreator

+ func (ctx ServiceCtx) CreateRuntime() framework.RuntimeCreator

Feb 20, 2024

Changes in this version

+ var ErrComponentNotWorking = errors.New("async/await: component not working")

type ServiceCtx

+ func (ctx ServiceCtx) GetMemKVs() *sync.Map

+ func (ctx ServiceCtx) GetStartupConf() *viper.Viper

Feb 18, 2024

Changes in this version

+ var ErrComponentIsDead = errors.New("async/await: component is dead")

+ var ErrDistEntityNodeNotFound = errors.New("rpc: distributed entity node not found")

+ var ErrDistEntityNotFound = errors.New("rpc: distributed entity not found")

+ func ReadChan[T any](cb *ComponentBehavior, ch <-chan T) runtime.AsyncRet

+ type AwaitDirector struct

+ func (ad AwaitDirector) All(fun generic.ActionVar1[[]runtime.Ret, any], va ...any)

+ func (ad AwaitDirector) Any(fun generic.ActionVar1[runtime.Ret, any], va ...any)

+ func (ad AwaitDirector) AnyOK(fun generic.ActionVar1[runtime.Ret, any], va ...any)

+ func (ad AwaitDirector) Pipe(fun generic.ActionVar1[runtime.Ret, any], va ...any)

+ type ComponentBehavior struct

+ func (c *ComponentBehavior) Async(fun generic.FuncVar0[any, runtime.Ret], va ...any) runtime.AsyncRet

+ func (c *ComponentBehavior) AsyncVoid(fun generic.ActionVar0[any], va ...any) runtime.AsyncRet

+ func (c *ComponentBehavior) Await(asyncRet ...runtime.AsyncRet) AwaitDirector

+ func (c *ComponentBehavior) BalanceOneWayRPC(service, comp, method string, args ...any) error

+ func (c *ComponentBehavior) BalanceRPC(service, comp, method string, args ...any) runtime.AsyncRet

+ func (c *ComponentBehavior) BroadcastOneWayRPC(service, comp, method string, args ...any) error

+ func (c *ComponentBehavior) GetRuntimeCtx() RuntimeCtx

+ func (c *ComponentBehavior) GetServiceCtx() ServiceCtx

+ func (c *ComponentBehavior) GlobalBalanceOneWayRPC(comp, method string, args ...any) error

+ func (c *ComponentBehavior) GlobalBalanceRPC(comp, method string, args ...any) runtime.AsyncRet

+ func (c *ComponentBehavior) GlobalBroadcastOneWayRPC(comp, method string, args ...any) error

+ func (c *ComponentBehavior) Go(fun generic.FuncVar0[any, runtime.Ret], va ...any) runtime.AsyncRet

+ func (c *ComponentBehavior) GoVoid(fun generic.ActionVar0[any], va ...any) runtime.AsyncRet

+ func (c *ComponentBehavior) OneWayRPC(service, comp, method string, args ...any) error

+ func (c *ComponentBehavior) RPC(service, comp, method string, args ...any) runtime.AsyncRet

+ func (c *ComponentBehavior) TimeAfter(dur time.Duration) runtime.AsyncRet

+ func (c *ComponentBehavior) TimeAt(at time.Time) runtime.AsyncRet

+ func (c *ComponentBehavior) TimeTick(dur time.Duration) runtime.AsyncRet

+ type EntityProxied struct

+ Context service.Context

+ Id uid.Id

+ func ProxyEntity(servCtx service.Context, id uid.Id) EntityProxied

+ func (ep EntityProxied) BalanceOneWayRPC(service, comp, method string, args ...any) error

+ func (ep EntityProxied) BalanceRPC(service, comp, method string, args ...any) runtime.AsyncRet

+ func (ep EntityProxied) BroadcastOneWayRPC(service, comp, method string, args ...any) error

+ func (ep EntityProxied) GlobalBalanceOneWayRPC(comp, method string, args ...any) error

+ func (ep EntityProxied) GlobalBalanceRPC(comp, method string, args ...any) runtime.AsyncRet

+ func (ep EntityProxied) GlobalBroadcastOneWayRPC(comp, method string, args ...any) error

+ func (ep EntityProxied) OneWayRPC(service, comp, method string, args ...any) error

+ func (ep EntityProxied) RPC(service, comp, method string, args ...any) runtime.AsyncRet

+ type RuntimeCtx struct

+ func (ctx RuntimeCtx) GetDistEntities() dent.IDistEntities

+ type ServiceCtx struct

+ func (ctx ServiceCtx) GetBroker() broker.IBroker

+ func (ctx ServiceCtx) GetConf() conf.IVisitConf

+ func (ctx ServiceCtx) GetDistEntityQuerier() dentq.IDistEntityQuerier

+ func (ctx ServiceCtx) GetDistService() dserv.IDistService

+ func (ctx ServiceCtx) GetDistSync() dsync.IDistSync

+ func (ctx ServiceCtx) GetRPC() rpc.IRPC

+ func (ctx ServiceCtx) GetRegistry() discovery.IRegistry