util

package

v0.0.0-...-c55d01b Latest Latest Go to latest Published: Apr 18, 2024 License: Apache-2.0 Imports: 19 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/hazelcast/hazelcast-platform-operator

Documentation ¶

Index ¶

Constants
func AddFinalizer(ctx context.Context, c client.Client, object client.Object, logger logr.Logger) error
func CheckIfRunning(ctx context.Context, cl client.Client, statefulSet *appsv1.StatefulSet, ...) (bool, error)
func CreateOrGet(ctx context.Context, c client.Client, key client.ObjectKey, obj client.Object) error
func CreateOrUpdate(ctx context.Context, c client.Client, obj client.Object, ...) (controllerutil.OperationResult, error)
func CreateOrUpdateForce(ctx context.Context, c client.Client, obj client.Object, ...) (controllerutil.OperationResult, error)
func DeleteObject(ctx context.Context, c client.Client, obj client.Object) error
func DeploymentName(podName string) string
func EnrichServiceNodePorts(newPorts []corev1.ServicePort, existing []corev1.ServicePort) []corev1.ServicePort
func GetExternalAddress(svc *corev1.Service) string
func GetExternalAddressesForMC(ctx context.Context, cli client.Client, cr ExternalAddresser, ...) []string
func GetLoadBalancerAddress(lb *corev1.LoadBalancerIngress) string
func IsDeveloperModeEnabled() bool
func IsEnterprise(repo string) bool
func IsPhoneHomeEnabled() bool
func Labels(cr ExternalAddresser) map[string]string
func ListRelatedServices(ctx context.Context, cli client.Client, cr ExternalAddresser) (*corev1.ServiceList, error)
func NodeDiscoveryEnabled() bool
func OperatorID(c *rest.Config) types.UID
func OperatorNamespace() string
func OperatorVersion() string
func PardotID() string
func RandString(length int) string
func Update(ctx context.Context, c client.Client, obj client.Object, ...) (controllerutil.OperationResult, error)
func WatchedNamespaces() []string
type ExternalAddresser
type PodError
- func NewPodError(pod *corev1.Pod) *PodError
- func NewPodErrorWithContainerStatus(pod *corev1.Pod, status corev1.ContainerStatus) *PodError
- func (e *PodError) Error() string
type PodErrors
- func AsPodErrors(err error) (PodErrors, bool)
- func (es PodErrors) Error() string
type WatchedNsType
- func WatchedNamespaceType(operatorNamespace string, watchedNamespaces []string) WatchedNsType

Constants ¶

View Source

const (
	PanicLevel int = iota - 3
	ErrorLevel
	WarnLevel
	InfoLevel
	DebugLevel
)

Variables ¶

This section is empty.

Functions ¶

func AddFinalizer ¶

func AddFinalizer(ctx context.Context, c client.Client, object client.Object, logger logr.Logger) error

func CheckIfRunning ¶

func CheckIfRunning(ctx context.Context, cl client.Client, statefulSet *appsv1.StatefulSet, expectedReplicas int32) (bool, error)

func CreateOrGet ¶

func CreateOrGet(ctx context.Context, c client.Client, key client.ObjectKey, obj client.Object) error

func CreateOrUpdate ¶

func CreateOrUpdate(ctx context.Context, c client.Client, obj client.Object, f controllerutil.MutateFn) (controllerutil.OperationResult, error)

func CreateOrUpdateForce ¶

func CreateOrUpdateForce(ctx context.Context, c client.Client, obj client.Object, f controllerutil.MutateFn) (controllerutil.OperationResult, error)

func DeleteObject ¶

func DeleteObject(ctx context.Context, c client.Client, obj client.Object) error

func DeploymentName ¶

func DeploymentName(podName string) string

func EnrichServiceNodePorts ¶

func EnrichServiceNodePorts(newPorts []corev1.ServicePort, existing []corev1.ServicePort) []corev1.ServicePort

func GetExternalAddress ¶

func GetExternalAddress(svc *corev1.Service) string

func GetExternalAddressesForMC ¶

func GetExternalAddressesForMC(
	ctx context.Context,
	cli client.Client,
	cr ExternalAddresser,
	logger logr.Logger,
) []string

func GetLoadBalancerAddress ¶

func GetLoadBalancerAddress(lb *corev1.LoadBalancerIngress) string

func IsDeveloperModeEnabled ¶

func IsDeveloperModeEnabled() bool

func IsEnterprise ¶

func IsEnterprise(repo string) bool

func IsPhoneHomeEnabled ¶

func IsPhoneHomeEnabled() bool

func Labels ¶

func Labels(cr ExternalAddresser) map[string]string

func ListRelatedServices ¶

func ListRelatedServices(ctx context.Context, cli client.Client, cr ExternalAddresser) (*corev1.ServiceList, error)

func NodeDiscoveryEnabled ¶

func NodeDiscoveryEnabled() bool

func OperatorID ¶

func OperatorID(c *rest.Config) types.UID

func OperatorNamespace ¶

func OperatorNamespace() string

func OperatorVersion ¶

func OperatorVersion() string

func PardotID ¶

func PardotID() string

func RandString ¶

func RandString(length int) string

func Update ¶

func Update(ctx context.Context, c client.Client, obj client.Object, f controllerutil.MutateFn) (controllerutil.OperationResult, error)

func WatchedNamespaces ¶

func WatchedNamespaces() []string

Types ¶

type ExternalAddresser ¶

type ExternalAddresser interface {
	metav1.Object
	ExternalAddressEnabled() bool
}

type PodError ¶

type PodError struct {
	Name         string
	Namespace    string
	Message      string
	Reason       string
	PodIp        string
	RestartCount int32
}

func NewPodError ¶

func NewPodError(pod *corev1.Pod) *PodError

func NewPodErrorWithContainerStatus ¶

func NewPodErrorWithContainerStatus(pod *corev1.Pod, status corev1.ContainerStatus) *PodError

func (*PodError) Error ¶

func (e *PodError) Error() string

type PodErrors ¶

type PodErrors []*PodError

func AsPodErrors ¶

func AsPodErrors(err error) (PodErrors, bool)

AsPodErrors tries to transform err to PodErrors and return it with true. If it is not possible nil and false is returned.

func (PodErrors) Error ¶

func (es PodErrors) Error() string

type WatchedNsType ¶

type WatchedNsType string

const (
	WatchedNsTypeAll    WatchedNsType = "All"
	WatchedNsTypeMulti  WatchedNsType = "Multi"
	WatchedNsTypeSingle WatchedNsType = "Single"
	WatchedNsTypeOwn    WatchedNsType = "Own"
)

func WatchedNamespaceType ¶

func WatchedNamespaceType(operatorNamespace string, watchedNamespaces []string) WatchedNsType

Source Files ¶

View all Source files

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