condition

Documentation

Index

• func False(ctype v1alpha1.TiflowClusterConditionType, ...) bool
• func InitConditionsIfNeed(status *v1alpha1.TiflowClusterStatus, now metav1.Time)
• func SetFalse(ctype v1alpha1.TiflowClusterConditionType, ...)
• func SetTrue(ctype v1alpha1.TiflowClusterConditionType, ...)
• func True(ctype v1alpha1.TiflowClusterConditionType, ...) bool
• func Unknown(ctype v1alpha1.TiflowClusterConditionType, ...) bool
• type ClusterCondition
  • func NewExecutorConditionManager(cli client.Client, clientSet kubernetes.Interface, tc *v1alpha1.TiflowCluster) ClusterCondition
  • func NewMasterConditionManager(cli client.Client, clientSet kubernetes.Interface, tc *v1alpha1.TiflowCluster) ClusterCondition
• type Condition
  • func NewTiflowClusterConditionManager(cli client.Client, clientSet kubernetes.Interface, tc *v1alpha1.TiflowCluster) Condition
• type TiflowClusterConditionManager
  • func (tcm *TiflowClusterConditionManager) Apply() error
  • func (tcm *TiflowClusterConditionManager) Sync(ctx context.Context) error
• type UpdateCondition
• type VerifyCondition

Functions

func False

func False(ctype v1alpha1.TiflowClusterConditionType, conds []v1alpha1.TiflowClusterCondition) bool

func InitConditionsIfNeed

func InitConditionsIfNeed(status *v1alpha1.TiflowClusterStatus, now metav1.Time)

func SetFalse

func SetFalse(ctype v1alpha1.TiflowClusterConditionType, status *v1alpha1.TiflowClusterStatus, now metav1.Time)

func SetTrue

func SetTrue(ctype v1alpha1.TiflowClusterConditionType, status *v1alpha1.TiflowClusterStatus, now metav1.Time)

func True

func True(ctype v1alpha1.TiflowClusterConditionType, conds []v1alpha1.TiflowClusterCondition) bool

func Unknown

func Unknown(ctype v1alpha1.TiflowClusterConditionType, conds []v1alpha1.TiflowClusterCondition) bool

Types

type ClusterCondition

type ClusterCondition interface {
	UpdateCondition
	VerifyCondition
}

func NewExecutorConditionManager

func NewExecutorConditionManager(cli client.Client, clientSet kubernetes.Interface, tc *v1alpha1.TiflowCluster) ClusterCondition

func NewMasterConditionManager

func NewMasterConditionManager(cli client.Client, clientSet kubernetes.Interface, tc *v1alpha1.TiflowCluster) ClusterCondition

type Condition

type Condition interface {
	Sync(context.Context) error
	Apply() error
}

func NewTiflowClusterConditionManager

func NewTiflowClusterConditionManager(cli client.Client, clientSet kubernetes.Interface, tc *v1alpha1.TiflowCluster) Condition

type TiflowClusterConditionManager

type TiflowClusterConditionManager struct {
	*v1alpha1.TiflowCluster
	// contains filtered or unexported fields
}

func (*TiflowClusterConditionManager) Apply

func (tcm *TiflowClusterConditionManager) Apply() error

func (*TiflowClusterConditionManager) Sync

func (tcm *TiflowClusterConditionManager) Sync(ctx context.Context) error

type UpdateCondition

type UpdateCondition interface {
	Update(context.Context, *appsv1.StatefulSet) error
}

type VerifyCondition

type VerifyCondition interface {
	Verify(context.Context) error
}