kude

Documentation

Index

• Constants
• func GetResourcePreviousName(r *kyaml.RNode) (string, error)
• func GetVersion() semver.Version
• type ByType
  • func (a ByType) Len() int
  • func (a ByType) Less(i, j int) bool
  • func (a ByType) Swap(i, j int)
• type Execution
  • func NewExecution(p Pipeline, logger *log.Logger) (Execution, error)
• type Pipeline
  • func NewPipeline(dir string) (Pipeline, error)
• type Step

Constants

const (
	PipelineAPIVersion = "kude.kfirs.com/v1alpha2"
	PipelineKind       = "Pipeline"
)

const APIVersionAPIExtensionsV1 = "apiextensions.k8s.io/v1"

const APIVersionAdmissionRegistrationV1 = "admissionregistration.k8s.io/v1"

const APIVersionAppsV1 = "apps/v1"

const APIVersionAutoscalingV1 = "autoscaling/v1"

const APIVersionAutoscalingV2 = "autoscaling/v2"

const APIVersionAutoscalingV2Beta2 = "autoscaling/v2beta2"

const APIVersionBatchV1 = "batch/v1"

const APIVersionNetworkingV1 = "networking.k8s.io/v1"

const APIVersionPolicyV1 = "policy/v1"

const APIVersionRBACV1 = "rbac.authorization.k8s.io/v1"

const APIVersionSchedulingV1 = "scheduling.k8s.io/v1"

const APIVersionStorageV1 = "storage.k8s.io/v1"

const APIVersionV1 = "v1"

const APIVersionV1Beta1 = "policy/v1beta1"

const KindCSIDriver = "CSIDriver"

const KindClusterRole = "ClusterRole"

const KindClusterRoleBinding = "ClusterRoleBinding"

const KindConfigMap = "ConfigMap"

const KindControllerRevision = "ControllerRevision"

const KindCronJob = "CronJob"

const KindCustomResourceDefinition = "CustomResourceDefinition"

const KindDaemonSet = "DaemonSet"

const KindDeployment = "Deployment"

const KindHorizontalPodAutoscaler = "HorizontalPodAutoscaler"

const KindIngress = "Ingress"

const KindJob = "Job"

const KindLimitRange = "LimitRange"

const KindMutatingWebhookConfiguration = "MutatingWebhookConfiguration"

const KindNamespace = "Namespace"

const KindNetworkPolicy = "NetworkPolicy"

const KindNode = "Node"

const KindPersistentVolume = "PersistentVolume"

const KindPersistentVolumeClaim = "PersistentVolumeClaim"

const KindPod = "Pod"

const KindPodDisruptionBudget = "PodDisruptionBudget"

const KindPodSecurityPolicy = "PodSecurityPolicy"

const KindPodTemplate = "PodTemplate"

const KindPriorityClass = "PriorityClass"

const KindReplicaSet = "ReplicaSet"

const KindReplicationController = "ReplicationController"

const KindResourceQuota = "ResourceQuota"

const KindRole = "Role"

const KindRoleBinding = "RoleBinding"

const KindSecret = "Secret"

const KindService = "Service"

const KindServiceAccount = "ServiceAccount"

const KindStatefulSet = "StatefulSet"

const KindStorageClass = "StorageClass"

const KindValidatingWebhookConfiguration = "ValidatingWebhookConfiguration"

const (
	// PreviousNameAnnotationName is the name of the annotation that is used to provide the friendly resource name of
	// a resource that has been renamed for uniqueness.
	PreviousNameAnnotationName = "kude.kfirs.com/previous-name"
)

Functions

func GetResourcePreviousName

func GetResourcePreviousName(r *kyaml.RNode) (string, error)

func GetVersion

func GetVersion() semver.Version

GetVersion returns the kude version currently running.

Types

type ByType

type ByType []*kyaml.RNode

func (ByType) Len

func (a ByType) Len() int

func (ByType) Less

func (a ByType) Less(i, j int) bool

func (ByType) Swap

func (a ByType) Swap(i, j int)

type Execution

type Execution interface {
	GetPipeline() Pipeline
	GetLogger() *log.Logger
	ExecuteToWriter(ctx context.Context, w io.Writer) error
	ExecuteToChannel(ctx context.Context, target chan *kyaml.RNode) error
}

func NewExecution

func NewExecution(p Pipeline, logger *log.Logger) (Execution, error)

type Pipeline

type Pipeline interface {
	GetAPIVersion() string
	GetKind() string
	GetDirectory() string
	GetResources() []string
	GetSteps() []Step
}

func NewPipeline

func NewPipeline(dir string) (Pipeline, error)

type Step

type Step interface {
	GetID() string
	GetName() string
	GetImage() string
	GetEntrypoint() []string
	GetUser() string
	GetWorkdir() string
	GetNetwork() bool
	GetMounts() []string
	GetConfig() map[string]interface{}
}