source

Documentation

Index

• func Kind(cache cache.Cache, object client.Object) source.SyncingSource
• func NewReplayEvent() event.GenericEvent
• func NewResourceEvent(name, ns string) event.GenericEvent
• type Event
  • func (e *Event) DeepCopyObject() runtime.Object
• type SyncCache
• type SyncType
• type WithSyncCache
  • func (s *WithSyncCache) WaitForSync(ctx context.Context) error

Functions

func Kind

func Kind(cache cache.Cache, object client.Object) source.SyncingSource

func NewReplayEvent

func NewReplayEvent() event.GenericEvent

NewReplayEvent returns a replay flow event

func NewResourceEvent

func NewResourceEvent(name, ns string) event.GenericEvent

Types

type Event

type Event struct {
	metav1.TypeMeta
	metav1.ObjectMeta
}

func (*Event) DeepCopyObject

func (e *Event) DeepCopyObject() runtime.Object

DeepCopyObject is deep copy method for a event

type SyncCache

type SyncCache interface {
	WaitForCacheSync(ctx context.Context) bool
}

type SyncType

type SyncType string

const (
	// ReplayType sync event type is replay service proxy flow
	ReplayType SyncType = "replay"
)

type WithSyncCache

type WithSyncCache struct {
	Name string
	source.Source
	SyncCaches []SyncCache
}

func (*WithSyncCache) WaitForSync

func (s *WithSyncCache) WaitForSync(ctx context.Context) error