Documentation ¶
Index ¶
- type Client
- func (_m *Client) AllHostnames(_a0 context.Context) ([]v1beta2.ActiveHostname, error)
- func (_m *Client) ConnectHostnameToDeployment(ctx context.Context, directive v1beta2.ConnectHostnameToDeploymentDirective) error
- func (_m *Client) DeclareHostname(ctx context.Context, lID typesv1beta2.LeaseID, host string, serviceName string, ...) error
- func (_m *Client) Deploy(ctx context.Context, lID typesv1beta2.LeaseID, mgroup *v2beta1.Group) error
- func (_m *Client) Deployments(_a0 context.Context) ([]v1beta2.Deployment, error)
- func (_m *Client) Exec(ctx context.Context, lID typesv1beta2.LeaseID, service string, podIndex uint, ...) (v1beta2.ExecResult, error)
- func (_m *Client) GetHostnameDeploymentConnections(ctx context.Context) ([]v1beta2.LeaseIDHostnameConnection, error)
- func (_m *Client) GetManifestGroup(_a0 context.Context, _a1 typesv1beta2.LeaseID) (bool, akash_networkv2beta1.ManifestGroup, error)
- func (_m *Client) Inventory(_a0 context.Context) (v1beta2.Inventory, error)
- func (_m *Client) KubeVersion() (*version.Info, error)
- func (_m *Client) LeaseEvents(_a0 context.Context, _a1 typesv1beta2.LeaseID, _a2 string, _a3 bool) (v1beta2.EventsWatcher, error)
- func (_m *Client) LeaseLogs(_a0 context.Context, _a1 typesv1beta2.LeaseID, _a2 string, _a3 bool, ...) ([]*v1beta2.ServiceLog, error)
- func (_m *Client) LeaseStatus(_a0 context.Context, _a1 typesv1beta2.LeaseID) (*v1beta2.LeaseStatus, error)
- func (_m *Client) ObserveHostnameState(ctx context.Context) (<-chan v1beta2.HostnameResourceEvent, error)
- func (_m *Client) PurgeDeclaredHostname(ctx context.Context, lID typesv1beta2.LeaseID, hostname string) error
- func (_m *Client) PurgeDeclaredHostnames(ctx context.Context, lID typesv1beta2.LeaseID) error
- func (_m *Client) RemoveHostnameFromDeployment(ctx context.Context, hostname string, leaseID typesv1beta2.LeaseID, ...) error
- func (_m *Client) ServiceStatus(_a0 context.Context, _a1 typesv1beta2.LeaseID, _a2 string) (*v1beta2.ServiceStatus, error)
- func (_m *Client) TeardownLease(_a0 context.Context, _a1 typesv1beta2.LeaseID) error
- type Cluster
- type Deployment
- type HostnameServiceClient
- func (_m *HostnameServiceClient) CanReserveHostnames(hostnames []string, ownerAddr types.Address) error
- func (_m *HostnameServiceClient) PrepareHostnamesForTransfer(ctx context.Context, hostnames []string, leaseID typesv1beta2.LeaseID) error
- func (_m *HostnameServiceClient) ReleaseHostnames(leaseID typesv1beta2.LeaseID) error
- func (_m *HostnameServiceClient) ReserveHostnames(ctx context.Context, hostnames []string, leaseID typesv1beta2.LeaseID) ([]string, error)
- type ReadClient
- func (_m *ReadClient) AllHostnames(_a0 context.Context) ([]v1beta2.ActiveHostname, error)
- func (_m *ReadClient) GetHostnameDeploymentConnections(ctx context.Context) ([]v1beta2.LeaseIDHostnameConnection, error)
- func (_m *ReadClient) GetManifestGroup(_a0 context.Context, _a1 typesv1beta2.LeaseID) (bool, v2beta1.ManifestGroup, error)
- func (_m *ReadClient) LeaseEvents(_a0 context.Context, _a1 typesv1beta2.LeaseID, _a2 string, _a3 bool) (v1beta2.EventsWatcher, error)
- func (_m *ReadClient) LeaseLogs(_a0 context.Context, _a1 typesv1beta2.LeaseID, _a2 string, _a3 bool, ...) ([]*v1beta2.ServiceLog, error)
- func (_m *ReadClient) LeaseStatus(_a0 context.Context, _a1 typesv1beta2.LeaseID) (*v1beta2.LeaseStatus, error)
- func (_m *ReadClient) ObserveHostnameState(ctx context.Context) (<-chan v1beta2.HostnameResourceEvent, error)
- func (_m *ReadClient) ServiceStatus(_a0 context.Context, _a1 typesv1beta2.LeaseID, _a2 string) (*v1beta2.ServiceStatus, error)
- type Reservation
- type Service
- func (_m *Service) Close() error
- func (_m *Service) Done() <-chan struct{}
- func (_m *Service) FindActiveLease(ctx context.Context, owner types.Address, dseq uint64, gseq uint32) (bool, v1beta2.LeaseID, v2beta1.ManifestGroup, error)
- func (_m *Service) HostnameService() typesv1beta2.HostnameServiceClient
- func (_m *Service) Ready() <-chan struct{}
- func (_m *Service) Reserve(_a0 v1beta2.OrderID, _a1 akashtypesv1beta2.ResourceGroup) (typesv1beta2.Reservation, error)
- func (_m *Service) Status(_a0 context.Context) (*typesv1beta2.Status, error)
- func (_m *Service) TransferHostname(ctx context.Context, leaseID v1beta2.LeaseID, hostname string, ...) error
- func (_m *Service) Unreserve(_a0 v1beta2.OrderID) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶ added in v0.0.9
Client is an autogenerated mock type for the Client type
func NewClient ¶ added in v0.16.2
NewClient creates a new instance of Client. It also registers the testing.TB interface on the mock and a cleanup function to assert the mocks expectations.
func (*Client) AllHostnames ¶ added in v0.14.0
AllHostnames provides a mock function with given fields: _a0
func (*Client) ConnectHostnameToDeployment ¶ added in v0.14.0
func (_m *Client) ConnectHostnameToDeployment(ctx context.Context, directive v1beta2.ConnectHostnameToDeploymentDirective) error
ConnectHostnameToDeployment provides a mock function with given fields: ctx, directive
func (*Client) DeclareHostname ¶ added in v0.14.0
func (_m *Client) DeclareHostname(ctx context.Context, lID typesv1beta2.LeaseID, host string, serviceName string, externalPort uint32) error
DeclareHostname provides a mock function with given fields: ctx, lID, host, serviceName, externalPort
func (*Client) Deploy ¶ added in v0.0.9
func (_m *Client) Deploy(ctx context.Context, lID typesv1beta2.LeaseID, mgroup *v2beta1.Group) error
Deploy provides a mock function with given fields: ctx, lID, mgroup
func (*Client) Deployments ¶ added in v0.0.9
Deployments provides a mock function with given fields: _a0
func (*Client) Exec ¶ added in v0.12.2
func (_m *Client) Exec(ctx context.Context, lID typesv1beta2.LeaseID, service string, podIndex uint, cmd []string, stdin io.Reader, stdout io.Writer, stderr io.Writer, tty bool, tsq remotecommand.TerminalSizeQueue) (v1beta2.ExecResult, error)
Exec provides a mock function with given fields: ctx, lID, service, podIndex, cmd, stdin, stdout, stderr, tty, tsq
func (*Client) GetHostnameDeploymentConnections ¶ added in v0.14.0
func (_m *Client) GetHostnameDeploymentConnections(ctx context.Context) ([]v1beta2.LeaseIDHostnameConnection, error)
GetHostnameDeploymentConnections provides a mock function with given fields: ctx
func (*Client) GetManifestGroup ¶ added in v0.14.0
func (_m *Client) GetManifestGroup(_a0 context.Context, _a1 typesv1beta2.LeaseID) (bool, akash_networkv2beta1.ManifestGroup, error)
GetManifestGroup provides a mock function with given fields: _a0, _a1
func (*Client) Inventory ¶ added in v0.2.4
Inventory provides a mock function with given fields: _a0
func (*Client) KubeVersion ¶ added in v0.16.0
KubeVersion provides a mock function with given fields:
func (*Client) LeaseEvents ¶ added in v0.10.1
func (_m *Client) LeaseEvents(_a0 context.Context, _a1 typesv1beta2.LeaseID, _a2 string, _a3 bool) (v1beta2.EventsWatcher, error)
LeaseEvents provides a mock function with given fields: _a0, _a1, _a2, _a3
func (*Client) LeaseLogs ¶ added in v0.10.1
func (_m *Client) LeaseLogs(_a0 context.Context, _a1 typesv1beta2.LeaseID, _a2 string, _a3 bool, _a4 *int64) ([]*v1beta2.ServiceLog, error)
LeaseLogs provides a mock function with given fields: _a0, _a1, _a2, _a3, _a4
func (*Client) LeaseStatus ¶ added in v0.2.2
func (_m *Client) LeaseStatus(_a0 context.Context, _a1 typesv1beta2.LeaseID) (*v1beta2.LeaseStatus, error)
LeaseStatus provides a mock function with given fields: _a0, _a1
func (*Client) ObserveHostnameState ¶ added in v0.14.0
func (_m *Client) ObserveHostnameState(ctx context.Context) (<-chan v1beta2.HostnameResourceEvent, error)
ObserveHostnameState provides a mock function with given fields: ctx
func (*Client) PurgeDeclaredHostname ¶ added in v0.14.0
func (_m *Client) PurgeDeclaredHostname(ctx context.Context, lID typesv1beta2.LeaseID, hostname string) error
PurgeDeclaredHostname provides a mock function with given fields: ctx, lID, hostname
func (*Client) PurgeDeclaredHostnames ¶ added in v0.14.0
PurgeDeclaredHostnames provides a mock function with given fields: ctx, lID
func (*Client) RemoveHostnameFromDeployment ¶ added in v0.14.0
func (_m *Client) RemoveHostnameFromDeployment(ctx context.Context, hostname string, leaseID typesv1beta2.LeaseID, allowMissing bool) error
RemoveHostnameFromDeployment provides a mock function with given fields: ctx, hostname, leaseID, allowMissing
func (*Client) ServiceStatus ¶ added in v0.2.2
func (_m *Client) ServiceStatus(_a0 context.Context, _a1 typesv1beta2.LeaseID, _a2 string) (*v1beta2.ServiceStatus, error)
ServiceStatus provides a mock function with given fields: _a0, _a1, _a2
func (*Client) TeardownLease ¶ added in v0.2.2
TeardownLease provides a mock function with given fields: _a0, _a1
type Cluster ¶
Cluster is an autogenerated mock type for the Cluster type
func NewCluster ¶ added in v0.16.2
NewCluster creates a new instance of Cluster. It also registers the testing.TB interface on the mock and a cleanup function to assert the mocks expectations.
func (*Cluster) Reserve ¶
func (_m *Cluster) Reserve(_a0 v1beta2.OrderID, _a1 typesv1beta2.ResourceGroup) (clustertypesv1beta2.Reservation, error)
Reserve provides a mock function with given fields: _a0, _a1
type Deployment ¶ added in v0.0.9
Deployment is an autogenerated mock type for the Deployment type
func NewDeployment ¶ added in v0.16.2
func NewDeployment(t testing.TB) *Deployment
NewDeployment creates a new instance of Deployment. It also registers the testing.TB interface on the mock and a cleanup function to assert the mocks expectations.
func (*Deployment) LeaseID ¶ added in v0.0.9
func (_m *Deployment) LeaseID() v1beta2.LeaseID
LeaseID provides a mock function with given fields:
func (*Deployment) ManifestGroup ¶ added in v0.0.9
func (_m *Deployment) ManifestGroup() v2beta1.Group
ManifestGroup provides a mock function with given fields:
type HostnameServiceClient ¶ added in v0.14.0
HostnameServiceClient is an autogenerated mock type for the HostnameServiceClient type
func NewHostnameServiceClient ¶ added in v0.16.2
func NewHostnameServiceClient(t testing.TB) *HostnameServiceClient
NewHostnameServiceClient creates a new instance of HostnameServiceClient. It also registers the testing.TB interface on the mock and a cleanup function to assert the mocks expectations.
func (*HostnameServiceClient) CanReserveHostnames ¶ added in v0.14.0
func (_m *HostnameServiceClient) CanReserveHostnames(hostnames []string, ownerAddr types.Address) error
CanReserveHostnames provides a mock function with given fields: hostnames, ownerAddr
func (*HostnameServiceClient) PrepareHostnamesForTransfer ¶ added in v0.14.0
func (_m *HostnameServiceClient) PrepareHostnamesForTransfer(ctx context.Context, hostnames []string, leaseID typesv1beta2.LeaseID) error
PrepareHostnamesForTransfer provides a mock function with given fields: ctx, hostnames, leaseID
func (*HostnameServiceClient) ReleaseHostnames ¶ added in v0.14.0
func (_m *HostnameServiceClient) ReleaseHostnames(leaseID typesv1beta2.LeaseID) error
ReleaseHostnames provides a mock function with given fields: leaseID
func (*HostnameServiceClient) ReserveHostnames ¶ added in v0.14.0
func (_m *HostnameServiceClient) ReserveHostnames(ctx context.Context, hostnames []string, leaseID typesv1beta2.LeaseID) ([]string, error)
ReserveHostnames provides a mock function with given fields: ctx, hostnames, leaseID
type ReadClient ¶ added in v0.7.3
ReadClient is an autogenerated mock type for the ReadClient type
func NewReadClient ¶ added in v0.16.2
func NewReadClient(t testing.TB) *ReadClient
NewReadClient creates a new instance of ReadClient. It also registers the testing.TB interface on the mock and a cleanup function to assert the mocks expectations.
func (*ReadClient) AllHostnames ¶ added in v0.14.0
func (_m *ReadClient) AllHostnames(_a0 context.Context) ([]v1beta2.ActiveHostname, error)
AllHostnames provides a mock function with given fields: _a0
func (*ReadClient) GetHostnameDeploymentConnections ¶ added in v0.14.0
func (_m *ReadClient) GetHostnameDeploymentConnections(ctx context.Context) ([]v1beta2.LeaseIDHostnameConnection, error)
GetHostnameDeploymentConnections provides a mock function with given fields: ctx
func (*ReadClient) GetManifestGroup ¶ added in v0.14.0
func (_m *ReadClient) GetManifestGroup(_a0 context.Context, _a1 typesv1beta2.LeaseID) (bool, v2beta1.ManifestGroup, error)
GetManifestGroup provides a mock function with given fields: _a0, _a1
func (*ReadClient) LeaseEvents ¶ added in v0.10.1
func (_m *ReadClient) LeaseEvents(_a0 context.Context, _a1 typesv1beta2.LeaseID, _a2 string, _a3 bool) (v1beta2.EventsWatcher, error)
LeaseEvents provides a mock function with given fields: _a0, _a1, _a2, _a3
func (*ReadClient) LeaseLogs ¶ added in v0.10.1
func (_m *ReadClient) LeaseLogs(_a0 context.Context, _a1 typesv1beta2.LeaseID, _a2 string, _a3 bool, _a4 *int64) ([]*v1beta2.ServiceLog, error)
LeaseLogs provides a mock function with given fields: _a0, _a1, _a2, _a3, _a4
func (*ReadClient) LeaseStatus ¶ added in v0.7.3
func (_m *ReadClient) LeaseStatus(_a0 context.Context, _a1 typesv1beta2.LeaseID) (*v1beta2.LeaseStatus, error)
LeaseStatus provides a mock function with given fields: _a0, _a1
func (*ReadClient) ObserveHostnameState ¶ added in v0.14.0
func (_m *ReadClient) ObserveHostnameState(ctx context.Context) (<-chan v1beta2.HostnameResourceEvent, error)
ObserveHostnameState provides a mock function with given fields: ctx
func (*ReadClient) ServiceStatus ¶ added in v0.7.3
func (_m *ReadClient) ServiceStatus(_a0 context.Context, _a1 typesv1beta2.LeaseID, _a2 string) (*v1beta2.ServiceStatus, error)
ServiceStatus provides a mock function with given fields: _a0, _a1, _a2
type Reservation ¶
Reservation is an autogenerated mock type for the Reservation type
func NewReservation ¶ added in v0.16.2
func NewReservation(t testing.TB) *Reservation
NewReservation creates a new instance of Reservation. It also registers the testing.TB interface on the mock and a cleanup function to assert the mocks expectations.
func (*Reservation) Allocated ¶ added in v0.16.0
func (_m *Reservation) Allocated() bool
Allocated provides a mock function with given fields:
func (*Reservation) OrderID ¶
func (_m *Reservation) OrderID() typesv1beta2.OrderID
OrderID provides a mock function with given fields:
func (*Reservation) Resources ¶ added in v0.3.0
func (_m *Reservation) Resources() akashtypesv1beta2.ResourceGroup
Resources provides a mock function with given fields:
type Service ¶ added in v0.14.0
Service is an autogenerated mock type for the Service type
func NewService ¶ added in v0.16.2
NewService creates a new instance of Service. It also registers the testing.TB interface on the mock and a cleanup function to assert the mocks expectations.
func (*Service) Done ¶ added in v0.14.0
func (_m *Service) Done() <-chan struct{}
Done provides a mock function with given fields:
func (*Service) FindActiveLease ¶ added in v0.14.0
func (_m *Service) FindActiveLease(ctx context.Context, owner types.Address, dseq uint64, gseq uint32) (bool, v1beta2.LeaseID, v2beta1.ManifestGroup, error)
FindActiveLease provides a mock function with given fields: ctx, owner, dseq, gseq
func (*Service) HostnameService ¶ added in v0.14.0
func (_m *Service) HostnameService() typesv1beta2.HostnameServiceClient
HostnameService provides a mock function with given fields:
func (*Service) Ready ¶ added in v0.14.0
func (_m *Service) Ready() <-chan struct{}
Ready provides a mock function with given fields:
func (*Service) Reserve ¶ added in v0.14.0
func (_m *Service) Reserve(_a0 v1beta2.OrderID, _a1 akashtypesv1beta2.ResourceGroup) (typesv1beta2.Reservation, error)
Reserve provides a mock function with given fields: _a0, _a1
func (*Service) TransferHostname ¶ added in v0.14.0
func (_m *Service) TransferHostname(ctx context.Context, leaseID v1beta2.LeaseID, hostname string, serviceName string, externalPort uint32) error
TransferHostname provides a mock function with given fields: ctx, leaseID, hostname, serviceName, externalPort