kubedatasource

Documentation

Index

• type ConfigMapDS
  • func NewConfigMapDS(ctx context.Context, cfg *config.Config, ...) (*ConfigMapDS, error)
  • func (c *ConfigMapDS) GetFdlist() kfoListersV1beta1.FluentdConfigLister
  • func (c *ConfigMapDS) GetFluentdConfig(ctx context.Context, namespace string) (string, error)
  • func (c *ConfigMapDS) IsReady() bool
• type FluentdConfigDS
  • func NewFluentdConfigDS(ctx context.Context, cfg *config.Config, kubeCfg *rest.Config, ...) (*FluentdConfigDS, error)
  • func (f *FluentdConfigDS) GetFdlist() kfoListersV1beta1.FluentdConfigLister
  • func (f *FluentdConfigDS) GetFluentdConfig(ctx context.Context, namespace string) (string, error)
  • func (f *FluentdConfigDS) IsReady() bool
• type KubeDS
• type MigrationModeDS
  • func NewMigrationModeDS(ctx context.Context, cfg *config.Config, kubeCfg *rest.Config, ...) (*MigrationModeDS, error)
  • func (m *MigrationModeDS) GetFdlist() kfoListersV1beta1.FluentdConfigLister
  • func (m *MigrationModeDS) GetFluentdConfig(ctx context.Context, namespace string) (string, error)
  • func (m *MigrationModeDS) IsReady() bool

Types

type ConfigMapDS

type ConfigMapDS struct {
	// contains filtered or unexported fields
}

func NewConfigMapDS

func NewConfigMapDS(ctx context.Context, cfg *config.Config, factory informers.SharedInformerFactory, updateChan chan time.Time) (*ConfigMapDS, error)

func (*ConfigMapDS) GetFdlist

func (c *ConfigMapDS) GetFdlist() kfoListersV1beta1.FluentdConfigLister

GetFdlist return nil for this mode because it does not use CRDs:

func (*ConfigMapDS) GetFluentdConfig

func (c *ConfigMapDS) GetFluentdConfig(ctx context.Context, namespace string) (string, error)

GetFluentdConfig returns the fluentd configs for the given ns extracted by the configured ConfigMaps

func (*ConfigMapDS) IsReady

func (c *ConfigMapDS) IsReady() bool

IsReady returns a boolean specifying whether the ConfigMapDS is ready

type FluentdConfigDS

type FluentdConfigDS struct {
	Cfg        *config.Config
	Fdlist     kfoListersV1beta1.FluentdConfigLister
	Fdready    func() bool
	UpdateChan chan time.Time
}

func NewFluentdConfigDS

func NewFluentdConfigDS(ctx context.Context, cfg *config.Config, kubeCfg *rest.Config, updateChan chan time.Time) (*FluentdConfigDS, error)

func (*FluentdConfigDS) GetFdlist

func (f *FluentdConfigDS) GetFdlist() kfoListersV1beta1.FluentdConfigLister

GetFdList returns the lister for fluentconfigs informer:

func (*FluentdConfigDS) GetFluentdConfig

func (f *FluentdConfigDS) GetFluentdConfig(ctx context.Context, namespace string) (string, error)

GetFluentdConfig returns the fluentd configs for the given ns extracted by the configured FluentdConfigs k8s resources

func (*FluentdConfigDS) IsReady

func (f *FluentdConfigDS) IsReady() bool

IsReady returns a boolean specifying whether the FluentdConfigDS is ready

type KubeDS

type KubeDS interface {
	GetFluentdConfig(ctx context.Context, namespace string) (string, error)
	IsReady() bool
	GetFdlist() kfoListersV1beta1.FluentdConfigLister
}

KubeDS is an interface defining behavor for the Kubernetes Resources containing FluentD configurations

type MigrationModeDS

type MigrationModeDS struct {
	// contains filtered or unexported fields
}

MigrationModeDS is an abstraction providing a virtual KubeDS instance that internally uses both the fluentdConfig KubeDS and the configMap KubeDS This abstraction allows both KubeDS to be used together

func NewMigrationModeDS

func NewMigrationModeDS(ctx context.Context, cfg *config.Config, kubeCfg *rest.Config, factory informers.SharedInformerFactory, updateChan chan time.Time) (*MigrationModeDS, error)

func (*MigrationModeDS) GetFdlist

func (m *MigrationModeDS) GetFdlist() kfoListersV1beta1.FluentdConfigLister

GetFdlist return nil for this mode because it does not use CRDs:

func (*MigrationModeDS) GetFluentdConfig

func (m *MigrationModeDS) GetFluentdConfig(ctx context.Context, namespace string) (string, error)

GetFluentdConfig returns the fluentd configs for the given ns extracted by the two KubeDS and concatenated together

func (*MigrationModeDS) IsReady

func (m *MigrationModeDS) IsReady() bool

IsReady returns a boolean specifying whether the MigrationModeDS is ready