Versions in this module Expand all Collapse all v0 v0.1.0 Nov 19, 2015 Changes in this version + type InternalClient struct + MachineName string + RPCClient *rpc.Client + func NewInternalClient(rpcclient *rpc.Client) *InternalClient + func (ic *InternalClient) Call(serviceMethod string, args interface{}, reply interface{}) error + type RPCCall struct + Args interface{} + Reply interface{} + ServiceMethod string + type RPCClientDriver struct + Client *InternalClient + func NewRPCClientDriver(rawDriverData []byte, driverName string) (*RPCClientDriver, error) + func (c *RPCClientDriver) Close() error + func (c *RPCClientDriver) Create() error + func (c *RPCClientDriver) DriverName() string + func (c *RPCClientDriver) GetConfigRaw() ([]byte, error) + func (c *RPCClientDriver) GetCreateFlags() []mcnflag.Flag + func (c *RPCClientDriver) GetIP() (string, error) + func (c *RPCClientDriver) GetMachineName() string + func (c *RPCClientDriver) GetSSHHostname() (string, error) + func (c *RPCClientDriver) GetSSHKeyPath() string + func (c *RPCClientDriver) GetSSHPort() (int, error) + func (c *RPCClientDriver) GetSSHUsername() string + func (c *RPCClientDriver) GetState() (state.State, error) + func (c *RPCClientDriver) GetURL() (string, error) + func (c *RPCClientDriver) GlobalArtifactPath() string + func (c *RPCClientDriver) Kill() error + func (c *RPCClientDriver) LocalArtifactPath(file string) string + func (c *RPCClientDriver) MarshalJSON() ([]byte, error) + func (c *RPCClientDriver) PreCreateCheck() error + func (c *RPCClientDriver) Remove() error + func (c *RPCClientDriver) Restart() error + func (c *RPCClientDriver) SetConfigFromFlags(flags drivers.DriverOptions) error + func (c *RPCClientDriver) SetConfigRaw(data []byte) error + func (c *RPCClientDriver) Start() error + func (c *RPCClientDriver) Stop() error + func (c *RPCClientDriver) UnmarshalJSON(data []byte) error + func (c *RPCClientDriver) Upgrade() error + type RPCFlags struct + Values map[string]interface{} + func (r RPCFlags) Bool(key string) bool + func (r RPCFlags) Get(key string) interface{} + func (r RPCFlags) Int(key string) int + func (r RPCFlags) String(key string) string + func (r RPCFlags) StringSlice(key string) []string + type RPCServerDriver struct + ActualDriver drivers.Driver + CloseCh chan bool + HeartbeatCh chan bool + func NewRPCServerDriver(d drivers.Driver) *RPCServerDriver + func (r *RPCServerDriver) Close(_, _ *struct{}) error + func (r *RPCServerDriver) Create(_, _ *struct{}) error + func (r *RPCServerDriver) DriverName(_ *struct{}, reply *string) error + func (r *RPCServerDriver) GetConfigRaw(_ *struct{}, reply *[]byte) error + func (r *RPCServerDriver) GetCreateFlags(_ *struct{}, reply *[]mcnflag.Flag) error + func (r *RPCServerDriver) GetIP(_ *struct{}, reply *string) error + func (r *RPCServerDriver) GetMachineName(_ *struct{}, reply *string) error + func (r *RPCServerDriver) GetSSHHostname(_ *struct{}, reply *string) error + func (r *RPCServerDriver) GetSSHKeyPath(_ *struct{}, reply *string) error + func (r *RPCServerDriver) GetSSHPort(_ *struct{}, reply *int) error + func (r *RPCServerDriver) GetSSHUsername(_ *struct{}, reply *string) error + func (r *RPCServerDriver) GetState(_ *struct{}, reply *state.State) error + func (r *RPCServerDriver) GetURL(_ *struct{}, reply *string) error + func (r *RPCServerDriver) GetVersion(_ *struct{}, reply *int) error + func (r *RPCServerDriver) Heartbeat(_ *struct{}, _ *struct{}) error + func (r *RPCServerDriver) Kill(_ *struct{}, _ *struct{}) error + func (r *RPCServerDriver) PreCreateCheck(_ *struct{}, _ *struct{}) error + func (r *RPCServerDriver) Remove(_ *struct{}, _ *struct{}) error + func (r *RPCServerDriver) Restart(_ *struct{}, _ *struct{}) error + func (r *RPCServerDriver) SetConfigFromFlags(flags *drivers.DriverOptions, _ *struct{}) error + func (r *RPCServerDriver) SetConfigRaw(data []byte, _ *struct{}) error + func (r *RPCServerDriver) Start(_ *struct{}, _ *struct{}) error + func (r *RPCServerDriver) Stop(_ *struct{}, _ *struct{}) error