router

Mar 2, 2021

Changes in this version

type Profile

+ KibanaAddress string

+ ProducerAddress string

Jan 30, 2020

Changes in this version

type Profile

+ ConsulHosts []string

Dec 18, 2019

Changes in this version

+ type ConsulCatalog interface

+ Service func(service, tag string, q *api.QueryOptions) ([]*api.CatalogService, *api.QueryMeta, error)

Oct 10, 2019

Changes in this version

+ const ConsulServiceBackupCachePrefix

+ const ProfileBackupCachePrefix

+ func ConvertBytesToTimber(b []byte, context pb.TimberContext) (timber pb.Timber, err error)

+ func ConvertBytesToTimberCollection(b []byte, context pb.TimberContext) (timberCol pb.TimberCollection, err error)

+ func TimberContextFromProfile(profile *Profile) pb.TimberContext

+ type ProducerStore map[producerAttributes]*grpcParts

+ func NewProducerStore() ProducerStore

+ func (s ProducerStore) CloseConns()

+ func (s ProducerStore) GetClient(attr producerAttributes) pb.ProducerClient

Jan 21, 2019

Changes in this version

+ const AppKibanaNoProfilePath

+ const AppNoProfilePath

+ const AppNoSecretPath

Nov 11, 2018

Changes in this version

type ProducerProxyHandler

+ ErrorHandler func(rw http.ResponseWriter, req *http.Request, err error)

Oct 13, 2018

Changes in this version

+ const AppGroupSecretHeaderName

+ const AppNameHeaderName

+ const AppSecretHeaderName

type Profile

+ AppSecret string

Sep 10, 2018

Changes in this version

type TimberContext

+ AppSecret string

Aug 8, 2018

Changes in this version

+ type ElasticsearchMeta struct

+ DocumentType string

+ IndexPrefix string

+ type KafkaMeta struct

+ ConsumerGroup string

+ Partition int32

+ ReplicationFactor int16

+ TopicName string

+ type KibanaProxy interface

+ KibanaProxyHandler func() *KibanaProxyHandler

+ ReverseProxy func() *reverseproxy.ReverseProxy

+ func NewKibanaProxy(source string, target string) KibanaProxy

+ type KibanaProxyHandler struct

+ func (h KibanaProxyHandler) Director(req *http.Request)

+ func (h KibanaProxyHandler) ModifyResponse(res *http.Response) error

+ type ProducerProxyHandler interface

+ Director func(req *http.Request)

+ func NewProducerProxyHandler(target *url.URL, profile Profile) ProducerProxyHandler

type Profile

+ ID int

+ MaxTps int

type ProfileMeta

+ Elasticsearch ElasticsearchMeta

+ Kafka KafkaMeta

+ type TimberContext struct

+ AppMaxTPS int

+ ESDocumentType string

+ ESIndexPrefix string

+ KafkaPartition int32

+ KafkaReplicationFactor int16

+ KafkaTopic string

Jul 25, 2018

Changes in this version

+ func KibanaGetClustername(req *http.Request) string

+ type KibanaRouter interface

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

+ Server func() *http.Server

+ type ProducerRouter interface

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

+ Server func() *http.Server

+ func NewProducerRouter(addr, marketUrl, profilePath string) ProducerRouter

Jun 12, 2018

Changes in this version

+ const KeyKibana

+ const KeyProducer

type Profile

+ Meta *ProfileMeta

+ func (p Profile) MetaServiceName(name string) (val string, ok bool)

+ type ProfileMeta struct

+ ServiceNames map[string]string

type Trader

+ func NewTraderByClusterName(url string) Trader

+ func NewTraderBySecret(url string) Trader

Jun 11, 2018

Changes in this version

type Profile

+ AppGroup string

+ AppStatus string

+ ClusterName string

+ ConsulHost string

+ TpsConfig string

Jun 3, 2018

Changes in this version

+ type KafkaPixy interface

+ Consume func() (message []byte, err error)

+ GrpcConn func() *grpc.ClientConn

+ KafkaPixyClient func() pb.KafkaPixyClient

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

type Router

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

+ XtailHandler func(w http.ResponseWriter, req *http.Request)

May 22, 2018

Changes in this version

type DummyTrader

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

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

+ type Proxy interface

+ ReverseProxy func() *reverseproxy.ReverseProxy

+ ReverseProxyHandler func() *ReverseProxyHandler

+ func NewProxy(source string, target string) Proxy

+ type ReverseProxyHandler struct

+ 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

+ KibanaHandler func(w http.ResponseWriter, req *http.Request)

+ ProduceHandler func(w http.ResponseWriter, req *http.Request)

type Trader

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

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

May 18, 2018

Changes in this version

+ const SecretHeaderName

+ type ConsulHandler interface

+ Service func(consulAddr, serviceName string) (srv *api.CatalogService, err error)

+ func NewConsulHandler() ConsulHandler

+ type DummyConsulHandler struct

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

+ type DummyTrader struct

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

+ func (t *DummyTrader) Url() string

+ type Profile struct

+ Consul string

+ Id int

+ Name string

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

+ type Router interface

+ Address func() string

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

+ Server func() *http.Server

+ Trader func() Trader

+ func NewRouter(addr string, trader Trader, consul ConsulHandler) Router

+ type Trader interface

+ Trade func(secret string) (profile *Profile, err error)

+ Url func() string

+ func NewTrader(url string) Trader