Parameters

This method does not accept any parameters

Returns

stream

stream<StreamTxsResponse>

An open-ended stream that emits one indexed response message for each new matching record.

id

string

The internal identifier assigned to the indexed transaction.

block_number

string

The height of the Injective block containing the record.

block_timestamp

string

The UTC timestamp of the block containing the record.

hash

string

The cryptographic hash that identifies the transaction.

codespace

string

The module namespace that produced the transaction result code.

messages

string

The serialized transaction messages returned by the indexer.

tx_number

string

The monotonically increasing transaction number assigned by the indexer.

error_log

string

The transaction error log when execution failed; otherwise empty.

code

integer

The numeric transaction result code; zero indicates successful execution.

claim_ids

array

The Peggy claim identifiers associated with deposit-claim messages in the transaction. Each value is returned as a decimal string.

Request

1
package main
2

3
import (
4
	"context"
5
	"crypto/tls"
6
	"fmt"
7
	"io"
8
	"log"
9
	"os"
10
	"os/signal"
11

12
	"google.golang.org/grpc"
13
	"google.golang.org/grpc/credentials"
14
	"google.golang.org/grpc/metadata"
15
	"google.golang.org/protobuf/encoding/protojson"
16

17
	pb "injective-indexer-grpc/pb/explorer"
18
)
19

20
const grpcEndpoint = "YOUR_ENDPOINT_NAME.injective-mainnet.quiknode.pro:443"
21
const authToken = "YOUR_TOKEN"
22

23
func main() {
24
	creds := credentials.NewTLS(&tls.Config{MinVersion: tls.VersionTLS12})
25
	conn, err := grpc.Dial(grpcEndpoint, grpc.WithTransportCredentials(creds))
26
	if err != nil {
27
		log.Fatal(err)
28
	}
29
	defer conn.Close()
30

31
	ctx, stop := signal.NotifyContext(context.Background(), os.Interrupt)
32
	defer stop()
33
	ctx = metadata.AppendToOutgoingContext(ctx, "x-token", authToken)
34

35
	client := pb.NewInjectiveExplorerRPCClient(conn)
36
	request := &pb.StreamTxsRequest{}
37
	requestJSON := `{}`
38
	if err := protojson.Unmarshal([]byte(requestJSON), request); err != nil {
39
		log.Fatal(err)
40
	}
41

42
	stream, err := client.StreamTxs(ctx, request)
43
	if err != nil {
44
		log.Fatal(err)
45
	}
46

47
	for {
48
		response, err := stream.Recv()
49
		if err == io.EOF {
50
			return
51
		}
52
		if err != nil {
53
			if ctx.Err() != nil {
54
				return
55
			}
56
			log.Fatal(err)
57
		}
58

59
		data, err := protojson.MarshalOptions{UseProtoNames: true, Indent: "  "}.Marshal(response)
60
		if err != nil {
61
			log.Fatal(err)
62
		}
63
		fmt.Println(string(data))
64
	}
65
}
66

1
package main
2

3
import (
4
	"context"
5
	"crypto/tls"
6
	"fmt"
7
	"io"
8
	"log"
9
	"os"
10
	"os/signal"
11

12
	"google.golang.org/grpc"
13
	"google.golang.org/grpc/credentials"
14
	"google.golang.org/grpc/metadata"
15
	"google.golang.org/protobuf/encoding/protojson"
16

17
	pb "injective-indexer-grpc/pb/explorer"
18
)
19

20
const grpcEndpoint = "YOUR_ENDPOINT_NAME.injective-mainnet.quiknode.pro:443"
21
const authToken = "YOUR_TOKEN"
22

23
func main() {
24
	creds := credentials.NewTLS(&tls.Config{MinVersion: tls.VersionTLS12})
25
	conn, err := grpc.Dial(grpcEndpoint, grpc.WithTransportCredentials(creds))
26
	if err != nil {
27
		log.Fatal(err)
28
	}
29
	defer conn.Close()
30

31
	ctx, stop := signal.NotifyContext(context.Background(), os.Interrupt)
32
	defer stop()
33
	ctx = metadata.AppendToOutgoingContext(ctx, "x-token", authToken)
34

35
	client := pb.NewInjectiveExplorerRPCClient(conn)
36
	request := &pb.StreamTxsRequest{}
37
	requestJSON := `{}`
38
	if err := protojson.Unmarshal([]byte(requestJSON), request); err != nil {
39
		log.Fatal(err)
40
	}
41

42
	stream, err := client.StreamTxs(ctx, request)
43
	if err != nil {
44
		log.Fatal(err)
45
	}
46

47
	for {
48
		response, err := stream.Recv()
49
		if err == io.EOF {
50
			return
51
		}
52
		if err != nil {
53
			if ctx.Err() != nil {
54
				return
55
			}
56
			log.Fatal(err)
57
		}
58

59
		data, err := protojson.MarshalOptions{UseProtoNames: true, Indent: "  "}.Marshal(response)
60
		if err != nil {
61
			log.Fatal(err)
62
		}
63
		fmt.Println(string(data))
64
	}
65
}
66

1
const grpc = require('@grpc/grpc-js')
2
const protoLoader = require('@grpc/proto-loader')
3
const path = require('path')
4

5
const GRPC_ENDPOINT = 'YOUR_ENDPOINT_NAME.injective-mainnet.quiknode.pro:443'
6
const AUTH_TOKEN = 'YOUR_TOKEN'
7

8
const definition = protoLoader.loadSync(
9
	path.join(__dirname, 'proto/explorer/injective_explorer_rpc.proto'),
10
	{
11
		keepCase: true,
12
		longs: String,
13
		enums: String,
14
		bytes: String,
15
		defaults: true,
16
		oneofs: true,
17
	}
18
)
19

20
const proto = grpc.loadPackageDefinition(definition).injective_explorer_rpc
21
const client = new proto.InjectiveExplorerRPC(
22
	GRPC_ENDPOINT,
23
	grpc.credentials.createSsl()
24
)
25

26
const metadata = new grpc.Metadata()
27
metadata.add('x-token', AUTH_TOKEN)
28

29
const request = {}
30

31
const stream = client.StreamTxs(request, metadata)
32

33
stream.on('data', response => {
34
	console.log(JSON.stringify(response, null, 2))
35
})
36

37
stream.on('error', error => {
38
	if (error.code !== grpc.status.CANCELLED) {
39
		console.error(error)
40
		process.exitCode = 1
41
	}
42
})
43

44
stream.on('end', () => client.close())
45

46
process.on('SIGINT', () => {
47
	stream.cancel()
48
	client.close()
49
})
50

1
const grpc = require('@grpc/grpc-js')
2
const protoLoader = require('@grpc/proto-loader')
3
const path = require('path')
4

5
const GRPC_ENDPOINT = 'YOUR_ENDPOINT_NAME.injective-mainnet.quiknode.pro:443'
6
const AUTH_TOKEN = 'YOUR_TOKEN'
7

8
const definition = protoLoader.loadSync(
9
	path.join(__dirname, 'proto/explorer/injective_explorer_rpc.proto'),
10
	{
11
		keepCase: true,
12
		longs: String,
13
		enums: String,
14
		bytes: String,
15
		defaults: true,
16
		oneofs: true,
17
	}
18
)
19

20
const proto = grpc.loadPackageDefinition(definition).injective_explorer_rpc
21
const client = new proto.InjectiveExplorerRPC(
22
	GRPC_ENDPOINT,
23
	grpc.credentials.createSsl()
24
)
25

26
const metadata = new grpc.Metadata()
27
metadata.add('x-token', AUTH_TOKEN)
28

29
const request = {}
30

31
const stream = client.StreamTxs(request, metadata)
32

33
stream.on('data', response => {
34
	console.log(JSON.stringify(response, null, 2))
35
})
36

37
stream.on('error', error => {
38
	if (error.code !== grpc.status.CANCELLED) {
39
		console.error(error)
40
		process.exitCode = 1
41
	}
42
})
43

44
stream.on('end', () => client.close())
45

46
process.on('SIGINT', () => {
47
	stream.cancel()
48
	client.close()
49
})
50

1
import json
2
import grpc
3
from google.protobuf.json_format import MessageToJson, ParseDict
4
from explorer import injective_explorer_rpc_pb2
5
from explorer import injective_explorer_rpc_pb2_grpc
6

7
GRPC_ENDPOINT = "YOUR_ENDPOINT_NAME.injective-mainnet.quiknode.pro:443"
8
AUTH_TOKEN = "YOUR_TOKEN"
9

10
channel = grpc.secure_channel(GRPC_ENDPOINT, grpc.ssl_channel_credentials())
11
client = injective_explorer_rpc_pb2_grpc.InjectiveExplorerRPCStub(channel)
12
metadata = (("x-token", AUTH_TOKEN),)
13

14
request_data = {}
15
request = ParseDict(request_data, injective_explorer_rpc_pb2.StreamTxsRequest())
16

17
stream = client.StreamTxs(request, metadata=metadata)
18

19
try:
20
    for response in stream:
21
        print(MessageToJson(response, preserving_proto_field_name=True, indent=2))
22
except KeyboardInterrupt:
23
    stream.cancel()
24
finally:
25
    channel.close()
26

1
import json
2
import grpc
3
from google.protobuf.json_format import MessageToJson, ParseDict
4
from explorer import injective_explorer_rpc_pb2
5
from explorer import injective_explorer_rpc_pb2_grpc
6

7
GRPC_ENDPOINT = "YOUR_ENDPOINT_NAME.injective-mainnet.quiknode.pro:443"
8
AUTH_TOKEN = "YOUR_TOKEN"
9

10
channel = grpc.secure_channel(GRPC_ENDPOINT, grpc.ssl_channel_credentials())
11
client = injective_explorer_rpc_pb2_grpc.InjectiveExplorerRPCStub(channel)
12
metadata = (("x-token", AUTH_TOKEN),)
13

14
request_data = {}
15
request = ParseDict(request_data, injective_explorer_rpc_pb2.StreamTxsRequest())
16

17
stream = client.StreamTxs(request, metadata=metadata)
18

19
try:
20
    for response in stream:
21
        print(MessageToJson(response, preserving_proto_field_name=True, indent=2))
22
except KeyboardInterrupt:
23
    stream.cancel()
24
finally:
25
    channel.close()
26

Don't have an account yet?

Create your Quicknode endpoint in seconds and start building

Get started for free