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) *Pool
  • 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) PruneBefore(t time.Time)
  • func (p *Pool) Put(endpoint *Endpoint) bool
  • func (p *Pool) Remove(endpoint *Endpoint) bool
• type Uri
  • func (u Uri) ToLower() Uri

Types

type Endpoint

type Endpoint struct {
	ApplicationId string

	Tags              map[string]string
	PrivateInstanceId string
	// contains filtered or unexported fields
}

func NewEndpoint

func NewEndpoint(appId, host string, port uint16, privateInstanceId string,
	tags map[string]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) *Pool

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) PruneBefore

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

func (*Pool) Put

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

func (*Pool) Remove

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

type Uri

type Uri string

func (Uri) ToLower

func (u Uri) ToLower() Uri