http

package
v4.15.0+incompatible Latest Latest
Warning

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

 Go to latest Published: Feb 7, 2019 License: MIT Imports: 14 Imported by: 0

Documentation ¶

Index ¶

Constants ¶

View Source 
const (
	// CRLF is the line ending in HTTP header
	CRLF = "\r\n"

	// ENDING is the double line ending between HTTP header and body.
	ENDING = CRLF + CRLF
)

Variables ¶

View Source 
var (
	ErrHeaderToLong = newError("Header too long.")
)

Functions ¶

This section is empty.

Types ¶

type Config ¶ 

type Config struct {
	// Settings for authenticating requests. If not set, client side will not send authenication header, and server side will bypass authentication.
	Request *RequestConfig `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	// Settings for authenticating responses. If not set, client side will bypass authentication, and server side will not send authentication header.
	Response             *ResponseConfig `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*Config) Descriptor ¶ 

func (*Config) Descriptor() ([]byte, []int)

func (*Config) GetRequest ¶ 

func (m *Config) GetRequest() *RequestConfig

func (*Config) GetResponse ¶ 

func (m *Config) GetResponse() *ResponseConfig

func (*Config) ProtoMessage ¶ 

func (*Config) ProtoMessage()

func (*Config) Reset ¶ 

func (m *Config) Reset()

func (*Config) String ¶ 

func (m *Config) String() string

func (*Config) XXX_DiscardUnknown ¶ 

func (m *Config) XXX_DiscardUnknown()

func (*Config) XXX_Marshal ¶ 

func (m *Config) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Config) XXX_Merge ¶ 

func (m *Config) XXX_Merge(src proto.Message)

func (*Config) XXX_Size ¶ 

func (m *Config) XXX_Size() int

func (*Config) XXX_Unmarshal ¶ 

func (m *Config) XXX_Unmarshal(b []byte) error
type Header struct {
	// "Accept", "Cookie", etc
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Each entry must be valid in one piece. Random entry will be chosen if multiple entries present.
	Value                []string `protobuf:"bytes,2,rep,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Header) Descriptor ¶ 

func (*Header) Descriptor() ([]byte, []int)

func (*Header) GetName ¶ 

func (m *Header) GetName() string

func (*Header) GetValue ¶ 

func (m *Header) GetValue() []string

func (*Header) ProtoMessage ¶ 

func (*Header) ProtoMessage()

func (*Header) Reset ¶ 

func (m *Header) Reset()

func (*Header) String ¶ 

func (m *Header) String() string

func (*Header) XXX_DiscardUnknown ¶ 

func (m *Header) XXX_DiscardUnknown()

func (*Header) XXX_Marshal ¶ 

func (m *Header) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Header) XXX_Merge ¶ 

func (m *Header) XXX_Merge(src proto.Message)

func (*Header) XXX_Size ¶ 

func (m *Header) XXX_Size() int

func (*Header) XXX_Unmarshal ¶ 

func (m *Header) XXX_Unmarshal(b []byte) error

type HeaderReader ¶ 

type HeaderReader struct {
}

func (*HeaderReader) Read ¶ 

func (*HeaderReader) Read(reader io.Reader) (*buf.Buffer, error)

type HeaderWriter ¶ 

type HeaderWriter struct {
	// contains filtered or unexported fields
}

func NewHeaderWriter ¶ 

func NewHeaderWriter(header *buf.Buffer) *HeaderWriter

func (*HeaderWriter) Write ¶ 

func (w *HeaderWriter) Write(writer io.Writer) error

type HttpAuthenticator ¶ 

type HttpAuthenticator struct {
	// contains filtered or unexported fields
}

func NewHttpAuthenticator ¶ 

func NewHttpAuthenticator(ctx context.Context, config *Config) (HttpAuthenticator, error)

func (HttpAuthenticator) Client ¶ 

func (a HttpAuthenticator) Client(conn net.Conn) net.Conn

func (HttpAuthenticator) GetClientWriter ¶ 

func (a HttpAuthenticator) GetClientWriter() *HeaderWriter

func (HttpAuthenticator) GetServerWriter ¶ 

func (a HttpAuthenticator) GetServerWriter() *HeaderWriter

func (HttpAuthenticator) Server ¶ 

func (a HttpAuthenticator) Server(conn net.Conn) net.Conn

type HttpConn ¶ 

type HttpConn struct {
	net.Conn
	// contains filtered or unexported fields
}

func NewHttpConn ¶ 

func NewHttpConn(conn net.Conn, reader Reader, writer Writer, errorWriter Writer) *HttpConn

func (*HttpConn) Close ¶ 

func (c *HttpConn) Close() error

Close implements net.Conn.Close().

func (*HttpConn) Read ¶ 

func (c *HttpConn) Read(b []byte) (int, error)

func (*HttpConn) Write ¶ 

func (c *HttpConn) Write(b []byte) (int, error)

Write implements io.Writer.

type Method ¶ 

type Method struct {
	Value                string   `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

HTTP method. Default value "GET".

func (*Method) Descriptor ¶ 

func (*Method) Descriptor() ([]byte, []int)

func (*Method) GetValue ¶ 

func (m *Method) GetValue() string

func (*Method) ProtoMessage ¶ 

func (*Method) ProtoMessage()

func (*Method) Reset ¶ 

func (m *Method) Reset()

func (*Method) String ¶ 

func (m *Method) String() string

func (*Method) XXX_DiscardUnknown ¶ 

func (m *Method) XXX_DiscardUnknown()

func (*Method) XXX_Marshal ¶ 

func (m *Method) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Method) XXX_Merge ¶ 

func (m *Method) XXX_Merge(src proto.Message)

func (*Method) XXX_Size ¶ 

func (m *Method) XXX_Size() int

func (*Method) XXX_Unmarshal ¶ 

func (m *Method) XXX_Unmarshal(b []byte) error

type NoOpReader ¶ 

type NoOpReader struct{}

func (NoOpReader) Read ¶ 

func (NoOpReader) Read(io.Reader) (*buf.Buffer, error)

type NoOpWriter ¶ 

type NoOpWriter struct{}

func (NoOpWriter) Write ¶ 

func (NoOpWriter) Write(io.Writer) error

type Reader ¶ 

type Reader interface {
	Read(io.Reader) (*buf.Buffer, error)
}

type RequestConfig ¶ 

type RequestConfig struct {
	// Full HTTP version like "1.1".
	Version *Version `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// GET, POST, CONNECT etc
	Method *Method `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	// URI like "/login.php"
	Uri                  []string  `protobuf:"bytes,3,rep,name=uri,proto3" json:"uri,omitempty"`
	Header               []*Header `protobuf:"bytes,4,rep,name=header,proto3" json:"header,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*RequestConfig) Descriptor ¶ 

func (*RequestConfig) Descriptor() ([]byte, []int)

func (*RequestConfig) GetFullVersion ¶ 

func (v *RequestConfig) GetFullVersion() string

func (*RequestConfig) GetHeader ¶ 

func (m *RequestConfig) GetHeader() []*Header

func (*RequestConfig) GetMethod ¶ 

func (m *RequestConfig) GetMethod() *Method

func (*RequestConfig) GetMethodValue ¶ 

func (v *RequestConfig) GetMethodValue() string

func (*RequestConfig) GetUri ¶ 

func (m *RequestConfig) GetUri() []string

func (*RequestConfig) GetVersion ¶ 

func (m *RequestConfig) GetVersion() *Version

func (*RequestConfig) GetVersionValue ¶ 

func (v *RequestConfig) GetVersionValue() string

func (*RequestConfig) PickHeaders ¶ 

func (v *RequestConfig) PickHeaders() []string

func (*RequestConfig) PickUri ¶ 

func (v *RequestConfig) PickUri() string

func (*RequestConfig) ProtoMessage ¶ 

func (*RequestConfig) ProtoMessage()

func (*RequestConfig) Reset ¶ 

func (m *RequestConfig) Reset()

func (*RequestConfig) String ¶ 

func (m *RequestConfig) String() string

func (*RequestConfig) XXX_DiscardUnknown ¶ 

func (m *RequestConfig) XXX_DiscardUnknown()

func (*RequestConfig) XXX_Marshal ¶ 

func (m *RequestConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RequestConfig) XXX_Merge ¶ 

func (m *RequestConfig) XXX_Merge(src proto.Message)

func (*RequestConfig) XXX_Size ¶ 

func (m *RequestConfig) XXX_Size() int

func (*RequestConfig) XXX_Unmarshal ¶ 

func (m *RequestConfig) XXX_Unmarshal(b []byte) error

type ResponseConfig ¶ 

type ResponseConfig struct {
	Version              *Version  `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	Status               *Status   `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	Header               []*Header `protobuf:"bytes,3,rep,name=header,proto3" json:"header,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ResponseConfig) Descriptor ¶ 

func (*ResponseConfig) Descriptor() ([]byte, []int)

func (*ResponseConfig) GetFullVersion ¶ 

func (v *ResponseConfig) GetFullVersion() string

func (*ResponseConfig) GetHeader ¶ 

func (m *ResponseConfig) GetHeader() []*Header

func (*ResponseConfig) GetStatus ¶ 

func (m *ResponseConfig) GetStatus() *Status

func (*ResponseConfig) GetStatusValue ¶ 

func (v *ResponseConfig) GetStatusValue() *Status

func (*ResponseConfig) GetVersion ¶ 

func (m *ResponseConfig) GetVersion() *Version

func (*ResponseConfig) GetVersionValue ¶ 

func (v *ResponseConfig) GetVersionValue() string

func (*ResponseConfig) HasHeader ¶ 

func (v *ResponseConfig) HasHeader(header string) bool

func (*ResponseConfig) PickHeaders ¶ 

func (v *ResponseConfig) PickHeaders() []string

func (*ResponseConfig) ProtoMessage ¶ 

func (*ResponseConfig) ProtoMessage()

func (*ResponseConfig) Reset ¶ 

func (m *ResponseConfig) Reset()

func (*ResponseConfig) String ¶ 

func (m *ResponseConfig) String() string

func (*ResponseConfig) XXX_DiscardUnknown ¶ 

func (m *ResponseConfig) XXX_DiscardUnknown()

func (*ResponseConfig) XXX_Marshal ¶ 

func (m *ResponseConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResponseConfig) XXX_Merge ¶ 

func (m *ResponseConfig) XXX_Merge(src proto.Message)

func (*ResponseConfig) XXX_Size ¶ 

func (m *ResponseConfig) XXX_Size() int

func (*ResponseConfig) XXX_Unmarshal ¶ 

func (m *ResponseConfig) XXX_Unmarshal(b []byte) error

type Status ¶ 

type Status struct {
	// Status code. Default "200".
	Code string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	// Statue reason. Default "OK".
	Reason               string   `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Status) Descriptor ¶ 

func (*Status) Descriptor() ([]byte, []int)

func (*Status) GetCode ¶ 

func (m *Status) GetCode() string

func (*Status) GetReason ¶ 

func (m *Status) GetReason() string

func (*Status) ProtoMessage ¶ 

func (*Status) ProtoMessage()

func (*Status) Reset ¶ 

func (m *Status) Reset()

func (*Status) String ¶ 

func (m *Status) String() string

func (*Status) XXX_DiscardUnknown ¶ 

func (m *Status) XXX_DiscardUnknown()

func (*Status) XXX_Marshal ¶ 

func (m *Status) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Status) XXX_Merge ¶ 

func (m *Status) XXX_Merge(src proto.Message)

func (*Status) XXX_Size ¶ 

func (m *Status) XXX_Size() int

func (*Status) XXX_Unmarshal ¶ 

func (m *Status) XXX_Unmarshal(b []byte) error

type Version ¶ 

type Version struct {
	Value                string   `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

HTTP version. Default value "1.1".

func (*Version) Descriptor ¶ 

func (*Version) Descriptor() ([]byte, []int)

func (*Version) GetValue ¶ 

func (m *Version) GetValue() string

func (*Version) ProtoMessage ¶ 

func (*Version) ProtoMessage()

func (*Version) Reset ¶ 

func (m *Version) Reset()

func (*Version) String ¶ 

func (m *Version) String() string

func (*Version) XXX_DiscardUnknown ¶ 

func (m *Version) XXX_DiscardUnknown()

func (*Version) XXX_Marshal ¶ 

func (m *Version) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Version) XXX_Merge ¶ 

func (m *Version) XXX_Merge(src proto.Message)

func (*Version) XXX_Size ¶ 

func (m *Version) XXX_Size() int

func (*Version) XXX_Unmarshal ¶ 

func (m *Version) XXX_Unmarshal(b []byte) error

type Writer ¶ 

type Writer interface {
	Write(io.Writer) error
}

Source Files ¶

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.
JackTT - Gopher 🇻🇳