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, q *s2hv1.Queue) error
• func GetComponentUpgradeRPCFromQueue(comStatus samsahairpc.ComponentUpgrade_UpgradeStatus, queueHistName string, ...) *samsahairpc.ComponentUpgrade
• func New(ns string, cli client.Client) internal.QueueController
• func NewInitialPullRequestQueue(teamName, namespace, queueName, prBundleName, prNumber string, ...) *s2hv1.Queue
• 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, q *s2hv1.Queue) 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, cli client.Client) internal.QueueController

New returns QueueController

func NewInitialPullRequestQueue

func NewInitialPullRequestQueue(teamName, namespace, queueName, prBundleName, prNumber string,
	comps s2hv1.QueueComponents, noOfRetry int, extra *s2hv1.QueueExtraParameters) *s2hv1.Queue

NewInitialPullRequestQueue returns initial value of PullRequestQueue

func NewQueue

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