subscribeReplayInfo gRPC Method - Solana gRPC

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

पैरामीटर

यह विधि किसी भी पैरामीटर को स्वीकार नहीं करती है।

रिटर्न

firstAvailable

डोरी

लोड हो रहा है...

अनुरोध

1
पैकेज मुख्य
2

3
आयात (
4
	"प्रसंग"
5
	"क्रिप्टो/टीएलएस"
6
	"एफएमटी"
7
	"लकड़ी का लट्ठा"
8
	"समय"
9

10
	pb "yellowstone/proto"
11

12
	"google.golang.org/ grpc "
13
	"google.golang.org/ 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
टोकन स्ट्रिंग
31
}
32

33
func (t tokenAuth) GetRequestMetadata(ctx context.Context, in ...string) (map[string]string, error) {
34
	वापस करना मानचित्र [ स्ट्रिंग ] स्ट्रिंग {
35
		"x-token": t.token,
36
	} , शून्य
37
}
38

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

43
समारोह मुख्य ( ) {
44
	opts := []grpc.DialOption{
45
grpc ( 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
	यदि त्रुटि != शून्य {
53
		log.Fatalf("Failed to connect: %v", err)
54
	}
55
	कनेक्शन स्थगित करें । बंद करें ( )
56

57
	client := pb.NewGeyserClient(conn)
58

59
	req := &pb.SubscribeReplayInfoRequest{}
60
	resp, err := client.SubscribeReplayInfo(context.Background(), req)
61
	यदि त्रुटि != शून्य {
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
	} अन्य {
68
		fmt.Println("No replay information available")
69
	}
70
}
71

1
पैकेज मुख्य
2

3
आयात (
4
	"प्रसंग"
5
	"क्रिप्टो/टीएलएस"
6
	"एफएमटी"
7
	"लकड़ी का लट्ठा"
8
	"समय"
9

10
	pb "yellowstone/proto"
11

12
	"google.golang.org/ grpc "
13
	"google.golang.org/ 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
टोकन स्ट्रिंग
31
}
32

33
func (t tokenAuth) GetRequestMetadata(ctx context.Context, in ...string) (map[string]string, error) {
34
	वापस करना मानचित्र [ स्ट्रिंग ] स्ट्रिंग {
35
		"x-token": t.token,
36
	} , शून्य
37
}
38

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

43
समारोह मुख्य ( ) {
44
	opts := []grpc.DialOption{
45
grpc ( 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
	यदि त्रुटि != शून्य {
53
		log.Fatalf("Failed to connect: %v", err)
54
	}
55
	कनेक्शन स्थगित करें । बंद करें ( )
56

57
	client := pb.NewGeyserClient(conn)
58

59
	req := &pb.SubscribeReplayInfoRequest{}
60
	resp, err := client.SubscribeReplayInfo(context.Background(), req)
61
	यदि त्रुटि != शून्य {
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
	} अन्य {
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
अतुल्यकालिक समारोह मुख्य ( ) {
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
अतुल्यकालिक समारोह मुख्य ( ) {
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

अब तक कोई खाता नहीं है?

अपना बनाएँ Quicknode endpoint कुछ ही सेकंड में निर्माण शुरू करें

मुफ़्त में शुरुआत करें