unmarshal

Documentation

Index

• func DecodePushRequest(b io.Reader, r *logproto.PushRequest) error
• 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 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.