replicasetcmd

type BootstrapCtx struct {
	// Orchestrator is the orchestrator to use.
	Orchestrator replicaset.Orchestrator
	// RunningCtx is an application running context.
	RunningCtx running.RunningCtx
	// Timeout describes a timeout in seconds.
	// We keep int as it can be passed to the target instance.
	Timeout int
	// BootstrapVShard is true when the vshard must be bootstrapped.
	BootstrapVShard bool
	// Instance is an instance name to bootstrap.
	Instance string
	// Replicaset is a replicaset name for an instance bootstrapping.
	Replicaset string
}

type DemoteCtx struct {
	// InstName is an instance name to demote.
	InstName string
	// Publishers is data publisher factory.
	Publishers sdkcluster.Factory
	// Collectors is data collector factory.
	Collectors sdkcluster.Factory
	// Integrity is the integrity context for cluster reads.
	Integrity integrity.IntegrityCtx
	// Orchestrator is the orchestrator to use.
	Orchestrator replicaset.Orchestrator
	// Conn is an active connection to a passed instance.
	Conn connector.Connector
	// RunningCtx is an application running context.
	RunningCtx running.RunningCtx
	// Force true if unavailable instances can be skipped.
	Force bool
	// Timeout describes a timeout in seconds.
	// We keep int as it can be passed to the target instance.
	Timeout int
}

type DiscoveryCtx struct {
	// IsApplication true if an application passed.
	IsApplication bool
	// RunningCtx is an application running context.
	RunningCtx running.RunningCtx
	// Conn is an active connection to a passed instance.
	Conn connector.Connector
	// Orchestrator is the orchestrator to use.
	Orchestrator replicaset.Orchestrator
}

type DowngradeOpts struct {
	// ChosenReplicasetAliases is a list of replicaset names specified by
	// the user for the downgrade.
	ChosenReplicasetAliases []string
	// Timeout period (in seconds) for waiting on LSN synchronization.
	Timeout int
	// DowngradeVersion is a version to downgrade the schema to.
	DowngradeVersion string
}

type ExpelCtx struct {
	// Instance is a target instance name.
	Instance string
	// Publishers is data publisher factory.
	Publishers sdkcluster.Factory
	// Collectors is data collector factory.
	Collectors sdkcluster.Factory
	// Integrity is the integrity context for cluster reads.
	Integrity integrity.IntegrityCtx
	// Orchestrator is the orchestrator to use.
	Orchestrator replicaset.Orchestrator
	// RunningCtx is an application running context.
	RunningCtx running.RunningCtx
	// Force true if unavailable instances can be skipped.
	Force bool
	// Timeout describes a timeout in seconds.
	// We keep int as it can be passed to the target instance.
	Timeout int
}

type PromoteCtx struct {
	// InstName is an instance name to promote.
	InstName string
	// Publishers is data publisher factory.
	Publishers sdkcluster.Factory
	// Collectors is data collector factory.
	Collectors sdkcluster.Factory
	// Integrity is the integrity context for cluster reads.
	Integrity integrity.IntegrityCtx
	// IsApplication true if an application passed.
	IsApplication bool
	// Orchestrator is the orchestrator to use.
	Orchestrator replicaset.Orchestrator
	// Conn is an active connection to a passed instance.
	Conn connector.Connector
	// RunningCtx is an application running context.
	RunningCtx running.RunningCtx
	// Force true if unavailable instances can be skipped.
	Force bool
	// Timeout describes a timeout in seconds.
	// We keep int as it can be passed to the target instance.
	Timeout int
}

type RolesChangeCtx struct {
	// InstName is an instance name in which add or remove role.
	InstName string
	// GroupName is a replicaset name in which add or remove role.
	GroupName string
	// ReplicasetName is a replicaset name in which add or remove role.
	ReplicasetName string
	// IsGlobal is a boolean value if role needs to add in global scope.
	IsGlobal bool
	// RoleName is a name of role to add.
	RoleName string
	// Publishers is a data publisher factory.
	Publishers sdkcluster.Factory
	// Collectors is a data collector factory.
	Collectors sdkcluster.Factory
	// Integrity is the integrity context for cluster reads.
	Integrity integrity.IntegrityCtx
	// IsApplication is true if an application passed.
	IsApplication bool
	// Orchestrator is the orchestrator to use.
	Orchestrator replicaset.Orchestrator
	// Conn is an active connection to a passed instance.
	Conn connector.Connector
	// RunningCtx is an application running context.
	RunningCtx running.RunningCtx
	// Force is true if unavailable instances can be skipped.
	Force bool
	// Timeout describes a timeout in seconds.
	// We keep int as it can be passed to the target instance.
	Timeout int
}

type UpgradeOpts struct {
	// List of replicaset names specified by the user for the upgrade.
	ChosenReplicasetAliases []string
	// Timeout period (in seconds) for waiting on LSN synchronization.
	LsnTimeout int
}

type VShardCmdCtx struct {
	// IsApplication true if an application passed.
	IsApplication bool
	// RunningCtx is an application running context.
	RunningCtx running.RunningCtx
	// Conn is an active connection to a passed instance.
	Conn connector.Connector
	// Orchestrator is the orchestrator to use.
	Orchestrator replicaset.Orchestrator
	// Publishers is data publisher factory.
	Publishers sdkcluster.Factory
	// Collectors is data collector factory.
	Collectors sdkcluster.Factory
	// Integrity is the integrity context for cluster reads.
	Integrity integrity.IntegrityCtx
	// Timeout describes a timeout in seconds.
	// We keep int as it can be passed to the target instance.
	Timeout int
}