router

Documentation

Index

• Constants
• type ConsulHandler
  • func NewConsulHandler() ConsulHandler
• type DummyConsulHandler
  • func (d *DummyConsulHandler) Service(consulAddr, serviceName string) (*api.CatalogService, error)
• type DummyTrader
  • func (t *DummyTrader) TradeName(name string) (profile *Profile, err error)
  • func (t *DummyTrader) TradeSecret(secret string) (profile *Profile, err error)
  • func (t *DummyTrader) Url() string
• type KafkaPixy
  • func NewKafkaPixy(addr string, topic string, group string) KafkaPixy
• type Profile
  • func NewProfileFromBytes(b []byte) (*Profile, error)
• type Proxy
  • func NewProxy(source string, target string) Proxy
• type ReverseProxyHandler
  • func (h ReverseProxyHandler) Director(req *http.Request)
  • func (h ReverseProxyHandler) ModifyResponse(res *http.Response) error
• type Router
  • func NewKibanaRouter(addr string, trader Trader, consul ConsulHandler) Router
  • func NewProduceRouter(addr string, trader Trader, consul ConsulHandler) Router
  • func NewXtailRouter(addr string, trader Trader, consul ConsulHandler) Router
• type Trader
  • func NewTrader(url string) Trader

Constants

const (
	SecretHeaderName = "X-App-Secret"
)

Types

type ConsulHandler

type ConsulHandler interface {
	Service(consulAddr, serviceName string) (srv *api.CatalogService, err error)
}

func NewConsulHandler

func NewConsulHandler() ConsulHandler

type DummyConsulHandler

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

func (*DummyConsulHandler) Service

func (d *DummyConsulHandler) Service(consulAddr, serviceName string) (*api.CatalogService, error)

type DummyTrader

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

func (*DummyTrader) TradeName

func (t *DummyTrader) TradeName(name string) (profile *Profile, err error)

func (*DummyTrader) TradeSecret

func (t *DummyTrader) TradeSecret(secret string) (profile *Profile, err error)

func (*DummyTrader) Url

func (t *DummyTrader) Url() string

type KafkaPixy

type KafkaPixy interface {
	GrpcConn() *grpc.ClientConn
	KafkaPixyClient() pb.KafkaPixyClient
	Consume() (message []byte, err error)
}

func NewKafkaPixy

func NewKafkaPixy(addr string, topic string, group string) KafkaPixy

type Profile

type Profile struct {
	Id     int    `json:"id"`
	Name   string `json:"name"`
	Consul string `json:"consul"`
}

func NewProfileFromBytes

func NewProfileFromBytes(b []byte) (*Profile, error)

type Proxy

type Proxy interface {
	ReverseProxy() *reverseproxy.ReverseProxy
	ReverseProxyHandler() *ReverseProxyHandler
}

func NewProxy

func NewProxy(source string, target string) Proxy

type ReverseProxyHandler

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

func (ReverseProxyHandler) Director

func (h ReverseProxyHandler) Director(req *http.Request)

func (ReverseProxyHandler) ModifyResponse

func (h ReverseProxyHandler) ModifyResponse(res *http.Response) error

type Router

type Router interface {
	Server() *http.Server
	Address() string
	Trader() Trader
	ProduceHandler(w http.ResponseWriter, req *http.Request)
	KibanaHandler(w http.ResponseWriter, req *http.Request)
	XtailHandler(w http.ResponseWriter, req *http.Request)
}

Router

func NewKibanaRouter

func NewKibanaRouter(addr string, trader Trader, consul ConsulHandler) Router

NewKibanaRouter

func NewProduceRouter

func NewProduceRouter(addr string, trader Trader, consul ConsulHandler) Router

NewProduceRouter

func NewXtailRouter

func NewXtailRouter(addr string, trader Trader, consul ConsulHandler) Router

NewXtailRouter

type Trader

type Trader interface {
	TradeSecret(secret string) (profile *Profile, err error)
	TradeName(name string) (profile *Profile, err error)
	Url() string
}

func NewTrader

func NewTrader(url string) Trader

NewHttpTrader