klcpermit

Documentation

Index

• Constants
• func GetCRDName(pod *corev1.Pod) string
• 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 (
	Name = "KLCPermit"
)

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

Functions

func GetCRDName

func GetCRDName(pod *corev1.Pod) string

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 (
	StateRunning   KeptnState = "Running"
	StateSucceeded KeptnState = "Succeeded"
	StateFailed    KeptnState = "Failed"
	StateUnknown   KeptnState = "Unknown"
	StatePending   KeptnState = "Pending"
)

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 implements a wait for pre-deployment checks

func (*Permit) Name

func (pl *Permit) Name() string

Name 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 (
	WorkloadInstanceStatusNotSpecified Status = "Workload run status not specified"
	WorkloadInstanceNotFound           Status = "Workload run not found"
	Success                            Status = "Success"
	Failure                            Status = "Failure"
	Wait                               Status = "Wait"
)

type WorkloadManager

type WorkloadManager struct {
	// 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