collector

Documentation

Index

• type KyveBlockCollector
  • func NewKyveBlockCollector(poolId int64, chainRest string) (*KyveBlockCollector, error)
  • func (collector *KyveBlockCollector) GetBlock(height int64) ([]byte, error)
  • func (collector *KyveBlockCollector) GetEarliestAvailableHeight() int64
  • func (collector *KyveBlockCollector) GetLatestAvailableHeight() int64
  • func (collector *KyveBlockCollector) StreamBlocks(blockCh chan<- *types.BlockItem, errorCh chan<- error, ...)
• type KyveSnapshotCollector
  • func NewKyveSnapshotCollector(poolId int64, chainRest string) (*KyveSnapshotCollector, error)
  • func (collector *KyveSnapshotCollector) DownloadChunkFromBundleId(bundleId int64) ([]byte, error)
  • func (collector *KyveSnapshotCollector) FindSnapshotBundleIdForHeight(height int64) (int64, error)
  • func (collector *KyveSnapshotCollector) GetCurrentHeight() (int64, error)
  • func (collector *KyveSnapshotCollector) GetEarliestAvailableHeight() int64
  • func (collector *KyveSnapshotCollector) GetInterval() int64
  • func (collector *KyveSnapshotCollector) GetLatestAvailableHeight() int64
  • func (collector *KyveSnapshotCollector) GetSnapshotFromBundleId(bundleId int64) (*types.SnapshotDataItem, error)
  • func (collector *KyveSnapshotCollector) GetSnapshotHeight(targetHeight int64, isServeSnapshot bool) int64
• type RpcBlockCollector
  • func NewRpcBlockCollector(rpc string, blockRpcReqTimeout int64) (*RpcBlockCollector, error)
  • func (collector *RpcBlockCollector) GetBlock(height int64) ([]byte, error)
  • func (collector *RpcBlockCollector) GetEarliestAvailableHeight() int64
  • func (collector *RpcBlockCollector) GetLatestAvailableHeight() int64
  • func (collector *RpcBlockCollector) StreamBlocks(blockCh chan<- *types.BlockItem, errorCh chan<- error, ...)

Types

type KyveBlockCollector

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

func NewKyveBlockCollector

func NewKyveBlockCollector(poolId int64, chainRest string) (*KyveBlockCollector, error)

func (*KyveBlockCollector) GetBlock

func (collector *KyveBlockCollector) GetBlock(height int64) ([]byte, error)

func (*KyveBlockCollector) GetEarliestAvailableHeight

func (collector *KyveBlockCollector) GetEarliestAvailableHeight() int64

func (*KyveBlockCollector) GetLatestAvailableHeight

func (collector *KyveBlockCollector) GetLatestAvailableHeight() int64

func (*KyveBlockCollector) StreamBlocks

func (collector *KyveBlockCollector) StreamBlocks(blockCh chan<- *types.BlockItem, errorCh chan<- error, continuationHeight, targetHeight int64)

type KyveSnapshotCollector

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

func NewKyveSnapshotCollector

func NewKyveSnapshotCollector(poolId int64, chainRest string) (*KyveSnapshotCollector, error)

func (*KyveSnapshotCollector) DownloadChunkFromBundleId

func (collector *KyveSnapshotCollector) DownloadChunkFromBundleId(bundleId int64) ([]byte, error)

func (*KyveSnapshotCollector) FindSnapshotBundleIdForHeight

func (collector *KyveSnapshotCollector) FindSnapshotBundleIdForHeight(height int64) (int64, error)

func (*KyveSnapshotCollector) GetCurrentHeight

func (collector *KyveSnapshotCollector) GetCurrentHeight() (int64, error)

func (*KyveSnapshotCollector) GetEarliestAvailableHeight

func (collector *KyveSnapshotCollector) GetEarliestAvailableHeight() int64

func (*KyveSnapshotCollector) GetInterval

func (collector *KyveSnapshotCollector) GetInterval() int64

func (*KyveSnapshotCollector) GetLatestAvailableHeight

func (collector *KyveSnapshotCollector) GetLatestAvailableHeight() int64

func (*KyveSnapshotCollector) GetSnapshotFromBundleId

func (collector *KyveSnapshotCollector) GetSnapshotFromBundleId(bundleId int64) (*types.SnapshotDataItem, error)

func (*KyveSnapshotCollector) GetSnapshotHeight

func (collector *KyveSnapshotCollector) GetSnapshotHeight(targetHeight int64, isServeSnapshot bool) int64

type RpcBlockCollector

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

func NewRpcBlockCollector

func NewRpcBlockCollector(rpc string, blockRpcReqTimeout int64) (*RpcBlockCollector, error)

func (*RpcBlockCollector) GetBlock

func (collector *RpcBlockCollector) GetBlock(height int64) ([]byte, error)

func (*RpcBlockCollector) GetEarliestAvailableHeight

func (collector *RpcBlockCollector) GetEarliestAvailableHeight() int64

func (*RpcBlockCollector) GetLatestAvailableHeight

func (collector *RpcBlockCollector) GetLatestAvailableHeight() int64

func (*RpcBlockCollector) StreamBlocks

func (collector *RpcBlockCollector) StreamBlocks(blockCh chan<- *types.BlockItem, errorCh chan<- error, continuationHeight, targetHeight int64)