subscribeReplayInfo gRPC Method - Solana gRPC

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

Paramètres

Cette méthode n'accepte aucun paramètre

Retours

firstAvailable

chaîne de caractères

Chargement en cours...

Demande

1
paquet principal
2

3
import (
4
	« contexte »
5
	« crypto/tls »
6
	« fmt »
7
	« journal »
8
	« temps »
9

10
	pb "yellowstone/proto"
11

12
	« google.golang.grpc »
13
	« google.golang.grpc »
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
	jeton chaîne de caractères
31
}
32

33
func (t tokenAuth) GetRequestMetadata(ctx context.Context, in ...string) (map[string]string, error) {
34
	retour carte[chaîne]chaîne{
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(informations d'authentification.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
	si err != nil {
53
		log.Fatalf("Failed to connect: %v", err)
54
	}
55
	reporter conn.Fermer()
56

57
	client := pb.NewGeyserClient(conn)
58

59
	req := &pb.SubscribeReplayInfoRequest{}
60
	resp, err := client.SubscribeReplayInfo(context.Background(), req)
61
	si 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
	} sinon {
68
		fmt.Println("No replay information available")
69
	}
70
}
71

1
paquet principal
2

3
import (
4
	« contexte »
5
	« crypto/tls »
6
	« fmt »
7
	« journal »
8
	« temps »
9

10
	pb "yellowstone/proto"
11

12
	« google.golang.grpc »
13
	« google.golang.grpc »
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
	jeton chaîne de caractères
31
}
32

33
func (t tokenAuth) GetRequestMetadata(ctx context.Context, in ...string) (map[string]string, error) {
34
	retour carte[chaîne]chaîne{
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(informations d'authentification.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
	si err != nil {
53
		log.Fatalf("Failed to connect: %v", err)
54
	}
55
	reporter conn.Fermer()
56

57
	client := pb.NewGeyserClient(conn)
58

59
	req := &pb.SubscribeReplayInfoRequest{}
60
	resp, err := client.SubscribeReplayInfo(context.Background(), req)
61
	si 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
	} sinon {
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 fonction 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
        } sinon {
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 fonction 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
        } sinon {
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

Vous n'avez pas encore de compte ?

Créez votreendpoint Quicknode endpoint quelques secondes et commencez à développer

Commencez gratuitement