Documentation ¶
Index ¶
- type Client
- func (_m *Client) AllHostnames(_a0 context.Context) ([]hostname.ActiveHostname, error)
- func (_m *Client) ConnectHostnameToDeployment(ctx context.Context, directive hostname.ConnectToDeploymentDirective) error
- func (_m *Client) DeclareHostname(ctx context.Context, lID v1beta4.LeaseID, host string, serviceName string, ...) error
- func (_m *Client) DeclareIP(ctx context.Context, lID v1beta4.LeaseID, serviceName string, port uint32, ...) error
- func (_m *Client) Deploy(ctx context.Context, deployment v1beta3.IDeployment) error
- func (_m *Client) Deployments(_a0 context.Context) ([]v1beta3.IDeployment, error)
- func (_m *Client) EXPECT() *Client_Expecter
- func (_m *Client) Exec(ctx context.Context, lID v1beta4.LeaseID, service string, podIndex uint, ...) (v1beta3.ExecResult, error)
- func (_m *Client) ForwardedPortStatus(_a0 context.Context, _a1 v1beta4.LeaseID) (map[string][]v1beta3.ForwardedPortStatus, error)
- func (_m *Client) GetDeclaredIPs(ctx context.Context, leaseID v1beta4.LeaseID) ([]akash_networkv2beta2.ProviderLeasedIPSpec, error)
- func (_m *Client) GetHostnameDeploymentConnections(ctx context.Context) ([]hostname.LeaseIDConnection, error)
- func (_m *Client) GetManifestGroup(_a0 context.Context, _a1 v1beta4.LeaseID) (bool, akash_networkv2beta2.ManifestGroup, error)
- func (_m *Client) KubeVersion() (*version.Info, error)
- func (_m *Client) LeaseEvents(_a0 context.Context, _a1 v1beta4.LeaseID, _a2 string, _a3 bool) (v1beta3.EventsWatcher, error)
- func (_m *Client) LeaseLogs(_a0 context.Context, _a1 v1beta4.LeaseID, _a2 string, _a3 bool, _a4 *int64) ([]*v1beta3.ServiceLog, error)
- func (_m *Client) LeaseStatus(_a0 context.Context, _a1 v1beta4.LeaseID) (map[string]*v1beta3.ServiceStatus, error)
- func (_m *Client) ObserveHostnameState(ctx context.Context) (<-chan hostname.ResourceEvent, error)
- func (_m *Client) ObserveIPState(ctx context.Context) (<-chan ip.ResourceEvent, error)
- func (_m *Client) PurgeDeclaredHostname(ctx context.Context, lID v1beta4.LeaseID, _a2 string) error
- func (_m *Client) PurgeDeclaredHostnames(ctx context.Context, lID v1beta4.LeaseID) error
- func (_m *Client) PurgeDeclaredIP(ctx context.Context, lID v1beta4.LeaseID, serviceName string, ...) error
- func (_m *Client) PurgeDeclaredIPs(ctx context.Context, lID v1beta4.LeaseID) error
- func (_m *Client) RemoveHostnameFromDeployment(ctx context.Context, _a1 string, leaseID v1beta4.LeaseID, allowMissing bool) error
- func (_m *Client) ServiceStatus(_a0 context.Context, _a1 v1beta4.LeaseID, _a2 string) (*v1beta3.ServiceStatus, error)
- func (_m *Client) TeardownLease(_a0 context.Context, _a1 v1beta4.LeaseID) error
- type Client_AllHostnames_Call
- func (_c *Client_AllHostnames_Call) Return(_a0 []hostname.ActiveHostname, _a1 error) *Client_AllHostnames_Call
- func (_c *Client_AllHostnames_Call) Run(run func(_a0 context.Context)) *Client_AllHostnames_Call
- func (_c *Client_AllHostnames_Call) RunAndReturn(run func(context.Context) ([]hostname.ActiveHostname, error)) *Client_AllHostnames_Call
- type Client_ConnectHostnameToDeployment_Call
- func (_c *Client_ConnectHostnameToDeployment_Call) Return(_a0 error) *Client_ConnectHostnameToDeployment_Call
- func (_c *Client_ConnectHostnameToDeployment_Call) Run(run func(ctx context.Context, directive hostname.ConnectToDeploymentDirective)) *Client_ConnectHostnameToDeployment_Call
- func (_c *Client_ConnectHostnameToDeployment_Call) RunAndReturn(run func(context.Context, hostname.ConnectToDeploymentDirective) error) *Client_ConnectHostnameToDeployment_Call
- type Client_DeclareHostname_Call
- func (_c *Client_DeclareHostname_Call) Return(_a0 error) *Client_DeclareHostname_Call
- func (_c *Client_DeclareHostname_Call) Run(...) *Client_DeclareHostname_Call
- func (_c *Client_DeclareHostname_Call) RunAndReturn(run func(context.Context, v1beta4.LeaseID, string, string, uint32) error) *Client_DeclareHostname_Call
- type Client_DeclareIP_Call
- type Client_Deploy_Call
- func (_c *Client_Deploy_Call) Return(_a0 error) *Client_Deploy_Call
- func (_c *Client_Deploy_Call) Run(run func(ctx context.Context, deployment v1beta3.IDeployment)) *Client_Deploy_Call
- func (_c *Client_Deploy_Call) RunAndReturn(run func(context.Context, v1beta3.IDeployment) error) *Client_Deploy_Call
- type Client_Deployments_Call
- func (_c *Client_Deployments_Call) Return(_a0 []v1beta3.IDeployment, _a1 error) *Client_Deployments_Call
- func (_c *Client_Deployments_Call) Run(run func(_a0 context.Context)) *Client_Deployments_Call
- func (_c *Client_Deployments_Call) RunAndReturn(run func(context.Context) ([]v1beta3.IDeployment, error)) *Client_Deployments_Call
- type Client_Exec_Call
- type Client_Expecter
- func (_e *Client_Expecter) AllHostnames(_a0 interface{}) *Client_AllHostnames_Call
- func (_e *Client_Expecter) ConnectHostnameToDeployment(ctx interface{}, directive interface{}) *Client_ConnectHostnameToDeployment_Call
- func (_e *Client_Expecter) DeclareHostname(ctx interface{}, lID interface{}, host interface{}, serviceName interface{}, ...) *Client_DeclareHostname_Call
- func (_e *Client_Expecter) DeclareIP(ctx interface{}, lID interface{}, serviceName interface{}, port interface{}, ...) *Client_DeclareIP_Call
- func (_e *Client_Expecter) Deploy(ctx interface{}, deployment interface{}) *Client_Deploy_Call
- func (_e *Client_Expecter) Deployments(_a0 interface{}) *Client_Deployments_Call
- func (_e *Client_Expecter) Exec(ctx interface{}, lID interface{}, service interface{}, podIndex interface{}, ...) *Client_Exec_Call
- func (_e *Client_Expecter) ForwardedPortStatus(_a0 interface{}, _a1 interface{}) *Client_ForwardedPortStatus_Call
- func (_e *Client_Expecter) GetDeclaredIPs(ctx interface{}, leaseID interface{}) *Client_GetDeclaredIPs_Call
- func (_e *Client_Expecter) GetHostnameDeploymentConnections(ctx interface{}) *Client_GetHostnameDeploymentConnections_Call
- func (_e *Client_Expecter) GetManifestGroup(_a0 interface{}, _a1 interface{}) *Client_GetManifestGroup_Call
- func (_e *Client_Expecter) KubeVersion() *Client_KubeVersion_Call
- func (_e *Client_Expecter) LeaseEvents(_a0 interface{}, _a1 interface{}, _a2 interface{}, _a3 interface{}) *Client_LeaseEvents_Call
- func (_e *Client_Expecter) LeaseLogs(_a0 interface{}, _a1 interface{}, _a2 interface{}, _a3 interface{}, ...) *Client_LeaseLogs_Call
- func (_e *Client_Expecter) LeaseStatus(_a0 interface{}, _a1 interface{}) *Client_LeaseStatus_Call
- func (_e *Client_Expecter) ObserveHostnameState(ctx interface{}) *Client_ObserveHostnameState_Call
- func (_e *Client_Expecter) ObserveIPState(ctx interface{}) *Client_ObserveIPState_Call
- func (_e *Client_Expecter) PurgeDeclaredHostname(ctx interface{}, lID interface{}, _a2 interface{}) *Client_PurgeDeclaredHostname_Call
- func (_e *Client_Expecter) PurgeDeclaredHostnames(ctx interface{}, lID interface{}) *Client_PurgeDeclaredHostnames_Call
- func (_e *Client_Expecter) PurgeDeclaredIP(ctx interface{}, lID interface{}, serviceName interface{}, ...) *Client_PurgeDeclaredIP_Call
- func (_e *Client_Expecter) PurgeDeclaredIPs(ctx interface{}, lID interface{}) *Client_PurgeDeclaredIPs_Call
- func (_e *Client_Expecter) RemoveHostnameFromDeployment(ctx interface{}, _a1 interface{}, leaseID interface{}, ...) *Client_RemoveHostnameFromDeployment_Call
- func (_e *Client_Expecter) ServiceStatus(_a0 interface{}, _a1 interface{}, _a2 interface{}) *Client_ServiceStatus_Call
- func (_e *Client_Expecter) TeardownLease(_a0 interface{}, _a1 interface{}) *Client_TeardownLease_Call
- type Client_ForwardedPortStatus_Call
- func (_c *Client_ForwardedPortStatus_Call) Return(_a0 map[string][]v1beta3.ForwardedPortStatus, _a1 error) *Client_ForwardedPortStatus_Call
- func (_c *Client_ForwardedPortStatus_Call) Run(run func(_a0 context.Context, _a1 v1beta4.LeaseID)) *Client_ForwardedPortStatus_Call
- func (_c *Client_ForwardedPortStatus_Call) RunAndReturn(...) *Client_ForwardedPortStatus_Call
- type Client_GetDeclaredIPs_Call
- func (_c *Client_GetDeclaredIPs_Call) Return(_a0 []akash_networkv2beta2.ProviderLeasedIPSpec, _a1 error) *Client_GetDeclaredIPs_Call
- func (_c *Client_GetDeclaredIPs_Call) Run(run func(ctx context.Context, leaseID v1beta4.LeaseID)) *Client_GetDeclaredIPs_Call
- func (_c *Client_GetDeclaredIPs_Call) RunAndReturn(...) *Client_GetDeclaredIPs_Call
- type Client_GetHostnameDeploymentConnections_Call
- func (_c *Client_GetHostnameDeploymentConnections_Call) Return(_a0 []hostname.LeaseIDConnection, _a1 error) *Client_GetHostnameDeploymentConnections_Call
- func (_c *Client_GetHostnameDeploymentConnections_Call) Run(run func(ctx context.Context)) *Client_GetHostnameDeploymentConnections_Call
- func (_c *Client_GetHostnameDeploymentConnections_Call) RunAndReturn(run func(context.Context) ([]hostname.LeaseIDConnection, error)) *Client_GetHostnameDeploymentConnections_Call
- type Client_GetManifestGroup_Call
- func (_c *Client_GetManifestGroup_Call) Return(_a0 bool, _a1 akash_networkv2beta2.ManifestGroup, _a2 error) *Client_GetManifestGroup_Call
- func (_c *Client_GetManifestGroup_Call) Run(run func(_a0 context.Context, _a1 v1beta4.LeaseID)) *Client_GetManifestGroup_Call
- func (_c *Client_GetManifestGroup_Call) RunAndReturn(...) *Client_GetManifestGroup_Call
- type Client_KubeVersion_Call
- type Client_LeaseEvents_Call
- func (_c *Client_LeaseEvents_Call) Return(_a0 v1beta3.EventsWatcher, _a1 error) *Client_LeaseEvents_Call
- func (_c *Client_LeaseEvents_Call) Run(run func(_a0 context.Context, _a1 v1beta4.LeaseID, _a2 string, _a3 bool)) *Client_LeaseEvents_Call
- func (_c *Client_LeaseEvents_Call) RunAndReturn(...) *Client_LeaseEvents_Call
- type Client_LeaseLogs_Call
- type Client_LeaseStatus_Call
- func (_c *Client_LeaseStatus_Call) Return(_a0 map[string]*v1beta3.ServiceStatus, _a1 error) *Client_LeaseStatus_Call
- func (_c *Client_LeaseStatus_Call) Run(run func(_a0 context.Context, _a1 v1beta4.LeaseID)) *Client_LeaseStatus_Call
- func (_c *Client_LeaseStatus_Call) RunAndReturn(...) *Client_LeaseStatus_Call
- type Client_ObserveHostnameState_Call
- func (_c *Client_ObserveHostnameState_Call) Return(_a0 <-chan hostname.ResourceEvent, _a1 error) *Client_ObserveHostnameState_Call
- func (_c *Client_ObserveHostnameState_Call) Run(run func(ctx context.Context)) *Client_ObserveHostnameState_Call
- func (_c *Client_ObserveHostnameState_Call) RunAndReturn(run func(context.Context) (<-chan hostname.ResourceEvent, error)) *Client_ObserveHostnameState_Call
- type Client_ObserveIPState_Call
- func (_c *Client_ObserveIPState_Call) Return(_a0 <-chan ip.ResourceEvent, _a1 error) *Client_ObserveIPState_Call
- func (_c *Client_ObserveIPState_Call) Run(run func(ctx context.Context)) *Client_ObserveIPState_Call
- func (_c *Client_ObserveIPState_Call) RunAndReturn(run func(context.Context) (<-chan ip.ResourceEvent, error)) *Client_ObserveIPState_Call
- type Client_PurgeDeclaredHostname_Call
- func (_c *Client_PurgeDeclaredHostname_Call) Return(_a0 error) *Client_PurgeDeclaredHostname_Call
- func (_c *Client_PurgeDeclaredHostname_Call) Run(run func(ctx context.Context, lID v1beta4.LeaseID, _a2 string)) *Client_PurgeDeclaredHostname_Call
- func (_c *Client_PurgeDeclaredHostname_Call) RunAndReturn(run func(context.Context, v1beta4.LeaseID, string) error) *Client_PurgeDeclaredHostname_Call
- type Client_PurgeDeclaredHostnames_Call
- func (_c *Client_PurgeDeclaredHostnames_Call) Return(_a0 error) *Client_PurgeDeclaredHostnames_Call
- func (_c *Client_PurgeDeclaredHostnames_Call) Run(run func(ctx context.Context, lID v1beta4.LeaseID)) *Client_PurgeDeclaredHostnames_Call
- func (_c *Client_PurgeDeclaredHostnames_Call) RunAndReturn(run func(context.Context, v1beta4.LeaseID) error) *Client_PurgeDeclaredHostnames_Call
- type Client_PurgeDeclaredIP_Call
- func (_c *Client_PurgeDeclaredIP_Call) Return(_a0 error) *Client_PurgeDeclaredIP_Call
- func (_c *Client_PurgeDeclaredIP_Call) Run(run func(ctx context.Context, lID v1beta4.LeaseID, serviceName string, ...)) *Client_PurgeDeclaredIP_Call
- func (_c *Client_PurgeDeclaredIP_Call) RunAndReturn(...) *Client_PurgeDeclaredIP_Call
- type Client_PurgeDeclaredIPs_Call
- func (_c *Client_PurgeDeclaredIPs_Call) Return(_a0 error) *Client_PurgeDeclaredIPs_Call
- func (_c *Client_PurgeDeclaredIPs_Call) Run(run func(ctx context.Context, lID v1beta4.LeaseID)) *Client_PurgeDeclaredIPs_Call
- func (_c *Client_PurgeDeclaredIPs_Call) RunAndReturn(run func(context.Context, v1beta4.LeaseID) error) *Client_PurgeDeclaredIPs_Call
- type Client_RemoveHostnameFromDeployment_Call
- func (_c *Client_RemoveHostnameFromDeployment_Call) Return(_a0 error) *Client_RemoveHostnameFromDeployment_Call
- func (_c *Client_RemoveHostnameFromDeployment_Call) Run(...) *Client_RemoveHostnameFromDeployment_Call
- func (_c *Client_RemoveHostnameFromDeployment_Call) RunAndReturn(run func(context.Context, string, v1beta4.LeaseID, bool) error) *Client_RemoveHostnameFromDeployment_Call
- type Client_ServiceStatus_Call
- func (_c *Client_ServiceStatus_Call) Return(_a0 *v1beta3.ServiceStatus, _a1 error) *Client_ServiceStatus_Call
- func (_c *Client_ServiceStatus_Call) Run(run func(_a0 context.Context, _a1 v1beta4.LeaseID, _a2 string)) *Client_ServiceStatus_Call
- func (_c *Client_ServiceStatus_Call) RunAndReturn(...) *Client_ServiceStatus_Call
- type Client_TeardownLease_Call
- func (_c *Client_TeardownLease_Call) Return(_a0 error) *Client_TeardownLease_Call
- func (_c *Client_TeardownLease_Call) Run(run func(_a0 context.Context, _a1 v1beta4.LeaseID)) *Client_TeardownLease_Call
- func (_c *Client_TeardownLease_Call) RunAndReturn(run func(context.Context, v1beta4.LeaseID) error) *Client_TeardownLease_Call
- type Cluster
- type Cluster_Expecter
- type Cluster_Reserve_Call
- type Cluster_Unreserve_Call
- type ReadClient
- func (_m *ReadClient) AllHostnames(_a0 context.Context) ([]hostname.ActiveHostname, error)
- func (_m *ReadClient) EXPECT() *ReadClient_Expecter
- func (_m *ReadClient) ForwardedPortStatus(_a0 context.Context, _a1 v1beta4.LeaseID) (map[string][]v1beta3.ForwardedPortStatus, error)
- func (_m *ReadClient) GetDeclaredIPs(ctx context.Context, leaseID v1beta4.LeaseID) ([]v2beta2.ProviderLeasedIPSpec, error)
- func (_m *ReadClient) GetHostnameDeploymentConnections(ctx context.Context) ([]hostname.LeaseIDConnection, error)
- func (_m *ReadClient) GetManifestGroup(_a0 context.Context, _a1 v1beta4.LeaseID) (bool, v2beta2.ManifestGroup, error)
- func (_m *ReadClient) LeaseEvents(_a0 context.Context, _a1 v1beta4.LeaseID, _a2 string, _a3 bool) (v1beta3.EventsWatcher, error)
- func (_m *ReadClient) LeaseLogs(_a0 context.Context, _a1 v1beta4.LeaseID, _a2 string, _a3 bool, _a4 *int64) ([]*v1beta3.ServiceLog, error)
- func (_m *ReadClient) LeaseStatus(_a0 context.Context, _a1 v1beta4.LeaseID) (map[string]*v1beta3.ServiceStatus, error)
- func (_m *ReadClient) ObserveHostnameState(ctx context.Context) (<-chan hostname.ResourceEvent, error)
- func (_m *ReadClient) ObserveIPState(ctx context.Context) (<-chan ip.ResourceEvent, error)
- func (_m *ReadClient) ServiceStatus(_a0 context.Context, _a1 v1beta4.LeaseID, _a2 string) (*v1beta3.ServiceStatus, error)
- type ReadClient_AllHostnames_Call
- func (_c *ReadClient_AllHostnames_Call) Return(_a0 []hostname.ActiveHostname, _a1 error) *ReadClient_AllHostnames_Call
- func (_c *ReadClient_AllHostnames_Call) Run(run func(_a0 context.Context)) *ReadClient_AllHostnames_Call
- func (_c *ReadClient_AllHostnames_Call) RunAndReturn(run func(context.Context) ([]hostname.ActiveHostname, error)) *ReadClient_AllHostnames_Call
- type ReadClient_Expecter
- func (_e *ReadClient_Expecter) AllHostnames(_a0 interface{}) *ReadClient_AllHostnames_Call
- func (_e *ReadClient_Expecter) ForwardedPortStatus(_a0 interface{}, _a1 interface{}) *ReadClient_ForwardedPortStatus_Call
- func (_e *ReadClient_Expecter) GetDeclaredIPs(ctx interface{}, leaseID interface{}) *ReadClient_GetDeclaredIPs_Call
- func (_e *ReadClient_Expecter) GetHostnameDeploymentConnections(ctx interface{}) *ReadClient_GetHostnameDeploymentConnections_Call
- func (_e *ReadClient_Expecter) GetManifestGroup(_a0 interface{}, _a1 interface{}) *ReadClient_GetManifestGroup_Call
- func (_e *ReadClient_Expecter) LeaseEvents(_a0 interface{}, _a1 interface{}, _a2 interface{}, _a3 interface{}) *ReadClient_LeaseEvents_Call
- func (_e *ReadClient_Expecter) LeaseLogs(_a0 interface{}, _a1 interface{}, _a2 interface{}, _a3 interface{}, ...) *ReadClient_LeaseLogs_Call
- func (_e *ReadClient_Expecter) LeaseStatus(_a0 interface{}, _a1 interface{}) *ReadClient_LeaseStatus_Call
- func (_e *ReadClient_Expecter) ObserveHostnameState(ctx interface{}) *ReadClient_ObserveHostnameState_Call
- func (_e *ReadClient_Expecter) ObserveIPState(ctx interface{}) *ReadClient_ObserveIPState_Call
- func (_e *ReadClient_Expecter) ServiceStatus(_a0 interface{}, _a1 interface{}, _a2 interface{}) *ReadClient_ServiceStatus_Call
- type ReadClient_ForwardedPortStatus_Call
- func (_c *ReadClient_ForwardedPortStatus_Call) Return(_a0 map[string][]v1beta3.ForwardedPortStatus, _a1 error) *ReadClient_ForwardedPortStatus_Call
- func (_c *ReadClient_ForwardedPortStatus_Call) Run(run func(_a0 context.Context, _a1 v1beta4.LeaseID)) *ReadClient_ForwardedPortStatus_Call
- func (_c *ReadClient_ForwardedPortStatus_Call) RunAndReturn(...) *ReadClient_ForwardedPortStatus_Call
- type ReadClient_GetDeclaredIPs_Call
- func (_c *ReadClient_GetDeclaredIPs_Call) Return(_a0 []v2beta2.ProviderLeasedIPSpec, _a1 error) *ReadClient_GetDeclaredIPs_Call
- func (_c *ReadClient_GetDeclaredIPs_Call) Run(run func(ctx context.Context, leaseID v1beta4.LeaseID)) *ReadClient_GetDeclaredIPs_Call
- func (_c *ReadClient_GetDeclaredIPs_Call) RunAndReturn(...) *ReadClient_GetDeclaredIPs_Call
- type ReadClient_GetHostnameDeploymentConnections_Call
- func (_c *ReadClient_GetHostnameDeploymentConnections_Call) Return(_a0 []hostname.LeaseIDConnection, _a1 error) *ReadClient_GetHostnameDeploymentConnections_Call
- func (_c *ReadClient_GetHostnameDeploymentConnections_Call) Run(run func(ctx context.Context)) *ReadClient_GetHostnameDeploymentConnections_Call
- func (_c *ReadClient_GetHostnameDeploymentConnections_Call) RunAndReturn(run func(context.Context) ([]hostname.LeaseIDConnection, error)) *ReadClient_GetHostnameDeploymentConnections_Call
- type ReadClient_GetManifestGroup_Call
- func (_c *ReadClient_GetManifestGroup_Call) Return(_a0 bool, _a1 v2beta2.ManifestGroup, _a2 error) *ReadClient_GetManifestGroup_Call
- func (_c *ReadClient_GetManifestGroup_Call) Run(run func(_a0 context.Context, _a1 v1beta4.LeaseID)) *ReadClient_GetManifestGroup_Call
- func (_c *ReadClient_GetManifestGroup_Call) RunAndReturn(...) *ReadClient_GetManifestGroup_Call
- type ReadClient_LeaseEvents_Call
- func (_c *ReadClient_LeaseEvents_Call) Return(_a0 v1beta3.EventsWatcher, _a1 error) *ReadClient_LeaseEvents_Call
- func (_c *ReadClient_LeaseEvents_Call) Run(run func(_a0 context.Context, _a1 v1beta4.LeaseID, _a2 string, _a3 bool)) *ReadClient_LeaseEvents_Call
- func (_c *ReadClient_LeaseEvents_Call) RunAndReturn(...) *ReadClient_LeaseEvents_Call
- type ReadClient_LeaseLogs_Call
- type ReadClient_LeaseStatus_Call
- func (_c *ReadClient_LeaseStatus_Call) Return(_a0 map[string]*v1beta3.ServiceStatus, _a1 error) *ReadClient_LeaseStatus_Call
- func (_c *ReadClient_LeaseStatus_Call) Run(run func(_a0 context.Context, _a1 v1beta4.LeaseID)) *ReadClient_LeaseStatus_Call
- func (_c *ReadClient_LeaseStatus_Call) RunAndReturn(...) *ReadClient_LeaseStatus_Call
- type ReadClient_ObserveHostnameState_Call
- func (_c *ReadClient_ObserveHostnameState_Call) Return(_a0 <-chan hostname.ResourceEvent, _a1 error) *ReadClient_ObserveHostnameState_Call
- func (_c *ReadClient_ObserveHostnameState_Call) Run(run func(ctx context.Context)) *ReadClient_ObserveHostnameState_Call
- func (_c *ReadClient_ObserveHostnameState_Call) RunAndReturn(run func(context.Context) (<-chan hostname.ResourceEvent, error)) *ReadClient_ObserveHostnameState_Call
- type ReadClient_ObserveIPState_Call
- func (_c *ReadClient_ObserveIPState_Call) Return(_a0 <-chan ip.ResourceEvent, _a1 error) *ReadClient_ObserveIPState_Call
- func (_c *ReadClient_ObserveIPState_Call) Run(run func(ctx context.Context)) *ReadClient_ObserveIPState_Call
- func (_c *ReadClient_ObserveIPState_Call) RunAndReturn(run func(context.Context) (<-chan ip.ResourceEvent, error)) *ReadClient_ObserveIPState_Call
- type ReadClient_ServiceStatus_Call
- func (_c *ReadClient_ServiceStatus_Call) Return(_a0 *v1beta3.ServiceStatus, _a1 error) *ReadClient_ServiceStatus_Call
- func (_c *ReadClient_ServiceStatus_Call) Run(run func(_a0 context.Context, _a1 v1beta4.LeaseID, _a2 string)) *ReadClient_ServiceStatus_Call
- func (_c *ReadClient_ServiceStatus_Call) RunAndReturn(...) *ReadClient_ServiceStatus_Call
- type Service
- func (_m *Service) Close() error
- func (_m *Service) Done() <-chan struct{}
- func (_m *Service) EXPECT() *Service_Expecter
- func (_m *Service) FindActiveLease(ctx context.Context, owner types.Address, dseq uint64, gseq uint32) (bool, v1beta4.LeaseID, v2beta2.ManifestGroup, error)
- func (_m *Service) HostnameService() v1beta3.HostnameServiceClient
- func (_m *Service) Ready() <-chan struct{}
- func (_m *Service) Reserve(_a0 v1beta4.OrderID, _a1 deploymentv1beta3.ResourceGroup) (v1beta3.Reservation, error)
- func (_m *Service) Status(_a0 context.Context) (*v1beta3.Status, error)
- func (_m *Service) StatusV1(_a0 context.Context) (*v1.ClusterStatus, error)
- func (_m *Service) TransferHostname(ctx context.Context, leaseID v1beta4.LeaseID, hostname string, ...) error
- func (_m *Service) Unreserve(_a0 v1beta4.OrderID) error
- type Service_Close_Call
- type Service_Done_Call
- type Service_Expecter
- func (_e *Service_Expecter) Close() *Service_Close_Call
- func (_e *Service_Expecter) Done() *Service_Done_Call
- func (_e *Service_Expecter) FindActiveLease(ctx interface{}, owner interface{}, dseq interface{}, gseq interface{}) *Service_FindActiveLease_Call
- func (_e *Service_Expecter) HostnameService() *Service_HostnameService_Call
- func (_e *Service_Expecter) Ready() *Service_Ready_Call
- func (_e *Service_Expecter) Reserve(_a0 interface{}, _a1 interface{}) *Service_Reserve_Call
- func (_e *Service_Expecter) Status(_a0 interface{}) *Service_Status_Call
- func (_e *Service_Expecter) StatusV1(_a0 interface{}) *Service_StatusV1_Call
- func (_e *Service_Expecter) TransferHostname(ctx interface{}, leaseID interface{}, hostname interface{}, ...) *Service_TransferHostname_Call
- func (_e *Service_Expecter) Unreserve(_a0 interface{}) *Service_Unreserve_Call
- type Service_FindActiveLease_Call
- func (_c *Service_FindActiveLease_Call) Return(_a0 bool, _a1 v1beta4.LeaseID, _a2 v2beta2.ManifestGroup, _a3 error) *Service_FindActiveLease_Call
- func (_c *Service_FindActiveLease_Call) Run(run func(ctx context.Context, owner types.Address, dseq uint64, gseq uint32)) *Service_FindActiveLease_Call
- func (_c *Service_FindActiveLease_Call) RunAndReturn(...) *Service_FindActiveLease_Call
- type Service_HostnameService_Call
- func (_c *Service_HostnameService_Call) Return(_a0 v1beta3.HostnameServiceClient) *Service_HostnameService_Call
- func (_c *Service_HostnameService_Call) Run(run func()) *Service_HostnameService_Call
- func (_c *Service_HostnameService_Call) RunAndReturn(run func() v1beta3.HostnameServiceClient) *Service_HostnameService_Call
- type Service_Ready_Call
- type Service_Reserve_Call
- type Service_StatusV1_Call
- func (_c *Service_StatusV1_Call) Return(_a0 *v1.ClusterStatus, _a1 error) *Service_StatusV1_Call
- func (_c *Service_StatusV1_Call) Run(run func(_a0 context.Context)) *Service_StatusV1_Call
- func (_c *Service_StatusV1_Call) RunAndReturn(run func(context.Context) (*v1.ClusterStatus, error)) *Service_StatusV1_Call
- type Service_Status_Call
- type Service_TransferHostname_Call
- func (_c *Service_TransferHostname_Call) Return(_a0 error) *Service_TransferHostname_Call
- func (_c *Service_TransferHostname_Call) Run(run func(ctx context.Context, leaseID v1beta4.LeaseID, hostname string, ...)) *Service_TransferHostname_Call
- func (_c *Service_TransferHostname_Call) RunAndReturn(run func(context.Context, v1beta4.LeaseID, string, string, uint32) error) *Service_TransferHostname_Call
- type Service_Unreserve_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
Client is an autogenerated mock type for the Client type
func NewClient ¶
NewClient creates a new instance of Client. 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 (*Client) AllHostnames ¶
AllHostnames provides a mock function with given fields: _a0
func (*Client) ConnectHostnameToDeployment ¶
func (_m *Client) ConnectHostnameToDeployment(ctx context.Context, directive hostname.ConnectToDeploymentDirective) error
ConnectHostnameToDeployment provides a mock function with given fields: ctx, directive
func (*Client) DeclareHostname ¶
func (_m *Client) DeclareHostname(ctx context.Context, lID v1beta4.LeaseID, host string, serviceName string, externalPort uint32) error
DeclareHostname provides a mock function with given fields: ctx, lID, host, serviceName, externalPort
func (*Client) DeclareIP ¶
func (_m *Client) DeclareIP(ctx context.Context, lID v1beta4.LeaseID, serviceName string, port uint32, externalPort uint32, proto v2beta2.ServiceProtocol, sharingKey string, overwrite bool) error
DeclareIP provides a mock function with given fields: ctx, lID, serviceName, port, externalPort, proto, sharingKey, overwrite
func (*Client) Deployments ¶
Deployments provides a mock function with given fields: _a0
func (*Client) EXPECT ¶
func (_m *Client) EXPECT() *Client_Expecter
func (*Client) Exec ¶
func (_m *Client) Exec(ctx context.Context, lID v1beta4.LeaseID, service string, podIndex uint, cmd []string, stdin io.Reader, stdout io.Writer, stderr io.Writer, tty bool, tsq remotecommand.TerminalSizeQueue) (v1beta3.ExecResult, error)
Exec provides a mock function with given fields: ctx, lID, service, podIndex, cmd, stdin, stdout, stderr, tty, tsq
func (*Client) ForwardedPortStatus ¶
func (_m *Client) ForwardedPortStatus(_a0 context.Context, _a1 v1beta4.LeaseID) (map[string][]v1beta3.ForwardedPortStatus, error)
ForwardedPortStatus provides a mock function with given fields: _a0, _a1
func (*Client) GetDeclaredIPs ¶
func (_m *Client) GetDeclaredIPs(ctx context.Context, leaseID v1beta4.LeaseID) ([]akash_networkv2beta2.ProviderLeasedIPSpec, error)
GetDeclaredIPs provides a mock function with given fields: ctx, leaseID
func (*Client) GetHostnameDeploymentConnections ¶
func (_m *Client) GetHostnameDeploymentConnections(ctx context.Context) ([]hostname.LeaseIDConnection, error)
GetHostnameDeploymentConnections provides a mock function with given fields: ctx
func (*Client) GetManifestGroup ¶
func (_m *Client) GetManifestGroup(_a0 context.Context, _a1 v1beta4.LeaseID) (bool, akash_networkv2beta2.ManifestGroup, error)
GetManifestGroup provides a mock function with given fields: _a0, _a1
func (*Client) KubeVersion ¶
KubeVersion provides a mock function with given fields:
func (*Client) LeaseEvents ¶
func (_m *Client) LeaseEvents(_a0 context.Context, _a1 v1beta4.LeaseID, _a2 string, _a3 bool) (v1beta3.EventsWatcher, error)
LeaseEvents provides a mock function with given fields: _a0, _a1, _a2, _a3
func (*Client) LeaseLogs ¶
func (_m *Client) LeaseLogs(_a0 context.Context, _a1 v1beta4.LeaseID, _a2 string, _a3 bool, _a4 *int64) ([]*v1beta3.ServiceLog, error)
LeaseLogs provides a mock function with given fields: _a0, _a1, _a2, _a3, _a4
func (*Client) LeaseStatus ¶
func (_m *Client) LeaseStatus(_a0 context.Context, _a1 v1beta4.LeaseID) (map[string]*v1beta3.ServiceStatus, error)
LeaseStatus provides a mock function with given fields: _a0, _a1
func (*Client) ObserveHostnameState ¶
ObserveHostnameState provides a mock function with given fields: ctx
func (*Client) ObserveIPState ¶
ObserveIPState provides a mock function with given fields: ctx
func (*Client) PurgeDeclaredHostname ¶
PurgeDeclaredHostname provides a mock function with given fields: ctx, lID, _a2
func (*Client) PurgeDeclaredHostnames ¶
PurgeDeclaredHostnames provides a mock function with given fields: ctx, lID
func (*Client) PurgeDeclaredIP ¶
func (_m *Client) PurgeDeclaredIP(ctx context.Context, lID v1beta4.LeaseID, serviceName string, externalPort uint32, proto v2beta2.ServiceProtocol) error
PurgeDeclaredIP provides a mock function with given fields: ctx, lID, serviceName, externalPort, proto
func (*Client) PurgeDeclaredIPs ¶
PurgeDeclaredIPs provides a mock function with given fields: ctx, lID
func (*Client) RemoveHostnameFromDeployment ¶
func (_m *Client) RemoveHostnameFromDeployment(ctx context.Context, _a1 string, leaseID v1beta4.LeaseID, allowMissing bool) error
RemoveHostnameFromDeployment provides a mock function with given fields: ctx, _a1, leaseID, allowMissing
type Client_AllHostnames_Call ¶
Client_AllHostnames_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AllHostnames'
func (*Client_AllHostnames_Call) Return ¶
func (_c *Client_AllHostnames_Call) Return(_a0 []hostname.ActiveHostname, _a1 error) *Client_AllHostnames_Call
func (*Client_AllHostnames_Call) Run ¶
func (_c *Client_AllHostnames_Call) Run(run func(_a0 context.Context)) *Client_AllHostnames_Call
func (*Client_AllHostnames_Call) RunAndReturn ¶
func (_c *Client_AllHostnames_Call) RunAndReturn(run func(context.Context) ([]hostname.ActiveHostname, error)) *Client_AllHostnames_Call
type Client_ConnectHostnameToDeployment_Call ¶
Client_ConnectHostnameToDeployment_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ConnectHostnameToDeployment'
func (*Client_ConnectHostnameToDeployment_Call) Return ¶
func (_c *Client_ConnectHostnameToDeployment_Call) Return(_a0 error) *Client_ConnectHostnameToDeployment_Call
func (*Client_ConnectHostnameToDeployment_Call) Run ¶
func (_c *Client_ConnectHostnameToDeployment_Call) Run(run func(ctx context.Context, directive hostname.ConnectToDeploymentDirective)) *Client_ConnectHostnameToDeployment_Call
func (*Client_ConnectHostnameToDeployment_Call) RunAndReturn ¶
func (_c *Client_ConnectHostnameToDeployment_Call) RunAndReturn(run func(context.Context, hostname.ConnectToDeploymentDirective) error) *Client_ConnectHostnameToDeployment_Call
type Client_DeclareHostname_Call ¶
Client_DeclareHostname_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeclareHostname'
func (*Client_DeclareHostname_Call) Return ¶
func (_c *Client_DeclareHostname_Call) Return(_a0 error) *Client_DeclareHostname_Call
func (*Client_DeclareHostname_Call) Run ¶
func (_c *Client_DeclareHostname_Call) Run(run func(ctx context.Context, lID v1beta4.LeaseID, host string, serviceName string, externalPort uint32)) *Client_DeclareHostname_Call
func (*Client_DeclareHostname_Call) RunAndReturn ¶
func (_c *Client_DeclareHostname_Call) RunAndReturn(run func(context.Context, v1beta4.LeaseID, string, string, uint32) error) *Client_DeclareHostname_Call
type Client_DeclareIP_Call ¶
Client_DeclareIP_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeclareIP'
func (*Client_DeclareIP_Call) Return ¶
func (_c *Client_DeclareIP_Call) Return(_a0 error) *Client_DeclareIP_Call
func (*Client_DeclareIP_Call) Run ¶
func (_c *Client_DeclareIP_Call) Run(run func(ctx context.Context, lID v1beta4.LeaseID, serviceName string, port uint32, externalPort uint32, proto v2beta2.ServiceProtocol, sharingKey string, overwrite bool)) *Client_DeclareIP_Call
func (*Client_DeclareIP_Call) RunAndReturn ¶
func (_c *Client_DeclareIP_Call) RunAndReturn(run func(context.Context, v1beta4.LeaseID, string, uint32, uint32, v2beta2.ServiceProtocol, string, bool) error) *Client_DeclareIP_Call
type Client_Deploy_Call ¶
Client_Deploy_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Deploy'
func (*Client_Deploy_Call) Return ¶
func (_c *Client_Deploy_Call) Return(_a0 error) *Client_Deploy_Call
func (*Client_Deploy_Call) Run ¶
func (_c *Client_Deploy_Call) Run(run func(ctx context.Context, deployment v1beta3.IDeployment)) *Client_Deploy_Call
func (*Client_Deploy_Call) RunAndReturn ¶
func (_c *Client_Deploy_Call) RunAndReturn(run func(context.Context, v1beta3.IDeployment) error) *Client_Deploy_Call
type Client_Deployments_Call ¶
Client_Deployments_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Deployments'
func (*Client_Deployments_Call) Return ¶
func (_c *Client_Deployments_Call) Return(_a0 []v1beta3.IDeployment, _a1 error) *Client_Deployments_Call
func (*Client_Deployments_Call) Run ¶
func (_c *Client_Deployments_Call) Run(run func(_a0 context.Context)) *Client_Deployments_Call
func (*Client_Deployments_Call) RunAndReturn ¶
func (_c *Client_Deployments_Call) RunAndReturn(run func(context.Context) ([]v1beta3.IDeployment, error)) *Client_Deployments_Call
type Client_Exec_Call ¶
Client_Exec_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Exec'
func (*Client_Exec_Call) Return ¶
func (_c *Client_Exec_Call) Return(_a0 v1beta3.ExecResult, _a1 error) *Client_Exec_Call
func (*Client_Exec_Call) Run ¶
func (_c *Client_Exec_Call) Run(run func(ctx context.Context, lID v1beta4.LeaseID, service string, podIndex uint, cmd []string, stdin io.Reader, stdout io.Writer, stderr io.Writer, tty bool, tsq remotecommand.TerminalSizeQueue)) *Client_Exec_Call
func (*Client_Exec_Call) RunAndReturn ¶
func (_c *Client_Exec_Call) RunAndReturn(run func(context.Context, v1beta4.LeaseID, string, uint, []string, io.Reader, io.Writer, io.Writer, bool, remotecommand.TerminalSizeQueue) (v1beta3.ExecResult, error)) *Client_Exec_Call
type Client_Expecter ¶
type Client_Expecter struct {
// contains filtered or unexported fields
}
func (*Client_Expecter) AllHostnames ¶
func (_e *Client_Expecter) AllHostnames(_a0 interface{}) *Client_AllHostnames_Call
AllHostnames is a helper method to define mock.On call
- _a0 context.Context
func (*Client_Expecter) ConnectHostnameToDeployment ¶
func (_e *Client_Expecter) ConnectHostnameToDeployment(ctx interface{}, directive interface{}) *Client_ConnectHostnameToDeployment_Call
ConnectHostnameToDeployment is a helper method to define mock.On call
- ctx context.Context
- directive hostname.ConnectToDeploymentDirective
func (*Client_Expecter) DeclareHostname ¶
func (_e *Client_Expecter) DeclareHostname(ctx interface{}, lID interface{}, host interface{}, serviceName interface{}, externalPort interface{}) *Client_DeclareHostname_Call
DeclareHostname is a helper method to define mock.On call
- ctx context.Context
- lID v1beta4.LeaseID
- host string
- serviceName string
- externalPort uint32
func (*Client_Expecter) DeclareIP ¶
func (_e *Client_Expecter) DeclareIP(ctx interface{}, lID interface{}, serviceName interface{}, port interface{}, externalPort interface{}, proto interface{}, sharingKey interface{}, overwrite interface{}) *Client_DeclareIP_Call
DeclareIP is a helper method to define mock.On call
- ctx context.Context
- lID v1beta4.LeaseID
- serviceName string
- port uint32
- externalPort uint32
- proto v2beta2.ServiceProtocol
- sharingKey string
- overwrite bool
func (*Client_Expecter) Deploy ¶
func (_e *Client_Expecter) Deploy(ctx interface{}, deployment interface{}) *Client_Deploy_Call
Deploy is a helper method to define mock.On call
- ctx context.Context
- deployment v1beta3.IDeployment
func (*Client_Expecter) Deployments ¶
func (_e *Client_Expecter) Deployments(_a0 interface{}) *Client_Deployments_Call
Deployments is a helper method to define mock.On call
- _a0 context.Context
func (*Client_Expecter) Exec ¶
func (_e *Client_Expecter) Exec(ctx interface{}, lID interface{}, service interface{}, podIndex interface{}, cmd interface{}, stdin interface{}, stdout interface{}, stderr interface{}, tty interface{}, tsq interface{}) *Client_Exec_Call
Exec is a helper method to define mock.On call
- ctx context.Context
- lID v1beta4.LeaseID
- service string
- podIndex uint
- cmd []string
- stdin io.Reader
- stdout io.Writer
- stderr io.Writer
- tty bool
- tsq remotecommand.TerminalSizeQueue
func (*Client_Expecter) ForwardedPortStatus ¶
func (_e *Client_Expecter) ForwardedPortStatus(_a0 interface{}, _a1 interface{}) *Client_ForwardedPortStatus_Call
ForwardedPortStatus is a helper method to define mock.On call
- _a0 context.Context
- _a1 v1beta4.LeaseID
func (*Client_Expecter) GetDeclaredIPs ¶
func (_e *Client_Expecter) GetDeclaredIPs(ctx interface{}, leaseID interface{}) *Client_GetDeclaredIPs_Call
GetDeclaredIPs is a helper method to define mock.On call
- ctx context.Context
- leaseID v1beta4.LeaseID
func (*Client_Expecter) GetHostnameDeploymentConnections ¶
func (_e *Client_Expecter) GetHostnameDeploymentConnections(ctx interface{}) *Client_GetHostnameDeploymentConnections_Call
GetHostnameDeploymentConnections is a helper method to define mock.On call
- ctx context.Context
func (*Client_Expecter) GetManifestGroup ¶
func (_e *Client_Expecter) GetManifestGroup(_a0 interface{}, _a1 interface{}) *Client_GetManifestGroup_Call
GetManifestGroup is a helper method to define mock.On call
- _a0 context.Context
- _a1 v1beta4.LeaseID
func (*Client_Expecter) KubeVersion ¶
func (_e *Client_Expecter) KubeVersion() *Client_KubeVersion_Call
KubeVersion is a helper method to define mock.On call
func (*Client_Expecter) LeaseEvents ¶
func (_e *Client_Expecter) LeaseEvents(_a0 interface{}, _a1 interface{}, _a2 interface{}, _a3 interface{}) *Client_LeaseEvents_Call
LeaseEvents is a helper method to define mock.On call
- _a0 context.Context
- _a1 v1beta4.LeaseID
- _a2 string
- _a3 bool
func (*Client_Expecter) LeaseLogs ¶
func (_e *Client_Expecter) LeaseLogs(_a0 interface{}, _a1 interface{}, _a2 interface{}, _a3 interface{}, _a4 interface{}) *Client_LeaseLogs_Call
LeaseLogs is a helper method to define mock.On call
- _a0 context.Context
- _a1 v1beta4.LeaseID
- _a2 string
- _a3 bool
- _a4 *int64
func (*Client_Expecter) LeaseStatus ¶
func (_e *Client_Expecter) LeaseStatus(_a0 interface{}, _a1 interface{}) *Client_LeaseStatus_Call
LeaseStatus is a helper method to define mock.On call
- _a0 context.Context
- _a1 v1beta4.LeaseID
func (*Client_Expecter) ObserveHostnameState ¶
func (_e *Client_Expecter) ObserveHostnameState(ctx interface{}) *Client_ObserveHostnameState_Call
ObserveHostnameState is a helper method to define mock.On call
- ctx context.Context
func (*Client_Expecter) ObserveIPState ¶
func (_e *Client_Expecter) ObserveIPState(ctx interface{}) *Client_ObserveIPState_Call
ObserveIPState is a helper method to define mock.On call
- ctx context.Context
func (*Client_Expecter) PurgeDeclaredHostname ¶
func (_e *Client_Expecter) PurgeDeclaredHostname(ctx interface{}, lID interface{}, _a2 interface{}) *Client_PurgeDeclaredHostname_Call
PurgeDeclaredHostname is a helper method to define mock.On call
- ctx context.Context
- lID v1beta4.LeaseID
- _a2 string
func (*Client_Expecter) PurgeDeclaredHostnames ¶
func (_e *Client_Expecter) PurgeDeclaredHostnames(ctx interface{}, lID interface{}) *Client_PurgeDeclaredHostnames_Call
PurgeDeclaredHostnames is a helper method to define mock.On call
- ctx context.Context
- lID v1beta4.LeaseID
func (*Client_Expecter) PurgeDeclaredIP ¶
func (_e *Client_Expecter) PurgeDeclaredIP(ctx interface{}, lID interface{}, serviceName interface{}, externalPort interface{}, proto interface{}) *Client_PurgeDeclaredIP_Call
PurgeDeclaredIP is a helper method to define mock.On call
- ctx context.Context
- lID v1beta4.LeaseID
- serviceName string
- externalPort uint32
- proto v2beta2.ServiceProtocol
func (*Client_Expecter) PurgeDeclaredIPs ¶
func (_e *Client_Expecter) PurgeDeclaredIPs(ctx interface{}, lID interface{}) *Client_PurgeDeclaredIPs_Call
PurgeDeclaredIPs is a helper method to define mock.On call
- ctx context.Context
- lID v1beta4.LeaseID
func (*Client_Expecter) RemoveHostnameFromDeployment ¶
func (_e *Client_Expecter) RemoveHostnameFromDeployment(ctx interface{}, _a1 interface{}, leaseID interface{}, allowMissing interface{}) *Client_RemoveHostnameFromDeployment_Call
RemoveHostnameFromDeployment is a helper method to define mock.On call
- ctx context.Context
- _a1 string
- leaseID v1beta4.LeaseID
- allowMissing bool
func (*Client_Expecter) ServiceStatus ¶
func (_e *Client_Expecter) ServiceStatus(_a0 interface{}, _a1 interface{}, _a2 interface{}) *Client_ServiceStatus_Call
ServiceStatus is a helper method to define mock.On call
- _a0 context.Context
- _a1 v1beta4.LeaseID
- _a2 string
func (*Client_Expecter) TeardownLease ¶
func (_e *Client_Expecter) TeardownLease(_a0 interface{}, _a1 interface{}) *Client_TeardownLease_Call
TeardownLease is a helper method to define mock.On call
- _a0 context.Context
- _a1 v1beta4.LeaseID
type Client_ForwardedPortStatus_Call ¶
Client_ForwardedPortStatus_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ForwardedPortStatus'
func (*Client_ForwardedPortStatus_Call) Return ¶
func (_c *Client_ForwardedPortStatus_Call) Return(_a0 map[string][]v1beta3.ForwardedPortStatus, _a1 error) *Client_ForwardedPortStatus_Call
func (*Client_ForwardedPortStatus_Call) Run ¶
func (_c *Client_ForwardedPortStatus_Call) Run(run func(_a0 context.Context, _a1 v1beta4.LeaseID)) *Client_ForwardedPortStatus_Call
func (*Client_ForwardedPortStatus_Call) RunAndReturn ¶
func (_c *Client_ForwardedPortStatus_Call) RunAndReturn(run func(context.Context, v1beta4.LeaseID) (map[string][]v1beta3.ForwardedPortStatus, error)) *Client_ForwardedPortStatus_Call
type Client_GetDeclaredIPs_Call ¶
Client_GetDeclaredIPs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetDeclaredIPs'
func (*Client_GetDeclaredIPs_Call) Return ¶
func (_c *Client_GetDeclaredIPs_Call) Return(_a0 []akash_networkv2beta2.ProviderLeasedIPSpec, _a1 error) *Client_GetDeclaredIPs_Call
func (*Client_GetDeclaredIPs_Call) Run ¶
func (_c *Client_GetDeclaredIPs_Call) Run(run func(ctx context.Context, leaseID v1beta4.LeaseID)) *Client_GetDeclaredIPs_Call
func (*Client_GetDeclaredIPs_Call) RunAndReturn ¶
func (_c *Client_GetDeclaredIPs_Call) RunAndReturn(run func(context.Context, v1beta4.LeaseID) ([]akash_networkv2beta2.ProviderLeasedIPSpec, error)) *Client_GetDeclaredIPs_Call
type Client_GetHostnameDeploymentConnections_Call ¶
Client_GetHostnameDeploymentConnections_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetHostnameDeploymentConnections'
func (*Client_GetHostnameDeploymentConnections_Call) Return ¶
func (_c *Client_GetHostnameDeploymentConnections_Call) Return(_a0 []hostname.LeaseIDConnection, _a1 error) *Client_GetHostnameDeploymentConnections_Call
func (*Client_GetHostnameDeploymentConnections_Call) Run ¶
func (_c *Client_GetHostnameDeploymentConnections_Call) Run(run func(ctx context.Context)) *Client_GetHostnameDeploymentConnections_Call
func (*Client_GetHostnameDeploymentConnections_Call) RunAndReturn ¶
func (_c *Client_GetHostnameDeploymentConnections_Call) RunAndReturn(run func(context.Context) ([]hostname.LeaseIDConnection, error)) *Client_GetHostnameDeploymentConnections_Call
type Client_GetManifestGroup_Call ¶
Client_GetManifestGroup_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetManifestGroup'
func (*Client_GetManifestGroup_Call) Return ¶
func (_c *Client_GetManifestGroup_Call) Return(_a0 bool, _a1 akash_networkv2beta2.ManifestGroup, _a2 error) *Client_GetManifestGroup_Call
func (*Client_GetManifestGroup_Call) Run ¶
func (_c *Client_GetManifestGroup_Call) Run(run func(_a0 context.Context, _a1 v1beta4.LeaseID)) *Client_GetManifestGroup_Call
func (*Client_GetManifestGroup_Call) RunAndReturn ¶
func (_c *Client_GetManifestGroup_Call) RunAndReturn(run func(context.Context, v1beta4.LeaseID) (bool, akash_networkv2beta2.ManifestGroup, error)) *Client_GetManifestGroup_Call
type Client_KubeVersion_Call ¶
Client_KubeVersion_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'KubeVersion'
func (*Client_KubeVersion_Call) Return ¶
func (_c *Client_KubeVersion_Call) Return(_a0 *version.Info, _a1 error) *Client_KubeVersion_Call
func (*Client_KubeVersion_Call) Run ¶
func (_c *Client_KubeVersion_Call) Run(run func()) *Client_KubeVersion_Call
func (*Client_KubeVersion_Call) RunAndReturn ¶
func (_c *Client_KubeVersion_Call) RunAndReturn(run func() (*version.Info, error)) *Client_KubeVersion_Call
type Client_LeaseEvents_Call ¶
Client_LeaseEvents_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'LeaseEvents'
func (*Client_LeaseEvents_Call) Return ¶
func (_c *Client_LeaseEvents_Call) Return(_a0 v1beta3.EventsWatcher, _a1 error) *Client_LeaseEvents_Call
func (*Client_LeaseEvents_Call) Run ¶
func (_c *Client_LeaseEvents_Call) Run(run func(_a0 context.Context, _a1 v1beta4.LeaseID, _a2 string, _a3 bool)) *Client_LeaseEvents_Call
func (*Client_LeaseEvents_Call) RunAndReturn ¶
func (_c *Client_LeaseEvents_Call) RunAndReturn(run func(context.Context, v1beta4.LeaseID, string, bool) (v1beta3.EventsWatcher, error)) *Client_LeaseEvents_Call
type Client_LeaseLogs_Call ¶
Client_LeaseLogs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'LeaseLogs'
func (*Client_LeaseLogs_Call) Return ¶
func (_c *Client_LeaseLogs_Call) Return(_a0 []*v1beta3.ServiceLog, _a1 error) *Client_LeaseLogs_Call
func (*Client_LeaseLogs_Call) Run ¶
func (_c *Client_LeaseLogs_Call) Run(run func(_a0 context.Context, _a1 v1beta4.LeaseID, _a2 string, _a3 bool, _a4 *int64)) *Client_LeaseLogs_Call
func (*Client_LeaseLogs_Call) RunAndReturn ¶
func (_c *Client_LeaseLogs_Call) RunAndReturn(run func(context.Context, v1beta4.LeaseID, string, bool, *int64) ([]*v1beta3.ServiceLog, error)) *Client_LeaseLogs_Call
type Client_LeaseStatus_Call ¶
Client_LeaseStatus_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'LeaseStatus'
func (*Client_LeaseStatus_Call) Return ¶
func (_c *Client_LeaseStatus_Call) Return(_a0 map[string]*v1beta3.ServiceStatus, _a1 error) *Client_LeaseStatus_Call
func (*Client_LeaseStatus_Call) Run ¶
func (_c *Client_LeaseStatus_Call) Run(run func(_a0 context.Context, _a1 v1beta4.LeaseID)) *Client_LeaseStatus_Call
func (*Client_LeaseStatus_Call) RunAndReturn ¶
func (_c *Client_LeaseStatus_Call) RunAndReturn(run func(context.Context, v1beta4.LeaseID) (map[string]*v1beta3.ServiceStatus, error)) *Client_LeaseStatus_Call
type Client_ObserveHostnameState_Call ¶
Client_ObserveHostnameState_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ObserveHostnameState'
func (*Client_ObserveHostnameState_Call) Return ¶
func (_c *Client_ObserveHostnameState_Call) Return(_a0 <-chan hostname.ResourceEvent, _a1 error) *Client_ObserveHostnameState_Call
func (*Client_ObserveHostnameState_Call) Run ¶
func (_c *Client_ObserveHostnameState_Call) Run(run func(ctx context.Context)) *Client_ObserveHostnameState_Call
func (*Client_ObserveHostnameState_Call) RunAndReturn ¶
func (_c *Client_ObserveHostnameState_Call) RunAndReturn(run func(context.Context) (<-chan hostname.ResourceEvent, error)) *Client_ObserveHostnameState_Call
type Client_ObserveIPState_Call ¶
Client_ObserveIPState_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ObserveIPState'
func (*Client_ObserveIPState_Call) Return ¶
func (_c *Client_ObserveIPState_Call) Return(_a0 <-chan ip.ResourceEvent, _a1 error) *Client_ObserveIPState_Call
func (*Client_ObserveIPState_Call) Run ¶
func (_c *Client_ObserveIPState_Call) Run(run func(ctx context.Context)) *Client_ObserveIPState_Call
func (*Client_ObserveIPState_Call) RunAndReturn ¶
func (_c *Client_ObserveIPState_Call) RunAndReturn(run func(context.Context) (<-chan ip.ResourceEvent, error)) *Client_ObserveIPState_Call
type Client_PurgeDeclaredHostname_Call ¶
Client_PurgeDeclaredHostname_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PurgeDeclaredHostname'
func (*Client_PurgeDeclaredHostname_Call) Return ¶
func (_c *Client_PurgeDeclaredHostname_Call) Return(_a0 error) *Client_PurgeDeclaredHostname_Call
func (*Client_PurgeDeclaredHostname_Call) Run ¶
func (_c *Client_PurgeDeclaredHostname_Call) Run(run func(ctx context.Context, lID v1beta4.LeaseID, _a2 string)) *Client_PurgeDeclaredHostname_Call
func (*Client_PurgeDeclaredHostname_Call) RunAndReturn ¶
func (_c *Client_PurgeDeclaredHostname_Call) RunAndReturn(run func(context.Context, v1beta4.LeaseID, string) error) *Client_PurgeDeclaredHostname_Call
type Client_PurgeDeclaredHostnames_Call ¶
Client_PurgeDeclaredHostnames_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PurgeDeclaredHostnames'
func (*Client_PurgeDeclaredHostnames_Call) Return ¶
func (_c *Client_PurgeDeclaredHostnames_Call) Return(_a0 error) *Client_PurgeDeclaredHostnames_Call
func (*Client_PurgeDeclaredHostnames_Call) Run ¶
func (_c *Client_PurgeDeclaredHostnames_Call) Run(run func(ctx context.Context, lID v1beta4.LeaseID)) *Client_PurgeDeclaredHostnames_Call
func (*Client_PurgeDeclaredHostnames_Call) RunAndReturn ¶
func (_c *Client_PurgeDeclaredHostnames_Call) RunAndReturn(run func(context.Context, v1beta4.LeaseID) error) *Client_PurgeDeclaredHostnames_Call
type Client_PurgeDeclaredIP_Call ¶
Client_PurgeDeclaredIP_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PurgeDeclaredIP'
func (*Client_PurgeDeclaredIP_Call) Return ¶
func (_c *Client_PurgeDeclaredIP_Call) Return(_a0 error) *Client_PurgeDeclaredIP_Call
func (*Client_PurgeDeclaredIP_Call) Run ¶
func (_c *Client_PurgeDeclaredIP_Call) Run(run func(ctx context.Context, lID v1beta4.LeaseID, serviceName string, externalPort uint32, proto v2beta2.ServiceProtocol)) *Client_PurgeDeclaredIP_Call
func (*Client_PurgeDeclaredIP_Call) RunAndReturn ¶
func (_c *Client_PurgeDeclaredIP_Call) RunAndReturn(run func(context.Context, v1beta4.LeaseID, string, uint32, v2beta2.ServiceProtocol) error) *Client_PurgeDeclaredIP_Call
type Client_PurgeDeclaredIPs_Call ¶
Client_PurgeDeclaredIPs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PurgeDeclaredIPs'
func (*Client_PurgeDeclaredIPs_Call) Return ¶
func (_c *Client_PurgeDeclaredIPs_Call) Return(_a0 error) *Client_PurgeDeclaredIPs_Call
func (*Client_PurgeDeclaredIPs_Call) Run ¶
func (_c *Client_PurgeDeclaredIPs_Call) Run(run func(ctx context.Context, lID v1beta4.LeaseID)) *Client_PurgeDeclaredIPs_Call
func (*Client_PurgeDeclaredIPs_Call) RunAndReturn ¶
func (_c *Client_PurgeDeclaredIPs_Call) RunAndReturn(run func(context.Context, v1beta4.LeaseID) error) *Client_PurgeDeclaredIPs_Call
type Client_RemoveHostnameFromDeployment_Call ¶
Client_RemoveHostnameFromDeployment_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RemoveHostnameFromDeployment'
func (*Client_RemoveHostnameFromDeployment_Call) Return ¶
func (_c *Client_RemoveHostnameFromDeployment_Call) Return(_a0 error) *Client_RemoveHostnameFromDeployment_Call
func (*Client_RemoveHostnameFromDeployment_Call) Run ¶
func (_c *Client_RemoveHostnameFromDeployment_Call) Run(run func(ctx context.Context, _a1 string, leaseID v1beta4.LeaseID, allowMissing bool)) *Client_RemoveHostnameFromDeployment_Call
func (*Client_RemoveHostnameFromDeployment_Call) RunAndReturn ¶
func (_c *Client_RemoveHostnameFromDeployment_Call) RunAndReturn(run func(context.Context, string, v1beta4.LeaseID, bool) error) *Client_RemoveHostnameFromDeployment_Call
type Client_ServiceStatus_Call ¶
Client_ServiceStatus_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ServiceStatus'
func (*Client_ServiceStatus_Call) Return ¶
func (_c *Client_ServiceStatus_Call) Return(_a0 *v1beta3.ServiceStatus, _a1 error) *Client_ServiceStatus_Call
func (*Client_ServiceStatus_Call) Run ¶
func (_c *Client_ServiceStatus_Call) Run(run func(_a0 context.Context, _a1 v1beta4.LeaseID, _a2 string)) *Client_ServiceStatus_Call
func (*Client_ServiceStatus_Call) RunAndReturn ¶
func (_c *Client_ServiceStatus_Call) RunAndReturn(run func(context.Context, v1beta4.LeaseID, string) (*v1beta3.ServiceStatus, error)) *Client_ServiceStatus_Call
type Client_TeardownLease_Call ¶
Client_TeardownLease_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'TeardownLease'
func (*Client_TeardownLease_Call) Return ¶
func (_c *Client_TeardownLease_Call) Return(_a0 error) *Client_TeardownLease_Call
func (*Client_TeardownLease_Call) Run ¶
func (_c *Client_TeardownLease_Call) Run(run func(_a0 context.Context, _a1 v1beta4.LeaseID)) *Client_TeardownLease_Call
func (*Client_TeardownLease_Call) RunAndReturn ¶
func (_c *Client_TeardownLease_Call) RunAndReturn(run func(context.Context, v1beta4.LeaseID) error) *Client_TeardownLease_Call
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) EXPECT ¶
func (_m *Cluster) EXPECT() *Cluster_Expecter
func (*Cluster) Reserve ¶
func (_m *Cluster) Reserve(_a0 v1beta4.OrderID, _a1 v1beta3.ResourceGroup) (typesv1beta3.Reservation, error)
Reserve provides a mock function with given fields: _a0, _a1
type Cluster_Expecter ¶
type Cluster_Expecter struct {
// contains filtered or unexported fields
}
func (*Cluster_Expecter) Reserve ¶
func (_e *Cluster_Expecter) Reserve(_a0 interface{}, _a1 interface{}) *Cluster_Reserve_Call
Reserve is a helper method to define mock.On call
- _a0 v1beta4.OrderID
- _a1 v1beta3.ResourceGroup
func (*Cluster_Expecter) Unreserve ¶
func (_e *Cluster_Expecter) Unreserve(_a0 interface{}) *Cluster_Unreserve_Call
Unreserve is a helper method to define mock.On call
- _a0 v1beta4.OrderID
type Cluster_Reserve_Call ¶
Cluster_Reserve_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Reserve'
func (*Cluster_Reserve_Call) Return ¶
func (_c *Cluster_Reserve_Call) Return(_a0 typesv1beta3.Reservation, _a1 error) *Cluster_Reserve_Call
func (*Cluster_Reserve_Call) Run ¶
func (_c *Cluster_Reserve_Call) Run(run func(_a0 v1beta4.OrderID, _a1 v1beta3.ResourceGroup)) *Cluster_Reserve_Call
func (*Cluster_Reserve_Call) RunAndReturn ¶
func (_c *Cluster_Reserve_Call) RunAndReturn(run func(v1beta4.OrderID, v1beta3.ResourceGroup) (typesv1beta3.Reservation, error)) *Cluster_Reserve_Call
type Cluster_Unreserve_Call ¶
Cluster_Unreserve_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Unreserve'
func (*Cluster_Unreserve_Call) Return ¶
func (_c *Cluster_Unreserve_Call) Return(_a0 error) *Cluster_Unreserve_Call
func (*Cluster_Unreserve_Call) Run ¶
func (_c *Cluster_Unreserve_Call) Run(run func(_a0 v1beta4.OrderID)) *Cluster_Unreserve_Call
func (*Cluster_Unreserve_Call) RunAndReturn ¶
func (_c *Cluster_Unreserve_Call) RunAndReturn(run func(v1beta4.OrderID) error) *Cluster_Unreserve_Call
type ReadClient ¶
ReadClient is an autogenerated mock type for the ReadClient type
func NewReadClient ¶
func NewReadClient(t interface { mock.TestingT Cleanup(func()) }) *ReadClient
NewReadClient creates a new instance of ReadClient. 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 (*ReadClient) AllHostnames ¶
func (_m *ReadClient) AllHostnames(_a0 context.Context) ([]hostname.ActiveHostname, error)
AllHostnames provides a mock function with given fields: _a0
func (*ReadClient) EXPECT ¶
func (_m *ReadClient) EXPECT() *ReadClient_Expecter
func (*ReadClient) ForwardedPortStatus ¶
func (_m *ReadClient) ForwardedPortStatus(_a0 context.Context, _a1 v1beta4.LeaseID) (map[string][]v1beta3.ForwardedPortStatus, error)
ForwardedPortStatus provides a mock function with given fields: _a0, _a1
func (*ReadClient) GetDeclaredIPs ¶
func (_m *ReadClient) GetDeclaredIPs(ctx context.Context, leaseID v1beta4.LeaseID) ([]v2beta2.ProviderLeasedIPSpec, error)
GetDeclaredIPs provides a mock function with given fields: ctx, leaseID
func (*ReadClient) GetHostnameDeploymentConnections ¶
func (_m *ReadClient) GetHostnameDeploymentConnections(ctx context.Context) ([]hostname.LeaseIDConnection, error)
GetHostnameDeploymentConnections provides a mock function with given fields: ctx
func (*ReadClient) GetManifestGroup ¶
func (_m *ReadClient) GetManifestGroup(_a0 context.Context, _a1 v1beta4.LeaseID) (bool, v2beta2.ManifestGroup, error)
GetManifestGroup provides a mock function with given fields: _a0, _a1
func (*ReadClient) LeaseEvents ¶
func (_m *ReadClient) LeaseEvents(_a0 context.Context, _a1 v1beta4.LeaseID, _a2 string, _a3 bool) (v1beta3.EventsWatcher, error)
LeaseEvents provides a mock function with given fields: _a0, _a1, _a2, _a3
func (*ReadClient) LeaseLogs ¶
func (_m *ReadClient) LeaseLogs(_a0 context.Context, _a1 v1beta4.LeaseID, _a2 string, _a3 bool, _a4 *int64) ([]*v1beta3.ServiceLog, error)
LeaseLogs provides a mock function with given fields: _a0, _a1, _a2, _a3, _a4
func (*ReadClient) LeaseStatus ¶
func (_m *ReadClient) LeaseStatus(_a0 context.Context, _a1 v1beta4.LeaseID) (map[string]*v1beta3.ServiceStatus, error)
LeaseStatus provides a mock function with given fields: _a0, _a1
func (*ReadClient) ObserveHostnameState ¶
func (_m *ReadClient) ObserveHostnameState(ctx context.Context) (<-chan hostname.ResourceEvent, error)
ObserveHostnameState provides a mock function with given fields: ctx
func (*ReadClient) ObserveIPState ¶
func (_m *ReadClient) ObserveIPState(ctx context.Context) (<-chan ip.ResourceEvent, error)
ObserveIPState provides a mock function with given fields: ctx
func (*ReadClient) ServiceStatus ¶
func (_m *ReadClient) ServiceStatus(_a0 context.Context, _a1 v1beta4.LeaseID, _a2 string) (*v1beta3.ServiceStatus, error)
ServiceStatus provides a mock function with given fields: _a0, _a1, _a2
type ReadClient_AllHostnames_Call ¶
ReadClient_AllHostnames_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AllHostnames'
func (*ReadClient_AllHostnames_Call) Return ¶
func (_c *ReadClient_AllHostnames_Call) Return(_a0 []hostname.ActiveHostname, _a1 error) *ReadClient_AllHostnames_Call
func (*ReadClient_AllHostnames_Call) Run ¶
func (_c *ReadClient_AllHostnames_Call) Run(run func(_a0 context.Context)) *ReadClient_AllHostnames_Call
func (*ReadClient_AllHostnames_Call) RunAndReturn ¶
func (_c *ReadClient_AllHostnames_Call) RunAndReturn(run func(context.Context) ([]hostname.ActiveHostname, error)) *ReadClient_AllHostnames_Call
type ReadClient_Expecter ¶
type ReadClient_Expecter struct {
// contains filtered or unexported fields
}
func (*ReadClient_Expecter) AllHostnames ¶
func (_e *ReadClient_Expecter) AllHostnames(_a0 interface{}) *ReadClient_AllHostnames_Call
AllHostnames is a helper method to define mock.On call
- _a0 context.Context
func (*ReadClient_Expecter) ForwardedPortStatus ¶
func (_e *ReadClient_Expecter) ForwardedPortStatus(_a0 interface{}, _a1 interface{}) *ReadClient_ForwardedPortStatus_Call
ForwardedPortStatus is a helper method to define mock.On call
- _a0 context.Context
- _a1 v1beta4.LeaseID
func (*ReadClient_Expecter) GetDeclaredIPs ¶
func (_e *ReadClient_Expecter) GetDeclaredIPs(ctx interface{}, leaseID interface{}) *ReadClient_GetDeclaredIPs_Call
GetDeclaredIPs is a helper method to define mock.On call
- ctx context.Context
- leaseID v1beta4.LeaseID
func (*ReadClient_Expecter) GetHostnameDeploymentConnections ¶
func (_e *ReadClient_Expecter) GetHostnameDeploymentConnections(ctx interface{}) *ReadClient_GetHostnameDeploymentConnections_Call
GetHostnameDeploymentConnections is a helper method to define mock.On call
- ctx context.Context
func (*ReadClient_Expecter) GetManifestGroup ¶
func (_e *ReadClient_Expecter) GetManifestGroup(_a0 interface{}, _a1 interface{}) *ReadClient_GetManifestGroup_Call
GetManifestGroup is a helper method to define mock.On call
- _a0 context.Context
- _a1 v1beta4.LeaseID
func (*ReadClient_Expecter) LeaseEvents ¶
func (_e *ReadClient_Expecter) LeaseEvents(_a0 interface{}, _a1 interface{}, _a2 interface{}, _a3 interface{}) *ReadClient_LeaseEvents_Call
LeaseEvents is a helper method to define mock.On call
- _a0 context.Context
- _a1 v1beta4.LeaseID
- _a2 string
- _a3 bool
func (*ReadClient_Expecter) LeaseLogs ¶
func (_e *ReadClient_Expecter) LeaseLogs(_a0 interface{}, _a1 interface{}, _a2 interface{}, _a3 interface{}, _a4 interface{}) *ReadClient_LeaseLogs_Call
LeaseLogs is a helper method to define mock.On call
- _a0 context.Context
- _a1 v1beta4.LeaseID
- _a2 string
- _a3 bool
- _a4 *int64
func (*ReadClient_Expecter) LeaseStatus ¶
func (_e *ReadClient_Expecter) LeaseStatus(_a0 interface{}, _a1 interface{}) *ReadClient_LeaseStatus_Call
LeaseStatus is a helper method to define mock.On call
- _a0 context.Context
- _a1 v1beta4.LeaseID
func (*ReadClient_Expecter) ObserveHostnameState ¶
func (_e *ReadClient_Expecter) ObserveHostnameState(ctx interface{}) *ReadClient_ObserveHostnameState_Call
ObserveHostnameState is a helper method to define mock.On call
- ctx context.Context
func (*ReadClient_Expecter) ObserveIPState ¶
func (_e *ReadClient_Expecter) ObserveIPState(ctx interface{}) *ReadClient_ObserveIPState_Call
ObserveIPState is a helper method to define mock.On call
- ctx context.Context
func (*ReadClient_Expecter) ServiceStatus ¶
func (_e *ReadClient_Expecter) ServiceStatus(_a0 interface{}, _a1 interface{}, _a2 interface{}) *ReadClient_ServiceStatus_Call
ServiceStatus is a helper method to define mock.On call
- _a0 context.Context
- _a1 v1beta4.LeaseID
- _a2 string
type ReadClient_ForwardedPortStatus_Call ¶
ReadClient_ForwardedPortStatus_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ForwardedPortStatus'
func (*ReadClient_ForwardedPortStatus_Call) Return ¶
func (_c *ReadClient_ForwardedPortStatus_Call) Return(_a0 map[string][]v1beta3.ForwardedPortStatus, _a1 error) *ReadClient_ForwardedPortStatus_Call
func (*ReadClient_ForwardedPortStatus_Call) Run ¶
func (_c *ReadClient_ForwardedPortStatus_Call) Run(run func(_a0 context.Context, _a1 v1beta4.LeaseID)) *ReadClient_ForwardedPortStatus_Call
func (*ReadClient_ForwardedPortStatus_Call) RunAndReturn ¶
func (_c *ReadClient_ForwardedPortStatus_Call) RunAndReturn(run func(context.Context, v1beta4.LeaseID) (map[string][]v1beta3.ForwardedPortStatus, error)) *ReadClient_ForwardedPortStatus_Call
type ReadClient_GetDeclaredIPs_Call ¶
ReadClient_GetDeclaredIPs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetDeclaredIPs'
func (*ReadClient_GetDeclaredIPs_Call) Return ¶
func (_c *ReadClient_GetDeclaredIPs_Call) Return(_a0 []v2beta2.ProviderLeasedIPSpec, _a1 error) *ReadClient_GetDeclaredIPs_Call
func (*ReadClient_GetDeclaredIPs_Call) Run ¶
func (_c *ReadClient_GetDeclaredIPs_Call) Run(run func(ctx context.Context, leaseID v1beta4.LeaseID)) *ReadClient_GetDeclaredIPs_Call
func (*ReadClient_GetDeclaredIPs_Call) RunAndReturn ¶
func (_c *ReadClient_GetDeclaredIPs_Call) RunAndReturn(run func(context.Context, v1beta4.LeaseID) ([]v2beta2.ProviderLeasedIPSpec, error)) *ReadClient_GetDeclaredIPs_Call
type ReadClient_GetHostnameDeploymentConnections_Call ¶
ReadClient_GetHostnameDeploymentConnections_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetHostnameDeploymentConnections'
func (*ReadClient_GetHostnameDeploymentConnections_Call) Return ¶
func (_c *ReadClient_GetHostnameDeploymentConnections_Call) Return(_a0 []hostname.LeaseIDConnection, _a1 error) *ReadClient_GetHostnameDeploymentConnections_Call
func (*ReadClient_GetHostnameDeploymentConnections_Call) Run ¶
func (_c *ReadClient_GetHostnameDeploymentConnections_Call) Run(run func(ctx context.Context)) *ReadClient_GetHostnameDeploymentConnections_Call
func (*ReadClient_GetHostnameDeploymentConnections_Call) RunAndReturn ¶
func (_c *ReadClient_GetHostnameDeploymentConnections_Call) RunAndReturn(run func(context.Context) ([]hostname.LeaseIDConnection, error)) *ReadClient_GetHostnameDeploymentConnections_Call
type ReadClient_GetManifestGroup_Call ¶
ReadClient_GetManifestGroup_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetManifestGroup'
func (*ReadClient_GetManifestGroup_Call) Return ¶
func (_c *ReadClient_GetManifestGroup_Call) Return(_a0 bool, _a1 v2beta2.ManifestGroup, _a2 error) *ReadClient_GetManifestGroup_Call
func (*ReadClient_GetManifestGroup_Call) Run ¶
func (_c *ReadClient_GetManifestGroup_Call) Run(run func(_a0 context.Context, _a1 v1beta4.LeaseID)) *ReadClient_GetManifestGroup_Call
func (*ReadClient_GetManifestGroup_Call) RunAndReturn ¶
func (_c *ReadClient_GetManifestGroup_Call) RunAndReturn(run func(context.Context, v1beta4.LeaseID) (bool, v2beta2.ManifestGroup, error)) *ReadClient_GetManifestGroup_Call
type ReadClient_LeaseEvents_Call ¶
ReadClient_LeaseEvents_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'LeaseEvents'
func (*ReadClient_LeaseEvents_Call) Return ¶
func (_c *ReadClient_LeaseEvents_Call) Return(_a0 v1beta3.EventsWatcher, _a1 error) *ReadClient_LeaseEvents_Call
func (*ReadClient_LeaseEvents_Call) Run ¶
func (_c *ReadClient_LeaseEvents_Call) Run(run func(_a0 context.Context, _a1 v1beta4.LeaseID, _a2 string, _a3 bool)) *ReadClient_LeaseEvents_Call
func (*ReadClient_LeaseEvents_Call) RunAndReturn ¶
func (_c *ReadClient_LeaseEvents_Call) RunAndReturn(run func(context.Context, v1beta4.LeaseID, string, bool) (v1beta3.EventsWatcher, error)) *ReadClient_LeaseEvents_Call
type ReadClient_LeaseLogs_Call ¶
ReadClient_LeaseLogs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'LeaseLogs'
func (*ReadClient_LeaseLogs_Call) Return ¶
func (_c *ReadClient_LeaseLogs_Call) Return(_a0 []*v1beta3.ServiceLog, _a1 error) *ReadClient_LeaseLogs_Call
func (*ReadClient_LeaseLogs_Call) Run ¶
func (_c *ReadClient_LeaseLogs_Call) Run(run func(_a0 context.Context, _a1 v1beta4.LeaseID, _a2 string, _a3 bool, _a4 *int64)) *ReadClient_LeaseLogs_Call
func (*ReadClient_LeaseLogs_Call) RunAndReturn ¶
func (_c *ReadClient_LeaseLogs_Call) RunAndReturn(run func(context.Context, v1beta4.LeaseID, string, bool, *int64) ([]*v1beta3.ServiceLog, error)) *ReadClient_LeaseLogs_Call
type ReadClient_LeaseStatus_Call ¶
ReadClient_LeaseStatus_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'LeaseStatus'
func (*ReadClient_LeaseStatus_Call) Return ¶
func (_c *ReadClient_LeaseStatus_Call) Return(_a0 map[string]*v1beta3.ServiceStatus, _a1 error) *ReadClient_LeaseStatus_Call
func (*ReadClient_LeaseStatus_Call) Run ¶
func (_c *ReadClient_LeaseStatus_Call) Run(run func(_a0 context.Context, _a1 v1beta4.LeaseID)) *ReadClient_LeaseStatus_Call
func (*ReadClient_LeaseStatus_Call) RunAndReturn ¶
func (_c *ReadClient_LeaseStatus_Call) RunAndReturn(run func(context.Context, v1beta4.LeaseID) (map[string]*v1beta3.ServiceStatus, error)) *ReadClient_LeaseStatus_Call
type ReadClient_ObserveHostnameState_Call ¶
ReadClient_ObserveHostnameState_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ObserveHostnameState'
func (*ReadClient_ObserveHostnameState_Call) Return ¶
func (_c *ReadClient_ObserveHostnameState_Call) Return(_a0 <-chan hostname.ResourceEvent, _a1 error) *ReadClient_ObserveHostnameState_Call
func (*ReadClient_ObserveHostnameState_Call) Run ¶
func (_c *ReadClient_ObserveHostnameState_Call) Run(run func(ctx context.Context)) *ReadClient_ObserveHostnameState_Call
func (*ReadClient_ObserveHostnameState_Call) RunAndReturn ¶
func (_c *ReadClient_ObserveHostnameState_Call) RunAndReturn(run func(context.Context) (<-chan hostname.ResourceEvent, error)) *ReadClient_ObserveHostnameState_Call
type ReadClient_ObserveIPState_Call ¶
ReadClient_ObserveIPState_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ObserveIPState'
func (*ReadClient_ObserveIPState_Call) Return ¶
func (_c *ReadClient_ObserveIPState_Call) Return(_a0 <-chan ip.ResourceEvent, _a1 error) *ReadClient_ObserveIPState_Call
func (*ReadClient_ObserveIPState_Call) Run ¶
func (_c *ReadClient_ObserveIPState_Call) Run(run func(ctx context.Context)) *ReadClient_ObserveIPState_Call
func (*ReadClient_ObserveIPState_Call) RunAndReturn ¶
func (_c *ReadClient_ObserveIPState_Call) RunAndReturn(run func(context.Context) (<-chan ip.ResourceEvent, error)) *ReadClient_ObserveIPState_Call
type ReadClient_ServiceStatus_Call ¶
ReadClient_ServiceStatus_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ServiceStatus'
func (*ReadClient_ServiceStatus_Call) Return ¶
func (_c *ReadClient_ServiceStatus_Call) Return(_a0 *v1beta3.ServiceStatus, _a1 error) *ReadClient_ServiceStatus_Call
func (*ReadClient_ServiceStatus_Call) Run ¶
func (_c *ReadClient_ServiceStatus_Call) Run(run func(_a0 context.Context, _a1 v1beta4.LeaseID, _a2 string)) *ReadClient_ServiceStatus_Call
func (*ReadClient_ServiceStatus_Call) RunAndReturn ¶
func (_c *ReadClient_ServiceStatus_Call) RunAndReturn(run func(context.Context, v1beta4.LeaseID, string) (*v1beta3.ServiceStatus, error)) *ReadClient_ServiceStatus_Call
type Service ¶
Service is an autogenerated mock type for the Service type
func NewService ¶
NewService creates a new instance of Service. 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 (*Service) Done ¶
func (_m *Service) Done() <-chan struct{}
Done provides a mock function with given fields:
func (*Service) EXPECT ¶
func (_m *Service) EXPECT() *Service_Expecter
func (*Service) FindActiveLease ¶
func (_m *Service) FindActiveLease(ctx context.Context, owner types.Address, dseq uint64, gseq uint32) (bool, v1beta4.LeaseID, v2beta2.ManifestGroup, error)
FindActiveLease provides a mock function with given fields: ctx, owner, dseq, gseq
func (*Service) HostnameService ¶
func (_m *Service) HostnameService() v1beta3.HostnameServiceClient
HostnameService provides a mock function with given fields:
func (*Service) Ready ¶
func (_m *Service) Ready() <-chan struct{}
Ready provides a mock function with given fields:
func (*Service) Reserve ¶
func (_m *Service) Reserve(_a0 v1beta4.OrderID, _a1 deploymentv1beta3.ResourceGroup) (v1beta3.Reservation, error)
Reserve provides a mock function with given fields: _a0, _a1
type Service_Close_Call ¶
Service_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'
func (*Service_Close_Call) Return ¶
func (_c *Service_Close_Call) Return(_a0 error) *Service_Close_Call
func (*Service_Close_Call) Run ¶
func (_c *Service_Close_Call) Run(run func()) *Service_Close_Call
func (*Service_Close_Call) RunAndReturn ¶
func (_c *Service_Close_Call) RunAndReturn(run func() error) *Service_Close_Call
type Service_Done_Call ¶
Service_Done_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Done'
func (*Service_Done_Call) Return ¶
func (_c *Service_Done_Call) Return(_a0 <-chan struct{}) *Service_Done_Call
func (*Service_Done_Call) Run ¶
func (_c *Service_Done_Call) Run(run func()) *Service_Done_Call
func (*Service_Done_Call) RunAndReturn ¶
func (_c *Service_Done_Call) RunAndReturn(run func() <-chan struct{}) *Service_Done_Call
type Service_Expecter ¶
type Service_Expecter struct {
// contains filtered or unexported fields
}
func (*Service_Expecter) Close ¶
func (_e *Service_Expecter) Close() *Service_Close_Call
Close is a helper method to define mock.On call
func (*Service_Expecter) Done ¶
func (_e *Service_Expecter) Done() *Service_Done_Call
Done is a helper method to define mock.On call
func (*Service_Expecter) FindActiveLease ¶
func (_e *Service_Expecter) FindActiveLease(ctx interface{}, owner interface{}, dseq interface{}, gseq interface{}) *Service_FindActiveLease_Call
FindActiveLease is a helper method to define mock.On call
- ctx context.Context
- owner types.Address
- dseq uint64
- gseq uint32
func (*Service_Expecter) HostnameService ¶
func (_e *Service_Expecter) HostnameService() *Service_HostnameService_Call
HostnameService is a helper method to define mock.On call
func (*Service_Expecter) Ready ¶
func (_e *Service_Expecter) Ready() *Service_Ready_Call
Ready is a helper method to define mock.On call
func (*Service_Expecter) Reserve ¶
func (_e *Service_Expecter) Reserve(_a0 interface{}, _a1 interface{}) *Service_Reserve_Call
Reserve is a helper method to define mock.On call
- _a0 v1beta4.OrderID
- _a1 deploymentv1beta3.ResourceGroup
func (*Service_Expecter) Status ¶
func (_e *Service_Expecter) Status(_a0 interface{}) *Service_Status_Call
Status is a helper method to define mock.On call
- _a0 context.Context
func (*Service_Expecter) StatusV1 ¶
func (_e *Service_Expecter) StatusV1(_a0 interface{}) *Service_StatusV1_Call
StatusV1 is a helper method to define mock.On call
- _a0 context.Context
func (*Service_Expecter) TransferHostname ¶
func (_e *Service_Expecter) TransferHostname(ctx interface{}, leaseID interface{}, hostname interface{}, serviceName interface{}, externalPort interface{}) *Service_TransferHostname_Call
TransferHostname is a helper method to define mock.On call
- ctx context.Context
- leaseID v1beta4.LeaseID
- hostname string
- serviceName string
- externalPort uint32
func (*Service_Expecter) Unreserve ¶
func (_e *Service_Expecter) Unreserve(_a0 interface{}) *Service_Unreserve_Call
Unreserve is a helper method to define mock.On call
- _a0 v1beta4.OrderID
type Service_FindActiveLease_Call ¶
Service_FindActiveLease_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindActiveLease'
func (*Service_FindActiveLease_Call) Return ¶
func (_c *Service_FindActiveLease_Call) Return(_a0 bool, _a1 v1beta4.LeaseID, _a2 v2beta2.ManifestGroup, _a3 error) *Service_FindActiveLease_Call
func (*Service_FindActiveLease_Call) Run ¶
func (_c *Service_FindActiveLease_Call) Run(run func(ctx context.Context, owner types.Address, dseq uint64, gseq uint32)) *Service_FindActiveLease_Call
func (*Service_FindActiveLease_Call) RunAndReturn ¶
func (_c *Service_FindActiveLease_Call) RunAndReturn(run func(context.Context, types.Address, uint64, uint32) (bool, v1beta4.LeaseID, v2beta2.ManifestGroup, error)) *Service_FindActiveLease_Call
type Service_HostnameService_Call ¶
Service_HostnameService_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HostnameService'
func (*Service_HostnameService_Call) Return ¶
func (_c *Service_HostnameService_Call) Return(_a0 v1beta3.HostnameServiceClient) *Service_HostnameService_Call
func (*Service_HostnameService_Call) Run ¶
func (_c *Service_HostnameService_Call) Run(run func()) *Service_HostnameService_Call
func (*Service_HostnameService_Call) RunAndReturn ¶
func (_c *Service_HostnameService_Call) RunAndReturn(run func() v1beta3.HostnameServiceClient) *Service_HostnameService_Call
type Service_Ready_Call ¶
Service_Ready_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Ready'
func (*Service_Ready_Call) Return ¶
func (_c *Service_Ready_Call) Return(_a0 <-chan struct{}) *Service_Ready_Call
func (*Service_Ready_Call) Run ¶
func (_c *Service_Ready_Call) Run(run func()) *Service_Ready_Call
func (*Service_Ready_Call) RunAndReturn ¶
func (_c *Service_Ready_Call) RunAndReturn(run func() <-chan struct{}) *Service_Ready_Call
type Service_Reserve_Call ¶
Service_Reserve_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Reserve'
func (*Service_Reserve_Call) Return ¶
func (_c *Service_Reserve_Call) Return(_a0 v1beta3.Reservation, _a1 error) *Service_Reserve_Call
func (*Service_Reserve_Call) Run ¶
func (_c *Service_Reserve_Call) Run(run func(_a0 v1beta4.OrderID, _a1 deploymentv1beta3.ResourceGroup)) *Service_Reserve_Call
func (*Service_Reserve_Call) RunAndReturn ¶
func (_c *Service_Reserve_Call) RunAndReturn(run func(v1beta4.OrderID, deploymentv1beta3.ResourceGroup) (v1beta3.Reservation, error)) *Service_Reserve_Call
type Service_StatusV1_Call ¶
Service_StatusV1_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StatusV1'
func (*Service_StatusV1_Call) Return ¶
func (_c *Service_StatusV1_Call) Return(_a0 *v1.ClusterStatus, _a1 error) *Service_StatusV1_Call
func (*Service_StatusV1_Call) Run ¶
func (_c *Service_StatusV1_Call) Run(run func(_a0 context.Context)) *Service_StatusV1_Call
func (*Service_StatusV1_Call) RunAndReturn ¶
func (_c *Service_StatusV1_Call) RunAndReturn(run func(context.Context) (*v1.ClusterStatus, error)) *Service_StatusV1_Call
type Service_Status_Call ¶
Service_Status_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Status'
func (*Service_Status_Call) Return ¶
func (_c *Service_Status_Call) Return(_a0 *v1beta3.Status, _a1 error) *Service_Status_Call
func (*Service_Status_Call) Run ¶
func (_c *Service_Status_Call) Run(run func(_a0 context.Context)) *Service_Status_Call
func (*Service_Status_Call) RunAndReturn ¶
func (_c *Service_Status_Call) RunAndReturn(run func(context.Context) (*v1beta3.Status, error)) *Service_Status_Call
type Service_TransferHostname_Call ¶
Service_TransferHostname_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'TransferHostname'
func (*Service_TransferHostname_Call) Return ¶
func (_c *Service_TransferHostname_Call) Return(_a0 error) *Service_TransferHostname_Call
func (*Service_TransferHostname_Call) Run ¶
func (_c *Service_TransferHostname_Call) Run(run func(ctx context.Context, leaseID v1beta4.LeaseID, hostname string, serviceName string, externalPort uint32)) *Service_TransferHostname_Call
func (*Service_TransferHostname_Call) RunAndReturn ¶
func (_c *Service_TransferHostname_Call) RunAndReturn(run func(context.Context, v1beta4.LeaseID, string, string, uint32) error) *Service_TransferHostname_Call
type Service_Unreserve_Call ¶
Service_Unreserve_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Unreserve'
func (*Service_Unreserve_Call) Return ¶
func (_c *Service_Unreserve_Call) Return(_a0 error) *Service_Unreserve_Call
func (*Service_Unreserve_Call) Run ¶
func (_c *Service_Unreserve_Call) Run(run func(_a0 v1beta4.OrderID)) *Service_Unreserve_Call
func (*Service_Unreserve_Call) RunAndReturn ¶
func (_c *Service_Unreserve_Call) RunAndReturn(run func(v1beta4.OrderID) error) *Service_Unreserve_Call