Documentation ¶
Index ¶
- type ActorSystem
- type FioImport
- type Metrics
- func (metrics Metrics) ExportedAccounts(num int64)
- func (metrics Metrics) ExportedTransfers(num int64)
- func (metrics Metrics) ImportedAccounts(num int64)
- func (metrics Metrics) ImportedTransfers(num int64)
- func (metrics Metrics) Start()
- func (metrics Metrics) TimeExportAccount(f func())
- func (metrics Metrics) TimeExportTransaction(f func())
- func (metrics Metrics) TimeImportAccount(f func())
- func (metrics Metrics) TimeImportTransaction(f func())
- func (metrics Metrics) TimeSyncLatency(f func())
- func (metrics Metrics) TokenCreated()
- func (metrics Metrics) TokenDeleted()
- type Snapshot
- type Support
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ActorSystem ¶
type ActorSystem struct { system.Support Tenant string Storage string Metrics *Metrics ClientHTTP http.Client }
ActorSystem represents actor system subroutine
func NewActorSystem ¶
func NewActorSystem(ctx context.Context, cfg config.Configuration, metrics *Metrics) ActorSystem
NewActorSystem returns actor system fascade
type FioImport ¶
type FioImport struct { Support // contains filtered or unexported fields }
FioImport represents fio gateway to wall import subroutine
func NewFioImport ¶
func NewFioImport(ctx context.Context, cfg config.Configuration, metrics *Metrics, system *ActorSystem) FioImport
NewFioImport returns fio import fascade
type Metrics ¶
type Metrics struct { Support // contains filtered or unexported fields }
Metrics represents metrics subroutine
func NewMetrics ¶
func NewMetrics(ctx context.Context, cfg config.Configuration) Metrics
NewMetrics returns metrics fascade
func (Metrics) ExportedAccounts ¶
func (Metrics) ExportedTransfers ¶
func (Metrics) ImportedAccounts ¶
func (Metrics) ImportedTransfers ¶
func (Metrics) Start ¶
func (metrics Metrics) Start()
Start handles everything needed to start metrics daemon
func (Metrics) TimeExportAccount ¶
func (metrics Metrics) TimeExportAccount(f func())
func (Metrics) TimeExportTransaction ¶
func (metrics Metrics) TimeExportTransaction(f func())
func (Metrics) TimeImportAccount ¶
func (metrics Metrics) TimeImportAccount(f func())
func (Metrics) TimeImportTransaction ¶
func (metrics Metrics) TimeImportTransaction(f func())
func (Metrics) TimeSyncLatency ¶
func (metrics Metrics) TimeSyncLatency(f func())
func (Metrics) TokenCreated ¶
func (metrics Metrics) TokenCreated()
TokenCreated increments token created by one
func (Metrics) TokenDeleted ¶
func (metrics Metrics) TokenDeleted()
TokenDeleted increments token deleted by one
type Snapshot ¶
type Snapshot struct { CreatedTokens int64 `json:"createdTokens"` DeletedTokens int64 `json:"deletedTokens"` SyncLatency float64 `json:"syncLatency"` ImportAccountLatency float64 `json:"importAccountLatency"` ExportAccountLatency float64 `json:"exportAccountLatency"` ImportTransactionLatency float64 `json:"importTransactionLatency"` ExportTransactionLatency float64 `json:"exportTransactionLatency"` ImportedAccounts int64 `json:"importedAccounts"` ExportedAccounts int64 `json:"exportedAccounts"` ImportedTransfers int64 `json:"importedTransfers"` ExportedTransfers int64 `json:"exportedTransfers"` }
Snapshot holds metrics snapshot status
type Support ¶
type Support struct { IsReady chan interface{} // contains filtered or unexported fields }
Support provides support for graceful shutdown
func NewDaemonSupport ¶
NewDaemonSupport constructor
Click to show internal directories.
Click to hide internal directories.