tx

Documentation

Index

• type Response
• type Watcher
  • func DialWatcher(ctx context.Context, sub tmrpc.EventsClient) (*Watcher, error)
  • func (w *Watcher) Stop()
  • func (w *Watcher) Watch(ctx context.Context, hash string) (<-chan *Response, error)

Types

type Response

type Response struct {
	Bytes  []byte                  // readonly
	Result *abci.ResponseDeliverTx // readonly
	Block  int64
	Index  uint32
}

type Watcher

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

func DialWatcher

func DialWatcher(ctx context.Context, sub tmrpc.EventsClient) (*Watcher, error)

func (*Watcher) Stop

func (w *Watcher) Stop()

func (*Watcher) Watch

func (w *Watcher) Watch(ctx context.Context, hash string) (<-chan *Response, error)

Watch returns a channel that sends a Response, once its found. Contract: *Response is readonly.