protocol

Documentation

Index

• Constants
• Variables
• func ReadLine(reader *bufio.Reader) (string, error)
• func WriteLine(writer io.Writer, line string) error
• type Error
• type Header
• type MessageBase
  • func (message *MessageBase) Chunked() bool
  • func (message *MessageBase) DecodedBodyReader() (io.ReadCloser, error)
  • func (message *MessageBase) DecodedBodyWriter() io.WriteCloser
  • func (message *MessageBase) DeleteHeader(key string)
  • func (message *MessageBase) Header(key string) (string, bool)
  • func (message *MessageBase) ReadFrom(reader *bufio.Reader) error
  • func (message *MessageBase) SetChunked(value bool)
  • func (message *MessageBase) SetHeader(key, value string)
  • func (message *MessageBase) WriteTo(writer io.Writer) error
• type Pipe
  • func NewPipe() *Pipe
• type Request
  • func (request *Request) ReadFrom(conn net.Conn) error
  • func (request *Request) WriteTo(conn net.Conn) error
• type Response
  • func (response *Response) ReadFrom(conn net.Conn) error
  • func (response *Response) WriteTo(conn net.Conn) error

Constants

const (
	StatusOK = 200

	StatusBadRequest = 400
	StatusForbidden  = 403

	StatusNotImplemented = 501
	StatusBadGateway     = 502
)

const (
	EncodingGzip = "gzip"
	EncodingZlib = "zlib"
)

const MethodConnect = "CONNECT"

Variables

var StatusText = map[int]string{
	StatusOK: "OK",

	StatusBadRequest: "Bad Request",
	StatusForbidden:  "Forbidden",

	StatusNotImplemented: "Not implemented",
	StatusBadGateway:     "Bad Gateway",
}

Functions

func ReadLine

func ReadLine(reader *bufio.Reader) (string, error)

func WriteLine

func WriteLine(writer io.Writer, line string) error

Types

type Error

type Error struct {
	Status int
	Error  error
}

type Header

type Header struct {
	Key, Value string
}

type MessageBase

type MessageBase struct {
	Headers []Header
	Body    *Pipe
}

func (*MessageBase) Chunked

func (message *MessageBase) Chunked() bool

func (*MessageBase) DecodedBodyReader

func (message *MessageBase) DecodedBodyReader() (io.ReadCloser, error)

func (*MessageBase) DecodedBodyWriter

func (message *MessageBase) DecodedBodyWriter() io.WriteCloser

func (*MessageBase) DeleteHeader

func (message *MessageBase) DeleteHeader(key string)

func (*MessageBase) Header

func (message *MessageBase) Header(key string) (string, bool)

func (*MessageBase) ReadFrom

func (message *MessageBase) ReadFrom(reader *bufio.Reader) error

func (*MessageBase) SetChunked

func (message *MessageBase) SetChunked(value bool)

func (*MessageBase) SetHeader

func (message *MessageBase) SetHeader(key, value string)

func (*MessageBase) WriteTo

func (message *MessageBase) WriteTo(writer io.Writer) error

type Pipe

type Pipe struct {
	Reader *io.PipeReader
	Writer *io.PipeWriter
}

func NewPipe

func NewPipe() *Pipe

type Request

type Request struct {
	Method, Url, Protocol string
	MessageBase
}

func (*Request) ReadFrom

func (request *Request) ReadFrom(conn net.Conn) error

func (*Request) WriteTo

func (request *Request) WriteTo(conn net.Conn) error

type Response

type Response struct {
	Protocol string
	Code     int
	Reason   string
	MessageBase
}

func (*Response) ReadFrom

func (response *Response) ReadFrom(conn net.Conn) error

func (*Response) WriteTo

func (response *Response) WriteTo(conn net.Conn) error