route

Documentation

Index

• type Endpoint
  • func NewEndpoint(appId, host string, port uint16, privateInstanceId string, ...) *Endpoint
  • func (e *Endpoint) CanonicalAddr() string
  • func (e *Endpoint) MarshalJSON() ([]byte, error)
  • func (e *Endpoint) ToLogData() interface{}
• type EndpointIterator
• type Pool
  • func NewPool(retryAfterFailure time.Duration, contextPath string) *Pool
  • func (p *Pool) ContextPath() string
  • func (p *Pool) Each(f func(endpoint *Endpoint))
  • func (p *Pool) Endpoints(initial string) EndpointIterator
  • func (p *Pool) IsEmpty() bool
  • func (p *Pool) MarkUpdated(t time.Time)
  • func (p *Pool) MarshalJSON() ([]byte, error)
  • func (p *Pool) PruneEndpoints(defaultThreshold time.Duration)
  • func (p *Pool) Put(endpoint *Endpoint) bool
  • func (p *Pool) Remove(endpoint *Endpoint) bool
  • func (p *Pool) RouteServiceUrl() string
• type Uri
  • func (u Uri) NextWildcard() (Uri, error)
  • func (u Uri) RouteKey() Uri
  • func (u Uri) String() string
  • func (u Uri) ToLower() Uri

Types

type Endpoint

type Endpoint struct {
	ApplicationId string

	Tags              map[string]string
	PrivateInstanceId string

	RouteServiceUrl string
	// contains filtered or unexported fields
}

func NewEndpoint

func NewEndpoint(appId, host string, port uint16, privateInstanceId string,
	tags map[string]string, staleThresholdInSeconds int, routeServiceUrl string) *Endpoint

func (*Endpoint) CanonicalAddr

func (e *Endpoint) CanonicalAddr() string

func (*Endpoint) MarshalJSON

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

func (*Endpoint) ToLogData

func (e *Endpoint) ToLogData() interface{}

type EndpointIterator

type EndpointIterator interface {
	Next() *Endpoint
	EndpointFailed()
}

type Pool

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

func NewPool

func NewPool(retryAfterFailure time.Duration, contextPath string) *Pool

func (*Pool) ContextPath

func (p *Pool) ContextPath() string

func (*Pool) Each

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

func (*Pool) Endpoints

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

func (*Pool) IsEmpty

func (p *Pool) IsEmpty() bool

func (*Pool) MarkUpdated

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

func (*Pool) MarshalJSON

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

func (*Pool) PruneEndpoints

func (p *Pool) PruneEndpoints(defaultThreshold time.Duration)

func (*Pool) Put

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

func (*Pool) Remove

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

func (*Pool) RouteServiceUrl

func (p *Pool) RouteServiceUrl() string

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