Versions in this module Expand all Collapse all v0 v0.0.2 Sep 5, 2019 Changes in this version + type DynamicOptions struct + func (_m *DynamicOptions) ConfigServiceClient() client.Client + func (_m *DynamicOptions) InstrumentOptions() utils.Options + func (_m *DynamicOptions) QueryOptions() services.QueryOptions + func (_m *DynamicOptions) ServiceID() services.ServiceID + func (_m *DynamicOptions) ServicesOverrideOptions() services.OverrideOptions + func (_m *DynamicOptions) SetConfigServiceClient(c client.Client) topology.DynamicOptions + func (_m *DynamicOptions) SetInstrumentOptions(value utils.Options) topology.DynamicOptions + func (_m *DynamicOptions) SetQueryOptions(value services.QueryOptions) topology.DynamicOptions + func (_m *DynamicOptions) SetServiceID(s services.ServiceID) topology.DynamicOptions + func (_m *DynamicOptions) SetServicesOverrideOptions(opts services.OverrideOptions) topology.DynamicOptions + func (_m *DynamicOptions) Validate() error + type DynamicTopology struct + func (_m *DynamicTopology) Close() + func (_m *DynamicTopology) Get() topology.Map + func (_m *DynamicTopology) MarkShardsAvailable(instanceID string, shardIDs ...uint32) error + func (_m *DynamicTopology) Watch() (topology.MapWatch, error) + type HealthTrackingDynamicTopoloy struct + func (_m *HealthTrackingDynamicTopoloy) Close() + func (_m *HealthTrackingDynamicTopoloy) Get() topology.Map + func (_m *HealthTrackingDynamicTopoloy) MarkHostHealthy(host topology.Host) error + func (_m *HealthTrackingDynamicTopoloy) MarkHostUnhealthy(host topology.Host) error + func (_m *HealthTrackingDynamicTopoloy) Watch() (topology.MapWatch, error) + type Host struct + func (_m *Host) Address() string + func (_m *Host) ID() string + func (_m *Host) String() string + type HostShardSet struct + func (_m *HostShardSet) Host() topology.Host + func (_m *HostShardSet) ShardSet() shard.ShardSet + type Initializer struct + func (_m *Initializer) Init() (topology.Topology, error) + func (_m *Initializer) TopologyIsSet() (bool, error) + type Map struct + func (_m *Map) HostShardSets() []topology.HostShardSet + func (_m *Map) Hosts() []topology.Host + func (_m *Map) HostsLen() int + func (_m *Map) LookupHostShardSet(hostID string) (topology.HostShardSet, bool) + func (_m *Map) Replicas() int + func (_m *Map) RouteShard(_a0 uint32) ([]topology.Host, error) + func (_m *Map) ShardSet() shard.ShardSet + type MapProvider struct + func (_m *MapProvider) TopologyMap() (topology.Map, error) + type MapWatch struct + func (_m *MapWatch) C() <-chan struct{} + func (_m *MapWatch) Close() + func (_m *MapWatch) Get() topology.Map + type StaticOptions struct + func (_m *StaticOptions) HostShardSets() []topology.HostShardSet + func (_m *StaticOptions) Replicas() int + func (_m *StaticOptions) SetHostShardSets(value []topology.HostShardSet) topology.StaticOptions + func (_m *StaticOptions) SetReplicas(value int) topology.StaticOptions + func (_m *StaticOptions) SetShardSet(value shard.ShardSet) topology.StaticOptions + func (_m *StaticOptions) ShardSet() shard.ShardSet + func (_m *StaticOptions) Validate() error + type Topology struct + func (_m *Topology) Close() + func (_m *Topology) Get() topology.Map + func (_m *Topology) Watch() (topology.MapWatch, error)
Go to main page