utils

Documentation

Index

• func CreateEmbeddedTarget(dep rv1beta2.DeploymentInterface, sa rv1.ServiceAccountInterface, ...) error
• func CreateFluentd(ds rv1beta2.DaemonSetInterface, sa rv1.ServiceAccountInterface, ...) (err error)
• func GetClusterTarget(spec v3.ClusterLoggingSpec) string
• func InitConfigMap(cm rv1.ConfigMapInterface) error
• func IniteNamespace(ns rv1.NamespaceInterface) error
• func IsAllLoggingDisable(clusterLoggingLister v3.ClusterLoggingLister, ...) (bool, error)
• func NewESDeployment(namespace string) *v1beta2.Deployment
• func NewESService(namespace string) *v1.Service
• func NewKibanaDeployment(namespace string) *v1beta2.Deployment
• func NewKibanaService(namespace string) *v1.Service
• func RemoveConfigMap(configmaps rv1.ConfigMapInterface) error
• func RemoveEmbeddedTarget(dep rv1beta2.DeploymentInterface, sa rv1.ServiceAccountInterface, ...) error
• func RemoveFluentd(ds rv1beta2.DaemonSetInterface, sa rv1.ServiceAccountInterface, ...) error
• func UpdateConfigMap(configPath, loggingName, level string, configmaps rv1.ConfigMapInterface) error
• type WrapClusterLogging
  • func ToWrapClusterLogging(clusterLogging v3.ClusterLoggingSpec) (*WrapClusterLogging, error)
  • func (w *WrapClusterLogging) Validate() error
• type WrapElasticsearch
• type WrapEmbedded
• type WrapKafka
• type WrapProjectLogging
  • func ToWrapProjectLogging(grepNamespace string, projectLogging v3.ProjectLoggingSpec) (*WrapProjectLogging, error)
  • func (w *WrapProjectLogging) Validate() error
• type WrapSplunk
• type WrapSyslog

Functions

func CreateEmbeddedTarget

func CreateEmbeddedTarget(dep rv1beta2.DeploymentInterface, sa rv1.ServiceAccountInterface, se rv1.ServiceInterface, ro rrbacv1.RoleInterface, rb rrbacv1.RoleBindingInterface, namespace string) error

func CreateFluentd

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

func GetClusterTarget

func GetClusterTarget(spec v3.ClusterLoggingSpec) string

func InitConfigMap

func InitConfigMap(cm rv1.ConfigMapInterface) error

func IniteNamespace

func IniteNamespace(ns rv1.NamespaceInterface) error

func IsAllLoggingDisable

func IsAllLoggingDisable(clusterLoggingLister v3.ClusterLoggingLister, projectLoggingLister v3.ProjectLoggingLister) (bool, error)

func NewESDeployment

func NewESDeployment(namespace string) *v1beta2.Deployment

func NewESService

func NewESService(namespace string) *v1.Service

func NewKibanaDeployment

func NewKibanaDeployment(namespace string) *v1beta2.Deployment

func NewKibanaService

func NewKibanaService(namespace string) *v1.Service

func RemoveConfigMap

func RemoveConfigMap(configmaps rv1.ConfigMapInterface) error

func RemoveEmbeddedTarget

func RemoveEmbeddedTarget(dep rv1beta2.DeploymentInterface, sa rv1.ServiceAccountInterface, se rv1.ServiceInterface, ro rrbacv1.RoleInterface, rb rrbacv1.RoleBindingInterface) error

func RemoveFluentd

func RemoveFluentd(ds rv1beta2.DaemonSetInterface, sa rv1.ServiceAccountInterface, rb rrbacv1.ClusterRoleBindingInterface) error

func UpdateConfigMap

func UpdateConfigMap(configPath, loggingName, level string, configmaps rv1.ConfigMapInterface) error

Types

type WrapClusterLogging

type WrapClusterLogging struct {
	CurrentTarget string
	v3.ClusterLoggingSpec
	WrapSyslog
	WrapSplunk
	WrapEmbedded
	WrapElasticsearch
	WrapKafka
}

func ToWrapClusterLogging

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

func (*WrapClusterLogging) Validate

func (w *WrapClusterLogging) Validate() error

type WrapElasticsearch

type WrapElasticsearch struct {
	DateFormat string
	Host       string
	Scheme     string
}

type WrapEmbedded

type WrapEmbedded struct {
	DateFormat string
}

type WrapKafka

type WrapKafka struct {
	Brokers   string
	Zookeeper string
}

type WrapProjectLogging

type WrapProjectLogging struct {
	CurrentTarget string
	v3.ProjectLoggingSpec
	GrepNamespace string
	WrapSyslog
	WrapSplunk
	WrapElasticsearch
	WrapKafka
}

func ToWrapProjectLogging

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

func (*WrapProjectLogging) Validate

func (w *WrapProjectLogging) Validate() error

type WrapSplunk

type WrapSplunk struct {
	Server string
	Scheme string
}

type WrapSyslog

type WrapSyslog struct {
	Host string
	Port string
}