it

package

Go to main page

Versions in this module

v1

v1.4.2

Aug 7, 2024

v1.4.1

Aug 22, 2023

v1.4.0

Mar 17, 2023

Changes in this version

+ const ClusterNameCPEnabled

+ const RingbufferCapacity

+ func AtomicLongTester(t *testing.T, f func(t *testing.T, a *hz.AtomicLong))

+ func AtomicLongTesterWithConfig(t *testing.T, configCallback func(*hz.Config), ...)

+ func AtomicLongTesterWithConfigAndName(t *testing.T, makeName func() string, configCallback func(*hz.Config), ...)

+ func GetClientAtomicLongWithConfig(name string, config *hz.Config) (*hz.Client, *hz.AtomicLong)

+ func MakeCompactClusterConfig(clusterName, mapName, inMemoryFormat string, port int) string

+ func RingbufferTester(t *testing.T, f func(t *testing.T, rb *hz.Ringbuffer))

+ func RingbufferTesterWithConfigAndName(t *testing.T, ringBufferName func() string, cbCallback func(*hz.Config), ...)

+ type CompactTestContext struct

+ Client1 *hazelcast.Client

+ Client2 *hazelcast.Client

+ Cluster *TestCluster

+ InMemFmt string

+ M *hazelcast.Map

+ MapName string

+ Serializers1 []serialization.CompactSerializer

+ Serializers2 []serialization.CompactSerializer

+ T *testing.T

+ func (tcx CompactTestContext) ExecuteScript(ctx context.Context, script string) error

+ func (tcx CompactTestContext) Tester(f func(CompactTestContext))

type TestCluster

+ func (c TestCluster) StartMember(ctx context.Context) (*Member, error)

v1.3.2

Feb 9, 2023

Changes in this version

+ func MustData(value interface{}, err error) iserialization.Data

+ func MustSerializationService(ss *iserialization.Service, err error) *iserialization.Service

v1.3.1

Oct 5, 2022

Changes in this version

+ func MarkFlaky(t *testing.T, see ...string)

+ func MarkRacy(t *testing.T, see ...string)

+ func MarkSlow(t *testing.T)

+ func NextPort() int

+ func SQLXMLConfig(clusterName, publicAddr string, port int) string

+ type RemoteControllerClientWrapper struct

+ func (rcw *RemoteControllerClientWrapper) CreateClusterKeepClusterName(ctx context.Context, hzVersion string, xmlconfig string) (*Cluster, error)

+ func (rcw *RemoteControllerClientWrapper) ExecuteOnController(ctx context.Context, clusterID string, script string, lang Lang) (*Response, error)

+ func (rcw *RemoteControllerClientWrapper) Ping(ctx context.Context) (bool, error)

+ func (rcw *RemoteControllerClientWrapper) ShutdownMember(ctx context.Context, clusterID string, memberID string) (bool, error)

+ func (rcw *RemoteControllerClientWrapper) StartMember(ctx context.Context, clusterID string) (*Member, error)

+ func (rcw *RemoteControllerClientWrapper) TerminateMember(ctx context.Context, clusterID string, memberID string) (bool, error)

+ type SingletonTestCluster struct

+ func NewSingletonTestCluster(name string, launcher func() *TestCluster) *SingletonTestCluster

+ func (c *SingletonTestCluster) Launch(t testLogger) *TestCluster

v1.3.0

Jul 21, 2022

Changes in this version

+ func EqualStringContent(b1, b2 []byte) bool

+ type DataStructureAdapter interface

+ Get func(ctx context.Context, key interface{}) (interface{}, error)

+ LocalMapStats func() hazelcast.LocalMapStats

+ Put func(ctx context.Context, key, value interface{}) (interface{}, error)

+ type MapTestContext struct

+ After func(tcx MapTestContext)

+ Before func(tcx MapTestContext)

+ Client *hz.Client

+ Cluster *TestCluster

+ Config *hz.Config

+ ConfigCallback func(testContext MapTestContext)

+ M *hz.Map

+ MapName string

+ NameMaker func(...string) string

+ Smart bool

+ T *testing.T

+ func (tcx *MapTestContext) ExecuteScript(ctx context.Context, script string)

+ func (tcx MapTestContext) Properties() []string

+ func (tcx MapTestContext) Tester(f func(MapTestContext))

+ type NearCacheAdapter interface

+ Get func(key interface{}) (interface{}, error)

+ GetFromNearCache func(key interface{}) (interface{}, error)

+ GetRecord func(key interface{}) (*inearcache.Record, bool)

+ InvalidationRequests func() int64

+ NearCache func() *inearcache.NearCache

+ Size func() int

+ ToNearCacheKey func(key interface{}) interface{}

+ type NearCacheTestContext struct

+ Config *nearcache.Config

+ DSAdapter DataStructureAdapter

+ NC NearCacheAdapter

+ T *testing.T

+ func NewNearCacheTestContext(t *testing.T, nc NearCacheAdapter, dsa DataStructureAdapter, ...) *NearCacheTestContext

+ func (tcx *NearCacheTestContext) AssertNearCacheContent(nca NearCacheAdapter, size int64, valueFmt string)

+ func (tcx *NearCacheTestContext) AssertNearCacheInvalidationRequests(invalidationRequests int64)

+ func (tcx *NearCacheTestContext) AssertNearCacheRecord(rec *inearcache.Record, key int64, imf nearcache.InMemoryFormat)

+ func (tcx *NearCacheTestContext) AssertNearCacheStats(owned, hits, misses int64)

+ func (tcx *NearCacheTestContext) GetKey(key interface{}) interface{}

+ func (tcx *NearCacheTestContext) PopulateNearCacheDataAdapter(size int64, valueFmt string)

+ func (tcx *NearCacheTestContext) PopulateNearCacheWithGet(size int64, valueFmt string)

+ func (tcx *NearCacheTestContext) RequireNearCacheSize(target int64)

+ func (tcx *NearCacheTestContext) ResetInvalidationEvents()

+ func (tcx NearCacheTestContext) Stats() (nearcache.Stats, int64)

type TestCluster

+ func (c TestCluster) DefaultConfigWithNoSSL() hz.Config

v1.2.1

Jul 7, 2022

v1.2.0

Apr 13, 2022

Changes in this version

+ func GetClientMultiMapWithConfig(mapName string, config *hz.Config) (*hz.Client, *hz.MultiMap)

+ func MultiMapTester(t *testing.T, f func(t *testing.T, m *hz.MultiMap))

+ func MultiMapTesterWithConfig(t *testing.T, configCallback func(*hz.Config), ...)

+ func MultiMapTesterWithConfigAndName(t *testing.T, makeMapName func() string, configCallback func(*hz.Config), ...)

+ func MustSlice(slice []interface{}, err error) []interface

+ func SQLTester(t *testing.T, ...)

+ func SQLTesterWithConfigBuilder(t *testing.T, configFn func(config *hz.Config), ...)

+ func SerializationTester(t *testing.T, ...)

+ type PanicingGlobalSerializer struct

+ func (p PanicingGlobalSerializer) ID() (id int32)

+ func (p PanicingGlobalSerializer) Read(input serialization.DataInput) interface{}

+ func (p PanicingGlobalSerializer) Write(output serialization.DataOutput, object interface{})

type Response

+ func MapSetOnServer(clusterID string, mapName string, key, value string) *Response

+ type SkipChecker struct

+ func (s SkipChecker) CanSkip(condStr string) bool

v1.1.1

Nov 9, 2021

Changes in this version

type TestCluster

+ func StartNewClusterWithConfig(memberCount int, config string, port int) *TestCluster

v1.1.0

Sep 14, 2021

Changes in this version

+ func Eventually(t *testing.T, condition func() bool, msgAndArgs ...interface{})

+ func Never(t *testing.T, condition func() bool, msgAndArgs ...interface{})

+ func NewUniqueObjectName(service string) string

+ func SkipIf(t *testing.T, conditions string)

+ func WaitEventually(t *testing.T, wg *sync.WaitGroup)

+ func WaitEventuallyWithTimeout(t *testing.T, wg *sync.WaitGroup, timeout time.Duration)

v1.0.0

Jul 13, 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 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 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 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

+ 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()

v1.0.0-preview.4

Jun 18, 2021

v1.0.0-preview.3

Jun 8, 2021

v1.0.0-preview.2

May 21, 2021

v1.0.0-preview.1

May 7, 2021

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL