Documentation ¶
Index ¶
- type Client
- func (_m *Client) AllHostnames(_a0 context.Context) ([]cluster.ActiveHostname, error)
- func (_m *Client) ConnectHostnameToDeployment(ctx context.Context, directive cluster.ConnectHostnameToDeploymentDirective) error
- func (_m *Client) DeclareHostname(ctx context.Context, lID types.LeaseID, host string, serviceName string, ...) error
- func (_m *Client) Deploy(ctx context.Context, lID types.LeaseID, mgroup *manifest.Group) error
- func (_m *Client) Deployments(_a0 context.Context) ([]cluster.Deployment, error)
- func (_m *Client) Exec(ctx context.Context, lID types.LeaseID, service string, podIndex uint, ...) (cluster.ExecResult, error)
- func (_m *Client) GetHostnameDeploymentConnections(ctx context.Context) ([]cluster.LeaseIDHostnameConnection, error)
- func (_m *Client) GetManifestGroup(_a0 context.Context, _a1 types.LeaseID) (bool, v1.ManifestGroup, error)
- func (_m *Client) Inventory(_a0 context.Context) ([]cluster.Node, error)
- func (_m *Client) LeaseEvents(_a0 context.Context, _a1 types.LeaseID, _a2 string, _a3 bool) (cluster.EventsWatcher, error)
- func (_m *Client) LeaseLogs(_a0 context.Context, _a1 types.LeaseID, _a2 string, _a3 bool, _a4 *int64) ([]*cluster.ServiceLog, error)
- func (_m *Client) LeaseStatus(_a0 context.Context, _a1 types.LeaseID) (*cluster.LeaseStatus, error)
- func (_m *Client) ObserveHostnameState(ctx context.Context) (<-chan cluster.HostnameResourceEvent, error)
- func (_m *Client) PurgeDeclaredHostname(ctx context.Context, lID types.LeaseID, hostname string) error
- func (_m *Client) PurgeDeclaredHostnames(ctx context.Context, lID types.LeaseID) error
- func (_m *Client) RemoveHostnameFromDeployment(ctx context.Context, hostname string, leaseID types.LeaseID, allowMissing bool) error
- func (_m *Client) ServiceStatus(_a0 context.Context, _a1 types.LeaseID, _a2 string) (*cluster.ServiceStatus, error)
- func (_m *Client) TeardownLease(_a0 context.Context, _a1 types.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 markettypes.LeaseID) error
- func (_m *HostnameServiceClient) ReleaseHostnames(leaseID markettypes.LeaseID) error
- func (_m *HostnameServiceClient) ReserveHostnames(ctx context.Context, hostnames []string, leaseID markettypes.LeaseID) ([]string, error)
- type ReadClient
- func (_m *ReadClient) AllHostnames(_a0 context.Context) ([]cluster.ActiveHostname, error)
- func (_m *ReadClient) GetHostnameDeploymentConnections(ctx context.Context) ([]cluster.LeaseIDHostnameConnection, error)
- func (_m *ReadClient) GetManifestGroup(_a0 context.Context, _a1 types.LeaseID) (bool, v1.ManifestGroup, error)
- func (_m *ReadClient) LeaseEvents(_a0 context.Context, _a1 types.LeaseID, _a2 string, _a3 bool) (cluster.EventsWatcher, error)
- func (_m *ReadClient) LeaseLogs(_a0 context.Context, _a1 types.LeaseID, _a2 string, _a3 bool, _a4 *int64) ([]*cluster.ServiceLog, error)
- func (_m *ReadClient) LeaseStatus(_a0 context.Context, _a1 types.LeaseID) (*cluster.LeaseStatus, error)
- func (_m *ReadClient) ObserveHostnameState(ctx context.Context) (<-chan cluster.HostnameResourceEvent, error)
- func (_m *ReadClient) ServiceStatus(_a0 context.Context, _a1 types.LeaseID, _a2 string) (*cluster.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, markettypes.LeaseID, v1.ManifestGroup, error)
- func (_m *Service) HostnameService() clustertypes.HostnameServiceClient
- func (_m *Service) Ready() <-chan struct{}
- func (_m *Service) Reserve(_a0 markettypes.OrderID, _a1 akashtypes.ResourceGroup) (clustertypes.Reservation, error)
- func (_m *Service) Status(_a0 context.Context) (*clustertypes.Status, error)
- func (_m *Service) TransferHostname(ctx context.Context, leaseID markettypes.LeaseID, hostname string, ...) error
- func (_m *Service) Unreserve(_a0 markettypes.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 (*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 cluster.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 types.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
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 types.LeaseID, service string, podIndex uint, cmd []string, stdin io.Reader, stdout io.Writer, stderr io.Writer, tty bool, tsq remotecommand.TerminalSizeQueue) (cluster.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) ([]cluster.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 types.LeaseID) (bool, v1.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) LeaseEvents ¶ added in v0.10.1
func (_m *Client) LeaseEvents(_a0 context.Context, _a1 types.LeaseID, _a2 string, _a3 bool) (cluster.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 types.LeaseID, _a2 string, _a3 bool, _a4 *int64) ([]*cluster.ServiceLog, error)
LeaseLogs provides a mock function with given fields: _a0, _a1, _a2, _a3, _a4
func (*Client) LeaseStatus ¶ added in v0.2.2
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 cluster.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 types.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 types.LeaseID, allowMissing bool) error
RemoveHostnameFromDeployment provides a mock function with given fields: ctx, hostname, leaseID, allowMissing
type Cluster ¶
Cluster is an autogenerated mock type for the Cluster type
func (*Cluster) Reserve ¶
func (_m *Cluster) Reserve(_a0 types.OrderID, _a1 akashtypes.ResourceGroup) (cluster.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 (*Deployment) LeaseID ¶ added in v0.0.9
func (_m *Deployment) LeaseID() types.LeaseID
LeaseID provides a mock function with given fields:
func (*Deployment) ManifestGroup ¶ added in v0.0.9
func (_m *Deployment) ManifestGroup() manifest.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 (*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 markettypes.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 markettypes.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 markettypes.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 (*ReadClient) AllHostnames ¶ added in v0.14.0
func (_m *ReadClient) AllHostnames(_a0 context.Context) ([]cluster.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) ([]cluster.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 types.LeaseID) (bool, v1.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 types.LeaseID, _a2 string, _a3 bool) (cluster.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 types.LeaseID, _a2 string, _a3 bool, _a4 *int64) ([]*cluster.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 types.LeaseID) (*cluster.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 cluster.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 types.LeaseID, _a2 string) (*cluster.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 (*Reservation) OrderID ¶
func (_m *Reservation) OrderID() types.OrderID
OrderID provides a mock function with given fields:
func (*Reservation) Resources ¶ added in v0.3.0
func (_m *Reservation) Resources() akashtypes.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 (*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, markettypes.LeaseID, v1.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() clustertypes.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 markettypes.OrderID, _a1 akashtypes.ResourceGroup) (clustertypes.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 markettypes.LeaseID, hostname string, serviceName string, externalPort uint32) error
TransferHostname provides a mock function with given fields: ctx, leaseID, hostname, serviceName, externalPort