nimo-shake/common/fcv.go

package utils

var (
	FcvCheckpoint = Checkpoint{
		CurrentVersion:           0,
		FeatureCompatibleVersion: 0,
	}
	FcvConfiguration = Configuration{
		CurrentVersion:           4,
		FeatureCompatibleVersion: 1,
	}

	LowestCheckpointVersion = map[int]string{
		0: "1.0.0",
	}
	LowestConfigurationVersion = map[int]string{
		0: "1.0.0",
		1: "1.0.6",  // add full sync and incr sync http port
		2: "1.0.8",  // add full.read.concurrency
		3: "1.0.9",  // add full.document.write.batch
		4: "1.0.11", // add source.endpoint_url
	}
)

type Fcv interface {
	IsCompatible(int) bool
}

// for checkpoint
type Checkpoint struct {
	/*
	 * version: 0(or set not), MongoShake < 2.4, fcv == 0
	 * version: 1, MongoShake == 2.4, 0 < fcv <= 1
	 */
	CurrentVersion           int
	FeatureCompatibleVersion int
}

func (c Checkpoint) IsCompatible(v int) bool {
	return v >= c.FeatureCompatibleVersion && v <= c.CurrentVersion
}

// for configuration
type Configuration struct {
	/*
	 * version: 0(or set not), MongoShake < 2.4.0, fcv == 0
	 * version: 1, MongoShake == 2.4.0, 0 <= fcv <= 1
	 */
	CurrentVersion           int
	FeatureCompatibleVersion int
}

func (c Configuration) IsCompatible(v int) bool {
	return v >= c.FeatureCompatibleVersion && v <= c.CurrentVersion
}