internal

Documentation

Index

• func ParseRequest(req *http.Request) (*push.PushRequest, 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 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 but is unmarshalled to proto push format.

type Stream

type Stream push.Stream

Stream helps with unmarshalling of each log stream for push request.

func (*Stream) UnmarshalJSON

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