logger

Documentation

Index

• type Config
• type Formatter
• type LogAggregator
  • func NewLogAggregator(cli *kubectl.CLI, podSelector kubernetes.PodSelector, namespaces *[]string, ...) *LogAggregator
  • func (a *LogAggregator) GetFormatter() Formatter
  • func (a *LogAggregator) IsMuted() bool
  • func (a *LogAggregator) Mute()
  • func (a *LogAggregator) RegisterArtifacts(artifacts []graph.Artifact)
  • func (a *LogAggregator) SetSince(t time.Time)
  • func (a *LogAggregator) Start(ctx context.Context, out io.Writer) error
  • func (a *LogAggregator) Stop()
  • func (a *LogAggregator) Unmute()
• type Logger
• type NoopLogger
  • func (*NoopLogger) GetFormatter() Formatter

Types

type Config

type Config interface {
	Tail() bool
	PipelineForImage(imageName string) (latest.Pipeline, bool)
	DefaultPipeline() latest.Pipeline
	JSONParseConfig() latest.JSONParseConfig
}

type Formatter

type Formatter func(pod v1.Pod, containerStatus v1.ContainerStatus, isMuted func() bool) log.Formatter

type LogAggregator

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

LogAggregator aggregates the logs for all the deployed pods.

func NewLogAggregator

func NewLogAggregator(cli *kubectl.CLI, podSelector kubernetes.PodSelector, namespaces *[]string, config Config) *LogAggregator

NewLogAggregator creates a new LogAggregator for a given output.

func (*LogAggregator) GetFormatter

func (a *LogAggregator) GetFormatter() Formatter

func (*LogAggregator) IsMuted

func (a *LogAggregator) IsMuted() bool

IsMuted says if the logs are to be muted.

func (*LogAggregator) Mute

func (a *LogAggregator) Mute()

Mute mutes the logs.

func (*LogAggregator) RegisterArtifacts

func (a *LogAggregator) RegisterArtifacts(artifacts []graph.Artifact)

RegisterArtifacts tracks the provided build artifacts in the colorpicker

func (*LogAggregator) SetSince

func (a *LogAggregator) SetSince(t time.Time)

func (*LogAggregator) Start

func (a *LogAggregator) Start(ctx context.Context, out io.Writer) error

Start starts a logger that listens to pods and tail their logs if they are matched by the `podSelector`.

func (*LogAggregator) Stop

func (a *LogAggregator) Stop()

Stop stops the logger.

func (*LogAggregator) Unmute

func (a *LogAggregator) Unmute()

Unmute unmutes the logs.

type Logger

type Logger interface {
	log.Logger
	GetFormatter() Formatter
}

type NoopLogger

type NoopLogger struct {
	*log.NoopLogger
}

NoopLogger is used in tests. It will never retrieve any logs from any resources.

func (*NoopLogger) GetFormatter

func (*NoopLogger) GetFormatter() Formatter