Documentation
¶
Index ¶
- type HTTPStats
- type JobRun
- type NoopStats
- type Reputation
- type ReputationBuilder
- func (b *ReputationBuilder) Build() Reputation
- func (b *ReputationBuilder) WithJobCompletedNoValidation(val bool) *ReputationBuilder
- func (b *ReputationBuilder) WithJobFailed(val bool) *ReputationBuilder
- func (b *ReputationBuilder) WithJobMatched(val bool) *ReputationBuilder
- func (b *ReputationBuilder) WithModuleID(moduleID string) *ReputationBuilder
- func (b *ReputationBuilder) WithValidationLost(val bool) *ReputationBuilder
- type Stats
- type StatsOptions
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type HTTPStats ¶
type HTTPStats struct {
ClientOptions http.ClientOptions
// contains filtered or unexported fields
}
func (*HTTPStats) PostJobRun ¶
func (stat *HTTPStats) PostJobRun(deal *data.DealContainer) error
func (*HTTPStats) PostReputation ¶
func (stat *HTTPStats) PostReputation(address string, reputation Reputation) error
type JobRun ¶
type JobRun struct {
DealID string `json:"dealId"`
ModuleID string `json:"moduleId"`
JobCreator string `json:"jobCreator"`
ResourceProvider string `json:"resourceProvider"`
JobOffer string `json:"jobOffer"`
ResourceOffer string `json:"resourceOffer"`
JobState string `json:"jobState"`
MatchDurationMilliseconds float64 `json:"matchDuration_ms"`
ExecutionDurationMilliseconds float64 `json:"executionDuration_ms"`
RetrievalDurationMilliseconds float64 `json:"retrievalDuration_ms"`
TotalDurationMilliseconds float64 `json:"totalDuration_ms"`
ExtraData json.RawMessage `json:"extraData"`
}
type NoopStats ¶
type NoopStats struct{}
func (*NoopStats) PostJobRun ¶
func (stat *NoopStats) PostJobRun(deal *data.DealContainer) error
func (*NoopStats) PostReputation ¶
func (stat *NoopStats) PostReputation(address string, reputation Reputation) error
type Reputation ¶
type ReputationBuilder ¶
type ReputationBuilder struct {
// contains filtered or unexported fields
}
The reputation builder constructs reputation from reputation events. For now, it does not expose runtime millis or module ID. To work around this, WithModuleID sets the module ID using a shortcut derived from the module's repo and hash.
func NewReputationBuilder ¶
func NewReputationBuilder() *ReputationBuilder
func (*ReputationBuilder) Build ¶
func (b *ReputationBuilder) Build() Reputation
func (*ReputationBuilder) WithJobCompletedNoValidation ¶
func (b *ReputationBuilder) WithJobCompletedNoValidation(val bool) *ReputationBuilder
func (*ReputationBuilder) WithJobFailed ¶
func (b *ReputationBuilder) WithJobFailed(val bool) *ReputationBuilder
func (*ReputationBuilder) WithJobMatched ¶
func (b *ReputationBuilder) WithJobMatched(val bool) *ReputationBuilder
func (*ReputationBuilder) WithModuleID ¶ added in v2.23.0
func (b *ReputationBuilder) WithModuleID(moduleID string) *ReputationBuilder
func (*ReputationBuilder) WithValidationLost ¶
func (b *ReputationBuilder) WithValidationLost(val bool) *ReputationBuilder
type Stats ¶
type Stats interface {
PostJobRun(deal *data.DealContainer) error
PostReputation(address string, reputation Reputation) error
}
type StatsOptions ¶
Click to show internal directories.
Click to hide internal directories.