jsonfile

package
v2.3.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 29, 2026 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Decode 

func Decode(stdout, stderr io.Writer, r io.Reader, timestamps bool, since string, until string) ([]byte, error)

func Encode 

func Encode(stdout <-chan string, stderr <-chan string, writer io.Writer) error

func Path 

func Path(dataStore, ns, id string) string

Types

type Entry 

type Entry struct {
	Log    string    `json:"log,omitempty"`    // line, including "\r\n"
	Stream string    `json:"stream,omitempty"` // "stdout" or "stderr"
	Time   time.Time `json:"time"`             // e.g. "2020-12-11T20:29:41.939902251Z"
}

Entry is compatible with Docker "json-file" logs

type SyncEncoder added in v2.3.4 

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

SyncEncoder writes individual json-file log entries to a writer. Its Encode method is safe for concurrent use, so it can be shared between the goroutines reading a container's stdout and stderr.

func NewSyncEncoder added in v2.3.4 

func NewSyncEncoder(w io.Writer) *SyncEncoder

NewSyncEncoder returns a SyncEncoder that writes to w.

func (*SyncEncoder) Encode added in v2.3.4 

func (s *SyncEncoder) Encode(stream, line string) error

Encode writes a single log entry for the given stream.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.