forward

Documentation

Index

• Constants
• func EncodeRequestHeader(w io.Writer, h *RequestHeader) error
• func EncodeResponseHeader(w io.Writer, h *ResponseHeader) error
• func Pipe(log logs.Logger, c1, c2 io.ReadWriter)
• type RequestHeader
  • func DecodeRequestHeader(r io.Reader) (*RequestHeader, error)
• type ResponseHeader
  • func DecodeResponseHeader(r io.Reader) (*ResponseHeader, error)

Constants

const (
	// ProtocolVersion .
	ProtocolVersion = 1
	// HandshakeTimeout .
	HandshakeTimeout = 60 * time.Second
)

Functions

func EncodeRequestHeader

func EncodeRequestHeader(w io.Writer, h *RequestHeader) error

EncodeRequestHeader .

func EncodeResponseHeader

func EncodeResponseHeader(w io.Writer, h *ResponseHeader) error

EncodeResponseHeader .

func Pipe

func Pipe(log logs.Logger, c1, c2 io.ReadWriter)

Pipe .

Types

type RequestHeader

type RequestHeader struct {
	Version    uint32
	Name       string
	Token      string
	ShadowAddr string
}

RequestHeader .

func DecodeRequestHeader

func DecodeRequestHeader(r io.Reader) (*RequestHeader, error)

DecodeRequestHeader .

type ResponseHeader

type ResponseHeader struct {
	ShadowAddr string
	Error      string
	Values     map[string]interface{}
}

ResponseHeader .

func DecodeResponseHeader

func DecodeResponseHeader(r io.Reader) (*ResponseHeader, error)

DecodeResponseHeader .