runtime

package
v0.0.0-...-dc3a80b Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 20, 2025 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Codecs = serializer.NewCodecFactory(scheme.Scheme)

Codecs is a codec factory for the default scheme, including core and our custom types.

Functions

func Decode 

func Decode(manifest string) runtime.Object

Decode JSON or YAML resource manifest to a new typed struct.

func GroupVersionKind 

func GroupVersionKind(o runtime.Object) schema.GroupVersionKind

GroupVersionKind deduces the Kind from the Go type.

func ID 

func ID(o runtime.Object) string

ID returns a human-readable identifier for the object, for debugging and tests.

func Initialize 

func Initialize(o runtime.Object, namespace, name string, visitors ...func(o runtime.Object))

Initialize sets name, namespace and type metadata deduced from Go type.

func Meta 

func Meta(o runtime.Object) metav1.Object

Meta interface to get/set object metadata. Panics if o is not a metav1.Object, e.g. if it is a List type.

func NamespacedName 

func NamespacedName(o client.Object) types.NamespacedName

NamespacedName returns the namespaced name of an object.

func NewClusterRole 

func NewClusterRole(name string, rules ...rbacv1.PolicyRule) *rbacv1.ClusterRole

NewClusterRole returns a role with namespace, names, rules

func NewClusterRoleBinding 

func NewClusterRoleBinding(name string, roleRef rbacv1.RoleRef, subjects ...rbacv1.Subject) *rbacv1.ClusterRoleBinding

NewClusterRoleBinding returns a role with namespace, names, rules

func NewConfigMap 

func NewConfigMap(namespace, name string, data map[string]string, visitors ...func(o runtime.Object)) *corev1.ConfigMap

NewConfigMap returns a corev1.ConfigMap with namespace, name and data.

func NewContainer 

func NewContainer(name string, image string, pullPolicy corev1.PullPolicy, resources *corev1.ResourceRequirements) *corev1.Container

NewContainer stubs an instance of a corev1.Container

func NewDaemonSet 

func NewDaemonSet(namespace, name string, visitors ...func(o runtime.Object)) *appsv1.DaemonSet

NewDaemonSet returns a daemon set.

func NewDeployment 

func NewDeployment(namespace, name string, visitors ...func(o runtime.Object)) *appsv1.Deployment

NewDeployment returns a deployment

func NewLogFileMetricExporter 

func NewLogFileMetricExporter(namespace, name string) *loggingv1alpha1.LogFileMetricExporter

Returns a new default LogFileMetricExporter

func NewNamespace 

func NewNamespace(name string) *corev1.Namespace

NewNamespace returns a corev1.Namespace with name.

func NewNetworkPolicy 

func NewNetworkPolicy(namespace, name string, visitors ...func(o runtime.Object)) *networkingv1.NetworkPolicy

NewNetworkPolicy returns a networking.k8s.io/v1.NetworkPolicy with namespace and name.

func NewPod 

func NewPod(namespace, name string, containers ...corev1.Container) *corev1.Pod

NewPod returns a corev1.Pod with namespace, name, containers.

func NewPolicyRule 

func NewPolicyRule(apiGroups, resources, resourceNames, verbs []string) rbacv1.PolicyRule

NewPolicyRule stubs policy rule

func NewPolicyRules 

func NewPolicyRules(rules ...rbacv1.PolicyRule) []rbacv1.PolicyRule

NewPolicyRules stubs policy rules

func NewPriorityClass 

func NewPriorityClass(name string, priorityValue int32, globalDefault bool, description string) *scheduling.PriorityClass

NewPriorityClass is a constructor to create a PriorityClass

func NewPrometheusRule 

func NewPrometheusRule(namespace, ruleName string) *monitoringv1.PrometheusRule

func NewPrometheusRuleSpecFrom 

func NewPrometheusRuleSpecFrom(groups string) (*monitoringv1.PrometheusRuleSpec, error)

func NewRole 

func NewRole(namespace, name string, rules ...rbacv1.PolicyRule) *rbacv1.Role

NewRole returns a role with namespace, names, rules

func NewRoleBinding 

func NewRoleBinding(namespace, name string, roleRef rbacv1.RoleRef, subjects ...rbacv1.Subject) *rbacv1.RoleBinding

NewRoleBinding returns a role with namespace, names, rules

func NewRoute 

func NewRoute(namespace, name, service, port string) *openshiftv1.Route

NewRoute returns an openshift.io/v1.Route with namespace and name to port on service.

func NewSCC 

func NewSCC(name string) *security.SecurityContextConstraints

func NewSecret 

func NewSecret(namespace, name string, data map[string][]byte, visitors ...func(o runtime.Object)) *corev1.Secret

NewSecret returns a corev1.Secret with namespace and name.

func NewService 

func NewService(namespace, name string, visitors ...func(o runtime.Object)) *corev1.Service

NewService returns a corev1.Service with namespace and name.

func NewServiceAccount 

func NewServiceAccount(namespace, name string) *corev1.ServiceAccount

NewServiceAccount returns a corev1.ServiceAccount with namespace and name.

func NewServiceMonitor 

func NewServiceMonitor(namespace, name string) *monitoringv1.ServiceMonitor

func NewSubject 

func NewSubject(kind, name string) rbacv1.Subject

NewSubject stubs a new subject

func NewSubjects 

func NewSubjects(subjects ...rbacv1.Subject) []rbacv1.Subject

NewSubjects stubs subjects

func Selectors 

func Selectors(instanceName, component, name string) map[string]string

func ServiceDomainName 

func ServiceDomainName(o runtime.Object) string

ServiceDomainName returns "name.namespace.svc".

func SetCommonLabels 

func SetCommonLabels(object runtime.Object, name, instanceName, component string)

SetCommonLabels initialize given object labels with K8s Common labels These are recommended labels. They make it easier to manage applications but aren't required for any core tooling. https://kubernetes.io/docs/concepts/overview/working-with-objects/common-labels/#labels

func SvcClusterLocal 

func SvcClusterLocal(namespace, name string) string

SvcClusterLocal returns the svc.cluster.local hostname for name and namespace.

Types

type ConfigMapBuilder 

type ConfigMapBuilder struct {
	ConfigMap *corev1.ConfigMap
}

func NewConfigMapBuilder 

func NewConfigMapBuilder(cm *corev1.ConfigMap) *ConfigMapBuilder

func (*ConfigMapBuilder) Add 

func (builder *ConfigMapBuilder) Add(key, value string) *ConfigMapBuilder

func (*ConfigMapBuilder) AddAnnotation 

func (builder *ConfigMapBuilder) AddAnnotation(key, value string) *ConfigMapBuilder

func (*ConfigMapBuilder) AddLabel 

func (builder *ConfigMapBuilder) AddLabel(key, value string) *ConfigMapBuilder

type ContainerBuilder 

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

func (*ContainerBuilder) AddContainerPort 

func (builder *ContainerBuilder) AddContainerPort(name string, port int32) *ContainerBuilder

func (*ContainerBuilder) AddEnvVar 

func (builder *ContainerBuilder) AddEnvVar(name, value string) *ContainerBuilder

func (*ContainerBuilder) AddEnvVarFromFieldRef 

func (builder *ContainerBuilder) AddEnvVarFromFieldRef(name, fieldRef string) *ContainerBuilder

func (*ContainerBuilder) AddRunAsUser 

func (builder *ContainerBuilder) AddRunAsUser(uid int64) *ContainerBuilder

func (*ContainerBuilder) AddVolumeMount 

func (builder *ContainerBuilder) AddVolumeMount(name, path, subPath string, readonly bool) *ContainerBuilder

func (*ContainerBuilder) End 

func (builder *ContainerBuilder) End() *PodBuilder

func (*ContainerBuilder) ResourceRequirements 

func (builder *ContainerBuilder) ResourceRequirements(resources corev1.ResourceRequirements) *ContainerBuilder

func (*ContainerBuilder) Update 

func (builder *ContainerBuilder) Update() *PodBuilder

func (*ContainerBuilder) WithCmd 

func (builder *ContainerBuilder) WithCmd(cmdAgrgs []string) *ContainerBuilder

func (*ContainerBuilder) WithCmdArgs 

func (builder *ContainerBuilder) WithCmdArgs(cmdArgs []string) *ContainerBuilder

func (*ContainerBuilder) WithImage 

func (builder *ContainerBuilder) WithImage(image string) *ContainerBuilder

func (*ContainerBuilder) WithImagePullPolicy 

func (builder *ContainerBuilder) WithImagePullPolicy(policy corev1.PullPolicy) *ContainerBuilder

func (*ContainerBuilder) WithPodSecurity 

func (builder *ContainerBuilder) WithPodSecurity() *ContainerBuilder

func (*ContainerBuilder) WithPrivilege 

func (builder *ContainerBuilder) WithPrivilege() *ContainerBuilder

type DaemonSetBuilder 

type DaemonSetBuilder struct {
	DaemonSet *apps.DaemonSet
}

func NewDaemonSetBuilder 

func NewDaemonSetBuilder(ds *apps.DaemonSet) *DaemonSetBuilder

func (*DaemonSetBuilder) WithPodSpec 

func (builder *DaemonSetBuilder) WithPodSpec(podSpec core.PodSpec) *DaemonSetBuilder

func (*DaemonSetBuilder) WithSelector 

func (builder *DaemonSetBuilder) WithSelector(selector map[string]string) *DaemonSetBuilder

func (*DaemonSetBuilder) WithTemplateAnnotations 

func (builder *DaemonSetBuilder) WithTemplateAnnotations(annotations map[string]string) *DaemonSetBuilder

func (*DaemonSetBuilder) WithTemplateLabels 

func (builder *DaemonSetBuilder) WithTemplateLabels(labels map[string]string) *DaemonSetBuilder

func (*DaemonSetBuilder) WithUpdateStrategy 

func (builder *DaemonSetBuilder) WithUpdateStrategy(updateStrategy apps.DaemonSetUpdateStrategy) *DaemonSetBuilder

type DeploymentBuilder 

type DeploymentBuilder struct {
	Deployment *apps.Deployment
}

func NewDeploymentBuilder 

func NewDeploymentBuilder(ds *apps.Deployment) *DeploymentBuilder

func (*DeploymentBuilder) WithPodSpec 

func (builder *DeploymentBuilder) WithPodSpec(podSpec core.PodSpec) *DeploymentBuilder

func (*DeploymentBuilder) WithReplicas 

func (builder *DeploymentBuilder) WithReplicas(replicas *int32) *DeploymentBuilder

func (*DeploymentBuilder) WithSelector 

func (builder *DeploymentBuilder) WithSelector(selector map[string]string) *DeploymentBuilder

func (*DeploymentBuilder) WithTemplateAnnotations 

func (builder *DeploymentBuilder) WithTemplateAnnotations(annotations map[string]string) *DeploymentBuilder

func (*DeploymentBuilder) WithTemplateLabels 

func (builder *DeploymentBuilder) WithTemplateLabels(labels map[string]string) *DeploymentBuilder

func (*DeploymentBuilder) WithUpdateStrategy 

func (builder *DeploymentBuilder) WithUpdateStrategy(updateStrategy apps.DeploymentStrategy) *DeploymentBuilder

type EgressRuleBuilder 

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

EgressRuleBuilder helps build egress rules fluently

func (*EgressRuleBuilder) End 

func (erb *EgressRuleBuilder) End() *NetworkPolicyBuilder

End completes the egress rule and returns to the NetworkPolicyBuilder

func (*EgressRuleBuilder) OnNamedPort 

func (erb *EgressRuleBuilder) OnNamedPort(protocol corev1.Protocol, portName string) *EgressRuleBuilder

OnNamedPort adds a named port to the egress rule

func (*EgressRuleBuilder) OnPort 

func (erb *EgressRuleBuilder) OnPort(protocol corev1.Protocol, port int32) *EgressRuleBuilder

OnPort adds a port to the egress rule

type IngressRuleBuilder 

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

IngressRuleBuilder helps build ingress rules fluently

func (*IngressRuleBuilder) End 

func (irb *IngressRuleBuilder) End() *NetworkPolicyBuilder

End completes the ingress rule and returns to the NetworkPolicyBuilder

func (*IngressRuleBuilder) OnNamedPort 

func (irb *IngressRuleBuilder) OnNamedPort(protocol corev1.Protocol, portName string) *IngressRuleBuilder

OnNamedPort adds a named port to the ingress rule

func (*IngressRuleBuilder) OnPort 

func (irb *IngressRuleBuilder) OnPort(protocol corev1.Protocol, port int32) *IngressRuleBuilder

type NetworkPolicyBuilder 

type NetworkPolicyBuilder struct {
	NetworkPolicy *networkingv1.NetworkPolicy
}

func NewNetworkPolicyBuilder 

func NewNetworkPolicyBuilder(np *networkingv1.NetworkPolicy) *NetworkPolicyBuilder

NewNetworkPolicyBuilder creates a new NetworkPolicyBuilder with the given NetworkPolicy

func (*NetworkPolicyBuilder) AllowAllEgress 

func (builder *NetworkPolicyBuilder) AllowAllEgress() *NetworkPolicyBuilder

AllowAllEgress adds a rule that allows all egress traffic

func (*NetworkPolicyBuilder) AllowAllIngress 

func (builder *NetworkPolicyBuilder) AllowAllIngress() *NetworkPolicyBuilder

AllowAllIngress adds a rule that allows all ingress traffic

func (*NetworkPolicyBuilder) NewEgressRule 

func (builder *NetworkPolicyBuilder) NewEgressRule() *EgressRuleBuilder

NewEgressRule starts building a new egress rule

func (*NetworkPolicyBuilder) NewIngressRule 

func (builder *NetworkPolicyBuilder) NewIngressRule() *IngressRuleBuilder

NewIngressRule starts building a new ingress rule

func (*NetworkPolicyBuilder) WithEgressPolicyType 

func (builder *NetworkPolicyBuilder) WithEgressPolicyType() *NetworkPolicyBuilder

WithEgressPolicyType adds Egress to the policy types

func (*NetworkPolicyBuilder) WithIngressPolicyType 

func (builder *NetworkPolicyBuilder) WithIngressPolicyType() *NetworkPolicyBuilder

WithIngressPolicyType adds Ingress to the policy types

func (*NetworkPolicyBuilder) WithPodSelector 

func (builder *NetworkPolicyBuilder) WithPodSelector(matchLabels map[string]string) *NetworkPolicyBuilder

WithPodSelector sets the pod selector for the NetworkPolicy

type Object 

type Object = runtime.Object

Object is an alias for this central type.

type ObjectLabels 

type ObjectLabels map[string]string

func Labels 

func Labels(o runtime.Object) ObjectLabels

Labels returns the labels map for object, guaranteed to be non-nil.

func (ObjectLabels) Includes 

func (objLabels ObjectLabels) Includes(other ObjectLabels) bool

Includes compares an object labels to those given and returns true if the object set includes the keys and also matches the values

type PodBuilder 

type PodBuilder struct {
	Pod *corev1.Pod
}

func NewPodBuilder 

func NewPodBuilder(pod *corev1.Pod) *PodBuilder

func (*PodBuilder) AddAnnotation 

func (builder *PodBuilder) AddAnnotation(key, value string) *PodBuilder

func (*PodBuilder) AddConfigMapVolume 

func (builder *PodBuilder) AddConfigMapVolume(name, configMapName string) *PodBuilder

func (*PodBuilder) AddConfigMapVolumeWithPermissions 

func (builder *PodBuilder) AddConfigMapVolumeWithPermissions(name, configMapName string, permissions *int32) *PodBuilder

func (*PodBuilder) AddConfigMapWith 

func (builder *PodBuilder) AddConfigMapWith(name, configMapName string, handler func(corev1.Volume) corev1.Volume) *PodBuilder

func (*PodBuilder) AddContainer 

func (builder *PodBuilder) AddContainer(name, image string) *ContainerBuilder

func (*PodBuilder) AddEmptyDirVolume 

func (builder *PodBuilder) AddEmptyDirVolume(name string) *PodBuilder

func (*PodBuilder) AddHostAlias 

func (builder *PodBuilder) AddHostAlias(hostAlias corev1.HostAlias) *PodBuilder

func (*PodBuilder) AddHostPathVolume 

func (builder *PodBuilder) AddHostPathVolume(name, path string) *PodBuilder

func (*PodBuilder) AddInitContainer 

func (builder *PodBuilder) AddInitContainer(name, image string) *ContainerBuilder

func (*PodBuilder) AddLabels 

func (builder *PodBuilder) AddLabels(labels map[string]string) *PodBuilder

func (*PodBuilder) AddSecretVolume 

func (builder *PodBuilder) AddSecretVolume(name, secretName string) *PodBuilder

func (*PodBuilder) GetContainer 

func (builder *PodBuilder) GetContainer(name string) *ContainerBuilder

func (*PodBuilder) WithLabels 

func (builder *PodBuilder) WithLabels(labels map[string]string) *PodBuilder

type PodBuilderVisitor 

type PodBuilderVisitor func(builder *PodBuilder) error

PodBuilderVisitor provides the ability to manipulate the PodBuilder with custom logic

type ServiceBuilder 

type ServiceBuilder struct {
	Service *corev1.Service
}

func NewServiceBuilder 

func NewServiceBuilder(svc *corev1.Service) *ServiceBuilder

func (*ServiceBuilder) AddLabel 

func (builder *ServiceBuilder) AddLabel(key, val string) *ServiceBuilder

func (*ServiceBuilder) AddServicePort 

func (builder *ServiceBuilder) AddServicePort(port int32, targetPort int) *ServiceBuilder

func (*ServiceBuilder) WithSelector 

func (builder *ServiceBuilder) WithSelector(selector map[string]string) *ServiceBuilder

func (*ServiceBuilder) WithServicePort 

func (builder *ServiceBuilder) WithServicePort(servicePorts []corev1.ServicePort) *ServiceBuilder

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.