cluster

package
v2.2.0 Latest Latest
Warning

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

 Go to latest Published: Jun 16, 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) GetState added in v2.1.0 

func (_m *Interface) GetState(ctx context.Context, peerAddress string) (*internalpb.PeerState, error)

GetState provides a mock function with given fields: ctx, peerAddress

func (*Interface) Host added in v2.1.0 

func (_m *Interface) Host() string

Host provides a mock function with given fields:

func (*Interface) IsLeader added in v2.1.0 

func (_m *Interface) IsLeader(ctx context.Context) bool

IsLeader provides a mock function with given fields: ctx

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) Peers 

func (_m *Interface) Peers(ctx context.Context) ([]*internalcluster.Peer, error)

Peers provides a mock function with given fields: ctx

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) RemotingPort added in v2.1.0 

func (_m *Interface) RemotingPort() int

RemotingPort provides a mock function with given fields:

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

func (*Interface) UnsetKey added in v2.1.0 

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

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

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) GetState added in v2.1.0 

func (_e *Interface_Expecter) GetState(ctx interface{}, peerAddress interface{}) *Interface_GetState_Call

GetState is a helper method to define mock.On call

  • ctx context.Context
  • peerAddress string

func (*Interface_Expecter) Host added in v2.1.0 

func (_e *Interface_Expecter) Host() *Interface_Host_Call

Host is a helper method to define mock.On call

func (*Interface_Expecter) IsLeader added in v2.1.0 

func (_e *Interface_Expecter) IsLeader(ctx interface{}) *Interface_IsLeader_Call

IsLeader is a helper method to define mock.On call

  • ctx context.Context

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) Peers 

func (_e *Interface_Expecter) Peers(ctx interface{}) *Interface_Peers_Call

Peers is a helper method to define mock.On call

  • ctx context.Context

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) RemotingPort added in v2.1.0 

func (_e *Interface_Expecter) RemotingPort() *Interface_RemotingPort_Call

RemotingPort is a helper method to define mock.On call

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

func (*Interface_Expecter) UnsetKey added in v2.1.0 

func (_e *Interface_Expecter) UnsetKey(ctx interface{}, key interface{}) *Interface_UnsetKey_Call

UnsetKey is a helper method to define mock.On call

  • ctx context.Context
  • key string

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_GetState_Call added in v2.1.0 

type Interface_GetState_Call struct {
	*mock.Call
}

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

func (*Interface_GetState_Call) Return added in v2.1.0 

func (_c *Interface_GetState_Call) Return(_a0 *internalpb.PeerState, _a1 error) *Interface_GetState_Call

func (*Interface_GetState_Call) Run added in v2.1.0 

func (_c *Interface_GetState_Call) Run(run func(ctx context.Context, peerAddress string)) *Interface_GetState_Call

func (*Interface_GetState_Call) RunAndReturn added in v2.1.0 

func (_c *Interface_GetState_Call) RunAndReturn(run func(context.Context, string) (*internalpb.PeerState, error)) *Interface_GetState_Call

type Interface_Host_Call added in v2.1.0 

type Interface_Host_Call struct {
	*mock.Call
}

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

func (*Interface_Host_Call) Return added in v2.1.0 

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

func (*Interface_Host_Call) Run added in v2.1.0 

func (_c *Interface_Host_Call) Run(run func()) *Interface_Host_Call

func (*Interface_Host_Call) RunAndReturn added in v2.1.0 

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

type Interface_IsLeader_Call added in v2.1.0 

type Interface_IsLeader_Call struct {
	*mock.Call
}

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

func (*Interface_IsLeader_Call) Return added in v2.1.0 

func (_c *Interface_IsLeader_Call) Return(_a0 bool) *Interface_IsLeader_Call

func (*Interface_IsLeader_Call) Run added in v2.1.0 

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

func (*Interface_IsLeader_Call) RunAndReturn added in v2.1.0 

func (_c *Interface_IsLeader_Call) RunAndReturn(run func(context.Context) bool) *Interface_IsLeader_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_Peers_Call 

type Interface_Peers_Call struct {
	*mock.Call
}

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

func (*Interface_Peers_Call) Return 

func (_c *Interface_Peers_Call) Return(_a0 []*internalcluster.Peer, _a1 error) *Interface_Peers_Call

func (*Interface_Peers_Call) Run 

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

func (*Interface_Peers_Call) RunAndReturn 

func (_c *Interface_Peers_Call) RunAndReturn(run func(context.Context) ([]*internalcluster.Peer, error)) *Interface_Peers_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_RemotingPort_Call added in v2.1.0 

type Interface_RemotingPort_Call struct {
	*mock.Call
}

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

func (*Interface_RemotingPort_Call) Return added in v2.1.0 

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

func (*Interface_RemotingPort_Call) Run added in v2.1.0 

func (_c *Interface_RemotingPort_Call) Run(run func()) *Interface_RemotingPort_Call

func (*Interface_RemotingPort_Call) RunAndReturn added in v2.1.0 

func (_c *Interface_RemotingPort_Call) RunAndReturn(run func() int) *Interface_RemotingPort_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 Interface_UnsetKey_Call added in v2.1.0 

type Interface_UnsetKey_Call struct {
	*mock.Call
}

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

func (*Interface_UnsetKey_Call) Return added in v2.1.0 

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

func (*Interface_UnsetKey_Call) Run added in v2.1.0 

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

func (*Interface_UnsetKey_Call) RunAndReturn added in v2.1.0 

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

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.