cluster

Sep 5, 2023

Changes in this version

type ClusterInformation

+ Tags map[string]string

type Config

+ Tags map[string]string

type Metadata

+ Start func()

+ Stop func()

Feb 17, 2023

Changes in this version

type ClusterInformation

+ ClusterID string

+ ShardCount int32

Dec 1, 2022

Changes in this version

type MockMetadata

+ func (m *MockMetadata) GetPingChecks() []common.PingCheck

type MockMetadataMockRecorder

+ func (mr *MockMetadataMockRecorder) GetPingChecks() *gomock.Call

Jun 17, 2022

Changes in this version

type Metadata

+ GetClusterID func() int64

type MockMetadata

+ func (m *MockMetadata) GetClusterID() int64

type MockMetadataMockRecorder

+ func (mr *MockMetadataMockRecorder) GetClusterID() *gomock.Call

Feb 9, 2022

Changes in this version

+ const FakeClusterForEmptyVersion

Jan 21, 2022

Changes in this version

+ var MetadataLifetimeHooksModule = fx.Options(fx.Provide(NewMetadataFromConfig), fx.Invoke(MetadataLifetimeHooks))

+ func MetadataLifetimeHooks(lc fx.Lifecycle, clusterMetadata Metadata)

Dec 13, 2021

Changes in this version

+ type CallbackFn func(oldClusterMetadata map[string]*ClusterInformation, ...)

+ type ClusterInformation struct

+ Enabled bool

+ InitialFailoverVersion int64

+ RPCAddress string

+ type Config struct

+ ClusterInformation map[string]ClusterInformation

+ CurrentClusterName string

+ EnableGlobalNamespace bool

+ FailoverVersionIncrement int64

+ MasterClusterName string

type Metadata

+ func NewMetadataForTest(config *Config) Metadata

+ func NewMetadataFromConfig(config *Config, clusterMetadataStore persistence.ClusterMetadataManager, ...) Metadata

+ GetFailoverVersionIncrement func() int64

+ RegisterMetadataChangeCallback func(callbackId string, cb CallbackFn)

+ UnRegisterMetadataChangeCallback func(callbackId string)

type MockMetadata

+ func (m *MockMetadata) GetFailoverVersionIncrement() int64

+ func (m *MockMetadata) RegisterMetadataChangeCallback(callbackId string, cb CallbackFn)

+ func (m *MockMetadata) Start()

+ func (m *MockMetadata) Stop()

+ func (m *MockMetadata) UnRegisterMetadataChangeCallback(callbackId string)

type MockMetadataMockRecorder

+ func (mr *MockMetadataMockRecorder) GetFailoverVersionIncrement() *gomock.Call

+ func (mr *MockMetadataMockRecorder) RegisterMetadataChangeCallback(callbackId, cb interface{}) *gomock.Call

+ func (mr *MockMetadataMockRecorder) Start() *gomock.Call

+ func (mr *MockMetadataMockRecorder) Stop() *gomock.Call

+ func (mr *MockMetadataMockRecorder) UnRegisterMetadataChangeCallback(callbackId interface{}) *gomock.Call

Jun 2, 2021

Changes in this version

+ func NewTestClusterMetadataConfig(enableGlobalNamespace bool, isMasterCluster bool) *config.ClusterMetadata

type Metadata

+ func NewTestClusterMetadata(cfg *config.ClusterMetadata) Metadata

Apr 27, 2021

Changes in this version

+ func GetTestClusterMetadataConfig(enableGlobalNamespace bool, isMasterCluster bool) *config.ClusterMetadata

Jul 15, 2020

Changes in this version

type Metadata

+ GetReplicationConsumerConfig func() *config.ReplicationConsumerConfig

+ IsGlobalNamespaceEnabled func() bool

+ type MockMetadata struct

+ func NewMockMetadata(ctrl *gomock.Controller) *MockMetadata

+ func (m *MockMetadata) ClusterNameForFailoverVersion(failoverVersion int64) string

+ func (m *MockMetadata) EXPECT() *MockMetadataMockRecorder

+ func (m *MockMetadata) GetAllClusterInfo() map[string]config.ClusterInformation

+ func (m *MockMetadata) GetCurrentClusterName() string

+ func (m *MockMetadata) GetMasterClusterName() string

+ func (m *MockMetadata) GetNextFailoverVersion(arg0 string, arg1 int64) int64

+ func (m *MockMetadata) GetReplicationConsumerConfig() *config.ReplicationConsumerConfig

+ func (m *MockMetadata) IsGlobalNamespaceEnabled() bool

+ func (m *MockMetadata) IsMasterCluster() bool

+ func (m *MockMetadata) IsVersionFromSameCluster(version1, version2 int64) bool

+ type MockMetadataMockRecorder struct

+ func (mr *MockMetadataMockRecorder) ClusterNameForFailoverVersion(failoverVersion interface{}) *gomock.Call

+ func (mr *MockMetadataMockRecorder) GetAllClusterInfo() *gomock.Call

+ func (mr *MockMetadataMockRecorder) GetCurrentClusterName() *gomock.Call

+ func (mr *MockMetadataMockRecorder) GetMasterClusterName() *gomock.Call

+ func (mr *MockMetadataMockRecorder) GetNextFailoverVersion(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockMetadataMockRecorder) GetReplicationConsumerConfig() *gomock.Call

+ func (mr *MockMetadataMockRecorder) IsGlobalNamespaceEnabled() *gomock.Call

+ func (mr *MockMetadataMockRecorder) IsMasterCluster() *gomock.Call

+ func (mr *MockMetadataMockRecorder) IsVersionFromSameCluster(version1, version2 interface{}) *gomock.Call

May 14, 2019

Changes in this version

+ var TestAllClusterInfo = map[string]config.ClusterInformation

+ var TestSingleDCClusterInfo = map[string]config.ClusterInformation

type Metadata

+ GetAllClusterInfo func() map[string]config.ClusterInformation

May 8, 2019

Changes in this version

type ArchivalConfig

+ func (a *ArchivalConfig) EnableReadFromArchival() bool

Mar 8, 2019

Changes in this version

+ type ArchivalConfig struct

+ func NewArchivalConfig(status ArchivalStatus, defaultBucket string) *ArchivalConfig

+ func (a *ArchivalConfig) ConfiguredForArchival() bool

+ func (a *ArchivalConfig) GetArchivalStatus() ArchivalStatus

+ func (a *ArchivalConfig) GetDefaultBucket() string

+ func (a *ArchivalConfig) IsValid() bool

+ type ArchivalStatus int

+ const ArchivalDisabled

+ const ArchivalEnabled

+ const ArchivalPaused

+ func GetArchivalStatus(str string) (ArchivalStatus, error)

type Metadata

+ ArchivalConfig func() *ArchivalConfig

Jan 7, 2019

Changes in this version

+ const TestAlternativeClusterFrontendAddress

+ const TestCurrentClusterFrontendAddress

+ var TestAllClusterAddress = map[string]config.Address

+ var TestSingleDCAllClusterAddress = map[string]config.Address

+ var TestSingleDCAllClusterFailoverVersions = map[string]int64

+ var TestSingleDCAllClusterNames = []string

type Metadata

+ GetAllClientAddress func() map[string]config.Address

+ GetDefaultArchivalBucket func() string

+ IsArchivalEnabled func() bool

Jul 24, 2018

Changes in this version

type Metadata

+ IsVersionFromSameCluster func(version1 int64, version2 int64) bool

Apr 16, 2018

Changes in this version

+ const TestAlternativeClusterInitialFailoverVersion

+ const TestAlternativeClusterName

+ const TestCurrentClusterInitialFailoverVersion

+ const TestCurrentClusterName

+ const TestFailoverVersionIncrement

+ var TestAllClusterFailoverVersions = map[string]int64

+ var TestAllClusterNames = []string

type Metadata

+ func GetTestClusterMetadata(enableGlobalDomain bool, isMasterCluster bool) Metadata

+ ClusterNameForFailoverVersion func(failoverVersion int64) string

+ GetAllClusterFailoverVersions func() map[string]int64

Mar 12, 2018

Changes in this version

+ type Metadata interface

+ GetAllClusterNames func() map[string]bool

+ GetCurrentClusterName func() string

+ GetMasterClusterName func() string

+ GetNextFailoverVersion func(int64) int64

+ IsGlobalDomainEnabled func() bool

+ IsMasterCluster func() bool

+ func NewMetadata(enableGlobalDomain bool, initialFailoverVersion int64, ...) Metadata