metrics

type AuditorService ¶

type AuditorService struct {
	// contains filtered or unexported fields
}

AuditorService is a metrics wrapper around driver.AuditorService.

func NewAuditorService(inner driver.AuditorService, p Provider) *AuditorService

func (w *AuditorService) AuditorCheck(ctx context.Context, request *driver.TokenRequest, metadata *driver.TokenRequestMetadata, anchor driver.TokenRequestAnchor) error

type Counter ¶

type Counter = metrics.Counter

type CounterOpts ¶

type CounterOpts = metrics.CounterOpts

type Gauge ¶

type Gauge = metrics.Gauge

type GaugeOpts ¶

type GaugeOpts = metrics.GaugeOpts

type Histogram ¶

type Histogram = metrics.Histogram

type HistogramOpts ¶

type HistogramOpts = metrics.HistogramOpts

type IssueService ¶

type IssueService struct {
	// contains filtered or unexported fields
}

IssueService is a metrics wrapper around driver.IssueService.

func NewIssueService(inner driver.IssueService, p Provider) *IssueService

func (w *IssueService) DeserializeIssueAction(raw []byte) (driver.IssueAction, error)

func (w *IssueService) Issue(ctx context.Context, issuerIdentity driver.Identity, tokenType token.Type, values []uint64, owners [][]byte, opts *driver.IssueOptions) (driver.IssueAction, *driver.IssueMetadata, error)

func (w *IssueService) VerifyIssue(ctx context.Context, ia driver.IssueAction, metadata []*driver.IssueOutputMetadata) error

type MetricLabel ¶

type MetricLabel = string

const (
	NetworkLabel   MetricLabel = "network"
	ChannelLabel   MetricLabel = "channel"
	NamespaceLabel MetricLabel = "namespace"
)

type Provider ¶

type Provider = metrics.Provider

Provider is a metrics.Provider. When it is (or wraps) a tmsProvider — see NewTMSProvider — every metric it creates is bound to fixed network/channel/namespace label values via With(...) before it ever reaches the caller. Consequently any CounterOpts/GaugeOpts/HistogramOpts passed to such a Provider's NewCounter/NewGauge/NewHistogram MUST declare "network", "channel", "namespace" as the leading LabelNames (in addition to whatever labels the metric itself needs), even though the caller never supplies values for them. Omitting them causes the underlying Prometheus vector to be created with 0 label names while every .With(...)/.Add(...)/.Observe(...) call supplies 3 values, which panics at runtime with "inconsistent label cardinality" the first time the metric is used - see token/services/identity/metrics.go for a worked example.

type TokensService ¶

type TokensService struct {
	// contains filtered or unexported fields
}

TokensService is a metrics wrapper around driver.TokensService.

func NewTokensService(inner driver.TokensService, p Provider) *TokensService

func (w *TokensService) Deobfuscate(ctx context.Context, output driver.TokenOutput, outputMetadata driver.TokenOutputMetadata) (*token.Token, driver.Identity, []driver.Identity, token.Format, error)

func (w *TokensService) Recipients(output driver.TokenOutput) ([]driver.Identity, error)

func (w *TokensService) SupportedTokenFormats() []token.Format

type TokensUpgradeService ¶

type TokensUpgradeService struct {
	// contains filtered or unexported fields
}

TokensUpgradeService is a metrics wrapper around driver.TokensUpgradeService.

func NewTokensUpgradeService(inner driver.TokensUpgradeService, p Provider) *TokensUpgradeService

func (w *TokensUpgradeService) CheckUpgradeProof(ctx context.Context, ch driver.TokensUpgradeChallenge, proof driver.TokensUpgradeProof, tokens []token.LedgerToken) (bool, error)

func (w *TokensUpgradeService) GenUpgradeProof(ctx context.Context, ch driver.TokensUpgradeChallenge, tokens []token.LedgerToken, witness driver.TokensUpgradeWitness) (driver.TokensUpgradeProof, error)

func (w *TokensUpgradeService) NewUpgradeChallenge() (driver.TokensUpgradeChallenge, error)

type TransferService ¶

type TransferService struct {
	// contains filtered or unexported fields
}

TransferService is a metrics wrapper around driver.TransferService.

func NewTransferService(inner driver.TransferService, p Provider) *TransferService

func (w *TransferService) DeserializeTransferAction(raw []byte) (driver.TransferAction, error)

func (w *TransferService) Transfer(ctx context.Context, anchor driver.TokenRequestAnchor, wallet driver.OwnerWallet, ids []*token.ID, outputs []*token.Token, opts *driver.TransferOptions) (driver.TransferAction, *driver.TransferMetadata, error)

func (w *TransferService) VerifyTransfer(ctx context.Context, tr driver.TransferAction, outputMetadata []*driver.TransferOutputMetadata) error