knconf

Documentation

Index

• func AcceptsCEVersions(ctx context.Context, t feature.T, gvr schema.GroupVersionResource, name string)
• func AssertEventPatterns(prober *eventshub.EventProber, expected map[string]EventPattern) feature.StepFn
• func DeliveryAttempts(specs ...*v1.DeliverySpec) uint
• func EventToEvent(in *cloudevents.Event) conformanceevent.Event
• func HasReadyInConditions(_ context.Context, t feature.T, status duckv1.Status)
• func KResourceHasObservedGeneration(gvr schema.GroupVersionResource, name string) feature.StepFn
• func KResourceHasReadyInConditions(gvr schema.GroupVersionResource, name string) feature.StepFn
• func ReceivedEventsFromProber(ctx context.Context, prober *eventshub.EventProber, prefix string) []conformanceevent.Event
• func SentEventMatcher(uuid string) func(eventshub.EventInfo) error
• type EventInfoCombined
  • func Correlate(in []eventshub.EventInfo) []EventInfoCombined
• type EventPattern
  • func PatternFromEstimates(attempts, failures uint) EventPattern
  • func PatternFromProber(ctx context.Context, prober *eventshub.EventProber, prefix string) EventPattern

Functions

func AcceptsCEVersions

func AcceptsCEVersions(ctx context.Context, t feature.T, gvr schema.GroupVersionResource, name string)

func AssertEventPatterns

func AssertEventPatterns(prober *eventshub.EventProber, expected map[string]EventPattern) feature.StepFn

func DeliveryAttempts

func DeliveryAttempts(specs ...*v1.DeliverySpec) uint

DeliveryAttempts will return the number of times the first non-nil delivery spec declares retry to be. The returned value will be 1 + retry.

func EventToEvent

func EventToEvent(in *cloudevents.Event) conformanceevent.Event

func HasReadyInConditions

func HasReadyInConditions(_ context.Context, t feature.T, status duckv1.Status)

func KResourceHasObservedGeneration

func KResourceHasObservedGeneration(gvr schema.GroupVersionResource, name string) feature.StepFn

func KResourceHasReadyInConditions

func KResourceHasReadyInConditions(gvr schema.GroupVersionResource, name string) feature.StepFn

func ReceivedEventsFromProber

func ReceivedEventsFromProber(ctx context.Context, prober *eventshub.EventProber, prefix string) []conformanceevent.Event

func SentEventMatcher

func SentEventMatcher(uuid string) func(eventshub.EventInfo) error

Types

type EventInfoCombined

type EventInfoCombined struct {
	Sent     eventshub.EventInfo
	Response eventshub.EventInfo
}

func Correlate

func Correlate(in []eventshub.EventInfo) []EventInfoCombined

Correlate takes in an array of mixed Sent / Response events (matched with sentEventMatcher for example) and correlates them based on the sequence into a pair.

type EventPattern

type EventPattern struct {
	Success  []bool
	Interval []uint
}

func PatternFromEstimates

func PatternFromEstimates(attempts, failures uint) EventPattern

func PatternFromProber

func PatternFromProber(ctx context.Context, prober *eventshub.EventProber, prefix string) EventPattern