Ana içeriğe atla

​
Genel Bakış

Yellowstone gRPC, ağ ilerlemesini takip etmek için iki ilgili ancak birbirinden farklı abonelik türü sunar:
  • Slotlar — bir slot’un processed, confirmed veya finalized taahhüdüne ulaştığını gösteren hafif güncellemeler. Düşük bant genişliği, konsensüs izleme için kullanışlı.
  • Bloklar — işlemler, hesap güncellemeleri ve girişler dahil tam blok verisi. Daha yüksek bant genişliği, indeksleyiciler ve analitik için kullanışlı.

​
Slot Abonelikleri

​
Filtre Parametreleri

ParametreTürAçıklama
filterByCommitmentbooleantrue olduğunda, yalnızca aboneliğin taahhüt düzeyiyle eşleşen slot güncellemelerini yayınlar. false (varsayılan) olduğunda, tüm taahhüt düzeyleri için güncellemeler yayınlar.
interslotUpdatesbooleantrue olduğunda, yalnızca slot sınırlarında değil, slot içi durum değişikliklerini de yayınlar. Ayrıntılı gerçek zamanlı izleme için kullanışlı.

​
Örnek: Onaylanmış Slotları Takip Etme

import Client, { CommitmentLevel, SubscribeRequest } from "@triton-one/yellowstone-grpc";

const GRPC_URL = "https://your-endpoint.grpc.orbitflare.com";
const X_TOKEN = "YOUR_GRPC_TOKEN";

const client = new Client(GRPC_URL, X_TOKEN, {
  "grpc.max_receive_message_length": 64 * 1024 * 1024,
});

async function main() {
  const stream = await client.subscribe();

  const streamClosed = new Promise<void>((resolve, reject) => {
    stream.on("error", (error) => { reject(error); stream.end(); });
    stream.on("end", () => resolve());
    stream.on("close", () => resolve());
  });

  stream.on("data", (data) => {
    if (data.slot) {
      const { slot, parent, status } = data.slot;
      console.log(`Slot ${slot} (parent: ${parent}) — status: ${status}`);
    } else if (data.pong) {
      console.log("Pong received");
    }
  });

  const request: SubscribeRequest = {
    slots: {
      slotUpdates: {
        filterByCommitment: true,
      },
    },
    commitment: CommitmentLevel.CONFIRMED,
    accounts: {},
    accountsDataSlice: [],
    transactions: {},
    transactionsStatus: {},
    blocks: {},
    blocksMeta: {},
    entry: {},
    ping: { id: 1 },
  };

  await new Promise<void>((resolve, reject) => {
    stream.write(request, (err) => {
      if (err == null) resolve(); else reject(err);
    });
  });

  setInterval(() => {
    stream.write({ ping: { id: 1 }, accounts: {}, accountsDataSlice: [], transactions: {}, transactionsStatus: {}, slots: {}, blocks: {}, blocksMeta: {}, entry: {} }, () => {});
  }, 30_000);

  await streamClosed;
}

main();

​
Blok Abonelikleri

​
Filtre Parametreleri

ParametreTürAçıklama
accountIncludestring[]Bloklar içindeki işlemleri ve hesap güncellemelerini yalnızca bu hesapları içerecek şekilde filtrele.
includeTransactionsbooleanHer blok güncellemesine tam işlem verisi dahil et.
includeAccountsbooleanHer blok güncellemesine hesap durumu güncellemeleri dahil et.
includeEntriesbooleanHer blok güncellemesine girişler (yürütme birimleri) dahil et.
includeTransactions: true ve hesap filtresi olmayan blok abonelikleri çok yüksek veri hacimleri üretir. Akışı önem verdiğiniz hesaplarla daraltmak için accountInclude kullanın veya sürekli verim için özel bir düğümle birleştirin.

​
Örnek: İşlemlerle Blok Akışı

import Client, { CommitmentLevel, SubscribeRequest } from "@triton-one/yellowstone-grpc";

const client = new Client(
  "https://your-endpoint.grpc.orbitflare.com",
  "YOUR_GRPC_TOKEN",
  { "grpc.max_receive_message_length": 1024 * 1024 * 1024 }
);

async function main() {
  const stream = await client.subscribe();

  const streamClosed = new Promise<void>((resolve, reject) => {
    stream.on("error", (error) => { reject(error); stream.end(); });
    stream.on("end", () => resolve());
    stream.on("close", () => resolve());
  });

  stream.on("data", (data) => {
    if (data.block) {
      const { block } = data;
      console.log(`Block slot: ${block.slot}`);
      console.log(`  Blockhash: ${block.blockhash}`);
      console.log(`  Transactions: ${block.transactions?.length ?? 0}`);
    }
  });

  const request: SubscribeRequest = {
    blocks: {
      blockStream: {
        accountInclude: [
          "675kPX9MHTjS2zt1qfr1NYHuzeLXfQM9H24wFSUt1Mp8", // Raydium AMM
        ],
        includeTransactions: true,
        includeAccounts: false,
        includeEntries: false,
      },
    },
    commitment: CommitmentLevel.CONFIRMED,
    accounts: {},
    accountsDataSlice: [],
    transactions: {},
    transactionsStatus: {},
    slots: {},
    blocksMeta: {},
    entry: {},
    ping: { id: 1 },
  };

  await new Promise<void>((resolve, reject) => {
    stream.write(request, (err) => {
      if (err == null) resolve(); else reject(err);
    });
  });

  setInterval(() => {
    stream.write({ ping: { id: 1 }, accounts: {}, accountsDataSlice: [], transactions: {}, transactionsStatus: {}, slots: {}, blocks: {}, blocksMeta: {}, entry: {} }, () => {});
  }, 30_000);

  await streamClosed;
}

main();

​
Örnek: Yalnızca Blok Meta Verisi

İşlem yükü olmadan hafif blok başlıkları (slot, blockhash, blok zamanı) almak için blocksMeta kullanın: 
const request: SubscribeRequest = {
  blocksMeta: {
    blockMeta: {},
  },
  commitment: CommitmentLevel.FINALIZED,
  accounts: {},
  accountsDataSlice: [],
  transactions: {},
  transactionsStatus: {},
  slots: {},
  blocks: {},
  entry: {},
};

​
Slotlar ve Bloklar Arasında Seçim

İhtiyaçKullanım
Bir slot’un ne zaman kesinleştiğini tespit etmeSlot aboneliği (filterByCommitment: true)
Blok yüksekliği ilerlemesini takip etmeSlot aboneliği
Bir bloktaki tüm işlemleri indekslemeBlok aboneliği (includeTransactions: true)
Blok başına hesap durum değişikliklerini izlemeBlok aboneliği (includeAccounts: true)
Minimum gecikme konsensüs sinyaliprocessed durumunda slot aboneliği
Tam arşiv kalitesinde blok verisifinalized durumunda blok aboneliği