logger

Documentation

Index

• type Config
• type LogAggregator
  • func NewLogAggregator(cli *kubectl.CLI, podSelector kubernetes.PodSelector, config Config) *LogAggregator
  • func (a *LogAggregator) IsMuted() bool
  • func (a *LogAggregator) Mute()
  • func (a *LogAggregator) RegisterBuildArtifacts(artifacts []graph.Artifact)
  • func (a *LogAggregator) SetSince(t time.Time)
  • func (a *LogAggregator) StartLogger(ctx context.Context, out io.Writer, namespaces []string) error
  • func (a *LogAggregator) StopLogger()
  • 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(cli *kubectl.CLI, 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) RegisterBuildArtifacts

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

func (*LogAggregator) SetSince

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

func (*LogAggregator) StartLogger

func (a *LogAggregator) StartLogger(ctx context.Context, out io.Writer, namespaces []string) error

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

func (*LogAggregator) StopLogger

func (a *LogAggregator) StopLogger()

Stop stops the logger.

func (*LogAggregator) Unmute

func (a *LogAggregator) Unmute()

Unmute unmutes the logs.