kubernetes

type DefaultEventType ¶

type DefaultEventType int32

type Event ¶

type Event[T any] struct {
	EventType T
}

Event is a struct that represents a single event. It is a generic struct that can be cast to a more specific struct.

type INotify ¶

type INotify interface {
	GetEvent() Event[DefaultEventType]
}

type Notifier ¶

type Notifier struct {
	Event Event[DefaultEventType]
}

func (w *Notifier) GetEvent() Event[DefaultEventType]

type Sync ¶

type Sync struct {
	URI string
	// contains filtered or unexported fields
}

func NewK8sSync(
	logger *logger.Logger,
	uri string,
	dynamicClient dynamic.Interface,
) *Sync

func (k *Sync) Init(_ context.Context) error

func (k *Sync) IsReady() bool

func (k *Sync) ReSync(ctx context.Context, dataSync chan<- sync.DataSync) error

func (k *Sync) Sync(ctx context.Context, dataSync chan<- sync.DataSync) error

type SyncOption ¶ added in v0.7.3

type SyncOption func(s *Sync)