subscribeEntries gRPC Method - Solana gRPC

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

पैरामीटर

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

रिटर्न

slot

डोरी

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

entries

डोरी

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

अनुरोध

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

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

10
	pb "shredstream/proto"
11

12
	"google.golang.org/ grpc "
13
	"google.golang.org/ grpc /साख"
14
	"google.golang.org/grpc/keepalive"
15
)
16

17
// Quicknode endpoints consist of two crucial components: the endpoint name and the corresponding token
18
// For eg: QN Endpoint: https://docs-demo.solana-mainnet.quiknode.pro/abcde123456789
19
// endpoint will be: docs-demo.solana-mainnet.quiknode.pro:443  {443 is the port number for gRPC}
20
// token will be : abcde123456789
21

22
// Each message carries the serialized bytes of a Vec<Entry> of Solana ledger entries from one slot;
23
// a slot is delivered as multiple messages:
24
// https://docs.rs/solana-entry/latest/solana_entry/entry/struct.Entry.html
25
//
26
// SubscribeEntries belongs to the shredstream.ShredstreamProxy service, not to Geyser, so it needs
27
// its own generated client. Save the following as shredstream.proto and generate the client with
28
// protoc --go_out=module=shredstream:. --go-grpc_out=module=shredstream:. shredstream.proto
29
//
30
//   syntax = "proto3";
31
//   package shredstream;
32
//   option go_package = "shredstream/proto";
33
//
34
//   message SubscribeEntriesRequest {}
35
//
36
//   message Entry {
37
//     uint64 slot = 1;
38
//     bytes entries = 2;
39
//   }
40
//
41
//   service ShredstreamProxy {
42
//     rpc SubscribeEntries(SubscribeEntriesRequest) returns (stream Entry) {}
43
//   }
44
//
45
// This service does not accept compressed requests, so do not add grpc.UseCompressor to the dial options.
46

47
var (
48
	endpoint = "YOUR_QN_ENDPOINT:443"
49
	token    = "YOUR_TOKEN_NUMBER"
50
)
51

52
var kacp = keepalive.ClientParameters{
53
	Time:                10 * time.Second,
54
	Timeout:             time.Second,
55
	PermitWithoutStream: true,
56
}
57

58
type tokenAuth struct {
59
टोकन स्ट्रिंग
60
}
61

62
func (t tokenAuth) GetRequestMetadata(ctx context.Context, in ...string) (map[string]string, error) {
63
	वापस करना मानचित्र [ स्ट्रिंग ] स्ट्रिंग {
64
		"x-token": t.token,
65
	} , शून्य
66
}
67

68
func (tokenAuth) RequireTransportSecurity() bool {
69
	return true
70
}
71

72
समारोह मुख्य ( ) {
73
	opts := []grpc.DialOption{
74
grpc ( credentials.NewTLS ( & tls.Config { } ) )​​​​​​​
75
		grpc.WithKeepaliveParams(kacp),
76
		grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(1024*1024*1024)),
77
		grpc.WithPerRPCCredentials(tokenAuth{token: token}),
78
	}
79

80
	conn, err := grpc.NewClient(endpoint, opts...)
81
	यदि त्रुटि != शून्य {
82
		log.Fatalf("Failed to connect: %v", err)
83
	}
84
	कनेक्शन स्थगित करें । बंद करें ( )
85

86
	client := pb.NewShredstreamProxyClient(conn)
87

88
	stream, err := client.SubscribeEntries(context.Background(), &pb.SubscribeEntriesRequest{})
89
	यदि त्रुटि != शून्य {
90
		log.Fatalf("Failed to subscribe to entries: %v", err)
91
	}
92

93
	for {
94
		entry, err := stream.Recv()
95
		if err != nil {
96
			fmt.Printf("Failed to receive entry: %v\n", err)
97
			return
98
		}
99

100
		fmt.Printf("Slot: %d, entries payload: %d bytes\n", entry.GetSlot(), len(entry.GetEntries()))
101
	}
102
}
103

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

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

10
	pb "shredstream/proto"
11

12
	"google.golang.org/ grpc "
13
	"google.golang.org/ grpc /साख"
14
	"google.golang.org/grpc/keepalive"
15
)
16

17
// Quicknode endpoints consist of two crucial components: the endpoint name and the corresponding token
18
// For eg: QN Endpoint: https://docs-demo.solana-mainnet.quiknode.pro/abcde123456789
19
// endpoint will be: docs-demo.solana-mainnet.quiknode.pro:443  {443 is the port number for gRPC}
20
// token will be : abcde123456789
21

22
// Each message carries the serialized bytes of a Vec<Entry> of Solana ledger entries from one slot;
23
// a slot is delivered as multiple messages:
24
// https://docs.rs/solana-entry/latest/solana_entry/entry/struct.Entry.html
25
//
26
// SubscribeEntries belongs to the shredstream.ShredstreamProxy service, not to Geyser, so it needs
27
// its own generated client. Save the following as shredstream.proto and generate the client with
28
// protoc --go_out=module=shredstream:. --go-grpc_out=module=shredstream:. shredstream.proto
29
//
30
//   syntax = "proto3";
31
//   package shredstream;
32
//   option go_package = "shredstream/proto";
33
//
34
//   message SubscribeEntriesRequest {}
35
//
36
//   message Entry {
37
//     uint64 slot = 1;
38
//     bytes entries = 2;
39
//   }
40
//
41
//   service ShredstreamProxy {
42
//     rpc SubscribeEntries(SubscribeEntriesRequest) returns (stream Entry) {}
43
//   }
44
//
45
// This service does not accept compressed requests, so do not add grpc.UseCompressor to the dial options.
46

47
var (
48
	endpoint = "YOUR_QN_ENDPOINT:443"
49
	token    = "YOUR_TOKEN_NUMBER"
50
)
51

52
var kacp = keepalive.ClientParameters{
53
	Time:                10 * time.Second,
54
	Timeout:             time.Second,
55
	PermitWithoutStream: true,
56
}
57

58
type tokenAuth struct {
59
टोकन स्ट्रिंग
60
}
61

62
func (t tokenAuth) GetRequestMetadata(ctx context.Context, in ...string) (map[string]string, error) {
63
	वापस करना मानचित्र [ स्ट्रिंग ] स्ट्रिंग {
64
		"x-token": t.token,
65
	} , शून्य
66
}
67

68
func (tokenAuth) RequireTransportSecurity() bool {
69
	return true
70
}
71

72
समारोह मुख्य ( ) {
73
	opts := []grpc.DialOption{
74
grpc ( credentials.NewTLS ( & tls.Config { } ) )​​​​​​​
75
		grpc.WithKeepaliveParams(kacp),
76
		grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(1024*1024*1024)),
77
		grpc.WithPerRPCCredentials(tokenAuth{token: token}),
78
	}
79

80
	conn, err := grpc.NewClient(endpoint, opts...)
81
	यदि त्रुटि != शून्य {
82
		log.Fatalf("Failed to connect: %v", err)
83
	}
84
	कनेक्शन स्थगित करें । बंद करें ( )
85

86
	client := pb.NewShredstreamProxyClient(conn)
87

88
	stream, err := client.SubscribeEntries(context.Background(), &pb.SubscribeEntriesRequest{})
89
	यदि त्रुटि != शून्य {
90
		log.Fatalf("Failed to subscribe to entries: %v", err)
91
	}
92

93
	for {
94
		entry, err := stream.Recv()
95
		if err != nil {
96
			fmt.Printf("Failed to receive entry: %v\n", err)
97
			return
98
		}
99

100
		fmt.Printf("Slot: %d, entries payload: %d bytes\n", entry.GetSlot(), len(entry.GetEntries()))
101
	}
102
}
103

1
import * as grpc from "@grpc/grpc-js";
2
import * as protoLoader from "@grpc/proto-loader";
3

4
// Quicknode endpoints consist of two crucial components: the endpoint name and the corresponding token
5
// For eg: QN Endpoint: https://docs-demo.solana-mainnet.quiknode.pro/abcde123456789
6
// endpoint will be: docs-demo.solana-mainnet.quiknode.pro:443  {443 is the port number for gRPC}
7
// token will be : abcde123456789
8

9
// Each message carries the serialized bytes of a Vec<Entry> of Solana ledger entries from one slot;
10
// a slot is delivered as multiple messages:
11
// https://docs.rs/solana-entry/latest/solana_entry/entry/struct.Entry.html
12
//
13
// SubscribeEntries belongs to the shredstream.ShredstreamProxy service, not to Geyser, so it is not
14
// exposed by the @triton-one/yellowstone-grpc client. Save the following as shredstream.proto next to
15
// this file and load it with @grpc/proto-loader:
16
//
17
//   syntax = "proto3";
18
//   package shredstream;
19
//   option go_package = "shredstream/proto";
20
//
21
//   message SubscribeEntriesRequest {}
22
//
23
//   message Entry {
24
//     uint64 slot = 1;
25
//     bytes entries = 2;
26
//   }
27
//
28
//   service ShredstreamProxy {
29
//     rpc SubscribeEntries(SubscribeEntriesRequest) returns (stream Entry) {}
30
//   }
31
//
32
// @grpc/grpc-js takes a host:port target, so do not prefix the endpoint with https://
33

34
const ENDPOINT = "YOUR_QN_ENDPOINT:443";
35
const TOKEN = "YOUR_TOKEN_NUMBER";
36

37
const packageDefinition = protoLoader.loadSync("./shredstream.proto", {
38
    keepCase: true,
39
    longs: String,
40
    enums: String,
41
    defaults: true,
42
    oneofs: true,
43
} ) ;
44
const shredstream = (grpc.loadPackageDefinition(packageDefinition) as any).shredstream;
45

46
function main() {
47
    const metadata = new grpc.Metadata();
48
    metadata.add("x-token", TOKEN);
49

50
    const client = new shredstream.ShredstreamProxy(ENDPOINT, grpc.credentials.createSsl());
51
    const stream = client.SubscribeEntries({}, metadata);
52

53
    stream.on("data", (entry: { slot: string; entries: Buffer }) => {
54
        console.log(`Slot: ${entry.slot}, entries payload: ${entry.entries.length} bytes`);
55
    });
56

57
    stream.on("error", (error: Error) => {
58
        console.error("Stream error:", error);
59
    });
60

61
    stream.on("end", () => {
62
        console.log("Stream ended");
63
    });
64
}
65

66
main();
67

1
import * as grpc from "@grpc/grpc-js";
2
import * as protoLoader from "@grpc/proto-loader";
3

4
// Quicknode endpoints consist of two crucial components: the endpoint name and the corresponding token
5
// For eg: QN Endpoint: https://docs-demo.solana-mainnet.quiknode.pro/abcde123456789
6
// endpoint will be: docs-demo.solana-mainnet.quiknode.pro:443  {443 is the port number for gRPC}
7
// token will be : abcde123456789
8

9
// Each message carries the serialized bytes of a Vec<Entry> of Solana ledger entries from one slot;
10
// a slot is delivered as multiple messages:
11
// https://docs.rs/solana-entry/latest/solana_entry/entry/struct.Entry.html
12
//
13
// SubscribeEntries belongs to the shredstream.ShredstreamProxy service, not to Geyser, so it is not
14
// exposed by the @triton-one/yellowstone-grpc client. Save the following as shredstream.proto next to
15
// this file and load it with @grpc/proto-loader:
16
//
17
//   syntax = "proto3";
18
//   package shredstream;
19
//   option go_package = "shredstream/proto";
20
//
21
//   message SubscribeEntriesRequest {}
22
//
23
//   message Entry {
24
//     uint64 slot = 1;
25
//     bytes entries = 2;
26
//   }
27
//
28
//   service ShredstreamProxy {
29
//     rpc SubscribeEntries(SubscribeEntriesRequest) returns (stream Entry) {}
30
//   }
31
//
32
// @grpc/grpc-js takes a host:port target, so do not prefix the endpoint with https://
33

34
const ENDPOINT = "YOUR_QN_ENDPOINT:443";
35
const TOKEN = "YOUR_TOKEN_NUMBER";
36

37
const packageDefinition = protoLoader.loadSync("./shredstream.proto", {
38
    keepCase: true,
39
    longs: String,
40
    enums: String,
41
    defaults: true,
42
    oneofs: true,
43
} ) ;
44
const shredstream = (grpc.loadPackageDefinition(packageDefinition) as any).shredstream;
45

46
function main() {
47
    const metadata = new grpc.Metadata();
48
    metadata.add("x-token", TOKEN);
49

50
    const client = new shredstream.ShredstreamProxy(ENDPOINT, grpc.credentials.createSsl());
51
    const stream = client.SubscribeEntries({}, metadata);
52

53
    stream.on("data", (entry: { slot: string; entries: Buffer }) => {
54
        console.log(`Slot: ${entry.slot}, entries payload: ${entry.entries.length} bytes`);
55
    });
56

57
    stream.on("error", (error: Error) => {
58
        console.error("Stream error:", error);
59
    });
60

61
    stream.on("end", () => {
62
        console.log("Stream ended");
63
    });
64
}
65

66
main();
67

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

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

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