statesync

Oct 1, 2024

Changes in this version

+ const ABCILatestSnapshotHeightPath

+ const CreateFunction

+ const CreateSchema

+ const CreateTable

type Snapshot

+ func GetLatestSnapshotInfo(ctx context.Context, client cometClient.ABCIClient) (*Snapshot, error)

+ func (s *Snapshot) MarshalBinary() ([]byte, error)

+ func (s *Snapshot) UnmarshalBinary(data []byte) error

Jul 15, 2024

Changes in this version

type SnapshotConfig

+ MaxRowSize int

Jun 11, 2024

Changes in this version

+ const ABCISnapshotQueryPath

+ const DefaultSnapshotFormat

+ const HashLen

+ var ErrAbortSnapshot = fmt.Errorf("abort snapshot")

+ var ErrAbortSnapshotChunk = fmt.Errorf("abort snapshot chunk")

+ var ErrInvalidSnapshot = fmt.Errorf("invalid snapshot")

+ var ErrRefetchSnapshotChunk = fmt.Errorf("refetch snapshot chunk")

+ var ErrRejectSnapshot = fmt.Errorf("reject snapshot")

+ var ErrRejectSnapshotChunk = fmt.Errorf("reject snapshot chunk")

+ var ErrRetrySnapshotChunk = fmt.Errorf("retry snapshot chunk")

+ var ErrStateSyncInProgress = fmt.Errorf("statesync already in progress")

+ var ErrStateSyncNotInProgress = fmt.Errorf("statesync not in progress")

+ var ErrUnsupportedSnapshotFormat = fmt.Errorf("unsupported snapshot format")

+ func ChainRPCClient(server string) (*rpchttp.HTTP, error)

+ func RestoreDB(ctx context.Context, snapshot io.Reader, ...) error

+ func ToABCIApplySnapshotChunkResponse(err error) abciTypes.ResponseApplySnapshotChunk_Result

+ func ToABCIOfferSnapshotResponse(err error) abciTypes.ResponseOfferSnapshot_Result

+ type DBConfig struct

+ DBHost string

+ DBName string

+ DBPass string

+ DBPort string

+ DBUser string

+ type DBSnapshotter interface

+ CreateSnapshot func(ctx context.Context, height uint64, snapshotID string) (*Snapshot, error)

+ type Snapshot struct

+ ChunkCount uint32

+ ChunkHashes [][HashLen]byte

+ Format uint32

+ Height uint64

+ SnapshotHash []byte

+ SnapshotSize uint64

+ func (s *Snapshot) SaveAs(file string) error

+ type SnapshotConfig struct

+ MaxSnapshots int

+ RecurringHeight uint64

+ SnapshotDir string

+ type SnapshotStore struct

+ func NewSnapshotStore(cfg *SnapshotConfig, dbCfg *DBConfig, logger log.Logger) (*SnapshotStore, error)

+ func (s *SnapshotStore) CreateSnapshot(ctx context.Context, height uint64, snapshotID string) error

+ func (s *SnapshotStore) IsSnapshotDue(height uint64) bool

+ func (s *SnapshotStore) ListSnapshots() []*Snapshot

+ func (s *SnapshotStore) LoadSnapshotChunk(height uint64, format uint32, chunkIdx uint32) ([]byte, error)

+ func (s *SnapshotStore) RegisterSnapshot(snapshot *Snapshot) error

+ type Snapshotter struct

+ func NewSnapshotter(cfg *DBConfig, dir string, logger log.Logger) *Snapshotter

+ func (s *Snapshotter) CreateSnapshot(ctx context.Context, height uint64, snapshotID string) (*Snapshot, error)

+ type StateSyncer struct

+ func NewStateSyncer(ctx context.Context, cfg *DBConfig, snapshotDir string, providers []string, ...) *StateSyncer

+ func (ss *StateSyncer) ApplySnapshotChunk(ctx context.Context, chunk []byte, index uint32) (bool, error)

+ func (ss *StateSyncer) OfferSnapshot(ctx context.Context, snapshot *Snapshot) error

+ type Streamer struct

+ func NewStreamer(numChunks uint32, chunkDir string, logger log.Logger) *Streamer

+ func (s *Streamer) Close() error

+ func (s *Streamer) Next() error

+ func (s *Streamer) Read(p []byte) (n int, err error)