execlogwrap

package

v0.9.1 Latest Latest Go to latest Published: Aug 14, 2025 License: Apache-2.0 Imports: 10 Imported by: 0

Details

View Source

const ConnPollTime = 1 * time.Second

This section is empty.

func ExecCommand(args []string, appRunId string, cfg *config.Config, extraEnv map[string]string) error

ExecCommand executes a command with the provided arguments cfg cannot be nil

func ProcessExistingStreams(streams []TeeStreamDecl, appRunId string, cfg *config.Config) error

ProcessExistingStreams handles capturing logs from provided input/output streams cfg cannot be nil

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

LogDataWrap encapsulates a connection with its lock and related functionality

type TeeStreamDecl struct {
	Input  io.Reader
	Output io.Writer
	Source string
}

TeeStreamDecl defines a stream to be processed with TeeCopy