server

Documentation

Index

• func DatasetGC(ctx context.Context, ins dsync.Interface) error
• func NewEventHandlerFuncs(ctx context.Context, ins dsync.Interface, set nodeset.Interface) cache.ResourceEventHandlerFuncs
• func NewRouter(cfg *Config, kubeClient kubernetes.Interface, ins dsync.Interface, ...) http.Handler
• func Run(cfg *Config, kubeClient kubernetes.Interface, dynamicClient dynamic.Interface) error
• type Config
  • func Environ(envPrefix string) *Config
  • func (c *Config) Complete()
  • func (c *Config) Validate() error
• type Instance
• type Storage

Functions

func DatasetGC

func DatasetGC(ctx context.Context, ins dsync.Interface) error

DatasetGC runs the dataset garbage collection

func NewEventHandlerFuncs

func NewEventHandlerFuncs(ctx context.Context, ins dsync.Interface, set nodeset.Interface) cache.ResourceEventHandlerFuncs

NewEventHandlerFuncs returns a resource event handler funcs

func NewRouter

func NewRouter(cfg *Config, kubeClient kubernetes.Interface, ins dsync.Interface, set nodeset.Interface) http.Handler

func Run

func Run(cfg *Config, kubeClient kubernetes.Interface, dynamicClient dynamic.Interface) error

Types

type Config

type Config struct {
	Logger     logr.Config   `json:"logger,omitempty"`
	Instance   Instance      `json:"instance,omitempty"`
	Server     server.Config `json:"server,omitempty"`
	Kubernetes *k8s.Config   `json:"kubernetes,omitempty"`
	Storage    Storage       `json:"storage,omitempty"`
}

func Environ

func Environ(envPrefix string) *Config

func (*Config) Complete

func (c *Config) Complete()

func (*Config) Validate

func (c *Config) Validate() error

type Instance

type Instance struct {
	Name string `json:"name"`
}

type Storage

type Storage struct {
	Badger *badgerstorage.Config `json:"badger"`
}