service

README

service transformers

专门存放业务相关的特定Transformers

Documentation

Index

• Constants
• type K8sTag
  • func (g *K8sTag) ConfigOptions() []Option
  • func (g *K8sTag) Description() string
  • func (g *K8sTag) RawTransform(datas []string) ([]string, error)
  • func (g *K8sTag) SampleConfig() string
  • func (g *K8sTag) Stage() string
  • func (g *K8sTag) Stats() StatsInfo
  • func (g *K8sTag) Transform(datas []Data) ([]Data, error)
  • func (g *K8sTag) Type() string

Constants

const (
	K8sTagType       = "k8stag"
	K8sPodName       = "k8s_pod_name"
	K8sNamespace     = "k8s_namespace"
	K8sContainerName = "k8s_container_name"
	K8sContainerId   = "k8s_container_id"
)

Types

type K8sTag

type K8sTag struct {
	SourceFileKey string `json:"sourcefilefield"`
	// contains filtered or unexported fields
}

func (*K8sTag) ConfigOptions

func (g *K8sTag) ConfigOptions() []Option

func (*K8sTag) Description

func (g *K8sTag) Description() string

func (*K8sTag) RawTransform

func (g *K8sTag) RawTransform(datas []string) ([]string, error)

func (*K8sTag) SampleConfig

func (g *K8sTag) SampleConfig() string

func (*K8sTag) Stage

func (g *K8sTag) Stage() string

func (*K8sTag) Stats

func (g *K8sTag) Stats() StatsInfo

func (*K8sTag) Transform

func (g *K8sTag) Transform(datas []Data) ([]Data, error)

func (*K8sTag) Type

func (g *K8sTag) Type() string