index

package
v0.0.0-...-fd63c1f Latest Latest
Warning

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

 Go to latest Published: Mar 29, 2024 License: MIT Imports: 23 Imported by: 0

Documentation

Overview

Copyright (c) 2024 Blockwatch Data Inc. Author: alex@blockwatch.cc

Index

Constants

View Source 
const AccountIndexKey = "account"
View Source 
const BalanceIndexKey = "balance"
View Source 
const BigmapIndexKey = "bigmap"
View Source 
const BlockIndexKey = "block"
View Source 
const ChainIndexKey = "chain"
View Source 
const ConstantIndexKey = "constant"
View Source 
const ContractIndexKey = "contract"
View Source 
const CycleIndexKey = "cycle"
View Source 
const EventIndexKey = "event"
View Source 
const FlowIndexKey = "flow"
View Source 
const GovIndexKey = "gov"
View Source 
const IncomeIndexKey = "income"
View Source 
const MetadataIndexKey = "metadata"
View Source 
const OpIndexKey = "op"
View Source 
const SnapshotIndexKey = "snapshot"
View Source 
const StorageIndexKey = "storage"
View Source 
const SupplyIndexKey = "supply"
View Source 
const TicketIndexKey = "ticket"
View Source 
const TokenIndexKey = "token"

Variables

View Source 
var MaxStorageEntrySize = 0 // skip data larger than this, 0 = disable
View Source 
var RightsIndexKey = "rights"

Functions

func DisableLog 

func DisableLog()

DisableLog disables all library log output. Logging output is disabled by default until either UseLogger or SetLogWriter are called.

func UseLogger 

func UseLogger(logger logpkg.Logger)

UseLogger uses a specified Logger to output package logging info. This should be used in preference to SetLogWriter if the caller is also using logpkg.

Types

type AccountIndex 

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

func NewAccountIndex 

func NewAccountIndex() *AccountIndex

func (*AccountIndex) Close 

func (idx *AccountIndex) Close() error

func (*AccountIndex) ConnectBlock 

func (idx *AccountIndex) ConnectBlock(ctx context.Context, block *model.Block, builder model.BlockBuilder) error

func (*AccountIndex) Create 

func (idx *AccountIndex) Create(path, label string, opts interface{}) error

func (*AccountIndex) DB 

func (idx *AccountIndex) DB() *pack.DB

func (*AccountIndex) DeleteBlock 

func (idx *AccountIndex) DeleteBlock(ctx context.Context, height int64) error

func (*AccountIndex) DeleteCycle 

func (idx *AccountIndex) DeleteCycle(ctx context.Context, cycle int64) error

func (*AccountIndex) DisconnectBlock 

func (idx *AccountIndex) DisconnectBlock(ctx context.Context, block *model.Block, builder model.BlockBuilder) error

func (*AccountIndex) FinalizeSync 

func (idx *AccountIndex) FinalizeSync(_ context.Context) error

func (*AccountIndex) Flush 

func (idx *AccountIndex) Flush(ctx context.Context) error

func (*AccountIndex) Init 

func (idx *AccountIndex) Init(path, label string, opts interface{}) error

func (*AccountIndex) Key 

func (idx *AccountIndex) Key() string

func (*AccountIndex) Name 

func (idx *AccountIndex) Name() string

func (*AccountIndex) OnTaskComplete 

func (idx *AccountIndex) OnTaskComplete(_ context.Context, _ *task.TaskResult) error

func (*AccountIndex) Tables 

func (idx *AccountIndex) Tables() []*pack.Table

type BalanceIndex 

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

func NewBalanceIndex 

func NewBalanceIndex() *BalanceIndex

func (*BalanceIndex) Close 

func (idx *BalanceIndex) Close() error

func (*BalanceIndex) ConnectBlock 

func (idx *BalanceIndex) ConnectBlock(ctx context.Context, block *model.Block, builder model.BlockBuilder) error

func (*BalanceIndex) Create 

func (idx *BalanceIndex) Create(path, label string, opts interface{}) error

func (*BalanceIndex) DB 

func (idx *BalanceIndex) DB() *pack.DB

func (*BalanceIndex) DeleteBlock 

func (idx *BalanceIndex) DeleteBlock(ctx context.Context, height int64) error

func (*BalanceIndex) DeleteCycle 

func (idx *BalanceIndex) DeleteCycle(ctx context.Context, cycle int64) error

func (*BalanceIndex) DisconnectBlock 

func (idx *BalanceIndex) DisconnectBlock(ctx context.Context, block *model.Block, builder model.BlockBuilder) error

func (*BalanceIndex) FinalizeSync 

func (idx *BalanceIndex) FinalizeSync(_ context.Context) error

func (*BalanceIndex) Flush 

func (idx *BalanceIndex) Flush(ctx context.Context) error

func (*BalanceIndex) Init 

func (idx *BalanceIndex) Init(path, label string, opts interface{}) error

func (*BalanceIndex) Key 

func (idx *BalanceIndex) Key() string

func (*BalanceIndex) Name 

func (idx *BalanceIndex) Name() string

func (*BalanceIndex) OnTaskComplete 

func (idx *BalanceIndex) OnTaskComplete(_ context.Context, _ *task.TaskResult) error

func (*BalanceIndex) Tables 

func (idx *BalanceIndex) Tables() []*pack.Table

type BigmapIndex 

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

func NewBigmapIndex 

func NewBigmapIndex() *BigmapIndex

func (*BigmapIndex) Close 

func (idx *BigmapIndex) Close() error

func (*BigmapIndex) ConnectBlock 

func (idx *BigmapIndex) ConnectBlock(ctx context.Context, block *model.Block, builder model.BlockBuilder) error

assumes op ids are already set (must run after OpIndex)

func (*BigmapIndex) Create 

func (idx *BigmapIndex) Create(path, label string, opts interface{}) error

func (*BigmapIndex) DB 

func (idx *BigmapIndex) DB() *pack.DB

func (*BigmapIndex) DeleteBlock 

func (idx *BigmapIndex) DeleteBlock(ctx context.Context, height int64) error

func (*BigmapIndex) DeleteCycle 

func (idx *BigmapIndex) DeleteCycle(ctx context.Context, cycle int64) error

func (*BigmapIndex) DisconnectBlock 

func (idx *BigmapIndex) DisconnectBlock(ctx context.Context, block *model.Block, _ model.BlockBuilder) error

func (*BigmapIndex) FinalizeSync 

func (idx *BigmapIndex) FinalizeSync(_ context.Context) error

func (*BigmapIndex) Flush 

func (idx *BigmapIndex) Flush(ctx context.Context) error

func (*BigmapIndex) Init 

func (idx *BigmapIndex) Init(path, label string, opts interface{}) error

func (*BigmapIndex) Key 

func (idx *BigmapIndex) Key() string

func (*BigmapIndex) Name 

func (idx *BigmapIndex) Name() string

func (*BigmapIndex) OnTaskComplete 

func (idx *BigmapIndex) OnTaskComplete(_ context.Context, _ *task.TaskResult) error

func (*BigmapIndex) Tables 

func (idx *BigmapIndex) Tables() []*pack.Table

type BlockIndex 

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

func NewBlockIndex 

func NewBlockIndex() *BlockIndex

func (*BlockIndex) Close 

func (idx *BlockIndex) Close() error

func (*BlockIndex) ConnectBlock 

func (idx *BlockIndex) ConnectBlock(ctx context.Context, block *model.Block, b model.BlockBuilder) error

func (*BlockIndex) Create 

func (idx *BlockIndex) Create(path, label string, opts interface{}) error

func (*BlockIndex) DB 

func (idx *BlockIndex) DB() *pack.DB

func (*BlockIndex) DeleteBlock 

func (idx *BlockIndex) DeleteBlock(ctx context.Context, height int64) error

func (*BlockIndex) DeleteCycle 

func (idx *BlockIndex) DeleteCycle(ctx context.Context, cycle int64) error

func (*BlockIndex) DisconnectBlock 

func (idx *BlockIndex) DisconnectBlock(ctx context.Context, block *model.Block, _ model.BlockBuilder) error

func (*BlockIndex) FinalizeSync 

func (idx *BlockIndex) FinalizeSync(ctx context.Context) error

func (*BlockIndex) Flush 

func (idx *BlockIndex) Flush(ctx context.Context) error

func (*BlockIndex) Init 

func (idx *BlockIndex) Init(path, label string, opts interface{}) error

func (*BlockIndex) Key 

func (idx *BlockIndex) Key() string

func (*BlockIndex) Name 

func (idx *BlockIndex) Name() string

func (*BlockIndex) OnTaskComplete 

func (idx *BlockIndex) OnTaskComplete(_ context.Context, _ *task.TaskResult) error

func (*BlockIndex) Tables 

func (idx *BlockIndex) Tables() []*pack.Table

type ChainIndex 

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

func NewChainIndex 

func NewChainIndex() *ChainIndex

func (*ChainIndex) Close 

func (idx *ChainIndex) Close() error

func (*ChainIndex) ConnectBlock 

func (idx *ChainIndex) ConnectBlock(ctx context.Context, block *model.Block, _ model.BlockBuilder) error

func (*ChainIndex) Create 

func (idx *ChainIndex) Create(path, label string, opts interface{}) error

func (*ChainIndex) DB 

func (idx *ChainIndex) DB() *pack.DB

func (*ChainIndex) DeleteBlock 

func (idx *ChainIndex) DeleteBlock(ctx context.Context, height int64) error

func (*ChainIndex) DeleteCycle 

func (idx *ChainIndex) DeleteCycle(ctx context.Context, cycle int64) error

func (*ChainIndex) DisconnectBlock 

func (idx *ChainIndex) DisconnectBlock(ctx context.Context, block *model.Block, _ model.BlockBuilder) error

func (*ChainIndex) FinalizeSync 

func (idx *ChainIndex) FinalizeSync(_ context.Context) error

func (*ChainIndex) Flush 

func (idx *ChainIndex) Flush(ctx context.Context) error

func (*ChainIndex) Init 

func (idx *ChainIndex) Init(path, label string, opts interface{}) error

func (*ChainIndex) Key 

func (idx *ChainIndex) Key() string

func (*ChainIndex) Name 

func (idx *ChainIndex) Name() string

func (*ChainIndex) OnTaskComplete 

func (idx *ChainIndex) OnTaskComplete(_ context.Context, _ *task.TaskResult) error

func (*ChainIndex) Tables 

func (idx *ChainIndex) Tables() []*pack.Table

type ConstantIndex 

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

func NewConstantIndex 

func NewConstantIndex() *ConstantIndex

func (*ConstantIndex) Close 

func (idx *ConstantIndex) Close() error

func (*ConstantIndex) ConnectBlock 

func (idx *ConstantIndex) ConnectBlock(ctx context.Context, block *model.Block, builder model.BlockBuilder) error

func (*ConstantIndex) Create 

func (idx *ConstantIndex) Create(path, label string, opts interface{}) error

func (*ConstantIndex) DB 

func (idx *ConstantIndex) DB() *pack.DB

func (*ConstantIndex) DeleteBlock 

func (idx *ConstantIndex) DeleteBlock(ctx context.Context, height int64) error

func (*ConstantIndex) DeleteCycle 

func (idx *ConstantIndex) DeleteCycle(ctx context.Context, cycle int64) error

func (*ConstantIndex) DisconnectBlock 

func (idx *ConstantIndex) DisconnectBlock(ctx context.Context, block *model.Block, builder model.BlockBuilder) error

func (*ConstantIndex) FinalizeSync 

func (idx *ConstantIndex) FinalizeSync(_ context.Context) error

func (*ConstantIndex) Flush 

func (idx *ConstantIndex) Flush(ctx context.Context) error

func (*ConstantIndex) Init 

func (idx *ConstantIndex) Init(path, label string, opts interface{}) error

func (*ConstantIndex) Key 

func (idx *ConstantIndex) Key() string

func (*ConstantIndex) Name 

func (idx *ConstantIndex) Name() string

func (*ConstantIndex) OnTaskComplete 

func (idx *ConstantIndex) OnTaskComplete(_ context.Context, _ *task.TaskResult) error

func (*ConstantIndex) Tables 

func (idx *ConstantIndex) Tables() []*pack.Table

type ContractIndex 

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

func NewContractIndex 

func NewContractIndex() *ContractIndex

func (*ContractIndex) Close 

func (idx *ContractIndex) Close() error

func (*ContractIndex) ConnectBlock 

func (idx *ContractIndex) ConnectBlock(ctx context.Context, block *model.Block, builder model.BlockBuilder) error

func (*ContractIndex) Create 

func (idx *ContractIndex) Create(path, label string, opts interface{}) error

func (*ContractIndex) DB 

func (idx *ContractIndex) DB() *pack.DB

func (*ContractIndex) DeleteBlock 

func (idx *ContractIndex) DeleteBlock(ctx context.Context, height int64) error

func (*ContractIndex) DeleteCycle 

func (idx *ContractIndex) DeleteCycle(ctx context.Context, cycle int64) error

func (*ContractIndex) DisconnectBlock 

func (idx *ContractIndex) DisconnectBlock(ctx context.Context, block *model.Block, builder model.BlockBuilder) error

func (*ContractIndex) FinalizeSync 

func (idx *ContractIndex) FinalizeSync(_ context.Context) error

func (*ContractIndex) Flush 

func (idx *ContractIndex) Flush(ctx context.Context) error

func (*ContractIndex) Init 

func (idx *ContractIndex) Init(path, label string, opts interface{}) error

func (*ContractIndex) Key 

func (idx *ContractIndex) Key() string

func (*ContractIndex) Name 

func (idx *ContractIndex) Name() string

func (*ContractIndex) OnTaskComplete 

func (idx *ContractIndex) OnTaskComplete(_ context.Context, _ *task.TaskResult) error

func (*ContractIndex) Tables 

func (idx *ContractIndex) Tables() []*pack.Table

type CycleIndex 

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

func NewCycleIndex 

func NewCycleIndex() *CycleIndex

func (*CycleIndex) Close 

func (idx *CycleIndex) Close() error

func (*CycleIndex) ConnectBlock 

func (idx *CycleIndex) ConnectBlock(ctx context.Context, block *model.Block, builder model.BlockBuilder) error

func (*CycleIndex) Create 

func (idx *CycleIndex) Create(path, label string, opts interface{}) error

func (*CycleIndex) DB 

func (idx *CycleIndex) DB() *pack.DB

func (*CycleIndex) DeleteBlock 

func (idx *CycleIndex) DeleteBlock(ctx context.Context, height int64) error

func (*CycleIndex) DeleteCycle 

func (idx *CycleIndex) DeleteCycle(ctx context.Context, cycle int64) error

func (*CycleIndex) DisconnectBlock 

func (idx *CycleIndex) DisconnectBlock(ctx context.Context, block *model.Block, builder model.BlockBuilder) error

func (*CycleIndex) FinalizeSync 

func (idx *CycleIndex) FinalizeSync(_ context.Context) error

func (*CycleIndex) Flush 

func (idx *CycleIndex) Flush(ctx context.Context) error

func (*CycleIndex) Init 

func (idx *CycleIndex) Init(path, label string, opts interface{}) error

func (*CycleIndex) Key 

func (idx *CycleIndex) Key() string

func (*CycleIndex) Name 

func (idx *CycleIndex) Name() string

func (*CycleIndex) OnTaskComplete 

func (idx *CycleIndex) OnTaskComplete(_ context.Context, _ *task.TaskResult) error

func (*CycleIndex) Tables 

func (idx *CycleIndex) Tables() []*pack.Table

type EventIndex 

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

func NewEventIndex 

func NewEventIndex() *EventIndex

func (*EventIndex) Close 

func (idx *EventIndex) Close() error

func (*EventIndex) ConnectBlock 

func (idx *EventIndex) ConnectBlock(ctx context.Context, block *model.Block, builder model.BlockBuilder) error

func (*EventIndex) Create 

func (idx *EventIndex) Create(path, label string, opts interface{}) error

func (*EventIndex) DB 

func (idx *EventIndex) DB() *pack.DB

func (*EventIndex) DeleteBlock 

func (idx *EventIndex) DeleteBlock(ctx context.Context, height int64) error

func (*EventIndex) DeleteCycle 

func (idx *EventIndex) DeleteCycle(ctx context.Context, cycle int64) error

func (*EventIndex) DisconnectBlock 

func (idx *EventIndex) DisconnectBlock(ctx context.Context, block *model.Block, builder model.BlockBuilder) error

func (*EventIndex) FinalizeSync 

func (idx *EventIndex) FinalizeSync(_ context.Context) error

func (*EventIndex) Flush 

func (idx *EventIndex) Flush(ctx context.Context) error

func (*EventIndex) Init 

func (idx *EventIndex) Init(path, label string, opts interface{}) error

func (*EventIndex) Key 

func (idx *EventIndex) Key() string

func (*EventIndex) Name 

func (idx *EventIndex) Name() string

func (*EventIndex) OnTaskComplete 

func (idx *EventIndex) OnTaskComplete(_ context.Context, _ *task.TaskResult) error

func (*EventIndex) Tables 

func (idx *EventIndex) Tables() []*pack.Table

type FlowIndex 

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

func NewFlowIndex 

func NewFlowIndex() *FlowIndex

func (*FlowIndex) Close 

func (idx *FlowIndex) Close() error

func (*FlowIndex) ConnectBlock 

func (idx *FlowIndex) ConnectBlock(ctx context.Context, block *model.Block, _ model.BlockBuilder) error

func (*FlowIndex) Create 

func (idx *FlowIndex) Create(path, label string, opts interface{}) error

func (*FlowIndex) DB 

func (idx *FlowIndex) DB() *pack.DB

func (*FlowIndex) DeleteBlock 

func (idx *FlowIndex) DeleteBlock(ctx context.Context, height int64) error

func (*FlowIndex) DeleteCycle 

func (idx *FlowIndex) DeleteCycle(ctx context.Context, cycle int64) error

func (*FlowIndex) DisconnectBlock 

func (idx *FlowIndex) DisconnectBlock(ctx context.Context, block *model.Block, _ model.BlockBuilder) error

func (*FlowIndex) FinalizeSync 

func (idx *FlowIndex) FinalizeSync(_ context.Context) error

func (*FlowIndex) Flush 

func (idx *FlowIndex) Flush(ctx context.Context) error

func (*FlowIndex) Init 

func (idx *FlowIndex) Init(path, label string, opts interface{}) error

func (*FlowIndex) Key 

func (idx *FlowIndex) Key() string

func (*FlowIndex) Name 

func (idx *FlowIndex) Name() string

func (*FlowIndex) OnTaskComplete 

func (idx *FlowIndex) OnTaskComplete(_ context.Context, _ *task.TaskResult) error

func (*FlowIndex) Tables 

func (idx *FlowIndex) Tables() []*pack.Table

type GovIndex 

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

func NewGovIndex 

func NewGovIndex() *GovIndex

func (*GovIndex) Close 

func (idx *GovIndex) Close() error

func (*GovIndex) ConnectBlock 

func (idx *GovIndex) ConnectBlock(ctx context.Context, block *model.Block, builder model.BlockBuilder) error

func (*GovIndex) Create 

func (idx *GovIndex) Create(path, label string, opts interface{}) error

func (*GovIndex) DB 

func (idx *GovIndex) DB() *pack.DB

func (*GovIndex) DeleteBlock 

func (idx *GovIndex) DeleteBlock(ctx context.Context, height int64) error

func (*GovIndex) DeleteCycle 

func (idx *GovIndex) DeleteCycle(ctx context.Context, cycle int64) error

func (*GovIndex) DisconnectBlock 

func (idx *GovIndex) DisconnectBlock(ctx context.Context, block *model.Block, builder model.BlockBuilder) error

func (*GovIndex) FinalizeSync 

func (idx *GovIndex) FinalizeSync(_ context.Context) error

func (*GovIndex) Flush 

func (idx *GovIndex) Flush(ctx context.Context) error

func (*GovIndex) Init 

func (idx *GovIndex) Init(path, label string, opts interface{}) error

func (*GovIndex) Key 

func (idx *GovIndex) Key() string

func (*GovIndex) Name 

func (idx *GovIndex) Name() string

func (*GovIndex) OnTaskComplete 

func (idx *GovIndex) OnTaskComplete(_ context.Context, _ *task.TaskResult) error

func (*GovIndex) Tables 

func (idx *GovIndex) Tables() []*pack.Table

type InMemoryBigmap 

type InMemoryBigmap struct {
	Alloc   *model.BigmapAlloc
	Updates []*model.BigmapUpdate
	Live    []*model.BigmapValue
}

func NewInMemoryBigmap 

func NewInMemoryBigmap(alloc *model.BigmapAlloc) *InMemoryBigmap

type IncomeIndex 

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

func NewIncomeIndex 

func NewIncomeIndex() *IncomeIndex

func (*IncomeIndex) Close 

func (idx *IncomeIndex) Close() error

func (*IncomeIndex) ConnectBlock 

func (idx *IncomeIndex) ConnectBlock(ctx context.Context, block *model.Block, builder model.BlockBuilder) error

func (*IncomeIndex) Create 

func (idx *IncomeIndex) Create(path, label string, opts interface{}) error

func (*IncomeIndex) DB 

func (idx *IncomeIndex) DB() *pack.DB

func (*IncomeIndex) DeleteBlock 

func (idx *IncomeIndex) DeleteBlock(ctx context.Context, height int64) error

func (*IncomeIndex) DeleteCycle 

func (idx *IncomeIndex) DeleteCycle(ctx context.Context, cycle int64) error

func (*IncomeIndex) DisconnectBlock 

func (idx *IncomeIndex) DisconnectBlock(ctx context.Context, block *model.Block, builder model.BlockBuilder) error

func (*IncomeIndex) FinalizeSync 

func (idx *IncomeIndex) FinalizeSync(_ context.Context) error

func (*IncomeIndex) Flush 

func (idx *IncomeIndex) Flush(ctx context.Context) error

func (*IncomeIndex) Init 

func (idx *IncomeIndex) Init(path, label string, opts interface{}) error

func (*IncomeIndex) Key 

func (idx *IncomeIndex) Key() string

func (*IncomeIndex) Name 

func (idx *IncomeIndex) Name() string

func (*IncomeIndex) OnTaskComplete 

func (idx *IncomeIndex) OnTaskComplete(_ context.Context, _ *task.TaskResult) error

func (*IncomeIndex) Tables 

func (idx *IncomeIndex) Tables() []*pack.Table

type MetadataIndex 

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

func NewMetadataIndex 

func NewMetadataIndex() *MetadataIndex

func (*MetadataIndex) Close 

func (idx *MetadataIndex) Close() error

func (*MetadataIndex) ConnectBlock 

func (idx *MetadataIndex) ConnectBlock(ctx context.Context, block *model.Block, builder model.BlockBuilder) error

func (*MetadataIndex) Create 

func (idx *MetadataIndex) Create(path, label string, opts interface{}) error

func (*MetadataIndex) DB 

func (idx *MetadataIndex) DB() *pack.DB

func (*MetadataIndex) DeleteBlock 

func (idx *MetadataIndex) DeleteBlock(ctx context.Context, height int64) error

func (*MetadataIndex) DeleteCycle 

func (idx *MetadataIndex) DeleteCycle(ctx context.Context, cycle int64) error

func (*MetadataIndex) DisconnectBlock 

func (idx *MetadataIndex) DisconnectBlock(ctx context.Context, block *model.Block, builder model.BlockBuilder) error

func (*MetadataIndex) FinalizeSync 

func (idx *MetadataIndex) FinalizeSync(ctx context.Context) error

func (*MetadataIndex) FindOrCreateMetaModel 

func (idx *MetadataIndex) FindOrCreateMetaModel(ctx context.Context, addr tezos.Address, id model.AccountID) (*model.Metadata, error)

func (*MetadataIndex) Flush 

func (idx *MetadataIndex) Flush(ctx context.Context) error

func (*MetadataIndex) Init 

func (idx *MetadataIndex) Init(path, label string, opts interface{}) error

func (*MetadataIndex) Key 

func (idx *MetadataIndex) Key() string

func (*MetadataIndex) Name 

func (idx *MetadataIndex) Name() string

func (*MetadataIndex) OnTaskComplete 

func (idx *MetadataIndex) OnTaskComplete(ctx context.Context, res *task.TaskResult) error

TaskCompletionCallback

func (*MetadataIndex) Tables 

func (idx *MetadataIndex) Tables() []*pack.Table

type OpIndex 

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

func NewOpIndex 

func NewOpIndex() *OpIndex

func (*OpIndex) Close 

func (idx *OpIndex) Close() error

func (*OpIndex) ConnectBlock 

func (idx *OpIndex) ConnectBlock(ctx context.Context, block *model.Block, b model.BlockBuilder) error

func (*OpIndex) Create 

func (idx *OpIndex) Create(path, label string, opts interface{}) error

func (*OpIndex) DB 

func (idx *OpIndex) DB() *pack.DB

func (*OpIndex) DeleteBlock 

func (idx *OpIndex) DeleteBlock(ctx context.Context, height int64) error

func (*OpIndex) DeleteCycle 

func (idx *OpIndex) DeleteCycle(ctx context.Context, cycle int64) error

func (*OpIndex) DisconnectBlock 

func (idx *OpIndex) DisconnectBlock(ctx context.Context, block *model.Block, _ model.BlockBuilder) error

func (*OpIndex) FinalizeSync 

func (idx *OpIndex) FinalizeSync(ctx context.Context) error

func (*OpIndex) Flush 

func (idx *OpIndex) Flush(ctx context.Context) error

func (*OpIndex) Init 

func (idx *OpIndex) Init(path, label string, opts interface{}) error

func (*OpIndex) Key 

func (idx *OpIndex) Key() string

func (*OpIndex) Name 

func (idx *OpIndex) Name() string

func (*OpIndex) OnTaskComplete 

func (idx *OpIndex) OnTaskComplete(_ context.Context, _ *task.TaskResult) error

func (*OpIndex) Tables 

func (idx *OpIndex) Tables() []*pack.Table

type RightsIndex 

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

func NewRightsIndex 

func NewRightsIndex() *RightsIndex

func (*RightsIndex) Close 

func (idx *RightsIndex) Close() error

func (*RightsIndex) ConnectBlock 

func (idx *RightsIndex) ConnectBlock(ctx context.Context, block *model.Block, builder model.BlockBuilder) error

func (*RightsIndex) Create 

func (idx *RightsIndex) Create(path, label string, opts interface{}) error

func (*RightsIndex) DB 

func (idx *RightsIndex) DB() *pack.DB

func (*RightsIndex) DeleteBlock 

func (idx *RightsIndex) DeleteBlock(ctx context.Context, height int64) error

func (*RightsIndex) DeleteCycle 

func (idx *RightsIndex) DeleteCycle(ctx context.Context, cycle int64) error

func (*RightsIndex) DisconnectBlock 

func (idx *RightsIndex) DisconnectBlock(ctx context.Context, block *model.Block, builder model.BlockBuilder) error

Does not work on rollback of the first cycle block!

func (*RightsIndex) FinalizeSync 

func (idx *RightsIndex) FinalizeSync(_ context.Context) error

func (*RightsIndex) Flush 

func (idx *RightsIndex) Flush(ctx context.Context) error

func (*RightsIndex) Init 

func (idx *RightsIndex) Init(path, label string, opts interface{}) error

func (*RightsIndex) Key 

func (idx *RightsIndex) Key() string

func (*RightsIndex) Name 

func (idx *RightsIndex) Name() string

func (*RightsIndex) OnTaskComplete 

func (idx *RightsIndex) OnTaskComplete(_ context.Context, _ *task.TaskResult) error

func (*RightsIndex) Tables 

func (idx *RightsIndex) Tables() []*pack.Table

type SnapshotIndex 

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

func NewSnapshotIndex 

func NewSnapshotIndex() *SnapshotIndex

func (*SnapshotIndex) Close 

func (idx *SnapshotIndex) Close() error

func (*SnapshotIndex) ConnectBlock 

func (idx *SnapshotIndex) ConnectBlock(ctx context.Context, block *model.Block, builder model.BlockBuilder) error

func (*SnapshotIndex) Create 

func (idx *SnapshotIndex) Create(path, label string, opts interface{}) error

func (*SnapshotIndex) DB 

func (idx *SnapshotIndex) DB() *pack.DB

func (*SnapshotIndex) DeleteBlock 

func (idx *SnapshotIndex) DeleteBlock(ctx context.Context, height int64) error

func (*SnapshotIndex) DeleteCycle 

func (idx *SnapshotIndex) DeleteCycle(ctx context.Context, cycle int64) error

func (*SnapshotIndex) DisconnectBlock 

func (idx *SnapshotIndex) DisconnectBlock(ctx context.Context, block *model.Block, _ model.BlockBuilder) error

func (*SnapshotIndex) FinalizeSync 

func (idx *SnapshotIndex) FinalizeSync(_ context.Context) error

func (*SnapshotIndex) Flush 

func (idx *SnapshotIndex) Flush(ctx context.Context) error

func (*SnapshotIndex) Init 

func (idx *SnapshotIndex) Init(path, label string, opts interface{}) error

func (*SnapshotIndex) Key 

func (idx *SnapshotIndex) Key() string

func (*SnapshotIndex) Name 

func (idx *SnapshotIndex) Name() string

func (*SnapshotIndex) OnTaskComplete 

func (idx *SnapshotIndex) OnTaskComplete(_ context.Context, _ *task.TaskResult) error

func (*SnapshotIndex) Tables 

func (idx *SnapshotIndex) Tables() []*pack.Table

type StorageIndex 

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

func NewStorageIndex 

func NewStorageIndex() *StorageIndex

func (*StorageIndex) Close 

func (idx *StorageIndex) Close() error

func (*StorageIndex) ConnectBlock 

func (idx *StorageIndex) ConnectBlock(ctx context.Context, block *model.Block, b model.BlockBuilder) error

func (*StorageIndex) Create 

func (idx *StorageIndex) Create(path, label string, opts interface{}) error

func (*StorageIndex) DB 

func (idx *StorageIndex) DB() *pack.DB

func (*StorageIndex) DeleteBlock 

func (idx *StorageIndex) DeleteBlock(ctx context.Context, height int64) error

func (*StorageIndex) DeleteCycle 

func (idx *StorageIndex) DeleteCycle(ctx context.Context, cycle int64) error

func (*StorageIndex) DisconnectBlock 

func (idx *StorageIndex) DisconnectBlock(ctx context.Context, block *model.Block, _ model.BlockBuilder) error

func (*StorageIndex) FinalizeSync 

func (idx *StorageIndex) FinalizeSync(ctx context.Context) error

func (*StorageIndex) Flush 

func (idx *StorageIndex) Flush(ctx context.Context) error

func (*StorageIndex) Init 

func (idx *StorageIndex) Init(path, label string, opts interface{}) error

func (*StorageIndex) Key 

func (idx *StorageIndex) Key() string

func (*StorageIndex) Name 

func (idx *StorageIndex) Name() string

func (*StorageIndex) OnTaskComplete 

func (idx *StorageIndex) OnTaskComplete(_ context.Context, _ *task.TaskResult) error

func (*StorageIndex) Tables 

func (idx *StorageIndex) Tables() []*pack.Table

type SupplyIndex 

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

func NewSupplyIndex 

func NewSupplyIndex() *SupplyIndex

func (*SupplyIndex) Close 

func (idx *SupplyIndex) Close() error

func (*SupplyIndex) ConnectBlock 

func (idx *SupplyIndex) ConnectBlock(ctx context.Context, block *model.Block, _ model.BlockBuilder) error

func (*SupplyIndex) Create 

func (idx *SupplyIndex) Create(path, label string, opts interface{}) error

func (*SupplyIndex) DB 

func (idx *SupplyIndex) DB() *pack.DB

func (*SupplyIndex) DeleteBlock 

func (idx *SupplyIndex) DeleteBlock(ctx context.Context, height int64) error

func (*SupplyIndex) DeleteCycle 

func (idx *SupplyIndex) DeleteCycle(ctx context.Context, cycle int64) error

func (*SupplyIndex) DisconnectBlock 

func (idx *SupplyIndex) DisconnectBlock(ctx context.Context, block *model.Block, _ model.BlockBuilder) error

func (*SupplyIndex) FinalizeSync 

func (idx *SupplyIndex) FinalizeSync(_ context.Context) error

func (*SupplyIndex) Flush 

func (idx *SupplyIndex) Flush(ctx context.Context) error

func (*SupplyIndex) Init 

func (idx *SupplyIndex) Init(path, label string, opts interface{}) error

func (*SupplyIndex) Key 

func (idx *SupplyIndex) Key() string

func (*SupplyIndex) Name 

func (idx *SupplyIndex) Name() string

func (*SupplyIndex) OnTaskComplete 

func (idx *SupplyIndex) OnTaskComplete(_ context.Context, _ *task.TaskResult) error

func (*SupplyIndex) Tables 

func (idx *SupplyIndex) Tables() []*pack.Table

type TicketIndex 

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

func NewTicketIndex 

func NewTicketIndex() *TicketIndex

func (*TicketIndex) Close 

func (idx *TicketIndex) Close() error

func (*TicketIndex) ConnectBlock 

func (idx *TicketIndex) ConnectBlock(ctx context.Context, block *model.Block, b model.BlockBuilder) error

func (*TicketIndex) Create 

func (idx *TicketIndex) Create(path, label string, opts interface{}) error

func (*TicketIndex) DB 

func (idx *TicketIndex) DB() *pack.DB

func (*TicketIndex) DeleteBlock 

func (idx *TicketIndex) DeleteBlock(ctx context.Context, height int64) error

func (*TicketIndex) DeleteCycle 

func (idx *TicketIndex) DeleteCycle(ctx context.Context, cycle int64) error

func (*TicketIndex) DisconnectBlock 

func (idx *TicketIndex) DisconnectBlock(ctx context.Context, block *model.Block, _ model.BlockBuilder) error

func (*TicketIndex) FinalizeSync 

func (idx *TicketIndex) FinalizeSync(_ context.Context) error

func (*TicketIndex) Flush 

func (idx *TicketIndex) Flush(ctx context.Context) error

func (*TicketIndex) Init 

func (idx *TicketIndex) Init(path, label string, opts interface{}) error

func (*TicketIndex) Key 

func (idx *TicketIndex) Key() string

func (*TicketIndex) Name 

func (idx *TicketIndex) Name() string

func (*TicketIndex) OnTaskComplete 

func (idx *TicketIndex) OnTaskComplete(_ context.Context, _ *task.TaskResult) error

func (*TicketIndex) Tables 

func (idx *TicketIndex) Tables() []*pack.Table

type TokenIndex 

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

func NewTokenIndex 

func NewTokenIndex() *TokenIndex

func (*TokenIndex) Close 

func (idx *TokenIndex) Close() error

func (*TokenIndex) ConnectBlock 

func (idx *TokenIndex) ConnectBlock(ctx context.Context, block *model.Block, b model.BlockBuilder) error

func (*TokenIndex) Create 

func (idx *TokenIndex) Create(path, label string, opts interface{}) error

func (*TokenIndex) DB 

func (idx *TokenIndex) DB() *pack.DB

func (*TokenIndex) DeleteBlock 

func (idx *TokenIndex) DeleteBlock(ctx context.Context, height int64) error

func (*TokenIndex) DeleteCycle 

func (idx *TokenIndex) DeleteCycle(ctx context.Context, cycle int64) error

func (*TokenIndex) DisconnectBlock 

func (idx *TokenIndex) DisconnectBlock(ctx context.Context, block *model.Block, _ model.BlockBuilder) error

func (*TokenIndex) FinalizeSync 

func (idx *TokenIndex) FinalizeSync(_ context.Context) error

func (*TokenIndex) Flush 

func (idx *TokenIndex) Flush(ctx context.Context) error

func (*TokenIndex) Init 

func (idx *TokenIndex) Init(path, label string, opts interface{}) error

func (*TokenIndex) Key 

func (idx *TokenIndex) Key() string

func (*TokenIndex) Name 

func (idx *TokenIndex) Name() string

func (*TokenIndex) OnTaskComplete 

func (idx *TokenIndex) OnTaskComplete(ctx context.Context, res *task.TaskResult) error

func (*TokenIndex) Tables 

func (idx *TokenIndex) Tables() []*pack.Table

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.