it

package
v1.4.2 Latest Latest
Warning

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

 Go to latest Published: Aug 7, 2024 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	EnvDisableSmart       = "DISABLE_SMART"
	EnvDisableNonsmart    = "DISABLE_NONSMART"
	EnvEnableTraceLogging = "ENABLE_TRACE"
	EnvMemberCount        = "MEMBER_COUNT"
	EnvEnableLeakCheck    = "ENABLE_LEAKCHECK"
	EnvEnableSSL          = "ENABLE_SSL"
	EnvHzVersion          = "HZ_VERSION"
)
View Source 
const (
	DefaultClusterName   = "integration-test"
	RingbufferCapacity   = 10
	ClusterNameCPEnabled = "integration-test-cp"
)
View Source 
const EnvWarmupCount = "WARMUPS"
View Source 
const SamplePortableClassID = 1
View Source 
const SamplePortableFactoryID = 1

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

func AssertEquals 

func AssertEquals(t *testing.T, target, value interface{})

func AtomicLongTester added in v1.4.0 

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

func AtomicLongTesterWithConfig added in v1.4.0 

func AtomicLongTesterWithConfig(t *testing.T, configCallback func(*hz.Config), f func(t *testing.T, a *hz.AtomicLong))

func AtomicLongTesterWithConfigAndName added in v1.4.0 

func AtomicLongTesterWithConfigAndName(t *testing.T, makeName func() string, configCallback func(*hz.Config), f func(t *testing.T, a *hz.AtomicLong))

func Benchmarker 

func Benchmarker(b *testing.B, f func(b *testing.B, config *hz.Config))

func BenchmarkerWithConfigBuilder 

func BenchmarkerWithConfigBuilder(b *testing.B, configCallback func(*hz.Config), f func(b *testing.B, config *hz.Config))

func EqualStringContent added in v1.3.0 

func EqualStringContent(b1, b2 []byte) bool

func Eventually added in v1.1.0 

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

Eventually asserts that given condition will be met in 2 minutes, checking target function every 200 milliseconds.

func GetClientAtomicLongWithConfig added in v1.4.0 

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

func GetClientMapWithConfig 

func GetClientMapWithConfig(mapName string, config *hz.Config) (*hz.Client, *hz.Map)

func GetClientMultiMapWithConfig added in v1.2.0 

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

func GetClientPNCounterWithConfig 

func GetClientPNCounterWithConfig(name string, config *hz.Config) (*hz.Client, *hz.PNCounter)

func GetClientSetWithConfig 

func GetClientSetWithConfig(setName string, config *hz.Config) (*hz.Client, *hz.Set)

func HzVersion 

func HzVersion() string

func LeakCheckEnabled 

func LeakCheckEnabled() bool

func ListTester 

func ListTester(t *testing.T, f func(t *testing.T, l *hz.List))

func ListTesterWithConfigAndName 

func ListTesterWithConfigAndName(t *testing.T, listName func() string, cbCallback func(*hz.Config), f func(*testing.T, *hz.List))

func MakeCompactClusterConfig added in v1.4.0 

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

func MapBenchmarker 

func MapBenchmarker(t *testing.B, fixture func(m *hz.Map), f func(t *testing.B, m *hz.Map))

func MapBenchmarkerWithConfigAndName 

func MapBenchmarkerWithConfigAndName(b *testing.B, makeMapName func() string, cbCallback func(config *hz.Config), fixture func(m *hz.Map), f func(b *testing.B, m *hz.Map))

func MapBenchmarkerWithConfigBuilder 

func MapBenchmarkerWithConfigBuilder(t *testing.B, cbCallback func(*hz.Config), fixture func(m *hz.Map), f func(t *testing.B, m *hz.Map))

func MapTester 

func MapTester(t *testing.T, f func(t *testing.T, m *hz.Map))

func MapTesterWithConfig 

func MapTesterWithConfig(t *testing.T, configCallback func(*hz.Config), f func(t *testing.T, m *hz.Map))

func MapTesterWithConfigAndName 

func MapTesterWithConfigAndName(t *testing.T, makeMapName func(...string) string, configCallback func(*hz.Config), f func(t *testing.T, m *hz.Map))

func MarkFlaky added in v1.3.1 

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

MarkFlaky marks a test "flaky", so it is run only when flaky test mode is enabled. Note that if "all" mode is enabled, the test runs disregard of whether flaky test mode is enabled or disabled.

func MarkRacy added in v1.3.1 

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

MarkRacy marks a test "racy", so it is run only when race detector is not enabled. Note that if "all" mode is enabled, the test runs disregard of whether the race detector is enabled or disabled.

func MarkSlow added in v1.3.1 

func MarkSlow(t *testing.T)

MarkSlow marks a test "slow", so it is run only when slow test mode is enabled. Note that if "all" mode is enabled, the test runs disregard of whether slow test mode is enabled or disabled.

func MemberCount 

func MemberCount() int

func MultiMapTester added in v1.2.0 

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

func MultiMapTesterWithConfig added in v1.2.0 

func MultiMapTesterWithConfig(t *testing.T, configCallback func(*hz.Config), f func(t *testing.T, m *hz.MultiMap))

func MultiMapTesterWithConfigAndName added in v1.2.0 

func MultiMapTesterWithConfigAndName(t *testing.T, makeMapName func() string, configCallback func(*hz.Config), f func(t *testing.T, m *hz.MultiMap))

func Must 

func Must(err error)

Must panics if err is not nil.

func MustBool 

func MustBool(value bool, err error) bool

MustBool returns value if err is nil, otherwise it panics.

func MustClient 

func MustClient(client *hz.Client, err error) *hz.Client

MustClient returns client if err is nil, otherwise it panics.

func MustSlice added in v1.2.0 

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

MustSlice returns a slice of values if err is nil, otherwise it panics.

func MustValue 

func MustValue(value interface{}, err error) interface{}

MustValue returns value if err is nil, otherwise it panics.

func Never added in v1.1.0 

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

Never asserts that the given condition doesn't satisfy in 3 seconds, checking target function every 200 milliseconds.

func NewUniqueObjectName added in v1.1.0 

func NewUniqueObjectName(service string, labels ...string) string

func NextPort added in v1.3.1 

func NextPort() int

func NonSmartEnabled 

func NonSmartEnabled() bool

func PNCounterTester 

func PNCounterTester(t *testing.T, f func(t *testing.T, pn *hz.PNCounter))

func PNCounterTesterWithConfig 

func PNCounterTesterWithConfig(t *testing.T, configCallback func(*hz.Config), f func(t *testing.T, pn *hz.PNCounter))

func PNCounterTesterWithConfigAndName 

func PNCounterTesterWithConfigAndName(t *testing.T, makeName func() string, configCallback func(*hz.Config), f func(t *testing.T, s *hz.PNCounter))

func QueueTester 

func QueueTester(t *testing.T, f func(t *testing.T, q *hz.Queue))

func QueueTesterWithConfigAndName 

func QueueTesterWithConfigAndName(t *testing.T, queueName func() string, configCallback func(*hz.Config), f func(t *testing.T, q *hz.Queue))

func ReplicatedMapTester 

func ReplicatedMapTester(t *testing.T, f func(t *testing.T, m *hz.ReplicatedMap))

func ReplicatedMapTesterWithConfig 

func ReplicatedMapTesterWithConfig(t *testing.T, configCallback func(*hz.Config), f func(t *testing.T, m *hz.ReplicatedMap))

func ReplicatedMapTesterWithConfigAndName 

func ReplicatedMapTesterWithConfigAndName(t *testing.T, makeMapName func() string, cbCallback func(cb *hz.Config), f func(t *testing.T, m *hz.ReplicatedMap))

func RingbufferTester added in v1.4.0 

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

func RingbufferTesterWithConfigAndName added in v1.4.0 

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

func SQLTester added in v1.2.0 

func SQLTester(t *testing.T, f func(t *testing.T, client *hz.Client, config *hz.Config, m *hz.Map, mapName string))

func SQLTesterWithConfigBuilder added in v1.2.0 

func SQLTesterWithConfigBuilder(t *testing.T, configFn func(config *hz.Config), f func(t *testing.T, client *hz.Client, config *hz.Config, m *hz.Map, mapName string))

func SQLXMLConfig added in v1.3.1 

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

func SSLEnabled 

func SSLEnabled() bool

func SerializationTester added in v1.2.0 

func SerializationTester(t *testing.T, f func(t *testing.T, config hazelcast.Config, clusterID, mapName string))

func SetTester 

func SetTester(t *testing.T, f func(t *testing.T, s *hz.Set))

func SetTesterWithConfig 

func SetTesterWithConfig(t *testing.T, configCallback func(*hz.Config), f func(t *testing.T, s *hz.Set))

func SetTesterWithConfigAndName 

func SetTesterWithConfigAndName(t *testing.T, makeName func() string, configCallback func(*hz.Config), f func(t *testing.T, s *hz.Set))

func SkipIf added in v1.1.0 

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

SkipIf can be used to skip a test case based on comma-separated conditions. Deprecated: Use skip.If instead.

func SmartEnabled 

func SmartEnabled() bool

func Tester 

func Tester(t *testing.T, f func(t *testing.T, client *hz.Client))

func TesterWithConfigBuilder 

func TesterWithConfigBuilder(t *testing.T, cbCallback func(config *hz.Config), f func(t *testing.T, client *hz.Client))

func TopicTester 

func TopicTester(t *testing.T, f func(t *testing.T, tp *hz.Topic))

func TopicTesterWithConfigAndName 

func TopicTesterWithConfigAndName(t *testing.T, makeName func() string, cbCallback func(*hz.Config), f func(t *testing.T, q *hz.Topic))

func TraceLoggingEnabled 

func TraceLoggingEnabled() bool

func WaitEventually added in v1.1.0 

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

WaitEventually waits for the waitgroup for 2 minutes Fails the test if 2 mimutes is reached.

func WaitEventuallyWithTimeout added in v1.1.0 

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

WaitEventuallyWithTimeout waits for the waitgroup for the specified max timeout. Fails the test if given timeout is reached.

Types

type Cluster 

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

Attributes:

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

func NewCluster 

func NewCluster() *Cluster

func (*Cluster) Equals 

func (p *Cluster) Equals(other *Cluster) bool

func (*Cluster) GetID 

func (p *Cluster) GetID() string

func (*Cluster) Read 

func (p *Cluster) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*Cluster) ReadField1 

func (p *Cluster) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*Cluster) String 

func (p *Cluster) String() string

func (*Cluster) Write 

func (p *Cluster) Write(ctx context.Context, oprot thrift.TProtocol) error

type CompactTestContext added in v1.4.0 

type CompactTestContext struct {
	T            *testing.T
	M            *hazelcast.Map
	Cluster      *TestCluster
	Client1      *hazelcast.Client
	Client2      *hazelcast.Client
	MapName      string
	InMemFmt     string
	Serializers1 []serialization.CompactSerializer
	Serializers2 []serialization.CompactSerializer
}

func (CompactTestContext) ExecuteScript added in v1.4.0 

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

func (CompactTestContext) Tester added in v1.4.0 

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

type DataStructureAdapter added in v1.3.0 

type DataStructureAdapter interface {
	Get(ctx context.Context, key interface{}) (interface{}, error)
	Put(ctx context.Context, key, value interface{}) (interface{}, error)
	LocalMapStats() hazelcast.LocalMapStats
}

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 MapTestContext added in v1.3.0 

type MapTestContext struct {
	T              *testing.T
	M              *hz.Map
	Cluster        *TestCluster
	Client         *hz.Client
	Config         *hz.Config
	ConfigCallback func(testContext MapTestContext)
	NameMaker      func(...string) string
	Before         func(tcx MapTestContext)
	After          func(tcx MapTestContext)
	MapName        string
	Smart          bool
}

func (*MapTestContext) ExecuteScript added in v1.3.0 

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

func (MapTestContext) Properties added in v1.3.0 

func (tcx MapTestContext) Properties() []string

func (MapTestContext) Tester added in v1.3.0 

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

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) Equals 

func (p *Member) Equals(other *Member) bool

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(ctx context.Context, iprot thrift.TProtocol) error

func (*Member) ReadField1 

func (p *Member) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*Member) ReadField2 

func (p *Member) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*Member) ReadField3 

func (p *Member) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*Member) String 

func (p *Member) String() string

func (*Member) Write 

func (p *Member) Write(ctx context.Context, oprot thrift.TProtocol) error

type NearCacheAdapter added in v1.3.0 

type NearCacheAdapter interface {
	Size() int
	Get(key interface{}) (interface{}, error)
	GetFromNearCache(key interface{}) (interface{}, error)
	GetRecord(key interface{}) (*inearcache.Record, bool)
	InvalidationRequests() int64
	ToNearCacheKey(key interface{}) interface{}
	NearCache() *inearcache.NearCache
}

type NearCacheTestContext added in v1.3.0 

type NearCacheTestContext struct {
	T         *testing.T
	NC        NearCacheAdapter
	Config    *nearcache.Config
	DSAdapter DataStructureAdapter
	// contains filtered or unexported fields
}

func NewNearCacheTestContext added in v1.3.0 

func NewNearCacheTestContext(t *testing.T, nc NearCacheAdapter, dsa DataStructureAdapter, cfg *nearcache.Config, ss *serialization.Service) *NearCacheTestContext

func (*NearCacheTestContext) AssertNearCacheContent added in v1.3.0 

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

func (*NearCacheTestContext) AssertNearCacheInvalidationRequests added in v1.3.0 

func (tcx *NearCacheTestContext) AssertNearCacheInvalidationRequests(invalidationRequests int64)

func (*NearCacheTestContext) AssertNearCacheRecord added in v1.3.0 

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

func (*NearCacheTestContext) AssertNearCacheStats added in v1.3.0 

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

func (*NearCacheTestContext) GetKey added in v1.3.0 

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

func (*NearCacheTestContext) PopulateNearCacheDataAdapter added in v1.3.0 

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

func (*NearCacheTestContext) PopulateNearCacheWithGet added in v1.3.0 

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

func (*NearCacheTestContext) RequireNearCacheSize added in v1.3.0 

func (tcx *NearCacheTestContext) RequireNearCacheSize(target int64)

func (*NearCacheTestContext) ResetInvalidationEvents added in v1.3.0 

func (tcx *NearCacheTestContext) ResetInvalidationEvents()

func (NearCacheTestContext) Stats added in v1.3.0 

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

type PanicingGlobalSerializer added in v1.2.0 

type PanicingGlobalSerializer struct{}

func (PanicingGlobalSerializer) ID added in v1.2.0 

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

func (PanicingGlobalSerializer) Read added in v1.2.0 

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

func (PanicingGlobalSerializer) Write added in v1.2.0 

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

type RemoteController 

type RemoteController interface {
	Ping(ctx context.Context) (_r bool, _err error)
	Clean(ctx context.Context) (_r bool, _err error)
	Exit(ctx context.Context) (_r bool, _err error)
	// Parameters:
	//  - HzVersion
	//  - Xmlconfig
	CreateCluster(ctx context.Context, hzVersion string, xmlconfig string) (_r *Cluster, _err error)
	// Parameters:
	//  - HzVersion
	//  - Xmlconfig
	CreateClusterKeepClusterName(ctx context.Context, hzVersion string, xmlconfig string) (_r *Cluster, _err error)
	// Parameters:
	//  - ClusterId
	StartMember(ctx context.Context, clusterId string) (_r *Member, _err error)
	// Parameters:
	//  - ClusterId
	//  - MemberId
	ShutdownMember(ctx context.Context, clusterId string, memberId string) (_r bool, _err error)
	// Parameters:
	//  - ClusterId
	//  - MemberId
	TerminateMember(ctx context.Context, clusterId string, memberId string) (_r bool, _err error)
	// Parameters:
	//  - ClusterId
	//  - MemberId
	SuspendMember(ctx context.Context, clusterId string, memberId string) (_r bool, _err error)
	// Parameters:
	//  - ClusterId
	//  - MemberId
	ResumeMember(ctx context.Context, clusterId string, memberId string) (_r bool, _err error)
	// Parameters:
	//  - ClusterId
	ShutdownCluster(ctx context.Context, clusterId string) (_r bool, _err error)
	// Parameters:
	//  - ClusterId
	TerminateCluster(ctx context.Context, clusterId string) (_r bool, _err error)
	// Parameters:
	//  - MemberId
	SplitMemberFromCluster(ctx context.Context, memberId string) (_r *Cluster, _err error)
	// Parameters:
	//  - ClusterId
	//  - MemberId
	MergeMemberToCluster(ctx context.Context, clusterId string, memberId string) (_r *Cluster, _err error)
	// Parameters:
	//  - ClusterId
	//  - Script
	//  - Lang
	ExecuteOnController(ctx context.Context, 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(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerCleanArgs) String 

func (p *RemoteControllerCleanArgs) String() string

func (*RemoteControllerCleanArgs) Write 

func (p *RemoteControllerCleanArgs) Write(ctx context.Context, 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(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerCleanResult) ReadField0 

func (p *RemoteControllerCleanResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerCleanResult) String 

func (p *RemoteControllerCleanResult) String() string

func (*RemoteControllerCleanResult) Write 

func (p *RemoteControllerCleanResult) Write(ctx context.Context, oprot thrift.TProtocol) error

type RemoteControllerClient 

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

func CreateRemoteController 

func CreateRemoteController(addr string) *RemoteControllerClient

func NewRemoteControllerClient 

func NewRemoteControllerClient(c thrift.TClient) *RemoteControllerClient

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(ctx context.Context) (_r bool, _err error)

func (*RemoteControllerClient) Client_ 

func (p *RemoteControllerClient) Client_() thrift.TClient

func (*RemoteControllerClient) CreateCluster 

func (p *RemoteControllerClient) CreateCluster(ctx context.Context, hzVersion string, xmlconfig string) (_r *Cluster, _err error)

Parameters:

  • HzVersion
  • Xmlconfig

func (*RemoteControllerClient) CreateClusterKeepClusterName 

func (p *RemoteControllerClient) CreateClusterKeepClusterName(ctx context.Context, hzVersion string, xmlconfig string) (_r *Cluster, _err error)

Parameters:

  • HzVersion
  • Xmlconfig

func (*RemoteControllerClient) ExecuteOnController 

func (p *RemoteControllerClient) ExecuteOnController(ctx context.Context, clusterId string, script string, lang Lang) (_r *Response, _err error)

Parameters:

  • ClusterId
  • Script
  • Lang

func (*RemoteControllerClient) Exit 

func (p *RemoteControllerClient) Exit(ctx context.Context) (_r bool, _err error)

func (*RemoteControllerClient) LastResponseMeta_ 

func (p *RemoteControllerClient) LastResponseMeta_() thrift.ResponseMeta

func (*RemoteControllerClient) MergeMemberToCluster 

func (p *RemoteControllerClient) MergeMemberToCluster(ctx context.Context, clusterId string, memberId string) (_r *Cluster, _err error)

Parameters:

  • ClusterId
  • MemberId

func (*RemoteControllerClient) Ping 

func (p *RemoteControllerClient) Ping(ctx context.Context) (_r bool, _err error)

func (*RemoteControllerClient) ResumeMember 

func (p *RemoteControllerClient) ResumeMember(ctx context.Context, clusterId string, memberId string) (_r bool, _err error)

Parameters:

  • ClusterId
  • MemberId

func (*RemoteControllerClient) SetLastResponseMeta_ 

func (p *RemoteControllerClient) SetLastResponseMeta_(meta thrift.ResponseMeta)

func (*RemoteControllerClient) ShutdownCluster 

func (p *RemoteControllerClient) ShutdownCluster(ctx context.Context, clusterId string) (_r bool, _err error)

Parameters:

  • ClusterId

func (*RemoteControllerClient) ShutdownMember 

func (p *RemoteControllerClient) ShutdownMember(ctx context.Context, clusterId string, memberId string) (_r bool, _err error)

Parameters:

  • ClusterId
  • MemberId

func (*RemoteControllerClient) SplitMemberFromCluster 

func (p *RemoteControllerClient) SplitMemberFromCluster(ctx context.Context, memberId string) (_r *Cluster, _err error)

Parameters:

  • MemberId

func (*RemoteControllerClient) StartMember 

func (p *RemoteControllerClient) StartMember(ctx context.Context, clusterId string) (_r *Member, _err error)

Parameters:

  • ClusterId

func (*RemoteControllerClient) SuspendMember 

func (p *RemoteControllerClient) SuspendMember(ctx context.Context, clusterId string, memberId string) (_r bool, _err error)

Parameters:

  • ClusterId
  • MemberId

func (*RemoteControllerClient) TerminateCluster 

func (p *RemoteControllerClient) TerminateCluster(ctx context.Context, clusterId string) (_r bool, _err error)

Parameters:

  • ClusterId

func (*RemoteControllerClient) TerminateMember 

func (p *RemoteControllerClient) TerminateMember(ctx context.Context, clusterId string, memberId string) (_r bool, _err error)

Parameters:

  • ClusterId
  • MemberId

type RemoteControllerClientWrapper added in v1.3.1 

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

func CreateDefaultRemoteController 

func CreateDefaultRemoteController() *RemoteControllerClientWrapper

func (*RemoteControllerClientWrapper) CreateClusterKeepClusterName added in v1.3.1 

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

func (*RemoteControllerClientWrapper) ExecuteOnController added in v1.3.1 

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

func (*RemoteControllerClientWrapper) Ping added in v1.3.1 

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

func (*RemoteControllerClientWrapper) ShutdownMember added in v1.3.1 

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

func (*RemoteControllerClientWrapper) StartMember added in v1.3.1 

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

func (*RemoteControllerClientWrapper) TerminateMember added in v1.3.1 

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

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(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerCreateClusterArgs) ReadField1 

func (p *RemoteControllerCreateClusterArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerCreateClusterArgs) ReadField2 

func (p *RemoteControllerCreateClusterArgs) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerCreateClusterArgs) String 

func (p *RemoteControllerCreateClusterArgs) String() string

func (*RemoteControllerCreateClusterArgs) Write 

func (p *RemoteControllerCreateClusterArgs) Write(ctx context.Context, oprot thrift.TProtocol) error

type RemoteControllerCreateClusterKeepClusterNameArgs 

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

Attributes:

  • HzVersion
  • Xmlconfig

func NewRemoteControllerCreateClusterKeepClusterNameArgs 

func NewRemoteControllerCreateClusterKeepClusterNameArgs() *RemoteControllerCreateClusterKeepClusterNameArgs

func (*RemoteControllerCreateClusterKeepClusterNameArgs) GetHzVersion 

func (p *RemoteControllerCreateClusterKeepClusterNameArgs) GetHzVersion() string

func (*RemoteControllerCreateClusterKeepClusterNameArgs) GetXmlconfig 

func (p *RemoteControllerCreateClusterKeepClusterNameArgs) GetXmlconfig() string

func (*RemoteControllerCreateClusterKeepClusterNameArgs) Read 

func (p *RemoteControllerCreateClusterKeepClusterNameArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerCreateClusterKeepClusterNameArgs) ReadField1 

func (p *RemoteControllerCreateClusterKeepClusterNameArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerCreateClusterKeepClusterNameArgs) ReadField2 

func (p *RemoteControllerCreateClusterKeepClusterNameArgs) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerCreateClusterKeepClusterNameArgs) String 

func (p *RemoteControllerCreateClusterKeepClusterNameArgs) String() string

func (*RemoteControllerCreateClusterKeepClusterNameArgs) Write 

func (p *RemoteControllerCreateClusterKeepClusterNameArgs) Write(ctx context.Context, oprot thrift.TProtocol) error

type RemoteControllerCreateClusterKeepClusterNameResult 

type RemoteControllerCreateClusterKeepClusterNameResult 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 NewRemoteControllerCreateClusterKeepClusterNameResult 

func NewRemoteControllerCreateClusterKeepClusterNameResult() *RemoteControllerCreateClusterKeepClusterNameResult

func (*RemoteControllerCreateClusterKeepClusterNameResult) GetServerException 

func (p *RemoteControllerCreateClusterKeepClusterNameResult) GetServerException() *ServerException

func (*RemoteControllerCreateClusterKeepClusterNameResult) GetSuccess 

func (p *RemoteControllerCreateClusterKeepClusterNameResult) GetSuccess() *Cluster

func (*RemoteControllerCreateClusterKeepClusterNameResult) IsSetServerException 

func (p *RemoteControllerCreateClusterKeepClusterNameResult) IsSetServerException() bool

func (*RemoteControllerCreateClusterKeepClusterNameResult) IsSetSuccess 

func (p *RemoteControllerCreateClusterKeepClusterNameResult) IsSetSuccess() bool

func (*RemoteControllerCreateClusterKeepClusterNameResult) Read 

func (p *RemoteControllerCreateClusterKeepClusterNameResult) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerCreateClusterKeepClusterNameResult) ReadField0 

func (p *RemoteControllerCreateClusterKeepClusterNameResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerCreateClusterKeepClusterNameResult) ReadField1 

func (p *RemoteControllerCreateClusterKeepClusterNameResult) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerCreateClusterKeepClusterNameResult) String 

func (p *RemoteControllerCreateClusterKeepClusterNameResult) String() string

func (*RemoteControllerCreateClusterKeepClusterNameResult) Write 

func (p *RemoteControllerCreateClusterKeepClusterNameResult) Write(ctx context.Context, 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(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerCreateClusterResult) ReadField0 

func (p *RemoteControllerCreateClusterResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerCreateClusterResult) ReadField1 

func (p *RemoteControllerCreateClusterResult) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerCreateClusterResult) String 

func (p *RemoteControllerCreateClusterResult) String() string

func (*RemoteControllerCreateClusterResult) Write 

func (p *RemoteControllerCreateClusterResult) Write(ctx context.Context, 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(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerExecuteOnControllerArgs) ReadField1 

func (p *RemoteControllerExecuteOnControllerArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerExecuteOnControllerArgs) ReadField2 

func (p *RemoteControllerExecuteOnControllerArgs) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerExecuteOnControllerArgs) ReadField3 

func (p *RemoteControllerExecuteOnControllerArgs) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerExecuteOnControllerArgs) String 

func (p *RemoteControllerExecuteOnControllerArgs) String() string

func (*RemoteControllerExecuteOnControllerArgs) Write 

func (p *RemoteControllerExecuteOnControllerArgs) Write(ctx context.Context, 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(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerExecuteOnControllerResult) ReadField0 

func (p *RemoteControllerExecuteOnControllerResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerExecuteOnControllerResult) String 

func (p *RemoteControllerExecuteOnControllerResult) String() string

func (*RemoteControllerExecuteOnControllerResult) Write 

func (p *RemoteControllerExecuteOnControllerResult) Write(ctx context.Context, oprot thrift.TProtocol) error

type RemoteControllerExitArgs 

type RemoteControllerExitArgs struct {
}

func NewRemoteControllerExitArgs 

func NewRemoteControllerExitArgs() *RemoteControllerExitArgs

func (*RemoteControllerExitArgs) Read 

func (p *RemoteControllerExitArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerExitArgs) String 

func (p *RemoteControllerExitArgs) String() string

func (*RemoteControllerExitArgs) Write 

func (p *RemoteControllerExitArgs) Write(ctx context.Context, 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(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerExitResult) ReadField0 

func (p *RemoteControllerExitResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerExitResult) String 

func (p *RemoteControllerExitResult) String() string

func (*RemoteControllerExitResult) Write 

func (p *RemoteControllerExitResult) Write(ctx context.Context, 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(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerMergeMemberToClusterArgs) ReadField1 

func (p *RemoteControllerMergeMemberToClusterArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerMergeMemberToClusterArgs) ReadField2 

func (p *RemoteControllerMergeMemberToClusterArgs) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerMergeMemberToClusterArgs) String 

func (p *RemoteControllerMergeMemberToClusterArgs) String() string

func (*RemoteControllerMergeMemberToClusterArgs) Write 

func (p *RemoteControllerMergeMemberToClusterArgs) Write(ctx context.Context, 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(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerMergeMemberToClusterResult) ReadField0 

func (p *RemoteControllerMergeMemberToClusterResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerMergeMemberToClusterResult) String 

func (p *RemoteControllerMergeMemberToClusterResult) String() string

func (*RemoteControllerMergeMemberToClusterResult) Write 

func (p *RemoteControllerMergeMemberToClusterResult) Write(ctx context.Context, oprot thrift.TProtocol) error

type RemoteControllerPingArgs 

type RemoteControllerPingArgs struct {
}

func NewRemoteControllerPingArgs 

func NewRemoteControllerPingArgs() *RemoteControllerPingArgs

func (*RemoteControllerPingArgs) Read 

func (p *RemoteControllerPingArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerPingArgs) String 

func (p *RemoteControllerPingArgs) String() string

func (*RemoteControllerPingArgs) Write 

func (p *RemoteControllerPingArgs) Write(ctx context.Context, 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(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerPingResult) ReadField0 

func (p *RemoteControllerPingResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerPingResult) String 

func (p *RemoteControllerPingResult) String() string

func (*RemoteControllerPingResult) Write 

func (p *RemoteControllerPingResult) Write(ctx context.Context, 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(ctx context.Context, 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(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerResumeMemberArgs) ReadField1 

func (p *RemoteControllerResumeMemberArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerResumeMemberArgs) ReadField2 

func (p *RemoteControllerResumeMemberArgs) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerResumeMemberArgs) String 

func (p *RemoteControllerResumeMemberArgs) String() string

func (*RemoteControllerResumeMemberArgs) Write 

func (p *RemoteControllerResumeMemberArgs) Write(ctx context.Context, 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(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerResumeMemberResult) ReadField0 

func (p *RemoteControllerResumeMemberResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerResumeMemberResult) String 

func (p *RemoteControllerResumeMemberResult) String() string

func (*RemoteControllerResumeMemberResult) Write 

func (p *RemoteControllerResumeMemberResult) Write(ctx context.Context, 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(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerShutdownClusterArgs) ReadField1 

func (p *RemoteControllerShutdownClusterArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerShutdownClusterArgs) String 

func (p *RemoteControllerShutdownClusterArgs) String() string

func (*RemoteControllerShutdownClusterArgs) Write 

func (p *RemoteControllerShutdownClusterArgs) Write(ctx context.Context, 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(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerShutdownClusterResult) ReadField0 

func (p *RemoteControllerShutdownClusterResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerShutdownClusterResult) String 

func (p *RemoteControllerShutdownClusterResult) String() string

func (*RemoteControllerShutdownClusterResult) Write 

func (p *RemoteControllerShutdownClusterResult) Write(ctx context.Context, 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(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerShutdownMemberArgs) ReadField1 

func (p *RemoteControllerShutdownMemberArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerShutdownMemberArgs) ReadField2 

func (p *RemoteControllerShutdownMemberArgs) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerShutdownMemberArgs) String 

func (p *RemoteControllerShutdownMemberArgs) String() string

func (*RemoteControllerShutdownMemberArgs) Write 

func (p *RemoteControllerShutdownMemberArgs) Write(ctx context.Context, 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(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerShutdownMemberResult) ReadField0 

func (p *RemoteControllerShutdownMemberResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerShutdownMemberResult) String 

func (p *RemoteControllerShutdownMemberResult) String() string

func (*RemoteControllerShutdownMemberResult) Write 

func (p *RemoteControllerShutdownMemberResult) Write(ctx context.Context, 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(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerSplitMemberFromClusterArgs) ReadField1 

func (p *RemoteControllerSplitMemberFromClusterArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerSplitMemberFromClusterArgs) String 

func (p *RemoteControllerSplitMemberFromClusterArgs) String() string

func (*RemoteControllerSplitMemberFromClusterArgs) Write 

func (p *RemoteControllerSplitMemberFromClusterArgs) Write(ctx context.Context, 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(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerSplitMemberFromClusterResult) ReadField0 

func (p *RemoteControllerSplitMemberFromClusterResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerSplitMemberFromClusterResult) String 

func (p *RemoteControllerSplitMemberFromClusterResult) String() string

func (*RemoteControllerSplitMemberFromClusterResult) Write 

func (p *RemoteControllerSplitMemberFromClusterResult) Write(ctx context.Context, 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(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerStartMemberArgs) ReadField1 

func (p *RemoteControllerStartMemberArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerStartMemberArgs) String 

func (p *RemoteControllerStartMemberArgs) String() string

func (*RemoteControllerStartMemberArgs) Write 

func (p *RemoteControllerStartMemberArgs) Write(ctx context.Context, 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(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerStartMemberResult) ReadField0 

func (p *RemoteControllerStartMemberResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerStartMemberResult) ReadField1 

func (p *RemoteControllerStartMemberResult) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerStartMemberResult) String 

func (p *RemoteControllerStartMemberResult) String() string

func (*RemoteControllerStartMemberResult) Write 

func (p *RemoteControllerStartMemberResult) Write(ctx context.Context, 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(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerSuspendMemberArgs) ReadField1 

func (p *RemoteControllerSuspendMemberArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerSuspendMemberArgs) ReadField2 

func (p *RemoteControllerSuspendMemberArgs) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerSuspendMemberArgs) String 

func (p *RemoteControllerSuspendMemberArgs) String() string

func (*RemoteControllerSuspendMemberArgs) Write 

func (p *RemoteControllerSuspendMemberArgs) Write(ctx context.Context, 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(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerSuspendMemberResult) ReadField0 

func (p *RemoteControllerSuspendMemberResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerSuspendMemberResult) String 

func (p *RemoteControllerSuspendMemberResult) String() string

func (*RemoteControllerSuspendMemberResult) Write 

func (p *RemoteControllerSuspendMemberResult) Write(ctx context.Context, 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(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerTerminateClusterArgs) ReadField1 

func (p *RemoteControllerTerminateClusterArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerTerminateClusterArgs) String 

func (p *RemoteControllerTerminateClusterArgs) String() string

func (*RemoteControllerTerminateClusterArgs) Write 

func (p *RemoteControllerTerminateClusterArgs) Write(ctx context.Context, 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(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerTerminateClusterResult) ReadField0 

func (p *RemoteControllerTerminateClusterResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerTerminateClusterResult) String 

func (p *RemoteControllerTerminateClusterResult) String() string

func (*RemoteControllerTerminateClusterResult) Write 

func (p *RemoteControllerTerminateClusterResult) Write(ctx context.Context, 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(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerTerminateMemberArgs) ReadField1 

func (p *RemoteControllerTerminateMemberArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerTerminateMemberArgs) ReadField2 

func (p *RemoteControllerTerminateMemberArgs) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerTerminateMemberArgs) String 

func (p *RemoteControllerTerminateMemberArgs) String() string

func (*RemoteControllerTerminateMemberArgs) Write 

func (p *RemoteControllerTerminateMemberArgs) Write(ctx context.Context, 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(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerTerminateMemberResult) ReadField0 

func (p *RemoteControllerTerminateMemberResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*RemoteControllerTerminateMemberResult) String 

func (p *RemoteControllerTerminateMemberResult) String() string

func (*RemoteControllerTerminateMemberResult) Write 

func (p *RemoteControllerTerminateMemberResult) Write(ctx context.Context, oprot thrift.TProtocol) error

type Response 

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

Attributes:

  • Success
  • Message
  • Result_
var RemoteControllerExecuteOnControllerResult_Success_DEFAULT *Response

func MapSetOnServer added in v1.2.0 

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

func NewResponse 

func NewResponse() *Response

func (*Response) Equals 

func (p *Response) Equals(other *Response) bool

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(ctx context.Context, iprot thrift.TProtocol) error

func (*Response) ReadField1 

func (p *Response) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*Response) ReadField2 

func (p *Response) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*Response) ReadField3 

func (p *Response) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*Response) String 

func (p *Response) String() string

func (*Response) Write 

func (p *Response) Write(ctx context.Context, oprot thrift.TProtocol) error

type SamplePortable 

type SamplePortable struct {
	A string
	B int32
}

func (SamplePortable) ClassID 

func (s SamplePortable) ClassID() int32

func (SamplePortable) FactoryID 

func (s SamplePortable) FactoryID() int32

func (SamplePortable) Json 

func (s SamplePortable) Json() serialization.JSON

func (*SamplePortable) ReadPortable 

func (s *SamplePortable) ReadPortable(reader serialization.PortableReader)

func (SamplePortable) WritePortable 

func (s SamplePortable) WritePortable(writer serialization.PortableWriter)

type SamplePortableFactory 

type SamplePortableFactory struct {
}

func (SamplePortableFactory) Create 

func (f SamplePortableFactory) Create(classID int32) serialization.Portable

func (SamplePortableFactory) FactoryID 

func (f SamplePortableFactory) FactoryID() int32

type ServerException 

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

Attributes:

  • Message
var RemoteControllerCreateClusterKeepClusterNameResult_ServerException_DEFAULT *ServerException
var RemoteControllerCreateClusterResult_ServerException_DEFAULT *ServerException
var RemoteControllerStartMemberResult_ServerException_DEFAULT *ServerException

func NewServerException 

func NewServerException() *ServerException

func (*ServerException) Equals 

func (p *ServerException) Equals(other *ServerException) bool

func (*ServerException) Error 

func (p *ServerException) Error() string

func (*ServerException) GetMessage 

func (p *ServerException) GetMessage() string

func (*ServerException) Read 

func (p *ServerException) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*ServerException) ReadField1 

func (p *ServerException) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*ServerException) String 

func (p *ServerException) String() string

func (ServerException) TExceptionType 

func (ServerException) TExceptionType() thrift.TExceptionType

func (*ServerException) Write 

func (p *ServerException) Write(ctx context.Context, oprot thrift.TProtocol) error

type SingletonTestCluster added in v1.3.1 

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

func NewSingletonTestCluster added in v1.3.1 

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

func (*SingletonTestCluster) Launch added in v1.3.1 

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

type TestCluster 

type TestCluster struct {
	RC          *RemoteControllerClientWrapper
	ClusterID   string
	MemberUUIDs []string
	Port        int
}

func StartNewClusterWithConfig added in v1.1.1 

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

func StartNewClusterWithOptions 

func StartNewClusterWithOptions(clusterName string, port, memberCount int) *TestCluster

func (TestCluster) DefaultConfig 

func (c TestCluster) DefaultConfig() hz.Config

func (TestCluster) DefaultConfigWithNoSSL added in v1.3.0 

func (c TestCluster) DefaultConfigWithNoSSL() hz.Config

func (TestCluster) Shutdown 

func (c TestCluster) Shutdown()

func (TestCluster) StartMember added in v1.4.0 

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

Source Files

View all Source files

Directories

Path Synopsis

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.