mocks

package
v0.0.0-...-1c5d739 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 14, 2023 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FacadeInterface 

type FacadeInterface struct {
	mock.Mock
}

FacadeInterface is an autogenerated mock type for the FacadeInterface type

func (*FacadeInterface) AddHost 

func (_m *FacadeInterface) AddHost(ctx datastore.Context, entity *host.Host) ([]byte, error)

AddHost provides a mock function with given fields: ctx, entity

func (*FacadeInterface) AddHostPrivate 

func (_m *FacadeInterface) AddHostPrivate(ctx datastore.Context, entity *host.Host) ([]byte, error)

AddHostPrivate provides a mock function with given fields: ctx, entity

func (*FacadeInterface) AddPublicEndpointPort 

func (_m *FacadeInterface) AddPublicEndpointPort(ctx datastore.Context, serviceid string, endpointName string, portAddr string, usetls bool, protocol string, isEnabled bool, restart bool) (*servicedefinition.Port, error)

AddPublicEndpointPort provides a mock function with given fields: ctx, serviceid, endpointName, portAddr, usetls, protocol, isEnabled, restart

func (*FacadeInterface) AddPublicEndpointVHost 

func (_m *FacadeInterface) AddPublicEndpointVHost(ctx datastore.Context, serviceid string, endpointName string, vhost string, isEnabled bool, restart bool) (*servicedefinition.VHost, error)

AddPublicEndpointVHost provides a mock function with given fields: ctx, serviceid, endpointName, vhost, isEnabled, restart

func (*FacadeInterface) AddResourcePool 

func (_m *FacadeInterface) AddResourcePool(ctx datastore.Context, entity *pool.ResourcePool) error

AddResourcePool provides a mock function with given fields: ctx, entity

func (*FacadeInterface) AddService 

func (_m *FacadeInterface) AddService(ctx datastore.Context, svc service.Service) error

AddService provides a mock function with given fields: ctx, svc

func (*FacadeInterface) AddServiceConfig 

func (_m *FacadeInterface) AddServiceConfig(ctx datastore.Context, serviceID string, conf servicedefinition.ConfigFile) error

AddServiceConfig provides a mock function with given fields: ctx, serviceID, conf

func (*FacadeInterface) AddServiceTemplate 

func (_m *FacadeInterface) AddServiceTemplate(ctx datastore.Context, serviceTemplate servicetemplate.ServiceTemplate, reloadLogstashConfig bool) (string, error)

AddServiceTemplate provides a mock function with given fields: ctx, serviceTemplate, reloadLogstashConfig

func (*FacadeInterface) AddUser 

func (_m *FacadeInterface) AddUser(ctx datastore.Context, newUser user.User) error

AddUser provides a mock function with given fields: ctx, newUser

func (*FacadeInterface) AssignIPs 

func (_m *FacadeInterface) AssignIPs(ctx datastore.Context, assignmentRequest addressassignment.AssignmentRequest) error

AssignIPs provides a mock function with given fields: ctx, assignmentRequest

func (*FacadeInterface) ClearEmergencyStopFlag 

func (_m *FacadeInterface) ClearEmergencyStopFlag(ctx datastore.Context, serviceID string) (int, error)

ClearEmergencyStopFlag provides a mock function with given fields: ctx, serviceID

func (*FacadeInterface) CountDescendantStates 

func (_m *FacadeInterface) CountDescendantStates(ctx datastore.Context, serviceID string) (map[string]map[string]int, error)

CountDescendantStates provides a mock function with given fields: ctx, serviceID

func (*FacadeInterface) DeleteServiceConfig 

func (_m *FacadeInterface) DeleteServiceConfig(ctx datastore.Context, fileID string) error

DeleteServiceConfig provides a mock function with given fields: ctx, fileID

func (*FacadeInterface) DeployTemplate 

func (_m *FacadeInterface) DeployTemplate(ctx datastore.Context, poolID string, templateID string, deploymentID string) ([]string, error)

DeployTemplate provides a mock function with given fields: ctx, poolID, templateID, deploymentID

func (*FacadeInterface) DeployTemplateActive 

func (_m *FacadeInterface) DeployTemplateActive() ([]map[string]string, error)

DeployTemplateActive provides a mock function with given fields:

func (*FacadeInterface) DeployTemplateStatus 

func (_m *FacadeInterface) DeployTemplateStatus(deploymentID string, lastStatus string, timeout time.Duration) (string, error)

DeployTemplateStatus provides a mock function with given fields: deploymentID, lastStatus, timeout

func (*FacadeInterface) EmergencyStopService 

func (_m *FacadeInterface) EmergencyStopService(ctx datastore.Context, request dao.ScheduleServiceRequest) (int, error)

EmergencyStopService provides a mock function with given fields: ctx, request

func (*FacadeInterface) EnablePublicEndpointPort 

func (_m *FacadeInterface) EnablePublicEndpointPort(ctx datastore.Context, serviceid string, endpointName string, portAddr string, isEnabled bool) error

EnablePublicEndpointPort provides a mock function with given fields: ctx, serviceid, endpointName, portAddr, isEnabled

func (*FacadeInterface) EnablePublicEndpointVHost 

func (_m *FacadeInterface) EnablePublicEndpointVHost(ctx datastore.Context, serviceid string, endpointName string, vhost string, isEnabled bool) error

EnablePublicEndpointVHost provides a mock function with given fields: ctx, serviceid, endpointName, vhost, isEnabled

func (*FacadeInterface) FindHostsInPool 

func (_m *FacadeInterface) FindHostsInPool(ctx datastore.Context, poolID string) ([]host.Host, error)

FindHostsInPool provides a mock function with given fields: ctx, poolID

func (*FacadeInterface) FindReadHostsInPool 

func (_m *FacadeInterface) FindReadHostsInPool(ctx datastore.Context, poolID string) ([]host.ReadHost, error)

FindReadHostsInPool provides a mock function with given fields: ctx, poolID

func (*FacadeInterface) GetActiveHostIDs 

func (_m *FacadeInterface) GetActiveHostIDs(ctx datastore.Context) ([]string, error)

GetActiveHostIDs provides a mock function with given fields: ctx

func (*FacadeInterface) GetAggregateServices 

func (_m *FacadeInterface) GetAggregateServices(ctx datastore.Context, since time.Time, serviceids []string) ([]service.AggregateService, error)

GetAggregateServices provides a mock function with given fields: ctx, since, serviceids

func (*FacadeInterface) GetAllPublicEndpoints 

func (_m *FacadeInterface) GetAllPublicEndpoints(ctx datastore.Context) ([]service.PublicEndpoint, error)

GetAllPublicEndpoints provides a mock function with given fields: ctx

func (*FacadeInterface) GetEvaluatedService 

func (_m *FacadeInterface) GetEvaluatedService(ctx datastore.Context, servicedID string, instanceID int) (*service.Service, error)

GetEvaluatedService provides a mock function with given fields: ctx, servicedID, instanceID

func (*FacadeInterface) GetHealthChecksForService 

func (_m *FacadeInterface) GetHealthChecksForService(ctx datastore.Context, id string) (map[string]health.HealthCheck, error)

GetHealthChecksForService provides a mock function with given fields: ctx, id

func (*FacadeInterface) GetHost 

func (_m *FacadeInterface) GetHost(ctx datastore.Context, hostID string) (*host.Host, error)

GetHost provides a mock function with given fields: ctx, hostID

func (*FacadeInterface) GetHostInstances 

func (_m *FacadeInterface) GetHostInstances(ctx datastore.Context, since time.Time, hostid string) ([]service.Instance, error)

GetHostInstances provides a mock function with given fields: ctx, since, hostid

func (*FacadeInterface) GetHostKey 

func (_m *FacadeInterface) GetHostKey(ctx datastore.Context, hostID string) ([]byte, error)

GetHostKey provides a mock function with given fields: ctx, hostID

func (*FacadeInterface) GetHostStatuses 

func (_m *FacadeInterface) GetHostStatuses(ctx datastore.Context, hostIDs []string, since time.Time) ([]host.HostStatus, error)

GetHostStatuses provides a mock function with given fields: ctx, hostIDs, since

func (*FacadeInterface) GetHosts 

func (_m *FacadeInterface) GetHosts(ctx datastore.Context) ([]host.Host, error)

GetHosts provides a mock function with given fields: ctx

func (*FacadeInterface) GetPoolIPs 

func (_m *FacadeInterface) GetPoolIPs(ctx datastore.Context, poolID string) (*pool.PoolIPs, error)

GetPoolIPs provides a mock function with given fields: ctx, poolID

func (*FacadeInterface) GetReadHosts 

func (_m *FacadeInterface) GetReadHosts(ctx datastore.Context) ([]host.ReadHost, error)

GetReadHosts provides a mock function with given fields: ctx

func (*FacadeInterface) GetReadPools 

func (_m *FacadeInterface) GetReadPools(ctx datastore.Context) ([]pool.ReadPool, error)

GetReadPools provides a mock function with given fields: ctx

func (*FacadeInterface) GetResourcePool 

func (_m *FacadeInterface) GetResourcePool(ctx datastore.Context, poolID string) (*pool.ResourcePool, error)

GetResourcePool provides a mock function with given fields: ctx, poolID

func (*FacadeInterface) GetResourcePools 

func (_m *FacadeInterface) GetResourcePools(ctx datastore.Context) ([]pool.ResourcePool, error)

GetResourcePools provides a mock function with given fields: ctx

func (*FacadeInterface) GetService 

func (_m *FacadeInterface) GetService(ctx datastore.Context, id string) (*service.Service, error)

GetService provides a mock function with given fields: ctx, id

func (*FacadeInterface) GetServiceAddressAssignmentDetails 

func (_m *FacadeInterface) GetServiceAddressAssignmentDetails(ctx datastore.Context, serviceID string, children bool) ([]service.IPAssignment, error)

GetServiceAddressAssignmentDetails provides a mock function with given fields: ctx, serviceID, children

func (*FacadeInterface) GetServiceConfig 

func (_m *FacadeInterface) GetServiceConfig(ctx datastore.Context, fileID string) (*servicedefinition.ConfigFile, error)

GetServiceConfig provides a mock function with given fields: ctx, fileID

func (*FacadeInterface) GetServiceConfigs 

func (_m *FacadeInterface) GetServiceConfigs(ctx datastore.Context, serviceID string) ([]service.Config, error)

GetServiceConfigs provides a mock function with given fields: ctx, serviceID

func (*FacadeInterface) GetServiceDetails 

func (_m *FacadeInterface) GetServiceDetails(ctx datastore.Context, serviceID string) (*service.ServiceDetails, error)

GetServiceDetails provides a mock function with given fields: ctx, serviceID

func (*FacadeInterface) GetServiceDetailsAncestry 

func (_m *FacadeInterface) GetServiceDetailsAncestry(ctx datastore.Context, serviceID string) (*service.ServiceDetails, error)

GetServiceDetailsAncestry provides a mock function with given fields: ctx, serviceID

func (*FacadeInterface) GetServiceDetailsByParentID 

func (_m *FacadeInterface) GetServiceDetailsByParentID(ctx datastore.Context, serviceID string, since time.Duration) ([]service.ServiceDetails, error)

GetServiceDetailsByParentID provides a mock function with given fields: ctx, serviceID, since

func (*FacadeInterface) GetServiceDetailsByTenantID 

func (_m *FacadeInterface) GetServiceDetailsByTenantID(ctx datastore.Context, tenantID string) ([]service.ServiceDetails, error)

GetServiceDetailsByTenantID provides a mock function with given fields: ctx, tenantID

func (*FacadeInterface) GetServiceExportedEndpoints 

func (_m *FacadeInterface) GetServiceExportedEndpoints(ctx datastore.Context, serviceID string, children bool) ([]service.ExportedEndpoint, error)

GetServiceExportedEndpoints provides a mock function with given fields: ctx, serviceID, children

func (*FacadeInterface) GetServiceInstances 

func (_m *FacadeInterface) GetServiceInstances(ctx datastore.Context, since time.Time, serviceid string) ([]service.Instance, error)

GetServiceInstances provides a mock function with given fields: ctx, since, serviceid

func (*FacadeInterface) GetServiceMonitoringProfile 

func (_m *FacadeInterface) GetServiceMonitoringProfile(ctx datastore.Context, serviceID string) (*domain.MonitorProfile, error)

GetServiceMonitoringProfile provides a mock function with given fields: ctx, serviceID

func (*FacadeInterface) GetServiceNamePath 

func (_m *FacadeInterface) GetServiceNamePath(ctx datastore.Context, serviceID string) (string, string, error)

func (*FacadeInterface) GetServicePublicEndpoints 

func (_m *FacadeInterface) GetServicePublicEndpoints(ctx datastore.Context, serviceID string, children bool) ([]service.PublicEndpoint, error)

GetServicePublicEndpoints provides a mock function with given fields: ctx, serviceID, children

func (*FacadeInterface) GetServiceTemplates 

func (_m *FacadeInterface) GetServiceTemplates(ctx datastore.Context) (map[string]servicetemplate.ServiceTemplate, error)

GetServiceTemplates provides a mock function with given fields: ctx

func (*FacadeInterface) GetServices 

func (_m *FacadeInterface) GetServices(ctx datastore.Context, request dao.EntityRequest) ([]service.Service, error)

GetServices provides a mock function with given fields: ctx, request

func (*FacadeInterface) GetServicesHealth 

func (_m *FacadeInterface) GetServicesHealth(ctx datastore.Context) (map[string]map[int]map[string]health.HealthStatus, error)

GetServicesHealth provides a mock function with given fields: ctx

func (*FacadeInterface) GetSystemUser 

func (_m *FacadeInterface) GetSystemUser(ctx datastore.Context) (user.User, error)

GetSystemUser provides a mock function with given fields: ctx

func (*FacadeInterface) GetTaggedServices 

func (_m *FacadeInterface) GetTaggedServices(ctx datastore.Context, request dao.EntityRequest) ([]service.Service, error)

GetTaggedServices provides a mock function with given fields: ctx, request

func (*FacadeInterface) GetTenantID 

func (_m *FacadeInterface) GetTenantID(ctx datastore.Context, serviceID string) (string, error)

GetTenantID provides a mock function with given fields: ctx, serviceID

func (*FacadeInterface) GetUser 

func (_m *FacadeInterface) GetUser(ctx datastore.Context, userName string) (user.User, error)

GetUser provides a mock function with given fields: ctx, userName

func (*FacadeInterface) HasIP 

func (_m *FacadeInterface) HasIP(ctx datastore.Context, poolID string, ipAddr string) (bool, error)

HasIP provides a mock function with given fields: ctx, poolID, ipAddr

func (*FacadeInterface) HostIsAuthenticated 

func (_m *FacadeInterface) HostIsAuthenticated(ctx datastore.Context, hostid string) (bool, error)

HostIsAuthenticated provides a mock function with given fields: ctx, hostid

func (*FacadeInterface) ListTenants 

func (_m *FacadeInterface) ListTenants(_a0 datastore.Context) ([]string, error)

ListTenants provides a mock function with given fields: _a0

func (*FacadeInterface) MigrateServices 

func (_m *FacadeInterface) MigrateServices(ctx datastore.Context, request dao.ServiceMigrationRequest) error

MigrateServices provides a mock function with given fields: ctx, request

func (*FacadeInterface) PauseService 

func (_m *FacadeInterface) PauseService(ctx datastore.Context, request dao.ScheduleServiceRequest) (int, error)

PauseService provides a mock function with given fields: ctx, ScheduleServiceRequest

func (*FacadeInterface) PredictStorageAvailability 

func (_m *FacadeInterface) PredictStorageAvailability(ctx datastore.Context, lookahead time.Duration) (map[string]float64, error)

PredictStorageAvailability provides a mock function with given fields: ctx, lookahead

func (*FacadeInterface) QueryServiceDetails 

func (_m *FacadeInterface) QueryServiceDetails(ctx datastore.Context, query service.Query) ([]service.ServiceDetails, error)

func (*FacadeInterface) RegisterHostKeys 

func (_m *FacadeInterface) RegisterHostKeys(ctx datastore.Context, entity *host.Host, nat utils.URL, keys []byte, prompt bool) error

RegisterHostKeys provides a mock function with given fields: ctx, entity, keys, prompt

func (*FacadeInterface) ReloadLogstashConfig 

func (_m *FacadeInterface) ReloadLogstashConfig(ctx datastore.Context) error

ReloadLogstashConfig provides a mock function with given fields: ctx

func (*FacadeInterface) RemoveHost 

func (_m *FacadeInterface) RemoveHost(ctx datastore.Context, hostID string) error

RemoveHost provides a mock function with given fields: ctx, hostID

func (*FacadeInterface) RemoveHostExpiration 

func (_m *FacadeInterface) RemoveHostExpiration(ctx datastore.Context, hostID string)

RemoveHostExpiration provides a mock function with given fields: ctx, hostID

func (*FacadeInterface) RemoveIPs 

func (_m *FacadeInterface) RemoveIPs(ctx datastore.Context, args []string) error

RemoveIPs provides a mock function with given fields: ctx, []string

func (*FacadeInterface) RemovePublicEndpointPort 

func (_m *FacadeInterface) RemovePublicEndpointPort(ctx datastore.Context, serviceid string, endpointName string, portAddr string) error

RemovePublicEndpointPort provides a mock function with given fields: ctx, serviceid, endpointName, portAddr

func (*FacadeInterface) RemovePublicEndpointVHost 

func (_m *FacadeInterface) RemovePublicEndpointVHost(ctx datastore.Context, serviceid string, endpointName string, vhost string) error

RemovePublicEndpointVHost provides a mock function with given fields: ctx, serviceid, endpointName, vhost

func (*FacadeInterface) RemoveResourcePool 

func (_m *FacadeInterface) RemoveResourcePool(ctx datastore.Context, id string) error

RemoveResourcePool provides a mock function with given fields: ctx, id

func (*FacadeInterface) RemoveService 

func (_m *FacadeInterface) RemoveService(ctx datastore.Context, id string) error

RemoveService provides a mock function with given fields: ctx, id

func (*FacadeInterface) RemoveServiceTemplate 

func (_m *FacadeInterface) RemoveServiceTemplate(ctx datastore.Context, templateID string) error

RemoveServiceTemplate provides a mock function with given fields: ctx, templateID

func (*FacadeInterface) RemoveUser 

func (_m *FacadeInterface) RemoveUser(ctx datastore.Context, userName string) error

RemoveUser provides a mock function with given fields: ctx, userName

func (*FacadeInterface) ReportHealthStatus 

func (_m *FacadeInterface) ReportHealthStatus(key health.HealthStatusKey, value health.HealthStatus, expires time.Duration)

ReportHealthStatus provides a mock function with given fields: key, value, expires

func (*FacadeInterface) ReportInstanceDead 

func (_m *FacadeInterface) ReportInstanceDead(serviceID string, instanceID int)

ReportInstanceDead provides a mock function with given fields: serviceID, instanceID

func (*FacadeInterface) ResetHostKey 

func (_m *FacadeInterface) ResetHostKey(ctx datastore.Context, hostID string) ([]byte, error)

ResetHostKey provides a mock function with given fields: ctx, hostID

func (*FacadeInterface) RestartService 

func (_m *FacadeInterface) RestartService(ctx datastore.Context, request dao.ScheduleServiceRequest) (int, error)

RestartService provides a mock function with given fields: ctx, ScheduleServiceRequest

func (*FacadeInterface) ScheduleServices 

func (_m *FacadeInterface) ScheduleServices(ctx datastore.Context, serviceIDs []string, autoLaunch bool, synchronous bool, desiredState service.DesiredState, emergency bool) (int, error)

ScheduleService provides a mock function with given fields: ctx, serviceID, autoLaunch, synchronous, desiredState

func (*FacadeInterface) SetHostExpiration 

func (_m *FacadeInterface) SetHostExpiration(ctx datastore.Context, hostID string, expiration int64)

SetHostExpiration provides a mock function with given fields: ctx, hostID, expiration

func (*FacadeInterface) SetIPs 

func (_m *FacadeInterface) SetIPs(ctx datastore.Context, assignmentRequest addressassignment.AssignmentRequest) error

SetIPs provides a mock function with given fields: ctx, assignmentRequest

func (*FacadeInterface) StartService 

func (_m *FacadeInterface) StartService(ctx datastore.Context, request dao.ScheduleServiceRequest) (int, error)

StartService provides a mock function with given fields: ctx, ScheduleServiceRequest

func (*FacadeInterface) StopService 

func (_m *FacadeInterface) StopService(ctx datastore.Context, request dao.ScheduleServiceRequest) (int, error)

StopService provides a mock function with given fields: ctx, ScheduleServiceRequest

func (*FacadeInterface) SyncServiceRegistry 

func (_m *FacadeInterface) SyncServiceRegistry(ctx datastore.Context, svc *service.Service) error

SyncServiceRegistry provides a mock function with given fields: ctx, svc

func (*FacadeInterface) UpdateHost 

func (_m *FacadeInterface) UpdateHost(ctx datastore.Context, entity *host.Host) error

UpdateHost provides a mock function with given fields: ctx, entity

func (*FacadeInterface) UpdateResourcePool 

func (_m *FacadeInterface) UpdateResourcePool(ctx datastore.Context, entity *pool.ResourcePool) error

UpdateResourcePool provides a mock function with given fields: ctx, entity

func (*FacadeInterface) UpdateService 

func (_m *FacadeInterface) UpdateService(ctx datastore.Context, svc service.Service) error

UpdateService provides a mock function with given fields: ctx, svc

func (*FacadeInterface) UpdateServiceCache 

func (_m *FacadeInterface) UpdateServiceCache(ctx datastore.Context) error

UpdateServiceCache provides a mock function with given fields: ctx

func (*FacadeInterface) UpdateServiceConfig 

func (_m *FacadeInterface) UpdateServiceConfig(ctx datastore.Context, fileID string, conf servicedefinition.ConfigFile) error

UpdateServiceConfig provides a mock function with given fields: ctx, fileID, conf

func (*FacadeInterface) UpdateServiceTemplate 

func (_m *FacadeInterface) UpdateServiceTemplate(ctx datastore.Context, template servicetemplate.ServiceTemplate, reloadLogstashConfig bool) error

UpdateServiceTemplate provides a mock function with given fields: ctx, template, reloadLogstashConfig

func (*FacadeInterface) UpdateUser 

func (_m *FacadeInterface) UpdateUser(ctx datastore.Context, u user.User) error

UpdateUser provides a mock function with given fields: ctx, u

func (*FacadeInterface) ValidateCredentials 

func (_m *FacadeInterface) ValidateCredentials(ctx datastore.Context, u user.User) (bool, error)

ValidateCredentials provides a mock function with given fields: ctx, u

func (*FacadeInterface) WaitService 

func (_m *FacadeInterface) WaitService(ctx datastore.Context, dstate service.DesiredState, timeout time.Duration, recursive bool, serviceIDs ...string) error

WaitService provides a mock function with given fields: ctx, dstate, timeout, recursive, serviceIDs

type MetricsClient 

type MetricsClient struct {
	mock.Mock
}

MetricsClient is an autogenerated mock type for the MetricsClient type

func (*MetricsClient) GetAvailableStorage 

func (_m *MetricsClient) GetAvailableStorage(_a0 time.Duration, _a1 string, _a2 ...string) (*metrics.StorageMetrics, error)

GetAvailableStorage provides a mock function with given fields: _a0, _a1, _a2

func (*MetricsClient) GetInstanceMemoryStats 

func (_m *MetricsClient) GetInstanceMemoryStats(_a0 time.Time, _a1 ...metrics.ServiceInstance) ([]metrics.MemoryUsageStats, error)

GetInstanceMemoryStats provides a mock function with given fields: _a0, _a1

type ZZK 

type ZZK struct {
	mock.Mock
}

func (*ZZK) AddHost 

func (_m *ZZK) AddHost(_host *host.Host) error

func (*ZZK) AddVirtualIP 

func (_m *ZZK) AddVirtualIP(vip *pool.VirtualIP) error

func (*ZZK) DeleteRegistryImage 

func (_m *ZZK) DeleteRegistryImage(id string) error

func (*ZZK) DeleteRegistryLibrary 

func (_m *ZZK) DeleteRegistryLibrary(tenantID string) error

func (*ZZK) GetActiveHosts 

func (_m *ZZK) GetActiveHosts(ctx datastore.Context, poolID string, hosts *[]string) error

func (*ZZK) GetHostStates 

func (_m *ZZK) GetHostStates(ctx datastore.Context, poolID string, hostID string) ([]zkservice.State, error)

func (*ZZK) GetPublicPort 

func (_m *ZZK) GetPublicPort(portAddress string) (string, string, error)

func (*ZZK) GetRegistryImage 

func (_m *ZZK) GetRegistryImage(id string) (*registry.Image, error)

func (*ZZK) GetServiceNodes 

func (_m *ZZK) GetServiceNodes() ([]zkservice.ServiceNode, error)

func (*ZZK) GetServiceState 

func (_m *ZZK) GetServiceState(ctx datastore.Context, poolID string, serviceID string, instanceID int) (*zkservice.State, error)

func (*ZZK) GetServiceStateIDs 

func (_m *ZZK) GetServiceStateIDs(poolID string, serviceID string) ([]zkservice.StateRequest, error)

func (*ZZK) GetServiceStates 

func (_m *ZZK) GetServiceStates(ctx datastore.Context, poolID string, serviceID string) ([]zkservice.State, error)

func (*ZZK) GetVHost 

func (_m *ZZK) GetVHost(subdomain string) (string, string, error)

func (*ZZK) GetVirtualIPHostID 

func (_m *ZZK) GetVirtualIPHostID(poolID string, ip string) (string, error)

func (*ZZK) IsHostActive 

func (_m *ZZK) IsHostActive(poolID string, hostId string) (bool, error)

func (*ZZK) LockServices 

func (_m *ZZK) LockServices(ctx datastore.Context, svcs []service.ServiceDetails) error

func (*ZZK) RegisterDfsClients 

func (_m *ZZK) RegisterDfsClients(clients ...host.Host) error

func (*ZZK) RemoveHost 

func (_m *ZZK) RemoveHost(_host *host.Host) error

func (*ZZK) RemoveResourcePool 

func (_m *ZZK) RemoveResourcePool(poolID string) error

func (*ZZK) RemoveService 

func (_m *ZZK) RemoveService(poolID string, serviceID string) error

func (*ZZK) RemoveServiceEndpoints 

func (_m *ZZK) RemoveServiceEndpoints(serviceID string) error

func (*ZZK) RemoveTenantExports 

func (_m *ZZK) RemoveTenantExports(tenantID string) error

func (*ZZK) RemoveVirtualIP 

func (_m *ZZK) RemoveVirtualIP(vip *pool.VirtualIP) error

func (*ZZK) RestartInstance 

func (_m *ZZK) RestartInstance(ctx datastore.Context, poolID string, serviceID string, instanceID int) error

func (*ZZK) SendDockerAction 

func (_m *ZZK) SendDockerAction(poolID string, serviceID string, instanceID int, command string, args []string) error

func (*ZZK) SetRegistryImage 

func (_m *ZZK) SetRegistryImage(rImage *registry.Image) error

func (*ZZK) StopServiceInstance 

func (_m *ZZK) StopServiceInstance(poolID string, serviceID string, instanceID int) error

func (*ZZK) StopServiceInstances 

func (_m *ZZK) StopServiceInstances(ctx datastore.Context, poolID string, serviceID string) error

func (*ZZK) SyncServiceRegistry 

func (_m *ZZK) SyncServiceRegistry(ctx datastore.Context, tenantID string, svc *service.Service) error

func (*ZZK) UnlockServices 

func (_m *ZZK) UnlockServices(ctx datastore.Context, svcs []service.ServiceDetails) error

func (*ZZK) UnregisterDfsClients 

func (_m *ZZK) UnregisterDfsClients(clients ...host.Host) error

func (*ZZK) UpdateHost 

func (_m *ZZK) UpdateHost(_host *host.Host) error

func (*ZZK) UpdateInstanceCurrentState 

func (_m *ZZK) UpdateInstanceCurrentState(ctx datastore.Context, poolID, serviceID string, instanceID int, state service.InstanceCurrentState) error

func (*ZZK) UpdateResourcePool 

func (_m *ZZK) UpdateResourcePool(_pool *pool.ResourcePool) error

func (*ZZK) UpdateService 

func (_m *ZZK) UpdateService(ctx datastore.Context, tenantID string, svc *service.Service, setLockOnCreate bool, setLockOnUpdate bool) error

func (*ZZK) UpdateServices 

func (_m *ZZK) UpdateServices(ctx datastore.Context, tenantID string, svcs []*service.Service, setLockOnCreate bool, setLockOnUpdate bool) error

func (*ZZK) WaitInstance 

func (_m *ZZK) WaitInstance(ctx datastore.Context, svc *service.Service, instanceID int, checkInstance func(*zkservice.State, bool) bool, cancel <-chan struct{}) error

func (*ZZK) WaitService 

func (_m *ZZK) WaitService(svc *service.Service, state service.DesiredState, cancel <-chan interface{}) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.