subscribeReplayInfo gRPC Method - Solana gRPC

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

参数

该方法不接受任何参数

退货

firstAvailable

字符串

正在加载...

请求

1
包 main
2

3
import (
4
	"上下文"
5
	"crypto/tls"
6
	"fmt"
7
	“日志”
8
	“时间”
9

10
	pb "yellowstone"
11

12
	"google.golang.grpc"
13
	"google.golang.grpc"
14
	"google.golang.grpc"
15
	"google.golang.grpc"
16
)
17

18
var (
19
	endpoint = "YOUR_QN_ENDPOINT:443"
20
	token    = "您的令牌编号"
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 字符串
31
}
32

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

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

43
func main() {
44
	opts := []grpc.DialOption{
45
		grpc.WithTransportCredentials(凭证.NewTLS(&tls.配置{})),
46
		grpc.WithKeepaliveParams(kacp)，
47
		grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(1024*1024*1024), grpc.UseCompressor(gzip.名称)),
48
		grpc.WithPerRPCCredentials(tokenAuth{token: token}),
49
	}
50

51
	conn, err := grpc.NewClient(endpoint, opts...)
52
	如果 err != nil {
53
		log.Fatalf("连接失败：%v", err)
54
	}
55
	推迟 conn.关闭()
56

57
	client := pb.NewGeyserClient(conn)
58

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

3
import (
4
	"上下文"
5
	"crypto/tls"
6
	"fmt"
7
	“日志”
8
	“时间”
9

10
	pb "yellowstone"
11

12
	"google.golang.grpc"
13
	"google.golang.grpc"
14
	"google.golang.grpc"
15
	"google.golang.grpc"
16
)
17

18
var (
19
	endpoint = "YOUR_QN_ENDPOINT:443"
20
	token    = "您的令牌编号"
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 字符串
31
}
32

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

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

43
func main() {
44
	opts := []grpc.DialOption{
45
		grpc.WithTransportCredentials(凭证.NewTLS(&tls.配置{})),
46
		grpc.WithKeepaliveParams(kacp)，
47
		grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(1024*1024*1024), grpc.UseCompressor(gzip.名称)),
48
		grpc.WithPerRPCCredentials(tokenAuth{token: token}),
49
	}
50

51
	conn, err := grpc.NewClient(endpoint, opts...)
52
	如果 err != nil {
53
		log.Fatalf("连接失败：%v", err)
54
	}
55
	推迟 conn.关闭()
56

57
	client := pb.NewGeyserClient(conn)
58

59
	req := &pb.SubscribeReplayInfoRequest{}
60
	resp, err := client.SubscribeReplayInfo(context.Background(), req)
61
	如果 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 = "您的令牌编号";
5

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

12
    试一试 {
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
主()
27
    .catch((err) => {
28
        控制台.错误("未处理的错误：", err);
29
        流程.退出(1);
30
    });
31

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

3
const ENDPOINT = "https://YOUR_QN_ENDPOINT:443";
4
const TOKEN = "您的令牌编号";
5

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

12
    试一试 {
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
主()
27
    .catch((err) => {
28
        控制台.错误("未处理的错误：", err);
29
        流程.退出(1);
30
    });
31

还没有账号吗？

endpoint 几秒钟endpoint 创建您的Quicknode endpoint ，并开始构建

免费开始使用