agent

Documentation

Index

• Constants
• func NewServer(opts *ServerOption) cloud_agent.AgentServer
• func NewSocket(network, address string) (net.Listener, error)
• func NewWatcher(opts WatcherOptions, fn ...WatchFn) (*cron.Cron, error)
• type Cache
  • func NewCache[T any]() Cache[T]
• type RegisteredResource
• type ServerOption
• type WatchFn
• 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)

func NewWatcher

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

Types

type Cache

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

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.Logger
}

type WatchFn

type WatchFn func(context.Context)

type WatcherOptions

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