viola

README

viola

HTTP容错代理服务.

使用 resilience4go 包装代理请求.

支持:

• 舱壁隔离
• 限时
• 限速
• 熔断
• 重试
• 缓存
• 故障恢复

配置样例

请参考: config_help.toml

部署执行

1. 下载最新的可执行文件压缩包并解压

   下载地址: viola release

$ tar -xvJf viola.[version].[os].[arch].tar.xz

1. 新建/编辑配置文件, 启动运行

$ nohup ./viola.[version].[os].[arch].bin -configFile config.toml &

数据平面

端口号: 22915

控制平面

端口号: 22920

/config: 响应返回当前配置

/metrics: 响应返回Prometheus指标数据

/circuitbreaker/disable: 停用指定Endpoint的熔断器, 使用url-query或post-form参数endpoint=xxx指定Endpoint

/circuitbreaker/force-open: 强制开启指定Endpoint的熔断器, 使用url-query或post-form参数endpoint=xxx指定Endpoint

/circuitbreaker/close: 关闭指定Endpoint的熔断器, 使用url-query或post-form参数endpoint=xxx指定Endpoint

/circuitbreaker/state: 查询指定Endpoint的熔断器的当前状态, 使用url-query或post-form参数endpoint=xxx指定Endpoint

Documentation

Index

• Constants
• Variables
• func CircuitBreakerStateHandler(dataPlane DataPlane) http.Handler
• func CloseCircuitBreakerHandler(dataPlane DataPlane) http.Handler
• func ConfigHandler(dataPlane DataPlane) http.Handler
• func DisableCircuitBreakerHandler(dataPlane DataPlane) http.Handler
• func ForceOpenCircuitBreakerHandler(dataPlane DataPlane) http.Handler
• func MetricsHandler(dataPlane DataPlane) http.Handler
• func NewCtrlPlane(dataPlane DataPlane) http.Handler
• type BulkheadConfig
• type CacheConfig
• type CircuitBreakerConfig
• type Config
  • func FormatConfig(config *Config) *Config
  • func LoadConfig(data string) (*Config, error)
• type DataPlane
  • func NewDataPlane(config *Config) DataPlane
• type Defaults
• type DumpMessage
• type DumpType
• type EndpointConfig
• type FallbackConfig
• type MessageType
• type RateLimiterConfig
• type ResilienceConfig
• type RetryConfig
• type TimeLimiterConfig

Constants

const DumpTopic = proxy.DumpTopic

Variables

var (
	RegisterRspFailedPredicate = resilience.RegisterRspFailedPredicate
	RegisterRspCachePredicate  = resilience.RegisterRspCachePredicate
	RegisterFallbackFunction   = resilience.RegisterFallbackFunction
)

Functions

func CircuitBreakerStateHandler

func CircuitBreakerStateHandler(dataPlane DataPlane) http.Handler

func CloseCircuitBreakerHandler

func CloseCircuitBreakerHandler(dataPlane DataPlane) http.Handler

func ConfigHandler

func ConfigHandler(dataPlane DataPlane) http.Handler

func DisableCircuitBreakerHandler

func DisableCircuitBreakerHandler(dataPlane DataPlane) http.Handler

func ForceOpenCircuitBreakerHandler

func ForceOpenCircuitBreakerHandler(dataPlane DataPlane) http.Handler

func MetricsHandler

func MetricsHandler(dataPlane DataPlane) http.Handler

func NewCtrlPlane

func NewCtrlPlane(dataPlane DataPlane) http.Handler

Types

type BulkheadConfig

type BulkheadConfig = resilience.BulkheadConfig

type CacheConfig

type CacheConfig = resilience.CacheConfig

type CircuitBreakerConfig

type CircuitBreakerConfig = resilience.CircuitBreakerConfig

type Config

type Config struct {
	Endpoint []EndpointConfig

	Defaults Defaults
}

func FormatConfig

func FormatConfig(config *Config) *Config

func LoadConfig

func LoadConfig(data string) (*Config, error)

type DataPlane

type DataPlane interface {
	http.Handler
	GetConfig() *Config
	SetConfig(*Config)

	GetRegisterer() prometheus.Registerer
	GetGatherer() prometheus.Gatherer
	SetRegistry(*prometheus.Registry)

	DisableCircuitBreaker(string) error
	ForceOpenCircuitBreaker(string) error
	CloseCircuitBreaker(string) error
	CircuitBreakerState(string) string
}

func NewDataPlane

func NewDataPlane(config *Config) DataPlane

type Defaults

type Defaults struct {
	Resilience ResilienceConfig
}

type DumpMessage

type DumpMessage = proxy.DumpMessage

type DumpType

type DumpType = proxy.DumpType

type EndpointConfig

type EndpointConfig struct {
	Name string

	Location            string
	StripLocationPrefix string

	TargetURL string

	DumpTarget string
	DumpSource string

	Resilience ResilienceConfig
}

type FallbackConfig

type FallbackConfig = resilience.FallbackConfig

type MessageType

type MessageType = proxy.MessageType

type RateLimiterConfig

type RateLimiterConfig = resilience.RateLimiterConfig

type ResilienceConfig

type ResilienceConfig struct {
	Bulkhead       BulkheadConfig
	TimeLimiter    TimeLimiterConfig
	RateLimiter    RateLimiterConfig
	CircuitBreaker CircuitBreakerConfig
	Retry          RetryConfig
	Cache          CacheConfig
	Fallback       FallbackConfig
}

type RetryConfig

type RetryConfig = resilience.RetryConfig

type TimeLimiterConfig

type TimeLimiterConfig = resilience.TimeLimiterConfig