subscribeReplayInfo gRPC Method - Solana gRPC

Solana gRPC est inclus dans les plans Scale et Business. Pour les plans Build et Accelerate, il reste disponible via l'extension Solana gRPC.

Paramètres

Cette méthode n'accepte aucun paramètre

Renvoie

first_available

chaîne de caractères

Chargement...

Requête

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:10000"
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 false
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("Échec de la connexion : %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:10000"
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 false
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("Échec de la connexion : %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 POINT D'EXTRÉMITÉ = "VOTRE_POINT_D'ACCÈS_QN:10000";
4
const TOKEN = "VOTRE_NUMÉRO_DE_TOKEN";
5

6
async function main() {
7
    const client = new Client(ENDPOINT, TOKEN, {});
8

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

23
main()
24
    .catch((err) => {
25
        console.error("Erreur non gérée :", err);
26
        process.exit(1);
27
    });
28

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

3
const POINT D'EXTRÉMITÉ = "VOTRE_POINT_D'ACCÈS_QN:10000";
4
const TOKEN = "VOTRE_NUMÉRO_DE_TOKEN";
5

6
async function main() {
7
    const client = new Client(ENDPOINT, TOKEN, {});
8

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

23
main()
24
    .catch((err) => {
25
        console.error("Erreur non gérée :", err);
26
        process.exit(1);
27
    });
28

Vous n'avez pas encore de compte ?

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

Commencez gratuitement