Documentation
¶
Index ¶
- Constants
- type FilesystemOSS
- type OSS
- type Reader
- type S3
- type Service
- func (s *Service) Append(ctx context.Context, jobExecutionID int64, logName string, ...) error
- func (s *Service) Archive(ctx context.Context, jobExecutionID int64) error
- func (s *Service) GetLogLines(ctx context.Context, jobExecutionID int64, logName string, start int64, ...) ([]*api.LogLine, error)
Constants ¶
View Source
const ErrNotFound = util.StringError("not found")
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FilesystemOSS ¶
type FilesystemOSS struct {
// contains filtered or unexported fields
}
func NewFilesystemOSS ¶
func NewFilesystemOSS(baseDir string) *FilesystemOSS
func (*FilesystemOSS) Open ¶
func (o *FilesystemOSS) Open(ctx context.Context, filename string) (io.ReadCloser, error)
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
func (*Service) Append ¶
func (s *Service) Append(ctx context.Context, jobExecutionID int64, logName string, lines []*api.LogLine, ) error
Append appends log lines to the log storage. logName is the name of the log. For step, it is the name of the step. But there are some special log names, and generated by the system. These special log names typically start with _ and mainly for system logs.
func (*Service) Archive ¶
Archive archives logs to S3. It should be invoked when there are no more logs to be appended. Typically, it is invoked after the job is finished.
func (*Service) GetLogLines ¶
func (s *Service) GetLogLines(ctx context.Context, jobExecutionID int64, logName string, start int64, limit int64, ) ([]*api.LogLine, error)
GetLogLines returns the log lines for a job execution. start is the start index of the log lines. It is 0-based. limit is the maximum number of log lines to return.
Source Files
Click to show internal directories.
Click to hide internal directories.