suites

Documentation

Index

• func BenchmarkTableDeleteSuite(bs *bench.BenchmarkSuite) []bench.BenchmarkResult
• func BenchmarkTableExistSuite(bs *bench.BenchmarkSuite) []bench.BenchmarkResult
• func BenchmarkTableGetSuite(bs *bench.BenchmarkSuite) []bench.BenchmarkResult
• func BenchmarkTableInsertSuite(bs *bench.BenchmarkSuite) []bench.BenchmarkResult
• func BenchmarkTableQueryIntersectSuite(bs *bench.BenchmarkSuite) []bench.BenchmarkResult
• func BenchmarkTableQuerySuite(bs *bench.BenchmarkSuite) []bench.BenchmarkResult
• func BenchmarkTableQueryWithTableSerializerSuite(bs *bench.BenchmarkSuite) []bench.BenchmarkResult
• func BenchmarkTableScanSuite(bs *bench.BenchmarkSuite) []bench.BenchmarkResult
• func BenchmarkTableUpdateSuite(bs *bench.BenchmarkSuite) []bench.BenchmarkResult
• func BenchmarkTableUpsertSuite(bs *bench.BenchmarkSuite) []bench.BenchmarkResult
• func DeleteInBatchSize(tbt bond.Table[*TokenBalance], tbs []*TokenBalance, updateBatchSize int) func(*testing.B)
• func InsertInBatchSize(tbt bond.Table[*TokenBalance], tbs []*TokenBalance, insertBatchSize int) func(*testing.B)
• func QueryFilterWithOpts(tbt bond.Table[*TokenBalance], idx *bond.Index[*TokenBalance], ...) func(b *testing.B)
• func QueryIntersectWithOpts(tbt bond.Table[*TokenBalance], idx *bond.Index[*TokenBalance], ...) func(b *testing.B)
• func QueryWithOpts(tbt bond.Table[*TokenBalance], idx *bond.Index[*TokenBalance], ...) func(b *testing.B)
• func ScanElements(tbt bond.Table[*TokenBalance], tbs []*TokenBalance, numberToScan int) func(*testing.B)
• func ScanIndexElements(tbt bond.Table[*TokenBalance], idx *bond.Index[*TokenBalance], ...) func(*testing.B)
• func ScanIndexSkipThrough(tbt bond.Table[*TokenBalance], idx *bond.Index[*TokenBalance], ...) func(*testing.B)
• func ScanSkipThrough(tbt bond.Table[*TokenBalance], numberToSkip int, numberToRead int) func(*testing.B)
• func UpdateInBatchSize(tbt bond.Table[*TokenBalance], tbs []*TokenBalance, updateBatchSize int) func(*testing.B)
• func UpsertInBatchSize(tbt bond.Table[*TokenBalance], tbs []*TokenBalance, insertBatchSize int) func(*testing.B)
• func UpsertInBatchSizeWithBatch(db bond.DB, tbt bond.Table[*TokenBalance], tbs []*TokenBalance, ...) func(*testing.B)
• type TokenBalance
  • func (z *TokenBalance) DecodeMsg(dc *msgp.Reader) (err error)
  • func (z *TokenBalance) EncodeMsg(en *msgp.Writer) (err error)
  • func (z *TokenBalance) MarshalMsg(b []byte) (o []byte, err error)
  • func (z *TokenBalance) Msgsize() (s int)
  • func (z *TokenBalance) UnmarshalMsg(bts []byte) (o []byte, err error)
• type TokenBalanceSerializer
  • func (s *TokenBalanceSerializer) Deserialize(b []byte, tb **TokenBalance) error
  • func (s *TokenBalanceSerializer) Serialize(tb **TokenBalance) ([]byte, error)

Functions

func BenchmarkTableDeleteSuite

func BenchmarkTableDeleteSuite(bs *bench.BenchmarkSuite) []bench.BenchmarkResult

func BenchmarkTableExistSuite

func BenchmarkTableExistSuite(bs *bench.BenchmarkSuite) []bench.BenchmarkResult

func BenchmarkTableGetSuite

func BenchmarkTableGetSuite(bs *bench.BenchmarkSuite) []bench.BenchmarkResult

func BenchmarkTableInsertSuite

func BenchmarkTableInsertSuite(bs *bench.BenchmarkSuite) []bench.BenchmarkResult

func BenchmarkTableQueryIntersectSuite

func BenchmarkTableQueryIntersectSuite(bs *bench.BenchmarkSuite) []bench.BenchmarkResult

func BenchmarkTableQuerySuite

func BenchmarkTableQuerySuite(bs *bench.BenchmarkSuite) []bench.BenchmarkResult

func BenchmarkTableQueryWithTableSerializerSuite

func BenchmarkTableQueryWithTableSerializerSuite(bs *bench.BenchmarkSuite) []bench.BenchmarkResult

func BenchmarkTableScanSuite

func BenchmarkTableScanSuite(bs *bench.BenchmarkSuite) []bench.BenchmarkResult

func BenchmarkTableUpdateSuite

func BenchmarkTableUpdateSuite(bs *bench.BenchmarkSuite) []bench.BenchmarkResult

func BenchmarkTableUpsertSuite

func BenchmarkTableUpsertSuite(bs *bench.BenchmarkSuite) []bench.BenchmarkResult

func DeleteInBatchSize

func DeleteInBatchSize(tbt bond.Table[*TokenBalance], tbs []*TokenBalance, updateBatchSize int) func(*testing.B)

func InsertInBatchSize

func InsertInBatchSize(tbt bond.Table[*TokenBalance], tbs []*TokenBalance, insertBatchSize int) func(*testing.B)

func QueryFilterWithOpts

func QueryFilterWithOpts(tbt bond.Table[*TokenBalance], idx *bond.Index[*TokenBalance], sel bond.Selector[*TokenBalance], filter func(tb *TokenBalance) bool, offset int, limit int) func(b *testing.B)

func QueryIntersectWithOpts

func QueryIntersectWithOpts(tbt bond.Table[*TokenBalance], idx *bond.Index[*TokenBalance], sel bond.Selector[*TokenBalance], idx2 *bond.Index[*TokenBalance], sel2 bond.Selector[*TokenBalance], offset int, limit int) func(b *testing.B)

func QueryWithOpts

func QueryWithOpts(tbt bond.Table[*TokenBalance], idx *bond.Index[*TokenBalance], sel bond.Selector[*TokenBalance], offset int, limit int) func(b *testing.B)

func ScanElements

func ScanElements(tbt bond.Table[*TokenBalance], tbs []*TokenBalance, numberToScan int) func(*testing.B)

func ScanIndexElements

func ScanIndexElements(tbt bond.Table[*TokenBalance], idx *bond.Index[*TokenBalance], sel bond.Selector[*TokenBalance], tbs []*TokenBalance, numberToScan int) func(*testing.B)

func ScanIndexSkipThrough

func ScanIndexSkipThrough(tbt bond.Table[*TokenBalance], idx *bond.Index[*TokenBalance], sel bond.Selector[*TokenBalance], numberToSkip int, numberToRead int) func(*testing.B)

func ScanSkipThrough

func ScanSkipThrough(tbt bond.Table[*TokenBalance], numberToSkip int, numberToRead int) func(*testing.B)

func UpdateInBatchSize

func UpdateInBatchSize(tbt bond.Table[*TokenBalance], tbs []*TokenBalance, updateBatchSize int) func(*testing.B)

func UpsertInBatchSize

func UpsertInBatchSize(tbt bond.Table[*TokenBalance], tbs []*TokenBalance, insertBatchSize int) func(*testing.B)

func UpsertInBatchSizeWithBatch

func UpsertInBatchSizeWithBatch(db bond.DB, tbt bond.Table[*TokenBalance], tbs []*TokenBalance, insertBatchSize int) func(*testing.B)

Types

type TokenBalance

type TokenBalance struct {
	ID              uint64 `json:"id"`
	AccountID       uint32 `json:"accountId"`
	ContractAddress string `json:"contractAddress"`
	AccountAddress  string `json:"accountAddress"`
	TokenID         uint32 `json:"tokenId"`
	Balance         uint64 `json:"balance"`
}

func (*TokenBalance) DecodeMsg

func (z *TokenBalance) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*TokenBalance) EncodeMsg

func (z *TokenBalance) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*TokenBalance) MarshalMsg

func (z *TokenBalance) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*TokenBalance) Msgsize

func (z *TokenBalance) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*TokenBalance) UnmarshalMsg

func (z *TokenBalance) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type TokenBalanceSerializer

type TokenBalanceSerializer struct {
}

func (*TokenBalanceSerializer) Deserialize

func (s *TokenBalanceSerializer) Deserialize(b []byte, tb **TokenBalance) error

func (*TokenBalanceSerializer) Serialize

func (s *TokenBalanceSerializer) Serialize(tb **TokenBalance) ([]byte, error)