router

type ConsulCatalog interface {
	Service(service, tag string, q *api.QueryOptions) ([]*api.CatalogService, *api.QueryMeta, error)
}

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

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

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

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

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

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

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

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"`
	ConsulHosts     []string    `json:"consul_hosts"`
	ProducerAddress string      `json:"producer_address"`
	KibanaAddress   string      `json:"kibana_address"`
	AppStatus       string      `json:"status"`
	Meta            ProfileMeta `json:"meta"`
}

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