dnspath

Documentation

Index

• Variables
• type DNSPath
  • func (m *DNSPath) ForwardRequest(w http.ResponseWriter, r *http.Request, target *url.URL, ...)
  • func (m *DNSPath) Middleware() (func(http.Handler) http.Handler, error)
  • func (m *DNSPath) ReplaceRequest(r *http.Request) (*url.URL, http.RoundTripper)
• type IPHolder
  • func NewIPHolder() *IPHolder
  • func (h *IPHolder) Dump() string
  • func (h *IPHolder) Get(i int) string
  • func (h *IPHolder) GetStr(i string) string
  • func (h *IPHolder) Set(ips []net.IP)
• type Number
  • func NewNumber(length int) *Number
  • func (n *Number) Delete(number int)
  • func (n *Number) Order()
  • func (n *Number) Pop() int
  • func (n *Number) Set(number int)
• type Path
  • func (p *Path) DNSFetch()
  • func (p *Path) IsFetched() bool

Variables

var (
	DefaultDuration = 10 * time.Second
	DefaultSchema   = "http"
)

Types

type DNSPath

type DNSPath struct {
	Paths []*Path `cfg:"paths"`
}

DNSPath is a middleware that replaces the path of the request with hostname to IP address.

• http://proxy/metrics/kafka/1/metrics -> http://10.0.0.1/metrics
• http://proxy/metrics/kafka/2/metrics -> http://10.0.0.2/metrics

func (*DNSPath) ForwardRequest

func (m *DNSPath) ForwardRequest(w http.ResponseWriter, r *http.Request, target *url.URL, transport http.RoundTripper)

func (*DNSPath) Middleware

func (m *DNSPath) Middleware() (func(http.Handler) http.Handler, error)

func (*DNSPath) ReplaceRequest

func (m *DNSPath) ReplaceRequest(r *http.Request) (*url.URL, http.RoundTripper)

type IPHolder

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

func NewIPHolder

func NewIPHolder() *IPHolder

func (*IPHolder) Dump

func (h *IPHolder) Dump() string

func (*IPHolder) Get

func (h *IPHolder) Get(i int) string

func (*IPHolder) GetStr

func (h *IPHolder) GetStr(i string) string

func (*IPHolder) Set

func (h *IPHolder) Set(ips []net.IP)

type Number

type Number struct {
	Map   map[int]struct{}
	Slice []int
}

func NewNumber

func NewNumber(length int) *Number

func (*Number) Delete

func (n *Number) Delete(number int)

func (*Number) Order

func (n *Number) Order()

func (*Number) Pop

func (n *Number) Pop() int

func (*Number) Set

func (n *Number) Set(number int)

type Path

type Path struct {
	DNS string `cfg:"dns"`
	// Regex to match the path
	// Example: /metrics/kafka/(\d+)/(.*)
	Regex string `cfg:"regex"`
	// Number to extract in regex
	// Example: $1
	Number      string `cfg:"number"`
	Replacement string `cfg:"replacement"`

	Schema             string        `cfg:"schema"`
	Port               string        `cfg:"port"`
	InsecureSkipVerify bool          `cfg:"insecure_skip_verify"`
	Duration           time.Duration `cfg:"duration"`
	// contains filtered or unexported fields
}

func (*Path) DNSFetch

func (p *Path) DNSFetch()

func (*Path) IsFetched

func (p *Path) IsFetched() bool