router

Documentation

Index

• Constants
• func KibanaGetClustername(req *http.Request) string
• type ElasticsearchMeta
• type KafkaMeta
• type KibanaProxy
  • func NewKibanaProxy(source string, target string) KibanaProxy
• type KibanaProxyHandler
  • func (h KibanaProxyHandler) Director(req *http.Request)
  • func (h KibanaProxyHandler) ModifyResponse(res *http.Response) error
• type KibanaRouter
  • func NewKibanaRouter(addr, marketUrl, profilePath, authorizePath, casAddr string) KibanaRouter
• type ProducerProxyHandler
  • func NewProducerProxyHandler(target *url.URL, profile Profile, appSecret string) ProducerProxyHandler
• type ProducerRouter
  • func NewProducerRouter(addr, marketUrl, profilePath string, profileByAppGroupPath string) ProducerRouter
• type Profile
  • func NewProfileFromBytes(b []byte) (*Profile, error)
  • func (p Profile) MetaServiceName(name string) (val string, ok bool)
• type ProfileMeta
• type TimberContext

Constants

const (
	AppSecretHeaderName      = "X-App-Secret"
	AppGroupSecretHeaderName = "X-App-Group-Secret"
	AppNameHeaderName        = "X-App-Name"
	KeyProducer              = "producer"
)

const (
	KeyKibana = "kibana"
)

Functions

func KibanaGetClustername

func KibanaGetClustername(req *http.Request) string

Types

type ElasticsearchMeta

type ElasticsearchMeta struct {
	IndexPrefix  string `json:"index_prefix"`
	DocumentType string `json:"document_type"`
}

type KafkaMeta

type KafkaMeta struct {
	TopicName         string `json:"topic_name"`
	Partition         int32  `json:"partition"`
	ReplicationFactor int16  `json:"replication_factor"`
	ConsumerGroup     string `json:"consumer_group"`
}

type KibanaProxy

type KibanaProxy interface {
	ReverseProxy() *reverseproxy.ReverseProxy
	KibanaProxyHandler() *KibanaProxyHandler
}

func NewKibanaProxy

func NewKibanaProxy(source string, target string) KibanaProxy

type KibanaProxyHandler

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

func (KibanaProxyHandler) Director

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

func (KibanaProxyHandler) ModifyResponse

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

type KibanaRouter

type KibanaRouter interface {
	Server() *http.Server
	ServeHTTP(w http.ResponseWriter, req *http.Request)
}

func NewKibanaRouter

func NewKibanaRouter(addr, marketUrl, profilePath, authorizePath, casAddr string) KibanaRouter

NewKibanaRouter

type ProducerProxyHandler

type ProducerProxyHandler interface {
	Director(req *http.Request)
	ErrorHandler(rw http.ResponseWriter, req *http.Request, err error)
}

func NewProducerProxyHandler

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

type ProducerRouter

type ProducerRouter interface {
	Server() *http.Server
	ServeHTTP(w http.ResponseWriter, req *http.Request)
}

func NewProducerRouter

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

type Profile

type Profile struct {
	ID          int         `json:"id"`
	Name        string      `json:"name"`
	AppSecret   string      `json:"app_secret"`
	AppGroup    string      `json:"app_group_name"`
	MaxTps      int         `json:"max_tps"`
	ClusterName string      `json:"cluster_name"`
	ConsulHost  string      `json:"consul_host"`
	AppStatus   string      `json:"status"`
	Meta        ProfileMeta `json:"meta"`
}

func NewProfileFromBytes

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

func (Profile) MetaServiceName

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

type ProfileMeta

type ProfileMeta struct {
	ServiceNames  map[string]string `json:"service_names"`
	Kafka         KafkaMeta         `json:"kafka"`
	Elasticsearch ElasticsearchMeta `json:"elasticsearch"`
}

type TimberContext

type TimberContext struct {
	KafkaTopic             string `json:"kafka_topic"`
	KafkaPartition         int32  `json:"kafka_partition"`
	KafkaReplicationFactor int16  `json:"kafka_replication_factor"`
	ESIndexPrefix          string `json:"es_index_prefix"`
	ESDocumentType         string `json:"es_document_type"`
	AppMaxTPS              int    `json:"app_max_tps"`
	AppSecret              string `json:"app_secret"`
}