managers

Jul 31, 2019

Changes in this version

+ 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 interface

+ Ready func() error

+ func NewDockerImageManager(serverAddr string, dockerClient *client.Client, ...) (DockerImageManager, error)

+ type HTTPDockerImageManager struct

+ func (im *HTTPDockerImageManager) Ready() error

+ type RemoteRegistryDockerImageManager struct

+ func (im *RemoteRegistryDockerImageManager) Ready() error