The highest tagged major version is
Documentation
¶
Index ¶
- Constants
- func CheckEnvirontmentStatus(wg *sync.WaitGroup, splitStorage storage.SplitStorage, ...)
- func CheckProducerStatus(splitStorage storage.SplitStorage, httpClients common.HTTPClients) (bool, bool, bool, bool)
- func CheckSplitServers(httpClients common.HTTPClients) (bool, bool, bool)
- func FinishOperation(operation string)
- func GetEventsLambda() float64
- func GetHealthySince() string
- func GetHealthySinceTimestamp() string
- func GetImpressionsLambda() float64
- func GetStorageStatus(splitStorage storage.SplitStorage) bool
- func InitializeEvictionCalculator()
- func IsOperationRunning(operation string) bool
- func PostImpressionsToListener(ilSubmitter recorder.ImpressionListenerSubmitter)
- func QueueImpressionsForListener(impressions *ImpressionBulk) error
- func RequestOperation(operation string) bool
- func StopHealtcheck()
- func StoreDataFlushed(timestamp int64, countFlushed int, countInStorage int64, operation string)
- type ImpressionBulk
Constants ¶
const EventsOperation = "eventsOperation"
EventsOperation tag to register an operation on Events
const ImpressionsOperation = "impressionsOperation"
ImpressionsOperation tag to register an operation on Impressions
Variables ¶
This section is empty.
Functions ¶
func CheckEnvirontmentStatus ¶
func CheckEnvirontmentStatus(wg *sync.WaitGroup, splitStorage storage.SplitStorage, httpClients common.HTTPClients)
CheckEnvirontmentStatus task to check status of Synchronizer
func CheckProducerStatus ¶
func CheckProducerStatus(splitStorage storage.SplitStorage, httpClients common.HTTPClients) (bool, bool, bool, bool)
CheckProducerStatus checks producer status
func CheckSplitServers ¶
func CheckSplitServers(httpClients common.HTTPClients) (bool, bool, bool)
CheckSplitServers checks status for splits servers
func FinishOperation ¶
func FinishOperation(operation string)
FinishOperation finished an operation already executed
func GetEventsLambda ¶
func GetEventsLambda() float64
GetEventsLambda returns eviction factor for events
func GetHealthySince ¶
func GetHealthySince() string
GetHealthySince returns last time that healtcheck was successful
func GetHealthySinceTimestamp ¶
func GetHealthySinceTimestamp() string
GetHealthySinceTimestamp returns timestamp of the last healthceck that was ok
func GetImpressionsLambda ¶
func GetImpressionsLambda() float64
GetImpressionsLambda returns eviction factor for impressions
func GetStorageStatus ¶
func GetStorageStatus(splitStorage storage.SplitStorage) bool
GetStorageStatus checks status for split storage
func InitializeEvictionCalculator ¶
func InitializeEvictionCalculator()
InitializeEvictionCalculator initializes the eviction calculator module
func IsOperationRunning ¶
IsOperationRunning Indicates if the operation is running or not
func PostImpressionsToListener ¶
func PostImpressionsToListener(ilSubmitter recorder.ImpressionListenerSubmitter)
PostImpressionsToListener Add Impressions to Listener
func QueueImpressionsForListener ¶
func QueueImpressionsForListener(impressions *ImpressionBulk) error
QueueImpressionsForListener Impression Listener for Synchronizer
func RequestOperation ¶
RequestOperation Checks if the operation can be executed
func StopHealtcheck ¶
func StopHealtcheck()
StopHealtcheck stops StopHealtcheck task sendding signal
Types ¶
type ImpressionBulk ¶
type ImpressionBulk struct {
Data json.RawMessage
SdkVersion string
MachineIP string
MachineName string
// contains filtered or unexported fields
}
ImpressionBulk struct
Source Files