Documentation
¶
Index ¶
- func Init(listenAddr string) error
- func Listen()
- type AuthorizeSSHExecutor
- type ContainerMaintenanceExecutor
- type DeauthorizeSSHExecutor
- type DeleteIPGroupExecutor
- type DeployExecutor
- type GetExecutor
- type HealthCheckExecutor
- func (e *HealthCheckExecutor) AllowDuringMaintenance() bool
- func (e *HealthCheckExecutor) Authorize() error
- func (e *HealthCheckExecutor) Description() string
- func (e *HealthCheckExecutor) Execute(t *Task) error
- func (e *HealthCheckExecutor) Request() interface{}
- func (e *HealthCheckExecutor) Result() interface{}
- type IdleExecutor
- type ListExecutor
- type Supervisor
- func (ih *Supervisor) AuthorizeSSH(arg SupervisorAuthorizeSSHArg, reply *SupervisorAuthorizeSSHReply) error
- func (ih *Supervisor) ContainerMaintenance(arg SupervisorContainerMaintenanceArg, ...) error
- func (ih *Supervisor) DeauthorizeSSH(arg SupervisorDeauthorizeSSHArg, reply *SupervisorDeauthorizeSSHReply) error
- func (ih *Supervisor) DeleteIPGroup(arg SupervisorDeleteIPGroupArg, reply *SupervisorDeleteIPGroupReply) error
- func (ih *Supervisor) Deploy(arg SupervisorDeployArg, reply *SupervisorDeployReply) error
- func (ih *Supervisor) Get(arg SupervisorGetArg, reply *SupervisorGetReply) (err error)
- func (ih *Supervisor) HealthCheck(arg SupervisorHealthCheckArg, reply *SupervisorHealthCheckReply) (err error)
- func (o *Supervisor) Idle(arg SupervisorIdleArg, reply *SupervisorIdleReply) error
- func (ih *Supervisor) List(arg SupervisorListArg, reply *SupervisorListReply) error
- func (ih *Supervisor) Teardown(arg SupervisorTeardownArg, reply *SupervisorTeardownReply) error
- func (ih *Supervisor) UpdateIPGroup(arg SupervisorUpdateIPGroupArg, reply *SupervisorUpdateIPGroupReply) error
- func (ih *Supervisor) Version(arg VersionArg, reply *VersionReply) error
- type TeardownExecutor
- type UpdateIPGroupExecutor
- type VersionExecutor
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type AuthorizeSSHExecutor ¶
type AuthorizeSSHExecutor struct {
// contains filtered or unexported fields
}
func (*AuthorizeSSHExecutor) Authorize ¶
func (e *AuthorizeSSHExecutor) Authorize() error
func (*AuthorizeSSHExecutor) Description ¶
func (e *AuthorizeSSHExecutor) Description() string
func (*AuthorizeSSHExecutor) Execute ¶
func (e *AuthorizeSSHExecutor) Execute(t *Task) error
func (*AuthorizeSSHExecutor) Request ¶
func (e *AuthorizeSSHExecutor) Request() interface{}
func (*AuthorizeSSHExecutor) Result ¶
func (e *AuthorizeSSHExecutor) Result() interface{}
type ContainerMaintenanceExecutor ¶
type ContainerMaintenanceExecutor struct {
// contains filtered or unexported fields
}
func (*ContainerMaintenanceExecutor) Authorize ¶
func (e *ContainerMaintenanceExecutor) Authorize() error
func (*ContainerMaintenanceExecutor) Description ¶
func (e *ContainerMaintenanceExecutor) Description() string
func (*ContainerMaintenanceExecutor) Execute ¶
func (e *ContainerMaintenanceExecutor) Execute(t *Task) error
func (*ContainerMaintenanceExecutor) Request ¶
func (e *ContainerMaintenanceExecutor) Request() interface{}
func (*ContainerMaintenanceExecutor) Result ¶
func (e *ContainerMaintenanceExecutor) Result() interface{}
type DeauthorizeSSHExecutor ¶
type DeauthorizeSSHExecutor struct {
// contains filtered or unexported fields
}
func (*DeauthorizeSSHExecutor) Authorize ¶
func (e *DeauthorizeSSHExecutor) Authorize() error
func (*DeauthorizeSSHExecutor) Description ¶
func (e *DeauthorizeSSHExecutor) Description() string
func (*DeauthorizeSSHExecutor) Execute ¶
func (e *DeauthorizeSSHExecutor) Execute(t *Task) error
func (*DeauthorizeSSHExecutor) Request ¶
func (e *DeauthorizeSSHExecutor) Request() interface{}
func (*DeauthorizeSSHExecutor) Result ¶
func (e *DeauthorizeSSHExecutor) Result() interface{}
type DeleteIPGroupExecutor ¶
type DeleteIPGroupExecutor struct {
// contains filtered or unexported fields
}
func (*DeleteIPGroupExecutor) Authorize ¶
func (e *DeleteIPGroupExecutor) Authorize() error
func (*DeleteIPGroupExecutor) Description ¶
func (e *DeleteIPGroupExecutor) Description() string
func (*DeleteIPGroupExecutor) Execute ¶
func (e *DeleteIPGroupExecutor) Execute(t *Task) error
func (*DeleteIPGroupExecutor) Request ¶
func (e *DeleteIPGroupExecutor) Request() interface{}
func (*DeleteIPGroupExecutor) Result ¶
func (e *DeleteIPGroupExecutor) Result() interface{}
type DeployExecutor ¶
type DeployExecutor struct {
// contains filtered or unexported fields
}
Deploys an app+sha to the given container id using the given service dependencies (comes from arg.Manifest)
func (*DeployExecutor) Authorize ¶
func (e *DeployExecutor) Authorize() error
func (*DeployExecutor) Description ¶
func (e *DeployExecutor) Description() string
func (*DeployExecutor) Execute ¶
func (e *DeployExecutor) Execute(t *Task) error
func (*DeployExecutor) Request ¶
func (e *DeployExecutor) Request() interface{}
func (*DeployExecutor) Result ¶
func (e *DeployExecutor) Result() interface{}
type GetExecutor ¶
type GetExecutor struct {
// contains filtered or unexported fields
}
func (*GetExecutor) Authorize ¶
func (e *GetExecutor) Authorize() error
func (*GetExecutor) Description ¶
func (e *GetExecutor) Description() string
func (*GetExecutor) Execute ¶
func (e *GetExecutor) Execute(t *Task) (err error)
func (*GetExecutor) Request ¶
func (e *GetExecutor) Request() interface{}
func (*GetExecutor) Result ¶
func (e *GetExecutor) Result() interface{}
type HealthCheckExecutor ¶
type HealthCheckExecutor struct {
// contains filtered or unexported fields
}
Check the health of Supervisor. Supervisor will return some useful stats as well.
func (*HealthCheckExecutor) AllowDuringMaintenance ¶
func (e *HealthCheckExecutor) AllowDuringMaintenance() bool
func (*HealthCheckExecutor) Authorize ¶
func (e *HealthCheckExecutor) Authorize() error
func (*HealthCheckExecutor) Description ¶
func (e *HealthCheckExecutor) Description() string
func (*HealthCheckExecutor) Execute ¶
func (e *HealthCheckExecutor) Execute(t *Task) error
func (*HealthCheckExecutor) Request ¶
func (e *HealthCheckExecutor) Request() interface{}
func (*HealthCheckExecutor) Result ¶
func (e *HealthCheckExecutor) Result() interface{}
type IdleExecutor ¶
type IdleExecutor struct {
// contains filtered or unexported fields
}
Supervisor Idle Check
func (*IdleExecutor) AllowDuringMaintenance ¶
func (e *IdleExecutor) AllowDuringMaintenance() bool
func (*IdleExecutor) Authorize ¶
func (e *IdleExecutor) Authorize() error
func (*IdleExecutor) Description ¶
func (e *IdleExecutor) Description() string
func (*IdleExecutor) Execute ¶
func (e *IdleExecutor) Execute(t *Task) error
func (*IdleExecutor) Request ¶
func (e *IdleExecutor) Request() interface{}
func (*IdleExecutor) Result ¶
func (e *IdleExecutor) Result() interface{}
type ListExecutor ¶
type ListExecutor struct {
// contains filtered or unexported fields
}
List all the deployed containers and available ports
func (*ListExecutor) Authorize ¶
func (e *ListExecutor) Authorize() error
func (*ListExecutor) Description ¶
func (e *ListExecutor) Description() string
func (*ListExecutor) Execute ¶
func (e *ListExecutor) Execute(t *Task) error
func (*ListExecutor) Request ¶
func (e *ListExecutor) Request() interface{}
func (*ListExecutor) Result ¶
func (e *ListExecutor) Result() interface{}
type Supervisor ¶
type Supervisor bool
func (*Supervisor) AuthorizeSSH ¶
func (ih *Supervisor) AuthorizeSSH(arg SupervisorAuthorizeSSHArg, reply *SupervisorAuthorizeSSHReply) error
func (*Supervisor) ContainerMaintenance ¶
func (ih *Supervisor) ContainerMaintenance(arg SupervisorContainerMaintenanceArg, reply *SupervisorContainerMaintenanceReply) error
func (*Supervisor) DeauthorizeSSH ¶
func (ih *Supervisor) DeauthorizeSSH(arg SupervisorDeauthorizeSSHArg, reply *SupervisorDeauthorizeSSHReply) error
func (*Supervisor) DeleteIPGroup ¶
func (ih *Supervisor) DeleteIPGroup(arg SupervisorDeleteIPGroupArg, reply *SupervisorDeleteIPGroupReply) error
func (*Supervisor) Deploy ¶
func (ih *Supervisor) Deploy(arg SupervisorDeployArg, reply *SupervisorDeployReply) error
func (*Supervisor) Get ¶
func (ih *Supervisor) Get(arg SupervisorGetArg, reply *SupervisorGetReply) (err error)
func (*Supervisor) HealthCheck ¶
func (ih *Supervisor) HealthCheck(arg SupervisorHealthCheckArg, reply *SupervisorHealthCheckReply) (err error)
func (*Supervisor) Idle ¶
func (o *Supervisor) Idle(arg SupervisorIdleArg, reply *SupervisorIdleReply) error
func (*Supervisor) List ¶
func (ih *Supervisor) List(arg SupervisorListArg, reply *SupervisorListReply) error
func (*Supervisor) Teardown ¶
func (ih *Supervisor) Teardown(arg SupervisorTeardownArg, reply *SupervisorTeardownReply) error
func (*Supervisor) UpdateIPGroup ¶
func (ih *Supervisor) UpdateIPGroup(arg SupervisorUpdateIPGroupArg, reply *SupervisorUpdateIPGroupReply) error
func (*Supervisor) Version ¶
func (ih *Supervisor) Version(arg VersionArg, reply *VersionReply) error
type TeardownExecutor ¶
type TeardownExecutor struct {
// contains filtered or unexported fields
}
Teardown an already deployed container. Will return status "OK" if the container iff was found.
func (*TeardownExecutor) Authorize ¶
func (e *TeardownExecutor) Authorize() error
func (*TeardownExecutor) Description ¶
func (e *TeardownExecutor) Description() string
func (*TeardownExecutor) Execute ¶
func (e *TeardownExecutor) Execute(t *Task) error
func (*TeardownExecutor) Request ¶
func (e *TeardownExecutor) Request() interface{}
func (*TeardownExecutor) Result ¶
func (e *TeardownExecutor) Result() interface{}
type UpdateIPGroupExecutor ¶
type UpdateIPGroupExecutor struct {
// contains filtered or unexported fields
}
func (*UpdateIPGroupExecutor) Authorize ¶
func (e *UpdateIPGroupExecutor) Authorize() error
func (*UpdateIPGroupExecutor) Description ¶
func (e *UpdateIPGroupExecutor) Description() string
func (*UpdateIPGroupExecutor) Execute ¶
func (e *UpdateIPGroupExecutor) Execute(t *Task) error
func (*UpdateIPGroupExecutor) Request ¶
func (e *UpdateIPGroupExecutor) Request() interface{}
func (*UpdateIPGroupExecutor) Result ¶
func (e *UpdateIPGroupExecutor) Result() interface{}
type VersionExecutor ¶
type VersionExecutor struct {
// contains filtered or unexported fields
}
Return the current RPC Version
func (*VersionExecutor) AllowDuringMaintenance ¶
func (e *VersionExecutor) AllowDuringMaintenance() bool
func (*VersionExecutor) Authorize ¶
func (e *VersionExecutor) Authorize() error
func (*VersionExecutor) Description ¶
func (e *VersionExecutor) Description() string
func (*VersionExecutor) Execute ¶
func (e *VersionExecutor) Execute(t *Task) error
func (*VersionExecutor) Request ¶
func (e *VersionExecutor) Request() interface{}
func (*VersionExecutor) Result ¶
func (e *VersionExecutor) Result() interface{}
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.