logs

package
v2.0.400-0...-14731b4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 21, 2021 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewBucketProviderFromTeamSettingsConfiguration

func NewBucketProviderFromTeamSettingsConfiguration(jxClient versioned.Interface, ns string) (buckets.Provider, error)

Types

type LogLine

type LogLine struct {
	Line       string
	ShouldMask bool
}

LogLine is the object sent to and received from the channels in the StreamLog and WriteLog functions defined by LogWriter

type TektonLogger

type TektonLogger struct {
	JXClient          versioned.Interface
	TektonClient      tektonclient.Interface
	KubeClient        kubernetes.Interface
	Namespace         string
	BytesLimit        int64
	FailIfPodFails    bool
	LogsRetrieverFunc retrieverFunc
	// contains filtered or unexported fields
}

TektonLogger contains the necessary clients and the namespace to get data from the cluster, an implementation of LogWriter to write logs to and a logs retriever function to override the default way to obtain logs

func (*TektonLogger) Err

func (t *TektonLogger) Err() error

Err returns the last error that occurred during streaming logs. It should be checked after the log stream channel has been closed.

func (*TektonLogger) GetRunningBuildLogs

func (t *TektonLogger) GetRunningBuildLogs(pa *v1.PipelineActivity, buildName string, noWaitForRuns bool) <-chan LogLine

GetRunningBuildLogs obtains the logs of the provided PipelineActivity and streams the running build pods' logs using the provided LogWriter

func (TektonLogger) GetTektonPipelinesWithActivePipelineActivity

func (t TektonLogger) GetTektonPipelinesWithActivePipelineActivity(filters []string) ([]string, map[string]*v1.PipelineActivity, error)

GetTektonPipelinesWithActivePipelineActivity returns list of all PipelineActivities with corresponding Tekton PipelineRuns ordered by the PipelineRun creation timestamp and a map to obtain its reference once a name has been selected

func (*TektonLogger) StreamPipelinePersistentLogs

func (t *TektonLogger) StreamPipelinePersistentLogs(logsURL string, authSvc auth.ConfigService) <-chan LogLine

StreamPipelinePersistentLogs reads logs from the provided bucket URL and writes them using the provided LogWriter

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL