cluster

package
v1.6.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 28, 2024 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Interface 

type Interface struct {
	mock.Mock
}

Interface is an autogenerated mock type for the Interface type

func NewInterface 

func NewInterface(t interface {
	mock.TestingT
	Cleanup(func())
}) *Interface

NewInterface creates a new instance of Interface. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Interface) AdvertisedAddress 

func (_m *Interface) AdvertisedAddress() string

AdvertisedAddress provides a mock function with given fields:

func (*Interface) EXPECT 

func (_m *Interface) EXPECT() *Interface_Expecter

func (*Interface) Events 

func (_m *Interface) Events() <-chan *internalcluster.Event

Events provides a mock function with given fields:

func (*Interface) GetActor 

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

GetActor provides a mock function with given fields: ctx, actorName

func (*Interface) GetPartition 

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

GetPartition provides a mock function with given fields: actorName

func (*Interface) KeyExists 

func (_m *Interface) KeyExists(ctx context.Context, key string) (bool, error)

KeyExists provides a mock function with given fields: ctx, key

func (*Interface) NodeHost 

func (_m *Interface) NodeHost() string

NodeHost provides a mock function with given fields:

func (*Interface) NodeRemotingPort 

func (_m *Interface) NodeRemotingPort() int

NodeRemotingPort provides a mock function with given fields:

func (*Interface) PutActor 

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

PutActor provides a mock function with given fields: ctx, actor

func (*Interface) RemoveActor 

func (_m *Interface) RemoveActor(ctx context.Context, actorName string) error

RemoveActor provides a mock function with given fields: ctx, actorName

func (*Interface) SetKey 

func (_m *Interface) SetKey(ctx context.Context, key string) error

SetKey provides a mock function with given fields: ctx, key

func (*Interface) Start 

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

Start provides a mock function with given fields: ctx

func (*Interface) Stop 

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

Stop provides a mock function with given fields: ctx

type Interface_AdvertisedAddress_Call 

type Interface_AdvertisedAddress_Call struct {
	*mock.Call
}

Interface_AdvertisedAddress_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AdvertisedAddress'

func (*Interface_AdvertisedAddress_Call) Return 

func (_c *Interface_AdvertisedAddress_Call) Return(_a0 string) *Interface_AdvertisedAddress_Call

func (*Interface_AdvertisedAddress_Call) Run 

func (_c *Interface_AdvertisedAddress_Call) Run(run func()) *Interface_AdvertisedAddress_Call

func (*Interface_AdvertisedAddress_Call) RunAndReturn 

func (_c *Interface_AdvertisedAddress_Call) RunAndReturn(run func() string) *Interface_AdvertisedAddress_Call

type Interface_Events_Call 

type Interface_Events_Call struct {
	*mock.Call
}

Interface_Events_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Events'

func (*Interface_Events_Call) Return 

func (_c *Interface_Events_Call) Return(_a0 <-chan *internalcluster.Event) *Interface_Events_Call

func (*Interface_Events_Call) Run 

func (_c *Interface_Events_Call) Run(run func()) *Interface_Events_Call

func (*Interface_Events_Call) RunAndReturn 

func (_c *Interface_Events_Call) RunAndReturn(run func() <-chan *internalcluster.Event) *Interface_Events_Call

type Interface_Expecter 

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

func (*Interface_Expecter) AdvertisedAddress 

func (_e *Interface_Expecter) AdvertisedAddress() *Interface_AdvertisedAddress_Call

AdvertisedAddress is a helper method to define mock.On call

func (*Interface_Expecter) Events 

func (_e *Interface_Expecter) Events() *Interface_Events_Call

Events is a helper method to define mock.On call

func (*Interface_Expecter) GetActor 

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

GetActor is a helper method to define mock.On call

  • ctx context.Context
  • actorName string

func (*Interface_Expecter) GetPartition 

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

GetPartition is a helper method to define mock.On call

  • actorName string

func (*Interface_Expecter) KeyExists 

func (_e *Interface_Expecter) KeyExists(ctx interface{}, key interface{}) *Interface_KeyExists_Call

KeyExists is a helper method to define mock.On call

  • ctx context.Context
  • key string

func (*Interface_Expecter) NodeHost 

func (_e *Interface_Expecter) NodeHost() *Interface_NodeHost_Call

NodeHost is a helper method to define mock.On call

func (*Interface_Expecter) NodeRemotingPort 

func (_e *Interface_Expecter) NodeRemotingPort() *Interface_NodeRemotingPort_Call

NodeRemotingPort is a helper method to define mock.On call

func (*Interface_Expecter) PutActor 

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

PutActor is a helper method to define mock.On call

  • ctx context.Context
  • actor *internalpb.WireActor

func (*Interface_Expecter) RemoveActor 

func (_e *Interface_Expecter) RemoveActor(ctx interface{}, actorName interface{}) *Interface_RemoveActor_Call

RemoveActor is a helper method to define mock.On call

  • ctx context.Context
  • actorName string

func (*Interface_Expecter) SetKey 

func (_e *Interface_Expecter) SetKey(ctx interface{}, key interface{}) *Interface_SetKey_Call

SetKey is a helper method to define mock.On call

  • ctx context.Context
  • key string

func (*Interface_Expecter) Start 

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

Start is a helper method to define mock.On call

  • ctx context.Context

func (*Interface_Expecter) Stop 

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

Stop is a helper method to define mock.On call

  • ctx context.Context

type Interface_GetActor_Call 

type Interface_GetActor_Call struct {
	*mock.Call
}

Interface_GetActor_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetActor'

func (*Interface_GetActor_Call) Return 

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

func (*Interface_GetActor_Call) Run 

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

func (*Interface_GetActor_Call) RunAndReturn 

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

type Interface_GetPartition_Call 

type Interface_GetPartition_Call struct {
	*mock.Call
}

Interface_GetPartition_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetPartition'

func (*Interface_GetPartition_Call) Return 

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

func (*Interface_GetPartition_Call) Run 

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

func (*Interface_GetPartition_Call) RunAndReturn 

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

type Interface_KeyExists_Call 

type Interface_KeyExists_Call struct {
	*mock.Call
}

Interface_KeyExists_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'KeyExists'

func (*Interface_KeyExists_Call) Return 

func (_c *Interface_KeyExists_Call) Return(_a0 bool, _a1 error) *Interface_KeyExists_Call

func (*Interface_KeyExists_Call) Run 

func (_c *Interface_KeyExists_Call) Run(run func(ctx context.Context, key string)) *Interface_KeyExists_Call

func (*Interface_KeyExists_Call) RunAndReturn 

func (_c *Interface_KeyExists_Call) RunAndReturn(run func(context.Context, string) (bool, error)) *Interface_KeyExists_Call

type Interface_NodeHost_Call 

type Interface_NodeHost_Call struct {
	*mock.Call
}

Interface_NodeHost_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NodeHost'

func (*Interface_NodeHost_Call) Return 

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

func (*Interface_NodeHost_Call) Run 

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

func (*Interface_NodeHost_Call) RunAndReturn 

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

type Interface_NodeRemotingPort_Call 

type Interface_NodeRemotingPort_Call struct {
	*mock.Call
}

Interface_NodeRemotingPort_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NodeRemotingPort'

func (*Interface_NodeRemotingPort_Call) Return 

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

func (*Interface_NodeRemotingPort_Call) Run 

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

func (*Interface_NodeRemotingPort_Call) RunAndReturn 

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

type Interface_PutActor_Call 

type Interface_PutActor_Call struct {
	*mock.Call
}

Interface_PutActor_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PutActor'

func (*Interface_PutActor_Call) Return 

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

func (*Interface_PutActor_Call) Run 

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

func (*Interface_PutActor_Call) RunAndReturn 

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

type Interface_RemoveActor_Call 

type Interface_RemoveActor_Call struct {
	*mock.Call
}

Interface_RemoveActor_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RemoveActor'

func (*Interface_RemoveActor_Call) Return 

func (_c *Interface_RemoveActor_Call) Return(_a0 error) *Interface_RemoveActor_Call

func (*Interface_RemoveActor_Call) Run 

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

func (*Interface_RemoveActor_Call) RunAndReturn 

func (_c *Interface_RemoveActor_Call) RunAndReturn(run func(context.Context, string) error) *Interface_RemoveActor_Call

type Interface_SetKey_Call 

type Interface_SetKey_Call struct {
	*mock.Call
}

Interface_SetKey_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetKey'

func (*Interface_SetKey_Call) Return 

func (_c *Interface_SetKey_Call) Return(_a0 error) *Interface_SetKey_Call

func (*Interface_SetKey_Call) Run 

func (_c *Interface_SetKey_Call) Run(run func(ctx context.Context, key string)) *Interface_SetKey_Call

func (*Interface_SetKey_Call) RunAndReturn 

func (_c *Interface_SetKey_Call) RunAndReturn(run func(context.Context, string) error) *Interface_SetKey_Call

type Interface_Start_Call 

type Interface_Start_Call struct {
	*mock.Call
}

Interface_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'

func (*Interface_Start_Call) Return 

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

func (*Interface_Start_Call) Run 

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

func (*Interface_Start_Call) RunAndReturn 

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

type Interface_Stop_Call 

type Interface_Stop_Call struct {
	*mock.Call
}

Interface_Stop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Stop'

func (*Interface_Stop_Call) Return 

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

func (*Interface_Stop_Call) Run 

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

func (*Interface_Stop_Call) RunAndReturn 

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

type Option 

type Option struct {
	mock.Mock
}

Option is an autogenerated mock type for the Option type

func NewOption 

func NewOption(t interface {
	mock.TestingT
	Cleanup(func())
}) *Option

NewOption creates a new instance of Option. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Option) Apply 

func (_m *Option) Apply(cl *internalcluster.Node)

Apply provides a mock function with given fields: cl

func (*Option) EXPECT 

func (_m *Option) EXPECT() *Option_Expecter

type OptionFunc 

type OptionFunc struct {
	mock.Mock
}

OptionFunc is an autogenerated mock type for the OptionFunc type

func NewOptionFunc 

func NewOptionFunc(t interface {
	mock.TestingT
	Cleanup(func())
}) *OptionFunc

NewOptionFunc creates a new instance of OptionFunc. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*OptionFunc) EXPECT 

func (_m *OptionFunc) EXPECT() *OptionFunc_Expecter

func (*OptionFunc) Execute 

func (_m *OptionFunc) Execute(cl *internalcluster.Node)

Execute provides a mock function with given fields: cl

type OptionFunc_Execute_Call 

type OptionFunc_Execute_Call struct {
	*mock.Call
}

OptionFunc_Execute_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Execute'

func (*OptionFunc_Execute_Call) Return 

func (_c *OptionFunc_Execute_Call) Return() *OptionFunc_Execute_Call

func (*OptionFunc_Execute_Call) Run 

func (_c *OptionFunc_Execute_Call) Run(run func(cl *internalcluster.Node)) *OptionFunc_Execute_Call

func (*OptionFunc_Execute_Call) RunAndReturn 

func (_c *OptionFunc_Execute_Call) RunAndReturn(run func(*internalcluster.Node)) *OptionFunc_Execute_Call

type OptionFunc_Expecter 

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

func (*OptionFunc_Expecter) Execute 

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

Execute is a helper method to define mock.On call

  • cl *internalcluster.Node

type Option_Apply_Call 

type Option_Apply_Call struct {
	*mock.Call
}

Option_Apply_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Apply'

func (*Option_Apply_Call) Return 

func (_c *Option_Apply_Call) Return() *Option_Apply_Call

func (*Option_Apply_Call) Run 

func (_c *Option_Apply_Call) Run(run func(cl *internalcluster.Node)) *Option_Apply_Call

func (*Option_Apply_Call) RunAndReturn 

func (_c *Option_Apply_Call) RunAndReturn(run func(*internalcluster.Node)) *Option_Apply_Call

type Option_Expecter 

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

func (*Option_Expecter) Apply 

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

Apply is a helper method to define mock.On call

  • cl *internalcluster.Node

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.