it

package
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: Sep 14, 2021 License: Apache-2.0 Imports: 25 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"
View Source 
const DefaultPort = 7701
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 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 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 GetClientMapWithConfig 

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

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 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, configCallback func(*hz.Config), f func(t *testing.T, m *hz.Map))

func MemberCount 

func MemberCount() int

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

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 SSLEnabled 

func SSLEnabled() bool

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. The following conditions may be set: "hz": Hazelcast version "ver": go client version "os": value of runtime.GOOS "enterprise"/"oss": presence of enterprise key environment variable Example: SkipIf(t, "ver > 1.1, hz = 5")

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 Lang 

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

func LangFromString 

func LangFromString(s string) (Lang, error)

func LangPtr 

func LangPtr(v Lang) *Lang

func (Lang) MarshalText 

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

func (*Lang) Scan 

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

func (Lang) String 

func (p Lang) String() string

func (*Lang) UnmarshalText 

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

func (*Lang) Value 

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

type Member 

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

Attributes:

  • UUID
  • Host
  • Port
var RemoteControllerStartMemberResult_Success_DEFAULT *Member

func NewMember 

func NewMember() *Member

func (*Member) 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 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 CreateDefaultRemoteController 

func CreateDefaultRemoteController() *RemoteControllerClient

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 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 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 TestCluster 

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

func StartNewCluster 

func StartNewCluster(memberCount int) *TestCluster

func StartNewClusterWithOptions 

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

func (TestCluster) DefaultConfig 

func (c TestCluster) DefaultConfig() hz.Config

func (TestCluster) Shutdown 

func (c TestCluster) Shutdown()

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.