Documentation ¶
Index ¶
- Constants
- Variables
- func CheckClusterVersion(ctx context.Context, client pd.Client, pdAddrs []string, ...) error
- func CheckPDVersion(ctx context.Context, pdAddr string, credential *security.Credential) error
- func CheckStoreVersion(ctx context.Context, client pd.Client, storeID uint64) error
- func CheckTiKVCDCClusterVersion(cdcClusterVer TiKVCDCClusterVersion) (unknown bool, err error)
- func GetRawInfo() string
- func LogVersionInfo()
- func ReleaseSemver() string
- type TiKVCDCClusterVersion
Constants ¶
const (
PDRequestTimeout = 5 * time.Second
)
Variables ¶
var ( ReleaseVersion = "None" BuildTS = "None" GitHash = "None" GitBranch = "None" GoVersion = "None" )
Version information.
var ( // MinTiKVVersion is the version of the minimal compatible TiKV. MinTiKVVersion *semver.Version = semver.New("6.2.0-alpha") )
var TiKVCDCClusterVersionUnknown = TiKVCDCClusterVersion{}
TiKVCDCClusterVersionUnknown is a read-only variable to represent the unknown cluster version
Functions ¶
func CheckClusterVersion ¶
func CheckClusterVersion( ctx context.Context, client pd.Client, pdAddrs []string, credential *security.Credential, errorTiKVIncompat bool, ) error
CheckClusterVersion check TiKV and PD version. need only one PD alive and match the cdc version.
func CheckPDVersion ¶
CheckPDVersion check PD version.
func CheckStoreVersion ¶
CheckStoreVersion checks whether the given TiKV is compatible with this CDC. If storeID is 0, it checks all TiKV.
func CheckTiKVCDCClusterVersion ¶
func CheckTiKVCDCClusterVersion(cdcClusterVer TiKVCDCClusterVersion) (unknown bool, err error)
CheckTiKVCDCClusterVersion returns the version of ticdc cluster
func ReleaseSemver ¶
func ReleaseSemver() string
ReleaseSemver returns a valid Semantic Versions or an empty if the ReleaseVersion is not set at compile time.
Types ¶
type TiKVCDCClusterVersion ¶
TiKVCDCClusterVersion is the version of TiKVCDC cluster
func GetTiKVCDCClusterVersion ¶
func GetTiKVCDCClusterVersion(captureVersion []string) (TiKVCDCClusterVersion, error)
GetTiKVCDCClusterVersion returns the version of ticdc cluster
func (*TiKVCDCClusterVersion) IsUnknown ¶
func (v *TiKVCDCClusterVersion) IsUnknown() bool
IsUnknown returns whether this is an unknown version