cluster

package
v2.9.0 Latest Latest
Warning

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

 Go to latest Published: Nov 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) 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.ActorRef, 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) 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) 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.ActorRef) 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) SchedulerJobKeyExists added in v2.8.1 

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

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

func (*Interface) SetSchedulerJobKey added in v2.8.1 

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

SetSchedulerJobKey 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) UnsetSchedulerJobKey added in v2.8.1 

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

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

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) 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) 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) 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.ActorRef

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) SchedulerJobKeyExists added in v2.8.1 

func (_e *Interface_Expecter) SchedulerJobKeyExists(ctx interface{}, key interface{}) *Interface_SchedulerJobKeyExists_Call

SchedulerJobKeyExists is a helper method to define mock.On call

  • ctx context.Context
  • key string

func (*Interface_Expecter) SetSchedulerJobKey added in v2.8.1 

func (_e *Interface_Expecter) SetSchedulerJobKey(ctx interface{}, key interface{}) *Interface_SetSchedulerJobKey_Call

SetSchedulerJobKey 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) UnsetSchedulerJobKey added in v2.8.1 

func (_e *Interface_Expecter) UnsetSchedulerJobKey(ctx interface{}, key interface{}) *Interface_UnsetSchedulerJobKey_Call

UnsetSchedulerJobKey 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.ActorRef, _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.ActorRef, 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_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_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.ActorRef)) *Interface_PutActor_Call

func (*Interface_PutActor_Call) RunAndReturn 

func (_c *Interface_PutActor_Call) RunAndReturn(run func(context.Context, *internalpb.ActorRef) 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_SchedulerJobKeyExists_Call added in v2.8.1 

type Interface_SchedulerJobKeyExists_Call struct {
	*mock.Call
}

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

func (*Interface_SchedulerJobKeyExists_Call) Return added in v2.8.1 

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

func (*Interface_SchedulerJobKeyExists_Call) Run added in v2.8.1 

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

func (*Interface_SchedulerJobKeyExists_Call) RunAndReturn added in v2.8.1 

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

type Interface_SetSchedulerJobKey_Call added in v2.8.1 

type Interface_SetSchedulerJobKey_Call struct {
	*mock.Call
}

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

func (*Interface_SetSchedulerJobKey_Call) Return added in v2.8.1 

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

func (*Interface_SetSchedulerJobKey_Call) Run added in v2.8.1 

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

func (*Interface_SetSchedulerJobKey_Call) RunAndReturn added in v2.8.1 

func (_c *Interface_SetSchedulerJobKey_Call) RunAndReturn(run func(context.Context, string) error) *Interface_SetSchedulerJobKey_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_UnsetSchedulerJobKey_Call added in v2.8.1 

type Interface_UnsetSchedulerJobKey_Call struct {
	*mock.Call
}

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

func (*Interface_UnsetSchedulerJobKey_Call) Return added in v2.8.1 

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

func (*Interface_UnsetSchedulerJobKey_Call) Run added in v2.8.1 

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

func (*Interface_UnsetSchedulerJobKey_Call) RunAndReturn added in v2.8.1 

func (_c *Interface_UnsetSchedulerJobKey_Call) RunAndReturn(run func(context.Context, string) error) *Interface_UnsetSchedulerJobKey_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.