utils

Documentation

Index

• func CleanResource(ns v1.NamespaceInterface, cl v3.ClusterLoggingLister, ...) (bool, error)
• func CreateFluentd(ds rv1beta2.DaemonSetInterface, sa rv1.ServiceAccountInterface, ...) (err error)
• func CreateLogAggregator(ds rv1beta2.DaemonSetInterface, sa rv1.ServiceAccountInterface, ...) (err error)
• func GetClusterTarget(spec v3.ClusterLoggingSpec) string
• func GetDriverDir(driverName string) string
• func GetProjectTarget(spec v3.ProjectLoggingSpec) string
• func InitSecret(secrets rv1.SecretInterface) (err error)
• func IniteNamespace(ns rv1.NamespaceInterface) error
• func IsAllLoggingDisable(clusterLoggingLister v3.ClusterLoggingLister, ...) (bool, error)
• func NewFluentdDaemonset(name, namespace, dockerRootDir string) *v1beta2.DaemonSet
• func NewLogAggregatorDaemonset(name, namespace, driverDir string) *v1beta2.DaemonSet
• func UnsetSecret(secrets rv1.SecretInterface, name, prefix string) error
• func UpdateConfig(configPath, name, level string, secrets rv1.SecretInterface) error
• func UpdateSSLAuthentication(prefix string, esConfig *v3.ElasticsearchConfig, spConfig *v3.SplunkConfig, ...) error
• type FluentServer
• type WrapClusterLogging
  • func ToWrapClusterLogging(clusterLogging v3.ClusterLoggingSpec) (*WrapClusterLogging, error)
• type WrapElasticsearch
• type WrapFluentForwarder
• type WrapKafka
• type WrapLogging
  • func GetWrapConfig(es *v3.ElasticsearchConfig, sp *v3.SplunkConfig, sl *v3.SyslogConfig, ...) (wrapLogging WrapLogging, err error)
• type WrapProjectLogging
  • func ToWrapProjectLogging(grepNamespace string, projectLogging v3.ProjectLoggingSpec) (*WrapProjectLogging, error)
• type WrapSplunk
• type WrapSyslog

Functions

func CleanResource

func CleanResource(ns v1.NamespaceInterface, cl v3.ClusterLoggingLister, pl v3.ProjectLoggingLister, currentCL *v3.ClusterLogging, currentPL *v3.ProjectLogging) (bool, error)

func CreateFluentd

func CreateFluentd(ds rv1beta2.DaemonSetInterface, sa rv1.ServiceAccountInterface, rb rrbacv1.ClusterRoleBindingInterface, namespace, dockerRootDir string) (err error)

func CreateLogAggregator

func CreateLogAggregator(ds rv1beta2.DaemonSetInterface, sa rv1.ServiceAccountInterface, rb rrbacv1.ClusterRoleBindingInterface, driverDir, namespace string) (err error)

func GetClusterTarget

func GetClusterTarget(spec v3.ClusterLoggingSpec) string

func GetDriverDir

func GetDriverDir(driverName string) string

func GetProjectTarget

func GetProjectTarget(spec v3.ProjectLoggingSpec) string

func InitSecret

func InitSecret(secrets rv1.SecretInterface) (err error)

func IniteNamespace

func IniteNamespace(ns rv1.NamespaceInterface) error

func IsAllLoggingDisable

func IsAllLoggingDisable(clusterLoggingLister v3.ClusterLoggingLister, projectLoggingLister v3.ProjectLoggingLister, currentCL *v3.ClusterLogging, currentPL *v3.ProjectLogging) (bool, error)

func NewFluentdDaemonset

func NewFluentdDaemonset(name, namespace, dockerRootDir string) *v1beta2.DaemonSet

func NewLogAggregatorDaemonset

func NewLogAggregatorDaemonset(name, namespace, driverDir string) *v1beta2.DaemonSet

func UnsetSecret

func UnsetSecret(secrets rv1.SecretInterface, name, prefix string) error

func UpdateConfig

func UpdateConfig(configPath, name, level string, secrets rv1.SecretInterface) error

func UpdateSSLAuthentication

func UpdateSSLAuthentication(prefix string, esConfig *v3.ElasticsearchConfig, spConfig *v3.SplunkConfig, kfConfig *v3.KafkaConfig, syslogConfig *v3.SyslogConfig, fluentForwarder *v3.FluentForwarderConfig, secrets rv1.SecretInterface) error

Types

type FluentServer

type FluentServer struct {
	Host string
	Port string
	v3.FluentServer
}

type WrapClusterLogging

type WrapClusterLogging struct {
	v3.ClusterLoggingSpec
	WrapLogging
	ContainerLogSourceTag string
}

func ToWrapClusterLogging

func ToWrapClusterLogging(clusterLogging v3.ClusterLoggingSpec) (*WrapClusterLogging, error)

type WrapElasticsearch

type WrapElasticsearch struct {
	DateFormat string
	Host       string
	Scheme     string
}

type WrapFluentForwarder

type WrapFluentForwarder struct {
	EnableShareKey bool
	FluentServers  []FluentServer
}

type WrapKafka

type WrapKafka struct {
	Brokers   string
	Zookeeper string
}

type WrapLogging

type WrapLogging struct {
	CurrentTarget string
	WrapSyslog
	WrapSplunk
	WrapElasticsearch
	WrapKafka
	WrapFluentForwarder
}

func GetWrapConfig

func GetWrapConfig(es *v3.ElasticsearchConfig, sp *v3.SplunkConfig, sl *v3.SyslogConfig, kf *v3.KafkaConfig, ff *v3.FluentForwarderConfig) (wrapLogging WrapLogging, err error)

type WrapProjectLogging

type WrapProjectLogging struct {
	v3.ProjectLoggingSpec
	GrepNamespace string
	WrapLogging
	WrapProjectName       string
	ContainerLogSourceTag string
}

func ToWrapProjectLogging

func ToWrapProjectLogging(grepNamespace string, projectLogging v3.ProjectLoggingSpec) (*WrapProjectLogging, error)

type WrapSplunk

type WrapSplunk struct {
	Host   string
	Port   string
	Scheme string
}

type WrapSyslog

type WrapSyslog struct {
	Host string
	Port string
}