Versions in this module Expand all Collapse all v1 v1.0.0 Dec 22, 2016 Changes in this version + var DebugInmemoryRegistry bool = false + var DebugRPCRegistry bool = false + func NewRPCServer(reg registry.Registry, addr string) (*rpcserver, error) + type RPCRegistry struct + func NewRPCRegistry(dialer func(string, time.Duration) (net.Conn, error)) *RPCRegistry + func (r *RPCRegistry) ClearUnitHeartbeat(unitName string) + func (r *RPCRegistry) Close() + func (r *RPCRegistry) Connect() + func (r *RPCRegistry) CreateMachineState(ms machine.MachineState, ttl time.Duration) (uint64, error) + func (r *RPCRegistry) CreateUnit(j *job.Unit) error + func (r *RPCRegistry) DeleteMachineMetadata(machID string, key string) error + func (r *RPCRegistry) DestroyUnit(unitName string) error + func (r *RPCRegistry) EngineVersion() (int, error) + func (r *RPCRegistry) IsRegistryReady() bool + func (r *RPCRegistry) LatestDaemonVersion() (*semver.Version, error) + func (r *RPCRegistry) MachineState(machID string) (machine.MachineState, error) + func (r *RPCRegistry) Machines() ([]machine.MachineState, error) + func (r *RPCRegistry) RemoveMachineState(machID string) error + func (r *RPCRegistry) RemoveUnitState(unitName string) error + func (r *RPCRegistry) SaveUnitState(unitName string, unitState *unit.UnitState, ttl time.Duration) + func (r *RPCRegistry) Schedule() ([]job.ScheduledUnit, error) + func (r *RPCRegistry) ScheduleUnit(unitName, machID string) error + func (r *RPCRegistry) ScheduledUnit(unitName string) (*job.ScheduledUnit, error) + func (r *RPCRegistry) SetMachineMetadata(machID string, key string, value string) error + func (r *RPCRegistry) SetMachineState(ms machine.MachineState, ttl time.Duration) (uint64, error) + func (r *RPCRegistry) SetUnitTargetState(unitName string, state job.JobState) error + func (r *RPCRegistry) Status() (pb.HealthCheckResponse_ServingStatus, error) + func (r *RPCRegistry) Unit(unitName string) (*job.Unit, error) + func (r *RPCRegistry) UnitHeartbeat(unitName, machID string, ttl time.Duration) error + func (r *RPCRegistry) UnitState(unitName string) (*unit.UnitState, error) + func (r *RPCRegistry) UnitStates() ([]*unit.UnitState, error) + func (r *RPCRegistry) Units() ([]job.Unit, error) + func (r *RPCRegistry) UnscheduleUnit(unitName, machID string) error + func (r *RPCRegistry) UpdateEngineVersion(from, to int) error + func (r *RPCRegistry) UseEtcdRegistry() bool + type RegistryMux struct + func NewRegistryMux(etcdRegistry *registry.EtcdRegistry, localMachine machine.Machine, ...) *RegistryMux + func (r *RegistryMux) ClearUnitHeartbeat(name string) + func (r *RegistryMux) ConnectToRegistry(e *engine.Engine) + func (r *RegistryMux) CreateMachineState(ms machine.MachineState, ttl time.Duration) (uint64, error) + func (r *RegistryMux) CreateUnit(unit *job.Unit) error + func (r *RegistryMux) DeleteMachineMetadata(machID string, key string) error + func (r *RegistryMux) DestroyUnit(unit string) error + func (r *RegistryMux) EngineChanged(newEngine machine.MachineState) + func (r *RegistryMux) EngineVersion() (int, error) + func (r *RegistryMux) IsRegistryReady() bool + func (r *RegistryMux) LatestDaemonVersion() (*semver.Version, error) + func (r *RegistryMux) MachineState(machID string) (machine.MachineState, error) + func (r *RegistryMux) Machines() ([]machine.MachineState, error) + func (r *RegistryMux) RemoveMachineState(machID string) error + func (r *RegistryMux) RemoveUnitState(jobName string) error + func (r *RegistryMux) SaveUnitState(jobName string, unitState *unit.UnitState, ttl time.Duration) + func (r *RegistryMux) Schedule() ([]job.ScheduledUnit, error) + func (r *RegistryMux) ScheduleUnit(name string, machID string) error + func (r *RegistryMux) ScheduledUnit(name string) (*job.ScheduledUnit, error) + func (r *RegistryMux) SetMachineMetadata(machID string, key string, value string) error + func (r *RegistryMux) SetMachineState(ms machine.MachineState, ttl time.Duration) (uint64, error) + func (r *RegistryMux) SetUnitTargetState(name string, state job.JobState) error + func (r *RegistryMux) Unit(name string) (*job.Unit, error) + func (r *RegistryMux) UnitHeartbeat(name string, machID string, ttl time.Duration) error + func (r *RegistryMux) UnitState(name string) (*unit.UnitState, error) + func (r *RegistryMux) UnitStates() ([]*unit.UnitState, error) + func (r *RegistryMux) Units() ([]job.Unit, error) + func (r *RegistryMux) UnscheduleUnit(name string, machID string) error + func (r *RegistryMux) UpdateEngineVersion(from int, to int) error + func (r *RegistryMux) UseEtcdRegistry() bool
Go to main page