indexer

package
v0.5.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 8, 2026 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Overview

Package indexer implements the runner for the indexer process.

The indexer has two concurrent responsibilities:

  1. A processor that streams TokenTransferEvents from the Canton ledger via GetUpdates and persists them (events, token supply, balances) into a dedicated PostgreSQL database.
  2. An HTTP read API that exposes the indexed data under /indexer/v1.

Both halves run under the same context via errgroup so that an OS signal or a fatal error in either half cancels the other cleanly.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Server

type Server struct {
	// contains filtered or unexported fields
}

Server holds the configuration for the indexer process.

func NewServer

func NewServer(cfg *config.IndexerServer) *Server

NewServer creates a new indexer Server.

func (*Server) Run

func (s *Server) Run() error

Run starts the Canton stream processor and the HTTP read API concurrently. It blocks until an OS shutdown signal is received or a fatal error occurs.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL