sub

Documentation

Index

• type ChainEvent
• type Sub
  • func NewSub(o SubOpts) (*Sub, error)
  • func (s *Sub) Close()
  • func (s *Sub) Process() error
• type SubOpts

Types

type ChainEvent

type ChainEvent struct {
	Block           uint64 `json:"block"`
	From            string `json:"from"`
	To              string `json:"to"`
	ContractAddress string `json:"contractAddress"`
	Success         bool   `json:"success"`
	TxHash          string `json:"transactionHash"`
	TxIndex         uint   `json:"transactionIndex"`
	Value           uint64 `json:"value"`
}

type Sub

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

func NewSub

func NewSub(o SubOpts) (*Sub, error)

func (*Sub) Close

func (s *Sub) Close()

func (*Sub) Process

func (s *Sub) Process() error

type SubOpts

type SubOpts struct {
	CustodialContainer *custodial.Custodial
	JsCtx              nats.JetStreamContext
	Logg               logf.Logger
	NatsConn           *nats.Conn
}