usp_k8s_pods

Documentation

Index

• type K8sEntity
• type K8sLogLine
• type K8sLogProcessor
  • func NewK8sLogProcessor(root string, cOpt uspclient.ClientOptions, rtOptions runtimeOptions) (*K8sLogProcessor, error)
  • func (klp *K8sLogProcessor) Close() error
  • func (klp *K8sLogProcessor) Lines() chan K8sLogLine
• type K8sPodsAdapter
  • func NewK8sPodsAdapter(conf K8sPodsConfig) (*K8sPodsAdapter, chan struct{}, error)
  • func (a *K8sPodsAdapter) Close() error
• type K8sPodsConfig
  • func (c *K8sPodsConfig) Validate() error

Types

type K8sEntity

type K8sEntity struct {
	Namespace     string `json:"namespace" msgpack:"namespace"`
	PodName       string `json:"pod_name" msgpack:"pod_name"`
	PodID         string `json:"pod_id" msgpack:"pod_id"`
	ContainerName string `json:"container_name" msgpack:"container_name"`
}

type K8sLogLine

type K8sLogLine struct {
	Entity K8sEntity `json:"entity" msgpack:"entity"`
	Line   string    `json:"line" msgpack:"line"`
}

type K8sLogProcessor

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

func NewK8sLogProcessor

func NewK8sLogProcessor(root string, cOpt uspclient.ClientOptions, rtOptions runtimeOptions) (*K8sLogProcessor, error)

func (*K8sLogProcessor) Close

func (klp *K8sLogProcessor) Close() error

func (*K8sLogProcessor) Lines

func (klp *K8sLogProcessor) Lines() chan K8sLogLine

type K8sPodsAdapter

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

func NewK8sPodsAdapter

func NewK8sPodsAdapter(conf K8sPodsConfig) (*K8sPodsAdapter, chan struct{}, error)

func (*K8sPodsAdapter) Close

func (a *K8sPodsAdapter) Close() error

type K8sPodsConfig

type K8sPodsConfig struct {
	ClientOptions   uspclient.ClientOptions `json:"client_options" yaml:"client_options"`
	WriteTimeoutSec uint64                  `json:"write_timeout_sec,omitempty" yaml:"write_timeout_sec,omitempty"`
	Root            string                  `json:"root" yaml:"root"`
	IncludePodsRE   string                  `json:"include_pods_re" yaml:"include_pods_re"`
	ExcludePodsRE   string                  `json:"exclude_pods_re" yaml:"exclude_pods_re"`
}

func (*K8sPodsConfig) Validate

func (c *K8sPodsConfig) Validate() error