events

Documentation

Index

• Constants
• type EventEmitter
  • func NewJetStreamEventEmitter(o JetStreamOpts) (EventEmitter, error)
• type EventPayload
• type JetStream
  • func (js *JetStream) Close()
  • func (js *JetStream) Publish(subject string, dedupId string, eventPayload interface{}) error
• type JetStreamOpts

Constants

const (
	StreamName     string = "CUSTODIAL"
	StreamSubjects string = "CUSTODIAL.*"
	// Subjects
	AccountNewNonce    string = "CUSTODIAL.accountNewNonce"
	AccountRegister    string = "CUSTODIAL.accountRegister"
	AccountGiftGas     string = "CUSTODIAL.systemNewAccountGas"
	AccountGiftVoucher string = "CUSTODIAL.systemNewAccountVoucher"
	AccountRefillGas   string = "CUSTODIAL.systemRefillAccountGas"
	DispatchFail       string = "CUSTODIAL.dispatchFail"
	DispatchSuccess    string = "CUSTODIAL.dispatchSuccess"
	SignTransfer       string = "CUSTODIAL.signTransfer"
)

Types

type EventEmitter

type EventEmitter interface {
	Close()
	Publish(subject string, dedupId string, eventPayload interface{}) error
}

func NewJetStreamEventEmitter

func NewJetStreamEventEmitter(o JetStreamOpts) (EventEmitter, error)

type EventPayload

type EventPayload struct {
	OtxId      uint   `json:"otxId"`
	TrackingId string `json:"trackingId"`
	TxHash     string `json:"txHash"`
}

type JetStream

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

func (*JetStream) Close

func (js *JetStream) Close()

Close gracefully shutdowns the JetStream connection.

func (*JetStream) Publish

func (js *JetStream) Publish(subject string, dedupId string, eventPayload interface{}) error

Publish publishes the JSON data to the NATS stream.

type JetStreamOpts

type JetStreamOpts struct {
	ServerUrl       string
	PersistDuration time.Duration
	DedupDuration   time.Duration
}