frontproxy

Documentation

Index

• Constants
• Variables
• type AccessLog
  • func (a AccessLog) Fields() []zap.Field
• type Client
  • func NewSocketProxyClient(in io.Reader, out io.Writer) *Client
  • func (c *Client) Dial(host, port, token string) error
  • func (c *Client) Pipe(ctx context.Context) error
• type ErrorTokenAuthorization
  • func (e *ErrorTokenAuthorization) Error() string
• type FrontendProxy
  • func NewFrontendProxy(conf *config.Config, ct *connector.Server, c *rpcclient.Client) *FrontendProxy
  • func (p *FrontendProxy) Accept(server *http.Server, conn *tls.Conn, handler http.Handler)
  • func (p *FrontendProxy) ServeHTTP(w http.ResponseWriter, req *http.Request)
• type HttpProxy
  • func NewHttpProxy(conf *config.Config, ct *connector.Server, rpcClient *rpcclient.Client) *HttpProxy
  • func (p *HttpProxy) ServeGithubWebHook(_ context.Context, w http.ResponseWriter, req *http.Request)
  • func (p *HttpProxy) ServeHTTP(ctx context.Context, w http.ResponseWriter, req *http.Request)
• type MessageError
  • func NewMessageError(code int, message string) MessageError
  • func ParseMessageError(v url.Values) (MessageError, error)
• type SocketProxy
  • func NewSocketProxy(conf *config.Config, ct *connector.Server) *SocketProxy
  • func (s *SocketProxy) Accept(_ *http.Server, conn tlsConn, _ http.Handler)
  • func (s *SocketProxy) Shutdown()
• type Stream
  • func NewStream(parent *SocketProxy, conn tlsConn, host string) *Stream
• type Transport
  • func NewTransport(conf *config.Config, ct *connector.Server) *Transport
  • func (t *Transport) RoundTrip(req *http.Request) (*http.Response, error)

Constants

const (
	TokenHeaderName  = "X-Auth-Token"
	UserIdHeaderName = "X-Auth-Id"
)

const (
	TypeOpen uint8 = 1 + iota
	TypeOpenSuccess
	TypePacket
	TypeMessage
	TypePing
	TypePong
)

const (
	SocketErrorCodeInvalidProtocol = 1 + iota
	SocketErrorCodeRequestAuth
	SocketErrorCodeNotAccessible
	SocketErrorCodeCloseConnection
	SocketErrorCodeServerUnavailable
)

const (
	SocketProxyNextProto = "lpsc1"
)

Variables

var (
	SocketErrorInvalidProtocol   = NewMessageError(SocketErrorCodeInvalidProtocol, "invalid protocol")
	SocketErrorRequestAuth       = NewMessageError(SocketErrorCodeRequestAuth, "need authenticate")
	SocketErrorNotAccessible     = NewMessageError(SocketErrorCodeNotAccessible, "You don't have privilege")
	SocketErrorCloseConnection   = NewMessageError(SocketErrorCodeCloseConnection, "Sorry, the server has close connection")
	SocketErrorServerUnavailable = NewMessageError(SocketErrorCodeServerUnavailable, "Temporary the server unavailable")
)

var (
	HeartbeatInterval = 30 * time.Second
)

Types

type AccessLog

type AccessLog struct {
	Host      string `json:"host"`
	Protocol  string `json:"protocol"`
	Method    string `json:"method"`
	Path      string `json:"path"`
	Status    int    `json:"status"`
	UserAgent string `json:"user_agent"`
	ClientIp  string `json:"client_ip"`
	AppTime   int    `json:"app_time_ms"`
	RequestId string `json:"request_id"`
	UserId    string `json:"user_id"`
}

func (AccessLog) Fields

func (a AccessLog) Fields() []zap.Field

type Client

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

func NewSocketProxyClient

func NewSocketProxyClient(in io.Reader, out io.Writer) *Client

func (*Client) Dial

func (c *Client) Dial(host, port, token string) error

func (*Client) Pipe

func (c *Client) Pipe(ctx context.Context) error

type ErrorTokenAuthorization

type ErrorTokenAuthorization struct {
	Endpoint string
}

func (*ErrorTokenAuthorization) Error

func (e *ErrorTokenAuthorization) Error() string

type FrontendProxy

type FrontendProxy struct {
	Config *config.Config
	// contains filtered or unexported fields
}

func NewFrontendProxy

func NewFrontendProxy(conf *config.Config, ct *connector.Server, c *rpcclient.Client) *FrontendProxy

func (*FrontendProxy) Accept

func (p *FrontendProxy) Accept(server *http.Server, conn *tls.Conn, handler http.Handler)

func (*FrontendProxy) ServeHTTP

func (p *FrontendProxy) ServeHTTP(w http.ResponseWriter, req *http.Request)

type HttpProxy

type HttpProxy struct {
	Config *config.Config
	// contains filtered or unexported fields
}

func NewHttpProxy

func NewHttpProxy(conf *config.Config, ct *connector.Server, rpcClient *rpcclient.Client) *HttpProxy

func (*HttpProxy) ServeGithubWebHook

func (p *HttpProxy) ServeGithubWebHook(_ context.Context, w http.ResponseWriter, req *http.Request)

func (*HttpProxy) ServeHTTP

func (p *HttpProxy) ServeHTTP(ctx context.Context, w http.ResponseWriter, req *http.Request)

ServeHTTP has responsibility to serving content to client. ctx should be used instead of req.Context().

type MessageError

type MessageError interface {
	error
	Code() int
	Message() string
	Params() url.Values
	Clone() MessageError
}

func NewMessageError

func NewMessageError(code int, message string) MessageError

func ParseMessageError

func ParseMessageError(v url.Values) (MessageError, error)

type SocketProxy

type SocketProxy struct {
	Config *config.Config
	// contains filtered or unexported fields
}

func NewSocketProxy

func NewSocketProxy(conf *config.Config, ct *connector.Server) *SocketProxy

func (*SocketProxy) Accept

func (s *SocketProxy) Accept(_ *http.Server, conn tlsConn, _ http.Handler)

Accept handles incoming connection. conn is an established connection that is finished handshake.

func (*SocketProxy) Shutdown

func (s *SocketProxy) Shutdown()

type Stream

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

func NewStream

func NewStream(parent *SocketProxy, conn tlsConn, host string) *Stream

type Transport

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

func NewTransport

func NewTransport(conf *config.Config, ct *connector.Server) *Transport

func (*Transport) RoundTrip

func (t *Transport) RoundTrip(req *http.Request) (*http.Response, error)