Documentation ¶
Overview ¶
Code generated by mockery v1.0.0
Code generated by mockery v1.0.0 ¶
Code generated by mockery v1.0.0 ¶
Code generated by mockery v1.0.0 ¶
Code generated by mockery v1.0.0 ¶
Code generated by mockery v1.0.0 ¶
Code generated by mockery v1.0.0 ¶
Code generated by mockery v1.0.0 ¶
Code generated by mockery v1.0.0 ¶
Code generated by mockery v1.0.0 ¶
Code generated by mockery v1.0.0
Index ¶
- type DynamicOptions
- 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
- type HealthTrackingDynamicTopoloy
- 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
- type HostShardSet
- type Initializer
- type Map
- 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
- type MapWatch
- type StaticOptions
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DynamicOptions ¶
DynamicOptions is an autogenerated mock type for the DynamicOptions type
func (*DynamicOptions) ConfigServiceClient ¶
func (_m *DynamicOptions) ConfigServiceClient() client.Client
ConfigServiceClient provides a mock function with given fields:
func (*DynamicOptions) InstrumentOptions ¶
func (_m *DynamicOptions) InstrumentOptions() utils.Options
InstrumentOptions provides a mock function with given fields:
func (*DynamicOptions) QueryOptions ¶
func (_m *DynamicOptions) QueryOptions() services.QueryOptions
QueryOptions provides a mock function with given fields:
func (*DynamicOptions) ServiceID ¶
func (_m *DynamicOptions) ServiceID() services.ServiceID
ServiceID provides a mock function with given fields:
func (*DynamicOptions) ServicesOverrideOptions ¶
func (_m *DynamicOptions) ServicesOverrideOptions() services.OverrideOptions
ServicesOverrideOptions provides a mock function with given fields:
func (*DynamicOptions) SetConfigServiceClient ¶
func (_m *DynamicOptions) SetConfigServiceClient(c client.Client) topology.DynamicOptions
SetConfigServiceClient provides a mock function with given fields: c
func (*DynamicOptions) SetInstrumentOptions ¶
func (_m *DynamicOptions) SetInstrumentOptions(value utils.Options) topology.DynamicOptions
SetInstrumentOptions provides a mock function with given fields: value
func (*DynamicOptions) SetQueryOptions ¶
func (_m *DynamicOptions) SetQueryOptions(value services.QueryOptions) topology.DynamicOptions
SetQueryOptions provides a mock function with given fields: value
func (*DynamicOptions) SetServiceID ¶
func (_m *DynamicOptions) SetServiceID(s services.ServiceID) topology.DynamicOptions
SetServiceID provides a mock function with given fields: s
func (*DynamicOptions) SetServicesOverrideOptions ¶
func (_m *DynamicOptions) SetServicesOverrideOptions(opts services.OverrideOptions) topology.DynamicOptions
SetServicesOverrideOptions provides a mock function with given fields: opts
func (*DynamicOptions) Validate ¶
func (_m *DynamicOptions) Validate() error
Validate provides a mock function with given fields:
type DynamicTopology ¶
DynamicTopology is an autogenerated mock type for the DynamicTopology type
func (*DynamicTopology) Close ¶
func (_m *DynamicTopology) Close()
Close provides a mock function with given fields:
func (*DynamicTopology) Get ¶
func (_m *DynamicTopology) Get() topology.Map
Get provides a mock function with given fields:
func (*DynamicTopology) MarkShardsAvailable ¶
func (_m *DynamicTopology) MarkShardsAvailable(instanceID string, shardIDs ...uint32) error
MarkShardsAvailable provides a mock function with given fields: instanceID, shardIDs
type HealthTrackingDynamicTopoloy ¶
HealthTrackingDynamicTopoloy is an autogenerated mock type for the HealthTrackingDynamicTopoloy type
func (*HealthTrackingDynamicTopoloy) Close ¶
func (_m *HealthTrackingDynamicTopoloy) Close()
Close provides a mock function with given fields:
func (*HealthTrackingDynamicTopoloy) Get ¶
func (_m *HealthTrackingDynamicTopoloy) Get() topology.Map
Get provides a mock function with given fields:
func (*HealthTrackingDynamicTopoloy) MarkHostHealthy ¶
func (_m *HealthTrackingDynamicTopoloy) MarkHostHealthy(host topology.Host) error
MarkHostHealthy provides a mock function with given fields: host
func (*HealthTrackingDynamicTopoloy) MarkHostUnhealthy ¶
func (_m *HealthTrackingDynamicTopoloy) MarkHostUnhealthy(host topology.Host) error
MarkHostUnhealthy provides a mock function with given fields: host
type Host ¶
Host is an autogenerated mock type for the Host type
type HostShardSet ¶
HostShardSet is an autogenerated mock type for the HostShardSet type
func (*HostShardSet) Host ¶
func (_m *HostShardSet) Host() topology.Host
Host provides a mock function with given fields:
func (*HostShardSet) ShardSet ¶
func (_m *HostShardSet) ShardSet() shard.ShardSet
ShardSet provides a mock function with given fields:
type Initializer ¶
Initializer is an autogenerated mock type for the Initializer type
func (*Initializer) Init ¶
func (_m *Initializer) Init() (topology.Topology, error)
Init provides a mock function with given fields:
func (*Initializer) TopologyIsSet ¶
func (_m *Initializer) TopologyIsSet() (bool, error)
TopologyIsSet provides a mock function with given fields:
type Map ¶
Map is an autogenerated mock type for the Map type
func (*Map) HostShardSets ¶
func (_m *Map) HostShardSets() []topology.HostShardSet
HostShardSets provides a mock function with given fields:
func (*Map) LookupHostShardSet ¶
func (_m *Map) LookupHostShardSet(hostID string) (topology.HostShardSet, bool)
LookupHostShardSet provides a mock function with given fields: hostID
func (*Map) RouteShard ¶
RouteShard provides a mock function with given fields: _a0
type MapProvider ¶
MapProvider is an autogenerated mock type for the MapProvider type
func (*MapProvider) TopologyMap ¶
func (_m *MapProvider) TopologyMap() (topology.Map, error)
TopologyMap provides a mock function with given fields:
type MapWatch ¶
MapWatch is an autogenerated mock type for the MapWatch type
func (*MapWatch) C ¶
func (_m *MapWatch) C() <-chan struct{}
C provides a mock function with given fields:
type StaticOptions ¶
StaticOptions is an autogenerated mock type for the StaticOptions type
func (*StaticOptions) HostShardSets ¶
func (_m *StaticOptions) HostShardSets() []topology.HostShardSet
HostShardSets provides a mock function with given fields:
func (*StaticOptions) Replicas ¶
func (_m *StaticOptions) Replicas() int
Replicas provides a mock function with given fields:
func (*StaticOptions) SetHostShardSets ¶
func (_m *StaticOptions) SetHostShardSets(value []topology.HostShardSet) topology.StaticOptions
SetHostShardSets provides a mock function with given fields: value
func (*StaticOptions) SetReplicas ¶
func (_m *StaticOptions) SetReplicas(value int) topology.StaticOptions
SetReplicas provides a mock function with given fields: value
func (*StaticOptions) SetShardSet ¶
func (_m *StaticOptions) SetShardSet(value shard.ShardSet) topology.StaticOptions
SetShardSet provides a mock function with given fields: value
func (*StaticOptions) ShardSet ¶
func (_m *StaticOptions) ShardSet() shard.ShardSet
ShardSet provides a mock function with given fields:
func (*StaticOptions) Validate ¶
func (_m *StaticOptions) Validate() error
Validate provides a mock function with given fields: