rpcclient

Documentation

Index

• Constants
• Variables
• type AllProcessInfoReply
• type ChangeAllProcessStateArg
• type ChangeAllProcessStateRet
• type ChangeProcessStateArg
• type ChangeProcessStateRet
• type Client
  • func NewClient(address string) Client
  • func NewHTTPClient(address string) Client
  • func NewTlsClient(protocol, address string, config *tls.Config) Client
• type GetAllProcessInfoArg
• type GetAllProcessInfoRet
• type GetEnvArg
• type GetEnvRet
• type GetProcessInfoArg
• type GetProcessInfoRet
• type GetVersionArg
• type GetVersionRet
• type ProcessInfoReply
• type RPCClient
  • func NewRPCClient(serverurl, user, passwd string, verbose bool) *RPCClient
  • func (r *RPCClient) ChangeAllProcessState(change string) (*ChangeAllProcessStateRet, error)
  • func (r *RPCClient) ChangeProcessState(change string, processName string) (*ChangeProcessStateRet, error)
  • func (r *RPCClient) GetAllProcessInfo() (*GetAllProcessInfoRet, error)
  • func (r *RPCClient) GetEnv(in *GetEnvArg) (*GetEnvRet, error)
  • func (r *RPCClient) GetProcessInfo(in *GetProcessInfoArg) (*GetProcessInfoRet, error)
  • func (r *RPCClient) GetVersion() (*GetVersionRet, error)
  • func (r *RPCClient) ReloadConfig() (*ReloadConfigRet, error)
  • func (r *RPCClient) SetEnv(in *SetEnvArg) (*SetEnvRet, error)
  • func (r *RPCClient) Shutdown() (*ShutdownRet, error)
  • func (r *RPCClient) SignalAllProcesses(in *SignalAllProcessesArg) (*SignalAllProcessesRet, error)
  • func (r *RPCClient) SignalProcess(in *SignalProcessArg) (*SignalProcessRet, error)
  • func (r *RPCClient) Url() string
• type ReloadConfigArg
• type ReloadConfigRet
• type SetEnvArg
• type SetEnvRet
• type ShutdownArg
• type ShutdownRet
• type SignalAllProcessesArg
• type SignalAllProcessesRet
• type SignalProcessArg
• type SignalProcessRet
• type StatusReply

Constants

const (
	RPCPath = "/RPC2"
)

const (
	ReConnSleepTime = 2 * time.Second
)

Variables

var (
	ErrCallCanceled = errors.New("ctx canceled")
)

Types

type AllProcessInfoReply

type AllProcessInfoReply struct {
	AllProcessInfo []types.ProcessInfo
}

type ChangeAllProcessStateArg

type ChangeAllProcessStateArg struct {
	Wait bool
}

type ChangeAllProcessStateRet

type ChangeAllProcessStateRet AllProcessInfoReply

type ChangeProcessStateArg

type ChangeProcessStateArg struct {
	Name string
}

type ChangeProcessStateRet

type ChangeProcessStateRet struct {
	Success bool
}

type Client

type Client interface {
	Close() error
	SetAuth(username, passwd string)
	Call(ctx context.Context, serviceMethod string, args interface{}, reply interface{}) error
}

func NewClient

func NewClient(address string) Client

func NewHTTPClient

func NewHTTPClient(address string) Client

func NewTlsClient

func NewTlsClient(protocol, address string, config *tls.Config) Client

protocol support http and tcp

type GetAllProcessInfoArg

type GetAllProcessInfoArg struct {
}

type GetAllProcessInfoRet

type GetAllProcessInfoRet AllProcessInfoReply

type GetEnvArg

type GetEnvArg struct {
	Key string
}

type GetEnvRet

type GetEnvRet struct {
	Value string
}

type GetProcessInfoArg

type GetProcessInfoArg struct {
	Name string
}

type GetProcessInfoRet

type GetProcessInfoRet ProcessInfoReply

type GetVersionArg

type GetVersionArg struct {
}

type GetVersionRet

type GetVersionRet struct {
	Version string
}

type ProcessInfoReply

type ProcessInfoReply struct {
	ProcessInfo *types.ProcessInfo
}

type RPCClient

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

func NewRPCClient

func NewRPCClient(serverurl, user, passwd string, verbose bool) *RPCClient

func (*RPCClient) ChangeAllProcessState

func (r *RPCClient) ChangeAllProcessState(change string) (*ChangeAllProcessStateRet, error)

func (*RPCClient) ChangeProcessState

func (r *RPCClient) ChangeProcessState(change string, processName string) (*ChangeProcessStateRet, error)

func (*RPCClient) GetAllProcessInfo

func (r *RPCClient) GetAllProcessInfo() (*GetAllProcessInfoRet, error)

func (*RPCClient) GetEnv

func (r *RPCClient) GetEnv(in *GetEnvArg) (*GetEnvRet, error)

func (*RPCClient) GetProcessInfo

func (r *RPCClient) GetProcessInfo(in *GetProcessInfoArg) (*GetProcessInfoRet, error)

func (*RPCClient) GetVersion

func (r *RPCClient) GetVersion() (*GetVersionRet, error)

func (*RPCClient) ReloadConfig

func (r *RPCClient) ReloadConfig() (*ReloadConfigRet, error)

func (*RPCClient) SetEnv

func (r *RPCClient) SetEnv(in *SetEnvArg) (*SetEnvRet, error)

func (*RPCClient) Shutdown

func (r *RPCClient) Shutdown() (*ShutdownRet, error)

func (*RPCClient) SignalAllProcesses

func (r *RPCClient) SignalAllProcesses(in *SignalAllProcessesArg) (*SignalAllProcessesRet, error)

func (*RPCClient) SignalProcess

func (r *RPCClient) SignalProcess(in *SignalProcessArg) (*SignalProcessRet, error)

func (*RPCClient) Url

func (r *RPCClient) Url() string

type ReloadConfigArg

type ReloadConfigArg struct {
}

type ReloadConfigRet

type ReloadConfigRet types.ReloadConfigResult

type SetEnvArg

type SetEnvArg struct {
	Key   string
	Value string
}

type SetEnvRet

type SetEnvRet struct {
}

type ShutdownArg

type ShutdownArg struct {
}

type ShutdownRet

type ShutdownRet struct {
	Success bool
}

type SignalAllProcessesArg

type SignalAllProcessesArg struct {
	Signal string
}

type SignalAllProcessesRet

type SignalAllProcessesRet AllProcessInfoReply

type SignalProcessArg

type SignalProcessArg struct {
	ProcName string
	Signal   string
}

type SignalProcessRet

type SignalProcessRet types.BooleanReply

type StatusReply

type StatusReply struct {
	Success bool
}