subscribeReplayInfo gRPC Method - Solana gRPC

Solana gRPC ist in den Tarifen „Scale“ und „Business“ enthalten. In den Tarifen „Build“ und „Accelerate“ ist es weiterhin über das Solana gRPC-Add-on verfügbar.

Parameter

Diese Methode akzeptiert keine Parameter.

Rücksendungen

first_available

Zeichenkette

Wird geladen...

Anfrage

1
Paket Hauptteil
2

3
import (
4
	„Kontext“
5
	„crypto/tls“
6
	„fmt“
7
	„log“
8
	„Zeit“
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
	Endpunkt = "YOUR_QN_ENDPOINT:10000"
20
	Token    = "IHRE_TOKEN-NUMMER"
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 Zeichenkette
31
}
32

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

39
func (tokenAuth) RequireTransportSecurity() bool {
40
	Zurück false
41
}
42

43
func main() {
44
	opts := []grpc.DialOption{
45
		grpc.WithTransportCredentials(Anmeldedaten.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(Endpunkt, opts...)
52
	wenn err != nil {
53
		Protokoll.Fatalf(„Verbindung konnte nicht hergestellt werden: %v“, err)
54
	}
55
	aufschieben conn.Schließen()
56

57
	Client := pb.NewGeyserClient(conn)
58

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

3
import (
4
	„Kontext“
5
	„crypto/tls“
6
	„fmt“
7
	„log“
8
	„Zeit“
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
	Endpunkt = "YOUR_QN_ENDPOINT:10000"
20
	Token    = "IHRE_TOKEN-NUMMER"
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 Zeichenkette
31
}
32

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

39
func (tokenAuth) RequireTransportSecurity() bool {
40
	Zurück false
41
}
42

43
func main() {
44
	opts := []grpc.DialOption{
45
		grpc.WithTransportCredentials(Anmeldedaten.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(Endpunkt, opts...)
52
	wenn err != nil {
53
		Protokoll.Fatalf(„Verbindung konnte nicht hergestellt werden: %v“, err)
54
	}
55
	aufschieben conn.Schließen()
56

57
	Client := pb.NewGeyserClient(conn)
58

59
	req := &pb.SubscribeReplayInfoRequest{}
60
	resp, err := client.SubscribeReplayInfo(context.Background(), req)
61
	wenn 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 = "YOUR_QN_ENDPOINT:10000";
4
const TOKEN = "IHRE_TOKEN-NUMMER";
5

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

9
    versuchen {
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 (Fehler) {
19
        console.error("Error getting replay info:", error);
20
    }
21
}
22

23
Hauptseite()
24
    .catch((err) => {
25
        Konsole.Fehler(„Unbehandelter Fehler:“, err);
26
        Prozess.Beenden(1);
27
    });
28

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

3
const ENDPOINT = "YOUR_QN_ENDPOINT:10000";
4
const TOKEN = "IHRE_TOKEN-NUMMER";
5

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

9
    versuchen {
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 (Fehler) {
19
        console.error("Error getting replay info:", error);
20
    }
21
}
22

23
Hauptseite()
24
    .catch((err) => {
25
        Konsole.Fehler(„Unbehandelter Fehler:“, err);
26
        Prozess.Beenden(1);
27
    });
28

Haben Sie noch kein Konto?

Erstellen Sie Ihren Quicknode-Endpunkt in Sekundenschnelle und legen Sie los

Kostenlos loslegen