canary

type CanaryStatus struct {
	v1beta1.CanaryStatus

	StatusGeneration uint64

	StatusIndicator *indicators.StringEqualConditionIndicator

	Duration string
	Age      string

	IsSucceeded  bool
	IsFailed     bool
	FailedReason string
}

type FailedReport struct {
	FailedReason string
	CanaryStatus CanaryStatus
}

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
}

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
}