mocks

package
v0.1.2 Latest Latest
Warning

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

 Go to latest Published: Aug 27, 2026 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Cluster 

type Cluster struct {
	mock.Mock
}

Cluster is an autogenerated mock type for the Cluster type

func NewCluster 

func NewCluster(t interface {
	mock.TestingT
	Cleanup(func())
}) *Cluster

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

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

AddNode provides a mock function for the type Cluster

func (*Cluster) AddPod 

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

AddPod provides a mock function for the type Cluster

func (*Cluster) BuildImage 

func (_mock *Cluster) BuildImage(ctx context.Context, opts *types.BuildOptions) (chan *types.BuildImageMessage, error)

BuildImage provides a mock function for the type Cluster

func (*Cluster) CacheImage 

func (_mock *Cluster) CacheImage(ctx context.Context, opts *types.ImageOptions) (chan *types.CacheImageMessage, error)

CacheImage provides a mock function for the type Cluster

func (*Cluster) CalculateCapacity 

func (_mock *Cluster) CalculateCapacity(context1 context.Context, deployOptions *types.DeployOptions) (*types.CapacityMessage, error)

CalculateCapacity provides a mock function for the type Cluster

func (*Cluster) ConnectNetwork 

func (_mock *Cluster) ConnectNetwork(ctx context.Context, network string, target string, ipv4 string, ipv6 string) ([]string, error)

ConnectNetwork provides a mock function for the type Cluster

func (*Cluster) ControlWorkload 

func (_mock *Cluster) ControlWorkload(ctx context.Context, IDs []string, t string, force bool) (chan *types.ControlWorkloadMessage, error)

ControlWorkload provides a mock function for the type Cluster

func (*Cluster) Copy 

func (_mock *Cluster) Copy(ctx context.Context, opts *types.CopyOptions) (chan *types.CopyMessage, error)

Copy provides a mock function for the type Cluster

func (*Cluster) CreateWorkload 

func (_mock *Cluster) CreateWorkload(ctx context.Context, opts *types.DeployOptions) (chan *types.CreateWorkloadMessage, error)

CreateWorkload provides a mock function for the type Cluster

func (*Cluster) DisconnectNetwork 

func (_mock *Cluster) DisconnectNetwork(ctx context.Context, network string, target string, force bool) error

DisconnectNetwork provides a mock function for the type Cluster

func (*Cluster) DissociateWorkload 

func (_mock *Cluster) DissociateWorkload(ctx context.Context, IDs []string) (chan *types.DissociateWorkloadMessage, error)

DissociateWorkload provides a mock function for the type Cluster

func (*Cluster) EXPECT 

func (_m *Cluster) EXPECT() *Cluster_Expecter

func (*Cluster) ExecuteWorkload 

func (_mock *Cluster) ExecuteWorkload(ctx context.Context, opts *types.ExecuteWorkloadOptions, inCh <-chan []byte) chan *types.AttachWorkloadMessage

ExecuteWorkload provides a mock function for the type Cluster

func (*Cluster) Finalizer 

func (_mock *Cluster) Finalizer()

Finalizer provides a mock function for the type Cluster

func (*Cluster) GetIdentifier 

func (_mock *Cluster) GetIdentifier() string

GetIdentifier provides a mock function for the type Cluster

func (*Cluster) GetNode 

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

GetNode provides a mock function for the type Cluster

func (*Cluster) GetNodeEngineInfo 

func (_mock *Cluster) GetNodeEngineInfo(ctx context.Context, nodename string) (*types0.Info, error)

GetNodeEngineInfo provides a mock function for the type Cluster

func (*Cluster) GetNodeStatus 

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

GetNodeStatus provides a mock function for the type Cluster

func (*Cluster) GetPod 

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

GetPod provides a mock function for the type Cluster

func (*Cluster) GetWorkload 

func (_mock *Cluster) GetWorkload(ctx context.Context, id string) (*types.Workload, error)

GetWorkload provides a mock function for the type Cluster

func (*Cluster) GetWorkloads 

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

GetWorkloads provides a mock function for the type Cluster

func (*Cluster) GetWorkloadsStatus 

func (_mock *Cluster) GetWorkloadsStatus(ctx context.Context, IDs []string) ([]*types.StatusMeta, error)

GetWorkloadsStatus provides a mock function for the type Cluster

func (*Cluster) ListImage 

func (_mock *Cluster) ListImage(ctx context.Context, opts *types.ImageOptions) (chan *types.ListImageMessage, error)

ListImage provides a mock function for the type Cluster

func (*Cluster) ListNetworks 

func (_mock *Cluster) ListNetworks(ctx context.Context, podname string, driver string) ([]*types0.Network, error)

ListNetworks provides a mock function for the type Cluster

func (*Cluster) ListNodeWorkloads 

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

ListNodeWorkloads provides a mock function for the type Cluster

func (*Cluster) ListPodNodes 

func (_mock *Cluster) ListPodNodes(context1 context.Context, listNodesOptions *types.ListNodesOptions) (<-chan *types.Node, error)

ListPodNodes provides a mock function for the type Cluster

func (*Cluster) ListPods 

func (_mock *Cluster) ListPods(ctx context.Context) ([]*types.Pod, error)

ListPods provides a mock function for the type Cluster

func (*Cluster) ListWorkloads 

func (_mock *Cluster) ListWorkloads(ctx context.Context, opts *types.ListWorkloadsOptions) ([]*types.Workload, error)

ListWorkloads provides a mock function for the type Cluster

func (*Cluster) LogStream 

func (_mock *Cluster) LogStream(ctx context.Context, opts *types.LogStreamOptions) (chan *types.LogStreamMessage, error)

LogStream provides a mock function for the type Cluster

func (*Cluster) NodeResource 

func (_mock *Cluster) NodeResource(ctx context.Context, nodename string, fix bool) (*types.NodeResourceInfo, error)

NodeResource provides a mock function for the type Cluster

func (*Cluster) NodeStatusStream 

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

NodeStatusStream provides a mock function for the type Cluster

func (*Cluster) PodResource 

func (_mock *Cluster) PodResource(ctx context.Context, podname string) (chan *types.NodeResourceInfo, error)

PodResource provides a mock function for the type Cluster

func (*Cluster) RawEngine 

func (_mock *Cluster) RawEngine(ctx context.Context, opts *types.RawEngineOptions) (*types.RawEngineMessage, error)

RawEngine provides a mock function for the type Cluster

func (*Cluster) ReallocResource 

func (_mock *Cluster) ReallocResource(ctx context.Context, opts *types.ReallocOptions) error

ReallocResource provides a mock function for the type Cluster

func (*Cluster) RemoveImage 

func (_mock *Cluster) RemoveImage(ctx context.Context, opts *types.ImageOptions) (chan *types.RemoveImageMessage, error)

RemoveImage provides a mock function for the type Cluster

func (*Cluster) RemoveNode 

func (_mock *Cluster) RemoveNode(ctx context.Context, nodename string) error

RemoveNode provides a mock function for the type Cluster

func (*Cluster) RemovePod 

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

RemovePod provides a mock function for the type Cluster

func (*Cluster) RemoveWorkload 

func (_mock *Cluster) RemoveWorkload(ctx context.Context, IDs []string, force bool) (chan *types.RemoveWorkloadMessage, error)

RemoveWorkload provides a mock function for the type Cluster

func (*Cluster) ReplaceWorkload 

func (_mock *Cluster) ReplaceWorkload(ctx context.Context, opts *types.ReplaceOptions) (chan *types.ReplaceWorkloadMessage, error)

ReplaceWorkload provides a mock function for the type Cluster

func (*Cluster) RunAndWait 

func (_mock *Cluster) RunAndWait(ctx context.Context, opts *types.DeployOptions, inCh <-chan []byte) ([]string, <-chan *types.AttachWorkloadMessage, error)

RunAndWait provides a mock function for the type Cluster

func (*Cluster) Send 

func (_mock *Cluster) Send(ctx context.Context, opts *types.SendOptions) (chan *types.SendMessage, error)

Send provides a mock function for the type Cluster

func (*Cluster) SendLargeFile 

func (_mock *Cluster) SendLargeFile(ctx context.Context, opts chan *types.SendLargeFileOptions) chan *types.SendMessage

SendLargeFile provides a mock function for the type Cluster

func (*Cluster) SetNode 

func (_mock *Cluster) SetNode(ctx context.Context, opts *types.SetNodeOptions) (*types.Node, error)

SetNode provides a mock function for the type Cluster

func (*Cluster) SetNodeStatus 

func (_mock *Cluster) SetNodeStatus(ctx context.Context, nodename string, ttl int64) error

SetNodeStatus provides a mock function for the type Cluster

func (*Cluster) SetWorkloadsStatus 

func (_mock *Cluster) SetWorkloadsStatus(ctx context.Context, status []*types.StatusMeta, ttls map[string]int64) ([]*types.StatusMeta, error)

SetWorkloadsStatus provides a mock function for the type Cluster

func (*Cluster) WatchServiceStatus 

func (_mock *Cluster) WatchServiceStatus(context1 context.Context) (<-chan types.ServiceStatus, error)

WatchServiceStatus provides a mock function for the type Cluster

func (*Cluster) WorkloadStatusStream 

func (_mock *Cluster) 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 Cluster

type Cluster_AddNode_Call 

type Cluster_AddNode_Call struct {
	*mock.Call
}

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

func (*Cluster_AddNode_Call) Return 

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

func (*Cluster_AddNode_Call) Run 

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

func (*Cluster_AddNode_Call) RunAndReturn 

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

type Cluster_AddPod_Call 

type Cluster_AddPod_Call struct {
	*mock.Call
}

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

func (*Cluster_AddPod_Call) Return 

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

func (*Cluster_AddPod_Call) Run 

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

func (*Cluster_AddPod_Call) RunAndReturn 

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

type Cluster_BuildImage_Call 

type Cluster_BuildImage_Call struct {
	*mock.Call
}

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

func (*Cluster_BuildImage_Call) Return 

func (_c *Cluster_BuildImage_Call) Return(buildImageMessageCh chan *types.BuildImageMessage, err error) *Cluster_BuildImage_Call

func (*Cluster_BuildImage_Call) Run 

func (_c *Cluster_BuildImage_Call) Run(run func(ctx context.Context, opts *types.BuildOptions)) *Cluster_BuildImage_Call

func (*Cluster_BuildImage_Call) RunAndReturn 

func (_c *Cluster_BuildImage_Call) RunAndReturn(run func(ctx context.Context, opts *types.BuildOptions) (chan *types.BuildImageMessage, error)) *Cluster_BuildImage_Call

type Cluster_CacheImage_Call 

type Cluster_CacheImage_Call struct {
	*mock.Call
}

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

func (*Cluster_CacheImage_Call) Return 

func (_c *Cluster_CacheImage_Call) Return(cacheImageMessageCh chan *types.CacheImageMessage, err error) *Cluster_CacheImage_Call

func (*Cluster_CacheImage_Call) Run 

func (_c *Cluster_CacheImage_Call) Run(run func(ctx context.Context, opts *types.ImageOptions)) *Cluster_CacheImage_Call

func (*Cluster_CacheImage_Call) RunAndReturn 

func (_c *Cluster_CacheImage_Call) RunAndReturn(run func(ctx context.Context, opts *types.ImageOptions) (chan *types.CacheImageMessage, error)) *Cluster_CacheImage_Call

type Cluster_CalculateCapacity_Call 

type Cluster_CalculateCapacity_Call struct {
	*mock.Call
}

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

func (*Cluster_CalculateCapacity_Call) Return 

func (_c *Cluster_CalculateCapacity_Call) Return(capacityMessage *types.CapacityMessage, err error) *Cluster_CalculateCapacity_Call

func (*Cluster_CalculateCapacity_Call) Run 

func (_c *Cluster_CalculateCapacity_Call) Run(run func(context1 context.Context, deployOptions *types.DeployOptions)) *Cluster_CalculateCapacity_Call

func (*Cluster_CalculateCapacity_Call) RunAndReturn 

func (_c *Cluster_CalculateCapacity_Call) RunAndReturn(run func(context1 context.Context, deployOptions *types.DeployOptions) (*types.CapacityMessage, error)) *Cluster_CalculateCapacity_Call

type Cluster_ConnectNetwork_Call 

type Cluster_ConnectNetwork_Call struct {
	*mock.Call
}

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

func (*Cluster_ConnectNetwork_Call) Return 

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

func (*Cluster_ConnectNetwork_Call) Run 

func (_c *Cluster_ConnectNetwork_Call) Run(run func(ctx context.Context, network string, target string, ipv4 string, ipv6 string)) *Cluster_ConnectNetwork_Call

func (*Cluster_ConnectNetwork_Call) RunAndReturn 

func (_c *Cluster_ConnectNetwork_Call) RunAndReturn(run func(ctx context.Context, network string, target string, ipv4 string, ipv6 string) ([]string, error)) *Cluster_ConnectNetwork_Call

type Cluster_ControlWorkload_Call 

type Cluster_ControlWorkload_Call struct {
	*mock.Call
}

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

func (*Cluster_ControlWorkload_Call) Return 

func (_c *Cluster_ControlWorkload_Call) Return(controlWorkloadMessageCh chan *types.ControlWorkloadMessage, err error) *Cluster_ControlWorkload_Call

func (*Cluster_ControlWorkload_Call) Run 

func (_c *Cluster_ControlWorkload_Call) Run(run func(ctx context.Context, IDs []string, t string, force bool)) *Cluster_ControlWorkload_Call

func (*Cluster_ControlWorkload_Call) RunAndReturn 

func (_c *Cluster_ControlWorkload_Call) RunAndReturn(run func(ctx context.Context, IDs []string, t string, force bool) (chan *types.ControlWorkloadMessage, error)) *Cluster_ControlWorkload_Call

type Cluster_Copy_Call 

type Cluster_Copy_Call struct {
	*mock.Call
}

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

func (*Cluster_Copy_Call) Return 

func (_c *Cluster_Copy_Call) Return(copyMessageCh chan *types.CopyMessage, err error) *Cluster_Copy_Call

func (*Cluster_Copy_Call) Run 

func (_c *Cluster_Copy_Call) Run(run func(ctx context.Context, opts *types.CopyOptions)) *Cluster_Copy_Call

func (*Cluster_Copy_Call) RunAndReturn 

func (_c *Cluster_Copy_Call) RunAndReturn(run func(ctx context.Context, opts *types.CopyOptions) (chan *types.CopyMessage, error)) *Cluster_Copy_Call

type Cluster_CreateWorkload_Call 

type Cluster_CreateWorkload_Call struct {
	*mock.Call
}

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

func (*Cluster_CreateWorkload_Call) Return 

func (_c *Cluster_CreateWorkload_Call) Return(createWorkloadMessageCh chan *types.CreateWorkloadMessage, err error) *Cluster_CreateWorkload_Call

func (*Cluster_CreateWorkload_Call) Run 

func (_c *Cluster_CreateWorkload_Call) Run(run func(ctx context.Context, opts *types.DeployOptions)) *Cluster_CreateWorkload_Call

func (*Cluster_CreateWorkload_Call) RunAndReturn 

func (_c *Cluster_CreateWorkload_Call) RunAndReturn(run func(ctx context.Context, opts *types.DeployOptions) (chan *types.CreateWorkloadMessage, error)) *Cluster_CreateWorkload_Call

type Cluster_DisconnectNetwork_Call 

type Cluster_DisconnectNetwork_Call struct {
	*mock.Call
}

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

func (*Cluster_DisconnectNetwork_Call) Return 

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

func (*Cluster_DisconnectNetwork_Call) Run 

func (_c *Cluster_DisconnectNetwork_Call) Run(run func(ctx context.Context, network string, target string, force bool)) *Cluster_DisconnectNetwork_Call

func (*Cluster_DisconnectNetwork_Call) RunAndReturn 

func (_c *Cluster_DisconnectNetwork_Call) RunAndReturn(run func(ctx context.Context, network string, target string, force bool) error) *Cluster_DisconnectNetwork_Call

type Cluster_DissociateWorkload_Call 

type Cluster_DissociateWorkload_Call struct {
	*mock.Call
}

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

func (*Cluster_DissociateWorkload_Call) Return 

func (_c *Cluster_DissociateWorkload_Call) Return(dissociateWorkloadMessageCh chan *types.DissociateWorkloadMessage, err error) *Cluster_DissociateWorkload_Call

func (*Cluster_DissociateWorkload_Call) Run 

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

func (*Cluster_DissociateWorkload_Call) RunAndReturn 

func (_c *Cluster_DissociateWorkload_Call) RunAndReturn(run func(ctx context.Context, IDs []string) (chan *types.DissociateWorkloadMessage, error)) *Cluster_DissociateWorkload_Call

type Cluster_ExecuteWorkload_Call 

type Cluster_ExecuteWorkload_Call struct {
	*mock.Call
}

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

func (*Cluster_ExecuteWorkload_Call) Return 

func (_c *Cluster_ExecuteWorkload_Call) Return(attachWorkloadMessageCh chan *types.AttachWorkloadMessage) *Cluster_ExecuteWorkload_Call

func (*Cluster_ExecuteWorkload_Call) Run 

func (_c *Cluster_ExecuteWorkload_Call) Run(run func(ctx context.Context, opts *types.ExecuteWorkloadOptions, inCh <-chan []byte)) *Cluster_ExecuteWorkload_Call

func (*Cluster_ExecuteWorkload_Call) RunAndReturn 

func (_c *Cluster_ExecuteWorkload_Call) RunAndReturn(run func(ctx context.Context, opts *types.ExecuteWorkloadOptions, inCh <-chan []byte) chan *types.AttachWorkloadMessage) *Cluster_ExecuteWorkload_Call

type Cluster_Expecter 

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

func (*Cluster_Expecter) AddNode 

func (_e *Cluster_Expecter) AddNode(context1 any, addNodeOptions any) *Cluster_AddNode_Call

AddNode is a helper method to define mock.On call

  • context1 context.Context
  • addNodeOptions *types.AddNodeOptions

func (*Cluster_Expecter) AddPod 

func (_e *Cluster_Expecter) AddPod(ctx any, podname any, desc any) *Cluster_AddPod_Call

AddPod is a helper method to define mock.On call

  • ctx context.Context
  • podname string
  • desc string

func (*Cluster_Expecter) BuildImage 

func (_e *Cluster_Expecter) BuildImage(ctx any, opts any) *Cluster_BuildImage_Call

BuildImage is a helper method to define mock.On call

  • ctx context.Context
  • opts *types.BuildOptions

func (*Cluster_Expecter) CacheImage 

func (_e *Cluster_Expecter) CacheImage(ctx any, opts any) *Cluster_CacheImage_Call

CacheImage is a helper method to define mock.On call

  • ctx context.Context
  • opts *types.ImageOptions

func (*Cluster_Expecter) CalculateCapacity 

func (_e *Cluster_Expecter) CalculateCapacity(context1 any, deployOptions any) *Cluster_CalculateCapacity_Call

CalculateCapacity is a helper method to define mock.On call

  • context1 context.Context
  • deployOptions *types.DeployOptions

func (*Cluster_Expecter) ConnectNetwork 

func (_e *Cluster_Expecter) ConnectNetwork(ctx any, network any, target any, ipv4 any, ipv6 any) *Cluster_ConnectNetwork_Call

ConnectNetwork is a helper method to define mock.On call

  • ctx context.Context
  • network string
  • target string
  • ipv4 string
  • ipv6 string

func (*Cluster_Expecter) ControlWorkload 

func (_e *Cluster_Expecter) ControlWorkload(ctx any, IDs any, t any, force any) *Cluster_ControlWorkload_Call

ControlWorkload is a helper method to define mock.On call

  • ctx context.Context
  • IDs []string
  • t string
  • force bool

func (*Cluster_Expecter) Copy 

func (_e *Cluster_Expecter) Copy(ctx any, opts any) *Cluster_Copy_Call

Copy is a helper method to define mock.On call

  • ctx context.Context
  • opts *types.CopyOptions

func (*Cluster_Expecter) CreateWorkload 

func (_e *Cluster_Expecter) CreateWorkload(ctx any, opts any) *Cluster_CreateWorkload_Call

CreateWorkload is a helper method to define mock.On call

  • ctx context.Context
  • opts *types.DeployOptions

func (*Cluster_Expecter) DisconnectNetwork 

func (_e *Cluster_Expecter) DisconnectNetwork(ctx any, network any, target any, force any) *Cluster_DisconnectNetwork_Call

DisconnectNetwork is a helper method to define mock.On call

  • ctx context.Context
  • network string
  • target string
  • force bool

func (*Cluster_Expecter) DissociateWorkload 

func (_e *Cluster_Expecter) DissociateWorkload(ctx any, IDs any) *Cluster_DissociateWorkload_Call

DissociateWorkload is a helper method to define mock.On call

  • ctx context.Context
  • IDs []string

func (*Cluster_Expecter) ExecuteWorkload 

func (_e *Cluster_Expecter) ExecuteWorkload(ctx any, opts any, inCh any) *Cluster_ExecuteWorkload_Call

ExecuteWorkload is a helper method to define mock.On call

  • ctx context.Context
  • opts *types.ExecuteWorkloadOptions
  • inCh <-chan []byte

func (*Cluster_Expecter) Finalizer 

func (_e *Cluster_Expecter) Finalizer() *Cluster_Finalizer_Call

Finalizer is a helper method to define mock.On call

func (*Cluster_Expecter) GetIdentifier 

func (_e *Cluster_Expecter) GetIdentifier() *Cluster_GetIdentifier_Call

GetIdentifier is a helper method to define mock.On call

func (*Cluster_Expecter) GetNode 

func (_e *Cluster_Expecter) GetNode(ctx any, nodename any) *Cluster_GetNode_Call

GetNode is a helper method to define mock.On call

  • ctx context.Context
  • nodename string

func (*Cluster_Expecter) GetNodeEngineInfo 

func (_e *Cluster_Expecter) GetNodeEngineInfo(ctx any, nodename any) *Cluster_GetNodeEngineInfo_Call

GetNodeEngineInfo is a helper method to define mock.On call

  • ctx context.Context
  • nodename string

func (*Cluster_Expecter) GetNodeStatus 

func (_e *Cluster_Expecter) GetNodeStatus(ctx any, nodename any) *Cluster_GetNodeStatus_Call

GetNodeStatus is a helper method to define mock.On call

  • ctx context.Context
  • nodename string

func (*Cluster_Expecter) GetPod 

func (_e *Cluster_Expecter) GetPod(ctx any, podname any) *Cluster_GetPod_Call

GetPod is a helper method to define mock.On call

  • ctx context.Context
  • podname string

func (*Cluster_Expecter) GetWorkload 

func (_e *Cluster_Expecter) GetWorkload(ctx any, id any) *Cluster_GetWorkload_Call

GetWorkload is a helper method to define mock.On call

  • ctx context.Context
  • id string

func (*Cluster_Expecter) GetWorkloads 

func (_e *Cluster_Expecter) GetWorkloads(ctx any, IDs any) *Cluster_GetWorkloads_Call

GetWorkloads is a helper method to define mock.On call

  • ctx context.Context
  • IDs []string

func (*Cluster_Expecter) GetWorkloadsStatus 

func (_e *Cluster_Expecter) GetWorkloadsStatus(ctx any, IDs any) *Cluster_GetWorkloadsStatus_Call

GetWorkloadsStatus is a helper method to define mock.On call

  • ctx context.Context
  • IDs []string

func (*Cluster_Expecter) ListImage 

func (_e *Cluster_Expecter) ListImage(ctx any, opts any) *Cluster_ListImage_Call

ListImage is a helper method to define mock.On call

  • ctx context.Context
  • opts *types.ImageOptions

func (*Cluster_Expecter) ListNetworks 

func (_e *Cluster_Expecter) ListNetworks(ctx any, podname any, driver any) *Cluster_ListNetworks_Call

ListNetworks is a helper method to define mock.On call

  • ctx context.Context
  • podname string
  • driver string

func (*Cluster_Expecter) ListNodeWorkloads 

func (_e *Cluster_Expecter) ListNodeWorkloads(ctx any, nodename any, labels any) *Cluster_ListNodeWorkloads_Call

ListNodeWorkloads is a helper method to define mock.On call

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

func (*Cluster_Expecter) ListPodNodes 

func (_e *Cluster_Expecter) ListPodNodes(context1 any, listNodesOptions any) *Cluster_ListPodNodes_Call

ListPodNodes is a helper method to define mock.On call

  • context1 context.Context
  • listNodesOptions *types.ListNodesOptions

func (*Cluster_Expecter) ListPods 

func (_e *Cluster_Expecter) ListPods(ctx any) *Cluster_ListPods_Call

ListPods is a helper method to define mock.On call

  • ctx context.Context

func (*Cluster_Expecter) ListWorkloads 

func (_e *Cluster_Expecter) ListWorkloads(ctx any, opts any) *Cluster_ListWorkloads_Call

ListWorkloads is a helper method to define mock.On call

  • ctx context.Context
  • opts *types.ListWorkloadsOptions

func (*Cluster_Expecter) LogStream 

func (_e *Cluster_Expecter) LogStream(ctx any, opts any) *Cluster_LogStream_Call

LogStream is a helper method to define mock.On call

  • ctx context.Context
  • opts *types.LogStreamOptions

func (*Cluster_Expecter) NodeResource 

func (_e *Cluster_Expecter) NodeResource(ctx any, nodename any, fix any) *Cluster_NodeResource_Call

NodeResource is a helper method to define mock.On call

  • ctx context.Context
  • nodename string
  • fix bool

func (*Cluster_Expecter) NodeStatusStream 

func (_e *Cluster_Expecter) NodeStatusStream(ctx any) *Cluster_NodeStatusStream_Call

NodeStatusStream is a helper method to define mock.On call

  • ctx context.Context

func (*Cluster_Expecter) PodResource 

func (_e *Cluster_Expecter) PodResource(ctx any, podname any) *Cluster_PodResource_Call

PodResource is a helper method to define mock.On call

  • ctx context.Context
  • podname string

func (*Cluster_Expecter) RawEngine 

func (_e *Cluster_Expecter) RawEngine(ctx any, opts any) *Cluster_RawEngine_Call

RawEngine is a helper method to define mock.On call

  • ctx context.Context
  • opts *types.RawEngineOptions

func (*Cluster_Expecter) ReallocResource 

func (_e *Cluster_Expecter) ReallocResource(ctx any, opts any) *Cluster_ReallocResource_Call

ReallocResource is a helper method to define mock.On call

  • ctx context.Context
  • opts *types.ReallocOptions

func (*Cluster_Expecter) RemoveImage 

func (_e *Cluster_Expecter) RemoveImage(ctx any, opts any) *Cluster_RemoveImage_Call

RemoveImage is a helper method to define mock.On call

  • ctx context.Context
  • opts *types.ImageOptions

func (*Cluster_Expecter) RemoveNode 

func (_e *Cluster_Expecter) RemoveNode(ctx any, nodename any) *Cluster_RemoveNode_Call

RemoveNode is a helper method to define mock.On call

  • ctx context.Context
  • nodename string

func (*Cluster_Expecter) RemovePod 

func (_e *Cluster_Expecter) RemovePod(ctx any, podname any) *Cluster_RemovePod_Call

RemovePod is a helper method to define mock.On call

  • ctx context.Context
  • podname string

func (*Cluster_Expecter) RemoveWorkload 

func (_e *Cluster_Expecter) RemoveWorkload(ctx any, IDs any, force any) *Cluster_RemoveWorkload_Call

RemoveWorkload is a helper method to define mock.On call

  • ctx context.Context
  • IDs []string
  • force bool

func (*Cluster_Expecter) ReplaceWorkload 

func (_e *Cluster_Expecter) ReplaceWorkload(ctx any, opts any) *Cluster_ReplaceWorkload_Call

ReplaceWorkload is a helper method to define mock.On call

  • ctx context.Context
  • opts *types.ReplaceOptions

func (*Cluster_Expecter) RunAndWait 

func (_e *Cluster_Expecter) RunAndWait(ctx any, opts any, inCh any) *Cluster_RunAndWait_Call

RunAndWait is a helper method to define mock.On call

  • ctx context.Context
  • opts *types.DeployOptions
  • inCh <-chan []byte

func (*Cluster_Expecter) Send 

func (_e *Cluster_Expecter) Send(ctx any, opts any) *Cluster_Send_Call

Send is a helper method to define mock.On call

  • ctx context.Context
  • opts *types.SendOptions

func (*Cluster_Expecter) SendLargeFile 

func (_e *Cluster_Expecter) SendLargeFile(ctx any, opts any) *Cluster_SendLargeFile_Call

SendLargeFile is a helper method to define mock.On call

  • ctx context.Context
  • opts chan *types.SendLargeFileOptions

func (*Cluster_Expecter) SetNode 

func (_e *Cluster_Expecter) SetNode(ctx any, opts any) *Cluster_SetNode_Call

SetNode is a helper method to define mock.On call

  • ctx context.Context
  • opts *types.SetNodeOptions

func (*Cluster_Expecter) SetNodeStatus 

func (_e *Cluster_Expecter) SetNodeStatus(ctx any, nodename any, ttl any) *Cluster_SetNodeStatus_Call

SetNodeStatus is a helper method to define mock.On call

  • ctx context.Context
  • nodename string
  • ttl int64

func (*Cluster_Expecter) SetWorkloadsStatus 

func (_e *Cluster_Expecter) SetWorkloadsStatus(ctx any, status any, ttls any) *Cluster_SetWorkloadsStatus_Call

SetWorkloadsStatus is a helper method to define mock.On call

  • ctx context.Context
  • status []*types.StatusMeta
  • ttls map[string]int64

func (*Cluster_Expecter) WatchServiceStatus 

func (_e *Cluster_Expecter) WatchServiceStatus(context1 any) *Cluster_WatchServiceStatus_Call

WatchServiceStatus is a helper method to define mock.On call

  • context1 context.Context

func (*Cluster_Expecter) WorkloadStatusStream 

func (_e *Cluster_Expecter) WorkloadStatusStream(ctx any, appname any, entrypoint any, nodename any, labels any) *Cluster_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 Cluster_Finalizer_Call 

type Cluster_Finalizer_Call struct {
	*mock.Call
}

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

func (*Cluster_Finalizer_Call) Return 

func (_c *Cluster_Finalizer_Call) Return() *Cluster_Finalizer_Call

func (*Cluster_Finalizer_Call) Run 

func (_c *Cluster_Finalizer_Call) Run(run func()) *Cluster_Finalizer_Call

func (*Cluster_Finalizer_Call) RunAndReturn 

func (_c *Cluster_Finalizer_Call) RunAndReturn(run func()) *Cluster_Finalizer_Call

type Cluster_GetIdentifier_Call 

type Cluster_GetIdentifier_Call struct {
	*mock.Call
}

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

func (*Cluster_GetIdentifier_Call) Return 

func (_c *Cluster_GetIdentifier_Call) Return(s string) *Cluster_GetIdentifier_Call

func (*Cluster_GetIdentifier_Call) Run 

func (_c *Cluster_GetIdentifier_Call) Run(run func()) *Cluster_GetIdentifier_Call

func (*Cluster_GetIdentifier_Call) RunAndReturn 

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

type Cluster_GetNodeEngineInfo_Call 

type Cluster_GetNodeEngineInfo_Call struct {
	*mock.Call
}

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

func (*Cluster_GetNodeEngineInfo_Call) Return 

func (_c *Cluster_GetNodeEngineInfo_Call) Return(info *types0.Info, err error) *Cluster_GetNodeEngineInfo_Call

func (*Cluster_GetNodeEngineInfo_Call) Run 

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

func (*Cluster_GetNodeEngineInfo_Call) RunAndReturn 

func (_c *Cluster_GetNodeEngineInfo_Call) RunAndReturn(run func(ctx context.Context, nodename string) (*types0.Info, error)) *Cluster_GetNodeEngineInfo_Call

type Cluster_GetNodeStatus_Call 

type Cluster_GetNodeStatus_Call struct {
	*mock.Call
}

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

func (*Cluster_GetNodeStatus_Call) Return 

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

func (*Cluster_GetNodeStatus_Call) Run 

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

func (*Cluster_GetNodeStatus_Call) RunAndReturn 

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

type Cluster_GetNode_Call 

type Cluster_GetNode_Call struct {
	*mock.Call
}

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

func (*Cluster_GetNode_Call) Return 

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

func (*Cluster_GetNode_Call) Run 

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

func (*Cluster_GetNode_Call) RunAndReturn 

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

type Cluster_GetPod_Call 

type Cluster_GetPod_Call struct {
	*mock.Call
}

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

func (*Cluster_GetPod_Call) Return 

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

func (*Cluster_GetPod_Call) Run 

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

func (*Cluster_GetPod_Call) RunAndReturn 

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

type Cluster_GetWorkload_Call 

type Cluster_GetWorkload_Call struct {
	*mock.Call
}

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

func (*Cluster_GetWorkload_Call) Return 

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

func (*Cluster_GetWorkload_Call) Run 

func (_c *Cluster_GetWorkload_Call) Run(run func(ctx context.Context, id string)) *Cluster_GetWorkload_Call

func (*Cluster_GetWorkload_Call) RunAndReturn 

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

type Cluster_GetWorkloadsStatus_Call 

type Cluster_GetWorkloadsStatus_Call struct {
	*mock.Call
}

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

func (*Cluster_GetWorkloadsStatus_Call) Return 

func (_c *Cluster_GetWorkloadsStatus_Call) Return(statusMetas []*types.StatusMeta, err error) *Cluster_GetWorkloadsStatus_Call

func (*Cluster_GetWorkloadsStatus_Call) Run 

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

func (*Cluster_GetWorkloadsStatus_Call) RunAndReturn 

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

type Cluster_GetWorkloads_Call 

type Cluster_GetWorkloads_Call struct {
	*mock.Call
}

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

func (*Cluster_GetWorkloads_Call) Return 

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

func (*Cluster_GetWorkloads_Call) Run 

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

func (*Cluster_GetWorkloads_Call) RunAndReturn 

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

type Cluster_ListImage_Call 

type Cluster_ListImage_Call struct {
	*mock.Call
}

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

func (*Cluster_ListImage_Call) Return 

func (_c *Cluster_ListImage_Call) Return(listImageMessageCh chan *types.ListImageMessage, err error) *Cluster_ListImage_Call

func (*Cluster_ListImage_Call) Run 

func (_c *Cluster_ListImage_Call) Run(run func(ctx context.Context, opts *types.ImageOptions)) *Cluster_ListImage_Call

func (*Cluster_ListImage_Call) RunAndReturn 

func (_c *Cluster_ListImage_Call) RunAndReturn(run func(ctx context.Context, opts *types.ImageOptions) (chan *types.ListImageMessage, error)) *Cluster_ListImage_Call

type Cluster_ListNetworks_Call 

type Cluster_ListNetworks_Call struct {
	*mock.Call
}

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

func (*Cluster_ListNetworks_Call) Return 

func (_c *Cluster_ListNetworks_Call) Return(networks []*types0.Network, err error) *Cluster_ListNetworks_Call

func (*Cluster_ListNetworks_Call) Run 

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

func (*Cluster_ListNetworks_Call) RunAndReturn 

func (_c *Cluster_ListNetworks_Call) RunAndReturn(run func(ctx context.Context, podname string, driver string) ([]*types0.Network, error)) *Cluster_ListNetworks_Call

type Cluster_ListNodeWorkloads_Call 

type Cluster_ListNodeWorkloads_Call struct {
	*mock.Call
}

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

func (*Cluster_ListNodeWorkloads_Call) Return 

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

func (*Cluster_ListNodeWorkloads_Call) Run 

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

func (*Cluster_ListNodeWorkloads_Call) RunAndReturn 

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

type Cluster_ListPodNodes_Call 

type Cluster_ListPodNodes_Call struct {
	*mock.Call
}

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

func (*Cluster_ListPodNodes_Call) Return 

func (_c *Cluster_ListPodNodes_Call) Return(nodeCh <-chan *types.Node, err error) *Cluster_ListPodNodes_Call

func (*Cluster_ListPodNodes_Call) Run 

func (_c *Cluster_ListPodNodes_Call) Run(run func(context1 context.Context, listNodesOptions *types.ListNodesOptions)) *Cluster_ListPodNodes_Call

func (*Cluster_ListPodNodes_Call) RunAndReturn 

func (_c *Cluster_ListPodNodes_Call) RunAndReturn(run func(context1 context.Context, listNodesOptions *types.ListNodesOptions) (<-chan *types.Node, error)) *Cluster_ListPodNodes_Call

type Cluster_ListPods_Call 

type Cluster_ListPods_Call struct {
	*mock.Call
}

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

func (*Cluster_ListPods_Call) Return 

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

func (*Cluster_ListPods_Call) Run 

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

func (*Cluster_ListPods_Call) RunAndReturn 

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

type Cluster_ListWorkloads_Call 

type Cluster_ListWorkloads_Call struct {
	*mock.Call
}

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

func (*Cluster_ListWorkloads_Call) Return 

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

func (*Cluster_ListWorkloads_Call) Run 

func (_c *Cluster_ListWorkloads_Call) Run(run func(ctx context.Context, opts *types.ListWorkloadsOptions)) *Cluster_ListWorkloads_Call

func (*Cluster_ListWorkloads_Call) RunAndReturn 

func (_c *Cluster_ListWorkloads_Call) RunAndReturn(run func(ctx context.Context, opts *types.ListWorkloadsOptions) ([]*types.Workload, error)) *Cluster_ListWorkloads_Call

type Cluster_LogStream_Call 

type Cluster_LogStream_Call struct {
	*mock.Call
}

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

func (*Cluster_LogStream_Call) Return 

func (_c *Cluster_LogStream_Call) Return(logStreamMessageCh chan *types.LogStreamMessage, err error) *Cluster_LogStream_Call

func (*Cluster_LogStream_Call) Run 

func (_c *Cluster_LogStream_Call) Run(run func(ctx context.Context, opts *types.LogStreamOptions)) *Cluster_LogStream_Call

func (*Cluster_LogStream_Call) RunAndReturn 

func (_c *Cluster_LogStream_Call) RunAndReturn(run func(ctx context.Context, opts *types.LogStreamOptions) (chan *types.LogStreamMessage, error)) *Cluster_LogStream_Call

type Cluster_NodeResource_Call 

type Cluster_NodeResource_Call struct {
	*mock.Call
}

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

func (*Cluster_NodeResource_Call) Return 

func (_c *Cluster_NodeResource_Call) Return(nodeResourceInfo *types.NodeResourceInfo, err error) *Cluster_NodeResource_Call

func (*Cluster_NodeResource_Call) Run 

func (_c *Cluster_NodeResource_Call) Run(run func(ctx context.Context, nodename string, fix bool)) *Cluster_NodeResource_Call

func (*Cluster_NodeResource_Call) RunAndReturn 

func (_c *Cluster_NodeResource_Call) RunAndReturn(run func(ctx context.Context, nodename string, fix bool) (*types.NodeResourceInfo, error)) *Cluster_NodeResource_Call

type Cluster_NodeStatusStream_Call 

type Cluster_NodeStatusStream_Call struct {
	*mock.Call
}

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

func (*Cluster_NodeStatusStream_Call) Return 

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

func (*Cluster_NodeStatusStream_Call) Run 

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

func (*Cluster_NodeStatusStream_Call) RunAndReturn 

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

type Cluster_PodResource_Call 

type Cluster_PodResource_Call struct {
	*mock.Call
}

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

func (*Cluster_PodResource_Call) Return 

func (_c *Cluster_PodResource_Call) Return(nodeResourceInfoCh chan *types.NodeResourceInfo, err error) *Cluster_PodResource_Call

func (*Cluster_PodResource_Call) Run 

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

func (*Cluster_PodResource_Call) RunAndReturn 

func (_c *Cluster_PodResource_Call) RunAndReturn(run func(ctx context.Context, podname string) (chan *types.NodeResourceInfo, error)) *Cluster_PodResource_Call

type Cluster_RawEngine_Call 

type Cluster_RawEngine_Call struct {
	*mock.Call
}

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

func (*Cluster_RawEngine_Call) Return 

func (_c *Cluster_RawEngine_Call) Return(rawEngineMessage *types.RawEngineMessage, err error) *Cluster_RawEngine_Call

func (*Cluster_RawEngine_Call) Run 

func (_c *Cluster_RawEngine_Call) Run(run func(ctx context.Context, opts *types.RawEngineOptions)) *Cluster_RawEngine_Call

func (*Cluster_RawEngine_Call) RunAndReturn 

func (_c *Cluster_RawEngine_Call) RunAndReturn(run func(ctx context.Context, opts *types.RawEngineOptions) (*types.RawEngineMessage, error)) *Cluster_RawEngine_Call

type Cluster_ReallocResource_Call 

type Cluster_ReallocResource_Call struct {
	*mock.Call
}

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

func (*Cluster_ReallocResource_Call) Return 

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

func (*Cluster_ReallocResource_Call) Run 

func (_c *Cluster_ReallocResource_Call) Run(run func(ctx context.Context, opts *types.ReallocOptions)) *Cluster_ReallocResource_Call

func (*Cluster_ReallocResource_Call) RunAndReturn 

func (_c *Cluster_ReallocResource_Call) RunAndReturn(run func(ctx context.Context, opts *types.ReallocOptions) error) *Cluster_ReallocResource_Call

type Cluster_RemoveImage_Call 

type Cluster_RemoveImage_Call struct {
	*mock.Call
}

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

func (*Cluster_RemoveImage_Call) Return 

func (_c *Cluster_RemoveImage_Call) Return(removeImageMessageCh chan *types.RemoveImageMessage, err error) *Cluster_RemoveImage_Call

func (*Cluster_RemoveImage_Call) Run 

func (_c *Cluster_RemoveImage_Call) Run(run func(ctx context.Context, opts *types.ImageOptions)) *Cluster_RemoveImage_Call

func (*Cluster_RemoveImage_Call) RunAndReturn 

func (_c *Cluster_RemoveImage_Call) RunAndReturn(run func(ctx context.Context, opts *types.ImageOptions) (chan *types.RemoveImageMessage, error)) *Cluster_RemoveImage_Call

type Cluster_RemoveNode_Call 

type Cluster_RemoveNode_Call struct {
	*mock.Call
}

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

func (*Cluster_RemoveNode_Call) Return 

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

func (*Cluster_RemoveNode_Call) Run 

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

func (*Cluster_RemoveNode_Call) RunAndReturn 

func (_c *Cluster_RemoveNode_Call) RunAndReturn(run func(ctx context.Context, nodename string) error) *Cluster_RemoveNode_Call

type Cluster_RemovePod_Call 

type Cluster_RemovePod_Call struct {
	*mock.Call
}

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

func (*Cluster_RemovePod_Call) Return 

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

func (*Cluster_RemovePod_Call) Run 

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

func (*Cluster_RemovePod_Call) RunAndReturn 

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

type Cluster_RemoveWorkload_Call 

type Cluster_RemoveWorkload_Call struct {
	*mock.Call
}

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

func (*Cluster_RemoveWorkload_Call) Return 

func (_c *Cluster_RemoveWorkload_Call) Return(removeWorkloadMessageCh chan *types.RemoveWorkloadMessage, err error) *Cluster_RemoveWorkload_Call

func (*Cluster_RemoveWorkload_Call) Run 

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

func (*Cluster_RemoveWorkload_Call) RunAndReturn 

func (_c *Cluster_RemoveWorkload_Call) RunAndReturn(run func(ctx context.Context, IDs []string, force bool) (chan *types.RemoveWorkloadMessage, error)) *Cluster_RemoveWorkload_Call

type Cluster_ReplaceWorkload_Call 

type Cluster_ReplaceWorkload_Call struct {
	*mock.Call
}

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

func (*Cluster_ReplaceWorkload_Call) Return 

func (_c *Cluster_ReplaceWorkload_Call) Return(replaceWorkloadMessageCh chan *types.ReplaceWorkloadMessage, err error) *Cluster_ReplaceWorkload_Call

func (*Cluster_ReplaceWorkload_Call) Run 

func (_c *Cluster_ReplaceWorkload_Call) Run(run func(ctx context.Context, opts *types.ReplaceOptions)) *Cluster_ReplaceWorkload_Call

func (*Cluster_ReplaceWorkload_Call) RunAndReturn 

func (_c *Cluster_ReplaceWorkload_Call) RunAndReturn(run func(ctx context.Context, opts *types.ReplaceOptions) (chan *types.ReplaceWorkloadMessage, error)) *Cluster_ReplaceWorkload_Call

type Cluster_RunAndWait_Call 

type Cluster_RunAndWait_Call struct {
	*mock.Call
}

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

func (*Cluster_RunAndWait_Call) Return 

func (_c *Cluster_RunAndWait_Call) Return(strings []string, attachWorkloadMessageCh <-chan *types.AttachWorkloadMessage, err error) *Cluster_RunAndWait_Call

func (*Cluster_RunAndWait_Call) Run 

func (_c *Cluster_RunAndWait_Call) Run(run func(ctx context.Context, opts *types.DeployOptions, inCh <-chan []byte)) *Cluster_RunAndWait_Call

func (*Cluster_RunAndWait_Call) RunAndReturn 

func (_c *Cluster_RunAndWait_Call) RunAndReturn(run func(ctx context.Context, opts *types.DeployOptions, inCh <-chan []byte) ([]string, <-chan *types.AttachWorkloadMessage, error)) *Cluster_RunAndWait_Call

type Cluster_SendLargeFile_Call 

type Cluster_SendLargeFile_Call struct {
	*mock.Call
}

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

func (*Cluster_SendLargeFile_Call) Return 

func (_c *Cluster_SendLargeFile_Call) Return(sendMessageCh chan *types.SendMessage) *Cluster_SendLargeFile_Call

func (*Cluster_SendLargeFile_Call) Run 

func (_c *Cluster_SendLargeFile_Call) Run(run func(ctx context.Context, opts chan *types.SendLargeFileOptions)) *Cluster_SendLargeFile_Call

func (*Cluster_SendLargeFile_Call) RunAndReturn 

func (_c *Cluster_SendLargeFile_Call) RunAndReturn(run func(ctx context.Context, opts chan *types.SendLargeFileOptions) chan *types.SendMessage) *Cluster_SendLargeFile_Call

type Cluster_Send_Call 

type Cluster_Send_Call struct {
	*mock.Call
}

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

func (*Cluster_Send_Call) Return 

func (_c *Cluster_Send_Call) Return(sendMessageCh chan *types.SendMessage, err error) *Cluster_Send_Call

func (*Cluster_Send_Call) Run 

func (_c *Cluster_Send_Call) Run(run func(ctx context.Context, opts *types.SendOptions)) *Cluster_Send_Call

func (*Cluster_Send_Call) RunAndReturn 

func (_c *Cluster_Send_Call) RunAndReturn(run func(ctx context.Context, opts *types.SendOptions) (chan *types.SendMessage, error)) *Cluster_Send_Call

type Cluster_SetNodeStatus_Call 

type Cluster_SetNodeStatus_Call struct {
	*mock.Call
}

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

func (*Cluster_SetNodeStatus_Call) Return 

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

func (*Cluster_SetNodeStatus_Call) Run 

func (_c *Cluster_SetNodeStatus_Call) Run(run func(ctx context.Context, nodename string, ttl int64)) *Cluster_SetNodeStatus_Call

func (*Cluster_SetNodeStatus_Call) RunAndReturn 

func (_c *Cluster_SetNodeStatus_Call) RunAndReturn(run func(ctx context.Context, nodename string, ttl int64) error) *Cluster_SetNodeStatus_Call

type Cluster_SetNode_Call 

type Cluster_SetNode_Call struct {
	*mock.Call
}

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

func (*Cluster_SetNode_Call) Return 

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

func (*Cluster_SetNode_Call) Run 

func (_c *Cluster_SetNode_Call) Run(run func(ctx context.Context, opts *types.SetNodeOptions)) *Cluster_SetNode_Call

func (*Cluster_SetNode_Call) RunAndReturn 

func (_c *Cluster_SetNode_Call) RunAndReturn(run func(ctx context.Context, opts *types.SetNodeOptions) (*types.Node, error)) *Cluster_SetNode_Call

type Cluster_SetWorkloadsStatus_Call 

type Cluster_SetWorkloadsStatus_Call struct {
	*mock.Call
}

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

func (*Cluster_SetWorkloadsStatus_Call) Return 

func (_c *Cluster_SetWorkloadsStatus_Call) Return(statusMetas []*types.StatusMeta, err error) *Cluster_SetWorkloadsStatus_Call

func (*Cluster_SetWorkloadsStatus_Call) Run 

func (_c *Cluster_SetWorkloadsStatus_Call) Run(run func(ctx context.Context, status []*types.StatusMeta, ttls map[string]int64)) *Cluster_SetWorkloadsStatus_Call

func (*Cluster_SetWorkloadsStatus_Call) RunAndReturn 

func (_c *Cluster_SetWorkloadsStatus_Call) RunAndReturn(run func(ctx context.Context, status []*types.StatusMeta, ttls map[string]int64) ([]*types.StatusMeta, error)) *Cluster_SetWorkloadsStatus_Call

type Cluster_WatchServiceStatus_Call 

type Cluster_WatchServiceStatus_Call struct {
	*mock.Call
}

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

func (*Cluster_WatchServiceStatus_Call) Return 

func (_c *Cluster_WatchServiceStatus_Call) Return(serviceStatusCh <-chan types.ServiceStatus, err error) *Cluster_WatchServiceStatus_Call

func (*Cluster_WatchServiceStatus_Call) Run 

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

func (*Cluster_WatchServiceStatus_Call) RunAndReturn 

func (_c *Cluster_WatchServiceStatus_Call) RunAndReturn(run func(context1 context.Context) (<-chan types.ServiceStatus, error)) *Cluster_WatchServiceStatus_Call

type Cluster_WorkloadStatusStream_Call 

type Cluster_WorkloadStatusStream_Call struct {
	*mock.Call
}

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

func (*Cluster_WorkloadStatusStream_Call) Return 

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

func (*Cluster_WorkloadStatusStream_Call) Run 

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

func (*Cluster_WorkloadStatusStream_Call) RunAndReturn 

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