collector

Documentation

Index

• type Collector
  • func New(c *Config) *Collector
  • func (cr *Collector) Cleanup() error
  • func (cr *Collector) CollectPodLogs(pod string) ([]string, error)
  • func (cr *Collector) CollectServiceLogs(service string) ([]string, error)
  • func (cr *Collector) Start() error
  • func (cr *Collector) WithLocalOuput(dstDir string) error
  • func (cr *Collector) WithS3Output(keyId, keySecret, region, bucketName, bucketPrefix string) error
• type Config
• type Output

Types

type Collector

type Collector struct {
	Output Output
	// contains filtered or unexported fields
}

func New

func New(c *Config) *Collector

func (*Collector) Cleanup

func (cr *Collector) Cleanup() error

func (*Collector) CollectPodLogs

func (cr *Collector) CollectPodLogs(pod string) ([]string, error)

func (*Collector) CollectServiceLogs

func (cr *Collector) CollectServiceLogs(service string) ([]string, error)

func (*Collector) Start

func (cr *Collector) Start() error

func (*Collector) WithLocalOuput

func (cr *Collector) WithLocalOuput(dstDir string) error

func (*Collector) WithS3Output

func (cr *Collector) WithS3Output(keyId, keySecret, region, bucketName, bucketPrefix string) error

type Config

type Config struct {
	RemoteUser    string
	RemotePort    int32
	RemoteKeyFile string
	K8sClient     kubernetes.Interface
	Namespace     string
}

type Output

type Output interface {
	Put(io.ReadSeeker, string) (string, error)
}