rpcdriver

Documentation

Index

• type InternalClient
  • func NewInternalClient(rpcclient *rpc.Client) *InternalClient
  • func (ic *InternalClient) Call(serviceMethod string, args interface{}, reply interface{}) error
• type RpcCall
• type RpcClientDriver
  • 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
  • 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
  • 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) 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

Types

type InternalClient

type InternalClient struct {
	RpcClient *rpc.Client
	Calls     chan RpcCall
	CallErrs  chan error
}

func NewInternalClient

func NewInternalClient(rpcclient *rpc.Client) *InternalClient

func (*InternalClient) Call

func (ic *InternalClient) Call(serviceMethod string, args interface{}, reply interface{}) error

type RpcCall

type RpcCall struct {
	ServiceMethod string
	Args          interface{}
	Reply         interface{}
}

type RpcClientDriver

type RpcClientDriver struct {
	Client *InternalClient
}

func NewRpcClientDriver

func NewRpcClientDriver(rawDriverData []byte, driverName string) (*RpcClientDriver, error)

func (*RpcClientDriver) Close

func (c *RpcClientDriver) Close() error

func (*RpcClientDriver) Create

func (c *RpcClientDriver) Create() error

func (*RpcClientDriver) DriverName

func (c *RpcClientDriver) DriverName() string

func (*RpcClientDriver) GetConfigRaw

func (c *RpcClientDriver) GetConfigRaw() ([]byte, error)

func (*RpcClientDriver) GetCreateFlags

func (c *RpcClientDriver) GetCreateFlags() []mcnflag.Flag

func (*RpcClientDriver) GetIP

func (c *RpcClientDriver) GetIP() (string, error)

func (*RpcClientDriver) GetMachineName

func (c *RpcClientDriver) GetMachineName() string

func (*RpcClientDriver) GetSSHHostname

func (c *RpcClientDriver) GetSSHHostname() (string, error)

func (*RpcClientDriver) GetSSHKeyPath

func (c *RpcClientDriver) GetSSHKeyPath() string

TODO: This method doesn't even make sense to have with RPC.

func (*RpcClientDriver) GetSSHPort

func (c *RpcClientDriver) GetSSHPort() (int, error)

func (*RpcClientDriver) GetSSHUsername

func (c *RpcClientDriver) GetSSHUsername() string

func (*RpcClientDriver) GetState

func (c *RpcClientDriver) GetState() (state.State, error)

func (*RpcClientDriver) GetURL

func (c *RpcClientDriver) GetURL() (string, error)

func (*RpcClientDriver) GlobalArtifactPath

func (c *RpcClientDriver) GlobalArtifactPath() string

func (*RpcClientDriver) Kill

func (c *RpcClientDriver) Kill() error

func (*RpcClientDriver) LocalArtifactPath

func (c *RpcClientDriver) LocalArtifactPath(file string) string

func (*RpcClientDriver) MarshalJSON

func (c *RpcClientDriver) MarshalJSON() ([]byte, error)

func (*RpcClientDriver) PreCreateCheck

func (c *RpcClientDriver) PreCreateCheck() error

func (*RpcClientDriver) Remove

func (c *RpcClientDriver) Remove() error

func (*RpcClientDriver) Restart

func (c *RpcClientDriver) Restart() error

func (*RpcClientDriver) SetConfigFromFlags

func (c *RpcClientDriver) SetConfigFromFlags(flags drivers.DriverOptions) error

func (*RpcClientDriver) SetConfigRaw

func (c *RpcClientDriver) SetConfigRaw(data []byte) error

func (*RpcClientDriver) Start

func (c *RpcClientDriver) Start() error

func (*RpcClientDriver) Stop

func (c *RpcClientDriver) Stop() error

func (*RpcClientDriver) UnmarshalJSON

func (c *RpcClientDriver) UnmarshalJSON(data []byte) error

func (*RpcClientDriver) Upgrade

func (c *RpcClientDriver) Upgrade() error

type RpcFlags

type RpcFlags struct {
	Values map[string]interface{}
}

func (RpcFlags) Bool

func (r RpcFlags) Bool(key string) bool

func (RpcFlags) Get

func (r RpcFlags) Get(key string) interface{}

func (RpcFlags) Int

func (r RpcFlags) Int(key string) int

func (RpcFlags) String

func (r RpcFlags) String(key string) string

func (RpcFlags) StringSlice

func (r RpcFlags) StringSlice(key string) []string

type RpcServerDriver

type RpcServerDriver struct {
	ActualDriver drivers.Driver
	CloseCh      chan bool
}

func (*RpcServerDriver) Close

func (r *RpcServerDriver) Close(_, _ *struct{}) error

func (*RpcServerDriver) Create

func (r *RpcServerDriver) Create(_, _ *struct{}) error

func (*RpcServerDriver) DriverName

func (r *RpcServerDriver) DriverName(_ *struct{}, reply *string) error

func (*RpcServerDriver) GetConfigRaw

func (r *RpcServerDriver) GetConfigRaw(_ *struct{}, reply *[]byte) error

func (*RpcServerDriver) GetCreateFlags

func (r *RpcServerDriver) GetCreateFlags(_ *struct{}, reply *[]mcnflag.Flag) error

func (*RpcServerDriver) GetIP

func (r *RpcServerDriver) GetIP(_ *struct{}, reply *string) error

func (*RpcServerDriver) GetMachineName

func (r *RpcServerDriver) GetMachineName(_ *struct{}, reply *string) error

func (*RpcServerDriver) GetSSHHostname

func (r *RpcServerDriver) GetSSHHostname(_ *struct{}, reply *string) error

func (*RpcServerDriver) GetSSHKeyPath

func (r *RpcServerDriver) GetSSHKeyPath(_ *struct{}, reply *string) error

func (*RpcServerDriver) GetSSHPort

func (r *RpcServerDriver) GetSSHPort(_ *struct{}, reply *int) error

GetSSHPort returns port for use with ssh

func (*RpcServerDriver) GetSSHUsername

func (r *RpcServerDriver) GetSSHUsername(_ *struct{}, reply *string) error

func (*RpcServerDriver) GetState

func (r *RpcServerDriver) GetState(_ *struct{}, reply *state.State) error

func (*RpcServerDriver) GetURL

func (r *RpcServerDriver) GetURL(_ *struct{}, reply *string) error

func (*RpcServerDriver) GetVersion

func (r *RpcServerDriver) GetVersion(_ *struct{}, reply *int) error

func (*RpcServerDriver) Kill

func (r *RpcServerDriver) Kill(_ *struct{}, _ *struct{}) error

func (*RpcServerDriver) PreCreateCheck

func (r *RpcServerDriver) PreCreateCheck(_ *struct{}, _ *struct{}) error

func (*RpcServerDriver) Remove

func (r *RpcServerDriver) Remove(_ *struct{}, _ *struct{}) error

func (*RpcServerDriver) Restart

func (r *RpcServerDriver) Restart(_ *struct{}, _ *struct{}) error

func (*RpcServerDriver) SetConfigFromFlags

func (r *RpcServerDriver) SetConfigFromFlags(flags *drivers.DriverOptions, _ *struct{}) error

func (*RpcServerDriver) SetConfigRaw

func (r *RpcServerDriver) SetConfigRaw(data []byte, _ *struct{}) error

func (*RpcServerDriver) Start

func (r *RpcServerDriver) Start(_ *struct{}, _ *struct{}) error

func (*RpcServerDriver) Stop

func (r *RpcServerDriver) Stop(_ *struct{}, _ *struct{}) error