Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Announce ¶
type Announce struct {
Add Map // contains newly discovered endpoints
Update Map // contains endpoints with changes (reserved for later use with load factor)
Del []InfoShort // contains endpoints that are no longer present in YDB cluster
}
Announce is helpful message for consumers of this service about changes in YDB endpoints. For example dispatcher uses it to adjust balancing tree.
type DB ¶
type DB struct {
// contains filtered or unexported fields
}
DB is thread safe in-memory storage for endpoints.
func (*DB) Compare ¶
func (db *DB) Compare(endpoints []*Ydb_Discovery.EndpointInfo) bool
Compare takes current state of endpoints and compares it with internal endpoints Map. It returns true if incoming state is identical to internal or false otherwise.
func (*DB) Update ¶
func (db *DB) Update(endpoints []*Ydb_Discovery.EndpointInfo) (Announce, int, int)
Update takes current state of endpoints and - updates internal DB accordingly - constructs endpoints announcement that reflects performed changes.
type InfoShort ¶
InfoShort uniquely identifies YDB endpoint.
func NewInfoShort ¶
func NewInfoShort(ep *Ydb_Discovery.EndpointInfo) InfoShort
func (*InfoShort) GetAddress ¶
type Map ¶
type Map map[InfoShort]*Ydb_Discovery.EndpointInfo
Map stores endpoints as kay-value structure.
Source Files
Click to show internal directories.
Click to hide internal directories.