rpcdriver

package
v0.16.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 13, 2020 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	RPCServiceNameV0 = `RpcServerDriver`
	RPCServiceNameV1 = `RPCServerDriver`

	HeartbeatMethod          = `.Heartbeat`
	GetVersionMethod         = `.GetVersion`
	CloseMethod              = `.Close`
	GetCreateFlagsMethod     = `.GetCreateFlags`
	SetConfigRawMethod       = `.SetConfigRaw`
	GetConfigRawMethod       = `.GetConfigRaw`
	DriverNameMethod         = `.DriverName`
	SetConfigFromFlagsMethod = `.SetConfigFromFlags`
	GetURLMethod             = `.GetURL`
	GetMachineNameMethod     = `.GetMachineName`
	GetIPMethod              = `.GetIP`
	GetSSHHostnameMethod     = `.GetSSHHostname`
	GetSSHKeyPathMethod      = `.GetSSHKeyPath`
	GetSSHPortMethod         = `.GetSSHPort`
	GetSSHUsernameMethod     = `.GetSSHUsername`
	GetStateMethod           = `.GetState`
	PreCreateCheckMethod     = `.PreCreateCheck`
	CreateMethod             = `.Create`
	RemoveMethod             = `.Remove`
	StartMethod              = `.Start`
	StopMethod               = `.Stop`
	RestartMethod            = `.Restart`
	KillMethod               = `.Kill`
	UpgradeMethod            = `.Upgrade`
)

Variables

This section is empty.

Functions

This section is empty.

Types

type DefaultRPCClientDriverFactory added in v0.5.6 

type DefaultRPCClientDriverFactory struct {
	// contains filtered or unexported fields
}

func (*DefaultRPCClientDriverFactory) Close added in v0.5.6 

func (f *DefaultRPCClientDriverFactory) Close() error

func (*DefaultRPCClientDriverFactory) NewRPCClientDriver added in v0.5.6 

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

type InternalClient 

type InternalClient struct {
	MachineName string
	RPCClient   *rpc.Client
	// contains filtered or unexported fields
}

func NewInternalClient 

func NewInternalClient(rpcclient *rpc.Client) *InternalClient

func (*InternalClient) Call 

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

type RPCCall added in v0.5.1 

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

type RPCClientDriver added in v0.5.1 

type RPCClientDriver struct {
	Client *InternalClient
	// contains filtered or unexported fields
}

func (*RPCClientDriver) Create added in v0.5.1 

func (c *RPCClientDriver) Create() error

func (*RPCClientDriver) DriverName added in v0.5.1 

func (c *RPCClientDriver) DriverName() string

DriverName returns the name of the driver

func (*RPCClientDriver) GetConfigRaw added in v0.5.1 

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

func (*RPCClientDriver) GetCreateFlags added in v0.5.1 

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

func (*RPCClientDriver) GetIP added in v0.5.1 

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

func (*RPCClientDriver) GetMachineName added in v0.5.1 

func (c *RPCClientDriver) GetMachineName() string

func (*RPCClientDriver) GetSSHHostname added in v0.5.1 

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

func (*RPCClientDriver) GetSSHKeyPath added in v0.5.1 

func (c *RPCClientDriver) GetSSHKeyPath() string

GetSSHKeyPath returns the key path TODO: This method doesn't even make sense to have with RPC.

func (*RPCClientDriver) GetSSHPort added in v0.5.1 

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

func (*RPCClientDriver) GetSSHUsername added in v0.5.1 

func (c *RPCClientDriver) GetSSHUsername() string

func (*RPCClientDriver) GetState added in v0.5.1 

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

func (*RPCClientDriver) GetURL added in v0.5.1 

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

func (*RPCClientDriver) Kill added in v0.5.1 

func (c *RPCClientDriver) Kill() error

func (*RPCClientDriver) MarshalJSON added in v0.5.1 

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

func (*RPCClientDriver) PreCreateCheck added in v0.5.1 

func (c *RPCClientDriver) PreCreateCheck() error

func (*RPCClientDriver) Remove added in v0.5.1 

func (c *RPCClientDriver) Remove() error

func (*RPCClientDriver) Restart added in v0.5.1 

func (c *RPCClientDriver) Restart() error

func (*RPCClientDriver) SetConfigFromFlags added in v0.5.1 

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

func (*RPCClientDriver) SetConfigRaw added in v0.5.1 

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

func (*RPCClientDriver) Start added in v0.5.1 

func (c *RPCClientDriver) Start() error

func (*RPCClientDriver) Stop added in v0.5.1 

func (c *RPCClientDriver) Stop() error

func (*RPCClientDriver) UnmarshalJSON added in v0.5.1 

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

func (*RPCClientDriver) Upgrade added in v0.5.1 

func (c *RPCClientDriver) Upgrade() error

type RPCClientDriverFactory added in v0.5.6 

type RPCClientDriverFactory interface {
	NewRPCClientDriver(driverName string, rawDriver []byte) (*RPCClientDriver, error)
	io.Closer
}

func NewRPCClientDriverFactory added in v0.5.6 

func NewRPCClientDriverFactory() RPCClientDriverFactory

type RPCFlags added in v0.5.1 

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

func (RPCFlags) Bool added in v0.5.1 

func (r RPCFlags) Bool(key string) bool

func (RPCFlags) Get added in v0.5.1 

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

func (RPCFlags) Int added in v0.5.1 

func (r RPCFlags) Int(key string) int

func (RPCFlags) String added in v0.5.1 

func (r RPCFlags) String(key string) string

func (RPCFlags) StringSlice added in v0.5.1 

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

type RPCServerDriver added in v0.5.1 

type RPCServerDriver struct {
	ActualDriver drivers.Driver
	CloseCh      chan bool
	HeartbeatCh  chan bool
}

func NewRPCServerDriver added in v0.5.1 

func NewRPCServerDriver(d drivers.Driver) *RPCServerDriver

func (*RPCServerDriver) Close added in v0.5.1 

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

func (*RPCServerDriver) Create added in v0.5.1 

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

func (*RPCServerDriver) DriverName added in v0.5.1 

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

func (*RPCServerDriver) GetConfigRaw added in v0.5.1 

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

func (*RPCServerDriver) GetCreateFlags added in v0.5.1 

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

func (*RPCServerDriver) GetIP added in v0.5.1 

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

func (*RPCServerDriver) GetMachineName added in v0.5.1 

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

func (*RPCServerDriver) GetSSHHostname added in v0.5.1 

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

func (*RPCServerDriver) GetSSHKeyPath added in v0.5.1 

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

func (*RPCServerDriver) GetSSHPort added in v0.5.1 

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

GetSSHPort returns port for use with ssh

func (*RPCServerDriver) GetSSHUsername added in v0.5.1 

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

func (*RPCServerDriver) GetState added in v0.5.1 

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

func (*RPCServerDriver) GetURL added in v0.5.1 

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

func (*RPCServerDriver) GetVersion added in v0.5.1 

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

func (*RPCServerDriver) Heartbeat added in v0.5.1 

func (r *RPCServerDriver) Heartbeat(_ *struct{}, _ *struct{}) error

func (*RPCServerDriver) Kill added in v0.5.1 

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

func (*RPCServerDriver) PreCreateCheck added in v0.5.1 

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

func (*RPCServerDriver) Remove added in v0.5.1 

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

func (*RPCServerDriver) Restart added in v0.5.1 

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

func (*RPCServerDriver) SetConfigFromFlags added in v0.5.1 

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

func (*RPCServerDriver) SetConfigRaw added in v0.5.1 

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

func (*RPCServerDriver) Start added in v0.5.1 

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

func (*RPCServerDriver) Stop added in v0.5.1 

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

type Stacker added in v0.6.0 

type Stacker interface {
	Stack() []byte
}

type StandardStack added in v0.6.0 

type StandardStack struct{}

func (*StandardStack) Stack added in v0.6.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.