proxy

Documentation

Index

• Constants
• func AddConstellationToken(route utils.ProxyRouteConfig) func(next http.Handler) http.Handler
• func BotDetectionMiddleware(next http.Handler) http.Handler
• func BuildFromConfig(router *mux.Router, config utils.ProxyConfig) *mux.Router
• func CleanUp()
• func GetActiveProxies() map[string]chan bool
• func GetClientID(r *http.Request, route utils.ProxyRouteConfig) string
• func GetShield() int
• func InitInternalTCPProxy()
• func NewProxy(targetHost string, AcceptInsecureHTTPSTarget bool, DisableHeaderHardening bool, ...) (*httputil.ReverseProxy, error)
• func PublishAllMDNSFromConfig()
• func RouteTo(route utils.ProxyRouteConfig) http.Handler
• func RouterGen(route utils.ProxyRouteConfig, router *mux.Router, destination http.Handler) *mux.Route
• func SmartShieldMiddleware(shieldID string, route utils.ProxyRouteConfig) func(http.Handler) http.Handler
• type PortsPair
• type Publisher
  • func NewPublisher() (*Publisher, error)
  • func (p *Publisher) Close()
  • func (p *Publisher) Fqdn() string
  • func (p *Publisher) PublishCNAMES(cnames []string, ttl uint32) error
• type SmartResponseWriterWrapper
  • func (w *SmartResponseWriterWrapper) Flush()
  • func (w *SmartResponseWriterWrapper) Hijack() (net.Conn, *bufio.ReadWriter, error)
  • func (w *SmartResponseWriterWrapper) IsOld() bool
  • func (w *SmartResponseWriterWrapper) IsOver() bool
  • func (w *SmartResponseWriterWrapper) Write(p []byte) (int, error)
  • func (w *SmartResponseWriterWrapper) WriteHeader(status int)

Constants

const (
	// https://github.com/lathiat/avahi/blob/v0.8/avahi-common/defs.h#L343
	AVAHI_DNS_CLASS_IN = uint16(0x01)
	// https://github.com/lathiat/avahi/blob/v0.8/avahi-common/defs.h#L331
	AVAHI_DNS_TYPE_CNAME = uint16(0x05)
)

const (
	STRIKE = 0
	TEMP   = 1
	PERM   = 2
)

Functions

func AddConstellationToken

func AddConstellationToken(route utils.ProxyRouteConfig) func(next http.Handler) http.Handler

func BotDetectionMiddleware

func BotDetectionMiddleware(next http.Handler) http.Handler

botDetectionMiddleware checks if the User-Agent is a known bot

func BuildFromConfig

func BuildFromConfig(router *mux.Router, config utils.ProxyConfig) *mux.Router

func CleanUp

func CleanUp()

func GetActiveProxies

func GetActiveProxies() map[string]chan bool

func GetClientID

func GetClientID(r *http.Request, route utils.ProxyRouteConfig) string

func GetShield

func GetShield() int

func InitInternalTCPProxy

func InitInternalTCPProxy()

func NewProxy

func NewProxy(targetHost string, AcceptInsecureHTTPSTarget bool, DisableHeaderHardening bool, CORSOrigin string, route utils.ProxyRouteConfig) (*httputil.ReverseProxy, error)

NewProxy takes target host and creates a reverse proxy

func PublishAllMDNSFromConfig

func PublishAllMDNSFromConfig()

func RouteTo

func RouteTo(route utils.ProxyRouteConfig) http.Handler

func RouterGen

func RouterGen(route utils.ProxyRouteConfig, router *mux.Router, destination http.Handler) *mux.Route

func SmartShieldMiddleware

func SmartShieldMiddleware(shieldID string, route utils.ProxyRouteConfig) func(http.Handler) http.Handler

Types

type PortsPair

type PortsPair struct {
	From string
	To   string
}

type Publisher

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

func NewPublisher

func NewPublisher() (*Publisher, error)

NewPublisher creates a new service for Publisher.

func (*Publisher) Close

func (p *Publisher) Close()

Close associated resources.

func (*Publisher) Fqdn

func (p *Publisher) Fqdn() string

Fqdn returns the fully qualified domain name from Avahi.

func (*Publisher) PublishCNAMES

func (p *Publisher) PublishCNAMES(cnames []string, ttl uint32) error

PublishCNAMES send via Avahi-daemon CNAME records with the provided TTL.

type SmartResponseWriterWrapper

type SmartResponseWriterWrapper struct {
	http.ResponseWriter
	ClientID     string
	Status       int
	Bytes        int64
	ThrottleNext int
	TimeStarted  time.Time
	TimeEnded    time.Time
	RequestCost  int
	Method       string
	// contains filtered or unexported fields
}

func (*SmartResponseWriterWrapper) Flush

func (w *SmartResponseWriterWrapper) Flush()

func (*SmartResponseWriterWrapper) Hijack

func (w *SmartResponseWriterWrapper) Hijack() (net.Conn, *bufio.ReadWriter, error)

func (*SmartResponseWriterWrapper) IsOld

func (w *SmartResponseWriterWrapper) IsOld() bool

func (*SmartResponseWriterWrapper) IsOver

func (w *SmartResponseWriterWrapper) IsOver() bool

func (*SmartResponseWriterWrapper) Write

func (w *SmartResponseWriterWrapper) Write(p []byte) (int, error)

func (*SmartResponseWriterWrapper) WriteHeader

func (w *SmartResponseWriterWrapper) WriteHeader(status int)