datasource

Nov 26, 2020

Changes in this version

+ func IsolationRuleJsonArrayParser(src []byte) (interface{}, error)

+ func IsolationRulesUpdater(data interface{}) error

type DefaultPropertyHandler

+ func NewIsolationRulesHandler(converter PropertyConverter) *DefaultPropertyHandler

+ type HotspotRule struct

+ BurstCount int64

+ ControlBehavior hotspot.ControlBehavior

+ DurationInSec int64

+ ID string

+ MaxQueueingTimeMs int64

+ MetricType hotspot.MetricType

+ ParamIndex int

+ ParamsMaxCapacity int64

+ Resource string

+ SpecificItems []SpecificValue

+ Threshold int64

+ type ParamKind int

+ const KindBool

+ const KindFloat64

+ const KindInt

+ const KindString

+ const KindSum

+ func (t ParamKind) String() string

+ type SpecificValue struct

+ Threshold int64

+ ValKind ParamKind

+ ValStr string

+ func (s *SpecificValue) String() string

Sep 2, 2020

Changes in this version

+ func CircuitBreakerRuleJsonArrayParser(src []byte) (interface{}, error)

+ func FlowRuleJsonArrayParser(src []byte) (interface{}, error)

+ func HotSpotParamRuleJsonArrayParser(src []byte) (interface{}, error)

+ func SystemRuleJsonArrayParser(src []byte) (interface{}, error)

Jun 18, 2020

Changes in this version

+ func CircuitBreakerRulesJsonConverter(src []byte) (interface{}, error)

+ func CircuitBreakerRulesUpdater(data interface{}) error

+ func HotSpotParamRulesJsonConverter(src []byte) (interface{}, error)

+ func HotSpotParamRulesUpdater(data interface{}) error

type DefaultPropertyHandler

+ func NewCircuitBreakerRulesHandler(converter PropertyConverter) *DefaultPropertyHandler

type PropertyHandler

+ func NewHotSpotParamRulesHandler(converter PropertyConverter) PropertyHandler

May 22, 2020

Changes in this version

+ const ConvertSourceError

+ const HandleSourceError

+ const OK

+ const UpdatePropertyError

type Base

+ func (b *Base) Handle(src []byte) (err error)

+ type Code uint32

+ type Error struct

+ func NewError(code Code, desc string) Error

+ func (e Error) Code() Code

+ func (e Error) Error() string

Mar 19, 2020

Changes in this version

+ func FlowRulesJsonConverter(src []byte) (interface{}, error)

+ func FlowRulesUpdater(data interface{}) error

+ func SystemRulesJsonConverter(src []byte) (interface{}, error)

+ func SystemRulesUpdater(data interface{}) error

+ type Base struct

+ func (b *Base) AddPropertyHandler(h PropertyHandler)

+ func (b *Base) Handlers() []PropertyHandler

+ func (b *Base) RemovePropertyHandler(h PropertyHandler)

+ type DataSource interface

+ AddPropertyHandler func(h PropertyHandler)

+ Initialize func() error

+ ReadSource func() ([]byte, error)

+ RemovePropertyHandler func(h PropertyHandler)

+ type DefaultPropertyHandler struct

+ func NewDefaultPropertyHandler(converter PropertyConverter, updater PropertyUpdater) *DefaultPropertyHandler

+ func NewSystemRulesHandler(converter PropertyConverter) *DefaultPropertyHandler

+ func (h *DefaultPropertyHandler) Handle(src []byte) error

+ type MockPropertyHandler struct

+ func (m *MockPropertyHandler) Handle(src []byte) error

+ type PropertyConverter func(src []byte) (interface{}, error)

+ type PropertyHandler interface

+ Handle func(src []byte) error

+ func NewFlowRulesHandler(converter PropertyConverter) PropertyHandler

+ type PropertyUpdater func(data interface{}) error