datasource

Documentation

Index

• type Datasource
  • func NewFakeDatasource(ctx context.Context) Datasource
  • func NewFileSystemDatasource(ctx context.Context, rootDir string, statusOutputDir string) Datasource
  • func NewKubernetesInformerDatasource(ctx context.Context, cfg *config.Config, updateChan chan time.Time) (Datasource, error)
• type MiniContainer
• type Mount
• type NamespaceConfig
• type StatusUpdater

Types

type Datasource

type Datasource interface {
	StatusUpdater
	GetNamespaces(ctx context.Context) ([]*NamespaceConfig, error)
	WriteCurrentConfigHash(namespace string, hash string)
}

Datasource reads data from k8s

func NewFakeDatasource

func NewFakeDatasource(ctx context.Context) Datasource

NewFakeDatasource returns a predefined set of namespaces + configs

func NewFileSystemDatasource

func NewFileSystemDatasource(ctx context.Context, rootDir string, statusOutputDir string) Datasource

NewFileSystemDatasource turns all files matching *.conf patter in the given dir into namespace configs

func NewKubernetesInformerDatasource

func NewKubernetesInformerDatasource(ctx context.Context, cfg *config.Config, updateChan chan time.Time) (Datasource, error)

NewKubernetesInformerDatasource builds a new Datasource from the provided config. The returned Datasource uses Informers to efficiently track objects in the kubernetes API by watching for updates to a known state.

type MiniContainer

type MiniContainer struct {
	// the pod id
	PodID   string
	PodName string

	Image       string
	ContainerID string

	// pod labels
	Labels map[string]string

	// container name
	Name string
	// only the emptyDir mounts, never empty, sorted by len(Path), descending
	HostMounts []*Mount

	NodeName string
}

MiniContainer container subset with the parent pod's metadata

type Mount

type Mount struct {
	Path       string
	VolumeName string
	SubPath    string
}

type NamespaceConfig

type NamespaceConfig struct {
	Name               string
	FluentdConfig      string
	PreviousConfigHash string
	MiniContainers     []*MiniContainer
	Labels             map[string]string
}

NamespaceConfig holds all relevant data for a namespace

type StatusUpdater

type StatusUpdater interface {
	UpdateStatus(ctx context.Context, namespace string, status string)
}

StatusUpdater sets an error description on the namespace in case configuration cannot be applied or an empty string otherwise