Get node status including node info, pubkey, latest block hash, app hash, block height and time.

Get node health. Returns empty result (200 OK) on success, no response - in case of an error.

Get network info.

Get Block.

Get block_results. When the discard_abci_responses storage flag is enabled, this endpoint will return an error.

Get Commit.

Get Validators. Validators are sorted by voting power.

Get consensus state.

Not safe to call from inside the ABCI application during a block execution.

Get consensus parameters.

Returns CheckTx. Does not wait for DeliverTx result. Subscribe to websocket events to be sure a tx is included in a block. If you don't receive a notification, try sending to another node.

Returns immediately with no response. Subscribe to websocket events to get CheckTx and DeliverTx response. If you haven't received anything after a couple of blocks, resend it. If the same happens again, send it to a different other node.

Returns with the responses from CheckTx and DeliverTx. USE ONLY FOR TESTING AND DEVELOPMENT. In production, use BroadcastTxSync or BroadcastTxAsync. Subscribe to Websocket events. CONTRACT: only returns error if mempool.CheckTx() errs or if there is a timeout waiting for tx to commit. If CheckTx or DeliverTx fail, no error is returned but the returned result contains a non-OK ABCI code.

Checks the transaction without executing it. The transaction is NOT added to the mempool.

Get list of unconfirmed transactions

Get data about unconfirmed transactions

Subscribe to events via WebSocket.

Perform queries using the form: "condition AND condition ..." (no OR at the moment).

Condition has a form: "key operation operand"

Key is a string with a restricted set of possible symbols ( \t\n\r\()"'=>< are not allowed).

Operation can be "=", "<", "<=", ">", ">=", "CONTAINS" AND "EXISTS". operand can be a string (escaped with single quotes), number, date or time.

Examples

  tm.event = 'NewBlock'               # new blocks
  tm.event = 'CompleteProposal'       # node got a complete proposal
  tm.event = 'Tx' AND tx.hash = 'XYZ' # single transaction
  tm.event = 'Tx' AND tx.height = 5   # all txs of the fifth block
  tx.height = 5                       # all txs of the fifth block

Tendermint provides a few predefined keys: tm.event, tx.hash and tx.height.

NOTE: For transactions, you can define additional keys by providing events with DeliverTx response.

import (
    abci "github.com/tendermint/tendermint/abci/types"
    "github.com/tendermint/tendermint/libs/pubsub/query"
)
abci.ResponseDeliverTx{
  Events: []abci.Event{
      {
          Type: "rewards.withdraw",
          Attributes: abci.EventAttribute{
              {Key: []byte("address"), Value: []byte("AddrA"), Index: true},
              {Key: []byte("source"), Value: []byte("SrcX"), Index: true},
              {Key: []byte("amount"), Value: []byte("..."), Index: true},
              {Key: []byte("balance"), Value: []byte("..."), Index: true},
          },
      },
      {
          Type: "rewards.withdraw",
          Attributes: abci.EventAttribute{
              {Key: []byte("address"), Value: []byte("AddrB"), Index: true},
              {Key: []byte("source"), Value: []byte("SrcY"), Index: true},
              {Key: []byte("amount"), Value: []byte("..."), Index: true},
              {Key: []byte("balance"), Value: []byte("..."), Index: true},
          },
      },
      {
          Type: "transfer",
          Attributes: abci.EventAttribute{
              {Key: []byte("sender"), Value: []byte("AddrC"), Index: true},
              {Key: []byte("recipient"), Value: []byte("AddrD"), Index: true},
              {Key: []byte("amount"), Value: []byte("..."), Index: true},
          },
      },
  },
}

All events are indexed by a composite key of the form {eventType}.{evenAttrKey}. In the above examples, the following keys would be indexed:

• rewards.withdraw.address
• rewards.withdraw.source
• rewards.withdraw.amount
• rewards.withdraw.balance
• transfer.sender
• transfer.recipient
• transfer.amount Multiple event types with duplicate keys are allowed and are meant to categorize unique and distinct events. In the above example, all events indexed under the key rewards.withdraw.address will have the following values stored and queryable:
• AddrA
• AddrB To create a query for txs where address AddrA withdrew rewards: query.MustParse("tm.event = 'Tx' AND rewards.withdraw.address = 'AddrA'") To create a query for txs where address AddrA withdrew rewards from source Y: query.MustParse("tm.event = 'Tx' AND rewards.withdraw.address = 'AddrA' AND rewards.withdraw.source = 'Y'") To create a query for txs where AddrA transferred funds: query.MustParse("tm.event = 'Tx' AND transfer.sender = 'AddrA'") The following queries would return no results: query.MustParse("tm.event = 'Tx' AND transfer.sender = 'AddrZ'") query.MustParse("tm.event = 'Tx' AND rewards.withdraw.address = 'AddrZ'") query.MustParse("tm.event = 'Tx' AND rewards.withdraw.source = 'W'")

See list of all possible events here https://godoc.org/github.com/tendermint/tendermint/types#pkg-constants

For complete query syntax, check out https://godoc.org/github.com/tendermint/tendermint/libs/pubsub/query.

import rpchttp "github.com/tendermint/rpc/client/http"
import "github.com/tendermint/tendermint/types"
client := rpchttp.New("tcp:0.0.0.0:26657", "/websocket")
err := client.Start()
if err != nil {
  handle error
}
defer client.Stop()
ctx, cancel := context.WithTimeout(context.Background(), 1 * time.Second)
defer cancel()
query := "tm.event = 'Tx' AND tx.height = 3"
txs, err := client.Subscribe(ctx, "test-client", query)
if err != nil {
  handle error
}
go func() {
 for e := range txs {
   fmt.Println("got ", e.Data.(types.EventDataTx))
   }
}()

NOTE: if you're not reading events fast enough your subsciption may be terminated.

client := rpchttp.New("tcp:0.0.0.0:26657", "/websocket")
err := client.Start()
if err != nil {
   handle error
}
defer client.Stop()
query := "tm.event = 'Tx' AND tx.height = 3"
err = client.Unsubscribe(context.Background(), "test-client", query)
if err != nil {
   handle error
}

Unsubscribe from all events via WebSocket

Get some info about the application.