filter

package
v0.0.0-...-b9d6073 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 19, 2018 License: Apache-2.0 Imports: 11 Imported by: 1

Documentation

Overview

Package filter is some default filter implements.

Index

Constants

View Source 
const (
	CircuitBreakerEnable        = "circuitBreakerEnable"
	CircuitBreakerTimeoutField  = "circuitBreakerTimeout"
	MaxConcurrentRequestsField  = "maxConcurrentRequests"
	RequestVolumeThresholdField = "requestVolumeThreshold"
	SleepWindowField            = "sleepWindow"
	ErrorPercentThreshold       = "errorPercentThreshold"
)
View Source 
const (
	AccessLog      = "accessLog"
	Metrics        = "metrics"
	CircuitBreaker = "circuitbreaker"
	FailFast       = "failfast"
)

ext name

Variables

This section is empty.

Functions

func RegistDefaultFilters 

func RegistDefaultFilters(extFactory motan.ExtentionFactory)

Types

type AccessLogEndPointFilter 

type AccessLogEndPointFilter struct {
	// contains filtered or unexported fields
}

func (*AccessLogEndPointFilter) Filter 

func (t *AccessLogEndPointFilter) Filter(caller motan.Caller, request motan.Request) motan.Response

Filter : Filter

func (*AccessLogEndPointFilter) GetIndex 

func (t *AccessLogEndPointFilter) GetIndex() int

func (*AccessLogEndPointFilter) GetName 

func (t *AccessLogEndPointFilter) GetName() string

func (*AccessLogEndPointFilter) GetNext 

func (t *AccessLogEndPointFilter) GetNext() motan.EndPointFilter

func (*AccessLogEndPointFilter) GetType 

func (t *AccessLogEndPointFilter) GetType() int32

func (*AccessLogEndPointFilter) HasNext 

func (t *AccessLogEndPointFilter) HasNext() bool

func (*AccessLogEndPointFilter) NewFilter 

func (t *AccessLogEndPointFilter) NewFilter(url *motan.URL) motan.Filter

func (*AccessLogEndPointFilter) SetNext 

func (t *AccessLogEndPointFilter) SetNext(nextFilter motan.EndPointFilter)

type CircuitBreakerEndPointFilter 

type CircuitBreakerEndPointFilter struct {
	URL *motan.URL
	// contains filtered or unexported fields
}

func (*CircuitBreakerEndPointFilter) Filter 

func (t *CircuitBreakerEndPointFilter) Filter(caller motan.Caller, request motan.Request) motan.Response

func (*CircuitBreakerEndPointFilter) GetIndex 

func (t *CircuitBreakerEndPointFilter) GetIndex() int

func (*CircuitBreakerEndPointFilter) GetName 

func (t *CircuitBreakerEndPointFilter) GetName() string

func (*CircuitBreakerEndPointFilter) GetNext 

func (t *CircuitBreakerEndPointFilter) GetNext() motan.EndPointFilter

func (*CircuitBreakerEndPointFilter) GetType 

func (t *CircuitBreakerEndPointFilter) GetType() int32

func (*CircuitBreakerEndPointFilter) HasNext 

func (t *CircuitBreakerEndPointFilter) HasNext() bool

func (*CircuitBreakerEndPointFilter) NewFilter 

func (t *CircuitBreakerEndPointFilter) NewFilter(url *motan.URL) motan.Filter

func (*CircuitBreakerEndPointFilter) SetNext 

func (t *CircuitBreakerEndPointFilter) SetNext(nextFilter motan.EndPointFilter)

type ClusterMetricsFilter 

type ClusterMetricsFilter struct {
	// contains filtered or unexported fields
}

func (*ClusterMetricsFilter) Filter 

func (c *ClusterMetricsFilter) Filter(haStrategy motan.HaStrategy, loadBalance motan.LoadBalance, request motan.Request) motan.Response

func (*ClusterMetricsFilter) GetIndex 

func (c *ClusterMetricsFilter) GetIndex() int

func (*ClusterMetricsFilter) GetName 

func (c *ClusterMetricsFilter) GetName() string

func (*ClusterMetricsFilter) GetNext 

func (c *ClusterMetricsFilter) GetNext() motan.ClusterFilter

func (*ClusterMetricsFilter) GetType 

func (c *ClusterMetricsFilter) GetType() int32

func (*ClusterMetricsFilter) HasNext 

func (c *ClusterMetricsFilter) HasNext() bool

func (*ClusterMetricsFilter) NewFilter 

func (c *ClusterMetricsFilter) NewFilter(url *motan.URL) motan.Filter

func (*ClusterMetricsFilter) SetNext 

func (c *ClusterMetricsFilter) SetNext(cf motan.ClusterFilter)

type FailfastFilter 

type FailfastFilter struct {
	URL *motan.URL
	// contains filtered or unexported fields
}

func (*FailfastFilter) Filter 

func (e *FailfastFilter) Filter(caller motan.Caller, request motan.Request) motan.Response

func (*FailfastFilter) GetIndex 

func (e *FailfastFilter) GetIndex() int

func (*FailfastFilter) GetName 

func (e *FailfastFilter) GetName() string

func (*FailfastFilter) GetNext 

func (e *FailfastFilter) GetNext() motan.EndPointFilter

func (*FailfastFilter) GetType 

func (e *FailfastFilter) GetType() int32

func (*FailfastFilter) HasNext 

func (e *FailfastFilter) HasNext() bool

func (*FailfastFilter) IsAvailable 

func (e *FailfastFilter) IsAvailable() bool

func (*FailfastFilter) NewFilter 

func (e *FailfastFilter) NewFilter(url *motan.URL) motan.Filter

func (*FailfastFilter) SetNext 

func (e *FailfastFilter) SetNext(nextFilter motan.EndPointFilter)

type MetricsFilter 

type MetricsFilter struct {
	// contains filtered or unexported fields
}

func (*MetricsFilter) Filter 

func (m *MetricsFilter) Filter(caller motan.Caller, request motan.Request) motan.Response

func (*MetricsFilter) GetIndex 

func (m *MetricsFilter) GetIndex() int

func (*MetricsFilter) GetName 

func (m *MetricsFilter) GetName() string

func (*MetricsFilter) GetNext 

func (m *MetricsFilter) GetNext() motan.EndPointFilter

func (*MetricsFilter) GetType 

func (m *MetricsFilter) GetType() int32

func (*MetricsFilter) HasNext 

func (m *MetricsFilter) HasNext() bool

func (*MetricsFilter) NewFilter 

func (m *MetricsFilter) NewFilter(url *motan.URL) motan.Filter

func (*MetricsFilter) SetContext 

func (m *MetricsFilter) SetContext(context *motan.Context)

func (*MetricsFilter) SetNext 

func (m *MetricsFilter) SetNext(e motan.EndPointFilter)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.