config

Documentation

Index

• Constants
• func GetUpstreamConfigs() map[string]UpstreamConfig
• func SetProxyConfig(cfg ProxyConfig)
• func SetUpstream(ups []UpstreamConfig)
• func UpdateUpstreamReadableStatus(key string, active bool)
• func UpdateUpstreamWriteableStatus(key string, active bool)
• type ProxyConfig
  • func GetProxyConfig() ProxyConfig
• type UpstreamConfig
  • func GetUpstreamConfig(key string) UpstreamConfig
  • func (v *UpstreamConfig) SafeGetQueueName() string

Constants

const Body pipeline.ParaKey = "body"

const BuildDate = "N/A"

const InactiveUpstream = "inactive_upstream"

Bucket

const LastCommitLog = "N/A"

const Message pipeline.ParaKey = "message"

const Method pipeline.ParaKey = "method"

const Response pipeline.ParaKey = "response"

const ResponseSize pipeline.ParaKey = "response_size"

const ResponseStatusCode pipeline.ParaKey = "response_code"

const Upstream pipeline.ParaKey = "upstream"

const Url pipeline.ParaKey = "url"

const Version = "0.0.1-SNAPSHOT"

Functions

func GetUpstreamConfigs

func GetUpstreamConfigs() map[string]UpstreamConfig

func SetProxyConfig

func SetProxyConfig(cfg ProxyConfig)

func SetUpstream

func SetUpstream(ups []UpstreamConfig)

func UpdateUpstreamReadableStatus

func UpdateUpstreamReadableStatus(key string, active bool)

func UpdateUpstreamWriteableStatus

func UpdateUpstreamWriteableStatus(key string, active bool)

Types

type ProxyConfig

type ProxyConfig struct {
	UIEnabled           bool             `config:"ui_enabled"`
	Upstream            []UpstreamConfig `config:"upstream"`
	Algorithm           string           `config:"algorithm"`
	PassthroughPatterns []string         `config:"pass_through"`
}

func GetProxyConfig

func GetProxyConfig() ProxyConfig

type UpstreamConfig

type UpstreamConfig struct {
	Name          string `config:"name"`
	QueueName     string `config:"queue_name"`
	MaxQueueDepth int64  `config:"max_queue_depth"`
	Enabled       bool   `config:"enabled"`
	Writeable     bool   `config:"writeable"`
	Readable      bool   `config:"readable"`
	Timeout       string `config:"timeout"`
	Elasticsearch string `config:"elasticsearch"`
}

func GetUpstreamConfig

func GetUpstreamConfig(key string) UpstreamConfig

func (*UpstreamConfig) SafeGetQueueName

func (v *UpstreamConfig) SafeGetQueueName() string