kubernetes

Documentation

Index

• Constants
• func GetClients() (client.Reader, dynamic.Interface, error)
• type DefaultEventType
• type Event
• type INotify
• type Notifier
  • func (w *Notifier) GetEvent() Event[DefaultEventType]
• type Sync
  • func NewK8sSync(logger *logger.Logger, uri string, reader client.Reader, ...) *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

Constants

const (
	DefaultEventTypeCreate = iota
	DefaultEventTypeModify = 1
	DefaultEventTypeDelete = 2
	DefaultEventTypeReady  = 3
)

Functions

func GetClients

func GetClients() (client.Reader, dynamic.Interface, error)

Types

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 (*Notifier) GetEvent

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

type Sync

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

func NewK8sSync

func NewK8sSync(
	logger *logger.Logger,
	uri string,
	reader client.Reader,
	dynamic dynamic.Interface,
) *Sync

func (*Sync) Init

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

func (*Sync) IsReady

func (k *Sync) IsReady() bool

func (*Sync) ReSync

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

func (*Sync) Sync

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