logger

Documentation

Index

• Constants
• func NewStatusBackoff() *wait.Backoff
• type AtomicBool
  • func (b *AtomicBool) Get() bool
  • func (b *AtomicBool) Set(value bool)
• type Logger
  • func NewLogger(ctx context.Context, tracker *tracker.JobTracker, ...) *Logger
  • func (l *Logger) CancelJobLogger(jobID string)
  • func (l *Logger) IsMuted() bool
  • func (l *Logger) Mute()
  • func (l *Logger) RegisterArtifacts(artifacts []graph.Artifact)
  • func (l *Logger) RegisterJob(id string)
  • func (l *Logger) SetSince(time.Time)
  • func (l *Logger) Start(ctx context.Context, out io.Writer) error
  • func (l *Logger) Stop()
  • func (l *Logger) Unmute()

Constants

const (

	// RetryDelay is the time to wait in between polling the status of the cloud build
	RetryDelay = 1 * time.Second

	// BackoffFactor is the exponent for exponential backoff during build status polling
	BackoffFactor = 1.5

	// BackoffSteps is the number of times we increase the backoff time during exponential backoff
	BackoffSteps = 10

	// RetryTimeout is the max amount of time to retry getting the status of the build before erroring
	RetryTimeout = 3 * time.Minute
)

Functions

func NewStatusBackoff

func NewStatusBackoff() *wait.Backoff

Types

type AtomicBool

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

func (*AtomicBool) Get

func (b *AtomicBool) Get() bool

func (*AtomicBool) Set

func (b *AtomicBool) Set(value bool)

type Logger

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

func NewLogger

func NewLogger(ctx context.Context, tracker *tracker.JobTracker, labeller *label.DefaultLabeller, kubeContext string) *Logger

func (*Logger) CancelJobLogger

func (l *Logger) CancelJobLogger(jobID string)

func (*Logger) IsMuted

func (l *Logger) IsMuted() bool

func (*Logger) Mute

func (l *Logger) Mute()

Mute mutes the logs.

func (*Logger) RegisterArtifacts

func (l *Logger) RegisterArtifacts(artifacts []graph.Artifact)

func (*Logger) RegisterJob

func (l *Logger) RegisterJob(id string)

func (*Logger) SetSince

func (l *Logger) SetSince(time.Time)

func (*Logger) Start

func (l *Logger) Start(ctx context.Context, out io.Writer) error

func (*Logger) Stop

func (l *Logger) Stop()

func (*Logger) Unmute

func (l *Logger) Unmute()

Unmute unmutes the logs.