canary

Documentation

Index

• type CanaryStatus
  • func NewCanaryStatus(object *v1beta1.Canary, statusGeneration uint64, isTrackerFailed bool, ...) CanaryStatus
• type FailedReport
• type Feed
  • func NewFeed() Feed
• type Tracker
  • func NewTracker(name, namespace string, kube kubernetes.Interface, opts tracker.Options) *Tracker
  • func (canary *Tracker) Track(ctx context.Context) error

Types

type CanaryStatus

type CanaryStatus struct {
	v1beta1.CanaryStatus

	StatusGeneration uint64

	StatusIndicator *indicators.StringEqualConditionIndicator

	Duration string
	Age      string

	IsSucceeded  bool
	IsFailed     bool
	FailedReason string
}

func NewCanaryStatus

func NewCanaryStatus(object *v1beta1.Canary, statusGeneration uint64, isTrackerFailed bool, trackerFailedReason string, canariesStatuses map[string]v1beta1.CanaryStatus) CanaryStatus

type FailedReport

type FailedReport struct {
	FailedReason string
	CanaryStatus CanaryStatus
}

type Feed

type Feed interface {
	OnAdded(func() error)
	OnSucceeded(func() error)
	OnFailed(func(reason string) error)
	OnEventMsg(func(msg string) error)
	OnStatus(func(CanaryStatus) error)

	GetStatus() CanaryStatus
	Track(name, namespace string, kube kubernetes.Interface, opts tracker.Options) error
}

func NewFeed

func NewFeed() Feed

type Tracker

type Tracker struct {
	tracker.Tracker
	LogsFromTime time.Time

	Added     chan CanaryStatus
	Succeeded chan CanaryStatus
	Failed    chan CanaryStatus
	Status    chan CanaryStatus

	EventMsg chan string

	State tracker.TrackerState
	// contains filtered or unexported fields
}

func NewTracker

func NewTracker(name, namespace string, kube kubernetes.Interface, opts tracker.Options) *Tracker

func (*Tracker) Track

func (canary *Tracker) Track(ctx context.Context) error