managers

Documentation

Index

• func AgentReportStatus(clusterId, agentId string, status entities.LightningMonkeyAgentReportStatus) (int64, error)
• func GetClusterCertificates(clusterId string) (entities.LightningMonkeyCertificateCollection, error)
• func NewCluster(cluster *entities.LightningMonkeyClusterSettings) (string, error)
• func QueryAgentNextWorkItem(clusterId, agentId string) (*entities.AgentJob, error)
• func RegisterAgent(agent *entities.LightningMonkeyAgent) (*entities.LightningMonkeyClusterSettings, string, int64, error)
• type DockerImageManager
  • func NewDockerImageManager(serverAddr string, dockerClient *client.Client, ...) (DockerImageManager, error)
• type HTTPDockerImageManager
  • func (im *HTTPDockerImageManager) Ready() error
• type RemoteRegistryDockerImageManager
  • func (im *RemoteRegistryDockerImageManager) Ready() error

Functions

func AgentReportStatus

func AgentReportStatus(clusterId, agentId string, status entities.LightningMonkeyAgentReportStatus) (int64, error)

func GetClusterCertificates

func GetClusterCertificates(clusterId string) (entities.LightningMonkeyCertificateCollection, error)

func NewCluster

func NewCluster(cluster *entities.LightningMonkeyClusterSettings) (string, error)

func QueryAgentNextWorkItem

func QueryAgentNextWorkItem(clusterId, agentId string) (*entities.AgentJob, error)

func RegisterAgent

func RegisterAgent(agent *entities.LightningMonkeyAgent) (*entities.LightningMonkeyClusterSettings, string, int64, error)

Types

type DockerImageManager

type DockerImageManager interface {
	Ready() error
}

func NewDockerImageManager

func NewDockerImageManager(serverAddr string, dockerClient *client.Client, imageCollectionSettings *entities.DockerImageCollection) (DockerImageManager, error)

type HTTPDockerImageManager

type HTTPDockerImageManager struct {
	// contains filtered or unexported fields
}

func (*HTTPDockerImageManager) Ready

func (im *HTTPDockerImageManager) Ready() error

type RemoteRegistryDockerImageManager

type RemoteRegistryDockerImageManager struct {
	// contains filtered or unexported fields
}

func (*RemoteRegistryDockerImageManager) Ready

func (im *RemoteRegistryDockerImageManager) Ready() error