logs

Documentation

Index

• func NewBucketProviderFromTeamSettingsConfiguration(jxClient versioned.Interface, ns string) (buckets.Provider, error)
• type LogLine
• type TektonLogger
  • func (t *TektonLogger) Err() error
  • func (t *TektonLogger) GetRunningBuildLogs(pa *v1.PipelineActivity, buildName string, noWaitForRuns bool) <-chan LogLine
  • func (t TektonLogger) GetTektonPipelinesWithActivePipelineActivity(filters []string) ([]string, map[string]*v1.PipelineActivity, error)
  • func (t *TektonLogger) StreamPipelinePersistentLogs(logsURL string, authSvc auth.ConfigService) <-chan LogLine

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