Versions in this module Expand all Collapse all v1 v1.2.1 Nov 9, 2021 Changes in this version + const DefaultClusterName + const DefaultPort + const EnvDisableNonsmart + const EnvDisableSmart + const EnvEnableLeakCheck + const EnvEnableSSL + const EnvEnableTraceLogging + const EnvHzVersion + const EnvMemberCount + const EnvWarmupCount + const SamplePortableClassID + const SamplePortableFactoryID + var RemoteControllerCleanResult_Success_DEFAULT bool + var RemoteControllerExitResult_Success_DEFAULT bool + var RemoteControllerPingResult_Success_DEFAULT bool + var RemoteControllerResumeMemberResult_Success_DEFAULT bool + var RemoteControllerShutdownClusterResult_Success_DEFAULT bool + var RemoteControllerShutdownMemberResult_Success_DEFAULT bool + var RemoteControllerSuspendMemberResult_Success_DEFAULT bool + var RemoteControllerTerminateClusterResult_Success_DEFAULT bool + var RemoteControllerTerminateMemberResult_Success_DEFAULT bool + func AssertEquals(t *testing.T, target, value interface{}) + func Benchmarker(b *testing.B, f func(b *testing.B, config *hz.Config)) + func BenchmarkerWithConfigBuilder(b *testing.B, configCallback func(*hz.Config), ...) + func Eventually(t *testing.T, condition func() bool, msgAndArgs ...interface{}) + func GetClientMapWithConfig(mapName string, config *hz.Config) (*hz.Client, *hz.Map) + func GetClientPNCounterWithConfig(name string, config *hz.Config) (*hz.Client, *hz.PNCounter) + func GetClientSetWithConfig(setName string, config *hz.Config) (*hz.Client, *hz.Set) + func HzVersion() string + func LeakCheckEnabled() bool + func ListTester(t *testing.T, f func(t *testing.T, l *hz.List)) + func ListTesterWithConfigAndName(t *testing.T, listName func() string, cbCallback func(*hz.Config), ...) + func MapBenchmarker(t *testing.B, fixture func(m *hz.Map), f func(t *testing.B, m *hz.Map)) + func MapBenchmarkerWithConfigAndName(b *testing.B, makeMapName func() string, cbCallback func(config *hz.Config), ...) + func MapBenchmarkerWithConfigBuilder(t *testing.B, cbCallback func(*hz.Config), fixture func(m *hz.Map), ...) + func MapTester(t *testing.T, f func(t *testing.T, m *hz.Map)) + func MapTesterWithConfig(t *testing.T, configCallback func(*hz.Config), f func(t *testing.T, m *hz.Map)) + func MapTesterWithConfigAndName(t *testing.T, makeMapName func() string, configCallback func(*hz.Config), ...) + func MemberCount() int + func Must(err error) + func MustBool(value bool, err error) bool + func MustClient(client *hz.Client, err error) *hz.Client + func MustValue(value interface{}, err error) interface + func Never(t *testing.T, condition func() bool, msgAndArgs ...interface{}) + func NewUniqueObjectName(service string) string + func NonSmartEnabled() bool + func PNCounterTester(t *testing.T, f func(t *testing.T, pn *hz.PNCounter)) + func PNCounterTesterWithConfig(t *testing.T, configCallback func(*hz.Config), ...) + func PNCounterTesterWithConfigAndName(t *testing.T, makeName func() string, configCallback func(*hz.Config), ...) + func QueueTester(t *testing.T, f func(t *testing.T, q *hz.Queue)) + func QueueTesterWithConfigAndName(t *testing.T, queueName func() string, configCallback func(*hz.Config), ...) + func ReplicatedMapTester(t *testing.T, f func(t *testing.T, m *hz.ReplicatedMap)) + func ReplicatedMapTesterWithConfig(t *testing.T, configCallback func(*hz.Config), ...) + func ReplicatedMapTesterWithConfigAndName(t *testing.T, makeMapName func() string, cbCallback func(cb *hz.Config), ...) + func SSLEnabled() bool + func SetTester(t *testing.T, f func(t *testing.T, s *hz.Set)) + func SetTesterWithConfig(t *testing.T, configCallback func(*hz.Config), f func(t *testing.T, s *hz.Set)) + func SetTesterWithConfigAndName(t *testing.T, makeName func() string, configCallback func(*hz.Config), ...) + func SkipIf(t *testing.T, conditions string) + func SmartEnabled() bool + func Tester(t *testing.T, f func(t *testing.T, client *hz.Client)) + func TesterWithConfigBuilder(t *testing.T, cbCallback func(config *hz.Config), ...) + func TopicTester(t *testing.T, f func(t *testing.T, tp *hz.Topic)) + func TopicTesterWithConfigAndName(t *testing.T, makeName func() string, cbCallback func(*hz.Config), ...) + func TraceLoggingEnabled() bool + func WaitEventually(t *testing.T, wg *sync.WaitGroup) + func WaitEventuallyWithTimeout(t *testing.T, wg *sync.WaitGroup, timeout time.Duration) + type Cluster struct + ID string + var RemoteControllerCreateClusterKeepClusterNameResult_Success_DEFAULT *Cluster + var RemoteControllerCreateClusterResult_Success_DEFAULT *Cluster + var RemoteControllerMergeMemberToClusterResult_Success_DEFAULT *Cluster + var RemoteControllerSplitMemberFromClusterResult_Success_DEFAULT *Cluster + func NewCluster() *Cluster + func (p *Cluster) Equals(other *Cluster) bool + func (p *Cluster) GetID() string + func (p *Cluster) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *Cluster) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *Cluster) String() string + func (p *Cluster) Write(ctx context.Context, oprot thrift.TProtocol) error + type Lang int64 + const Lang_GROOVY + const Lang_JAVASCRIPT + const Lang_PYTHON + const Lang_RUBY + func LangFromString(s string) (Lang, error) + func LangPtr(v Lang) *Lang + func (p *Lang) Scan(value interface{}) error + func (p *Lang) UnmarshalText(text []byte) error + func (p *Lang) Value() (driver.Value, error) + func (p Lang) MarshalText() ([]byte, error) + func (p Lang) String() string + type Member struct + Host string + Port int32 + UUID string + var RemoteControllerStartMemberResult_Success_DEFAULT *Member + func NewMember() *Member + func (p *Member) Equals(other *Member) bool + func (p *Member) GetHost() string + func (p *Member) GetPort() int32 + func (p *Member) GetUUID() string + func (p *Member) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *Member) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *Member) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *Member) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *Member) String() string + func (p *Member) Write(ctx context.Context, oprot thrift.TProtocol) error + type RemoteController interface + Clean func(ctx context.Context) (_r bool, _err error) + CreateCluster func(ctx context.Context, hzVersion string, xmlconfig string) (_r *Cluster, _err error) + CreateClusterKeepClusterName func(ctx context.Context, hzVersion string, xmlconfig string) (_r *Cluster, _err error) + ExecuteOnController func(ctx context.Context, clusterId string, script string, lang Lang) (_r *Response, _err error) + Exit func(ctx context.Context) (_r bool, _err error) + MergeMemberToCluster func(ctx context.Context, clusterId string, memberId string) (_r *Cluster, _err error) + Ping func(ctx context.Context) (_r bool, _err error) + ResumeMember func(ctx context.Context, clusterId string, memberId string) (_r bool, _err error) + ShutdownCluster func(ctx context.Context, clusterId string) (_r bool, _err error) + ShutdownMember func(ctx context.Context, clusterId string, memberId string) (_r bool, _err error) + SplitMemberFromCluster func(ctx context.Context, memberId string) (_r *Cluster, _err error) + StartMember func(ctx context.Context, clusterId string) (_r *Member, _err error) + SuspendMember func(ctx context.Context, clusterId string, memberId string) (_r bool, _err error) + TerminateCluster func(ctx context.Context, clusterId string) (_r bool, _err error) + TerminateMember func(ctx context.Context, clusterId string, memberId string) (_r bool, _err error) + type RemoteControllerCleanArgs struct + func NewRemoteControllerCleanArgs() *RemoteControllerCleanArgs + func (p *RemoteControllerCleanArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerCleanArgs) String() string + func (p *RemoteControllerCleanArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type RemoteControllerCleanResult struct + Success *bool + func NewRemoteControllerCleanResult() *RemoteControllerCleanResult + func (p *RemoteControllerCleanResult) GetSuccess() bool + func (p *RemoteControllerCleanResult) IsSetSuccess() bool + func (p *RemoteControllerCleanResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerCleanResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerCleanResult) String() string + func (p *RemoteControllerCleanResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type RemoteControllerClient struct + func CreateDefaultRemoteController() *RemoteControllerClient + func CreateRemoteController(addr string) *RemoteControllerClient + func NewRemoteControllerClient(c thrift.TClient) *RemoteControllerClient + func NewRemoteControllerClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *RemoteControllerClient + func NewRemoteControllerClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *RemoteControllerClient + func (p *RemoteControllerClient) Clean(ctx context.Context) (_r bool, _err error) + func (p *RemoteControllerClient) Client_() thrift.TClient + func (p *RemoteControllerClient) CreateCluster(ctx context.Context, hzVersion string, xmlconfig string) (_r *Cluster, _err error) + func (p *RemoteControllerClient) CreateClusterKeepClusterName(ctx context.Context, hzVersion string, xmlconfig string) (_r *Cluster, _err error) + func (p *RemoteControllerClient) ExecuteOnController(ctx context.Context, clusterId string, script string, lang Lang) (_r *Response, _err error) + func (p *RemoteControllerClient) Exit(ctx context.Context) (_r bool, _err error) + func (p *RemoteControllerClient) LastResponseMeta_() thrift.ResponseMeta + func (p *RemoteControllerClient) MergeMemberToCluster(ctx context.Context, clusterId string, memberId string) (_r *Cluster, _err error) + func (p *RemoteControllerClient) Ping(ctx context.Context) (_r bool, _err error) + func (p *RemoteControllerClient) ResumeMember(ctx context.Context, clusterId string, memberId string) (_r bool, _err error) + func (p *RemoteControllerClient) SetLastResponseMeta_(meta thrift.ResponseMeta) + func (p *RemoteControllerClient) ShutdownCluster(ctx context.Context, clusterId string) (_r bool, _err error) + func (p *RemoteControllerClient) ShutdownMember(ctx context.Context, clusterId string, memberId string) (_r bool, _err error) + func (p *RemoteControllerClient) SplitMemberFromCluster(ctx context.Context, memberId string) (_r *Cluster, _err error) + func (p *RemoteControllerClient) StartMember(ctx context.Context, clusterId string) (_r *Member, _err error) + func (p *RemoteControllerClient) SuspendMember(ctx context.Context, clusterId string, memberId string) (_r bool, _err error) + func (p *RemoteControllerClient) TerminateCluster(ctx context.Context, clusterId string) (_r bool, _err error) + func (p *RemoteControllerClient) TerminateMember(ctx context.Context, clusterId string, memberId string) (_r bool, _err error) + type RemoteControllerCreateClusterArgs struct + HzVersion string + Xmlconfig string + func NewRemoteControllerCreateClusterArgs() *RemoteControllerCreateClusterArgs + func (p *RemoteControllerCreateClusterArgs) GetHzVersion() string + func (p *RemoteControllerCreateClusterArgs) GetXmlconfig() string + func (p *RemoteControllerCreateClusterArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerCreateClusterArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerCreateClusterArgs) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerCreateClusterArgs) String() string + func (p *RemoteControllerCreateClusterArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type RemoteControllerCreateClusterKeepClusterNameArgs struct + HzVersion string + Xmlconfig string + func NewRemoteControllerCreateClusterKeepClusterNameArgs() *RemoteControllerCreateClusterKeepClusterNameArgs + func (p *RemoteControllerCreateClusterKeepClusterNameArgs) GetHzVersion() string + func (p *RemoteControllerCreateClusterKeepClusterNameArgs) GetXmlconfig() string + func (p *RemoteControllerCreateClusterKeepClusterNameArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerCreateClusterKeepClusterNameArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerCreateClusterKeepClusterNameArgs) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerCreateClusterKeepClusterNameArgs) String() string + func (p *RemoteControllerCreateClusterKeepClusterNameArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type RemoteControllerCreateClusterKeepClusterNameResult struct + ServerException *ServerException + Success *Cluster + func NewRemoteControllerCreateClusterKeepClusterNameResult() *RemoteControllerCreateClusterKeepClusterNameResult + func (p *RemoteControllerCreateClusterKeepClusterNameResult) GetServerException() *ServerException + func (p *RemoteControllerCreateClusterKeepClusterNameResult) GetSuccess() *Cluster + func (p *RemoteControllerCreateClusterKeepClusterNameResult) IsSetServerException() bool + func (p *RemoteControllerCreateClusterKeepClusterNameResult) IsSetSuccess() bool + func (p *RemoteControllerCreateClusterKeepClusterNameResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerCreateClusterKeepClusterNameResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerCreateClusterKeepClusterNameResult) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerCreateClusterKeepClusterNameResult) String() string + func (p *RemoteControllerCreateClusterKeepClusterNameResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type RemoteControllerCreateClusterResult struct + ServerException *ServerException + Success *Cluster + func NewRemoteControllerCreateClusterResult() *RemoteControllerCreateClusterResult + func (p *RemoteControllerCreateClusterResult) GetServerException() *ServerException + func (p *RemoteControllerCreateClusterResult) GetSuccess() *Cluster + func (p *RemoteControllerCreateClusterResult) IsSetServerException() bool + func (p *RemoteControllerCreateClusterResult) IsSetSuccess() bool + func (p *RemoteControllerCreateClusterResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerCreateClusterResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerCreateClusterResult) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerCreateClusterResult) String() string + func (p *RemoteControllerCreateClusterResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type RemoteControllerExecuteOnControllerArgs struct + ClusterId string + Lang Lang + Script string + func NewRemoteControllerExecuteOnControllerArgs() *RemoteControllerExecuteOnControllerArgs + func (p *RemoteControllerExecuteOnControllerArgs) GetClusterId() string + func (p *RemoteControllerExecuteOnControllerArgs) GetLang() Lang + func (p *RemoteControllerExecuteOnControllerArgs) GetScript() string + func (p *RemoteControllerExecuteOnControllerArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerExecuteOnControllerArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerExecuteOnControllerArgs) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerExecuteOnControllerArgs) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerExecuteOnControllerArgs) String() string + func (p *RemoteControllerExecuteOnControllerArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type RemoteControllerExecuteOnControllerResult struct + Success *Response + func NewRemoteControllerExecuteOnControllerResult() *RemoteControllerExecuteOnControllerResult + func (p *RemoteControllerExecuteOnControllerResult) GetSuccess() *Response + func (p *RemoteControllerExecuteOnControllerResult) IsSetSuccess() bool + func (p *RemoteControllerExecuteOnControllerResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerExecuteOnControllerResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerExecuteOnControllerResult) String() string + func (p *RemoteControllerExecuteOnControllerResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type RemoteControllerExitArgs struct + func NewRemoteControllerExitArgs() *RemoteControllerExitArgs + func (p *RemoteControllerExitArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerExitArgs) String() string + func (p *RemoteControllerExitArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type RemoteControllerExitResult struct + Success *bool + func NewRemoteControllerExitResult() *RemoteControllerExitResult + func (p *RemoteControllerExitResult) GetSuccess() bool + func (p *RemoteControllerExitResult) IsSetSuccess() bool + func (p *RemoteControllerExitResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerExitResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerExitResult) String() string + func (p *RemoteControllerExitResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type RemoteControllerMergeMemberToClusterArgs struct + ClusterId string + MemberId string + func NewRemoteControllerMergeMemberToClusterArgs() *RemoteControllerMergeMemberToClusterArgs + func (p *RemoteControllerMergeMemberToClusterArgs) GetClusterId() string + func (p *RemoteControllerMergeMemberToClusterArgs) GetMemberId() string + func (p *RemoteControllerMergeMemberToClusterArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerMergeMemberToClusterArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerMergeMemberToClusterArgs) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerMergeMemberToClusterArgs) String() string + func (p *RemoteControllerMergeMemberToClusterArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type RemoteControllerMergeMemberToClusterResult struct + Success *Cluster + func NewRemoteControllerMergeMemberToClusterResult() *RemoteControllerMergeMemberToClusterResult + func (p *RemoteControllerMergeMemberToClusterResult) GetSuccess() *Cluster + func (p *RemoteControllerMergeMemberToClusterResult) IsSetSuccess() bool + func (p *RemoteControllerMergeMemberToClusterResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerMergeMemberToClusterResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerMergeMemberToClusterResult) String() string + func (p *RemoteControllerMergeMemberToClusterResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type RemoteControllerPingArgs struct + func NewRemoteControllerPingArgs() *RemoteControllerPingArgs + func (p *RemoteControllerPingArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerPingArgs) String() string + func (p *RemoteControllerPingArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type RemoteControllerPingResult struct + Success *bool + func NewRemoteControllerPingResult() *RemoteControllerPingResult + func (p *RemoteControllerPingResult) GetSuccess() bool + func (p *RemoteControllerPingResult) IsSetSuccess() bool + func (p *RemoteControllerPingResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerPingResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerPingResult) String() string + func (p *RemoteControllerPingResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type RemoteControllerProcessor struct + func NewRemoteControllerProcessor(handler RemoteController) *RemoteControllerProcessor + func (p *RemoteControllerProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction) + func (p *RemoteControllerProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool) + func (p *RemoteControllerProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) + func (p *RemoteControllerProcessor) ProcessorMap() map[string]thrift.TProcessorFunction + type RemoteControllerResumeMemberArgs struct + ClusterId string + MemberId string + func NewRemoteControllerResumeMemberArgs() *RemoteControllerResumeMemberArgs + func (p *RemoteControllerResumeMemberArgs) GetClusterId() string + func (p *RemoteControllerResumeMemberArgs) GetMemberId() string + func (p *RemoteControllerResumeMemberArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerResumeMemberArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerResumeMemberArgs) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerResumeMemberArgs) String() string + func (p *RemoteControllerResumeMemberArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type RemoteControllerResumeMemberResult struct + Success *bool + func NewRemoteControllerResumeMemberResult() *RemoteControllerResumeMemberResult + func (p *RemoteControllerResumeMemberResult) GetSuccess() bool + func (p *RemoteControllerResumeMemberResult) IsSetSuccess() bool + func (p *RemoteControllerResumeMemberResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerResumeMemberResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerResumeMemberResult) String() string + func (p *RemoteControllerResumeMemberResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type RemoteControllerShutdownClusterArgs struct + ClusterId string + func NewRemoteControllerShutdownClusterArgs() *RemoteControllerShutdownClusterArgs + func (p *RemoteControllerShutdownClusterArgs) GetClusterId() string + func (p *RemoteControllerShutdownClusterArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerShutdownClusterArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerShutdownClusterArgs) String() string + func (p *RemoteControllerShutdownClusterArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type RemoteControllerShutdownClusterResult struct + Success *bool + func NewRemoteControllerShutdownClusterResult() *RemoteControllerShutdownClusterResult + func (p *RemoteControllerShutdownClusterResult) GetSuccess() bool + func (p *RemoteControllerShutdownClusterResult) IsSetSuccess() bool + func (p *RemoteControllerShutdownClusterResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerShutdownClusterResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerShutdownClusterResult) String() string + func (p *RemoteControllerShutdownClusterResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type RemoteControllerShutdownMemberArgs struct + ClusterId string + MemberId string + func NewRemoteControllerShutdownMemberArgs() *RemoteControllerShutdownMemberArgs + func (p *RemoteControllerShutdownMemberArgs) GetClusterId() string + func (p *RemoteControllerShutdownMemberArgs) GetMemberId() string + func (p *RemoteControllerShutdownMemberArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerShutdownMemberArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerShutdownMemberArgs) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerShutdownMemberArgs) String() string + func (p *RemoteControllerShutdownMemberArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type RemoteControllerShutdownMemberResult struct + Success *bool + func NewRemoteControllerShutdownMemberResult() *RemoteControllerShutdownMemberResult + func (p *RemoteControllerShutdownMemberResult) GetSuccess() bool + func (p *RemoteControllerShutdownMemberResult) IsSetSuccess() bool + func (p *RemoteControllerShutdownMemberResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerShutdownMemberResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerShutdownMemberResult) String() string + func (p *RemoteControllerShutdownMemberResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type RemoteControllerSplitMemberFromClusterArgs struct + MemberId string + func NewRemoteControllerSplitMemberFromClusterArgs() *RemoteControllerSplitMemberFromClusterArgs + func (p *RemoteControllerSplitMemberFromClusterArgs) GetMemberId() string + func (p *RemoteControllerSplitMemberFromClusterArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerSplitMemberFromClusterArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerSplitMemberFromClusterArgs) String() string + func (p *RemoteControllerSplitMemberFromClusterArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type RemoteControllerSplitMemberFromClusterResult struct + Success *Cluster + func NewRemoteControllerSplitMemberFromClusterResult() *RemoteControllerSplitMemberFromClusterResult + func (p *RemoteControllerSplitMemberFromClusterResult) GetSuccess() *Cluster + func (p *RemoteControllerSplitMemberFromClusterResult) IsSetSuccess() bool + func (p *RemoteControllerSplitMemberFromClusterResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerSplitMemberFromClusterResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerSplitMemberFromClusterResult) String() string + func (p *RemoteControllerSplitMemberFromClusterResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type RemoteControllerStartMemberArgs struct + ClusterId string + func NewRemoteControllerStartMemberArgs() *RemoteControllerStartMemberArgs + func (p *RemoteControllerStartMemberArgs) GetClusterId() string + func (p *RemoteControllerStartMemberArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerStartMemberArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerStartMemberArgs) String() string + func (p *RemoteControllerStartMemberArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type RemoteControllerStartMemberResult struct + ServerException *ServerException + Success *Member + func NewRemoteControllerStartMemberResult() *RemoteControllerStartMemberResult + func (p *RemoteControllerStartMemberResult) GetServerException() *ServerException + func (p *RemoteControllerStartMemberResult) GetSuccess() *Member + func (p *RemoteControllerStartMemberResult) IsSetServerException() bool + func (p *RemoteControllerStartMemberResult) IsSetSuccess() bool + func (p *RemoteControllerStartMemberResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerStartMemberResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerStartMemberResult) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerStartMemberResult) String() string + func (p *RemoteControllerStartMemberResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type RemoteControllerSuspendMemberArgs struct + ClusterId string + MemberId string + func NewRemoteControllerSuspendMemberArgs() *RemoteControllerSuspendMemberArgs + func (p *RemoteControllerSuspendMemberArgs) GetClusterId() string + func (p *RemoteControllerSuspendMemberArgs) GetMemberId() string + func (p *RemoteControllerSuspendMemberArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerSuspendMemberArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerSuspendMemberArgs) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerSuspendMemberArgs) String() string + func (p *RemoteControllerSuspendMemberArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type RemoteControllerSuspendMemberResult struct + Success *bool + func NewRemoteControllerSuspendMemberResult() *RemoteControllerSuspendMemberResult + func (p *RemoteControllerSuspendMemberResult) GetSuccess() bool + func (p *RemoteControllerSuspendMemberResult) IsSetSuccess() bool + func (p *RemoteControllerSuspendMemberResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerSuspendMemberResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerSuspendMemberResult) String() string + func (p *RemoteControllerSuspendMemberResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type RemoteControllerTerminateClusterArgs struct + ClusterId string + func NewRemoteControllerTerminateClusterArgs() *RemoteControllerTerminateClusterArgs + func (p *RemoteControllerTerminateClusterArgs) GetClusterId() string + func (p *RemoteControllerTerminateClusterArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerTerminateClusterArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerTerminateClusterArgs) String() string + func (p *RemoteControllerTerminateClusterArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type RemoteControllerTerminateClusterResult struct + Success *bool + func NewRemoteControllerTerminateClusterResult() *RemoteControllerTerminateClusterResult + func (p *RemoteControllerTerminateClusterResult) GetSuccess() bool + func (p *RemoteControllerTerminateClusterResult) IsSetSuccess() bool + func (p *RemoteControllerTerminateClusterResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerTerminateClusterResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerTerminateClusterResult) String() string + func (p *RemoteControllerTerminateClusterResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type RemoteControllerTerminateMemberArgs struct + ClusterId string + MemberId string + func NewRemoteControllerTerminateMemberArgs() *RemoteControllerTerminateMemberArgs + func (p *RemoteControllerTerminateMemberArgs) GetClusterId() string + func (p *RemoteControllerTerminateMemberArgs) GetMemberId() string + func (p *RemoteControllerTerminateMemberArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerTerminateMemberArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerTerminateMemberArgs) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerTerminateMemberArgs) String() string + func (p *RemoteControllerTerminateMemberArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type RemoteControllerTerminateMemberResult struct + Success *bool + func NewRemoteControllerTerminateMemberResult() *RemoteControllerTerminateMemberResult + func (p *RemoteControllerTerminateMemberResult) GetSuccess() bool + func (p *RemoteControllerTerminateMemberResult) IsSetSuccess() bool + func (p *RemoteControllerTerminateMemberResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerTerminateMemberResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *RemoteControllerTerminateMemberResult) String() string + func (p *RemoteControllerTerminateMemberResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type Response struct + Message string + Result_ []byte + Success bool + var RemoteControllerExecuteOnControllerResult_Success_DEFAULT *Response + func NewResponse() *Response + func (p *Response) Equals(other *Response) bool + func (p *Response) GetMessage() string + func (p *Response) GetResult_() []byte + func (p *Response) GetSuccess() bool + func (p *Response) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *Response) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *Response) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *Response) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *Response) String() string + func (p *Response) Write(ctx context.Context, oprot thrift.TProtocol) error + type SamplePortable struct + A string + B int32 + func (s *SamplePortable) ReadPortable(reader serialization.PortableReader) + func (s SamplePortable) ClassID() int32 + func (s SamplePortable) FactoryID() int32 + func (s SamplePortable) Json() serialization.JSON + func (s SamplePortable) WritePortable(writer serialization.PortableWriter) + type SamplePortableFactory struct + func (f SamplePortableFactory) Create(classID int32) serialization.Portable + func (f SamplePortableFactory) FactoryID() int32 + type ServerException struct + Message string + var RemoteControllerCreateClusterKeepClusterNameResult_ServerException_DEFAULT *ServerException + var RemoteControllerCreateClusterResult_ServerException_DEFAULT *ServerException + var RemoteControllerStartMemberResult_ServerException_DEFAULT *ServerException + func NewServerException() *ServerException + func (ServerException) TExceptionType() thrift.TExceptionType + func (p *ServerException) Equals(other *ServerException) bool + func (p *ServerException) Error() string + func (p *ServerException) GetMessage() string + func (p *ServerException) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *ServerException) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *ServerException) String() string + func (p *ServerException) Write(ctx context.Context, oprot thrift.TProtocol) error + type TestCluster struct + ClusterID string + MemberUUIDs []string + Port int + RC *RemoteControllerClient + func StartNewCluster(memberCount int) *TestCluster + func StartNewClusterWithOptions(clusterName string, port, memberCount int) *TestCluster + func (c TestCluster) DefaultConfig() hz.Config + func (c TestCluster) Shutdown()