output

type CacheEntry struct {
	Content   *OutputContent
	Timestamp time.Time
	TTL       time.Duration
}

type CacheStats struct {
	Entries   int
	Hits      int64
	Misses    int64
	Evictions int64
	HitRate   float64
	MaxSize   int
}

type FileMetadata struct {
	Path        string
	Size        int64
	ModTime     time.Time
	Exists      bool
	IsLocal     bool
	NodeID      string
	Permissions os.FileMode
	Encoding    string
}

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

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

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

type OutputContent struct {
	Content     string
	Metadata    *FileMetadata
	Truncated   bool
	TruncatedAt int64
	LinesRead   int
	BytesRead   int64
	Source      string // "local" or "remote:node042"
}

type PathResolver interface {
	ResolveOutputPath(jobID, outputType string) (path string, isRemote bool, nodeID string, err error)
}

type ReadOptions struct {
	MaxBytes     int64         // Maximum bytes to read (0 = unlimited)
	MaxLines     int           // Maximum lines to read (0 = unlimited)
	TailMode     bool          // Read from end instead of beginning
	Offset       int64         // Byte offset to start reading
	Timeout      time.Duration // Timeout for remote operations
	CacheEnabled bool          // Enable local caching
	ForceRefresh bool          // Bypass cache
}

type Reader interface {
	// ReadJobOutput reads complete job output
	ReadJobOutput(ctx context.Context, jobID, outputType string) (*OutputContent, error)

	// ReadPartial reads output with options
	ReadPartial(ctx context.Context, jobID, outputType string, opts ReadOptions) (*OutputContent, error)

	// GetMetadata returns file metadata without reading content
	GetMetadata(ctx context.Context, jobID, outputType string) (*FileMetadata, error)
}

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

type SSHExecutor interface {
	ExecuteCommand(ctx context.Context, hostname, command string) (string, error)
}