route

package
v0.0.0-...-2fc2a81 Latest Latest
Warning

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

 Go to latest Published: Aug 28, 2018 License: Apache-2.0, BSD-2-Clause-Views, BSD-3-Clause, + 1 more Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	UNMODIFIED = PoolPutResult(iota)
	UPDATED
	ADDED
)

Variables

This section is empty.

Functions

func PoolsMatch 

func PoolsMatch(p1, p2 *Pool) bool

Types

type Counter 

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

func NewCounter 

func NewCounter(initial int64) *Counter

func (*Counter) Count 

func (c *Counter) Count() int64

func (*Counter) Decrement 

func (c *Counter) Decrement()

func (*Counter) Increment 

func (c *Counter) Increment()

type Endpoint 

type Endpoint struct {
	sync.RWMutex
	ApplicationId string

	Tags                 map[string]string
	ServerCertDomainSAN  string
	PrivateInstanceId    string
	StaleThreshold       time.Duration
	RouteServiceUrl      string
	PrivateInstanceIndex string
	ModificationTag      models.ModificationTag
	Stats                *Stats
	IsolationSegment     string

	RoundTripper ProxyRoundTripper
	UpdatedAt    time.Time
	// contains filtered or unexported fields
}

func NewEndpoint 

func NewEndpoint(opts *EndpointOpts) *Endpoint

func (*Endpoint) CanonicalAddr 

func (e *Endpoint) CanonicalAddr() string

func (*Endpoint) Component 

func (rm *Endpoint) Component() string

func (*Endpoint) IsTLS 

func (e *Endpoint) IsTLS() bool

func (*Endpoint) MarshalJSON 

func (e *Endpoint) MarshalJSON() ([]byte, error)

func (*Endpoint) ToLogData 

func (e *Endpoint) ToLogData() []zap.Field

type EndpointIterator 

type EndpointIterator interface {
	Next() *Endpoint
	EndpointFailed(err error)
	PreRequest(e *Endpoint)
	PostRequest(e *Endpoint)
}

func NewLeastConnection 

func NewLeastConnection(p *Pool, initial string) EndpointIterator

func NewRoundRobin 

func NewRoundRobin(p *Pool, initial string) EndpointIterator

type EndpointOpts 

type EndpointOpts struct {
	AppId                   string
	Host                    string
	Port                    uint16
	ServerCertDomainSAN     string
	PrivateInstanceId       string
	PrivateInstanceIndex    string
	Tags                    map[string]string
	StaleThresholdInSeconds int
	RouteServiceUrl         string
	ModificationTag         models.ModificationTag
	IsolationSegment        string
	UseTLS                  bool
	UpdatedAt               time.Time
}

type LeastConnection 

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

func (*LeastConnection) EndpointFailed 

func (r *LeastConnection) EndpointFailed(err error)

func (*LeastConnection) Next 

func (r *LeastConnection) Next() *Endpoint

func (*LeastConnection) PostRequest 

func (r *LeastConnection) PostRequest(e *Endpoint)

func (*LeastConnection) PreRequest 

func (r *LeastConnection) PreRequest(e *Endpoint)

type Pool 

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

func NewPool 

func NewPool(opts *PoolOpts) *Pool

func (*Pool) ContextPath 

func (p *Pool) ContextPath() string

func (*Pool) Each 

func (p *Pool) Each(f func(endpoint *Endpoint))

func (*Pool) EndpointFailed 

func (p *Pool) EndpointFailed(endpoint *Endpoint, err error)

func (*Pool) Endpoints 

func (p *Pool) Endpoints(defaultLoadBalance, initial string) EndpointIterator

func (*Pool) Host 

func (p *Pool) Host() string

func (*Pool) IsEmpty 

func (p *Pool) IsEmpty() bool

func (*Pool) IsOverloaded 

func (p *Pool) IsOverloaded() bool

func (*Pool) MarkUpdated 

func (p *Pool) MarkUpdated(t time.Time)

func (*Pool) MarshalJSON 

func (p *Pool) MarshalJSON() ([]byte, error)

func (*Pool) MaxConnsPerBackend 

func (p *Pool) MaxConnsPerBackend() int64

func (*Pool) PruneEndpoints 

func (p *Pool) PruneEndpoints() []*Endpoint

func (*Pool) Put 

func (p *Pool) Put(endpoint *Endpoint) PoolPutResult

Returns true if endpoint was added or updated, false otherwise

func (*Pool) Remove 

func (p *Pool) Remove(endpoint *Endpoint) bool

Returns true if the endpoint was removed from the Pool, false otherwise.

func (*Pool) RouteServiceUrl 

func (p *Pool) RouteServiceUrl() string

type PoolOpts 

type PoolOpts struct {
	RetryAfterFailure  time.Duration
	Host               string
	ContextPath        string
	MaxConnsPerBackend int64
}

type PoolPutResult 

type PoolPutResult int

type ProxyRoundTripper 

type ProxyRoundTripper interface {
	http.RoundTripper
	CancelRequest(*http.Request)
}

type RoundRobin 

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

func (*RoundRobin) EndpointFailed 

func (r *RoundRobin) EndpointFailed(err error)

func (*RoundRobin) Next 

func (r *RoundRobin) Next() *Endpoint

func (*RoundRobin) PostRequest 

func (r *RoundRobin) PostRequest(e *Endpoint)

func (*RoundRobin) PreRequest 

func (r *RoundRobin) PreRequest(e *Endpoint)

type Stats 

type Stats struct {
	NumberConnections *Counter
}

func NewStats 

func NewStats() *Stats

type Uri 

type Uri string

func (Uri) NextWildcard 

func (u Uri) NextWildcard() (Uri, error)

func (Uri) RouteKey 

func (u Uri) RouteKey() Uri

func (Uri) String 

func (u Uri) String() string

func (Uri) ToLower 

func (u Uri) ToLower() Uri

Source Files

View all Source files

Directories

Path Synopsis
Code generated by counterfeiter.
 Code generated by counterfeiter.

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.