runtime

package
v0.0.0-...-1bc13c6 Latest Latest
Warning

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

 Go to latest Published: Apr 27, 2024 License: Apache-2.0 Imports: 26 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 Labels 

func Labels(o runtime.Object) map[string]string

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

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 NewClusterLogForwarder 

func NewClusterLogForwarder(namespace, name string) *loggingv1.ClusterLogForwarder

NewClusterLogForwarder returns a ClusterLogForwarder with default name and namespace.

func NewClusterLogging 

func NewClusterLogging(namespace, name string) *loggingv1.ClusterLogging

NewClusterLogging returns a ClusterLogging with default name and namespace.

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 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 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 ServiceDomainName 

func ServiceDomainName(o runtime.Object) string

ServiceDomainName returns "name.namespace.svc".

func SetCommonLabels 

func SetCommonLabels(object runtime.Object, collectorType, 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 Object 

type Object = runtime.Object

Object is an alias for this central type.

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

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.