job

package

v0.0.0-...-f49f4f7 Latest Latest Go to latest Published: Nov 24, 2025 License: MPL-2.0 Imports: 15 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type LogHandler struct {
	// contains filtered or unexported fields
}

func NewLogHandler(logger *zap.Logger, pipe io.ReadCloser, rpcClient *rpc.Client, req *LogHandlerReq) *LogHandler

func (l *LogHandler) Start(ctx context.Context)

type LogHandlerReq struct {
	Namespace string
	RunID     string
	StepID    string
	Type      string
}

type Runner struct {
	// contains filtered or unexported fields
}

func NewRunner(path string) (*Runner, error)

func (r *Runner) Run() error