Documentation ¶
Index ¶
- type Cluster
- func (_m *Cluster) AddNode(_a0 context.Context, _a1 *types.AddNodeOptions) (*types.Node, error)
- func (_m *Cluster) AddPod(ctx context.Context, podname string, desc string) (*types.Pod, error)
- func (_m *Cluster) BuildImage(ctx context.Context, opts *types.BuildOptions) (chan *types.BuildImageMessage, error)
- func (_m *Cluster) CacheImage(ctx context.Context, opts *types.ImageOptions) (chan *types.CacheImageMessage, error)
- func (_m *Cluster) CalculateCapacity(_a0 context.Context, _a1 *types.DeployOptions) (*types.CapacityMessage, error)
- func (_m *Cluster) ConnectNetwork(ctx context.Context, network string, target string, ipv4 string, ipv6 string) ([]string, error)
- func (_m *Cluster) ControlWorkload(ctx context.Context, IDs []string, t string, force bool) (chan *types.ControlWorkloadMessage, error)
- func (_m *Cluster) Copy(ctx context.Context, opts *types.CopyOptions) (chan *types.CopyMessage, error)
- func (_m *Cluster) CreateWorkload(ctx context.Context, opts *types.DeployOptions) (chan *types.CreateWorkloadMessage, error)
- func (_m *Cluster) DisconnectNetwork(ctx context.Context, network string, target string, force bool) error
- func (_m *Cluster) DissociateWorkload(ctx context.Context, IDs []string) (chan *types.DissociateWorkloadMessage, error)
- func (_m *Cluster) ExecuteWorkload(ctx context.Context, opts *types.ExecuteWorkloadOptions, inCh <-chan []byte) chan *types.AttachWorkloadMessage
- func (_m *Cluster) Finalizer()
- func (_m *Cluster) GetIdentifier() string
- func (_m *Cluster) GetNode(ctx context.Context, nodename string) (*types.Node, error)
- func (_m *Cluster) GetNodeEngineInfo(ctx context.Context, nodename string) (*enginetypes.Info, error)
- func (_m *Cluster) GetNodeStatus(ctx context.Context, nodename string) (*types.NodeStatus, error)
- func (_m *Cluster) GetPod(ctx context.Context, podname string) (*types.Pod, error)
- func (_m *Cluster) GetWorkload(ctx context.Context, id string) (*types.Workload, error)
- func (_m *Cluster) GetWorkloads(ctx context.Context, IDs []string) ([]*types.Workload, error)
- func (_m *Cluster) GetWorkloadsStatus(ctx context.Context, IDs []string) ([]*types.StatusMeta, error)
- func (_m *Cluster) ListImage(ctx context.Context, opts *types.ImageOptions) (chan *types.ListImageMessage, error)
- func (_m *Cluster) ListNetworks(ctx context.Context, podname string, driver string) ([]*enginetypes.Network, error)
- func (_m *Cluster) ListNodeWorkloads(ctx context.Context, nodename string, labels map[string]string) ([]*types.Workload, error)
- func (_m *Cluster) ListPodNodes(_a0 context.Context, _a1 *types.ListNodesOptions) (<-chan *types.Node, error)
- func (_m *Cluster) ListPods(ctx context.Context) ([]*types.Pod, error)
- func (_m *Cluster) ListWorkloads(ctx context.Context, opts *types.ListWorkloadsOptions) ([]*types.Workload, error)
- func (_m *Cluster) LogStream(ctx context.Context, opts *types.LogStreamOptions) (chan *types.LogStreamMessage, error)
- func (_m *Cluster) NodeResource(ctx context.Context, nodename string, fix bool) (*types.NodeResourceInfo, error)
- func (_m *Cluster) NodeStatusStream(ctx context.Context) chan *types.NodeStatus
- func (_m *Cluster) PodResource(ctx context.Context, podname string) (chan *types.NodeResourceInfo, error)
- func (_m *Cluster) RawEngine(ctx context.Context, opts *types.RawEngineOptions) (*types.RawEngineMessage, error)
- func (_m *Cluster) ReallocResource(ctx context.Context, opts *types.ReallocOptions) error
- func (_m *Cluster) RemoveImage(ctx context.Context, opts *types.ImageOptions) (chan *types.RemoveImageMessage, error)
- func (_m *Cluster) RemoveNode(ctx context.Context, nodename string) error
- func (_m *Cluster) RemovePod(ctx context.Context, podname string) error
- func (_m *Cluster) RemoveWorkload(ctx context.Context, IDs []string, force bool) (chan *types.RemoveWorkloadMessage, error)
- func (_m *Cluster) RemoveWorkloadSync(ctx context.Context, IDs []string) error
- func (_m *Cluster) ReplaceWorkload(ctx context.Context, opts *types.ReplaceOptions) (chan *types.ReplaceWorkloadMessage, error)
- func (_m *Cluster) RunAndWait(ctx context.Context, opts *types.DeployOptions, inCh <-chan []byte) ([]string, <-chan *types.AttachWorkloadMessage, error)
- func (_m *Cluster) Send(ctx context.Context, opts *types.SendOptions) (chan *types.SendMessage, error)
- func (_m *Cluster) SendLargeFile(ctx context.Context, opts chan *types.SendLargeFileOptions) chan *types.SendMessage
- func (_m *Cluster) SetNode(ctx context.Context, opts *types.SetNodeOptions) (*types.Node, error)
- func (_m *Cluster) SetNodeStatus(ctx context.Context, nodename string, ttl int64) error
- func (_m *Cluster) SetWorkloadsStatus(ctx context.Context, status []*types.StatusMeta, ttls map[string]int64) ([]*types.StatusMeta, error)
- func (_m *Cluster) WatchServiceStatus(_a0 context.Context) (<-chan types.ServiceStatus, error)
- func (_m *Cluster) WorkloadStatusStream(ctx context.Context, appname string, entrypoint string, nodename string, ...) chan *types.WorkloadStatus
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Cluster ¶
Cluster is an autogenerated mock type for the Cluster type
func NewCluster ¶
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) BuildImage ¶
func (_m *Cluster) BuildImage(ctx context.Context, opts *types.BuildOptions) (chan *types.BuildImageMessage, error)
BuildImage provides a mock function with given fields: ctx, opts
func (*Cluster) CacheImage ¶
func (_m *Cluster) CacheImage(ctx context.Context, opts *types.ImageOptions) (chan *types.CacheImageMessage, error)
CacheImage provides a mock function with given fields: ctx, opts
func (*Cluster) CalculateCapacity ¶
func (_m *Cluster) CalculateCapacity(_a0 context.Context, _a1 *types.DeployOptions) (*types.CapacityMessage, error)
CalculateCapacity provides a mock function with given fields: _a0, _a1
func (*Cluster) ConnectNetwork ¶
func (_m *Cluster) ConnectNetwork(ctx context.Context, network string, target string, ipv4 string, ipv6 string) ([]string, error)
ConnectNetwork provides a mock function with given fields: ctx, network, target, ipv4, ipv6
func (*Cluster) ControlWorkload ¶
func (_m *Cluster) ControlWorkload(ctx context.Context, IDs []string, t string, force bool) (chan *types.ControlWorkloadMessage, error)
ControlWorkload provides a mock function with given fields: ctx, IDs, t, force
func (*Cluster) Copy ¶
func (_m *Cluster) Copy(ctx context.Context, opts *types.CopyOptions) (chan *types.CopyMessage, error)
Copy provides a mock function with given fields: ctx, opts
func (*Cluster) CreateWorkload ¶
func (_m *Cluster) CreateWorkload(ctx context.Context, opts *types.DeployOptions) (chan *types.CreateWorkloadMessage, error)
CreateWorkload provides a mock function with given fields: ctx, opts
func (*Cluster) DisconnectNetwork ¶
func (_m *Cluster) DisconnectNetwork(ctx context.Context, network string, target string, force bool) error
DisconnectNetwork provides a mock function with given fields: ctx, network, target, force
func (*Cluster) DissociateWorkload ¶
func (_m *Cluster) DissociateWorkload(ctx context.Context, IDs []string) (chan *types.DissociateWorkloadMessage, error)
DissociateWorkload provides a mock function with given fields: ctx, IDs
func (*Cluster) ExecuteWorkload ¶
func (_m *Cluster) ExecuteWorkload(ctx context.Context, opts *types.ExecuteWorkloadOptions, inCh <-chan []byte) chan *types.AttachWorkloadMessage
ExecuteWorkload provides a mock function with given fields: ctx, opts, inCh
func (*Cluster) Finalizer ¶
func (_m *Cluster) Finalizer()
Finalizer provides a mock function with given fields:
func (*Cluster) GetIdentifier ¶
GetIdentifier provides a mock function with given fields:
func (*Cluster) GetNodeEngineInfo ¶
func (_m *Cluster) GetNodeEngineInfo(ctx context.Context, nodename string) (*enginetypes.Info, error)
GetNodeEngineInfo provides a mock function with given fields: ctx, nodename
func (*Cluster) GetNodeStatus ¶
GetNodeStatus provides a mock function with given fields: ctx, nodename
func (*Cluster) GetWorkload ¶
GetWorkload provides a mock function with given fields: ctx, id
func (*Cluster) GetWorkloads ¶
GetWorkloads provides a mock function with given fields: ctx, IDs
func (*Cluster) GetWorkloadsStatus ¶
func (_m *Cluster) GetWorkloadsStatus(ctx context.Context, IDs []string) ([]*types.StatusMeta, error)
GetWorkloadsStatus provides a mock function with given fields: ctx, IDs
func (*Cluster) ListImage ¶
func (_m *Cluster) ListImage(ctx context.Context, opts *types.ImageOptions) (chan *types.ListImageMessage, error)
ListImage provides a mock function with given fields: ctx, opts
func (*Cluster) ListNetworks ¶
func (_m *Cluster) ListNetworks(ctx context.Context, podname string, driver string) ([]*enginetypes.Network, error)
ListNetworks provides a mock function with given fields: ctx, podname, driver
func (*Cluster) ListNodeWorkloads ¶
func (_m *Cluster) ListNodeWorkloads(ctx context.Context, nodename string, labels map[string]string) ([]*types.Workload, error)
ListNodeWorkloads provides a mock function with given fields: ctx, nodename, labels
func (*Cluster) ListPodNodes ¶
func (_m *Cluster) ListPodNodes(_a0 context.Context, _a1 *types.ListNodesOptions) (<-chan *types.Node, error)
ListPodNodes provides a mock function with given fields: _a0, _a1
func (*Cluster) ListWorkloads ¶
func (_m *Cluster) ListWorkloads(ctx context.Context, opts *types.ListWorkloadsOptions) ([]*types.Workload, error)
ListWorkloads provides a mock function with given fields: ctx, opts
func (*Cluster) LogStream ¶
func (_m *Cluster) LogStream(ctx context.Context, opts *types.LogStreamOptions) (chan *types.LogStreamMessage, error)
LogStream provides a mock function with given fields: ctx, opts
func (*Cluster) NodeResource ¶
func (_m *Cluster) NodeResource(ctx context.Context, nodename string, fix bool) (*types.NodeResourceInfo, error)
NodeResource provides a mock function with given fields: ctx, nodename, fix
func (*Cluster) NodeStatusStream ¶
func (_m *Cluster) NodeStatusStream(ctx context.Context) chan *types.NodeStatus
NodeStatusStream provides a mock function with given fields: ctx
func (*Cluster) PodResource ¶
func (_m *Cluster) PodResource(ctx context.Context, podname string) (chan *types.NodeResourceInfo, error)
PodResource provides a mock function with given fields: ctx, podname
func (*Cluster) RawEngine ¶
func (_m *Cluster) RawEngine(ctx context.Context, opts *types.RawEngineOptions) (*types.RawEngineMessage, error)
RawEngine provides a mock function with given fields: ctx, opts
func (*Cluster) ReallocResource ¶
ReallocResource provides a mock function with given fields: ctx, opts
func (*Cluster) RemoveImage ¶
func (_m *Cluster) RemoveImage(ctx context.Context, opts *types.ImageOptions) (chan *types.RemoveImageMessage, error)
RemoveImage provides a mock function with given fields: ctx, opts
func (*Cluster) RemoveNode ¶
RemoveNode provides a mock function with given fields: ctx, nodename
func (*Cluster) RemoveWorkload ¶
func (_m *Cluster) RemoveWorkload(ctx context.Context, IDs []string, force bool) (chan *types.RemoveWorkloadMessage, error)
RemoveWorkload provides a mock function with given fields: ctx, IDs, force
func (*Cluster) RemoveWorkloadSync ¶
RemoveWorkloadSync provides a mock function with given fields: ctx, IDs
func (*Cluster) ReplaceWorkload ¶
func (_m *Cluster) ReplaceWorkload(ctx context.Context, opts *types.ReplaceOptions) (chan *types.ReplaceWorkloadMessage, error)
ReplaceWorkload provides a mock function with given fields: ctx, opts
func (*Cluster) RunAndWait ¶
func (_m *Cluster) RunAndWait(ctx context.Context, opts *types.DeployOptions, inCh <-chan []byte) ([]string, <-chan *types.AttachWorkloadMessage, error)
RunAndWait provides a mock function with given fields: ctx, opts, inCh
func (*Cluster) Send ¶
func (_m *Cluster) Send(ctx context.Context, opts *types.SendOptions) (chan *types.SendMessage, error)
Send provides a mock function with given fields: ctx, opts
func (*Cluster) SendLargeFile ¶
func (_m *Cluster) SendLargeFile(ctx context.Context, opts chan *types.SendLargeFileOptions) chan *types.SendMessage
SendLargeFile provides a mock function with given fields: ctx, opts
func (*Cluster) SetNodeStatus ¶
SetNodeStatus provides a mock function with given fields: ctx, nodename, ttl
func (*Cluster) SetWorkloadsStatus ¶
func (_m *Cluster) SetWorkloadsStatus(ctx context.Context, status []*types.StatusMeta, ttls map[string]int64) ([]*types.StatusMeta, error)
SetWorkloadsStatus provides a mock function with given fields: ctx, status, ttls
func (*Cluster) WatchServiceStatus ¶
WatchServiceStatus provides a mock function with given fields: _a0
func (*Cluster) WorkloadStatusStream ¶
func (_m *Cluster) WorkloadStatusStream(ctx context.Context, appname string, entrypoint string, nodename string, labels map[string]string) chan *types.WorkloadStatus
WorkloadStatusStream provides a mock function with given fields: ctx, appname, entrypoint, nodename, labels