record

Documentation

Index

• type ArrayDecoder
  • func NewArrayDecoder(log logger.Logger) *ArrayDecoder
  • func (d *ArrayDecoder) FromByteArray(raw []byte) (LogRecords, error)
  • func (d *ArrayDecoder) FromReader(reader io.Reader) (LogRecords, error)
  • func (d *ArrayDecoder) FromString(raw string) (LogRecords, error)
• type Decoder
  • func NewDecoder(log logger.Logger) *Decoder
  • func (d *Decoder) FromByteArray(raw []byte) (*LogRecord, error)
  • func (d *Decoder) FromReader(reader io.Reader) (*LogRecord, error)
  • func (d *Decoder) FromString(raw string) (*LogRecord, error)
• type LogRecord
• type LogRecords

Types

type ArrayDecoder

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

func NewArrayDecoder

func NewArrayDecoder(log logger.Logger) *ArrayDecoder

func (*ArrayDecoder) FromByteArray

func (d *ArrayDecoder) FromByteArray(raw []byte) (LogRecords, error)

func (*ArrayDecoder) FromReader

func (d *ArrayDecoder) FromReader(reader io.Reader) (LogRecords, error)

func (*ArrayDecoder) FromString

func (d *ArrayDecoder) FromString(raw string) (LogRecords, error)

type Decoder

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

func NewDecoder

func NewDecoder(log logger.Logger) *Decoder

func (*Decoder) FromByteArray

func (d *Decoder) FromByteArray(raw []byte) (*LogRecord, error)

func (*Decoder) FromReader

func (d *Decoder) FromReader(reader io.Reader) (*LogRecord, error)

func (*Decoder) FromString

func (d *Decoder) FromString(raw string) (*LogRecord, error)

type LogRecord

type LogRecord struct {
	Stream     string `json:"stream"`
	Time       string `json:"time"`
	Log        string `json:"log"`
	Kubernetes struct {
		Namespace     string            `json:"namespace_name"`
		PodName       string            `json:"pod_name"`
		ContainerName string            `json:"container_name"`
		Host          string            `json:"host"`
		Labels        map[string]string `json:"labels"`
	} `json:"kubernetes"`
}

type LogRecords

type LogRecords []LogRecord