rpcdriver

package

Go to main page

Versions in this module

v0

v0.5.6

Jan 11, 2016

Changes in this version

+ type DefaultRPCClientDriverFactory struct

+ func (f *DefaultRPCClientDriverFactory) Close() error

+ func (f *DefaultRPCClientDriverFactory) NewRPCClientDriver(driverName string, rawDriver []byte) (*RPCClientDriver, error)

+ type RPCClientDriverFactory interface

+ NewRPCClientDriver func(driverName string, rawDriver []byte) (*RPCClientDriver, error)

+ func NewRPCClientDriverFactory() RPCClientDriverFactory

v0.5.5

Dec 28, 2015

Changes in this version

+ func CloseDrivers()

v0.5.4

Dec 16, 2015

v0.5.3

Dec 14, 2015

v0.5.2

Dec 1, 2015

Changes in this version

+ const CloseMethod

+ const CreateMethod

+ const DriverNameMethod

+ const GetConfigRawMethod

+ const GetCreateFlagsMethod

+ const GetIPMethod

+ const GetMachineNameMethod

+ const GetSSHHostnameMethod

+ const GetSSHKeyPathMethod

+ const GetSSHPortMethod

+ const GetSSHUsernameMethod

+ const GetStateMethod

+ const GetURLMethod

+ const GetVersionMethod

+ const GlobalArtifactPathMethod

+ const HeartbeatMethod

+ const KillMethod

+ const LocalArtifactPathMethod

+ const PreCreateCheckMethod

+ const RPCServiceNameV0

+ const RPCServiceNameV1

+ const RemoveMethod

+ const RestartMethod

+ const SetConfigFromFlagsMethod

+ const SetConfigRawMethod

+ const StartMethod

+ const StopMethod

+ const UpgradeMethod

v0.5.1

Nov 16, 2015

Changes in this version

type InternalClient

+ RPCClient *rpc.Client

+ 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

v0.5.0

Nov 3, 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

v0.5.0-rc4

Oct 29, 2015

v0.5.0-rc3

Oct 21, 2015

v0.5.0-rc2

Oct 20, 2015

v0.5.0-rc1

Oct 17, 2015

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL