pub

Documentation

Index

• Constants
• type EventPayload
• type Pub
  • func NewPub(o PubOpts) (*Pub, error)
  • func (p *Pub) Publish(subject string, dedupId string, eventPayload interface{}) error
• type PubOpts

Constants

const (
	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 EventPayload

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

type Pub

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

func NewPub

func NewPub(o PubOpts) (*Pub, error)

func (*Pub) Publish

func (p *Pub) Publish(subject string, dedupId string, eventPayload interface{}) error

type PubOpts

type PubOpts struct {
	DedupDuration   time.Duration
	JsCtx           nats.JetStreamContext
	PersistDuration time.Duration
}