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 (*RemoteControllerCleanArgs) String

func (p *RemoteControllerCleanArgs) String() string

func (*RemoteControllerCleanArgs) Write

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 (*RemoteControllerCleanResult) ReadField0

func (*RemoteControllerCleanResult) String

func (p *RemoteControllerCleanResult) String() string

func (*RemoteControllerCleanResult) Write

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 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 (*RemoteControllerCreateClusterArgs) ReadField1

func (*RemoteControllerCreateClusterArgs) ReadField2

func (*RemoteControllerCreateClusterArgs) String

func (*RemoteControllerCreateClusterArgs) Write

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 (*RemoteControllerCreateClusterKeepClusterNameArgs) GetXmlconfig

func (*RemoteControllerCreateClusterKeepClusterNameArgs) Read

func (*RemoteControllerCreateClusterKeepClusterNameArgs) ReadField1

func (*RemoteControllerCreateClusterKeepClusterNameArgs) ReadField2

func (*RemoteControllerCreateClusterKeepClusterNameArgs) String

func (*RemoteControllerCreateClusterKeepClusterNameArgs) Write

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 (*RemoteControllerCreateClusterKeepClusterNameResult) GetSuccess

func (*RemoteControllerCreateClusterKeepClusterNameResult) IsSetServerException

func (p *RemoteControllerCreateClusterKeepClusterNameResult) IsSetServerException() bool

func (*RemoteControllerCreateClusterKeepClusterNameResult) IsSetSuccess

func (*RemoteControllerCreateClusterKeepClusterNameResult) Read

func (*RemoteControllerCreateClusterKeepClusterNameResult) ReadField0

func (*RemoteControllerCreateClusterKeepClusterNameResult) ReadField1

func (*RemoteControllerCreateClusterKeepClusterNameResult) String

func (*RemoteControllerCreateClusterKeepClusterNameResult) Write

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 (*RemoteControllerCreateClusterResult) IsSetServerException

func (p *RemoteControllerCreateClusterResult) IsSetServerException() bool

func (*RemoteControllerCreateClusterResult) IsSetSuccess

func (p *RemoteControllerCreateClusterResult) IsSetSuccess() bool

func (*RemoteControllerCreateClusterResult) Read

func (*RemoteControllerCreateClusterResult) ReadField0

func (*RemoteControllerCreateClusterResult) ReadField1

func (*RemoteControllerCreateClusterResult) String

func (*RemoteControllerCreateClusterResult) Write

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 (*RemoteControllerExecuteOnControllerArgs) GetLang

func (*RemoteControllerExecuteOnControllerArgs) GetScript

func (*RemoteControllerExecuteOnControllerArgs) Read

func (*RemoteControllerExecuteOnControllerArgs) ReadField1

func (*RemoteControllerExecuteOnControllerArgs) ReadField2

func (*RemoteControllerExecuteOnControllerArgs) ReadField3

func (*RemoteControllerExecuteOnControllerArgs) String

func (*RemoteControllerExecuteOnControllerArgs) Write

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 (*RemoteControllerExecuteOnControllerResult) IsSetSuccess

func (*RemoteControllerExecuteOnControllerResult) Read

func (*RemoteControllerExecuteOnControllerResult) ReadField0

func (*RemoteControllerExecuteOnControllerResult) String

func (*RemoteControllerExecuteOnControllerResult) Write

type RemoteControllerExitArgs

type RemoteControllerExitArgs struct {
}

func NewRemoteControllerExitArgs

func NewRemoteControllerExitArgs() *RemoteControllerExitArgs

func (*RemoteControllerExitArgs) Read

func (*RemoteControllerExitArgs) String

func (p *RemoteControllerExitArgs) String() string

func (*RemoteControllerExitArgs) Write

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 (*RemoteControllerExitResult) ReadField0

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

func (*RemoteControllerExitResult) String

func (p *RemoteControllerExitResult) String() string

func (*RemoteControllerExitResult) Write

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 (*RemoteControllerMergeMemberToClusterArgs) GetMemberId

func (*RemoteControllerMergeMemberToClusterArgs) Read

func (*RemoteControllerMergeMemberToClusterArgs) ReadField1

func (*RemoteControllerMergeMemberToClusterArgs) ReadField2

func (*RemoteControllerMergeMemberToClusterArgs) String

func (*RemoteControllerMergeMemberToClusterArgs) Write

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 (*RemoteControllerMergeMemberToClusterResult) IsSetSuccess

func (*RemoteControllerMergeMemberToClusterResult) Read

func (*RemoteControllerMergeMemberToClusterResult) ReadField0

func (*RemoteControllerMergeMemberToClusterResult) String

func (*RemoteControllerMergeMemberToClusterResult) Write

type RemoteControllerPingArgs

type RemoteControllerPingArgs struct {
}

func NewRemoteControllerPingArgs

func NewRemoteControllerPingArgs() *RemoteControllerPingArgs

func (*RemoteControllerPingArgs) Read

func (*RemoteControllerPingArgs) String

func (p *RemoteControllerPingArgs) String() string

func (*RemoteControllerPingArgs) Write

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 (*RemoteControllerPingResult) ReadField0

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

func (*RemoteControllerPingResult) String

func (p *RemoteControllerPingResult) String() string

func (*RemoteControllerPingResult) Write

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

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 (*RemoteControllerResumeMemberArgs) ReadField1

func (*RemoteControllerResumeMemberArgs) ReadField2

func (*RemoteControllerResumeMemberArgs) String

func (*RemoteControllerResumeMemberArgs) Write

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 (*RemoteControllerResumeMemberResult) ReadField0

func (*RemoteControllerResumeMemberResult) String

func (*RemoteControllerResumeMemberResult) Write

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 (*RemoteControllerShutdownClusterArgs) ReadField1

func (*RemoteControllerShutdownClusterArgs) String

func (*RemoteControllerShutdownClusterArgs) Write

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 (*RemoteControllerShutdownClusterResult) IsSetSuccess

func (p *RemoteControllerShutdownClusterResult) IsSetSuccess() bool

func (*RemoteControllerShutdownClusterResult) Read

func (*RemoteControllerShutdownClusterResult) ReadField0

func (*RemoteControllerShutdownClusterResult) String

func (*RemoteControllerShutdownClusterResult) Write

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 (*RemoteControllerShutdownMemberArgs) ReadField1

func (*RemoteControllerShutdownMemberArgs) ReadField2

func (*RemoteControllerShutdownMemberArgs) String

func (*RemoteControllerShutdownMemberArgs) Write

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 (*RemoteControllerShutdownMemberResult) IsSetSuccess

func (p *RemoteControllerShutdownMemberResult) IsSetSuccess() bool

func (*RemoteControllerShutdownMemberResult) Read

func (*RemoteControllerShutdownMemberResult) ReadField0

func (*RemoteControllerShutdownMemberResult) String

func (*RemoteControllerShutdownMemberResult) Write

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 (*RemoteControllerSplitMemberFromClusterArgs) Read

func (*RemoteControllerSplitMemberFromClusterArgs) ReadField1

func (*RemoteControllerSplitMemberFromClusterArgs) String

func (*RemoteControllerSplitMemberFromClusterArgs) Write

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 (*RemoteControllerSplitMemberFromClusterResult) IsSetSuccess

func (*RemoteControllerSplitMemberFromClusterResult) Read

func (*RemoteControllerSplitMemberFromClusterResult) ReadField0

func (*RemoteControllerSplitMemberFromClusterResult) String

func (*RemoteControllerSplitMemberFromClusterResult) Write

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 (*RemoteControllerStartMemberArgs) ReadField1

func (*RemoteControllerStartMemberArgs) String

func (*RemoteControllerStartMemberArgs) Write

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 (*RemoteControllerStartMemberResult) ReadField0

func (*RemoteControllerStartMemberResult) ReadField1

func (*RemoteControllerStartMemberResult) String

func (*RemoteControllerStartMemberResult) Write

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 (*RemoteControllerSuspendMemberArgs) ReadField1

func (*RemoteControllerSuspendMemberArgs) ReadField2

func (*RemoteControllerSuspendMemberArgs) String

func (*RemoteControllerSuspendMemberArgs) Write

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 (*RemoteControllerSuspendMemberResult) ReadField0

func (*RemoteControllerSuspendMemberResult) String

func (*RemoteControllerSuspendMemberResult) Write

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 (*RemoteControllerTerminateClusterArgs) ReadField1

func (*RemoteControllerTerminateClusterArgs) String

func (*RemoteControllerTerminateClusterArgs) Write

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 (*RemoteControllerTerminateClusterResult) IsSetSuccess

func (p *RemoteControllerTerminateClusterResult) IsSetSuccess() bool

func (*RemoteControllerTerminateClusterResult) Read

func (*RemoteControllerTerminateClusterResult) ReadField0

func (*RemoteControllerTerminateClusterResult) String

func (*RemoteControllerTerminateClusterResult) Write

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 (*RemoteControllerTerminateMemberArgs) Read

func (*RemoteControllerTerminateMemberArgs) ReadField1

func (*RemoteControllerTerminateMemberArgs) ReadField2

func (*RemoteControllerTerminateMemberArgs) String

func (*RemoteControllerTerminateMemberArgs) Write

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 (*RemoteControllerTerminateMemberResult) IsSetSuccess

func (p *RemoteControllerTerminateMemberResult) IsSetSuccess() bool

func (*RemoteControllerTerminateMemberResult) Read

func (*RemoteControllerTerminateMemberResult) ReadField0

func (*RemoteControllerTerminateMemberResult) String

func (*RemoteControllerTerminateMemberResult) Write

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

Jump to

Keyboard shortcuts

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