loggers

package

v0.1.15 Latest Latest Go to latest Published: Feb 14, 2025 License: GPL-3.0 Imports: 17 Imported by: 0

Details

This section is empty.

View Source

var AddJobLogsPipeline *goPipeline.Pipeline[string, JobLog]

func Get(parameters map[string]interface{}) (jobs.Logger, error)

func GetJobLogsWriter(jobId, organizationId string, logger jobs.Logger, mode runner_enums.Mode) (*io.PipeWriter, error)

func Init()

func LogBuffer(logBuffer *bytes.Buffer, logger jobs.Logger) error

func Shutdown()

type JobLog struct {
	Logger         jobs.Logger
	Message        string
	ErrorMessage   string
	Ts             int64
	OrganizationID string
}

Path	Synopsis
cloudwatch