replica

Documentation

Index

• type AccessMode
• type CheckRole
  • func (s *CheckRole) Do(ctx context.Context, _ *operations.OpsRequest) (*operations.OpsResponse, error)
  • func (s *CheckRole) Init(ctx context.Context) error
  • func (s *CheckRole) IsReadonly(ctx context.Context) bool
• type CheckRunning
  • func (s *CheckRunning) Do(ctx context.Context, req *operations.OpsRequest) (*operations.OpsResponse, error)
  • func (s *CheckRunning) Init(ctx context.Context) error
• type CheckStatus
  • func (s *CheckStatus) Do(ctx context.Context, req *operations.OpsRequest) (*operations.OpsResponse, error)
  • func (s *CheckStatus) Init(ctx context.Context) error
  • func (s *CheckStatus) IsReadonly(ctx context.Context) bool
• type FailoverManager
• type GetLag
  • func (s *GetLag) Do(ctx context.Context, req *operations.OpsRequest) (*operations.OpsResponse, error)
  • func (s *GetLag) Init(context.Context) error
  • func (s *GetLag) IsReadonly(context.Context) bool
• type GetRole
  • func (s *GetRole) Do(ctx context.Context, req *operations.OpsRequest) (*operations.OpsResponse, error)
  • func (s *GetRole) Init(ctx context.Context) error
  • func (s *GetRole) IsReadonly(ctx context.Context) bool
• type Join
  • func (s *Join) Do(ctx context.Context, req *operations.OpsRequest) (*operations.OpsResponse, error)
  • func (s *Join) Init(ctx context.Context) error
• type Leave
  • func (s *Leave) Do(ctx context.Context, req *operations.OpsRequest) (*operations.OpsResponse, error)
  • func (s *Leave) Init(ctx context.Context) error
• type Switchover
  • func (s *Switchover) Do(ctx context.Context, req *operations.OpsRequest) (*operations.OpsResponse, error)
  • func (s *Switchover) Init(_ context.Context) error
  • func (s *Switchover) PreCheck(ctx context.Context, req *operations.OpsRequest) error
• type SwitchoverManager

Types

type AccessMode

type AccessMode string

AccessMode defines SVC access mode enums. +enum

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)

func (*CheckRole) Init

func (s *CheckRole) Init(ctx context.Context) error

func (*CheckRole) IsReadonly

func (s *CheckRole) IsReadonly(ctx context.Context) bool

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)

func (*CheckRunning) Init

func (s *CheckRunning) Init(ctx context.Context) 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) Init

func (s *CheckStatus) Init(ctx context.Context) error

func (*CheckStatus) IsReadonly

func (s *CheckStatus) IsReadonly(ctx context.Context) bool

type FailoverManager

type FailoverManager interface {
	Failover(ctx context.Context, cluster *dcs.Cluster, candidate string) error
}

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)

func (*GetLag) Init

func (s *GetLag) Init(context.Context) error

func (*GetLag) IsReadonly

func (s *GetLag) IsReadonly(context.Context) bool

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)

func (*GetRole) Init

func (s *GetRole) Init(ctx context.Context) error

func (*GetRole) IsReadonly

func (s *GetRole) IsReadonly(ctx context.Context) bool

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)

func (*Join) Init

func (s *Join) Init(ctx context.Context) 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)

func (*Leave) Init

func (s *Leave) Init(ctx context.Context) 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) Init

func (s *Switchover) Init(_ context.Context) error

func (*Switchover) PreCheck

func (s *Switchover) PreCheck(ctx context.Context, req *operations.OpsRequest) error

type SwitchoverManager

type SwitchoverManager interface {
	Switchover(ctx context.Context, cluster *dcs.Cluster, primary, candidate string, force bool) error
}