Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 ¶
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 (*FluentdConfigDS) GetFdlist ¶
func (f *FluentdConfigDS) GetFdlist() kfoListersV1beta1.FluentdConfigLister
GetFdList returns the lister for fluentconfigs informer:
func (*FluentdConfigDS) GetFluentdConfig ¶
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 (*MigrationModeDS) GetFdlist ¶
func (m *MigrationModeDS) GetFdlist() kfoListersV1beta1.FluentdConfigLister
GetFdlist return nil for this mode because it does not use CRDs:
func (*MigrationModeDS) GetFluentdConfig ¶
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
Source Files
¶
Directories
¶
| Path | Synopsis |
|---|---|
|
fluentdconfig
|
|
|
client/clientset/versioned
This package has the automatically generated clientset.
|
This package has the automatically generated clientset. |
|
client/clientset/versioned/fake
This package has the automatically generated fake clientset.
|
This package has the automatically generated fake clientset. |
|
client/clientset/versioned/scheme
This package contains the scheme of the automatically generated clientset.
|
This package contains the scheme of the automatically generated clientset. |
|
client/clientset/versioned/typed/logs.vdp.vmware.com/v1beta1
This package has the automatically generated typed clients.
|
This package has the automatically generated typed clients. |
|
client/clientset/versioned/typed/logs.vdp.vmware.com/v1beta1/fake
Package fake has the automatically generated clients.
|
Package fake has the automatically generated clients. |