meta

Documentation

Index

• type BaseNotifier
  • func NewBaseNotifier() BaseNotifier
  • func (i *BaseNotifier) Notify(event *informer.Event)
  • func (i *BaseNotifier) Subscribe(observer Observer)
  • func (i *BaseNotifier) Unsubscribe(observer Observer)
• type InformerOption
  • func WithKubeClient(client kubernetes.Interface) InformerOption
  • func WithKubeConfigPath(path string) InformerOption
  • func WithResyncPeriod(period time.Duration) InformerOption
  • func WithoutNodes() InformerOption
  • func WithoutServices() InformerOption
• type Informers
  • func InitInformers(ctx context.Context, opts ...InformerOption) (*Informers, error)
  • func (inf *Informers) Subscribe(observer Observer)
• type Notifier
• type Observer

Types

type BaseNotifier

type BaseNotifier struct {
	// contains filtered or unexported fields
}

func NewBaseNotifier

func NewBaseNotifier() BaseNotifier

func (*BaseNotifier) Notify

func (i *BaseNotifier) Notify(event *informer.Event)

func (*BaseNotifier) Subscribe

func (i *BaseNotifier) Subscribe(observer Observer)

func (*BaseNotifier) Unsubscribe

func (i *BaseNotifier) Unsubscribe(observer Observer)

type InformerOption

type InformerOption func(*informersConfig)

func WithKubeClient

func WithKubeClient(client kubernetes.Interface) InformerOption

func WithKubeConfigPath

func WithKubeConfigPath(path string) InformerOption

func WithResyncPeriod

func WithResyncPeriod(period time.Duration) InformerOption

func WithoutNodes

func WithoutNodes() InformerOption

func WithoutServices

func WithoutServices() InformerOption

type Informers

type Informers struct {
	BaseNotifier
	// contains filtered or unexported fields
}

func InitInformers

func InitInformers(ctx context.Context, opts ...InformerOption) (*Informers, error)

func (*Informers) Subscribe

func (inf *Informers) Subscribe(observer Observer)

type Notifier

type Notifier interface {
	Subscribe(observer Observer)
	Unsubscribe(observer Observer)
	Notify(event *informer.Event)
}

type Observer

type Observer interface {
	ID() string
	On(event *informer.Event)
}