cwlog

Documentation

Index

• Constants
• type Unmarshaler
  • func NewUnmarshaler(logger *zap.Logger) *Unmarshaler
  • func (u Unmarshaler) Type() string
  • func (u Unmarshaler) Unmarshal(records [][]byte) (plog.Logs, error)

Constants

const (
	TypeStr = "cwlogs"
)

Types

type Unmarshaler

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

Unmarshaler for the CloudWatch Log JSON record format.

func NewUnmarshaler

func NewUnmarshaler(logger *zap.Logger) *Unmarshaler

NewUnmarshaler creates a new instance of the Unmarshaler.

func (Unmarshaler) Type

func (u Unmarshaler) Type() string

Type of the serialized messages.

func (Unmarshaler) Unmarshal

func (u Unmarshaler) Unmarshal(records [][]byte) (plog.Logs, error)

Unmarshal deserializes the records into cWLogs and uses the resourceLogsBuilder to group them into a single plog.Logs. Skips invalid cWLogs received in the record and