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: 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) 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) 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_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.