unmarshal

Documentation

Index

• func DecodePushRequest(b io.Reader, r *logproto.PushRequest) error
• func NewPushRequest(r loghttp.PushRequest) logproto.PushRequest
• func NewStream(s *loghttp.Stream) logproto.Stream
• func ReadTailResponseJSON(r *loghttp.TailResponse, reader WebsocketReader) error
• type WebsocketReader

Functions

func DecodePushRequest

func DecodePushRequest(b io.Reader, r *logproto.PushRequest) error

DecodePushRequest directly decodes json to a logproto.PushRequest

func NewPushRequest

func NewPushRequest(r loghttp.PushRequest) logproto.PushRequest

NewPushRequest constructs a logproto.PushRequest from a PushRequest

func NewStream

func NewStream(s *loghttp.Stream) logproto.Stream

NewStream constructs a logproto.Stream from a Stream

func ReadTailResponseJSON

func ReadTailResponseJSON(r *loghttp.TailResponse, reader WebsocketReader) error

ReadTailResponseJSON unmarshals the loghttp.TailResponse from a websocket reader.

Types

type WebsocketReader

type WebsocketReader interface {
	ReadMessage() (int, []byte, error)
}

WebsocketReader knows how to read message to a websocket connection.