sql

Documentation

Index

• Variables
• func New(dsnString string, opts ...eosdb.Option) (eosdb.Driver, error)
• type DB
  • func (db *DB) BlockIDAfter(ctx context.Context, start time.Time, inclusive bool) (id string, foundtime time.Time, err error)
  • func (db *DB) BlockIDAt(ctx context.Context, start time.Time) (id string, err error)
  • func (db *DB) BlockIDBefore(ctx context.Context, start time.Time, inclusive bool) (id string, foundtime time.Time, err error)
  • func (db *DB) Close() error
  • func (db *DB) Flush(ctx context.Context) error
  • func (db *DB) FlushAllMutations(context.Context) error
  • func (db *DB) GetAccount(ctx context.Context, accountName string) (*pbcodec.AccountCreationRef, error)
  • func (db *DB) GetBlock(ctx context.Context, id string) (*pbcodec.BlockWithRefs, error)
  • func (db *DB) GetBlockByNum(ctx context.Context, num uint32) ([]*pbcodec.BlockWithRefs, error)
  • func (db *DB) GetClosestIrreversibleIDAtBlockNum(ctx context.Context, num uint32) (ref bstream.BlockRef, err error)
  • func (db *DB) GetIrreversibleIDAtBlockID(ctx context.Context, ID string) (ref bstream.BlockRef, err error)
  • func (db *DB) GetLastWrittenBlockID(ctx context.Context) (blockID string, err error)
  • func (db *DB) GetLastWrittenIrreversibleBlockRef(ctx context.Context) (ref bstream.BlockRef, err error)
  • func (db *DB) GetTransactionEvents(ctx context.Context, idPrefix string) (out []*pbcodec.TransactionEvent, err error)
  • func (db *DB) GetTransactionEventsBatch(ctx context.Context, idPrefixes []string) (out [][]*pbcodec.TransactionEvent, err error)
  • func (db *DB) GetTransactionTraces(ctx context.Context, idPrefix string) (out []*pbcodec.TransactionEvent, err error)
  • func (db *DB) GetTransactionTracesBatch(ctx context.Context, idPrefixes []string) (out [][]*pbcodec.TransactionEvent, err error)
  • func (db *DB) ListAccountNames(ctx context.Context, concurrentReadCount uint32) ([]string, error)
  • func (db *DB) ListBlocks(ctx context.Context, startBlockNum uint32, limit int) (out []*pbcodec.BlockWithRefs, err error)
  • func (db *DB) ListMostRecentTransactions(ctx context.Context, startKey string, limit int, ...) (*mdl.TransactionList, error)
  • func (db *DB) ListSiblingBlocks(ctx context.Context, blockNum uint32, spread uint32) (out []*pbcodec.BlockWithRefs, err error)
  • func (db *DB) ListTransactionsForBlockID(ctx context.Context, id string, startKey string, limit int, ...) (*mdl.TransactionList, error)
  • func (db *DB) PutBlock(ctx context.Context, blk *pbcodec.Block) error
  • func (db *DB) SetWriterChainID(chainID []byte)
  • func (db *DB) UpdateNowIrreversibleBlock(ctx context.Context, blk *pbcodec.Block) error
• type SqliteTime
  • func (t *SqliteTime) Scan(v interface{}) error

Variables

var BEGIN_TRANSACTION = ""

var INSERT_IGNORE = ""

Functions

func New

func New(dsnString string, opts ...eosdb.Option) (eosdb.Driver, error)

Types

type DB

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

func (*DB) BlockIDAfter

func (db *DB) BlockIDAfter(ctx context.Context, start time.Time, inclusive bool) (id string, foundtime time.Time, err error)

func (*DB) BlockIDAt

func (db *DB) BlockIDAt(ctx context.Context, start time.Time) (id string, err error)

func (*DB) BlockIDBefore

func (db *DB) BlockIDBefore(ctx context.Context, start time.Time, inclusive bool) (id string, foundtime time.Time, err error)

func (*DB) Close

func (db *DB) Close() error

func (*DB) Flush

func (db *DB) Flush(ctx context.Context) error

func (*DB) FlushAllMutations

func (db *DB) FlushAllMutations(context.Context) error

func (*DB) GetAccount

func (db *DB) GetAccount(ctx context.Context, accountName string) (*pbcodec.AccountCreationRef, error)

func (*DB) GetBlock

func (db *DB) GetBlock(ctx context.Context, id string) (*pbcodec.BlockWithRefs, error)

func (*DB) GetBlockByNum

func (db *DB) GetBlockByNum(ctx context.Context, num uint32) ([]*pbcodec.BlockWithRefs, error)

func (*DB) GetClosestIrreversibleIDAtBlockNum

func (db *DB) GetClosestIrreversibleIDAtBlockNum(ctx context.Context, num uint32) (ref bstream.BlockRef, err error)

func (*DB) GetIrreversibleIDAtBlockID

func (db *DB) GetIrreversibleIDAtBlockID(ctx context.Context, ID string) (ref bstream.BlockRef, err error)

func (*DB) GetLastWrittenBlockID

func (db *DB) GetLastWrittenBlockID(ctx context.Context) (blockID string, err error)

func (*DB) GetLastWrittenIrreversibleBlockRef

func (db *DB) GetLastWrittenIrreversibleBlockRef(ctx context.Context) (ref bstream.BlockRef, err error)

func (*DB) GetTransactionEvents

func (db *DB) GetTransactionEvents(ctx context.Context, idPrefix string) (out []*pbcodec.TransactionEvent, err error)

func (*DB) GetTransactionEventsBatch

func (db *DB) GetTransactionEventsBatch(ctx context.Context, idPrefixes []string) (out [][]*pbcodec.TransactionEvent, err error)

func (*DB) GetTransactionTraces

func (db *DB) GetTransactionTraces(ctx context.Context, idPrefix string) (out []*pbcodec.TransactionEvent, err error)

func (*DB) GetTransactionTracesBatch

func (db *DB) GetTransactionTracesBatch(ctx context.Context, idPrefixes []string) (out [][]*pbcodec.TransactionEvent, err error)

func (*DB) ListAccountNames

func (db *DB) ListAccountNames(ctx context.Context, concurrentReadCount uint32) ([]string, error)

func (*DB) ListBlocks

func (db *DB) ListBlocks(ctx context.Context, startBlockNum uint32, limit int) (out []*pbcodec.BlockWithRefs, err error)

func (*DB) ListMostRecentTransactions

func (db *DB) ListMostRecentTransactions(ctx context.Context, startKey string, limit int, chainDiscriminator eosdb.ChainDiscriminator) (*mdl.TransactionList, error)

func (*DB) ListSiblingBlocks

func (db *DB) ListSiblingBlocks(ctx context.Context, blockNum uint32, spread uint32) (out []*pbcodec.BlockWithRefs, err error)

func (*DB) ListTransactionsForBlockID

func (db *DB) ListTransactionsForBlockID(ctx context.Context, id string, startKey string, limit int, chainDiscriminator eosdb.ChainDiscriminator) (*mdl.TransactionList, error)

func (*DB) PutBlock

func (db *DB) PutBlock(ctx context.Context, blk *pbcodec.Block) error

func (*DB) SetWriterChainID

func (db *DB) SetWriterChainID(chainID []byte)

func (*DB) UpdateNowIrreversibleBlock

func (db *DB) UpdateNowIrreversibleBlock(ctx context.Context, blk *pbcodec.Block) error

type SqliteTime

type SqliteTime time.Time

func (*SqliteTime) Scan

func (t *SqliteTime) Scan(v interface{}) error