agent

type Config struct {
	*flag.FlagSet

	// ClusterName distinguishes one Master-Slaves cluster from another
	ClusterName string `toml:"cluster-name" json:"cluster-name"`

	// LeaderLeaseTTL is the leader lease time to live, measured by second
	LeaderLeaseTTL int64 `toml:"leader-lease-ttl" json:"leader-lease-ttl"`
	// ShutdownThreshold is the time that costs when agent shutdown, measured by second
	ShutdownThreshold int64 `toml:"shutdown-threshold" json:"shutdown-threshold"`

	DataDir    string `toml:"data-dir" json:"data-dir"`
	NodeID     string `toml:"node-id" json:"node-id"`
	ListenAddr string `toml:"addr" json:"addr"`

	// OnlyFollow decides whether current node join in leader campaign
	// if onlyFollow is true, current node will NOT campaign leader
	// else, aka onlyFollow is false, node will participate in leader campaign
	OnlyFollow bool `toml:"only-follow" json:"only-follow"`

	EtcdURLs        string `toml:"etcd-urls" json:"etcd-urls"`
	EtcdDialTimeout time.Duration
	RefreshInterval int    `toml:"refresh-interval" json:"refresh-interval"`
	RegisterTTL     int    `toml:"register-ttl" json:"register-ttl"`
	EtcdRootPath    string `toml:"etcd-root-path" json:"etcd-root-path"`
	EtcdUsername    string `toml:"etcd-username" json:"etcd-username"`
	EtcdPassword    string `toml:"etcd-password" json:"etcd-password"`

	LogLevel    string `toml:"log-level" json:"log-level"`
	LogFile     string `toml:"log-file" json:"log-file"`
	ErrorLog    string `toml:"error-log" json:"error-log"`
	LogMaxSize  int    `toml:"log-max-size" json:"log-max-size"`
	LogMaxDays  int    `toml:"log-max-days" json:"log-max-days"`
	LogCompress bool   `toml:"log-compress" json:"log-compress"`

	ServiceType string         `toml:"service-type" json:"service-type"`
	DBConfig    types.DBConfig `toml:"db-config" json:"db-config"`

	InternalServiceHost string `toml:"internal-service-host" json:"internal-service-host"`
	ExternalServiceHost string `toml:"external-service-host" json:"external-service-host"`

	ForkProcessFile       string   `toml:"fork-process-file" json:"fork-process-file"`
	ForkProcessArgs       []string `toml:"fork-process-args" json:"fork-process-args"`
	ForkProcessWaitSecond int      `toml:"fork-process-wait-second" json:"fork-process-wait-second"`

	CampaignWaitTime time.Duration
	// contains filtered or unexported fields
}

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

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

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

type LogForElection struct {
	Term     uint64 `json:"term"`
	LastUUID string `json:"last_uuid"`
	LastGTID string `json:"last_gtid"`
	EndTxnID uint64 `json:"end_txn_id"`

	// Version is the schema version of LogForElection, used for backward compatibility
	Version int `json:"version"`
}

type Node interface {
	// ID returns node ID
	ID() string
	// Register registers node to etcd.
	Register(ctx context.Context) error
	// Unregister unregisters node from etcd.
	Unregister(ctx context.Context) error
	// Heartbeat refreshes node state in etcd.
	// key 'root/nodes/<nodeID/alive' will disappear after TTL time passed.
	Heartbeat(ctx context.Context) <-chan error
	// RowClient returns raw etcd client.
	RawClient() *etcd.Client
	// NodeStatus return one node status
	NodeStatus(ctx context.Context, nodeID string) (*NodeStatus, error)
}

type NodeStatus struct {
	NodeID       string
	InternalHost string
	ExternalHost string
	IsAlive      bool     `json:",omitempty"`
	LatestPos    Position `json:",omitempty"`
}

type Position struct {
	File string
	Pos  string
	GTID string

	UUID string

	EndTxnID uint64 `json:",omitempty"`

	SlaveIORunning      bool `json:",omitempty"`
	SlaveSQLRunning     bool `json:",omitempty"`
	SecondsBehindMaster int  `json:",omitempty"`
}

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

type ServiceManager interface {
	// SetReadOnly set service readonly
	SetReadOnly() error
	// SetReadWrite set service readwrite
	SetReadWrite() error
	// PromoteToMaster promotes a slave to master
	PromoteToMaster() error
	// RedirectMaster make a slave point to another master
	RedirectMaster(masterHost, masterPort string) error
	// SetReadOnlyManually sets service readonly, but only executed manually
	SetReadOnlyManually() (bool, error)

	LoadSlaveStatusFromDB() (*Position, error)
	LoadMasterStatusFromDB() (*Position, error)
	LoadReplicationInfoOfMaster() (masterUUID, executedGTID string, endTxnID uint64, err error)
	LoadReplicationInfoOfSlave() (masterUUID, executedGTID string, endTxnID uint64, err error)
	GetServerUUID() (string, error)

	Close() error
}

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