Documentation
¶
Index ¶
- func GetElementTable() map[string]func() element.RPCElement
- func NewAdmissioncontrolElement() element.RPCElement
- func NewBandwidthlimitElement() element.RPCElement
- func NewCacheweakElement() element.RPCElement
- func NewCircuitbreakerElement() element.RPCElement
- func NewFirewallElement() element.RPCElement
- func NewMetricsElement() element.RPCElement
- type AdmissioncontrolElement
- type BandwidthlimitElement
- type CacheweakElement
- type CircuitbreakerElement
- type FirewallElement
- type MetricsElement
- func (m *MetricsElement) GetRequestCount() uint64
- func (m *MetricsElement) Name() string
- func (m *MetricsElement) ProcessRequest(ctx context.Context, req *element.RPCRequest) (*element.RPCRequest, error)
- func (m *MetricsElement) ProcessResponse(ctx context.Context, resp *element.RPCResponse) (*element.RPCResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetElementTable ¶
func GetElementTable() map[string]func() element.RPCElement
func NewAdmissioncontrolElement ¶
func NewAdmissioncontrolElement() element.RPCElement
func NewBandwidthlimitElement ¶
func NewBandwidthlimitElement() element.RPCElement
func NewCacheweakElement ¶
func NewCacheweakElement() element.RPCElement
func NewCircuitbreakerElement ¶
func NewCircuitbreakerElement() element.RPCElement
func NewFirewallElement ¶
func NewFirewallElement() element.RPCElement
func NewMetricsElement ¶
func NewMetricsElement() element.RPCElement
NewMetricsElement creates a new metrics element and starts the metrics printer
Types ¶
type AdmissioncontrolElement ¶
type AdmissioncontrolElement struct {
// contains filtered or unexported fields
}
func (*AdmissioncontrolElement) Name ¶
func (e *AdmissioncontrolElement) Name() string
func (*AdmissioncontrolElement) ProcessRequest ¶
func (e *AdmissioncontrolElement) ProcessRequest(ctx context.Context, req *element.RPCRequest) (*element.RPCRequest, error)
func (*AdmissioncontrolElement) ProcessResponse ¶
func (e *AdmissioncontrolElement) ProcessResponse(ctx context.Context, resp *element.RPCResponse) (*element.RPCResponse, error)
type BandwidthlimitElement ¶
type BandwidthlimitElement struct {
// contains filtered or unexported fields
}
func (*BandwidthlimitElement) Name ¶
func (e *BandwidthlimitElement) Name() string
func (*BandwidthlimitElement) ProcessRequest ¶
func (e *BandwidthlimitElement) ProcessRequest(ctx context.Context, req *element.RPCRequest) (*element.RPCRequest, error)
func (*BandwidthlimitElement) ProcessResponse ¶
func (e *BandwidthlimitElement) ProcessResponse(ctx context.Context, resp *element.RPCResponse) (*element.RPCResponse, error)
type CacheweakElement ¶
type CacheweakElement struct {
// contains filtered or unexported fields
}
func (*CacheweakElement) Name ¶
func (e *CacheweakElement) Name() string
func (*CacheweakElement) ProcessRequest ¶
func (e *CacheweakElement) ProcessRequest(ctx context.Context, req *element.RPCRequest) (*element.RPCRequest, error)
func (*CacheweakElement) ProcessResponse ¶
func (e *CacheweakElement) ProcessResponse(ctx context.Context, resp *element.RPCResponse) (*element.RPCResponse, error)
type CircuitbreakerElement ¶
type CircuitbreakerElement struct {
// contains filtered or unexported fields
}
func (*CircuitbreakerElement) Name ¶
func (e *CircuitbreakerElement) Name() string
func (*CircuitbreakerElement) ProcessRequest ¶
func (e *CircuitbreakerElement) ProcessRequest(ctx context.Context, req *element.RPCRequest) (*element.RPCRequest, error)
func (*CircuitbreakerElement) ProcessResponse ¶
func (e *CircuitbreakerElement) ProcessResponse(ctx context.Context, resp *element.RPCResponse) (*element.RPCResponse, error)
type FirewallElement ¶
type FirewallElement struct {
// contains filtered or unexported fields
}
func (*FirewallElement) Name ¶
func (e *FirewallElement) Name() string
func (*FirewallElement) ProcessRequest ¶
func (e *FirewallElement) ProcessRequest(ctx context.Context, req *element.RPCRequest) (*element.RPCRequest, error)
func (*FirewallElement) ProcessResponse ¶
func (e *FirewallElement) ProcessResponse(ctx context.Context, resp *element.RPCResponse) (*element.RPCResponse, error)
type MetricsElement ¶
type MetricsElement struct {
// contains filtered or unexported fields
}
MetricsElement tracks various RPC metrics
func (*MetricsElement) GetRequestCount ¶
func (m *MetricsElement) GetRequestCount() uint64
GetRequestCount returns the total number of requests processed
func (*MetricsElement) Name ¶
func (m *MetricsElement) Name() string
Name returns the name of the metrics element
func (*MetricsElement) ProcessRequest ¶
func (m *MetricsElement) ProcessRequest(ctx context.Context, req *element.RPCRequest) (*element.RPCRequest, error)
ProcessRequest increments the request counter and passes through the request
func (*MetricsElement) ProcessResponse ¶
func (m *MetricsElement) ProcessResponse(ctx context.Context, resp *element.RPCResponse) (*element.RPCResponse, error)
ProcessResponse passes through the response without modification
Source Files
Click to show internal directories.
Click to hide internal directories.