nats

Documentation

Index

• type API
• type Metrics
• type Nats
  • func New(url string, subjPrefix string, api API, logger *logrus.Entry) (*Nats, func(), error)
  • func (n *Nats) AddMetrics(m *Metrics)
  • func (n *Nats) NotifyRefilling(service string, to, from mint.PublicKey, t mint.Token, a *amount.Amount, ...) error
  • func (n *Nats) Task(token *gotask.Token)

Types

type API

type API interface {
	AddWallet(serviceTrans types.ServiceTransport, service string, callbackURL string, p ...mint.PublicKey) bool
	RemoveWallet(service string, p ...mint.PublicKey) bool
}

API provides API methods

type Metrics

type Metrics struct {
	RequestDuration      *prometheus.HistogramVec
	NotificationDuration prometheus.Histogram
}

Metrics data

type Nats

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

Nats is Nats server transport for service API

func New

func New(
	url string,
	subjPrefix string,
	api API,
	logger *logrus.Entry,
) (*Nats, func(), error)

New instance

func (*Nats) AddMetrics

func (n *Nats) AddMetrics(m *Metrics)

AddMetrics adds metrics counters and should be called before service launch

func (*Nats) NotifyRefilling

func (n *Nats) NotifyRefilling(service string, to, from mint.PublicKey, t mint.Token, a *amount.Amount, tx mint.Digest) error

NotifyRefilling sends an event

func (*Nats) Task

func (n *Nats) Task(token *gotask.Token)

Task loop