registry

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

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

type Registry interface {
	GetEtcdAddrs() string
	// Check whether tiadmin registry is bootstrapped normally
	IsBootstrapped(*config.Config) bool
	// Initialize the basic directory structure of tiadmin registry
	Bootstrap() error
	// Get Infomation of machine in cluster by the given machID
	Machine(machID string) (*machine.MachineStatus, error)
	// Retrieve all machines in Ti-Cluster,
	// return a map of machID to machineStatus
	Machines() (map[string]*machine.MachineStatus, error)
	// Create new machine node in etcd
	RegisterMachine(machID, hostName, hostRegion, hostIDC, publicIP string) error
	// Update statistic info of machine and refresh the TTL of alive state in etcd
	RefreshMachine(machID string, machStat machine.MachineStat, ttl time.Duration) error
	// Return the status of process with specified procID
	Process(procID string) (*proc.ProcessStatus, error)
	// Retrieve all processes in Ti-Cluster,
	// with either running or stopped state
	// return a map of procID to processStatus
	Processes() (map[string]*proc.ProcessStatus, error)
	// Retrieve processes which scheduled at the specified host by given machID
	// return a map of procID to status infomation of process
	ProcessesOnMachine(machID string) (map[string]*proc.ProcessStatus, error)
	// Retrieve all processes instantiated from the specified service
	// return a map of procID to status infomation of process
	ProcessesOfService(svcName string) (map[string]*proc.ProcessStatus, error)
	// Create new process node of specified service in etcd
	NewProcess(machID, svcName string, hostIP, hostName, hostRegion, hostIDC string,
		executor []string, command string, args []string, env map[string]string, endpoints map[string]pkg.Endpoint) error
	// Destroy the process, normally the process should be in stopped state
	DeleteProcess(procID string) (*proc.ProcessStatus, error)
	// Update process desirede state in etcd
	UpdateProcessDesiredState(procID string, state proc.ProcessState) error
	// Update process current state in etcd, notice that isAlive is real run state of the local process
	UpdateProcessState(procID, machID, svcName string, state proc.ProcessState, isAlive bool, ttl time.Duration) error
}