rc

package
v0.10.0 Latest Latest
Warning

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

 Go to latest Published: Jan 18, 2020 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var RemoteControllerCleanResult_Success_DEFAULT bool
View Source 
var RemoteControllerExitResult_Success_DEFAULT bool
View Source 
var RemoteControllerPingResult_Success_DEFAULT bool
View Source 
var RemoteControllerResumeMemberResult_Success_DEFAULT bool
View Source 
var RemoteControllerShutdownClusterResult_Success_DEFAULT bool
View Source 
var RemoteControllerShutdownMemberResult_Success_DEFAULT bool
View Source 
var RemoteControllerSuspendMemberResult_Success_DEFAULT bool
View Source 
var RemoteControllerTerminateClusterResult_Success_DEFAULT bool
View Source 
var RemoteControllerTerminateMemberResult_Success_DEFAULT bool

Functions

This section is empty.

Types

type Cluster 

type Cluster struct {
	ID string `thrift:"id,1" db:"id" json:"id"`
}

Attributes:

  • ID
var RemoteControllerCreateClusterResult_Success_DEFAULT *Cluster
var RemoteControllerMergeMemberToClusterResult_Success_DEFAULT *Cluster
var RemoteControllerSplitMemberFromClusterResult_Success_DEFAULT *Cluster

func NewCluster 

func NewCluster() *Cluster

func (*Cluster) GetID 

func (p *Cluster) GetID() string

func (*Cluster) Read 

func (p *Cluster) Read(iprot thrift.TProtocol) error

func (*Cluster) ReadField1 

func (p *Cluster) ReadField1(iprot thrift.TProtocol) error

func (*Cluster) String 

func (p *Cluster) String() string

func (*Cluster) Write 

func (p *Cluster) Write(oprot thrift.TProtocol) error

type Lang 

type Lang int64
const (
	Lang_JAVASCRIPT Lang = 1
	Lang_GROOVY     Lang = 2
	Lang_PYTHON     Lang = 3
	Lang_RUBY       Lang = 4
)

func LangFromString 

func LangFromString(s string) (Lang, error)

func LangPtr 

func LangPtr(v Lang) *Lang

func (Lang) MarshalText 

func (p Lang) MarshalText() ([]byte, error)

func (*Lang) Scan 

func (p *Lang) Scan(value interface{}) error

func (Lang) String 

func (p Lang) String() string

func (*Lang) UnmarshalText 

func (p *Lang) UnmarshalText(text []byte) error

func (*Lang) Value 

func (p *Lang) Value() (driver.Value, error)

type Member 

type Member struct {
	UUID string `thrift:"uuid,1" db:"uuid" json:"uuid"`
	Host string `thrift:"host,2" db:"host" json:"host"`
	Port int32  `thrift:"port,3" db:"port" json:"port"`
}

Attributes:

  • UUID
  • Host
  • Port
var RemoteControllerStartMemberResult_Success_DEFAULT *Member

func NewMember 

func NewMember() *Member

func (*Member) GetHost 

func (p *Member) GetHost() string

func (*Member) GetPort 

func (p *Member) GetPort() int32

func (*Member) GetUUID 

func (p *Member) GetUUID() string

func (*Member) Read 

func (p *Member) Read(iprot thrift.TProtocol) error

func (*Member) ReadField1 

func (p *Member) ReadField1(iprot thrift.TProtocol) error

func (*Member) ReadField2 

func (p *Member) ReadField2(iprot thrift.TProtocol) error

func (*Member) ReadField3 

func (p *Member) ReadField3(iprot thrift.TProtocol) error

func (*Member) String 

func (p *Member) String() string

func (*Member) Write 

func (p *Member) Write(oprot thrift.TProtocol) error

type RemoteController 

type RemoteController interface {
	Ping() (r bool, err error)
	Clean() (r bool, err error)
	Exit() (r bool, err error)
	// Parameters:
	//  - HzVersion
	//  - Xmlconfig
	CreateCluster(hzVersion string, xmlconfig string) (r *Cluster, err error)
	// Parameters:
	//  - ClusterId
	StartMember(clusterId string) (r *Member, err error)
	// Parameters:
	//  - ClusterId
	//  - MemberId
	ShutdownMember(clusterId string, memberId string) (r bool, err error)
	// Parameters:
	//  - ClusterId
	//  - MemberId
	TerminateMember(clusterId string, memberId string) (r bool, err error)
	// Parameters:
	//  - ClusterId
	//  - MemberId
	SuspendMember(clusterId string, memberId string) (r bool, err error)
	// Parameters:
	//  - ClusterId
	//  - MemberId
	ResumeMember(clusterId string, memberId string) (r bool, err error)
	// Parameters:
	//  - ClusterId
	ShutdownCluster(clusterId string) (r bool, err error)
	// Parameters:
	//  - ClusterId
	TerminateCluster(clusterId string) (r bool, err error)
	// Parameters:
	//  - MemberId
	SplitMemberFromCluster(memberId string) (r *Cluster, err error)
	// Parameters:
	//  - ClusterId
	//  - MemberId
	MergeMemberToCluster(clusterId string, memberId string) (r *Cluster, err error)
	// Parameters:
	//  - ClusterId
	//  - Script
	//  - Lang
	ExecuteOnController(clusterId string, script string, lang Lang) (r *Response, err error)
}

type RemoteControllerCleanArgs 

type RemoteControllerCleanArgs struct {
}

func NewRemoteControllerCleanArgs 

func NewRemoteControllerCleanArgs() *RemoteControllerCleanArgs

func (*RemoteControllerCleanArgs) Read 

func (p *RemoteControllerCleanArgs) Read(iprot thrift.TProtocol) error

func (*RemoteControllerCleanArgs) String 

func (p *RemoteControllerCleanArgs) String() string

func (*RemoteControllerCleanArgs) Write 

func (p *RemoteControllerCleanArgs) Write(oprot thrift.TProtocol) error

type RemoteControllerCleanResult 

type RemoteControllerCleanResult struct {
	Success *bool `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewRemoteControllerCleanResult 

func NewRemoteControllerCleanResult() *RemoteControllerCleanResult

func (*RemoteControllerCleanResult) GetSuccess 

func (p *RemoteControllerCleanResult) GetSuccess() bool

func (*RemoteControllerCleanResult) IsSetSuccess 

func (p *RemoteControllerCleanResult) IsSetSuccess() bool

func (*RemoteControllerCleanResult) Read 

func (p *RemoteControllerCleanResult) Read(iprot thrift.TProtocol) error

func (*RemoteControllerCleanResult) ReadField0 

func (p *RemoteControllerCleanResult) ReadField0(iprot thrift.TProtocol) error

func (*RemoteControllerCleanResult) String 

func (p *RemoteControllerCleanResult) String() string

func (*RemoteControllerCleanResult) Write 

func (p *RemoteControllerCleanResult) Write(oprot thrift.TProtocol) error

type RemoteControllerClient 

type RemoteControllerClient struct {
	Transport       thrift.TTransport
	ProtocolFactory thrift.TProtocolFactory
	InputProtocol   thrift.TProtocol
	OutputProtocol  thrift.TProtocol
	SeqId           int32
}

func NewRemoteControllerClient 

func NewRemoteControllerClient(hostPort string) (rc *RemoteControllerClient, err error)

func NewRemoteControllerClientFactory 

func NewRemoteControllerClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *RemoteControllerClient

func NewRemoteControllerClientProtocol 

func NewRemoteControllerClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *RemoteControllerClient

func (*RemoteControllerClient) Clean 

func (p *RemoteControllerClient) Clean() (r bool, err error)

func (*RemoteControllerClient) CreateCluster 

func (p *RemoteControllerClient) CreateCluster(hzVersion string, xmlconfig string) (r *Cluster, err error)

Parameters:

  • HzVersion
  • Xmlconfig

func (*RemoteControllerClient) ExecuteOnController 

func (p *RemoteControllerClient) ExecuteOnController(clusterId string, script string, lang Lang) (r *Response, err error)

Parameters:

  • ClusterId
  • Script
  • Lang

func (*RemoteControllerClient) Exit 

func (p *RemoteControllerClient) Exit() (r bool, err error)

func (*RemoteControllerClient) MergeMemberToCluster 

func (p *RemoteControllerClient) MergeMemberToCluster(clusterId string, memberId string) (r *Cluster, err error)

Parameters:

  • ClusterId
  • MemberId

func (*RemoteControllerClient) Ping 

func (p *RemoteControllerClient) Ping() (r bool, err error)

func (*RemoteControllerClient) ResumeMember 

func (p *RemoteControllerClient) ResumeMember(clusterId string, memberId string) (r bool, err error)

Parameters:

  • ClusterId
  • MemberId

func (*RemoteControllerClient) ShutdownCluster 

func (p *RemoteControllerClient) ShutdownCluster(clusterId string) (r bool, err error)

Parameters:

  • ClusterId

func (*RemoteControllerClient) ShutdownMember 

func (p *RemoteControllerClient) ShutdownMember(clusterId string, memberId string) (r bool, err error)

Parameters:

  • ClusterId
  • MemberId

func (*RemoteControllerClient) SplitMemberFromCluster 

func (p *RemoteControllerClient) SplitMemberFromCluster(memberId string) (r *Cluster, err error)

Parameters:

  • MemberId

func (*RemoteControllerClient) StartMember 

func (p *RemoteControllerClient) StartMember(clusterId string) (r *Member, err error)

Parameters:

  • ClusterId

func (*RemoteControllerClient) SuspendMember 

func (p *RemoteControllerClient) SuspendMember(clusterId string, memberId string) (r bool, err error)

Parameters:

  • ClusterId
  • MemberId

func (*RemoteControllerClient) TerminateCluster 

func (p *RemoteControllerClient) TerminateCluster(clusterId string) (r bool, err error)

Parameters:

  • ClusterId

func (*RemoteControllerClient) TerminateMember 

func (p *RemoteControllerClient) TerminateMember(clusterId string, memberId string) (r bool, err error)

Parameters:

  • ClusterId
  • MemberId

type RemoteControllerCreateClusterArgs 

type RemoteControllerCreateClusterArgs struct {
	HzVersion string `thrift:"hzVersion,1" db:"hzVersion" json:"hzVersion"`
	Xmlconfig string `thrift:"xmlconfig,2" db:"xmlconfig" json:"xmlconfig"`
}

Attributes:

  • HzVersion
  • Xmlconfig

func NewRemoteControllerCreateClusterArgs 

func NewRemoteControllerCreateClusterArgs() *RemoteControllerCreateClusterArgs

func (*RemoteControllerCreateClusterArgs) GetHzVersion 

func (p *RemoteControllerCreateClusterArgs) GetHzVersion() string

func (*RemoteControllerCreateClusterArgs) GetXmlconfig 

func (p *RemoteControllerCreateClusterArgs) GetXmlconfig() string

func (*RemoteControllerCreateClusterArgs) Read 

func (p *RemoteControllerCreateClusterArgs) Read(iprot thrift.TProtocol) error

func (*RemoteControllerCreateClusterArgs) ReadField1 

func (p *RemoteControllerCreateClusterArgs) ReadField1(iprot thrift.TProtocol) error

func (*RemoteControllerCreateClusterArgs) ReadField2 

func (p *RemoteControllerCreateClusterArgs) ReadField2(iprot thrift.TProtocol) error

func (*RemoteControllerCreateClusterArgs) String 

func (p *RemoteControllerCreateClusterArgs) String() string

func (*RemoteControllerCreateClusterArgs) Write 

func (p *RemoteControllerCreateClusterArgs) Write(oprot thrift.TProtocol) error

type RemoteControllerCreateClusterResult 

type RemoteControllerCreateClusterResult struct {
	Success         *Cluster         `thrift:"success,0" db:"success" json:"success,omitempty"`
	ServerException *ServerException `thrift:"serverException,1" db:"serverException" json:"serverException,omitempty"`
}

Attributes:

  • Success
  • ServerException

func NewRemoteControllerCreateClusterResult 

func NewRemoteControllerCreateClusterResult() *RemoteControllerCreateClusterResult

func (*RemoteControllerCreateClusterResult) GetServerException 

func (p *RemoteControllerCreateClusterResult) GetServerException() *ServerException

func (*RemoteControllerCreateClusterResult) GetSuccess 

func (p *RemoteControllerCreateClusterResult) GetSuccess() *Cluster

func (*RemoteControllerCreateClusterResult) IsSetServerException 

func (p *RemoteControllerCreateClusterResult) IsSetServerException() bool

func (*RemoteControllerCreateClusterResult) IsSetSuccess 

func (p *RemoteControllerCreateClusterResult) IsSetSuccess() bool

func (*RemoteControllerCreateClusterResult) Read 

func (p *RemoteControllerCreateClusterResult) Read(iprot thrift.TProtocol) error

func (*RemoteControllerCreateClusterResult) ReadField0 

func (p *RemoteControllerCreateClusterResult) ReadField0(iprot thrift.TProtocol) error

func (*RemoteControllerCreateClusterResult) ReadField1 

func (p *RemoteControllerCreateClusterResult) ReadField1(iprot thrift.TProtocol) error

func (*RemoteControllerCreateClusterResult) String 

func (p *RemoteControllerCreateClusterResult) String() string

func (*RemoteControllerCreateClusterResult) Write 

func (p *RemoteControllerCreateClusterResult) Write(oprot thrift.TProtocol) error

type RemoteControllerExecuteOnControllerArgs 

type RemoteControllerExecuteOnControllerArgs struct {
	ClusterId string `thrift:"clusterId,1" db:"clusterId" json:"clusterId"`
	Script    string `thrift:"script,2" db:"script" json:"script"`
	Lang      Lang   `thrift:"lang,3" db:"lang" json:"lang"`
}

Attributes:

  • ClusterId
  • Script
  • Lang

func NewRemoteControllerExecuteOnControllerArgs 

func NewRemoteControllerExecuteOnControllerArgs() *RemoteControllerExecuteOnControllerArgs

func (*RemoteControllerExecuteOnControllerArgs) GetClusterId 

func (p *RemoteControllerExecuteOnControllerArgs) GetClusterId() string

func (*RemoteControllerExecuteOnControllerArgs) GetLang 

func (p *RemoteControllerExecuteOnControllerArgs) GetLang() Lang

func (*RemoteControllerExecuteOnControllerArgs) GetScript 

func (p *RemoteControllerExecuteOnControllerArgs) GetScript() string

func (*RemoteControllerExecuteOnControllerArgs) Read 

func (p *RemoteControllerExecuteOnControllerArgs) Read(iprot thrift.TProtocol) error

func (*RemoteControllerExecuteOnControllerArgs) ReadField1 

func (p *RemoteControllerExecuteOnControllerArgs) ReadField1(iprot thrift.TProtocol) error

func (*RemoteControllerExecuteOnControllerArgs) ReadField2 

func (p *RemoteControllerExecuteOnControllerArgs) ReadField2(iprot thrift.TProtocol) error

func (*RemoteControllerExecuteOnControllerArgs) ReadField3 

func (p *RemoteControllerExecuteOnControllerArgs) ReadField3(iprot thrift.TProtocol) error

func (*RemoteControllerExecuteOnControllerArgs) String 

func (p *RemoteControllerExecuteOnControllerArgs) String() string

func (*RemoteControllerExecuteOnControllerArgs) Write 

func (p *RemoteControllerExecuteOnControllerArgs) Write(oprot thrift.TProtocol) error

type RemoteControllerExecuteOnControllerResult 

type RemoteControllerExecuteOnControllerResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewRemoteControllerExecuteOnControllerResult 

func NewRemoteControllerExecuteOnControllerResult() *RemoteControllerExecuteOnControllerResult

func (*RemoteControllerExecuteOnControllerResult) GetSuccess 

func (p *RemoteControllerExecuteOnControllerResult) GetSuccess() *Response

func (*RemoteControllerExecuteOnControllerResult) IsSetSuccess 

func (p *RemoteControllerExecuteOnControllerResult) IsSetSuccess() bool

func (*RemoteControllerExecuteOnControllerResult) Read 

func (p *RemoteControllerExecuteOnControllerResult) Read(iprot thrift.TProtocol) error

func (*RemoteControllerExecuteOnControllerResult) ReadField0 

func (p *RemoteControllerExecuteOnControllerResult) ReadField0(iprot thrift.TProtocol) error

func (*RemoteControllerExecuteOnControllerResult) String 

func (p *RemoteControllerExecuteOnControllerResult) String() string

func (*RemoteControllerExecuteOnControllerResult) Write 

func (p *RemoteControllerExecuteOnControllerResult) Write(oprot thrift.TProtocol) error

type RemoteControllerExitArgs 

type RemoteControllerExitArgs struct {
}

func NewRemoteControllerExitArgs 

func NewRemoteControllerExitArgs() *RemoteControllerExitArgs

func (*RemoteControllerExitArgs) Read 

func (p *RemoteControllerExitArgs) Read(iprot thrift.TProtocol) error

func (*RemoteControllerExitArgs) String 

func (p *RemoteControllerExitArgs) String() string

func (*RemoteControllerExitArgs) Write 

func (p *RemoteControllerExitArgs) Write(oprot thrift.TProtocol) error

type RemoteControllerExitResult 

type RemoteControllerExitResult struct {
	Success *bool `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewRemoteControllerExitResult 

func NewRemoteControllerExitResult() *RemoteControllerExitResult

func (*RemoteControllerExitResult) GetSuccess 

func (p *RemoteControllerExitResult) GetSuccess() bool

func (*RemoteControllerExitResult) IsSetSuccess 

func (p *RemoteControllerExitResult) IsSetSuccess() bool

func (*RemoteControllerExitResult) Read 

func (p *RemoteControllerExitResult) Read(iprot thrift.TProtocol) error

func (*RemoteControllerExitResult) ReadField0 

func (p *RemoteControllerExitResult) ReadField0(iprot thrift.TProtocol) error

func (*RemoteControllerExitResult) String 

func (p *RemoteControllerExitResult) String() string

func (*RemoteControllerExitResult) Write 

func (p *RemoteControllerExitResult) Write(oprot thrift.TProtocol) error

type RemoteControllerMergeMemberToClusterArgs 

type RemoteControllerMergeMemberToClusterArgs struct {
	ClusterId string `thrift:"clusterId,1" db:"clusterId" json:"clusterId"`
	MemberId  string `thrift:"memberId,2" db:"memberId" json:"memberId"`
}

Attributes:

  • ClusterId
  • MemberId

func NewRemoteControllerMergeMemberToClusterArgs 

func NewRemoteControllerMergeMemberToClusterArgs() *RemoteControllerMergeMemberToClusterArgs

func (*RemoteControllerMergeMemberToClusterArgs) GetClusterId 

func (p *RemoteControllerMergeMemberToClusterArgs) GetClusterId() string

func (*RemoteControllerMergeMemberToClusterArgs) GetMemberId 

func (p *RemoteControllerMergeMemberToClusterArgs) GetMemberId() string

func (*RemoteControllerMergeMemberToClusterArgs) Read 

func (p *RemoteControllerMergeMemberToClusterArgs) Read(iprot thrift.TProtocol) error

func (*RemoteControllerMergeMemberToClusterArgs) ReadField1 

func (p *RemoteControllerMergeMemberToClusterArgs) ReadField1(iprot thrift.TProtocol) error

func (*RemoteControllerMergeMemberToClusterArgs) ReadField2 

func (p *RemoteControllerMergeMemberToClusterArgs) ReadField2(iprot thrift.TProtocol) error

func (*RemoteControllerMergeMemberToClusterArgs) String 

func (p *RemoteControllerMergeMemberToClusterArgs) String() string

func (*RemoteControllerMergeMemberToClusterArgs) Write 

func (p *RemoteControllerMergeMemberToClusterArgs) Write(oprot thrift.TProtocol) error

type RemoteControllerMergeMemberToClusterResult 

type RemoteControllerMergeMemberToClusterResult struct {
	Success *Cluster `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewRemoteControllerMergeMemberToClusterResult 

func NewRemoteControllerMergeMemberToClusterResult() *RemoteControllerMergeMemberToClusterResult

func (*RemoteControllerMergeMemberToClusterResult) GetSuccess 

func (p *RemoteControllerMergeMemberToClusterResult) GetSuccess() *Cluster

func (*RemoteControllerMergeMemberToClusterResult) IsSetSuccess 

func (p *RemoteControllerMergeMemberToClusterResult) IsSetSuccess() bool

func (*RemoteControllerMergeMemberToClusterResult) Read 

func (p *RemoteControllerMergeMemberToClusterResult) Read(iprot thrift.TProtocol) error

func (*RemoteControllerMergeMemberToClusterResult) ReadField0 

func (p *RemoteControllerMergeMemberToClusterResult) ReadField0(iprot thrift.TProtocol) error

func (*RemoteControllerMergeMemberToClusterResult) String 

func (p *RemoteControllerMergeMemberToClusterResult) String() string

func (*RemoteControllerMergeMemberToClusterResult) Write 

func (p *RemoteControllerMergeMemberToClusterResult) Write(oprot thrift.TProtocol) error

type RemoteControllerPingArgs 

type RemoteControllerPingArgs struct {
}

func NewRemoteControllerPingArgs 

func NewRemoteControllerPingArgs() *RemoteControllerPingArgs

func (*RemoteControllerPingArgs) Read 

func (p *RemoteControllerPingArgs) Read(iprot thrift.TProtocol) error

func (*RemoteControllerPingArgs) String 

func (p *RemoteControllerPingArgs) String() string

func (*RemoteControllerPingArgs) Write 

func (p *RemoteControllerPingArgs) Write(oprot thrift.TProtocol) error

type RemoteControllerPingResult 

type RemoteControllerPingResult struct {
	Success *bool `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewRemoteControllerPingResult 

func NewRemoteControllerPingResult() *RemoteControllerPingResult

func (*RemoteControllerPingResult) GetSuccess 

func (p *RemoteControllerPingResult) GetSuccess() bool

func (*RemoteControllerPingResult) IsSetSuccess 

func (p *RemoteControllerPingResult) IsSetSuccess() bool

func (*RemoteControllerPingResult) Read 

func (p *RemoteControllerPingResult) Read(iprot thrift.TProtocol) error

func (*RemoteControllerPingResult) ReadField0 

func (p *RemoteControllerPingResult) ReadField0(iprot thrift.TProtocol) error

func (*RemoteControllerPingResult) String 

func (p *RemoteControllerPingResult) String() string

func (*RemoteControllerPingResult) Write 

func (p *RemoteControllerPingResult) Write(oprot thrift.TProtocol) error

type RemoteControllerProcessor 

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

func NewRemoteControllerProcessor 

func NewRemoteControllerProcessor(handler RemoteController) *RemoteControllerProcessor

func (*RemoteControllerProcessor) AddToProcessorMap 

func (p *RemoteControllerProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

func (*RemoteControllerProcessor) GetProcessorFunction 

func (p *RemoteControllerProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

func (*RemoteControllerProcessor) Process 

func (p *RemoteControllerProcessor) Process(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*RemoteControllerProcessor) ProcessorMap 

func (p *RemoteControllerProcessor) ProcessorMap() map[string]thrift.TProcessorFunction

type RemoteControllerResumeMemberArgs 

type RemoteControllerResumeMemberArgs struct {
	ClusterId string `thrift:"clusterId,1" db:"clusterId" json:"clusterId"`
	MemberId  string `thrift:"memberId,2" db:"memberId" json:"memberId"`
}

Attributes:

  • ClusterId
  • MemberId

func NewRemoteControllerResumeMemberArgs 

func NewRemoteControllerResumeMemberArgs() *RemoteControllerResumeMemberArgs

func (*RemoteControllerResumeMemberArgs) GetClusterId 

func (p *RemoteControllerResumeMemberArgs) GetClusterId() string

func (*RemoteControllerResumeMemberArgs) GetMemberId 

func (p *RemoteControllerResumeMemberArgs) GetMemberId() string

func (*RemoteControllerResumeMemberArgs) Read 

func (p *RemoteControllerResumeMemberArgs) Read(iprot thrift.TProtocol) error

func (*RemoteControllerResumeMemberArgs) ReadField1 

func (p *RemoteControllerResumeMemberArgs) ReadField1(iprot thrift.TProtocol) error

func (*RemoteControllerResumeMemberArgs) ReadField2 

func (p *RemoteControllerResumeMemberArgs) ReadField2(iprot thrift.TProtocol) error

func (*RemoteControllerResumeMemberArgs) String 

func (p *RemoteControllerResumeMemberArgs) String() string

func (*RemoteControllerResumeMemberArgs) Write 

func (p *RemoteControllerResumeMemberArgs) Write(oprot thrift.TProtocol) error

type RemoteControllerResumeMemberResult 

type RemoteControllerResumeMemberResult struct {
	Success *bool `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewRemoteControllerResumeMemberResult 

func NewRemoteControllerResumeMemberResult() *RemoteControllerResumeMemberResult

func (*RemoteControllerResumeMemberResult) GetSuccess 

func (p *RemoteControllerResumeMemberResult) GetSuccess() bool

func (*RemoteControllerResumeMemberResult) IsSetSuccess 

func (p *RemoteControllerResumeMemberResult) IsSetSuccess() bool

func (*RemoteControllerResumeMemberResult) Read 

func (p *RemoteControllerResumeMemberResult) Read(iprot thrift.TProtocol) error

func (*RemoteControllerResumeMemberResult) ReadField0 

func (p *RemoteControllerResumeMemberResult) ReadField0(iprot thrift.TProtocol) error

func (*RemoteControllerResumeMemberResult) String 

func (p *RemoteControllerResumeMemberResult) String() string

func (*RemoteControllerResumeMemberResult) Write 

func (p *RemoteControllerResumeMemberResult) Write(oprot thrift.TProtocol) error

type RemoteControllerShutdownClusterArgs 

type RemoteControllerShutdownClusterArgs struct {
	ClusterId string `thrift:"clusterId,1" db:"clusterId" json:"clusterId"`
}

Attributes:

  • ClusterId

func NewRemoteControllerShutdownClusterArgs 

func NewRemoteControllerShutdownClusterArgs() *RemoteControllerShutdownClusterArgs

func (*RemoteControllerShutdownClusterArgs) GetClusterId 

func (p *RemoteControllerShutdownClusterArgs) GetClusterId() string

func (*RemoteControllerShutdownClusterArgs) Read 

func (p *RemoteControllerShutdownClusterArgs) Read(iprot thrift.TProtocol) error

func (*RemoteControllerShutdownClusterArgs) ReadField1 

func (p *RemoteControllerShutdownClusterArgs) ReadField1(iprot thrift.TProtocol) error

func (*RemoteControllerShutdownClusterArgs) String 

func (p *RemoteControllerShutdownClusterArgs) String() string

func (*RemoteControllerShutdownClusterArgs) Write 

func (p *RemoteControllerShutdownClusterArgs) Write(oprot thrift.TProtocol) error

type RemoteControllerShutdownClusterResult 

type RemoteControllerShutdownClusterResult struct {
	Success *bool `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewRemoteControllerShutdownClusterResult 

func NewRemoteControllerShutdownClusterResult() *RemoteControllerShutdownClusterResult

func (*RemoteControllerShutdownClusterResult) GetSuccess 

func (p *RemoteControllerShutdownClusterResult) GetSuccess() bool

func (*RemoteControllerShutdownClusterResult) IsSetSuccess 

func (p *RemoteControllerShutdownClusterResult) IsSetSuccess() bool

func (*RemoteControllerShutdownClusterResult) Read 

func (p *RemoteControllerShutdownClusterResult) Read(iprot thrift.TProtocol) error

func (*RemoteControllerShutdownClusterResult) ReadField0 

func (p *RemoteControllerShutdownClusterResult) ReadField0(iprot thrift.TProtocol) error

func (*RemoteControllerShutdownClusterResult) String 

func (p *RemoteControllerShutdownClusterResult) String() string

func (*RemoteControllerShutdownClusterResult) Write 

func (p *RemoteControllerShutdownClusterResult) Write(oprot thrift.TProtocol) error

type RemoteControllerShutdownMemberArgs 

type RemoteControllerShutdownMemberArgs struct {
	ClusterId string `thrift:"clusterId,1" db:"clusterId" json:"clusterId"`
	MemberId  string `thrift:"memberId,2" db:"memberId" json:"memberId"`
}

Attributes:

  • ClusterId
  • MemberId

func NewRemoteControllerShutdownMemberArgs 

func NewRemoteControllerShutdownMemberArgs() *RemoteControllerShutdownMemberArgs

func (*RemoteControllerShutdownMemberArgs) GetClusterId 

func (p *RemoteControllerShutdownMemberArgs) GetClusterId() string

func (*RemoteControllerShutdownMemberArgs) GetMemberId 

func (p *RemoteControllerShutdownMemberArgs) GetMemberId() string

func (*RemoteControllerShutdownMemberArgs) Read 

func (p *RemoteControllerShutdownMemberArgs) Read(iprot thrift.TProtocol) error

func (*RemoteControllerShutdownMemberArgs) ReadField1 

func (p *RemoteControllerShutdownMemberArgs) ReadField1(iprot thrift.TProtocol) error

func (*RemoteControllerShutdownMemberArgs) ReadField2 

func (p *RemoteControllerShutdownMemberArgs) ReadField2(iprot thrift.TProtocol) error

func (*RemoteControllerShutdownMemberArgs) String 

func (p *RemoteControllerShutdownMemberArgs) String() string

func (*RemoteControllerShutdownMemberArgs) Write 

func (p *RemoteControllerShutdownMemberArgs) Write(oprot thrift.TProtocol) error

type RemoteControllerShutdownMemberResult 

type RemoteControllerShutdownMemberResult struct {
	Success *bool `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewRemoteControllerShutdownMemberResult 

func NewRemoteControllerShutdownMemberResult() *RemoteControllerShutdownMemberResult

func (*RemoteControllerShutdownMemberResult) GetSuccess 

func (p *RemoteControllerShutdownMemberResult) GetSuccess() bool

func (*RemoteControllerShutdownMemberResult) IsSetSuccess 

func (p *RemoteControllerShutdownMemberResult) IsSetSuccess() bool

func (*RemoteControllerShutdownMemberResult) Read 

func (p *RemoteControllerShutdownMemberResult) Read(iprot thrift.TProtocol) error

func (*RemoteControllerShutdownMemberResult) ReadField0 

func (p *RemoteControllerShutdownMemberResult) ReadField0(iprot thrift.TProtocol) error

func (*RemoteControllerShutdownMemberResult) String 

func (p *RemoteControllerShutdownMemberResult) String() string

func (*RemoteControllerShutdownMemberResult) Write 

func (p *RemoteControllerShutdownMemberResult) Write(oprot thrift.TProtocol) error

type RemoteControllerSplitMemberFromClusterArgs 

type RemoteControllerSplitMemberFromClusterArgs struct {
	MemberId string `thrift:"memberId,1" db:"memberId" json:"memberId"`
}

Attributes:

  • MemberId

func NewRemoteControllerSplitMemberFromClusterArgs 

func NewRemoteControllerSplitMemberFromClusterArgs() *RemoteControllerSplitMemberFromClusterArgs

func (*RemoteControllerSplitMemberFromClusterArgs) GetMemberId 

func (p *RemoteControllerSplitMemberFromClusterArgs) GetMemberId() string

func (*RemoteControllerSplitMemberFromClusterArgs) Read 

func (p *RemoteControllerSplitMemberFromClusterArgs) Read(iprot thrift.TProtocol) error

func (*RemoteControllerSplitMemberFromClusterArgs) ReadField1 

func (p *RemoteControllerSplitMemberFromClusterArgs) ReadField1(iprot thrift.TProtocol) error

func (*RemoteControllerSplitMemberFromClusterArgs) String 

func (p *RemoteControllerSplitMemberFromClusterArgs) String() string

func (*RemoteControllerSplitMemberFromClusterArgs) Write 

func (p *RemoteControllerSplitMemberFromClusterArgs) Write(oprot thrift.TProtocol) error

type RemoteControllerSplitMemberFromClusterResult 

type RemoteControllerSplitMemberFromClusterResult struct {
	Success *Cluster `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewRemoteControllerSplitMemberFromClusterResult 

func NewRemoteControllerSplitMemberFromClusterResult() *RemoteControllerSplitMemberFromClusterResult

func (*RemoteControllerSplitMemberFromClusterResult) GetSuccess 

func (p *RemoteControllerSplitMemberFromClusterResult) GetSuccess() *Cluster

func (*RemoteControllerSplitMemberFromClusterResult) IsSetSuccess 

func (p *RemoteControllerSplitMemberFromClusterResult) IsSetSuccess() bool

func (*RemoteControllerSplitMemberFromClusterResult) Read 

func (p *RemoteControllerSplitMemberFromClusterResult) Read(iprot thrift.TProtocol) error

func (*RemoteControllerSplitMemberFromClusterResult) ReadField0 

func (p *RemoteControllerSplitMemberFromClusterResult) ReadField0(iprot thrift.TProtocol) error

func (*RemoteControllerSplitMemberFromClusterResult) String 

func (p *RemoteControllerSplitMemberFromClusterResult) String() string

func (*RemoteControllerSplitMemberFromClusterResult) Write 

func (p *RemoteControllerSplitMemberFromClusterResult) Write(oprot thrift.TProtocol) error

type RemoteControllerStartMemberArgs 

type RemoteControllerStartMemberArgs struct {
	ClusterId string `thrift:"clusterId,1" db:"clusterId" json:"clusterId"`
}

Attributes:

  • ClusterId

func NewRemoteControllerStartMemberArgs 

func NewRemoteControllerStartMemberArgs() *RemoteControllerStartMemberArgs

func (*RemoteControllerStartMemberArgs) GetClusterId 

func (p *RemoteControllerStartMemberArgs) GetClusterId() string

func (*RemoteControllerStartMemberArgs) Read 

func (p *RemoteControllerStartMemberArgs) Read(iprot thrift.TProtocol) error

func (*RemoteControllerStartMemberArgs) ReadField1 

func (p *RemoteControllerStartMemberArgs) ReadField1(iprot thrift.TProtocol) error

func (*RemoteControllerStartMemberArgs) String 

func (p *RemoteControllerStartMemberArgs) String() string

func (*RemoteControllerStartMemberArgs) Write 

func (p *RemoteControllerStartMemberArgs) Write(oprot thrift.TProtocol) error

type RemoteControllerStartMemberResult 

type RemoteControllerStartMemberResult struct {
	Success         *Member          `thrift:"success,0" db:"success" json:"success,omitempty"`
	ServerException *ServerException `thrift:"serverException,1" db:"serverException" json:"serverException,omitempty"`
}

Attributes:

  • Success
  • ServerException

func NewRemoteControllerStartMemberResult 

func NewRemoteControllerStartMemberResult() *RemoteControllerStartMemberResult

func (*RemoteControllerStartMemberResult) GetServerException 

func (p *RemoteControllerStartMemberResult) GetServerException() *ServerException

func (*RemoteControllerStartMemberResult) GetSuccess 

func (p *RemoteControllerStartMemberResult) GetSuccess() *Member

func (*RemoteControllerStartMemberResult) IsSetServerException 

func (p *RemoteControllerStartMemberResult) IsSetServerException() bool

func (*RemoteControllerStartMemberResult) IsSetSuccess 

func (p *RemoteControllerStartMemberResult) IsSetSuccess() bool

func (*RemoteControllerStartMemberResult) Read 

func (p *RemoteControllerStartMemberResult) Read(iprot thrift.TProtocol) error

func (*RemoteControllerStartMemberResult) ReadField0 

func (p *RemoteControllerStartMemberResult) ReadField0(iprot thrift.TProtocol) error

func (*RemoteControllerStartMemberResult) ReadField1 

func (p *RemoteControllerStartMemberResult) ReadField1(iprot thrift.TProtocol) error

func (*RemoteControllerStartMemberResult) String 

func (p *RemoteControllerStartMemberResult) String() string

func (*RemoteControllerStartMemberResult) Write 

func (p *RemoteControllerStartMemberResult) Write(oprot thrift.TProtocol) error

type RemoteControllerSuspendMemberArgs 

type RemoteControllerSuspendMemberArgs struct {
	ClusterId string `thrift:"clusterId,1" db:"clusterId" json:"clusterId"`
	MemberId  string `thrift:"memberId,2" db:"memberId" json:"memberId"`
}

Attributes:

  • ClusterId
  • MemberId

func NewRemoteControllerSuspendMemberArgs 

func NewRemoteControllerSuspendMemberArgs() *RemoteControllerSuspendMemberArgs

func (*RemoteControllerSuspendMemberArgs) GetClusterId 

func (p *RemoteControllerSuspendMemberArgs) GetClusterId() string

func (*RemoteControllerSuspendMemberArgs) GetMemberId 

func (p *RemoteControllerSuspendMemberArgs) GetMemberId() string

func (*RemoteControllerSuspendMemberArgs) Read 

func (p *RemoteControllerSuspendMemberArgs) Read(iprot thrift.TProtocol) error

func (*RemoteControllerSuspendMemberArgs) ReadField1 

func (p *RemoteControllerSuspendMemberArgs) ReadField1(iprot thrift.TProtocol) error

func (*RemoteControllerSuspendMemberArgs) ReadField2 

func (p *RemoteControllerSuspendMemberArgs) ReadField2(iprot thrift.TProtocol) error

func (*RemoteControllerSuspendMemberArgs) String 

func (p *RemoteControllerSuspendMemberArgs) String() string

func (*RemoteControllerSuspendMemberArgs) Write 

func (p *RemoteControllerSuspendMemberArgs) Write(oprot thrift.TProtocol) error

type RemoteControllerSuspendMemberResult 

type RemoteControllerSuspendMemberResult struct {
	Success *bool `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewRemoteControllerSuspendMemberResult 

func NewRemoteControllerSuspendMemberResult() *RemoteControllerSuspendMemberResult

func (*RemoteControllerSuspendMemberResult) GetSuccess 

func (p *RemoteControllerSuspendMemberResult) GetSuccess() bool

func (*RemoteControllerSuspendMemberResult) IsSetSuccess 

func (p *RemoteControllerSuspendMemberResult) IsSetSuccess() bool

func (*RemoteControllerSuspendMemberResult) Read 

func (p *RemoteControllerSuspendMemberResult) Read(iprot thrift.TProtocol) error

func (*RemoteControllerSuspendMemberResult) ReadField0 

func (p *RemoteControllerSuspendMemberResult) ReadField0(iprot thrift.TProtocol) error

func (*RemoteControllerSuspendMemberResult) String 

func (p *RemoteControllerSuspendMemberResult) String() string

func (*RemoteControllerSuspendMemberResult) Write 

func (p *RemoteControllerSuspendMemberResult) Write(oprot thrift.TProtocol) error

type RemoteControllerTerminateClusterArgs 

type RemoteControllerTerminateClusterArgs struct {
	ClusterId string `thrift:"clusterId,1" db:"clusterId" json:"clusterId"`
}

Attributes:

  • ClusterId

func NewRemoteControllerTerminateClusterArgs 

func NewRemoteControllerTerminateClusterArgs() *RemoteControllerTerminateClusterArgs

func (*RemoteControllerTerminateClusterArgs) GetClusterId 

func (p *RemoteControllerTerminateClusterArgs) GetClusterId() string

func (*RemoteControllerTerminateClusterArgs) Read 

func (p *RemoteControllerTerminateClusterArgs) Read(iprot thrift.TProtocol) error

func (*RemoteControllerTerminateClusterArgs) ReadField1 

func (p *RemoteControllerTerminateClusterArgs) ReadField1(iprot thrift.TProtocol) error

func (*RemoteControllerTerminateClusterArgs) String 

func (p *RemoteControllerTerminateClusterArgs) String() string

func (*RemoteControllerTerminateClusterArgs) Write 

func (p *RemoteControllerTerminateClusterArgs) Write(oprot thrift.TProtocol) error

type RemoteControllerTerminateClusterResult 

type RemoteControllerTerminateClusterResult struct {
	Success *bool `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewRemoteControllerTerminateClusterResult 

func NewRemoteControllerTerminateClusterResult() *RemoteControllerTerminateClusterResult

func (*RemoteControllerTerminateClusterResult) GetSuccess 

func (p *RemoteControllerTerminateClusterResult) GetSuccess() bool

func (*RemoteControllerTerminateClusterResult) IsSetSuccess 

func (p *RemoteControllerTerminateClusterResult) IsSetSuccess() bool

func (*RemoteControllerTerminateClusterResult) Read 

func (p *RemoteControllerTerminateClusterResult) Read(iprot thrift.TProtocol) error

func (*RemoteControllerTerminateClusterResult) ReadField0 

func (p *RemoteControllerTerminateClusterResult) ReadField0(iprot thrift.TProtocol) error

func (*RemoteControllerTerminateClusterResult) String 

func (p *RemoteControllerTerminateClusterResult) String() string

func (*RemoteControllerTerminateClusterResult) Write 

func (p *RemoteControllerTerminateClusterResult) Write(oprot thrift.TProtocol) error

type RemoteControllerTerminateMemberArgs 

type RemoteControllerTerminateMemberArgs struct {
	ClusterId string `thrift:"clusterId,1" db:"clusterId" json:"clusterId"`
	MemberId  string `thrift:"memberId,2" db:"memberId" json:"memberId"`
}

Attributes:

  • ClusterId
  • MemberId

func NewRemoteControllerTerminateMemberArgs 

func NewRemoteControllerTerminateMemberArgs() *RemoteControllerTerminateMemberArgs

func (*RemoteControllerTerminateMemberArgs) GetClusterId 

func (p *RemoteControllerTerminateMemberArgs) GetClusterId() string

func (*RemoteControllerTerminateMemberArgs) GetMemberId 

func (p *RemoteControllerTerminateMemberArgs) GetMemberId() string

func (*RemoteControllerTerminateMemberArgs) Read 

func (p *RemoteControllerTerminateMemberArgs) Read(iprot thrift.TProtocol) error

func (*RemoteControllerTerminateMemberArgs) ReadField1 

func (p *RemoteControllerTerminateMemberArgs) ReadField1(iprot thrift.TProtocol) error

func (*RemoteControllerTerminateMemberArgs) ReadField2 

func (p *RemoteControllerTerminateMemberArgs) ReadField2(iprot thrift.TProtocol) error

func (*RemoteControllerTerminateMemberArgs) String 

func (p *RemoteControllerTerminateMemberArgs) String() string

func (*RemoteControllerTerminateMemberArgs) Write 

func (p *RemoteControllerTerminateMemberArgs) Write(oprot thrift.TProtocol) error

type RemoteControllerTerminateMemberResult 

type RemoteControllerTerminateMemberResult struct {
	Success *bool `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewRemoteControllerTerminateMemberResult 

func NewRemoteControllerTerminateMemberResult() *RemoteControllerTerminateMemberResult

func (*RemoteControllerTerminateMemberResult) GetSuccess 

func (p *RemoteControllerTerminateMemberResult) GetSuccess() bool

func (*RemoteControllerTerminateMemberResult) IsSetSuccess 

func (p *RemoteControllerTerminateMemberResult) IsSetSuccess() bool

func (*RemoteControllerTerminateMemberResult) Read 

func (p *RemoteControllerTerminateMemberResult) Read(iprot thrift.TProtocol) error

func (*RemoteControllerTerminateMemberResult) ReadField0 

func (p *RemoteControllerTerminateMemberResult) ReadField0(iprot thrift.TProtocol) error

func (*RemoteControllerTerminateMemberResult) String 

func (p *RemoteControllerTerminateMemberResult) String() string

func (*RemoteControllerTerminateMemberResult) Write 

func (p *RemoteControllerTerminateMemberResult) Write(oprot thrift.TProtocol) error

type Response 

type Response struct {
	Success bool   `thrift:"success,1" db:"success" json:"success"`
	Message string `thrift:"message,2" db:"message" json:"message"`
	Result_ []byte `thrift:"result,3" db:"result" json:"result"`
}

Attributes:

  • Success
  • Message
  • Result_
var RemoteControllerExecuteOnControllerResult_Success_DEFAULT *Response

func NewResponse 

func NewResponse() *Response

func (*Response) GetMessage 

func (p *Response) GetMessage() string

func (*Response) GetResult_ 

func (p *Response) GetResult_() []byte

func (*Response) GetSuccess 

func (p *Response) GetSuccess() bool

func (*Response) Read 

func (p *Response) Read(iprot thrift.TProtocol) error

func (*Response) ReadField1 

func (p *Response) ReadField1(iprot thrift.TProtocol) error

func (*Response) ReadField2 

func (p *Response) ReadField2(iprot thrift.TProtocol) error

func (*Response) ReadField3 

func (p *Response) ReadField3(iprot thrift.TProtocol) error

func (*Response) String 

func (p *Response) String() string

func (*Response) Write 

func (p *Response) Write(oprot thrift.TProtocol) error

type ServerException 

type ServerException struct {
	Message string `thrift:"message,1" db:"message" json:"message"`
}

Attributes:

  • Message
var RemoteControllerCreateClusterResult_ServerException_DEFAULT *ServerException
var RemoteControllerStartMemberResult_ServerException_DEFAULT *ServerException

func NewServerException 

func NewServerException() *ServerException

func (*ServerException) Error 

func (p *ServerException) Error() string

func (*ServerException) GetMessage 

func (p *ServerException) GetMessage() string

func (*ServerException) Read 

func (p *ServerException) Read(iprot thrift.TProtocol) error

func (*ServerException) ReadField1 

func (p *ServerException) ReadField1(iprot thrift.TProtocol) error

func (*ServerException) String 

func (p *ServerException) String() string

func (*ServerException) Write 

func (p *ServerException) Write(oprot thrift.TProtocol) error

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.