Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CheckRole ¶
type CheckRole struct {
operations.Base
OriRole string
CheckRoleFailedCount int
FailedEventReportFrequency int
Timeout time.Duration
DBRoles map[string]AccessMode
Command []string
// contains filtered or unexported fields
}
func (*CheckRole) Do ¶
func (s *CheckRole) Do(ctx context.Context, _ *operations.OpsRequest) (*operations.OpsResponse, error)
type CheckRunning ¶
type CheckRunning struct {
operations.Base
Timeout time.Duration
DBAddress string
CheckRunningFailedCount int
FailedEventReportFrequency int
// contains filtered or unexported fields
}
CheckRunning checks whether the binding service is in running status, If check fails continuously, report an event at FailedEventReportFrequency frequency
func (*CheckRunning) Do ¶
func (s *CheckRunning) Do(ctx context.Context, req *operations.OpsRequest) (*operations.OpsResponse, error)
type CheckStatus ¶
type CheckStatus struct {
operations.Base
LeaderFailedCount int
FailureThreshold int
// contains filtered or unexported fields
}
func (*CheckStatus) Do ¶
func (s *CheckStatus) Do(ctx context.Context, req *operations.OpsRequest) (*operations.OpsResponse, error)
func (*CheckStatus) IsReadonly ¶
func (s *CheckStatus) IsReadonly(ctx context.Context) bool
type FailoverManager ¶ added in v0.8.4
type GetLag ¶
type GetLag struct {
operations.Base
// contains filtered or unexported fields
}
func (*GetLag) Do ¶
func (s *GetLag) Do(ctx context.Context, req *operations.OpsRequest) (*operations.OpsResponse, error)
type GetRole ¶
type GetRole struct {
operations.Base
// contains filtered or unexported fields
}
func (*GetRole) Do ¶
func (s *GetRole) Do(ctx context.Context, req *operations.OpsRequest) (*operations.OpsResponse, error)
type Join ¶
type Join struct {
operations.Base
Timeout time.Duration
Command []string
// contains filtered or unexported fields
}
func (*Join) Do ¶
func (s *Join) Do(ctx context.Context, req *operations.OpsRequest) (*operations.OpsResponse, error)
type Leave ¶
type Leave struct {
operations.Base
Timeout time.Duration
Command []string
// contains filtered or unexported fields
}
func (*Leave) Do ¶
func (s *Leave) Do(ctx context.Context, req *operations.OpsRequest) (*operations.OpsResponse, error)
type Switchover ¶
type Switchover struct {
operations.Base
// contains filtered or unexported fields
}
func (*Switchover) Do ¶
func (s *Switchover) Do(ctx context.Context, req *operations.OpsRequest) (*operations.OpsResponse, error)
func (*Switchover) PreCheck ¶
func (s *Switchover) PreCheck(ctx context.Context, req *operations.OpsRequest) error
Click to show internal directories.
Click to hide internal directories.