ticdcapi

type CaptureStatus struct {
	ID      string `json:"id"`
	Version string `json:"version"`
	IsOwner bool   `json:"is_owner"`
}

type Option func(opt *Options)

type Options struct {
	Timeout           time.Duration
	TLS               *tls.Config
	DisableKeepAlives bool
	// contains filtered or unexported fields
}

type TiCDCClient interface {
	// GetStatus returns ticdc's status
	GetStatus(ctx context.Context) (*CaptureStatus, error)
	// DrainCapture remove capture ownership and moves its tables to other captures.
	// Returns the number of tables in the capture.
	// If there is only one capture, it always return 0.
	DrainCapture(ctx context.Context) (tableCount int, err error)
	// ResignOwner tries to resign ownership from the current capture.
	// Returns true if the capture has already resigned ownership,
	// otherwise caller should retry resign owner.
	// If there is only one capture, it always return true.
	ResignOwner(ctx context.Context) (ok bool, err error)
	// IsHealthy gets the healthy status of TiCDC cluster.
	// Returns true if the TiCDC cluster is healthy.
	IsHealthy(ctx context.Context) (ok bool, err error)
}