logging

package

v0.0.0-...-0765232 Latest Latest Go to latest Published: Oct 31, 2024 License: MIT Imports: 14 Imported by: 0

Details

View Source

const (
	ErrUnexpectedFormat = errors.ConstError("unexpected format")

	HeaderFormat = "Fmt"
	HeaderLogFmt = "LogFmt"
	HeaderTerm   = "Term"
)

View Source

const (
	RecordTerm   = iota
	RecordLogFmt = 1
)

This section is empty.

func SetAgentsByNKey(ctx context.Context, byName AgentIndex) context.Context

func SetAgentsByName(ctx context.Context, byName AgentIndex) context.Context

func UnmarshalLogFmtRecord(ctx context.Context, msg *nats.Msg, record *LogFmtRecord) (err error)

func UnmarshalTerminalRecord(ctx context.Context, msg *nats.Msg, record *TerminalRecord) (err error)

type AgentIndex = map[string]*info.Response

func GetAgentsByNKey(ctx context.Context) AgentIndex

func GetAgentsByName(ctx context.Context) AgentIndex

type LogFmtRecord struct {
	Level log.Level
	Text  string
	Meta  map[string]string

	Timestamp time.Time
	// contains filtered or unexported fields
}

func (r *LogFmtRecord) Msg() *nats.Msg

func (r *LogFmtRecord) Type() RecordType

func (r *LogFmtRecord) Write(file *os.File) (n int, err error)

type Record interface {
	Type() RecordType
	Msg() *nats.Msg
	Write(file *os.File) (n int, err error)
}

type RecordReader struct {
	Sub     *nats.Subscription
	Context context.Context
}

func (r *RecordReader) Read() (record Record, err error)

type RecordType int

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

func (t *TerminalRecord) Msg() *nats.Msg

func (t *TerminalRecord) Type() RecordType

func (t *TerminalRecord) Write(file *os.File) (n int, err error)