Versions in this module Expand all Collapse all v0 v0.0.2 Sep 5, 2019 Changes in this version + type DynamicOptions interface + ConfigServiceClient func() client.Client + InstrumentOptions func() utils.Options + QueryOptions func() services.QueryOptions + ServiceID func() services.ServiceID + ServicesOverrideOptions func() services.OverrideOptions + SetConfigServiceClient func(c client.Client) DynamicOptions + SetInstrumentOptions func(value utils.Options) DynamicOptions + SetQueryOptions func(value services.QueryOptions) DynamicOptions + SetServiceID func(s services.ServiceID) DynamicOptions + SetServicesOverrideOptions func(opts services.OverrideOptions) DynamicOptions + Validate func() error + func NewDynamicOptions() DynamicOptions + type DynamicTopology interface + MarkShardsAvailable func(instanceID string, shardIDs ...uint32) error + type HealthTrackingDynamicTopoloy interface + MarkHostHealthy func(host Host) error + MarkHostUnhealthy func(host Host) error + func NewHealthTrackingDynamicTopology(opts DynamicOptions) (HealthTrackingDynamicTopoloy, error) + type Host interface + Address func() string + ID func() string + String func() string + func NewHost(id, address string) Host + type HostID string + type HostShardConfig struct + HostID string + ListenAddress string + type HostShardSet interface + Host func() Host + ShardSet func() shard.ShardSet + func NewHostShardSet(host Host, shardSet aresShard.ShardSet) HostShardSet + func NewHostShardSetFromServiceInstance(si services.ServiceInstance) (HostShardSet, error) + type HostShardState struct + Host Host + ShardState m3Shard.State + type Initializer interface + Init func() (Topology, error) + TopologyIsSet func() (bool, error) + func NewDynamicInitializer(opts DynamicOptions) Initializer + func NewStaticInitializer(opts StaticOptions) Initializer + type Map interface + HostShardSets func() []HostShardSet + Hosts func() []Host + HostsLen func() int + LookupHostShardSet func(hostID string) (HostShardSet, bool) + Replicas func() int + RouteShard func(shard uint32) ([]Host, error) + ShardSet func() shard.ShardSet + func NewStaticMap(opts StaticOptions) Map + type MapProvider interface + TopologyMap func() (Map, error) + type MapWatch interface + C func() <-chan struct{} + Close func() + Get func() Map + func NewMapWatch(w xwatch.Watch) MapWatch + type ShardID int + type ShardOwner interface + GetOwnedShards func() []int + func NewStaticShardOwner(shards []int) ShardOwner + func NewTopologyShardOwner(topo Topology) ShardOwner + type ShardStates map[ShardID]map[HostID]HostShardState + type StateSnapshot struct + ShardStates ShardStates + type StaticConfiguration struct + Hosts []HostShardConfig + Replicas int + Shards int + type StaticOptions interface + HostShardSets func() []HostShardSet + Replicas func() int + SetHostShardSets func(value []HostShardSet) StaticOptions + SetReplicas func(value int) StaticOptions + SetShardSet func(value shard.ShardSet) StaticOptions + ShardSet func() shard.ShardSet + Validate func() error + func NewStaticOptions() StaticOptions + type Topology interface + Close func() + Get func() Map + Watch func() (MapWatch, error) + func NewStaticTopology(opts StaticOptions) Topology
Go to main page