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
Source Files
Click to show internal directories.
Click to hide internal directories.