Solana gRPC is included with Scale plans and up. Learn more on our pricing page.

Parameters

This method does not accept any parameters

Returns

firstAvailable

string

The first available slot for replay

Request

1
package main
2

3
import (
4
	"context"
5
	"crypto/tls"
6
	"fmt"
7
	"log"
8
	"time"
9

10
	pb "yellowstone/proto"
11

12
	"google.golang.org/grpc"
13
	"google.golang.org/grpc/credentials"
14
	"google.golang.org/grpc/encoding/gzip"
15
	"google.golang.org/grpc/keepalive"
16
)
17

18
var (
19
	endpoint = "YOUR_QN_ENDPOINT:443"
20
	token    = "YOUR_TOKEN_NUMBER"
21
)
22

23
var kacp = keepalive.ClientParameters{
24
	Time:                10 * time.Second,
25
	Timeout:             time.Second,
26
	PermitWithoutStream: true,
27
}
28

29
type tokenAuth struct {
30
	token string
31
}
32

33
func (t tokenAuth) GetRequestMetadata(ctx context.Context, in ...string) (map[string]string, error) {
34
	return map[string]string{
35
		"x-token": t.token,
36
	}, nil
37
}
38

39
func (tokenAuth) RequireTransportSecurity() bool {
40
	return true
41
}
42

43
func main() {
44
	opts := []grpc.DialOption{
45
		grpc.WithTransportCredentials(credentials.NewTLS(&tls.Config{})),
46
		grpc.WithKeepaliveParams(kacp),
47
		grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(1024*1024*1024), grpc.UseCompressor(gzip.Name)),
48
		grpc.WithPerRPCCredentials(tokenAuth{token: token}),
49
	}
50

51
	conn, err := grpc.NewClient(endpoint, opts...)
52
	if err != nil {
53
		log.Fatalf("Failed to connect: %v", err)
54
	}
55
	defer conn.Close()
56

57
	client := pb.NewGeyserClient(conn)
58

59
	req := &pb.SubscribeReplayInfoRequest{}
60
	resp, err := client.SubscribeReplayInfo(context.Background(), req)
61
	if err != nil {
62
		log.Fatalf("Failed to get replay info: %v", err)
63
	}
64

65
	if resp.FirstAvailable != nil {
66
		fmt.Printf("First available slot for replay: %d\n", *resp.FirstAvailable)
67
	} else {
68
		fmt.Println("No replay information available")
69
	}
70
}
71

1
package main
2

3
import (
4
	"context"
5
	"crypto/tls"
6
	"fmt"
7
	"log"
8
	"time"
9

10
	pb "yellowstone/proto"
11

12
	"google.golang.org/grpc"
13
	"google.golang.org/grpc/credentials"
14
	"google.golang.org/grpc/encoding/gzip"
15
	"google.golang.org/grpc/keepalive"
16
)
17

18
var (
19
	endpoint = "YOUR_QN_ENDPOINT:443"
20
	token    = "YOUR_TOKEN_NUMBER"
21
)
22

23
var kacp = keepalive.ClientParameters{
24
	Time:                10 * time.Second,
25
	Timeout:             time.Second,
26
	PermitWithoutStream: true,
27
}
28

29
type tokenAuth struct {
30
	token string
31
}
32

33
func (t tokenAuth) GetRequestMetadata(ctx context.Context, in ...string) (map[string]string, error) {
34
	return map[string]string{
35
		"x-token": t.token,
36
	}, nil
37
}
38

39
func (tokenAuth) RequireTransportSecurity() bool {
40
	return true
41
}
42

43
func main() {
44
	opts := []grpc.DialOption{
45
		grpc.WithTransportCredentials(credentials.NewTLS(&tls.Config{})),
46
		grpc.WithKeepaliveParams(kacp),
47
		grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(1024*1024*1024), grpc.UseCompressor(gzip.Name)),
48
		grpc.WithPerRPCCredentials(tokenAuth{token: token}),
49
	}
50

51
	conn, err := grpc.NewClient(endpoint, opts...)
52
	if err != nil {
53
		log.Fatalf("Failed to connect: %v", err)
54
	}
55
	defer conn.Close()
56

57
	client := pb.NewGeyserClient(conn)
58

59
	req := &pb.SubscribeReplayInfoRequest{}
60
	resp, err := client.SubscribeReplayInfo(context.Background(), req)
61
	if err != nil {
62
		log.Fatalf("Failed to get replay info: %v", err)
63
	}
64

65
	if resp.FirstAvailable != nil {
66
		fmt.Printf("First available slot for replay: %d\n", *resp.FirstAvailable)
67
	} else {
68
		fmt.Println("No replay information available")
69
	}
70
}
71

1
import Client from "@triton-one/yellowstone-grpc";
2

3
const ENDPOINT = "https://YOUR_QN_ENDPOINT:443";
4
const TOKEN = "YOUR_TOKEN_NUMBER";
5

6
async function main() {
7
    const client = new Client(ENDPOINT, TOKEN, {
8
        grpcDefaultCompressionAlgorithm: 0, // 0 = gzip, 1 = zstd
9
    });
10
    await client.connect();
11

12
    try {
13
        const response = await client.subscribeReplayInfo();
14
        
15
        if (response.firstAvailable !== undefined) {
16
            console.log("First available slot for replay:", response.firstAvailable);
17
        } else {
18
            console.log("No replay information available");
19
        }
20
        
21
    } catch (error) {
22
        console.error("Error getting replay info:", error);
23
    }
24
}
25

26
main()
27
    .catch((err) => {
28
        console.error("Unhandled error:", err);
29
        process.exit(1);
30
    });
31

1
import Client from "@triton-one/yellowstone-grpc";
2

3
const ENDPOINT = "https://YOUR_QN_ENDPOINT:443";
4
const TOKEN = "YOUR_TOKEN_NUMBER";
5

6
async function main() {
7
    const client = new Client(ENDPOINT, TOKEN, {
8
        grpcDefaultCompressionAlgorithm: 0, // 0 = gzip, 1 = zstd
9
    });
10
    await client.connect();
11

12
    try {
13
        const response = await client.subscribeReplayInfo();
14
        
15
        if (response.firstAvailable !== undefined) {
16
            console.log("First available slot for replay:", response.firstAvailable);
17
        } else {
18
            console.log("No replay information available");
19
        }
20
        
21
    } catch (error) {
22
        console.error("Error getting replay info:", error);
23
    }
24
}
25

26
main()
27
    .catch((err) => {
28
        console.error("Unhandled error:", err);
29
        process.exit(1);
30
    });
31

Don't have an account yet?

Create your Quicknode endpoint in seconds and start building

Get started for free