kubernetes

Documentation

Index

• Constants
• func ConstructAuthRole(roleName, humioClusterName, humioClusterNamespace string) *rbacv1.Role
• func ConstructClusterRoleBinding(clusterRoleBindingName, clusterRoleName, humioClusterName, ... string) *rbacv1.ClusterRoleBinding
• func ConstructExtraKafkaConfigsConfigmap(extraKafkaConfigsConfigmapName, extraKafkaPropertiesFilename, ... string) *corev1.ConfigMap
• func ConstructInitClusterRole(clusterRoleName, humioClusterName string) *rbacv1.ClusterRole
• func ConstructRoleBinding(roleBindingName, roleName, humioClusterName, humioClusterNamespace, ... string) *rbacv1.RoleBinding
• func ConstructSecret(humioClusterName, humioClusterNamespace, secretName string, ...) *corev1.Secret
• func ConstructService(humioClusterName, humioClusterNamespace string) *corev1.Service
• func ConstructServiceAccount(serviceAccountName, humioClusterName, humioClusterNamespace string) *corev1.ServiceAccount
• func ConstructServiceAccountSecret(humioClusterName, humioClusterNamespace, secretName string, ...) *corev1.Secret
• func GetClusterRole(ctx context.Context, c client.Client, clusterRoleName string) (*rbacv1.ClusterRole, error)
• func GetClusterRoleBinding(ctx context.Context, c client.Client, clusterRoleBindingName string) (*rbacv1.ClusterRoleBinding, error)
• func GetConfigmap(ctx context.Context, c client.Client, ...) (*corev1.ConfigMap, error)
• func GetContainerIndexByName(pod corev1.Pod, name string) (int, error)
• func GetIngress(ctx context.Context, c client.Client, ...) (*v1beta1.Ingress, error)
• func GetRole(ctx context.Context, c client.Client, roleName, roleNamespace string) (*rbacv1.Role, error)
• func GetRoleBinding(ctx context.Context, c client.Client, ...) (*rbacv1.RoleBinding, error)
• func GetSecret(ctx context.Context, c client.Client, secretName, humioClusterNamespace string) (*corev1.Secret, error)
• func GetService(ctx context.Context, c client.Client, ...) (*corev1.Service, error)
• func GetServiceAccount(ctx context.Context, c client.Client, ...) (*corev1.ServiceAccount, error)
• func LabelListContainsLabel(labelList map[string]string, label string) bool
• func LabelsForHumio(clusterName string) map[string]string
• func LabelsForPod(clusterName string, nodeID int) map[string]string
• func ListIngresses(c client.Client, humioClusterNamespace string, ...) ([]v1beta1.Ingress, error)
• func ListPods(c client.Client, humioClusterNamespace string, ...) ([]corev1.Pod, error)
• func MatchingLabelsForHumio(clusterName string) client.MatchingLabels

Constants

const (
	ServiceTokenSecretName = "admin-token"
)

Functions

func ConstructAuthRole

func ConstructAuthRole(roleName, humioClusterName, humioClusterNamespace string) *rbacv1.Role

func ConstructClusterRoleBinding

func ConstructClusterRoleBinding(clusterRoleBindingName, clusterRoleName, humioClusterName, humioClusterNamespace, serviceAccountName string) *rbacv1.ClusterRoleBinding

func ConstructExtraKafkaConfigsConfigmap

func ConstructExtraKafkaConfigsConfigmap(extraKafkaConfigsConfigmapName, extraKafkaPropertiesFilename, extraKafkaConfigsConfigmapData, humioClusterName, humioClusterNamespace string) *corev1.ConfigMap

func ConstructInitClusterRole

func ConstructInitClusterRole(clusterRoleName, humioClusterName string) *rbacv1.ClusterRole

func ConstructRoleBinding

func ConstructRoleBinding(roleBindingName, roleName, humioClusterName, humioClusterNamespace, serviceAccountName string) *rbacv1.RoleBinding

func ConstructSecret

func ConstructSecret(humioClusterName, humioClusterNamespace, secretName string, data map[string][]byte) *corev1.Secret

func ConstructService

func ConstructService(humioClusterName, humioClusterNamespace string) *corev1.Service

func ConstructServiceAccount

func ConstructServiceAccount(serviceAccountName, humioClusterName, humioClusterNamespace string) *corev1.ServiceAccount

func ConstructServiceAccountSecret

func ConstructServiceAccountSecret(humioClusterName, humioClusterNamespace, secretName string, serviceAccountName string) *corev1.Secret

func GetClusterRole

func GetClusterRole(ctx context.Context, c client.Client, clusterRoleName string) (*rbacv1.ClusterRole, error)

GetClusterRole returns the given cluster role if it exists

func GetClusterRoleBinding

func GetClusterRoleBinding(ctx context.Context, c client.Client, clusterRoleBindingName string) (*rbacv1.ClusterRoleBinding, error)

GetClusterRoleBinding returns the given cluster role binding if it exists

func GetConfigmap

func GetConfigmap(ctx context.Context, c client.Client, configmapName, humioClusterNamespace string) (*corev1.ConfigMap, error)

GetConfigmap returns the configmap for the given configmap name if it exists

func GetContainerIndexByName

func GetContainerIndexByName(pod corev1.Pod, name string) (int, error)

func GetIngress

func GetIngress(ctx context.Context, c client.Client, ingressName, humioClusterNamespace string) (*v1beta1.Ingress, error)

GetIngress returns the ingress for the given ingress name if it exists

func GetRole

func GetRole(ctx context.Context, c client.Client, roleName, roleNamespace string) (*rbacv1.Role, error)

GetRole returns the given role if it exists

func GetRoleBinding

func GetRoleBinding(ctx context.Context, c client.Client, roleBindingName, roleBindingNamespace string) (*rbacv1.RoleBinding, error)

GetRoleBinding returns the given role if it exists

func GetSecret

func GetSecret(ctx context.Context, c client.Client, secretName, humioClusterNamespace string) (*corev1.Secret, error)

func GetService

func GetService(ctx context.Context, c client.Client, humioClusterName, humioClusterNamespace string) (*corev1.Service, error)

func GetServiceAccount

func GetServiceAccount(ctx context.Context, c client.Client, serviceAccountName, humioClusterNamespace string) (*corev1.ServiceAccount, error)

GetServiceAccount returns the service account

func LabelListContainsLabel

func LabelListContainsLabel(labelList map[string]string, label string) bool

func LabelsForHumio

func LabelsForHumio(clusterName string) map[string]string

func LabelsForPod

func LabelsForPod(clusterName string, nodeID int) map[string]string

func ListIngresses

func ListIngresses(c client.Client, humioClusterNamespace string, matchingLabels client.MatchingLabels) ([]v1beta1.Ingress, error)

ListPods grabs the list of all pods associated to a an instance of HumioCluster

func ListPods

func ListPods(c client.Client, humioClusterNamespace string, matchingLabels client.MatchingLabels) ([]corev1.Pod, error)

ListPods grabs the list of all pods associated to a an instance of HumioCluster

func MatchingLabelsForHumio

func MatchingLabelsForHumio(clusterName string) client.MatchingLabels