handler

Documentation

Index

• Constants
• Variables
• func CreateChains(chainType string, handlerNameMap map[string]string) error
• func GetFallbackFun(cmd, t string, i *invocation.Invocation, finish chan *invocation.Response, ...) (func(error) error, error)
• func GetFaultConfig(protocol, microServiceName, schemaID, operationID string) model.Fault
• func ProcessSpecialProtocol(inv *invocation.Invocation)
• func ProcessSuccessiveFailure(i *invocation.Invocation)
• func RegisterHandler(name string, f func() Handler) error
• func WriteBackErr(err error, status int, cb invocation.ResponseCallBack)
• type BizKeeperConsumerHandler
  • func (bk *BizKeeperConsumerHandler) Handle(chain *Chain, i *invocation.Invocation, cb invocation.ResponseCallBack)
  • func (bk *BizKeeperConsumerHandler) Name() string
• type BizKeeperProviderHandler
  • func (bk *BizKeeperProviderHandler) Handle(chain *Chain, i *invocation.Invocation, cb invocation.ResponseCallBack)
  • func (bk *BizKeeperProviderHandler) Name() string
• type Chain
  • 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)
• type ChainOption
  • func WithChainName(name string) ChainOption
• type ChainOptions
• type ConsumerRateLimiterHandler
  • func (rl *ConsumerRateLimiterHandler) Handle(chain *Chain, i *invocation.Invocation, cb invocation.ResponseCallBack)
  • func (rl *ConsumerRateLimiterHandler) Name() string
• type FaultHandler
  • func (rl *FaultHandler) Handle(chain *Chain, inv *invocation.Invocation, cb invocation.ResponseCallBack)
  • func (rl *FaultHandler) Name() string
• type Handler
  • func CreateHandler(name string) (Handler, error)
• type LBHandler
  • func (lb *LBHandler) Handle(chain *Chain, i *invocation.Invocation, cb invocation.ResponseCallBack)
  • func (lb *LBHandler) Name() string
• type ProviderRateLimiterHandler
  • func (rl *ProviderRateLimiterHandler) Handle(chain *Chain, i *invocation.Invocation, cb invocation.ResponseCallBack)
  • func (rl *ProviderRateLimiterHandler) Name() string
• type RouterHandler
  • func (ph *RouterHandler) Handle(chain *Chain, i *invocation.Invocation, cb invocation.ResponseCallBack)
  • func (ph *RouterHandler) Name() string
• type TracingConsumerHandler
  • func (t *TracingConsumerHandler) Handle(chain *Chain, i *invocation.Invocation, cb invocation.ResponseCallBack)
  • func (t *TracingConsumerHandler) Name() string
• type TracingProviderHandler
  • func (t *TracingProviderHandler) Handle(chain *Chain, i *invocation.Invocation, cb invocation.ResponseCallBack)
  • func (t *TracingProviderHandler) Name() string
• type TransportHandler
  • func (th *TransportHandler) Handle(chain *Chain, i *invocation.Invocation, cb invocation.ResponseCallBack)
  • func (th *TransportHandler) Name() string

Constants

const (
	//consumer chain
	Transport           = "transport"
	Loadbalance         = "loadbalance"
	BizkeeperConsumer   = "bizkeeper-consumer"
	TracingConsumer     = "tracing-consumer"
	RateLimiterConsumer = "ratelimiter-consumer"
	Router              = "router"
	FaultInject         = "fault-inject"
	SkyWalkingConsumer  = "skywalking-consumer"

	//provider chain
	RateLimiterProvider = "ratelimiter-provider"
	TracingProvider     = "tracing-provider"
	BizKeeperProvider   = "bizkeeper-provider"
	SkyWalkingProvider  = "skywalking-provider"
)

constant keys for handlers

const (
	FaultHandlerName = "fault-inject"
)

constant for fault handler name

const (
	Name = "bizkeeper-consumer"
)

constant for bizkeeper-consumer

Variables

var ChainMap = make(map[string]*Chain)

ChainMap just concurrent read

var ErrDuplicatedHandler = errors.New("duplicated handler registration")

ErrDuplicatedHandler means you registered more than 1 handler with same name

var HandlerFuncMap = make(map[string]func() Handler)

HandlerFuncMap handler function map

Functions

func CreateChains

func CreateChains(chainType string, handlerNameMap map[string]string) error

CreateChains create the chains based on type and handler map

func GetFallbackFun

func GetFallbackFun(cmd, t string, i *invocation.Invocation, finish chan *invocation.Response, isForce bool) (func(error) error, error)

GetFallbackFun get fallback function

func GetFaultConfig

func GetFaultConfig(protocol, microServiceName, schemaID, operationID string) model.Fault

GetFaultConfig get faultconfig

func ProcessSpecialProtocol

func ProcessSpecialProtocol(inv *invocation.Invocation)

ProcessSpecialProtocol handles special logic for protocol

func ProcessSuccessiveFailure

func ProcessSuccessiveFailure(i *invocation.Invocation)

ProcessSuccessiveFailure handles special logic for protocol

func RegisterHandler

func RegisterHandler(name string, f func() Handler) error

RegisterHandler Let developer custom handler

func WriteBackErr

func WriteBackErr(err error, status int, cb invocation.ResponseCallBack)

WriteBackErr write err and callback

Types

type BizKeeperConsumerHandler

type BizKeeperConsumerHandler struct{}

BizKeeperConsumerHandler bizkeeper consumer handler

func (*BizKeeperConsumerHandler) Handle

func (bk *BizKeeperConsumerHandler) Handle(chain *Chain, i *invocation.Invocation, cb invocation.ResponseCallBack)

Handle function is for to handle the chain

func (*BizKeeperConsumerHandler) Name

func (bk *BizKeeperConsumerHandler) Name() string

Name is for to represent the name of bizkeeper handler

type BizKeeperProviderHandler

type BizKeeperProviderHandler struct{}

BizKeeperProviderHandler bizkeeper provider handler

func (*BizKeeperProviderHandler) Handle

func (bk *BizKeeperProviderHandler) Handle(chain *Chain, i *invocation.Invocation, cb invocation.ResponseCallBack)

Handle handler for bizkeeper provider

func (*BizKeeperProviderHandler) Name

func (bk *BizKeeperProviderHandler) Name() string

Name returns bizkeeper-provider string

type Chain

type Chain struct {
	ServiceType string
	Name        string
	Handlers    []Handler
}

Chain struct for service and handlers

func CreateChain

func CreateChain(serviceType string, chainName string, handlerNames ...string) (*Chain, error)

CreateChain create consumer or provider's chain,the handlers is different

func GetChain

func GetChain(serviceType string, name string) (*Chain, error)

GetChain is to get chain

func (*Chain) AddHandler

func (c *Chain) AddHandler(h Handler)

AddHandler chain can add a handler

func (*Chain) Next

func (c *Chain) Next(i *invocation.Invocation, f invocation.ResponseCallBack)

Next is for to handle next handler in the chain

type ChainOption

type ChainOption func(*ChainOptions)

ChainOption is a function name

func WithChainName

func WithChainName(name string) ChainOption

WithChainName returns the name of the chain option

type ChainOptions

type ChainOptions struct {
	Name string
}

ChainOptions chain options

type ConsumerRateLimiterHandler

type ConsumerRateLimiterHandler struct{}

ConsumerRateLimiterHandler consumer rate limiter handler

func (*ConsumerRateLimiterHandler) Handle

func (rl *ConsumerRateLimiterHandler) Handle(chain *Chain, i *invocation.Invocation, cb invocation.ResponseCallBack)

Handle is handles the consumer rate limiter APIs

func (*ConsumerRateLimiterHandler) Name

func (rl *ConsumerRateLimiterHandler) Name() string

Name returns name

type FaultHandler

type FaultHandler struct{}

FaultHandler handler

func (*FaultHandler) Handle

func (rl *FaultHandler) Handle(chain *Chain, inv *invocation.Invocation, cb invocation.ResponseCallBack)

Handle is to handle the API

func (*FaultHandler) Name

func (rl *FaultHandler) Name() string

Name function returns fault-inject string

type Handler

type Handler interface {
	// handle invocation transportation,and tr response
	Handle(*Chain, *invocation.Invocation, invocation.ResponseCallBack)
	Name() string
}

Handler interface for handlers

func CreateHandler

func CreateHandler(name string) (Handler, error)

CreateHandler create a new handler by name your registered

type LBHandler

type LBHandler struct{}

LBHandler loadbalancer handler struct

func (*LBHandler) Handle

func (lb *LBHandler) Handle(chain *Chain, i *invocation.Invocation, cb invocation.ResponseCallBack)

Handle to handle the load balancing

func (*LBHandler) Name

func (lb *LBHandler) Name() string

Name returns loadbalancer string

type ProviderRateLimiterHandler

type ProviderRateLimiterHandler struct{}

ProviderRateLimiterHandler provider rate limiter handler

func (*ProviderRateLimiterHandler) Handle

func (rl *ProviderRateLimiterHandler) Handle(chain *Chain, i *invocation.Invocation, cb invocation.ResponseCallBack)

Handle is to handle provider rateLimiter things

func (*ProviderRateLimiterHandler) Name

func (rl *ProviderRateLimiterHandler) Name() string

Name returns the name providerratelimiter

type RouterHandler

type RouterHandler struct{}

RouterHandler router handler

func (*RouterHandler) Handle

func (ph *RouterHandler) Handle(chain *Chain, i *invocation.Invocation, cb invocation.ResponseCallBack)

Handle is to handle the router related things

func (*RouterHandler) Name

func (ph *RouterHandler) Name() string

Name returns the router string

type TracingConsumerHandler

type TracingConsumerHandler struct{}

TracingConsumerHandler tracing consumer handler

func (*TracingConsumerHandler) Handle

func (t *TracingConsumerHandler) Handle(chain *Chain, i *invocation.Invocation, cb invocation.ResponseCallBack)

Handle is handle consumer tracing related things

func (*TracingConsumerHandler) Name

func (t *TracingConsumerHandler) Name() string

Name returns tracing-consumer string

type TracingProviderHandler

type TracingProviderHandler struct{}

TracingProviderHandler tracing provider handler

func (*TracingProviderHandler) Handle

func (t *TracingProviderHandler) Handle(chain *Chain, i *invocation.Invocation, cb invocation.ResponseCallBack)

Handle is to handle the provider tracing related things

func (*TracingProviderHandler) Name

func (t *TracingProviderHandler) Name() string

Name returns tracing-provider string

type TransportHandler

type TransportHandler struct{}

TransportHandler transport handler

func (*TransportHandler) Handle

func (th *TransportHandler) Handle(chain *Chain, i *invocation.Invocation, cb invocation.ResponseCallBack)

Handle is to handle transport related things

func (*TransportHandler) Name

func (th *TransportHandler) Name() string

Name returns transport string