adapter

Documentation

Index

• func GetLoggingConfig(kc kubernetes.Interface, loggingConfigMapName string) (*pkglogging.Config, error)
• func Main(component string, ctor AdapterConstructor)
• func MainWithContext(component string, ctor AdapterConstructor, ctx context.Context)
• type Adapter
• type AdapterConstructor
• type SystemConfig

Functions

func GetLoggingConfig

func GetLoggingConfig(kc kubernetes.Interface, loggingConfigMapName string) (*pkglogging.Config, error)

GetLoggingConfig returns configmap typed pkglogging.Config from ApiServer.

func Main

func Main(component string, ctor AdapterConstructor)

func MainWithContext

func MainWithContext(component string, ctor AdapterConstructor, ctx context.Context)

MainWithContext - watches profiling and logging configmap - defines zap logger - runs injected AdapterConstructor which is called Receive Server - runs Profiling Server - Sends Signal to injected AdapterConstructor and shutdown Profiling Server when received

Types

type Adapter

type Adapter interface {
	Start(stopCh <-chan struct{})
}

Adapter must have Start method.

type AdapterConstructor

type AdapterConstructor func(ctx context.Context) Adapter

AdapterConstructor returns Adapter.

type SystemConfig

type SystemConfig struct {
	PodName                    string `split_words:"true"`
	ProfilePort                int    `default:"8018" split_words:"true"`
	LoggingConfigMapName       string `default:"config-logging" split_words:"true"`
	ObservabilityConfigMapName string `default:"config-observability" split_words:"true"`
	KubernetesMinVersion       string `split_words:"true" require:"true"`
}