Infront Data Manager Connect Client (.NET)
|
Inherits Gevasys.DataCore.Core.IConsumer.
Public Member Functions | |
StreamingPartitioner (String name, ParitionerStrategy strategy, bool automaticRebalancing, List< RebalanceTime > rebalancingTimes) | |
String | GetName () |
void | Add (ConsumerStore store) |
void | Remove (ConsumerStore store) |
void | Clear () |
void | AddInstrument (String instrument) |
void | AddInstruments (InstrumentList instruments) |
void | AddFilterElement (Common.FilterElement filterElement) |
void | RemoveFilterElement (Common.FilterElement filterElement) |
bool | IsAnyConsumerAlive () |
void | PrintInstrumentSizeForAliveStores () |
void | RequestRecaps (InstrumentList instruments) |
bool | IsMember (IConsumer store) |
void | AddExchange (String Exchange) |
void | RemoveInstrument (String instrument) |
void | RemoveInstruments (InstrumentList instruments) |
void | RemoveExchange (String Exchange) |
void | RemoveAll () |
InstrumentList | GetInstruments () |
ConsumerStoreStatistics | BuildStatistics () |
void | Rebalance () |
void | Run () |
void | Update (IConsumer source, ConsumerStateChangedEventArgs arg) |
ConsumerType | GetConsumerType () |
void | SetFieldFilter (List< string > fieldList) |
Sets a list of fields as a data filter for the streaming connection on the server side. Only fields that exists in the field filter will be pushed. More... | |
void | RemoveFieldFilter () |
Removes a field filter. More... | |
void | SubscribeNewsBroadcast () |
void | UnsubscribeNewsBroadcast () |
![]() | |
void | AddFilterElement (FilterElement filterElement) |
Adds a FilterElement More... | |
void | RemoveFilterElement (FilterElement filterElement) |
Removes the FilterElement More... | |
Events | |
EventHandler< ConsumerStateChangedEventArgs > | OnConsumerStateChanged |
Represents a manager that manages a list of ConsumerStore an the distribution of instruments over all attached ConsumerStore.
This class also manages failover scenarios as well as dynamic load balancing.
|
inline |
Initializes a new instance of the StreamingPartitioner class.
name | The name of the partitioner as configured in the configuration file. |
strategy | The distribution strategy for instruments among the attached consumers. |
automaticRebalancing | Enables or disables the automatic rebalancing of instruments. |
rebalancingTimes | A list of RebalanceTime. |
|
inline |
Adds a ConsumerStore to the list of managed consumers.
store | The ConsumerStore. |
|
inline |
Adds and subscribes a exchange.
Exchange | The exchange. |
<font color="#3F5FBF" size="2"> <font color="#3F5FBF" size="2">Not available in version 1.1.</font> </font>
Implements Gevasys.DataCore.Core.IConsumer.
|
inline |
Adds and subscribes a instrument.
instrument | The instrument. |
Implements Gevasys.DataCore.Core.IConsumer.
|
inline |
Adds and subscribes a list of instruments.
instruments | The list of instruments. |
Implements Gevasys.DataCore.Core.IConsumer.
|
inline |
Removes all attached ConsumerStore.
|
inline |
Gets the type of the Consumer.
Implements Gevasys.DataCore.Core.IConsumer.
|
inline |
Get the list of subscribed instruments.
Implements Gevasys.DataCore.Core.IConsumer.
|
inline |
Gets the name of the Consumer.
Implements Gevasys.DataCore.Core.IConsumer.
|
inline |
True if any of the attached ConsumerStore is online. False if all ConsumerStore are offline.
|
inline |
Removes a ConsumerStore from the managed consumers.
|
inline |
Removes and unsubscribes all instruments and exchanges.
Implements Gevasys.DataCore.Core.IConsumer.
|
inline |
Removes and unsubscribes a exchange.
<font color="#3F5FBF" size="2"> <font color="#3F5FBF" size="2">Available from version 2.x</font> </font>
Implements Gevasys.DataCore.Core.IConsumer.
|
inline |
Removes a field filter.
<font color="#3F5FBF" size="2"> <font color="#3F5FBF" size="2">Available from Version 2.x.</font> </font>
Implements Gevasys.DataCore.Core.IConsumer.
|
inline |
Removes an unsubscribes a instrument.
instrument | The instrument. |
Implements Gevasys.DataCore.Core.IConsumer.
|
inline |
Remove and unsubscribes a list of instruments.
instruments | <font color="#3F5FBF" size="2"> <font color="#3F5FBF" size="2">The list of Instruments</font> </font> |
Implements Gevasys.DataCore.Core.IConsumer.
|
inline |
Request recap messages for a list of instruments.
instrumentList | The list of instruments. |
Implements Gevasys.DataCore.Core.IConsumer.
|
inline |
Sets a list of fields as a data filter for the streaming connection on the server side. Only fields that exists in the field filter will be pushed.
fieldList |
<font color="#3F5FBF" size="2"> <font color="#3F5FBF" size="2">Available from Version 2.x.</font> </font>
Implements Gevasys.DataCore.Core.IConsumer.
Copyright (C) 2021 Infront Financial Technology GmbH
Mainzer Landstrasse 178 – 190
60327 Frankfurt am Main
Infront Data Manager Connect V4.1