endpoints

Nov 12, 2024

Changes in this version

type InfoShort

+ AddressHash uint64

+ func NewInfoShortFromParams(location, address string, nodeID, port uint32) InfoShort

Sep 23, 2024

Changes in this version

+ type Filter struct

+ Prefer *Prefer

+ Require *Require

+ func NewFilter() *Filter

+ func (f *Filter) Filter(endpoints []*Ydb_Discovery.EndpointInfo) (preferred []*Ydb_Discovery.EndpointInfo, ...)

+ func (f *Filter) WithQueryService() *Filter

+ type Prefer struct

+ Locations []string

+ type Require struct

+ Locations []string

+ Services []string

Sep 16, 2024

Changes in this version

+ type Announce struct

+ Add Map

+ Del []InfoShort

+ Update Map

+ type DB struct

+ func NewDB() DB

+ func (db *DB) Compare(endpoints []*Ydb_Discovery.EndpointInfo) bool

+ func (db *DB) GetAll() Map

+ func (db *DB) Update(endpoints []*Ydb_Discovery.EndpointInfo) (Announce, int, int)

+ type InfoShort struct

+ Address string

+ Location string

+ NodeID uint32

+ Port uint32

+ func NewInfoShort(ep *Ydb_Discovery.EndpointInfo) InfoShort

+ func (eis *InfoShort) GetAddress() string

+ func (eis *InfoShort) GetPort() uint32

+ type Map map[InfoShort]*Ydb_Discovery.EndpointInfo