klcpermit

Documentation

Index

• Constants
• func New(_ runtime.Object, h framework.Handle) (framework.Plugin, error)
• type KeptnState
• type Manager
• type Permit
  • func (pl *Permit) Name() string
  • func (pl *Permit) Permit(ctx context.Context, state *framework.CycleState, p *v1.Pod, nodeName string) (*framework.Status, time.Duration)
• type Status
• type WorkloadManager
  • func NewWorkloadManager(d dynamic.Interface) *WorkloadManager
  • func (sMgr *WorkloadManager) GetCRD(ctx context.Context, namespace string, name string) (*unstructured.Unstructured, error)
  • func (sMgr *WorkloadManager) Permit(ctx context.Context, pod *corev1.Pod) Status

Constants

const AppAnnotation = "keptn.sh/app"

const ContainerNameAnnotation = "keptn.sh/container"

const K8sRecommendedAppAnnotations = "app.kubernetes.io/part-of"

const K8sRecommendedVersionAnnotations = "app.kubernetes.io/version"

const K8sRecommendedWorkloadAnnotations = "app.kubernetes.io/name"

const MaxK8sObjectLength = 253

const MinKeptnNameLen = 80

const (
	PluginName = "KLCPermit"
)

PluginName is the name of the plugin used in the plugin registry and configurations.

const VersionAnnotation = "keptn.sh/version"

const WorkloadAnnotation = "keptn.sh/workload"

Functions

func New

func New(_ runtime.Object, h framework.Handle) (framework.Plugin, error)

New initializes a new plugin and returns it.

Types

type KeptnState

type KeptnState string

const (
	StateProgressing KeptnState = "Progressing"
	StateSucceeded   KeptnState = "Succeeded"
	StateFailed      KeptnState = "Failed"
	StateUnknown     KeptnState = "Unknown"
	StatePending     KeptnState = "Pending"
	StateDeprecated  KeptnState = "Deprecated"
)

type Manager

type Manager interface {
	Permit(context.Context, *corev1.Pod) Status
}

type Permit

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

Permit is a plugin that waits for pre-deployment checks to be successfully finished

func (*Permit) Name

func (pl *Permit) Name() string

PluginName returns name of the plugin.

func (*Permit) Permit

func (pl *Permit) Permit(ctx context.Context, state *framework.CycleState, p *v1.Pod, nodeName string) (*framework.Status, time.Duration)

type Status

type Status string

const (
	WorkloadVersionStatusNotSpecified Status = "Workload run status not specified"
	WorkloadVersionNotFound           Status = "Workload run not found"
	Success                           Status = "Success"
	Failure                           Status = "Failure"
	Wait                              Status = "Wait"
)

type WorkloadManager

type WorkloadManager struct {
	Tracer trace.Tracer
	// contains filtered or unexported fields
}

func NewWorkloadManager

func NewWorkloadManager(d dynamic.Interface) *WorkloadManager

func (*WorkloadManager) GetCRD

func (sMgr *WorkloadManager) GetCRD(ctx context.Context, namespace string, name string) (*unstructured.Unstructured, error)

GetCRD returns unstructured to avoid tight coupling with the CRD resource

func (*WorkloadManager) Permit

func (sMgr *WorkloadManager) Permit(ctx context.Context, pod *corev1.Pod) Status