replicaset

type BootstrapCtx struct {
	// 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 Bootstrapper interface {
	// Bootstrap bootstraps an instance/application.
	Bootstrap(ctx BootstrapCtx) error
}

type CConfigApplication struct {
	// contains filtered or unexported fields
}

type CConfigInstance struct {
	// contains filtered or unexported fields
}

type CConfigSource struct {
	// contains filtered or unexported fields
}

type CacheBehavior bool

type CustomApplication struct {
	// contains filtered or unexported fields
}

type CustomInstance struct {
	// contains filtered or unexported fields
}

type DataPublisher interface {
	// Publish publishes the config.
	Publish(key string, revision int64, data []byte) error
}

type DemoteCtx struct {
	// InstName is an instance name to demote.
	InstName string
	// Force is true when demoting can skip
	// some non-critical checks.
	Force bool
	// Timeout is a timeout for demoting waitings in seconds.
	// Keep int, because it can be passed to the target instance.
	Timeout int
}

type Demoter interface {
	// Demote demotes an instance.
	Demote(ctx DemoteCtx) error
}

type Discoverer interface {
	// Discovery returns replicasets information or an error.
	Discovery(behavior CacheBehavior) (Replicasets, error)
}

type ElectionMode int

type ExpelCtx struct {
	// InstName is an instance name to expel.
	InstName string
	// Force is true when expelling can skip
	// some non-critical checks.
	Force bool
	// Timeout is a timeout for expelling waitings in seconds.
	// Keep int, because it can be passed to the target instance.
	Timeout int
}

type Expeller interface {
	// Expel expels instance from a replicasets by its name.
	Expel(ctx ExpelCtx) error
}

type Failover int

type Instance struct {
	// Alias is a human-readable instance name.
	Alias string `mapstructure:"alias"`
	// UUID of the instance.
	UUID string `mapstructure:"uuid"`
	// URI of the instance.
	URI string `mapstructure:"uri"`
	// Mode of the instance.
	Mode Mode `mapstructure:"mode"`
	// InstanceCtx is an instance application context. It is configured if
	// InstanceCtxFound == true.
	InstanceCtx running.InstanceCtx `mapstructure:"-"`
	// InstanceCtxFound is true if an instance is connectable and could be
	// determined.
	InstanceCtxFound bool `mapstructure:"-"`
}

type InstanceEvalFunc func(instance running.InstanceCtx,
	evaler connector.Evaler) (bool, error)

type InstanceEvaler interface {
	// Eval could return true or an error to stop execution.
	Eval(instance running.InstanceCtx, evaler connector.Evaler) (bool, error)
}

type KeyPicker func(keys []string, force bool, pathMsg string) (int, error)

type Master int

type Mode int

type Orchestrator int

type PromoteCtx struct {
	// InstName is an instance name to promote.
	InstName string
	// Force is true when promoting can skip
	// some non-critical checks.
	Force bool
	// Timeout is a timeout for promoting waitings in seconds.
	// Keep int, because it can be passed to the target instance.
	Timeout int
}

type Promoter interface {
	// Promote promotes an instance.
	Promote(ctx PromoteCtx) error
}

type RebootstrapCtx struct {
	// Instance is the instance to re-bootstrap, as the instance commands
	// resolve it.
	Instance running.InstanceCtx
	// Confirmed is true if re-bootstrap confirmation is not required.
	Confirmed bool
}

type Replicaset struct {
	// UUID is UUID of the replicaset.
	UUID string
	// LeaderUUID is UUID of the leader in the replicaset. Could be "" if there
	// is no configured leader.
	LeaderUUID string
	// Alias is an alias name of the replicaset.
	Alias string
	// Roles is a list of roles of the replicaset.
	Roles []string
	// Master is a current master mode.
	Master Master
	// Failover is a configured failover.
	Failover Failover
	// Instances is a list of instances in the replicaset.
	Instances []Instance
}

type Replicasets struct {
	// State is a current state.
	State State
	// Orchestrator is a used orchestrator.
	Orchestrator Orchestrator
	// Replicasets is a list of replicasets.
	Replicasets []Replicaset
}

type RoleAction uint

type RolesAdder struct{}

type RolesChangeCtx struct {
	// InstName is an instance name in which add/remove role.
	InstName string
	// GroupName is an instance name in which add/remove role.
	GroupName string
	// ReplicasetName is an instance name in which add/remove role.
	ReplicasetName string
	// IsGlobal is an boolean value if role needs to add/remove in global scope.
	IsGlobal bool
	// RoleName is a role name which needs to add/remove into config.
	RoleName string
	// Force is true when promoting can skip
	// some non-critical checks.
	Force bool
	// Timeout is a timeout for promoting waitings in seconds.
	// Keep int, because it can be passed to the target instance.
	Timeout int
}

type RolesChanger interface {
	// RolesChange adds/removes role for a replicasets by its name.
	RolesChange(ctx RolesChangeCtx, action RolesChangerAction) error
}

type RolesChangerAction interface {
	// ChangeRoleFunc is a function type for addition or removing a role.
	Change(roles []string, role string) ([]string, error)
	// Action is a method that returns RoleAction.
	Action() RoleAction
}

type RolesRemover struct{}

type State int

type VShardBootstrapCtx struct {
	// Timeout is a timeout for bootstrapping in seconds.
	// Keep int, because it can be passed to the target instance.
	Timeout int
}

type VShardBootstrapper interface {
	// BootstrapVShard bootstraps vshard in the cluster.
	BootstrapVShard(ctx VShardBootstrapCtx) error
}