client

Documentation

Index

• type EngineManagerClient
  • func NewEngineManagerClient(address string) *EngineManagerClient
  • func (cli *EngineManagerClient) EngineCreate(size int64, name, volumeName, binary, listen, listenIP, frontend string, ...) (*api.Engine, error)
  • func (cli *EngineManagerClient) EngineDelete(name string) (*api.Engine, error)
  • func (cli *EngineManagerClient) EngineGet(name string) (*api.Engine, error)
  • func (cli *EngineManagerClient) EngineList() (map[string]*api.Engine, error)
  • func (cli *EngineManagerClient) EngineLog(volumeName string) (*api.LogStream, error)
  • func (cli *EngineManagerClient) EngineUpgrade(size int64, name, binary string, replicas []string) (*api.Engine, error)
  • func (cli *EngineManagerClient) EngineWatch() (*api.EngineStream, error)
  • func (cli *EngineManagerClient) FrontendShutdown(name string) error
  • func (cli *EngineManagerClient) FrontendShutdownCallback(name string) error
  • func (cli *EngineManagerClient) FrontendStart(name, frontend string) error
  • func (cli *EngineManagerClient) FrontendStartCallback(name string) error
• type ProcessManagerClient
  • func NewProcessManagerClient(address string) *ProcessManagerClient
  • func (cli *ProcessManagerClient) ProcessCreate(name, binary string, portCount int, args, portArgs []string) (*api.Process, error)
  • func (cli *ProcessManagerClient) ProcessDelete(name string) (*api.Process, error)
  • func (cli *ProcessManagerClient) ProcessGet(name string) (*api.Process, error)
  • func (cli *ProcessManagerClient) ProcessList() (map[string]*api.Process, error)
  • func (cli *ProcessManagerClient) ProcessLog(name string) (*api.LogStream, error)
  • func (cli *ProcessManagerClient) ProcessWatch() (*api.ProcessStream, error)

Types

type EngineManagerClient

type EngineManagerClient struct {
	Address string
}

func NewEngineManagerClient

func NewEngineManagerClient(address string) *EngineManagerClient

func (*EngineManagerClient) EngineCreate

func (cli *EngineManagerClient) EngineCreate(size int64, name, volumeName, binary, listen, listenIP, frontend string, backends, replicas []string) (*api.Engine, error)

func (*EngineManagerClient) EngineDelete

func (cli *EngineManagerClient) EngineDelete(name string) (*api.Engine, error)

func (*EngineManagerClient) EngineGet

func (cli *EngineManagerClient) EngineGet(name string) (*api.Engine, error)

func (*EngineManagerClient) EngineList

func (cli *EngineManagerClient) EngineList() (map[string]*api.Engine, error)

func (*EngineManagerClient) EngineLog

func (cli *EngineManagerClient) EngineLog(volumeName string) (*api.LogStream, error)

func (*EngineManagerClient) EngineUpgrade

func (cli *EngineManagerClient) EngineUpgrade(size int64, name, binary string, replicas []string) (*api.Engine, error)

func (*EngineManagerClient) EngineWatch

func (cli *EngineManagerClient) EngineWatch() (*api.EngineStream, error)

func (*EngineManagerClient) FrontendShutdown

func (cli *EngineManagerClient) FrontendShutdown(name string) error

func (*EngineManagerClient) FrontendShutdownCallback

func (cli *EngineManagerClient) FrontendShutdownCallback(name string) error

func (*EngineManagerClient) FrontendStart

func (cli *EngineManagerClient) FrontendStart(name, frontend string) error

func (*EngineManagerClient) FrontendStartCallback

func (cli *EngineManagerClient) FrontendStartCallback(name string) error

type ProcessManagerClient

type ProcessManagerClient struct {
	Address string
}

func NewProcessManagerClient

func NewProcessManagerClient(address string) *ProcessManagerClient

func (*ProcessManagerClient) ProcessCreate

func (cli *ProcessManagerClient) ProcessCreate(name, binary string, portCount int, args, portArgs []string) (*api.Process, error)

func (*ProcessManagerClient) ProcessDelete

func (cli *ProcessManagerClient) ProcessDelete(name string) (*api.Process, error)

func (*ProcessManagerClient) ProcessGet

func (cli *ProcessManagerClient) ProcessGet(name string) (*api.Process, error)

func (*ProcessManagerClient) ProcessList

func (cli *ProcessManagerClient) ProcessList() (map[string]*api.Process, error)

func (*ProcessManagerClient) ProcessLog

func (cli *ProcessManagerClient) ProcessLog(name string) (*api.LogStream, error)

func (*ProcessManagerClient) ProcessWatch

func (cli *ProcessManagerClient) ProcessWatch() (*api.ProcessStream, error)