util

Documentation

Index

• Variables
• func ContainsChars(s string) bool
• func GetAppLabel() map[string]string
• func HasDoguLabel(deployment client.Object) bool
• func IsMaintenanceModeActive(ctx context.Context, globalConfigRepo GlobalConfigRepository) (bool, error)
• type ExposedPort
  • func (ep ExposedPort) String() string
• type ExposedPorts
• type GlobalConfigRepository

Variables

var K8sCesServiceDiscoveryLabels = map[string]string{"app": "ces", "app.kubernetes.io/name": "k8s-service-discovery"}

Functions

func ContainsChars

func ContainsChars(s string) bool

func GetAppLabel

func GetAppLabel() map[string]string

func HasDoguLabel

func HasDoguLabel(deployment client.Object) bool

func IsMaintenanceModeActive

func IsMaintenanceModeActive(ctx context.Context, globalConfigRepo GlobalConfigRepository) (bool, error)

Types

type ExposedPort

type ExposedPort struct {
	Protocol   corev1.Protocol `json:"protocol"`
	Port       int32           `json:"port"`
	TargetPort int32           `json:"targetPort"`
}

func (ExposedPort) String

func (ep ExposedPort) String() string

type ExposedPorts

type ExposedPorts []ExposedPort

type GlobalConfigRepository

type GlobalConfigRepository interface {
	Get(context.Context) (libconfig.GlobalConfig, error)
	Watch(context.Context, ...libconfig.WatchFilter) (<-chan repository.GlobalConfigWatchResult, error)
	Update(ctx context.Context, globalConfig libconfig.GlobalConfig) (libconfig.GlobalConfig, error)
}