mocks

Documentation

Index

• type Store
  • func NewStore(t interface{ ... }) *Store
  • func (_m *Store) AddNode(_a0 context.Context, _a1 *types.AddNodeOptions) (*types.Node, error)
  • func (_m *Store) AddPod(ctx context.Context, name string, desc string) (*types.Pod, error)
  • func (_m *Store) AddWorkload(_a0 context.Context, _a1 *types.Workload, _a2 *types.Processing) error
  • func (_m *Store) CreateLock(key string, ttl time.Duration) (lock.DistributedLock, error)
  • func (_m *Store) CreateProcessing(ctx context.Context, process *types.Processing, count int) error
  • func (_m *Store) DeleteProcessing(_a0 context.Context, _a1 *types.Processing) error
  • func (_m *Store) GetAllPods(ctx context.Context) ([]*types.Pod, error)
  • func (_m *Store) GetDeployStatus(ctx context.Context, appname string, entryname string) (map[string]int, error)
  • func (_m *Store) GetNode(ctx context.Context, nodename string) (*types.Node, error)
  • func (_m *Store) GetNodeStatus(ctx context.Context, nodename string) (*types.NodeStatus, error)
  • func (_m *Store) GetNodes(ctx context.Context, nodenames []string) ([]*types.Node, error)
  • func (_m *Store) GetNodesByPod(ctx context.Context, nodeFilter *types.NodeFilter, opts ...store.Option) ([]*types.Node, error)
  • func (_m *Store) GetPod(ctx context.Context, podname string) (*types.Pod, error)
  • func (_m *Store) GetWorkload(ctx context.Context, ID string) (*types.Workload, error)
  • func (_m *Store) GetWorkloadStatus(ctx context.Context, ID string) (*types.StatusMeta, error)
  • func (_m *Store) GetWorkloads(ctx context.Context, IDs []string) ([]*types.Workload, error)
  • func (_m *Store) ListNodeWorkloads(ctx context.Context, nodename string, labels map[string]string) ([]*types.Workload, error)
  • func (_m *Store) ListWorkloads(ctx context.Context, appname string, entrypoint string, nodename string, ...) ([]*types.Workload, error)
  • func (_m *Store) LoadNodeCert(ctx context.Context, node *types.Node) error
  • func (_m *Store) NodeStatusStream(ctx context.Context) chan *types.NodeStatus
  • func (_m *Store) RegisterService(_a0 context.Context, _a1 string, _a2 time.Duration) (<-chan struct{}, func(), error)
  • func (_m *Store) RemoveNode(ctx context.Context, node *types.Node) error
  • func (_m *Store) RemovePod(ctx context.Context, podname string) error
  • func (_m *Store) RemoveWorkload(ctx context.Context, workload *types.Workload) error
  • func (_m *Store) ServiceStatusStream(_a0 context.Context) (chan []string, error)
  • func (_m *Store) SetNodeStatus(ctx context.Context, node *types.Node, ttl int64) error
  • func (_m *Store) SetWorkloadStatus(ctx context.Context, status *types.StatusMeta, ttl int64) error
  • func (_m *Store) StartEphemeral(ctx context.Context, path string, heartbeat time.Duration) (<-chan struct{}, func(), error)
  • func (_m *Store) UpdateNodes(_a0 context.Context, _a1 ...*types.Node) error
  • func (_m *Store) UpdateWorkload(ctx context.Context, workload *types.Workload) error
  • func (_m *Store) WorkloadStatusStream(ctx context.Context, appname string, entrypoint string, nodename string, ...) chan *types.WorkloadStatus

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 (_m *Store) AddNode(_a0 context.Context, _a1 *types.AddNodeOptions) (*types.Node, error)

AddNode provides a mock function with given fields: _a0, _a1

func (*Store) AddPod

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

AddPod provides a mock function with given fields: ctx, name, desc

func (*Store) AddWorkload

func (_m *Store) AddWorkload(_a0 context.Context, _a1 *types.Workload, _a2 *types.Processing) error

AddWorkload provides a mock function with given fields: _a0, _a1, _a2

func (*Store) CreateLock

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

CreateLock provides a mock function with given fields: key, ttl

func (*Store) CreateProcessing

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

CreateProcessing provides a mock function with given fields: ctx, process, count

func (*Store) DeleteProcessing

func (_m *Store) DeleteProcessing(_a0 context.Context, _a1 *types.Processing) error

DeleteProcessing provides a mock function with given fields: _a0, _a1

func (*Store) GetAllPods

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

GetAllPods provides a mock function with given fields: ctx

func (*Store) GetDeployStatus

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

GetDeployStatus provides a mock function with given fields: ctx, appname, entryname

func (*Store) GetNode

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

GetNode provides a mock function with given fields: ctx, nodename

func (*Store) GetNodeStatus

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

GetNodeStatus provides a mock function with given fields: ctx, nodename

func (*Store) GetNodes

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

GetNodes provides a mock function with given fields: ctx, nodenames

func (*Store) GetNodesByPod

func (_m *Store) GetNodesByPod(ctx context.Context, nodeFilter *types.NodeFilter, opts ...store.Option) ([]*types.Node, error)

GetNodesByPod provides a mock function with given fields: ctx, nodeFilter, opts

func (*Store) GetPod

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

GetPod provides a mock function with given fields: ctx, podname

func (*Store) GetWorkload

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

GetWorkload provides a mock function with given fields: ctx, ID

func (*Store) GetWorkloadStatus

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

GetWorkloadStatus provides a mock function with given fields: ctx, ID

func (*Store) GetWorkloads

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

GetWorkloads provides a mock function with given fields: ctx, IDs

func (*Store) ListNodeWorkloads

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

ListNodeWorkloads provides a mock function with given fields: ctx, nodename, labels

func (*Store) ListWorkloads

func (_m *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 with given fields: ctx, appname, entrypoint, nodename, limit, labels

func (*Store) LoadNodeCert

func (_m *Store) LoadNodeCert(ctx context.Context, node *types.Node) error

LoadNodeCert provides a mock function with given fields: ctx, node

func (*Store) NodeStatusStream

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

NodeStatusStream provides a mock function with given fields: ctx

func (*Store) RegisterService

func (_m *Store) RegisterService(_a0 context.Context, _a1 string, _a2 time.Duration) (<-chan struct{}, func(), error)

RegisterService provides a mock function with given fields: _a0, _a1, _a2

func (*Store) RemoveNode

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

RemoveNode provides a mock function with given fields: ctx, node

func (*Store) RemovePod

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

RemovePod provides a mock function with given fields: ctx, podname

func (*Store) RemoveWorkload

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

RemoveWorkload provides a mock function with given fields: ctx, workload

func (*Store) ServiceStatusStream

func (_m *Store) ServiceStatusStream(_a0 context.Context) (chan []string, error)

ServiceStatusStream provides a mock function with given fields: _a0

func (*Store) SetNodeStatus

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

SetNodeStatus provides a mock function with given fields: ctx, node, ttl

func (*Store) SetWorkloadStatus

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

SetWorkloadStatus provides a mock function with given fields: ctx, status, ttl

func (*Store) StartEphemeral

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

StartEphemeral provides a mock function with given fields: ctx, path, heartbeat

func (*Store) UpdateNodes

func (_m *Store) UpdateNodes(_a0 context.Context, _a1 ...*types.Node) error

UpdateNodes provides a mock function with given fields: _a0, _a1

func (*Store) UpdateWorkload

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

UpdateWorkload provides a mock function with given fields: ctx, workload

func (*Store) WorkloadStatusStream

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

WorkloadStatusStream provides a mock function with given fields: ctx, appname, entrypoint, nodename, labels