status

Documentation

Index

• func Completed(syncName v1alpha1.SyncTypeName, tc *v1alpha1.TiflowClusterStatus, ...)
• func Failed(syncName v1alpha1.SyncTypeName, tc *v1alpha1.TiflowClusterStatus, ...)
• func GetSyncStatus(syncName v1alpha1.SyncTypeName, tc *v1alpha1.TiflowClusterStatus, ...) v1alpha1.SyncTypeStatus
• func InitExecutorClusterSyncTypesIfNeed(executorStatus *v1alpha1.ExecutorStatus)
• func InitMasterClusterSyncTypesIfNeed(masterStatus *v1alpha1.MasterStatus)
• func Ongoing(syncName v1alpha1.SyncTypeName, tc *v1alpha1.TiflowClusterStatus, ...)
• func Unknown(syncName v1alpha1.SyncTypeName, tc *v1alpha1.TiflowClusterStatus, ...)
• type SyncPhaseManager
  • func NewExecutorPhaseManager(cli client.Client, clientSet kubernetes.Interface, tc *v1alpha1.TiflowCluster) SyncPhaseManager
  • func NewMasterPhaseManager(cli client.Client, clientSet kubernetes.Interface, tc *v1alpha1.TiflowCluster) SyncPhaseManager
• type TiflowClusterStatusManager
  • func (tcsm *TiflowClusterStatusManager) SetTiflowClusterPhase(phase v1alpha1.TiflowClusterPhaseType, message string)
  • func (tcsm *TiflowClusterStatusManager) SyncTiflowClusterPhase()
  • func (tcsm *TiflowClusterStatusManager) Update() error
  • func (tcsm TiflowClusterStatusManager) UpdateTiflowClusterPhase() error
• type UpdateStatus
  • func NewTiflowClusterStatusManager(cli client.Client, clientSet kubernetes.Interface, tc *v1alpha1.TiflowCluster) UpdateStatus
• type Updater

Functions

func Completed

func Completed(syncName v1alpha1.SyncTypeName, tc *v1alpha1.TiflowClusterStatus, member v1alpha1.MemberType, message string)

func Failed

func Failed(syncName v1alpha1.SyncTypeName, tc *v1alpha1.TiflowClusterStatus, member v1alpha1.MemberType, message string)

func GetSyncStatus

func GetSyncStatus(syncName v1alpha1.SyncTypeName, tc *v1alpha1.TiflowClusterStatus, member v1alpha1.MemberType) v1alpha1.SyncTypeStatus

func InitExecutorClusterSyncTypesIfNeed

func InitExecutorClusterSyncTypesIfNeed(executorStatus *v1alpha1.ExecutorStatus)

func InitMasterClusterSyncTypesIfNeed

func InitMasterClusterSyncTypesIfNeed(masterStatus *v1alpha1.MasterStatus)

func Ongoing

func Ongoing(syncName v1alpha1.SyncTypeName, tc *v1alpha1.TiflowClusterStatus, member v1alpha1.MemberType, message string)

func Unknown

func Unknown(syncName v1alpha1.SyncTypeName, tc *v1alpha1.TiflowClusterStatus, member v1alpha1.MemberType, message string)

Types

type SyncPhaseManager

type SyncPhaseManager interface {
	SyncPhase()
}

func NewExecutorPhaseManager

func NewExecutorPhaseManager(cli client.Client, clientSet kubernetes.Interface, tc *v1alpha1.TiflowCluster) SyncPhaseManager

func NewMasterPhaseManager

func NewMasterPhaseManager(cli client.Client, clientSet kubernetes.Interface, tc *v1alpha1.TiflowCluster) SyncPhaseManager

type TiflowClusterStatusManager

type TiflowClusterStatusManager struct {
	MasterStatus   SyncPhaseManager
	ExecutorStatus SyncPhaseManager
	// contains filtered or unexported fields
}

func (*TiflowClusterStatusManager) SetTiflowClusterPhase

func (tcsm *TiflowClusterStatusManager) SetTiflowClusterPhase(phase v1alpha1.TiflowClusterPhaseType, message string)

func (*TiflowClusterStatusManager) SyncTiflowClusterPhase

func (tcsm *TiflowClusterStatusManager) SyncTiflowClusterPhase()

func (*TiflowClusterStatusManager) Update

func (tcsm *TiflowClusterStatusManager) Update() error

func (TiflowClusterStatusManager) UpdateTiflowClusterPhase

func (tcsm TiflowClusterStatusManager) UpdateTiflowClusterPhase() error

type UpdateStatus

type UpdateStatus interface {
	Update() error
}

func NewTiflowClusterStatusManager

func NewTiflowClusterStatusManager(cli client.Client, clientSet kubernetes.Interface, tc *v1alpha1.TiflowCluster) UpdateStatus

type Updater

type Updater interface {
	Update(context.Context, *v1alpha1.TiflowCluster) error
}