internal

Documentation

Index

• func ParseRequest(req *http.Request) (*push.PushRequest, error)
• type Entry
  • func (e *Entry) UnmarshalJSON(data []byte) error
• type LabelSet
  • func (l LabelSet) String() string
  • func (l *LabelSet) UnmarshalJSON(data []byte) error
• type PushRequest
• type Stream
  • func (s *Stream) UnmarshalJSON(data []byte) error

Functions

func ParseRequest

func ParseRequest(req *http.Request) (*push.PushRequest, error)

Types

type Entry

type Entry struct {
	Timestamp time.Time
	Line      string
}

Entry represents a log entry. It includes a log message and the time it occurred at.

func (*Entry) UnmarshalJSON

func (e *Entry) UnmarshalJSON(data []byte) error

type LabelSet

type LabelSet map[string]string

LabelSet is a key/value pair mapping of labels

func (LabelSet) String

func (l LabelSet) String() string

String implements the Stringer interface. It returns a formatted/sorted set of label key/value pairs.

func (*LabelSet) UnmarshalJSON

func (l *LabelSet) UnmarshalJSON(data []byte) error

type PushRequest

type PushRequest struct {
	Streams []*Stream `json:"streams"`
}

PushRequest models a log stream push

type Stream

type Stream struct {
	Labels  LabelSet `json:"stream"`
	Entries []Entry  `json:"values"`
}

Stream represents a log stream. It includes a set of log entries and their labels.

func (*Stream) UnmarshalJSON

func (s *Stream) UnmarshalJSON(data []byte) error