cluster

Sep 7, 2023

Changes in this version

+ type Interface struct

+ func NewInterface(t interface{ ... }) *Interface

+ func (_m *Interface) EXPECT() *Interface_Expecter

+ func (_m *Interface) GetActor(ctx context.Context, actorName string) (*goaktv1.WireActor, error)

+ func (_m *Interface) GetPartition(actorName string) int

+ func (_m *Interface) NodeHost() string

+ func (_m *Interface) NodeRemotingPort() int

+ func (_m *Interface) PutActor(ctx context.Context, actor *goaktv1.WireActor) error

+ func (_m *Interface) Start(ctx context.Context) error

+ func (_m *Interface) Stop(ctx context.Context) error

+ type Interface_Expecter struct

+ func (_e *Interface_Expecter) GetActor(ctx interface{}, actorName interface{}) *Interface_GetActor_Call

+ func (_e *Interface_Expecter) GetPartition(actorName interface{}) *Interface_GetPartition_Call

+ func (_e *Interface_Expecter) NodeHost() *Interface_NodeHost_Call

+ func (_e *Interface_Expecter) NodeRemotingPort() *Interface_NodeRemotingPort_Call

+ func (_e *Interface_Expecter) PutActor(ctx interface{}, actor interface{}) *Interface_PutActor_Call

+ func (_e *Interface_Expecter) Start(ctx interface{}) *Interface_Start_Call

+ func (_e *Interface_Expecter) Stop(ctx interface{}) *Interface_Stop_Call

+ type Interface_GetActor_Call struct

+ func (_c *Interface_GetActor_Call) Return(_a0 *goaktv1.WireActor, _a1 error) *Interface_GetActor_Call

+ func (_c *Interface_GetActor_Call) Run(run func(ctx context.Context, actorName string)) *Interface_GetActor_Call

+ func (_c *Interface_GetActor_Call) RunAndReturn(run func(context.Context, string) (*goaktv1.WireActor, error)) *Interface_GetActor_Call

+ type Interface_GetPartition_Call struct

+ func (_c *Interface_GetPartition_Call) Return(_a0 int) *Interface_GetPartition_Call

+ func (_c *Interface_GetPartition_Call) Run(run func(actorName string)) *Interface_GetPartition_Call

+ func (_c *Interface_GetPartition_Call) RunAndReturn(run func(string) int) *Interface_GetPartition_Call

+ type Interface_NodeHost_Call struct

+ func (_c *Interface_NodeHost_Call) Return(_a0 string) *Interface_NodeHost_Call

+ func (_c *Interface_NodeHost_Call) Run(run func()) *Interface_NodeHost_Call

+ func (_c *Interface_NodeHost_Call) RunAndReturn(run func() string) *Interface_NodeHost_Call

+ type Interface_NodeRemotingPort_Call struct

+ func (_c *Interface_NodeRemotingPort_Call) Return(_a0 int) *Interface_NodeRemotingPort_Call

+ func (_c *Interface_NodeRemotingPort_Call) Run(run func()) *Interface_NodeRemotingPort_Call

+ func (_c *Interface_NodeRemotingPort_Call) RunAndReturn(run func() int) *Interface_NodeRemotingPort_Call

+ type Interface_PutActor_Call struct

+ func (_c *Interface_PutActor_Call) Return(_a0 error) *Interface_PutActor_Call

+ func (_c *Interface_PutActor_Call) Run(run func(ctx context.Context, actor *goaktv1.WireActor)) *Interface_PutActor_Call

+ func (_c *Interface_PutActor_Call) RunAndReturn(run func(context.Context, *goaktv1.WireActor) error) *Interface_PutActor_Call

+ type Interface_Start_Call struct

+ func (_c *Interface_Start_Call) Return(_a0 error) *Interface_Start_Call

+ func (_c *Interface_Start_Call) Run(run func(ctx context.Context)) *Interface_Start_Call

+ func (_c *Interface_Start_Call) RunAndReturn(run func(context.Context) error) *Interface_Start_Call

+ type Interface_Stop_Call struct

+ func (_c *Interface_Stop_Call) Return(_a0 error) *Interface_Stop_Call

+ func (_c *Interface_Stop_Call) Run(run func(ctx context.Context)) *Interface_Stop_Call

+ func (_c *Interface_Stop_Call) RunAndReturn(run func(context.Context) error) *Interface_Stop_Call

+ type Option struct

+ func NewOption(t interface{ ... }) *Option

+ func (_m *Option) Apply(cl *goaktcluster.Cluster)

+ func (_m *Option) EXPECT() *Option_Expecter

+ type OptionFunc struct

+ func NewOptionFunc(t interface{ ... }) *OptionFunc

+ func (_m *OptionFunc) EXPECT() *OptionFunc_Expecter

+ func (_m *OptionFunc) Execute(cl *goaktcluster.Cluster)

+ type OptionFunc_Execute_Call struct

+ func (_c *OptionFunc_Execute_Call) Return() *OptionFunc_Execute_Call

+ func (_c *OptionFunc_Execute_Call) Run(run func(cl *goaktcluster.Cluster)) *OptionFunc_Execute_Call

+ func (_c *OptionFunc_Execute_Call) RunAndReturn(run func(*goaktcluster.Cluster)) *OptionFunc_Execute_Call

+ type OptionFunc_Expecter struct

+ func (_e *OptionFunc_Expecter) Execute(cl interface{}) *OptionFunc_Execute_Call

+ type Option_Apply_Call struct

+ func (_c *Option_Apply_Call) Return() *Option_Apply_Call

+ func (_c *Option_Apply_Call) Run(run func(cl *goaktcluster.Cluster)) *Option_Apply_Call

+ func (_c *Option_Apply_Call) RunAndReturn(run func(*goaktcluster.Cluster)) *Option_Apply_Call

+ type Option_Expecter struct

+ func (_e *Option_Expecter) Apply(cl interface{}) *Option_Apply_Call