logger

Documentation

Index

• type Config
• type LogAggregator
  • func NewLogAggregator(out io.Writer, cli *kubectl.CLI, imageNames []string, ...) *LogAggregator
  • func (a *LogAggregator) IsMuted() bool
  • func (a *LogAggregator) Mute()
  • func (a *LogAggregator) SetSince(t time.Time)
  • func (a *LogAggregator) Start(ctx context.Context, namespaces []string) error
  • func (a *LogAggregator) Stop()
  • func (a *LogAggregator) Unmute()

Types

type Config

type Config interface {
	PipelineForImage(imageName string) (latestV1.Pipeline, bool)
	DefaultPipeline() latestV1.Pipeline
}

type LogAggregator

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

LogAggregator aggregates the logs for all the deployed pods.

func NewLogAggregator

func NewLogAggregator(out io.Writer, cli *kubectl.CLI, imageNames []string, podSelector kubernetes.PodSelector, config Config) *LogAggregator

NewLogAggregator creates a new LogAggregator for a given output.

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) SetSince

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

func (*LogAggregator) Start

func (a *LogAggregator) Start(ctx context.Context, namespaces []string) 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.