service

Documentation

Index

• func ContainerLogStream(ctx context.Context, streamChan chan interface{}, ...)
• func GetBuildJobContainerLogs(pipelineName, serviceName string, taskID int64, log *zap.SugaredLogger) (string, error)
• func GetCurrentContainerLogs(podName, containerName, envName, productName string, tailLines int64, ...) (string, error)
• func GetScanningContainerLogs(scanID string, taskID int64, log *zap.SugaredLogger) (string, error)
• func GetTestJobContainerLogs(pipelineName, serviceName string, taskID int64, log *zap.SugaredLogger) (string, error)
• func GetTestingContainerLogs(testName string, taskID int64, log *zap.SugaredLogger) (string, error)
• func GetWorkflowBuildJobContainerLogs(pipelineName, serviceName, buildType string, taskID int64, ...) (string, error)
• func GetWorkflowBuildV3JobContainerLogs(workflowName, buildType string, taskID int64, log *zap.SugaredLogger) (string, error)
• func GetWorkflowTestJobContainerLogs(pipelineName, serviceName, pipelineType string, taskID int64, ...) (string, error)
• func GetWorkflowV4JobContainerLogs(workflowName, jobName string, taskID int64, log *zap.SugaredLogger) (string, error)
• func JenkinsJobLogStream(ctx context.Context, jenkinsID, jobName string, jobID int64, ...)
• func ReadFromFileAndWriteToStreamChan(buf *bufio.Reader, streamChan chan interface{}) error
• func TaskContainerLogStream(ctx context.Context, streamChan chan interface{}, options *GetContainerOptions, ...)
• func TestJobContainerLogStream(ctx context.Context, streamChan chan interface{}, options *GetContainerOptions, ...)
• func WorkflowTaskV4ContainerLogStream(ctx context.Context, streamChan chan interface{}, options *GetContainerOptions, ...)
• type GetContainerOptions
• type GetVMJobLogOptions

Functions

func ContainerLogStream

func ContainerLogStream(ctx context.Context, streamChan chan interface{}, envName, productName, podName, containerName string, follow bool, tailLines int64, log *zap.SugaredLogger)

func GetBuildJobContainerLogs

func GetBuildJobContainerLogs(pipelineName, serviceName string, taskID int64, log *zap.SugaredLogger) (string, error)

func GetCurrentContainerLogs

func GetCurrentContainerLogs(podName, containerName, envName, productName string, tailLines int64, log *zap.SugaredLogger) (string, error)

func GetScanningContainerLogs

func GetScanningContainerLogs(scanID string, taskID int64, log *zap.SugaredLogger) (string, error)

func GetTestJobContainerLogs

func GetTestJobContainerLogs(pipelineName, serviceName string, taskID int64, log *zap.SugaredLogger) (string, error)

func GetTestingContainerLogs

func GetTestingContainerLogs(testName string, taskID int64, log *zap.SugaredLogger) (string, error)

func GetWorkflowBuildJobContainerLogs

func GetWorkflowBuildJobContainerLogs(pipelineName, serviceName, buildType string, taskID int64, log *zap.SugaredLogger) (string, error)

func GetWorkflowBuildV3JobContainerLogs

func GetWorkflowBuildV3JobContainerLogs(workflowName, buildType string, taskID int64, log *zap.SugaredLogger) (string, error)

func GetWorkflowTestJobContainerLogs

func GetWorkflowTestJobContainerLogs(pipelineName, serviceName, pipelineType string, taskID int64, log *zap.SugaredLogger) (string, error)

func GetWorkflowV4JobContainerLogs

func GetWorkflowV4JobContainerLogs(workflowName, jobName string, taskID int64, log *zap.SugaredLogger) (string, error)

func JenkinsJobLogStream

func JenkinsJobLogStream(ctx context.Context, jenkinsID, jobName string, jobID int64, streamChan chan interface{})

func ReadFromFileAndWriteToStreamChan

func ReadFromFileAndWriteToStreamChan(buf *bufio.Reader, streamChan chan interface{}) error

func TaskContainerLogStream

func TaskContainerLogStream(ctx context.Context, streamChan chan interface{}, options *GetContainerOptions, log *zap.SugaredLogger)

func TestJobContainerLogStream

func TestJobContainerLogStream(ctx context.Context, streamChan chan interface{}, options *GetContainerOptions, log *zap.SugaredLogger)

func WorkflowTaskV4ContainerLogStream

func WorkflowTaskV4ContainerLogStream(ctx context.Context, streamChan chan interface{}, options *GetContainerOptions, log *zap.SugaredLogger)

Types

type GetContainerOptions

type GetContainerOptions struct {
	Namespace     string
	PipelineName  string
	SubTask       string
	JobName       string
	JobType       string
	TailLines     int64
	TaskID        int64
	PipelineType  string
	ServiceName   string
	ServiceModule string
	TestName      string
	EnvName       string
	ProductName   string
	ClusterID     string
}

type GetVMJobLogOptions

type GetVMJobLogOptions struct {
	Infrastructure string
	ProjectKey     string
	WorkflowKey    string
	TaskID         int64
	JobName        string
}