catalog

package

Go to main page

Versions in this module

v1

v1.3.1

Nov 27, 2017

Changes in this version

type UrlListener

+ func (u *UrlListener) Stop()

v1.3.0

Nov 27, 2017

Changes in this version

+ const ClientTimeout

+ const DefaultRetries

type ChangeEvent

+ func (j *ChangeEvent) MarshalJSON() ([]byte, error)

+ func (j *ChangeEvent) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (j *ChangeEvent) UnmarshalJSON(input []byte) error

+ func (j *ChangeEvent) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

type Listener

+ Managed func() bool

type Server

+ func (j *Server) MarshalJSON() ([]byte, error)

+ func (j *Server) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (j *Server) UnmarshalJSON(input []byte) error

+ func (j *Server) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

type ServicesState

+ func (j *ServicesState) MarshalJSON() ([]byte, error)

+ func (j *ServicesState) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (j *ServicesState) UnmarshalJSON(input []byte) error

+ func (j *ServicesState) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

+ func (state *ServicesState) GetListeners() []Listener

+ func (state *ServicesState) TrackLocalListeners(fn func() []Listener, looper director.Looper)

type UrlListener

+ func (u *UrlListener) Managed() bool

+ func (u *UrlListener) SetName(name string)

v1.2.0

Apr 19, 2017

v1.1.3

Mar 14, 2017

v1.1.2

Mar 6, 2017

v1.1.1

Mar 3, 2017

Changes in this version

type ServicesState

+ func (state *ServicesState) RemoveListener(name string) error

v1.1.0

Feb 14, 2017

Changes in this version

+ func DecodeStream(input io.Reader, callback func(map[string][]*service.Service, error) error) error

+ type Listener interface

+ Chan func() chan ChangeEvent

+ Name func() string

type ServicesState

+ ServiceMsgs chan service.Service

+ func (state *ServicesState) ProcessServiceMsgs(looper director.Looper)

type UrlListener

+ func (u *UrlListener) Chan() chan ChangeEvent

+ func (u *UrlListener) Name() string

v1.0.0

Aug 30, 2016

Changes in this version

+ const ALIVE_BROADCAST_INTERVAL

+ const ALIVE_COUNT

+ const ALIVE_LIFESPAN

+ const ALIVE_SLEEP_INTERVAL

+ const CLIENT_TIMEOUT

+ const DEFAULT_RETRIES

+ const TOMBSTONE_COUNT

+ const TOMBSTONE_LIFESPAN

+ const TOMBSTONE_RETRANSMIT

+ const TOMBSTONE_SLEEP_INTERVAL

+ type ChangeEvent struct

+ PreviousStatus int

+ Service service.Service

+ Time time.Time

+ type Server struct

+ LastChanged time.Time

+ LastUpdated time.Time

+ Name string

+ Services map[string]*service.Service

+ func NewServer(name string) *Server

+ func (s *Server) SortedServices() []*service.Service

+ func (server *Server) HasService(id string) bool

+ type ServerByName []*Server

+ func (s ServerByName) Len() int

+ func (s ServerByName) Less(i, j int) bool

+ func (s ServerByName) Swap(i, j int)

+ type ServicesByAge []*service.Service

+ func (s ServicesByAge) Len() int

+ func (s ServicesByAge) Less(i, j int) bool

+ func (s ServicesByAge) Swap(i, j int)

+ type ServicesState struct

+ Broadcasts chan [][]byte

+ ClusterName string

+ Hostname string

+ LastChanged time.Time

+ Servers map[string]*Server

+ func Decode(data []byte) (*ServicesState, error)

+ func NewServicesState() *ServicesState

+ func (state *ServicesState) AddListener(listener chan ChangeEvent)

+ func (state *ServicesState) AddServiceEntry(entry service.Service)

+ func (state *ServicesState) BroadcastServices(fn func() []service.Service, looper director.Looper)

+ func (state *ServicesState) BroadcastTombstones(fn func() []service.Service, looper director.Looper)

+ func (state *ServicesState) ByService() map[string][]*service.Service

+ func (state *ServicesState) EachLocalService(fn func(hostname *string, serviceId *string, svc *service.Service))

+ func (state *ServicesState) EachServer(fn func(hostname *string, server *Server))

+ func (state *ServicesState) EachService(fn func(hostname *string, serviceId *string, svc *service.Service))

+ func (state *ServicesState) EachServiceSorted(fn func(hostname *string, serviceId *string, svc *service.Service))

+ func (state *ServicesState) Encode() []byte

+ func (state *ServicesState) ExpireServer(hostname string)

+ func (state *ServicesState) Format(list *memberlist.Memberlist) string

+ func (state *ServicesState) GetLocalService(id string) *service.Service

+ func (state *ServicesState) HasServer(hostname string) bool

+ func (state *ServicesState) IsNewService(svc *service.Service) bool

+ func (state *ServicesState) Merge(otherState *ServicesState)

+ func (state *ServicesState) NotifyListeners(svc *service.Service, previousStatus int, changedTime time.Time)

+ func (state *ServicesState) Print(list *memberlist.Memberlist)

+ func (state *ServicesState) SendServices(services []service.Service, looper director.Looper)

+ func (state *ServicesState) ServiceChanged(svc *service.Service, previousStatus int, updated time.Time)

+ func (state *ServicesState) SortedServers() []*Server

+ func (state *ServicesState) TombstoneOthersServices() []service.Service

+ func (state *ServicesState) TombstoneServices(hostname string, containerList []service.Service) []service.Service

+ func (state *ServicesState) TrackNewServices(fn func() []service.Service, looper director.Looper)

+ type StateChangedEvent struct

+ ChangeEvent ChangeEvent

+ State ServicesState

+ type UrlListener struct

+ Client *http.Client

+ Retries int

+ Url string

+ func NewUrlListener(url string) *UrlListener

+ func (u *UrlListener) Watch(state *ServicesState)

Incompatible versions in this module

v2.0.1+incompatible

Mar 23, 2018

v2.0.0+incompatible

Dec 5, 2017

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL