Documentation ¶
Index ¶
Constants ¶
View Source
const ( // TestCurrentClusterInitialFailoverVersion is initial failover version for current cluster TestCurrentClusterInitialFailoverVersion = int64(0) // TestAlternativeClusterInitialFailoverVersion is initial failover version for alternative cluster TestAlternativeClusterInitialFailoverVersion = int64(1) // TestFailoverVersionIncrement is failover version increment used for test TestFailoverVersionIncrement = int64(10) // TestCurrentClusterName is current cluster used for test TestCurrentClusterName = "active" // TestAlternativeClusterName is alternative cluster used for test TestAlternativeClusterName = "standby" // TestCurrentClusterFrontendAddress is the ip port address of current cluster TestCurrentClusterFrontendAddress = "127.0.0.1:7104" // TestAlternativeClusterFrontendAddress is the ip port address of alternative cluster TestAlternativeClusterFrontendAddress = "127.0.0.1:8104" )
Variables ¶
View Source
var ( // TestAllClusterNames is the all cluster names used for test TestAllClusterNames = []string{TestCurrentClusterName, TestAlternativeClusterName} // TestAllClusterInfo is the same as above, just convenient for test mocking TestAllClusterInfo = map[string]config.ClusterInformation{ TestCurrentClusterName: config.ClusterInformation{ Enabled: true, InitialFailoverVersion: TestCurrentClusterInitialFailoverVersion, RPCName: common.FrontendServiceName, RPCAddress: TestCurrentClusterFrontendAddress, }, TestAlternativeClusterName: config.ClusterInformation{ Enabled: true, InitialFailoverVersion: TestAlternativeClusterInitialFailoverVersion, RPCName: common.FrontendServiceName, RPCAddress: TestAlternativeClusterFrontendAddress, }, } // TestSingleDCAllClusterNames is the all cluster names used for test TestSingleDCAllClusterNames = []string{TestCurrentClusterName} // TestSingleDCClusterInfo is the same as above, just convenient for test mocking TestSingleDCClusterInfo = map[string]config.ClusterInformation{ TestCurrentClusterName: config.ClusterInformation{ Enabled: true, InitialFailoverVersion: TestCurrentClusterInitialFailoverVersion, RPCName: common.FrontendServiceName, RPCAddress: TestCurrentClusterFrontendAddress, }, } )
Functions ¶
This section is empty.
Types ¶
type Metadata ¶
type Metadata interface { // IsGlobalDomainEnabled whether the global domain is enabled, // this attr should be discarded when cross DC is made public IsGlobalDomainEnabled() bool // IsMasterCluster whether current cluster is master cluster IsMasterCluster() bool // GetNextFailoverVersion return the next failover version for domain failover GetNextFailoverVersion(string, int64) int64 // IsVersionFromSameCluster return true if 2 version are used for the same cluster IsVersionFromSameCluster(version1 int64, version2 int64) bool // GetMasterClusterName return the master cluster name GetMasterClusterName() string // GetCurrentClusterName return the current cluster name GetCurrentClusterName() string // GetAllClusterInfo return the all cluster name -> corresponding info GetAllClusterInfo() map[string]config.ClusterInformation // ClusterNameForFailoverVersion return the corresponding cluster name for a given failover version ClusterNameForFailoverVersion(failoverVersion int64) string }
Metadata provides information about clusters
func GetTestClusterMetadata ¶ added in v0.3.11
GetTestClusterMetadata return an cluster metadata instance, which is initialized
func NewMetadata ¶
func NewMetadata( logger log.Logger, enableGlobalDomain dynamicconfig.BoolPropertyFn, failoverVersionIncrement int64, masterClusterName string, currentClusterName string, clusterInfo map[string]config.ClusterInformation, ) Metadata
NewMetadata create a new instance of Metadata
Click to show internal directories.
Click to hide internal directories.