knconf

Documentation

Index

• func AcceptsCEVersions(ctx context.Context, t feature.T, gvr schema.GroupVersionResource, name string)
• 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 SentEventMatcher(uuid string) func(eventshubmain.EventInfo) error
• type EventInfoCombined
  • func Correlate(in []eventshubmain.EventInfo) []EventInfoCombined

Functions

func AcceptsCEVersions

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

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 SentEventMatcher

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

Types

type EventInfoCombined

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

func Correlate

func Correlate(in []eventshubmain.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.