controller

package

v1.0.0-20221102-166735... Latest Latest Go to latest Published: Oct 19, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/pingcap/tiflow-operator

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 ¶

View Source

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 ¶

View Source

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
tiflowcluster

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL