agent

Documentation

Index

• Constants
• func NewServer(opts *ServerOption) cloud_agent.AgentServer
• func NewSocket(network, address string) (net.Listener, error)
• type Cache
  • func NewCache[T any]() Cache[T]
• type RegisteredResource
• type ServerOption
• type WatchFn
• type Watcher
  • func NewWatcher(opts WatcherOptions, fn ...WatchFn) (*Watcher, error)
  • func (w *Watcher) Start()
  • func (w *Watcher) Stop() context.Context
• type WatcherOptions

Constants

const (
	Address = "/tmp/cloudagent/cloudagent.sock"
	Network = "unix"
)

Functions

func NewServer

func NewServer(opts *ServerOption) cloud_agent.AgentServer

func NewSocket

func NewSocket(network, address string) (net.Listener, error)

Types

type Cache

type Cache[T any] interface {
	Register(name string) RegisteredResource[T]
	Resources() map[string]RegisteredResource[T]
	Clean()
}

func NewCache

func NewCache[T any]() Cache[T]

type RegisteredResource

type RegisteredResource[T any] interface {
	Set(T)
	Get() T
}

type ServerOption

type ServerOption struct {
	GardenerCache Cache[*v1beta1.ShootList]
	Logger        *logrus.Entry
}

type WatchFn

type WatchFn func(context.Context)

type Watcher

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

func NewWatcher

func NewWatcher(opts WatcherOptions, fn ...WatchFn) (*Watcher, error)

func (*Watcher) Start

func (w *Watcher) Start()

func (*Watcher) Stop

func (w *Watcher) Stop() context.Context

type WatcherOptions

type WatcherOptions struct {
	Spec    string
	Context context.Context
	Logger  *logrus.Entry
}