1 package entrypoint
2
3 import (
4 "context"
5
6 "github.com/datawire/ambassador/v2/pkg/kates"
7 )
8
9 type K8sSource interface {
10 Watch(ctx context.Context, queries ...kates.Query) (K8sWatcher, error)
11 }
12
13 type K8sWatcher interface {
14 Changed() <-chan struct{}
15 FilteredUpdate(ctx context.Context, target interface{}, deltas *[]*kates.Delta, predicate func(*kates.Unstructured) bool) (bool, error)
16 }
17
18 type IstioCertSource interface {
19 Watch(ctx context.Context) (IstioCertWatcher, error)
20 }
21
22 type IstioCertWatcher interface {
23 Changed() <-chan IstioCertUpdate
24 }
25
View as plain text