rpcdriver

package

Go to main page

Versions in this module

v0

v0.16.2

Sep 2, 2019

v0.12.1

Jun 30, 2017

Changes in this version

+ type Stacker interface

+ Stack func() []byte

+ type StandardStack struct

+ func (ss *StandardStack) Stack() []byte

v0.7.0-rc3

Apr 8, 2016

v0.6.0-rc3

Feb 3, 2016

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.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 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

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