subscribeReplayInfo gRPC Method - Solana gRPC

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

Parâmetros

Este método não aceita quaisquer parâmetros

Devoluções

firstAvailable

cadeia de caracteres

Carregando...

Pedido

1
pacote principal
2

3
importar (
4
	"contexto"
5
	"crypto/tls"
6
	"fmt"
7
	"registo"
8
	"tempo"
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
	token cadeia de caracteres
31
}
32

33
func (t tokenAuth) GetRequestMetadata(ctx context.Context, in ...string) (map[string]string, error) {
34
	retornar mapa[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(credenciais.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
	se err != nil {
53
		log.Fatalf("Failed to connect: %v", err)
54
	}
55
	adiar conn.Fechar()
56

57
	client := pb.NewGeyserClient(conn)
58

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

1
pacote principal
2

3
importar (
4
	"contexto"
5
	"crypto/tls"
6
	"fmt"
7
	"registo"
8
	"tempo"
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
	token cadeia de caracteres
31
}
32

33
func (t tokenAuth) GetRequestMetadata(ctx context.Context, in ...string) (map[string]string, error) {
34
	retornar mapa[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(credenciais.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
	se err != nil {
53
		log.Fatalf("Failed to connect: %v", err)
54
	}
55
	adiar conn.Fechar()
56

57
	client := pb.NewGeyserClient(conn)
58

59
	req := &pb.SubscribeReplayInfoRequest{}
60
	resp, err := client.SubscribeReplayInfo(context.Background(), req)
61
	se 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
	} caso contrário {
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 função 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 função 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

Ainda não tem uma conta?

Crieendpoint seuendpoint Quicknode endpoint segundos e comece a desenvolver

Comece gratuitamente