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 ResourceGetter
• type ServerCache
  • func (sc *ServerCache) GetGardenerCache() Cache[*v1beta1.ShootList]
  • func (sc *ServerCache) GetGeneralError() error
• type ServerOption
• type Value
• 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, error)
	Get() Value[T]
}

type ResourceGetter

type ResourceGetter interface {
	GetGardenerCache() Cache[*v1beta1.ShootList]
	GetGeneralError() error
}

type ServerCache

type ServerCache struct {
	GardenerCache Cache[*v1beta1.ShootList]
	GeneralError  error
}

func (*ServerCache) GetGardenerCache

func (sc *ServerCache) GetGardenerCache() Cache[*v1beta1.ShootList]

func (*ServerCache) GetGeneralError

func (sc *ServerCache) GetGeneralError() error

type ServerOption

type ServerOption struct {
	ResourceGetter ResourceGetter
	Logger         *logrus.Entry
}

type Value

type Value[T any] struct {
	Error error
	Time  time.Time
	Value T
}

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
}