agent

type Agent struct {
	QualifyByTags

	ZkSettings
	DockerSettings

	RegistryContainerEntry

	ListenPort   int `json:"listen_port"`
	DockerUIPort int `json:"dockerui_port"`

	UiDocRoot string `json:"ui_doc_root,omitempty"`
	EnableUI  bool   `json:"enable_ui,omitempty"`

	Initializer *ConfigLoader `json:"config_loader"`

	StatusPubsubTopic string `json:"status_topic,omitempty"`
	// contains filtered or unexported fields
}

type AssignContainerImage func(step int, opts *docker.ContainerControl) (*docker.Image, error)

type AssignContainerName func(step int, template string, opts *docker.ContainerControl) string

type CheckContainer func(*docker.Container) map[ServiceKey]*ContainerMatchRule

type Constraint struct {
	MinInstancesPerHost *int `json:"min_instances_per_host,omitempty"`
	MaxInstancesPerHost *int `json:"max_instances_per_host,omitempty"`
	MinInstancesGlobal  *int `json:"min_instances_global,omitempty"`
	MaxInstancesGlobal  *int `json:"max_instances_global,omitempty"`
}

type ContainerAction struct {
	// Template for naming the container. Variables:  Group, Sequence, Domain, Service, Image
	// If not provided, docker naming will be used.
	ContainerNameTemplate *string `json:"container_name_template,omitempty" dash:"template"`

	docker.ContainerControl
}

type ContainerActionType int

type ContainerGroup struct {
	Image   string
	FsmById map[string]*Fsm
}

type ContainerMatchRule struct {
	MatchContainerRule

	Domain      string
	Service     ServiceKey
	PortMatched bool
}

type ContainerMatchRulesUnion struct {
	ByContainerName        *string           `json:"container_name,omitempty"`
	ByContainerEnvironment []string          `json:"container_envs,omitempty"`
	ByContainerLabels      map[string]string `json:"container_labels,omitempty"`
}

type ContainerState int

type ContainerTracker struct {
	Domain string
	// contains filtered or unexported fields
}

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

type Domain struct {
	Domain string `json:"domain"`

	RegistryContainerEntry

	Config *DomainConfig

	Identity string `json:"id"`
	// contains filtered or unexported fields
}

type DomainConfig struct {
	RegistryContainerEntry

	Services map[ServiceKey]*Scheduler `json:"services,omitempty"`

	Vacuums map[ServiceKey]*VacuumConfig `json:"vacuums,omitempty"`
}

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

type GlobalServiceState interface {
	Image() (path, version, image string, err error)
	Instances() (count int, err error)
}

type Health struct {
	Status        string  `json:"status"`
	UptimeSeconds float64 `json:uptime_seconds,omitempty`
}

type HostContainerStates interface {
	Instances(service ServiceKey, image string) []*Fsm
	CountVersions(service ServiceKey) int
	OldestVersion(service ServiceKey) (image string, instances []*Fsm)
	VisitVersions(func(service ServiceKey, cg *ContainerGroup))
	VisitStartTimes(func(service ServiceKey, c *docker.Container))
}

type HostContainerStatesChanged <-chan HostContainerStates

type Info struct {
	Version     version.Build `json:"version"`
	Now         time.Time     `json:"now"`
	Uptime      time.Duration `json:"uptime,omitempty"`
	Api         string        `json:"api,omitempty"`
	DockerApi   string        `json:"dockerapi,omitempty"`
	DockerUi    string        `json:"dockerui,omitempty"`
	StatusTopic string        `json:"status_topic,omitempty"`
	Environ     []string      `json:"environ,omitempty"`
	Agent       *Agent        `json:"agent"`
}

type MatchContainerRule struct {
	QualifyByTags
	docker.Image
	MatchContainerPort *int                       `json:"match_container_port,omitempty"`
	MatchFirst         []ContainerMatchRulesUnion `json:"match_first,omitempty"`
	MatchAll           []ContainerMatchRulesUnion `json:"mathc_all,omitempty"`
	// contains filtered or unexported fields
}

type MinStartTimeHeap []*docker.Container

type MinVersionHeap []*ContainerGroup

type OnMatch func(*docker.Container, *ContainerMatchRule)

type RunOnceSchedule struct {
	Trigger string `json:"trigger"`
}

type ScheduleExecutor struct {
	Inbox chan<- []Task
	Stop  chan<- bool
	// contains filtered or unexported fields
}

type Scheduler struct {
	QualifyByTags

	Task

	Register    *MatchContainerRule `json:"register,omitempty"`
	TriggerPath *Trigger            `json:"trigger_path,omitempty"`

	Constraint *Constraint      `json:"constraint,omitempty"`
	RunOnce    *RunOnceSchedule `json:"run_once,omitemtpy"`
	// contains filtered or unexported fields
}

type SchedulerExecutor chan<- []Task

type Task struct {

	// Registry path where the image to use is stored.
	ImagePath string `json:"image_path,omitempty"`

	// Max attempts at starting a container -- 0 means no bounds
	MaxAttempts int `json:"max_attempts,omitempty"`

	// Optional - Side effects if run multiple times?
	Idempotent bool `json:"idempotent,omitempty"`

	// Path where Docker auth info can be found in the registry.
	// The value at this path is expected to a json struct for AuthConfiguration
	// http://godoc.org/github.com/fsouza/go-dockerclient#AuthConfiguration
	DockerAuthInfoPath string               `json:"auth_info_path"`
	AuthIdentity       *docker.AuthIdentity `json:"auth"`
	Actions            []ContainerAction    `json:"actions,omitempty"`
	// contains filtered or unexported fields
}

type TlsHandler struct {
	Cert string
	Key  string
	Ca   string
	// contains filtered or unexported fields
}

type Trigger string

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

type Vacuum struct {
	Domain  string
	Service ServiceKey
	Config  VacuumConfig
	Stop    VacuumStop
	// contains filtered or unexported fields
}

type VacuumByStartTime struct {
}

type VacuumByVersions struct {
	VersionsToKeep int `json:"versions_to_keep"`
}

type VacuumConfig struct {
	QualifyByTags

	RemoveImage        bool   `json:"remove_image,omitempty"`
	ExportContainer    bool   `json:"export_container,omitempty"`
	ExportDestination  string `json:"exoprt_destination,omitempty"`
	RunIntervalSeconds uint32 `json:"run_interval_seconds,omitempty"`

	// Option when by version
	ByVersion *VacuumByVersions `json:"by_version,omitempty"`

	// Option when by start time
	ByStartTime *VacuumByStartTime `json:"by_start_time,omitempty"`
	// contains filtered or unexported fields
}

type VacuumStop chan<- bool

type VersionComparator func(imageA, imageB string) bool