mocks

package
v0.1.3 Latest Latest
Warning

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

 Go to latest Published: Aug 31, 2026 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Store 

type Store struct {
	mock.Mock
}

Store is an autogenerated mock type for the Store type

func NewStore 

func NewStore(t interface {
	mock.TestingT
	Cleanup(func())
}) *Store

NewStore creates a new instance of Store. 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 (*Store) AddNode 

func (_mock *Store) AddNode(context1 context.Context, addNodeOptions *types.AddNodeOptions) (*types.Node, error)

AddNode provides a mock function for the type Store

func (*Store) AddPod 

func (_mock *Store) AddPod(ctx context.Context, name string, desc string) (*types.Pod, error)

AddPod provides a mock function for the type Store

func (*Store) AddWorkload 

func (_mock *Store) AddWorkload(context1 context.Context, workload *types.Workload, processing *types.Processing) error

AddWorkload provides a mock function for the type Store

func (*Store) CreateLock 

func (_mock *Store) CreateLock(key string, ttl time.Duration) (lock.DistributedLock, error)

CreateLock provides a mock function for the type Store

func (*Store) CreateProcessing 

func (_mock *Store) CreateProcessing(ctx context.Context, process *types.Processing, count int) error

CreateProcessing provides a mock function for the type Store

func (*Store) Delete added in v0.1.1 

func (_mock *Store) Delete(ctx context.Context, keys []string) error

Delete provides a mock function for the type Store

func (*Store) DeleteProcessing 

func (_mock *Store) DeleteProcessing(context1 context.Context, processing *types.Processing) error

DeleteProcessing provides a mock function for the type Store

func (*Store) EXPECT 

func (_m *Store) EXPECT() *Store_Expecter

func (*Store) GetAllPods 

func (_mock *Store) GetAllPods(ctx context.Context) ([]*types.Pod, error)

GetAllPods provides a mock function for the type Store

func (*Store) GetDeployStatus 

func (_mock *Store) GetDeployStatus(ctx context.Context, appname string, entryname string) (map[string]int, error)

GetDeployStatus provides a mock function for the type Store

func (*Store) GetNode 

func (_mock *Store) GetNode(ctx context.Context, nodename string) (*types.Node, error)

GetNode provides a mock function for the type Store

func (*Store) GetNodeStatus 

func (_mock *Store) GetNodeStatus(ctx context.Context, nodename string) (*types.NodeStatus, error)

GetNodeStatus provides a mock function for the type Store

func (*Store) GetNodes 

func (_mock *Store) GetNodes(ctx context.Context, nodenames []string) ([]*types.Node, error)

GetNodes provides a mock function for the type Store

func (*Store) GetNodesByPod 

func (_mock *Store) GetNodesByPod(ctx context.Context, nodeFilter *types.NodeFilter, withoutEngine bool) ([]*types.Node, error)

GetNodesByPod provides a mock function for the type Store

func (*Store) GetPod 

func (_mock *Store) GetPod(ctx context.Context, podname string) (*types.Pod, error)

GetPod provides a mock function for the type Store

func (*Store) GetPrefix added in v0.1.1 

func (_mock *Store) GetPrefix(ctx context.Context, prefix string, limit int64) (map[string]string, error)

GetPrefix provides a mock function for the type Store

func (*Store) GetServiceStatus added in v0.1.1 

func (_mock *Store) GetServiceStatus(context1 context.Context) ([]string, error)

GetServiceStatus provides a mock function for the type Store

func (*Store) GetWorkload 

func (_mock *Store) GetWorkload(ctx context.Context, ID string) (*types.Workload, error)

GetWorkload provides a mock function for the type Store

func (*Store) GetWorkloadStatus 

func (_mock *Store) GetWorkloadStatus(ctx context.Context, ID string) (*types.StatusMeta, error)

GetWorkloadStatus provides a mock function for the type Store

func (*Store) GetWorkloads 

func (_mock *Store) GetWorkloads(ctx context.Context, IDs []string) ([]*types.Workload, error)

GetWorkloads provides a mock function for the type Store

func (*Store) ListNodeWorkloads 

func (_mock *Store) ListNodeWorkloads(ctx context.Context, nodename string, labels map[string]string) ([]*types.Workload, error)

ListNodeWorkloads provides a mock function for the type Store

func (*Store) ListPrefix added in v0.1.1 

func (_mock *Store) ListPrefix(ctx context.Context, prefix string) ([]string, error)

ListPrefix provides a mock function for the type Store

func (*Store) ListWorkloads 

func (_mock *Store) ListWorkloads(ctx context.Context, appname string, entrypoint string, nodename string, limit int64, labels map[string]string) ([]*types.Workload, error)

ListWorkloads provides a mock function for the type Store

func (*Store) NodeStatusStream 

func (_mock *Store) NodeStatusStream(ctx context.Context) chan *types.NodeStatus

NodeStatusStream provides a mock function for the type Store

func (*Store) NotFound added in v0.1.1 

func (_mock *Store) NotFound(err error) bool

NotFound provides a mock function for the type Store

func (*Store) Put added in v0.1.1 

func (_mock *Store) Put(ctx context.Context, data map[string]string) error

Put provides a mock function for the type Store

func (*Store) RegisterService 

func (_mock *Store) RegisterService(context1 context.Context, s string, duration time.Duration) (<-chan struct{}, func(), error)

RegisterService provides a mock function for the type Store

func (*Store) RemoveNode 

func (_mock *Store) RemoveNode(ctx context.Context, node *types.Node) error

RemoveNode provides a mock function for the type Store

func (*Store) RemovePod 

func (_mock *Store) RemovePod(ctx context.Context, podname string) error

RemovePod provides a mock function for the type Store

func (*Store) RemoveWorkload 

func (_mock *Store) RemoveWorkload(ctx context.Context, workload *types.Workload) error

RemoveWorkload provides a mock function for the type Store

func (*Store) ServiceStatusStream 

func (_mock *Store) ServiceStatusStream(context1 context.Context) (chan []string, error)

ServiceStatusStream provides a mock function for the type Store

func (*Store) SetNodeStatus 

func (_mock *Store) SetNodeStatus(ctx context.Context, node *types.Node, ttl int64) error

SetNodeStatus provides a mock function for the type Store

func (*Store) SetWorkloadStatus 

func (_mock *Store) SetWorkloadStatus(ctx context.Context, status *types.StatusMeta, ttl int64) error

SetWorkloadStatus provides a mock function for the type Store

func (*Store) StartEphemeral 

func (_mock *Store) StartEphemeral(ctx context.Context, path string, heartbeat time.Duration) (<-chan struct{}, func(), error)

StartEphemeral provides a mock function for the type Store

func (*Store) UpdateNodes 

func (_mock *Store) UpdateNodes(context1 context.Context, nodes ...*types.Node) error

UpdateNodes provides a mock function for the type Store

func (*Store) UpdateWorkload 

func (_mock *Store) UpdateWorkload(ctx context.Context, workload *types.Workload) error

UpdateWorkload provides a mock function for the type Store

func (*Store) WorkloadStatusStream 

func (_mock *Store) WorkloadStatusStream(ctx context.Context, appname string, entrypoint string, nodename string, labels map[string]string) chan *types.WorkloadStatus

WorkloadStatusStream provides a mock function for the type Store

type Store_AddNode_Call 

type Store_AddNode_Call struct {
	*mock.Call
}

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

func (*Store_AddNode_Call) Return 

func (_c *Store_AddNode_Call) Return(node *types.Node, err error) *Store_AddNode_Call

func (*Store_AddNode_Call) Run 

func (_c *Store_AddNode_Call) Run(run func(context1 context.Context, addNodeOptions *types.AddNodeOptions)) *Store_AddNode_Call

func (*Store_AddNode_Call) RunAndReturn 

func (_c *Store_AddNode_Call) RunAndReturn(run func(context1 context.Context, addNodeOptions *types.AddNodeOptions) (*types.Node, error)) *Store_AddNode_Call

type Store_AddPod_Call 

type Store_AddPod_Call struct {
	*mock.Call
}

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

func (*Store_AddPod_Call) Return 

func (_c *Store_AddPod_Call) Return(pod *types.Pod, err error) *Store_AddPod_Call

func (*Store_AddPod_Call) Run 

func (_c *Store_AddPod_Call) Run(run func(ctx context.Context, name string, desc string)) *Store_AddPod_Call

func (*Store_AddPod_Call) RunAndReturn 

func (_c *Store_AddPod_Call) RunAndReturn(run func(ctx context.Context, name string, desc string) (*types.Pod, error)) *Store_AddPod_Call

type Store_AddWorkload_Call 

type Store_AddWorkload_Call struct {
	*mock.Call
}

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

func (*Store_AddWorkload_Call) Return 

func (_c *Store_AddWorkload_Call) Return(err error) *Store_AddWorkload_Call

func (*Store_AddWorkload_Call) Run 

func (_c *Store_AddWorkload_Call) Run(run func(context1 context.Context, workload *types.Workload, processing *types.Processing)) *Store_AddWorkload_Call

func (*Store_AddWorkload_Call) RunAndReturn 

func (_c *Store_AddWorkload_Call) RunAndReturn(run func(context1 context.Context, workload *types.Workload, processing *types.Processing) error) *Store_AddWorkload_Call

type Store_CreateLock_Call 

type Store_CreateLock_Call struct {
	*mock.Call
}

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

func (*Store_CreateLock_Call) Return 

func (_c *Store_CreateLock_Call) Return(distributedLock lock.DistributedLock, err error) *Store_CreateLock_Call

func (*Store_CreateLock_Call) Run 

func (_c *Store_CreateLock_Call) Run(run func(key string, ttl time.Duration)) *Store_CreateLock_Call

func (*Store_CreateLock_Call) RunAndReturn 

func (_c *Store_CreateLock_Call) RunAndReturn(run func(key string, ttl time.Duration) (lock.DistributedLock, error)) *Store_CreateLock_Call

type Store_CreateProcessing_Call 

type Store_CreateProcessing_Call struct {
	*mock.Call
}

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

func (*Store_CreateProcessing_Call) Return 

func (_c *Store_CreateProcessing_Call) Return(err error) *Store_CreateProcessing_Call

func (*Store_CreateProcessing_Call) Run 

func (_c *Store_CreateProcessing_Call) Run(run func(ctx context.Context, process *types.Processing, count int)) *Store_CreateProcessing_Call

func (*Store_CreateProcessing_Call) RunAndReturn 

func (_c *Store_CreateProcessing_Call) RunAndReturn(run func(ctx context.Context, process *types.Processing, count int) error) *Store_CreateProcessing_Call

type Store_DeleteProcessing_Call 

type Store_DeleteProcessing_Call struct {
	*mock.Call
}

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

func (*Store_DeleteProcessing_Call) Return 

func (_c *Store_DeleteProcessing_Call) Return(err error) *Store_DeleteProcessing_Call

func (*Store_DeleteProcessing_Call) Run 

func (_c *Store_DeleteProcessing_Call) Run(run func(context1 context.Context, processing *types.Processing)) *Store_DeleteProcessing_Call

func (*Store_DeleteProcessing_Call) RunAndReturn 

func (_c *Store_DeleteProcessing_Call) RunAndReturn(run func(context1 context.Context, processing *types.Processing) error) *Store_DeleteProcessing_Call

type Store_Delete_Call added in v0.1.1 

type Store_Delete_Call struct {
	*mock.Call
}

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

func (*Store_Delete_Call) Return added in v0.1.1 

func (_c *Store_Delete_Call) Return(err error) *Store_Delete_Call

func (*Store_Delete_Call) Run added in v0.1.1 

func (_c *Store_Delete_Call) Run(run func(ctx context.Context, keys []string)) *Store_Delete_Call

func (*Store_Delete_Call) RunAndReturn added in v0.1.1 

func (_c *Store_Delete_Call) RunAndReturn(run func(ctx context.Context, keys []string) error) *Store_Delete_Call

type Store_Expecter 

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

func (*Store_Expecter) AddNode 

func (_e *Store_Expecter) AddNode(context1 any, addNodeOptions any) *Store_AddNode_Call

AddNode is a helper method to define mock.On call

  • context1 context.Context
  • addNodeOptions *types.AddNodeOptions

func (*Store_Expecter) AddPod 

func (_e *Store_Expecter) AddPod(ctx any, name any, desc any) *Store_AddPod_Call

AddPod is a helper method to define mock.On call

  • ctx context.Context
  • name string
  • desc string

func (*Store_Expecter) AddWorkload 

func (_e *Store_Expecter) AddWorkload(context1 any, workload any, processing any) *Store_AddWorkload_Call

AddWorkload is a helper method to define mock.On call

  • context1 context.Context
  • workload *types.Workload
  • processing *types.Processing

func (*Store_Expecter) CreateLock 

func (_e *Store_Expecter) CreateLock(key any, ttl any) *Store_CreateLock_Call

CreateLock is a helper method to define mock.On call

  • key string
  • ttl time.Duration

func (*Store_Expecter) CreateProcessing 

func (_e *Store_Expecter) CreateProcessing(ctx any, process any, count any) *Store_CreateProcessing_Call

CreateProcessing is a helper method to define mock.On call

  • ctx context.Context
  • process *types.Processing
  • count int

func (*Store_Expecter) Delete added in v0.1.1 

func (_e *Store_Expecter) Delete(ctx any, keys any) *Store_Delete_Call

Delete is a helper method to define mock.On call

  • ctx context.Context
  • keys []string

func (*Store_Expecter) DeleteProcessing 

func (_e *Store_Expecter) DeleteProcessing(context1 any, processing any) *Store_DeleteProcessing_Call

DeleteProcessing is a helper method to define mock.On call

  • context1 context.Context
  • processing *types.Processing

func (*Store_Expecter) GetAllPods 

func (_e *Store_Expecter) GetAllPods(ctx any) *Store_GetAllPods_Call

GetAllPods is a helper method to define mock.On call

  • ctx context.Context

func (*Store_Expecter) GetDeployStatus 

func (_e *Store_Expecter) GetDeployStatus(ctx any, appname any, entryname any) *Store_GetDeployStatus_Call

GetDeployStatus is a helper method to define mock.On call

  • ctx context.Context
  • appname string
  • entryname string

func (*Store_Expecter) GetNode 

func (_e *Store_Expecter) GetNode(ctx any, nodename any) *Store_GetNode_Call

GetNode is a helper method to define mock.On call

  • ctx context.Context
  • nodename string

func (*Store_Expecter) GetNodeStatus 

func (_e *Store_Expecter) GetNodeStatus(ctx any, nodename any) *Store_GetNodeStatus_Call

GetNodeStatus is a helper method to define mock.On call

  • ctx context.Context
  • nodename string

func (*Store_Expecter) GetNodes 

func (_e *Store_Expecter) GetNodes(ctx any, nodenames any) *Store_GetNodes_Call

GetNodes is a helper method to define mock.On call

  • ctx context.Context
  • nodenames []string

func (*Store_Expecter) GetNodesByPod 

func (_e *Store_Expecter) GetNodesByPod(ctx any, nodeFilter any, withoutEngine any) *Store_GetNodesByPod_Call

GetNodesByPod is a helper method to define mock.On call

  • ctx context.Context
  • nodeFilter *types.NodeFilter
  • withoutEngine bool

func (*Store_Expecter) GetPod 

func (_e *Store_Expecter) GetPod(ctx any, podname any) *Store_GetPod_Call

GetPod is a helper method to define mock.On call

  • ctx context.Context
  • podname string

func (*Store_Expecter) GetPrefix added in v0.1.1 

func (_e *Store_Expecter) GetPrefix(ctx any, prefix any, limit any) *Store_GetPrefix_Call

GetPrefix is a helper method to define mock.On call

  • ctx context.Context
  • prefix string
  • limit int64

func (*Store_Expecter) GetServiceStatus added in v0.1.1 

func (_e *Store_Expecter) GetServiceStatus(context1 any) *Store_GetServiceStatus_Call

GetServiceStatus is a helper method to define mock.On call

  • context1 context.Context

func (*Store_Expecter) GetWorkload 

func (_e *Store_Expecter) GetWorkload(ctx any, ID any) *Store_GetWorkload_Call

GetWorkload is a helper method to define mock.On call

  • ctx context.Context
  • ID string

func (*Store_Expecter) GetWorkloadStatus 

func (_e *Store_Expecter) GetWorkloadStatus(ctx any, ID any) *Store_GetWorkloadStatus_Call

GetWorkloadStatus is a helper method to define mock.On call

  • ctx context.Context
  • ID string

func (*Store_Expecter) GetWorkloads 

func (_e *Store_Expecter) GetWorkloads(ctx any, IDs any) *Store_GetWorkloads_Call

GetWorkloads is a helper method to define mock.On call

  • ctx context.Context
  • IDs []string

func (*Store_Expecter) ListNodeWorkloads 

func (_e *Store_Expecter) ListNodeWorkloads(ctx any, nodename any, labels any) *Store_ListNodeWorkloads_Call

ListNodeWorkloads is a helper method to define mock.On call

  • ctx context.Context
  • nodename string
  • labels map[string]string

func (*Store_Expecter) ListPrefix added in v0.1.1 

func (_e *Store_Expecter) ListPrefix(ctx any, prefix any) *Store_ListPrefix_Call

ListPrefix is a helper method to define mock.On call

  • ctx context.Context
  • prefix string

func (*Store_Expecter) ListWorkloads 

func (_e *Store_Expecter) ListWorkloads(ctx any, appname any, entrypoint any, nodename any, limit any, labels any) *Store_ListWorkloads_Call

ListWorkloads is a helper method to define mock.On call

  • ctx context.Context
  • appname string
  • entrypoint string
  • nodename string
  • limit int64
  • labels map[string]string

func (*Store_Expecter) NodeStatusStream 

func (_e *Store_Expecter) NodeStatusStream(ctx any) *Store_NodeStatusStream_Call

NodeStatusStream is a helper method to define mock.On call

  • ctx context.Context

func (*Store_Expecter) NotFound added in v0.1.1 

func (_e *Store_Expecter) NotFound(err any) *Store_NotFound_Call

NotFound is a helper method to define mock.On call

  • err error

func (*Store_Expecter) Put added in v0.1.1 

func (_e *Store_Expecter) Put(ctx any, data any) *Store_Put_Call

Put is a helper method to define mock.On call

  • ctx context.Context
  • data map[string]string

func (*Store_Expecter) RegisterService 

func (_e *Store_Expecter) RegisterService(context1 any, s any, duration any) *Store_RegisterService_Call

RegisterService is a helper method to define mock.On call

  • context1 context.Context
  • s string
  • duration time.Duration

func (*Store_Expecter) RemoveNode 

func (_e *Store_Expecter) RemoveNode(ctx any, node any) *Store_RemoveNode_Call

RemoveNode is a helper method to define mock.On call

  • ctx context.Context
  • node *types.Node

func (*Store_Expecter) RemovePod 

func (_e *Store_Expecter) RemovePod(ctx any, podname any) *Store_RemovePod_Call

RemovePod is a helper method to define mock.On call

  • ctx context.Context
  • podname string

func (*Store_Expecter) RemoveWorkload 

func (_e *Store_Expecter) RemoveWorkload(ctx any, workload any) *Store_RemoveWorkload_Call

RemoveWorkload is a helper method to define mock.On call

  • ctx context.Context
  • workload *types.Workload

func (*Store_Expecter) ServiceStatusStream 

func (_e *Store_Expecter) ServiceStatusStream(context1 any) *Store_ServiceStatusStream_Call

ServiceStatusStream is a helper method to define mock.On call

  • context1 context.Context

func (*Store_Expecter) SetNodeStatus 

func (_e *Store_Expecter) SetNodeStatus(ctx any, node any, ttl any) *Store_SetNodeStatus_Call

SetNodeStatus is a helper method to define mock.On call

  • ctx context.Context
  • node *types.Node
  • ttl int64

func (*Store_Expecter) SetWorkloadStatus 

func (_e *Store_Expecter) SetWorkloadStatus(ctx any, status any, ttl any) *Store_SetWorkloadStatus_Call

SetWorkloadStatus is a helper method to define mock.On call

  • ctx context.Context
  • status *types.StatusMeta
  • ttl int64

func (*Store_Expecter) StartEphemeral 

func (_e *Store_Expecter) StartEphemeral(ctx any, path any, heartbeat any) *Store_StartEphemeral_Call

StartEphemeral is a helper method to define mock.On call

  • ctx context.Context
  • path string
  • heartbeat time.Duration

func (*Store_Expecter) UpdateNodes 

func (_e *Store_Expecter) UpdateNodes(context1 any, nodes ...any) *Store_UpdateNodes_Call

UpdateNodes is a helper method to define mock.On call

  • context1 context.Context
  • nodes ...*types.Node

func (*Store_Expecter) UpdateWorkload 

func (_e *Store_Expecter) UpdateWorkload(ctx any, workload any) *Store_UpdateWorkload_Call

UpdateWorkload is a helper method to define mock.On call

  • ctx context.Context
  • workload *types.Workload

func (*Store_Expecter) WorkloadStatusStream 

func (_e *Store_Expecter) WorkloadStatusStream(ctx any, appname any, entrypoint any, nodename any, labels any) *Store_WorkloadStatusStream_Call

WorkloadStatusStream is a helper method to define mock.On call

  • ctx context.Context
  • appname string
  • entrypoint string
  • nodename string
  • labels map[string]string

type Store_GetAllPods_Call 

type Store_GetAllPods_Call struct {
	*mock.Call
}

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

func (*Store_GetAllPods_Call) Return 

func (_c *Store_GetAllPods_Call) Return(pods []*types.Pod, err error) *Store_GetAllPods_Call

func (*Store_GetAllPods_Call) Run 

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

func (*Store_GetAllPods_Call) RunAndReturn 

func (_c *Store_GetAllPods_Call) RunAndReturn(run func(ctx context.Context) ([]*types.Pod, error)) *Store_GetAllPods_Call

type Store_GetDeployStatus_Call 

type Store_GetDeployStatus_Call struct {
	*mock.Call
}

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

func (*Store_GetDeployStatus_Call) Return 

func (_c *Store_GetDeployStatus_Call) Return(stringToInt map[string]int, err error) *Store_GetDeployStatus_Call

func (*Store_GetDeployStatus_Call) Run 

func (_c *Store_GetDeployStatus_Call) Run(run func(ctx context.Context, appname string, entryname string)) *Store_GetDeployStatus_Call

func (*Store_GetDeployStatus_Call) RunAndReturn 

func (_c *Store_GetDeployStatus_Call) RunAndReturn(run func(ctx context.Context, appname string, entryname string) (map[string]int, error)) *Store_GetDeployStatus_Call

type Store_GetNodeStatus_Call 

type Store_GetNodeStatus_Call struct {
	*mock.Call
}

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

func (*Store_GetNodeStatus_Call) Return 

func (_c *Store_GetNodeStatus_Call) Return(nodeStatus *types.NodeStatus, err error) *Store_GetNodeStatus_Call

func (*Store_GetNodeStatus_Call) Run 

func (_c *Store_GetNodeStatus_Call) Run(run func(ctx context.Context, nodename string)) *Store_GetNodeStatus_Call

func (*Store_GetNodeStatus_Call) RunAndReturn 

func (_c *Store_GetNodeStatus_Call) RunAndReturn(run func(ctx context.Context, nodename string) (*types.NodeStatus, error)) *Store_GetNodeStatus_Call

type Store_GetNode_Call 

type Store_GetNode_Call struct {
	*mock.Call
}

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

func (*Store_GetNode_Call) Return 

func (_c *Store_GetNode_Call) Return(node *types.Node, err error) *Store_GetNode_Call

func (*Store_GetNode_Call) Run 

func (_c *Store_GetNode_Call) Run(run func(ctx context.Context, nodename string)) *Store_GetNode_Call

func (*Store_GetNode_Call) RunAndReturn 

func (_c *Store_GetNode_Call) RunAndReturn(run func(ctx context.Context, nodename string) (*types.Node, error)) *Store_GetNode_Call

type Store_GetNodesByPod_Call 

type Store_GetNodesByPod_Call struct {
	*mock.Call
}

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

func (*Store_GetNodesByPod_Call) Return 

func (_c *Store_GetNodesByPod_Call) Return(nodes []*types.Node, err error) *Store_GetNodesByPod_Call

func (*Store_GetNodesByPod_Call) Run 

func (_c *Store_GetNodesByPod_Call) Run(run func(ctx context.Context, nodeFilter *types.NodeFilter, withoutEngine bool)) *Store_GetNodesByPod_Call

func (*Store_GetNodesByPod_Call) RunAndReturn 

func (_c *Store_GetNodesByPod_Call) RunAndReturn(run func(ctx context.Context, nodeFilter *types.NodeFilter, withoutEngine bool) ([]*types.Node, error)) *Store_GetNodesByPod_Call

type Store_GetNodes_Call 

type Store_GetNodes_Call struct {
	*mock.Call
}

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

func (*Store_GetNodes_Call) Return 

func (_c *Store_GetNodes_Call) Return(nodes []*types.Node, err error) *Store_GetNodes_Call

func (*Store_GetNodes_Call) Run 

func (_c *Store_GetNodes_Call) Run(run func(ctx context.Context, nodenames []string)) *Store_GetNodes_Call

func (*Store_GetNodes_Call) RunAndReturn 

func (_c *Store_GetNodes_Call) RunAndReturn(run func(ctx context.Context, nodenames []string) ([]*types.Node, error)) *Store_GetNodes_Call

type Store_GetPod_Call 

type Store_GetPod_Call struct {
	*mock.Call
}

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

func (*Store_GetPod_Call) Return 

func (_c *Store_GetPod_Call) Return(pod *types.Pod, err error) *Store_GetPod_Call

func (*Store_GetPod_Call) Run 

func (_c *Store_GetPod_Call) Run(run func(ctx context.Context, podname string)) *Store_GetPod_Call

func (*Store_GetPod_Call) RunAndReturn 

func (_c *Store_GetPod_Call) RunAndReturn(run func(ctx context.Context, podname string) (*types.Pod, error)) *Store_GetPod_Call

type Store_GetPrefix_Call added in v0.1.1 

type Store_GetPrefix_Call struct {
	*mock.Call
}

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

func (*Store_GetPrefix_Call) Return added in v0.1.1 

func (_c *Store_GetPrefix_Call) Return(stringToString map[string]string, err error) *Store_GetPrefix_Call

func (*Store_GetPrefix_Call) Run added in v0.1.1 

func (_c *Store_GetPrefix_Call) Run(run func(ctx context.Context, prefix string, limit int64)) *Store_GetPrefix_Call

func (*Store_GetPrefix_Call) RunAndReturn added in v0.1.1 

func (_c *Store_GetPrefix_Call) RunAndReturn(run func(ctx context.Context, prefix string, limit int64) (map[string]string, error)) *Store_GetPrefix_Call

type Store_GetServiceStatus_Call added in v0.1.1 

type Store_GetServiceStatus_Call struct {
	*mock.Call
}

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

func (*Store_GetServiceStatus_Call) Return added in v0.1.1 

func (_c *Store_GetServiceStatus_Call) Return(strings []string, err error) *Store_GetServiceStatus_Call

func (*Store_GetServiceStatus_Call) Run added in v0.1.1 

func (_c *Store_GetServiceStatus_Call) Run(run func(context1 context.Context)) *Store_GetServiceStatus_Call

func (*Store_GetServiceStatus_Call) RunAndReturn added in v0.1.1 

func (_c *Store_GetServiceStatus_Call) RunAndReturn(run func(context1 context.Context) ([]string, error)) *Store_GetServiceStatus_Call

type Store_GetWorkloadStatus_Call 

type Store_GetWorkloadStatus_Call struct {
	*mock.Call
}

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

func (*Store_GetWorkloadStatus_Call) Return 

func (_c *Store_GetWorkloadStatus_Call) Return(statusMeta *types.StatusMeta, err error) *Store_GetWorkloadStatus_Call

func (*Store_GetWorkloadStatus_Call) Run 

func (_c *Store_GetWorkloadStatus_Call) Run(run func(ctx context.Context, ID string)) *Store_GetWorkloadStatus_Call

func (*Store_GetWorkloadStatus_Call) RunAndReturn 

func (_c *Store_GetWorkloadStatus_Call) RunAndReturn(run func(ctx context.Context, ID string) (*types.StatusMeta, error)) *Store_GetWorkloadStatus_Call

type Store_GetWorkload_Call 

type Store_GetWorkload_Call struct {
	*mock.Call
}

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

func (*Store_GetWorkload_Call) Return 

func (_c *Store_GetWorkload_Call) Return(workload *types.Workload, err error) *Store_GetWorkload_Call

func (*Store_GetWorkload_Call) Run 

func (_c *Store_GetWorkload_Call) Run(run func(ctx context.Context, ID string)) *Store_GetWorkload_Call

func (*Store_GetWorkload_Call) RunAndReturn 

func (_c *Store_GetWorkload_Call) RunAndReturn(run func(ctx context.Context, ID string) (*types.Workload, error)) *Store_GetWorkload_Call

type Store_GetWorkloads_Call 

type Store_GetWorkloads_Call struct {
	*mock.Call
}

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

func (*Store_GetWorkloads_Call) Return 

func (_c *Store_GetWorkloads_Call) Return(workloads []*types.Workload, err error) *Store_GetWorkloads_Call

func (*Store_GetWorkloads_Call) Run 

func (_c *Store_GetWorkloads_Call) Run(run func(ctx context.Context, IDs []string)) *Store_GetWorkloads_Call

func (*Store_GetWorkloads_Call) RunAndReturn 

func (_c *Store_GetWorkloads_Call) RunAndReturn(run func(ctx context.Context, IDs []string) ([]*types.Workload, error)) *Store_GetWorkloads_Call

type Store_ListNodeWorkloads_Call 

type Store_ListNodeWorkloads_Call struct {
	*mock.Call
}

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

func (*Store_ListNodeWorkloads_Call) Return 

func (_c *Store_ListNodeWorkloads_Call) Return(workloads []*types.Workload, err error) *Store_ListNodeWorkloads_Call

func (*Store_ListNodeWorkloads_Call) Run 

func (_c *Store_ListNodeWorkloads_Call) Run(run func(ctx context.Context, nodename string, labels map[string]string)) *Store_ListNodeWorkloads_Call

func (*Store_ListNodeWorkloads_Call) RunAndReturn 

func (_c *Store_ListNodeWorkloads_Call) RunAndReturn(run func(ctx context.Context, nodename string, labels map[string]string) ([]*types.Workload, error)) *Store_ListNodeWorkloads_Call

type Store_ListPrefix_Call added in v0.1.1 

type Store_ListPrefix_Call struct {
	*mock.Call
}

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

func (*Store_ListPrefix_Call) Return added in v0.1.1 

func (_c *Store_ListPrefix_Call) Return(strings []string, err error) *Store_ListPrefix_Call

func (*Store_ListPrefix_Call) Run added in v0.1.1 

func (_c *Store_ListPrefix_Call) Run(run func(ctx context.Context, prefix string)) *Store_ListPrefix_Call

func (*Store_ListPrefix_Call) RunAndReturn added in v0.1.1 

func (_c *Store_ListPrefix_Call) RunAndReturn(run func(ctx context.Context, prefix string) ([]string, error)) *Store_ListPrefix_Call

type Store_ListWorkloads_Call 

type Store_ListWorkloads_Call struct {
	*mock.Call
}

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

func (*Store_ListWorkloads_Call) Return 

func (_c *Store_ListWorkloads_Call) Return(workloads []*types.Workload, err error) *Store_ListWorkloads_Call

func (*Store_ListWorkloads_Call) Run 

func (_c *Store_ListWorkloads_Call) Run(run func(ctx context.Context, appname string, entrypoint string, nodename string, limit int64, labels map[string]string)) *Store_ListWorkloads_Call

func (*Store_ListWorkloads_Call) RunAndReturn 

func (_c *Store_ListWorkloads_Call) RunAndReturn(run func(ctx context.Context, appname string, entrypoint string, nodename string, limit int64, labels map[string]string) ([]*types.Workload, error)) *Store_ListWorkloads_Call

type Store_NodeStatusStream_Call 

type Store_NodeStatusStream_Call struct {
	*mock.Call
}

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

func (*Store_NodeStatusStream_Call) Return 

func (_c *Store_NodeStatusStream_Call) Return(nodeStatusCh chan *types.NodeStatus) *Store_NodeStatusStream_Call

func (*Store_NodeStatusStream_Call) Run 

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

func (*Store_NodeStatusStream_Call) RunAndReturn 

func (_c *Store_NodeStatusStream_Call) RunAndReturn(run func(ctx context.Context) chan *types.NodeStatus) *Store_NodeStatusStream_Call

type Store_NotFound_Call added in v0.1.1 

type Store_NotFound_Call struct {
	*mock.Call
}

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

func (*Store_NotFound_Call) Return added in v0.1.1 

func (_c *Store_NotFound_Call) Return(b bool) *Store_NotFound_Call

func (*Store_NotFound_Call) Run added in v0.1.1 

func (_c *Store_NotFound_Call) Run(run func(err error)) *Store_NotFound_Call

func (*Store_NotFound_Call) RunAndReturn added in v0.1.1 

func (_c *Store_NotFound_Call) RunAndReturn(run func(err error) bool) *Store_NotFound_Call

type Store_Put_Call added in v0.1.1 

type Store_Put_Call struct {
	*mock.Call
}

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

func (*Store_Put_Call) Return added in v0.1.1 

func (_c *Store_Put_Call) Return(err error) *Store_Put_Call

func (*Store_Put_Call) Run added in v0.1.1 

func (_c *Store_Put_Call) Run(run func(ctx context.Context, data map[string]string)) *Store_Put_Call

func (*Store_Put_Call) RunAndReturn added in v0.1.1 

func (_c *Store_Put_Call) RunAndReturn(run func(ctx context.Context, data map[string]string) error) *Store_Put_Call

type Store_RegisterService_Call 

type Store_RegisterService_Call struct {
	*mock.Call
}

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

func (*Store_RegisterService_Call) Return 

func (_c *Store_RegisterService_Call) Return(valCh <-chan struct{}, fn func(), err error) *Store_RegisterService_Call

func (*Store_RegisterService_Call) Run 

func (_c *Store_RegisterService_Call) Run(run func(context1 context.Context, s string, duration time.Duration)) *Store_RegisterService_Call

func (*Store_RegisterService_Call) RunAndReturn 

func (_c *Store_RegisterService_Call) RunAndReturn(run func(context1 context.Context, s string, duration time.Duration) (<-chan struct{}, func(), error)) *Store_RegisterService_Call

type Store_RemoveNode_Call 

type Store_RemoveNode_Call struct {
	*mock.Call
}

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

func (*Store_RemoveNode_Call) Return 

func (_c *Store_RemoveNode_Call) Return(err error) *Store_RemoveNode_Call

func (*Store_RemoveNode_Call) Run 

func (_c *Store_RemoveNode_Call) Run(run func(ctx context.Context, node *types.Node)) *Store_RemoveNode_Call

func (*Store_RemoveNode_Call) RunAndReturn 

func (_c *Store_RemoveNode_Call) RunAndReturn(run func(ctx context.Context, node *types.Node) error) *Store_RemoveNode_Call

type Store_RemovePod_Call 

type Store_RemovePod_Call struct {
	*mock.Call
}

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

func (*Store_RemovePod_Call) Return 

func (_c *Store_RemovePod_Call) Return(err error) *Store_RemovePod_Call

func (*Store_RemovePod_Call) Run 

func (_c *Store_RemovePod_Call) Run(run func(ctx context.Context, podname string)) *Store_RemovePod_Call

func (*Store_RemovePod_Call) RunAndReturn 

func (_c *Store_RemovePod_Call) RunAndReturn(run func(ctx context.Context, podname string) error) *Store_RemovePod_Call

type Store_RemoveWorkload_Call 

type Store_RemoveWorkload_Call struct {
	*mock.Call
}

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

func (*Store_RemoveWorkload_Call) Return 

func (_c *Store_RemoveWorkload_Call) Return(err error) *Store_RemoveWorkload_Call

func (*Store_RemoveWorkload_Call) Run 

func (_c *Store_RemoveWorkload_Call) Run(run func(ctx context.Context, workload *types.Workload)) *Store_RemoveWorkload_Call

func (*Store_RemoveWorkload_Call) RunAndReturn 

func (_c *Store_RemoveWorkload_Call) RunAndReturn(run func(ctx context.Context, workload *types.Workload) error) *Store_RemoveWorkload_Call

type Store_ServiceStatusStream_Call 

type Store_ServiceStatusStream_Call struct {
	*mock.Call
}

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

func (*Store_ServiceStatusStream_Call) Return 

func (_c *Store_ServiceStatusStream_Call) Return(stringsCh chan []string, err error) *Store_ServiceStatusStream_Call

func (*Store_ServiceStatusStream_Call) Run 

func (_c *Store_ServiceStatusStream_Call) Run(run func(context1 context.Context)) *Store_ServiceStatusStream_Call

func (*Store_ServiceStatusStream_Call) RunAndReturn 

func (_c *Store_ServiceStatusStream_Call) RunAndReturn(run func(context1 context.Context) (chan []string, error)) *Store_ServiceStatusStream_Call

type Store_SetNodeStatus_Call 

type Store_SetNodeStatus_Call struct {
	*mock.Call
}

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

func (*Store_SetNodeStatus_Call) Return 

func (_c *Store_SetNodeStatus_Call) Return(err error) *Store_SetNodeStatus_Call

func (*Store_SetNodeStatus_Call) Run 

func (_c *Store_SetNodeStatus_Call) Run(run func(ctx context.Context, node *types.Node, ttl int64)) *Store_SetNodeStatus_Call

func (*Store_SetNodeStatus_Call) RunAndReturn 

func (_c *Store_SetNodeStatus_Call) RunAndReturn(run func(ctx context.Context, node *types.Node, ttl int64) error) *Store_SetNodeStatus_Call

type Store_SetWorkloadStatus_Call 

type Store_SetWorkloadStatus_Call struct {
	*mock.Call
}

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

func (*Store_SetWorkloadStatus_Call) Return 

func (_c *Store_SetWorkloadStatus_Call) Return(err error) *Store_SetWorkloadStatus_Call

func (*Store_SetWorkloadStatus_Call) Run 

func (_c *Store_SetWorkloadStatus_Call) Run(run func(ctx context.Context, status *types.StatusMeta, ttl int64)) *Store_SetWorkloadStatus_Call

func (*Store_SetWorkloadStatus_Call) RunAndReturn 

func (_c *Store_SetWorkloadStatus_Call) RunAndReturn(run func(ctx context.Context, status *types.StatusMeta, ttl int64) error) *Store_SetWorkloadStatus_Call

type Store_StartEphemeral_Call 

type Store_StartEphemeral_Call struct {
	*mock.Call
}

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

func (*Store_StartEphemeral_Call) Return 

func (_c *Store_StartEphemeral_Call) Return(valCh <-chan struct{}, fn func(), err error) *Store_StartEphemeral_Call

func (*Store_StartEphemeral_Call) Run 

func (_c *Store_StartEphemeral_Call) Run(run func(ctx context.Context, path string, heartbeat time.Duration)) *Store_StartEphemeral_Call

func (*Store_StartEphemeral_Call) RunAndReturn 

func (_c *Store_StartEphemeral_Call) RunAndReturn(run func(ctx context.Context, path string, heartbeat time.Duration) (<-chan struct{}, func(), error)) *Store_StartEphemeral_Call

type Store_UpdateNodes_Call 

type Store_UpdateNodes_Call struct {
	*mock.Call
}

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

func (*Store_UpdateNodes_Call) Return 

func (_c *Store_UpdateNodes_Call) Return(err error) *Store_UpdateNodes_Call

func (*Store_UpdateNodes_Call) Run 

func (_c *Store_UpdateNodes_Call) Run(run func(context1 context.Context, nodes ...*types.Node)) *Store_UpdateNodes_Call

func (*Store_UpdateNodes_Call) RunAndReturn 

func (_c *Store_UpdateNodes_Call) RunAndReturn(run func(context1 context.Context, nodes ...*types.Node) error) *Store_UpdateNodes_Call

type Store_UpdateWorkload_Call 

type Store_UpdateWorkload_Call struct {
	*mock.Call
}

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

func (*Store_UpdateWorkload_Call) Return 

func (_c *Store_UpdateWorkload_Call) Return(err error) *Store_UpdateWorkload_Call

func (*Store_UpdateWorkload_Call) Run 

func (_c *Store_UpdateWorkload_Call) Run(run func(ctx context.Context, workload *types.Workload)) *Store_UpdateWorkload_Call

func (*Store_UpdateWorkload_Call) RunAndReturn 

func (_c *Store_UpdateWorkload_Call) RunAndReturn(run func(ctx context.Context, workload *types.Workload) error) *Store_UpdateWorkload_Call

type Store_WorkloadStatusStream_Call 

type Store_WorkloadStatusStream_Call struct {
	*mock.Call
}

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

func (*Store_WorkloadStatusStream_Call) Return 

func (_c *Store_WorkloadStatusStream_Call) Return(workloadStatusCh chan *types.WorkloadStatus) *Store_WorkloadStatusStream_Call

func (*Store_WorkloadStatusStream_Call) Run 

func (_c *Store_WorkloadStatusStream_Call) Run(run func(ctx context.Context, appname string, entrypoint string, nodename string, labels map[string]string)) *Store_WorkloadStatusStream_Call

func (*Store_WorkloadStatusStream_Call) RunAndReturn 

func (_c *Store_WorkloadStatusStream_Call) RunAndReturn(run func(ctx context.Context, appname string, entrypoint string, nodename string, labels map[string]string) chan *types.WorkloadStatus) *Store_WorkloadStatusStream_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.