controller

Documentation

Index

• Constants
• Variables
• func AnnProm(port int32) map[string]string
• func ContainerResource(req corev1.ResourceRequirements) corev1.ResourceRequirements
• func GetOwnerRef(tc *pingcapcomv1alpha1.TiflowCluster) metav1.OwnerReference
• func IsRequeueError(err error) bool
• func RequeueErrorf(format string, a ...interface{}) error
• func ServiceEqual(newSvc, oldSvc *corev1.Service) (bool, error)
• func SetServiceLastAppliedConfigAnnotation(svc *corev1.Service) error
• func TiflowExecutorMemberName(clusterName string) string
• func TiflowExecutorPeerMemberName(clusterName string) string
• func TiflowMasterFullHost(clusterName, namespace, clusterDomain string) string
• func TiflowMasterMemberName(clusterName string) string
• func TiflowMasterPeerMemberName(clusterName string) string
• type RequeueError
  • func (re *RequeueError) Error() string

Constants

const (
	// LastAppliedPodTemplate is annotation key of the last applied pod template
	LastAppliedPodTemplate = "pingcap.com/last-applied-podtemplate"

	// LastAppliedConfigAnnotation is annotation key of last applied configuration
	LastAppliedConfigAnnotation = "pingcap.com/last-applied-configuration"
)

Variables

var (
	// ControllerKind contains the group version for tiflowcluster controller type.
	ControllerKind = pingcapcomv1alpha1.GroupVersion.WithKind("TiflowCluster")
)

Functions

func AnnProm

func AnnProm(port int32) map[string]string

AnnProm adds annotations for prometheus scraping metrics

func ContainerResource

func ContainerResource(req corev1.ResourceRequirements) corev1.ResourceRequirements

func GetOwnerRef

func GetOwnerRef(tc *pingcapcomv1alpha1.TiflowCluster) metav1.OwnerReference

GetOwnerRef returns TiflowCluster's OwnerReference

func IsRequeueError

func IsRequeueError(err error) bool

IsRequeueError returns whether err is a RequeueError

func RequeueErrorf

func RequeueErrorf(format string, a ...interface{}) error

RequeueErrorf returns a RequeueError

func ServiceEqual

func ServiceEqual(newSvc, oldSvc *corev1.Service) (bool, error)

ServiceEqual compares the new Service's spec with old Service's last applied config

func SetServiceLastAppliedConfigAnnotation

func SetServiceLastAppliedConfigAnnotation(svc *corev1.Service) error

SetServiceLastAppliedConfigAnnotation set last applied config info to Service's annotation

func TiflowExecutorMemberName

func TiflowExecutorMemberName(clusterName string) string

TiflowExecutorMemberName returns tiflow-executor member name

func TiflowExecutorPeerMemberName

func TiflowExecutorPeerMemberName(clusterName string) string

TiflowExecutorPeerMemberName returns tiflow-executor peer service name

func TiflowMasterFullHost

func TiflowMasterFullHost(clusterName, namespace, clusterDomain string) string

TiflowMasterFullHost returns tiflow-master full host

func TiflowMasterMemberName

func TiflowMasterMemberName(clusterName string) string

TiflowMasterMemberName returns tiflow-master member name

func TiflowMasterPeerMemberName

func TiflowMasterPeerMemberName(clusterName string) string

TiflowMasterPeerMemberName returns tiflow-master peer service name

Types

type RequeueError

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

RequeueError is used to requeue the item, this error type should't be considered as a real error

func (*RequeueError) Error

func (re *RequeueError) Error() string