tiflowcluster

Documentation

Index

• type ControlInterface
  • func NewDefaultTiflowClusterControl(cli client.Client, clientSet kubernetes.Interface) ControlInterface

Types

type ControlInterface

type ControlInterface interface {
	// UpdateTiflowCluster implements the control logic for StatefulSet creation, update, and deletion
	UpdateTiflowCluster(ctx context.Context, cluster *v1alpha1.TiflowCluster) error
}

ControlInterface implements the control logic for updating TiflowClusters and their children StatefulSets. It is implemented as an interface to allow for extensions that provide different semantics. Currently, there is only one implementation.

func NewDefaultTiflowClusterControl

func NewDefaultTiflowClusterControl(cli client.Client, clientSet kubernetes.Interface) ControlInterface

NewDefaultTiflowClusterControl returns a new instance of the default implementation tiflowClusterControlInterface that implements the documented semantics for tiflowClusters.