queue

Documentation

Index

• Constants
• func DeleteDemoteFromActiveQueue(c client.Client, ns string) error
• func DeletePreActiveQueue(c client.Client, ns string) error
• func DeletePromoteToActiveQueue(c client.Client, ns string) error
• func DeletePullRequestQueue(c client.Client, ns, queueName string) error
• func EnsureDemoteFromActiveComponents(c client.Client, teamName, namespace string) (q *s2hv1.Queue, err error)
• func EnsurePreActiveComponents(c client.Client, teamName, namespace string, skipTest bool) (q *s2hv1.Queue, err error)
• func EnsurePromoteToActiveComponents(c client.Client, teamName, namespace string) (q *s2hv1.Queue, err error)
• func EnsurePullRequestComponents(c client.Client, teamName, namespace, queueName, prBundleName, prNumber string, ...) (q *s2hv1.Queue, err error)
• func GetComponentUpgradeRPCFromQueue(comStatus samsahairpc.ComponentUpgrade_UpgradeStatus, queueHistName string, ...) *samsahairpc.ComponentUpgrade
• func New(ns string, runtimeClient client.Client) internal.QueueController
• func NewQueue(teamName, namespace, name, bundle string, comps []*s2hv1.QueueComponent, ...) *s2hv1.Queue

Constants

const CtrlName = "queue-ctrl"

Functions

func DeleteDemoteFromActiveQueue

func DeleteDemoteFromActiveQueue(c client.Client, ns string) error

func DeletePreActiveQueue

func DeletePreActiveQueue(c client.Client, ns string) error

func DeletePromoteToActiveQueue

func DeletePromoteToActiveQueue(c client.Client, ns string) error

func DeletePullRequestQueue

func DeletePullRequestQueue(c client.Client, ns, queueName string) error

func EnsureDemoteFromActiveComponents

func EnsureDemoteFromActiveComponents(c client.Client, teamName, namespace string) (q *s2hv1.Queue, err error)

EnsureDemoteFromActiveComponents ensures that components were deployed without `active` config

func EnsurePreActiveComponents

func EnsurePreActiveComponents(c client.Client, teamName, namespace string, skipTest bool) (q *s2hv1.Queue, err error)

EnsurePreActiveComponents ensures that components were deployed with `pre-active` config and tested

func EnsurePromoteToActiveComponents

func EnsurePromoteToActiveComponents(c client.Client, teamName, namespace string) (q *s2hv1.Queue, err error)

EnsurePromoteToActiveComponents ensures that components were deployed with `active` config

func EnsurePullRequestComponents

func EnsurePullRequestComponents(c client.Client, teamName, namespace, queueName, prBundleName, prNumber string,
	comps s2hv1.QueueComponents, noOfRetry int) (q *s2hv1.Queue, err error)

EnsurePullRequestComponents ensures that pull request components were deployed with `pull-request` config and tested

func GetComponentUpgradeRPCFromQueue

func GetComponentUpgradeRPCFromQueue(
	comStatus samsahairpc.ComponentUpgrade_UpgradeStatus,
	queueHistName string,
	queueHistNamespace string,
	queue *s2hv1.Queue,
	prQueueRPC *samsahairpc.TeamWithPullRequest,
) *samsahairpc.ComponentUpgrade

func New

func New(ns string, runtimeClient client.Client) internal.QueueController

New returns QueueController

func NewQueue

func NewQueue(teamName, namespace, name, bundle string, comps []*s2hv1.QueueComponent, queueType s2hv1.QueueType) *s2hv1.Queue