Versions in this module Expand all Collapse all v0 v0.7.1 Aug 16, 2018 Changes in this version + var ErrDuplicatedHandler = errors.New("duplicated handler registration") v0.5.1 May 31, 2018 Changes in this version + const BizkeeperConsumer + const BizkeeperProvider + const FaultHandlerName + const FaultInject + const Loadbalance + const Name + const ProviderLimitKeyGlobal + const ProviderQPSLimit + const RatelimiterConsumer + const RatelimiterProvider + const Router + const TracingConsumer + const TracingProvider + const Transport + var ChainMap = make(map[string]*Chain) + var HandlerFuncMap = make(map[string]func() Handler) + func CreateChains(chainType string, handlerNameMap map[string]string) error + func GetFallbackFun(cmd, t string, i *invocation.Invocation, ...) func(error) error + func GetFaultConfig(protocol, microServiceName, schemaID, operationID string) model.Fault + func GetHystrixConfig(service, protype string) (string, hystrix.CommandConfig) + func ProcessSpecialProtocol(inv *invocation.Invocation, req *client.Request) + func ProcessSuccessiveFailure(i *invocation.Invocation, req *client.Request) + func RegisterHandler(name string, f func() Handler) error + type BizKeeperConsumerHandler struct + func (bk *BizKeeperConsumerHandler) Handle(chain *Chain, i *invocation.Invocation, cb invocation.ResponseCallBack) + func (bk *BizKeeperConsumerHandler) Name() string + type BizKeeperProviderHandler struct + func (bk *BizKeeperProviderHandler) Handle(chain *Chain, i *invocation.Invocation, cb invocation.ResponseCallBack) + func (bk *BizKeeperProviderHandler) Name() string + type Chain struct + HandlerIndex int + Handlers []Handler + Name string + ServiceType string + func CreateChain(serviceType string, chainName string, handlerNames ...string) (*Chain, error) + func GetChain(serviceType string, name string) (*Chain, error) + func (c *Chain) AddHandler(h Handler) + func (c *Chain) Next(i *invocation.Invocation, f invocation.ResponseCallBack) + func (c *Chain) Reset() + type ChainOption func(*ChainOptions) + func WithChainName(name string) ChainOption + type ChainOptions struct + Name string + type ConsumerRateLimiterHandler struct + func (rl *ConsumerRateLimiterHandler) GetOrCreate(op *qpslimiter.OperationMeta) + func (rl *ConsumerRateLimiterHandler) Handle(chain *Chain, i *invocation.Invocation, cb invocation.ResponseCallBack) + func (rl *ConsumerRateLimiterHandler) Name() string + type FaultHandler struct + func (rl *FaultHandler) Handle(chain *Chain, inv *invocation.Invocation, cb invocation.ResponseCallBack) + func (rl *FaultHandler) Name() string + type Handler interface + Handle func(*Chain, *invocation.Invocation, invocation.ResponseCallBack) + Name func() string + func CreateHandler(name string) (Handler, error) + func FaultHandle() Handler + type LBHandler struct + func (lb *LBHandler) Handle(chain *Chain, i *invocation.Invocation, cb invocation.ResponseCallBack) + func (lb *LBHandler) Name() string + type ProviderRateLimiterHandler struct + func (rl *ProviderRateLimiterHandler) Handle(chain *Chain, i *invocation.Invocation, cb invocation.ResponseCallBack) + func (rl *ProviderRateLimiterHandler) Name() string + type RouterHandler struct + func (ph *RouterHandler) Handle(chain *Chain, i *invocation.Invocation, cb invocation.ResponseCallBack) + func (ph *RouterHandler) Name() string + type TracingConsumerHandler struct + func (t *TracingConsumerHandler) Handle(chain *Chain, i *invocation.Invocation, cb invocation.ResponseCallBack) + func (t *TracingConsumerHandler) Name() string + type TracingProviderHandler struct + func (t *TracingProviderHandler) Handle(chain *Chain, i *invocation.Invocation, cb invocation.ResponseCallBack) + func (t *TracingProviderHandler) Name() string + type TransportHandler struct + func (th *TransportHandler) Handle(chain *Chain, i *invocation.Invocation, cb invocation.ResponseCallBack) + func (th *TransportHandler) Name() string