Documentation
¶
Index ¶
- Constants
- func CatchInterrupt()
- func GetInterrupt() bool
- func GetSyncDuration() time.Duration
- func IncreaseFailedRequests()
- func IncreaseSuccessfulRequests()
- func SendTrack(errorRuntime error)
- func SetCommand(_command string)
- func SetContinuationHeight(_continuationHeight int64)
- func SetLatestHeight(_latestHeight int64)
- func SetSnapshotHeight(_snapshotHeight int64)
- func SetSourceId(_sourceId string)
- func SetUserConfirmationDuration(_userConfirmationDuration time.Duration)
- func SetUserConfirmationInput(_userConfirmationInput string)
- func WaitForInterrupt()
Constants ¶
View Source
const (
SegmentWriteKey = "aTXiSVqhrmavVNbF2M61pyBDF4stWHgf"
)
Variables ¶
This section is empty.
Functions ¶
func CatchInterrupt ¶
func CatchInterrupt()
CatchInterrupt catches interrupt signals from Ctrl+C ensures that metrics are sent before KSYNC exits
func GetInterrupt ¶
func GetInterrupt() bool
func GetSyncDuration ¶
GetSyncDuration gets the sync time duration. We subtract the user confirmation duration since this time was not spent on actually syncing the node
func IncreaseFailedRequests ¶
func IncreaseFailedRequests()
func IncreaseSuccessfulRequests ¶
func IncreaseSuccessfulRequests()
func SetCommand ¶
func SetCommand(_command string)
func SetContinuationHeight ¶
func SetContinuationHeight(_continuationHeight int64)
func SetLatestHeight ¶
func SetLatestHeight(_latestHeight int64)
func SetSnapshotHeight ¶
func SetSnapshotHeight(_snapshotHeight int64)
func SetSourceId ¶
func SetSourceId(_sourceId string)
func SetUserConfirmationInput ¶
func SetUserConfirmationInput(_userConfirmationInput string)
func WaitForInterrupt ¶
func WaitForInterrupt()
WaitForInterrupt waits indefinitely until KSYNC gets exited in CatchInterrupt after the metrics have been sent. We wait or else KSYNC may exit before the metrics have been properly send
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.