Help us shape the future of Go! Take the 2026 Go Developer Survey

mocks

package
v0.1.7 Latest Latest
Warning

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

 Go to latest Published: Sep 29, 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) GetMulti added in v0.1.4 

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

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

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) GetMulti added in v0.1.4 

func (_e *Store_Expecter) GetMulti(ctx any, keys any) *Store_GetMulti_Call

GetMulti is a helper method to define mock.On call

  • ctx context.Context
  • keys []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) 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_GetMulti_Call added in v0.1.4 

type Store_GetMulti_Call struct {
	*mock.Call
}

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

func (*Store_GetMulti_Call) Return added in v0.1.4 

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

func (*Store_GetMulti_Call) Run added in v0.1.4 

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

func (*Store_GetMulti_Call) RunAndReturn added in v0.1.4 

func (_c *Store_GetMulti_Call) RunAndReturn(run func(ctx context.Context, keys []string) (map[string]string, error)) *Store_GetMulti_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_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) *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) *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.