backup

type BackupCleaner interface {
	Clean(backup *v1alpha1.Backup) error
}

type BackupTracker interface {
	StartTrackLogBackupProgress(backup *v1alpha1.Backup) error
	GetLogBackupTC(backup *v1alpha1.Backup) (*v1alpha1.TidbCluster, error)

	// New methods for unified state management
	GetLogBackupState(backup *v1alpha1.Backup, forceRefresh ...bool) (*LogBackupState, error)
	SyncLogBackupState(backup *v1alpha1.Backup) (bool, error)
	RefreshLogBackupState(backup *v1alpha1.Backup) (*LogBackupState, error)
	StopTrackLogBackupProgress(backup *v1alpha1.Backup)
}

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

type LogBackupKernelState string

type LogBackupState struct {
	// Raw data from etcd queries
	CheckpointTS uint64 // checkpoint timestamp
	IsPaused     bool   // whether the backup is paused
	PauseReason  string // pause reason (manual or error message)
	LastError    string // last error message
	InfoExists   bool   // whether the info key exists in etcd

	// Derived state information
	KernelState LogBackupKernelState // kernel state (running/paused)

	// Metadata
	LastQueryTime time.Time // last query timestamp
	QueryError    error     // non-fatal partial query error, currently used when pause state is unknown
}

type ManifestFetcher interface {
	ListByTC(tc *v1alpha1.TidbCluster) (objects []runtime.Object, err error)
}

type PauseStatus struct {
	IsPaused bool
	Message  string
}

type PauseV2Info struct {
	// Severity is the severity of this pause.
	// `SeverityError`: The task encounters some fatal errors and have to be paused.
	// `SeverityManual`: The task was paused by a normal operation.
	Severity string `json:"severity"`
	// OperatorHostName is the hostname that pauses the task.
	OperatorHostName string `json:"operation_hostname"`
	// OperatorPID is the pid of the operator process.
	OperatorPID int `json:"operation_pid"`
	// OperationTime is the time when the task was paused.
	OperationTime time.Time `json:"operation_time"`
	// PayloadType is the mime type of the payload.
	// For now, only the two types are supported:
	// - application/x-protobuf?messagetype=brpb.StreamBackupError
	// - text/plain
	PayloadType string `json:"payload_type"`
	// Payload is the payload attached to the pause.
	Payload []byte `json:"payload"`
}

type RFC3339Time time.Time

type StreamBackupError struct {
	// the unix epoch time (in millisecs) of the time the error reported.
	HappenAt uint64 `protobuf:"varint,1,opt,name=happen_at,json=happenAt,proto3" json:"happen_at,omitempty"`
	// the unified error code of the error.
	ErrorCode string `protobuf:"bytes,2,opt,name=error_code,json=errorCode,proto3" json:"error_code,omitempty"`
	// the user-friendly error message.
	ErrorMessage string `protobuf:"bytes,3,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// the store id of who issues the error.
	StoreId uint64 `protobuf:"varint,4,opt,name=store_id,json=storeId,proto3" json:"store_id,omitempty"`
}

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

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

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

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