framework

Nov 5, 2024

Changes in this version

type ConcurrentEntityCreator

+ func (c ConcurrentEntityCreator) ComponentAwakeOnFirstTouch(b bool) ConcurrentEntityCreator

+ func (c ConcurrentEntityCreator) ComponentUniqueID(b bool) ConcurrentEntityCreator

Oct 27, 2024

Changes in this version

+ var ErrFramework = errors.New("framework")

Sep 28, 2024

Changes in this version

type RuntimeGeneric

+ func (r *RuntimeGeneric) OnEntityMgrAddEntity(entityMgr runtime.EntityMgr, entity ec.Entity)

+ func (r *RuntimeGeneric) OnEntityMgrEntityAddComponents(entityMgr runtime.EntityMgr, entity ec.Entity, components []ec.Component)

Aug 30, 2024

Changes in this version

type ComponentBehavior

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

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

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

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

+ func (c *ComponentBehavior) GlobalBalanceOnewayRPC(excludeSelf bool, comp, method string, args ...any) error

+ func (c *ComponentBehavior) GlobalBroadcastOnewayRPC(excludeSelf bool, comp, method string, args ...any) error

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

type ConcurrentEntityCreator

+ func (c ConcurrentEntityCreator) Instance(composite ec.Entity) ConcurrentEntityCreator

+ func (c ConcurrentEntityCreator) InstanceFace(face iface.Face[ec.Entity]) ConcurrentEntityCreator

type EntityBehavior

+ func (e *EntityBehavior) BalanceOnewayRPC(service, comp, method string, args ...any) error

+ func (e *EntityBehavior) BroadcastCliOnewayRPC(proc, method string, args ...any) error

+ func (e *EntityBehavior) BroadcastOnewayRPC(excludeSelf bool, service, comp, method string, args ...any) error

+ func (e *EntityBehavior) CliOnewayRPC(proc, method string, args ...any) error

+ func (e *EntityBehavior) GlobalBalanceOnewayRPC(excludeSelf bool, comp, method string, args ...any) error

+ func (e *EntityBehavior) GlobalBroadcastOnewayRPC(excludeSelf bool, comp, method string, args ...any) error

+ func (e *EntityBehavior) OnewayRPC(service, comp, method string, args ...any) error

Aug 20, 2024

Changes in this version

type ComponentBehavior

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

type EntityBehavior

+ func (e *EntityBehavior) OneWayCliRPCToGroups(method string, args ...any) error

Aug 16, 2024

Changes in this version

type RuntimeGenericT

+ func NewRuntimeGenericT[T any]() *RuntimeGenericT[T]

type ServiceGenericT

+ func NewServiceGenericT[T any]() *ServiceGenericT[T]

Aug 12, 2024

Changes in this version

type App

+ func (app *App) InitFlags(fun generic.DelegateAction1[*cobra.Command]) *App

Jun 16, 2024

Changes in this version

type RuntimeCreator

+ func (c RuntimeCreator) PersistId(id uid.Id) RuntimeCreator

Jun 6, 2024

Changes in this version

type IRuntimeInstance

+ func GetRuntimeInstance(provider runtime.CurrentContextProvider) IRuntimeInstance

type IServiceInstance

+ func GetServiceInstance(provider runtime.ConcurrentContextProvider) IServiceInstance

Jun 1, 2024

Changes in this version

type IRuntimeInstance

+ CreateEntity func(prototype string) core.EntityCreator

+ GetDistEntityRegistry func() dentr.IDistEntityRegistry

+ GetRPCStack func() rpcstack.IRPCStack

+ GetService func() IServiceInstance

type IServiceInstance

+ CreateConcurrentEntity func(prototype string) ConcurrentEntityCreator

+ CreateEntityPT func(prototype string) core.EntityPTCreator

+ CreateRuntime func() RuntimeCreator

+ GetBroker func() broker.IBroker

+ GetConf func() conf.IConfig

+ GetDistEntityQuerier func() dentq.IDistEntityQuerier

+ GetDistService func() dserv.IDistService

+ GetDistSync func() dsync.IDistSync

+ GetMemKV func() *sync.Map

+ GetRPC func() rpc.IRPC

+ GetRegistry func() discovery.IRegistry

+ GetStartupConf func() *viper.Viper

+ GetStartupNo func() int

+ type InstallRuntimeDistEntityRegistry interface

+ InstallDistEntityRegistry func(inst IRuntimeInstance)

type RuntimeGeneric

+ func (r *RuntimeGeneric) GetService() IServiceInstance

type RuntimeInstance

+ func (inst *RuntimeInstance) GetDistEntityRegistry() dentr.IDistEntityRegistry

+ func (inst *RuntimeInstance) GetRPCStack() rpcstack.IRPCStack

+ func (inst *RuntimeInstance) GetService() IServiceInstance

May 30, 2024

Changes in this version

type ComponentBehavior

+ func (c *ComponentBehavior) GetPluginBundle() plugin.PluginBundle

type EntityBehavior

+ func (e *EntityBehavior) GetPluginBundle() plugin.PluginBundle

May 29, 2024

Changes in this version

type Runtime

+ func (rt Runtime) GetDistEntityRegistry() dentr.IDistEntityRegistry

type Service

+ func (serv Service) CreateConcurrentEntity(prototype string) ConcurrentEntityCreator

May 28, 2024

Changes in this version

+ var CreateEntityPT = core.CreateEntityPT

+ type ConcurrentEntityCreator struct

+ func CreateConcurrentEntity(ctx service.Context, prototype string) ConcurrentEntityCreator

+ func (c ConcurrentEntityCreator) AwakeOnFirstAccess(b bool) ConcurrentEntityCreator

+ func (c ConcurrentEntityCreator) Composite(composite ec.Entity) ConcurrentEntityCreator

+ func (c ConcurrentEntityCreator) CompositeFace(face iface.Face[ec.Entity]) ConcurrentEntityCreator

+ func (c ConcurrentEntityCreator) Meta(m ec.Meta) ConcurrentEntityCreator

+ func (c ConcurrentEntityCreator) ParentId(id uid.Id) ConcurrentEntityCreator

+ func (c ConcurrentEntityCreator) PersistId(id uid.Id) ConcurrentEntityCreator

+ func (c ConcurrentEntityCreator) Runtime(rt core.Runtime) ConcurrentEntityCreator

+ func (c ConcurrentEntityCreator) RuntimeCreator(rtCreator RuntimeCreator) ConcurrentEntityCreator

+ func (c ConcurrentEntityCreator) Scope(scope ec.Scope) ConcurrentEntityCreator

+ func (c ConcurrentEntityCreator) Spawn() (ec.ConcurrentEntity, error)

+ func (c ConcurrentEntityCreator) SpawnAsync() async.AsyncRetT[ec.ConcurrentEntity]

+ type EntityPTCreator = core.EntityPTCreator

type ServiceInstance

+ func (inst *ServiceInstance) CreateConcurrentEntity(prototype string) ConcurrentEntityCreator

May 26, 2024

Changes in this version

+ var ErrComponentNotAlive = errors.New("async/await: component not alive")

+ var ErrEntityNotAlive = errors.New("async/await: entity not alive")

type ComponentBehavior

+ func (c *ComponentBehavior) IsAlive() bool

+ type EntityBehavior struct

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

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

+ func (e *EntityBehavior) Await(asyncRet ...runtime.AsyncRet) AwaitDirector

+ func (e *EntityBehavior) BalanceOneWayRPC(service, comp, method string, args ...any) error

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

+ func (e *EntityBehavior) BroadcastOneWayRPC(excludeSelf bool, service, comp, method string, args ...any) error

+ func (e *EntityBehavior) CliRPC(method string, args ...any) runtime.AsyncRet

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

+ func (e *EntityBehavior) GetRuntime() Runtime

+ func (e *EntityBehavior) GetService() Service

+ func (e *EntityBehavior) GlobalBalanceOneWayRPC(comp, method string, args ...any) error

+ func (e *EntityBehavior) GlobalBalanceRPC(comp, method string, args ...any) runtime.AsyncRet

+ func (e *EntityBehavior) GlobalBroadcastOneWayRPC(excludeSelf bool, comp, method string, args ...any) error

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

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

+ func (e *EntityBehavior) IsAlive() bool

+ func (e *EntityBehavior) OneWayCliRPC(method string, args ...any) error

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

+ func (e *EntityBehavior) OneWayRPC(service, comp, method string, args ...any) error

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

+ func (e *EntityBehavior) TimeAfter(dur time.Duration) runtime.AsyncRet

+ func (e *EntityBehavior) TimeAt(at time.Time) runtime.AsyncRet

+ func (e *EntityBehavior) TimeTick(dur time.Duration) runtime.AsyncRet

May 24, 2024

Changes in this version

type App

+ func (app *App) GetWholeConf() *viper.Viper

type ServiceGeneric

+ func (s *ServiceGeneric) GetWholeConf() *viper.Viper

type ServiceInstance

+ func (inst *ServiceInstance) GetWholeConf() *viper.Viper

May 24, 2024

Changes in this version

type RuntimeGeneric

+ func (r *RuntimeGeneric) GetMemKV() *sync.Map

type RuntimeInstance

+ func (inst *RuntimeInstance) GetMemKV() *sync.Map

type Service

+ func (serv Service) GetMemKV() *sync.Map

+ func (serv Service) GetStartupNo() int

type ServiceInstance

+ func (inst *ServiceInstance) GetMemKV() *sync.Map

+ func (inst *ServiceInstance) GetStartupNo() int

May 24, 2024

Changes in this version

+ type InstallRuntimeRPCStack interface

+ InstallRPCStack func(ctx runtime.Context)

type Runtime

+ func (rt Runtime) GetRPCStack() rpcstack.IRPCStack

May 20, 2024

Changes in this version

+ type RuntimeGenericT struct

+ func (r *RuntimeGenericT[T]) Instantiation() runtime.Context

+ type ServiceGenericT struct

+ func (s *ServiceGenericT[T]) Instantiation() service.Context

May 10, 2024

Changes in this version

+ var ErrComponentNotLiving = errors.New("async/await: component not living")

+ 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(ctx context.Context, 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) CliRPC(method string, args ...any) runtime.AsyncRet

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

+ func (c *ComponentBehavior) GetRuntime() Runtime

+ func (c *ComponentBehavior) GetService() Service

+ 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) OneWayCliRPC(method string, args ...any) error

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

+ 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 Runtime struct

+ Ctx runtime.Context

+ func (rt Runtime) CreateEntity() core.EntityCreator

+ func (rt Runtime) GetDistEntities() dent.IDistEntities

+ type Service struct

+ Ctx service.Context

+ func (serv Service) CreateEntityPT() core.EntityPTCreator

+ func (serv Service) CreateRuntime() RuntimeCreator

+ func (serv Service) GetBroker() broker.IBroker

+ func (serv Service) GetConf() conf.IVisitConf

+ func (serv Service) GetDistEntityQuerier() dentq.IDistEntityQuerier

+ func (serv Service) GetDistService() dserv.IDistService

+ func (serv Service) GetDistSync() dsync.IDistSync

+ func (serv Service) GetMemKVs() *sync.Map

+ func (serv Service) GetRPC() rpc.IRPC

+ func (serv Service) GetRegistry() discovery.IRegistry

+ func (serv Service) GetStartupConf() *viper.Viper

Apr 21, 2024

Changes in this version

type ServiceInstance

+ func (instance *ServiceInstance) GetStartupIdx() int

Apr 20, 2024

Changes in this version

+ type IRuntimeInstantiation interface

+ Instantiation func() runtime.Context

+ type IServiceInstantiation interface

+ Instantiation func() service.Context

+ type LifecycleRuntimeBuilt interface

+ Built func(ctx runtime.Context)

+ type LifecycleServiceBuilt interface

+ Built func(ctx service.Context)

+ type RuntimeInstance struct

+ func (instance *RuntimeInstance) CreateEntity() core.EntityCreator

+ func (instance *RuntimeInstance) GetMemKVs() *sync.Map

+ func (instance *RuntimeInstance) GetStartupConf() *viper.Viper

+ type ServiceInstance struct

+ func (instance *ServiceInstance) CreateEntityPT() core.EntityPTCreator

+ func (instance *ServiceInstance) CreateRuntime() RuntimeCreator

+ func (instance *ServiceInstance) GetBroker() broker.IBroker

+ func (instance *ServiceInstance) GetConf() conf.IVisitConf

+ func (instance *ServiceInstance) GetDistEntityQuerier() dentq.IDistEntityQuerier

+ func (instance *ServiceInstance) GetDistService() dserv.IDistService

+ func (instance *ServiceInstance) GetDistSync() dsync.IDistSync

+ func (instance *ServiceInstance) GetMemKVs() *sync.Map

+ func (instance *ServiceInstance) GetRPC() rpc.IRPC

+ func (instance *ServiceInstance) GetRegistry() discovery.IRegistry

+ func (instance *ServiceInstance) GetStartupConf() *viper.Viper

Mar 30, 2024

Changes in this version

+ type IRuntimeInstance interface

+ Instance func() runtime.Context

+ type IServiceInstance interface

+ Instance func() service.Context

+ type RuntimeGeneric struct

+ func (r *RuntimeGeneric) GetMemKVs() *sync.Map

+ func (r *RuntimeGeneric) GetServiceCtx() service.Context

+ func (r *RuntimeGeneric) GetStartupConf() *viper.Viper

+ type ServiceGeneric struct

+ func (s *ServiceGeneric) GetName() string

+ func (s *ServiceGeneric) GetStartupConf() *viper.Viper

Mar 18, 2024

Changes in this version

type App

+ func (app *App) TerminateCB(cb generic.DelegateAction1[*App]) *App

Mar 10, 2024

Changes in this version

+ type LifecycleRuntimeContextBirth interface

+ Birth func()

+ type LifecycleRuntimeContextFrameLoopBegin interface

+ FrameLoopBegin func()

+ type LifecycleRuntimeContextFrameLoopEnd interface

+ FrameLoopEnd func()

+ type LifecycleRuntimeContextFrameUpdateBegin interface

+ FrameUpdateBegin func()

+ type LifecycleRuntimeContextFrameUpdateEnd interface

+ FrameUpdateEnd func()

+ type LifecycleRuntimeContextInit interface

+ Init func()

+ type LifecycleRuntimeContextRunCallBegin interface

+ RunCallBegin func()

+ type LifecycleRuntimeContextRunCallEnd interface

+ RunCallEnd func()

+ type LifecycleRuntimeContextRunGCBegin interface

+ RunGCBegin func()

+ type LifecycleRuntimeContextRunGCEnd interface

+ RunGCEnd func()

+ type LifecycleRuntimeContextStarted interface

+ Started func()

+ type LifecycleRuntimeContextStarting interface

+ Starting func()

+ type LifecycleRuntimeContextTerminated interface

+ Terminated func()

+ type LifecycleRuntimeContextTerminating interface

+ Terminating func()

+ type LifecycleServiceContextBirth interface

+ Birth func()

+ type LifecycleServiceContextInit interface

+ Init func()

+ type LifecycleServiceContextStarted interface

+ Started func()

+ type LifecycleServiceContextStarting interface

+ Starting func()

+ type LifecycleServiceContextTerminated interface

+ Terminated func()

+ type LifecycleServiceContextTerminating interface

+ Terminating func()

+ type SetupRuntimeContextComposite interface

+ MakeContextComposite func() runtime.Context

+ type SetupServiceContextComposite interface

+ MakeContextComposite func() service.Context

Feb 20, 2024

Changes in this version

type RuntimeCreator

+ func (c RuntimeCreator) FPS(fps float32) RuntimeCreator

+ func (c RuntimeCreator) PanicHandling(autoRecover bool, reportError chan error) RuntimeCreator

Feb 18, 2024

Changes in this version

+ type App struct

+ func NewApp() *App

+ func (app *App) GetStartupConf() *viper.Viper

+ func (app *App) InitCB(cb generic.DelegateAction1[*App]) *App

+ func (app *App) Run()

+ func (app *App) Setup(name string, serv any, num ...int) *App

+ func (app *App) StartingCB(cb generic.DelegateAction1[*App]) *App

+ func (app *App) StoppedCB(cb generic.DelegateAction1[*App]) *App

+ type InstallRuntimeDistEntities interface

+ InstallDistEntities func(ctx runtime.Context)

+ type InstallRuntimeLogger interface

+ InstallLogger func(ctx runtime.Context)

+ type InstallServiceBroker interface

+ InstallBroker func(ctx service.Context)

+ type InstallServiceConfig interface

+ InstallConfig func(ctx service.Context)

+ type InstallServiceDistEntityQuerier interface

+ InstallDistEntityQuerier func(ctx service.Context)

+ type InstallServiceDistService interface

+ InstallDistService func(ctx service.Context)

+ type InstallServiceDistSync interface

+ InstallDistSync func(ctx service.Context)

+ type InstallServiceLogger interface

+ InstallLogger func(ctx service.Context)

+ type InstallServiceRPC interface

+ InstallRPC func(ctx service.Context)

+ type InstallServiceRegistry interface

+ InstallRegistry func(ctx service.Context)

+ type LifecycleRuntimeBirth interface

+ Birth func(ctx runtime.Context)

+ type LifecycleRuntimeFrameLoopBegin interface

+ FrameLoopBegin func(ctx runtime.Context)

+ type LifecycleRuntimeFrameLoopEnd interface

+ FrameLoopEnd func(ctx runtime.Context)

+ type LifecycleRuntimeFrameUpdateBegin interface

+ FrameUpdateBegin func(ctx runtime.Context)

+ type LifecycleRuntimeFrameUpdateEnd interface

+ FrameUpdateEnd func(ctx runtime.Context)

+ type LifecycleRuntimeInit interface

+ Init func(ctx runtime.Context)

+ type LifecycleRuntimeRunCallBegin interface

+ RunCallBegin func(ctx runtime.Context)

+ type LifecycleRuntimeRunCallEnd interface

+ RunCallEnd func(ctx runtime.Context)

+ type LifecycleRuntimeRunGCBegin interface

+ RunGCBegin func(ctx runtime.Context)

+ type LifecycleRuntimeRunGCEnd interface

+ RunGCEnd func(ctx runtime.Context)

+ type LifecycleRuntimeStarted interface

+ Started func(ctx runtime.Context)

+ type LifecycleRuntimeStarting interface

+ Starting func(ctx runtime.Context)

+ type LifecycleRuntimeTerminated interface

+ Terminated func(ctx runtime.Context)

+ type LifecycleRuntimeTerminating interface

+ Terminating func(ctx runtime.Context)

+ type LifecycleServiceBirth interface

+ Birth func(ctx service.Context)

+ type LifecycleServiceInit interface

+ Init func(ctx service.Context)

+ type LifecycleServiceStarted interface

+ Started func(ctx service.Context)

+ type LifecycleServiceStarting interface

+ Starting func(ctx service.Context)

+ type LifecycleServiceTerminated interface

+ Terminated func(ctx service.Context)

+ type LifecycleServiceTerminating interface

+ Terminating func(ctx service.Context)

+ type RuntimeBehavior struct

+ func (rb *RuntimeBehavior) GetMemKVs() *sync.Map

+ func (rb *RuntimeBehavior) GetServiceCtx() service.Context

+ func (rb *RuntimeBehavior) GetStartupConf() *viper.Viper

+ type RuntimeCreator struct

+ func CreateRuntime(ctx service.Context) *RuntimeCreator

+ func (c *RuntimeCreator) AutoRun(auto bool) *RuntimeCreator

+ func (c *RuntimeCreator) ErrorHandling(autoRecover bool, reportError chan error) *RuntimeCreator

+ func (c *RuntimeCreator) Frames(fps float32, blink bool) *RuntimeCreator

+ func (c *RuntimeCreator) Name(name string) *RuntimeCreator

+ func (c *RuntimeCreator) ProcessQueueCapacity(cap int) *RuntimeCreator

+ func (c *RuntimeCreator) Setup(rt any) *RuntimeCreator

+ func (c *RuntimeCreator) Spawn() core.Runtime

+ type ServiceBehavior struct

+ func (sb *ServiceBehavior) GetName() string

+ func (sb *ServiceBehavior) GetStartupConf() *viper.Viper