unmarshal

package
Version: v2.1.1-0...-c609277 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 30, 2021 License: AGPL-3.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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.

Source Files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL