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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type LogLine ¶
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 ¶ added in v2.1.98
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
Source Files