router

Documentation

Index

• Constants
• 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 KibanaGetClustername(req *http.Request) string
• func TimberContextFromProfile(profile *Profile) pb.TimberContext
• 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, accessToken, profilePath, authorizePath, casAddr string, ...) KibanaRouter
• type ProducerRouter
  • func NewProducerRouter(addr, marketUrl, profilePath string, profileByAppGroupPath string, ...) ProducerRouter
• type ProducerStore
  • func NewProducerStore() ProducerStore
  • func (s ProducerStore) CloseConns()
  • func (s ProducerStore) GetClient(attr producerAttributes) pb.ProducerClient
• type Profile
  • func NewProfileFromBytes(b []byte) (*Profile, error)
  • func (p Profile) MetaServiceName(name string) (val string, ok bool)
• type ProfileMeta

Constants

const (
	// KeyKibana is meta service name of kibana
	KeyKibana = "kibana"

	// AppKibanaNoProfilePath is path to register when server returned no profile
	AppKibanaNoProfilePath = "api/kibana_no_profile"
)

const (
	AppSecretHeaderName      = "X-App-Secret"
	AppGroupSecretHeaderName = "X-App-Group-Secret"
	AppNameHeaderName        = "X-App-Name"
	KeyProducer              = "producer"
	AppNoProfilePath         = "api/producer_no_profile"
	AppNoSecretPath          = "api/no_secret"
)

const ConsulServiceBackupCachePrefix = "consul_backup_cache_"

const ProfileBackupCachePrefix = "profile_backup_cache_"

Functions

func ConvertBytesToTimber

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

func ConvertBytesToTimberCollection

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

func KibanaGetClustername

func KibanaGetClustername(req *http.Request) string

func TimberContextFromProfile

func TimberContextFromProfile(profile *Profile) pb.TimberContext

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, accessToken, profilePath, authorizePath, casAddr string, appCtx *appcontext.AppContext) KibanaRouter

NewKibanaRouter is a function for creating new kibana router

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, appCtx *appcontext.AppContext) ProducerRouter

type ProducerStore

type ProducerStore map[producerAttributes]*grpcParts

func NewProducerStore

func NewProducerStore() ProducerStore

func (ProducerStore) CloseConns

func (s ProducerStore) CloseConns()

func (ProducerStore) GetClient

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

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"`
}