db

func CreateReceipt ¶ added in v0.1.3

func CreateReceipt(t *testing.T, ctx context.Context, client *ent.Client, b ent.Block, destChainID uint64, streamOffset uint64) *ent.Receipt

func CreateSchema ¶

func CreateSchema(ctx context.Context, client *ent.Client) error

CreateSchema creates all schema resources and runs all required migrations.

func CreateTestBlock ¶ added in v0.1.3

func CreateTestBlock(t *testing.T, ctx context.Context, client *ent.Client, height int) ent.Block

func CreateTestBlocks ¶ added in v0.1.3

func CreateTestBlocks(t *testing.T, ctx context.Context, client *ent.Client, count int) []ent.Block

CreateTestBlocks creates n test blocks with n messages and n-1 receipts.

func CreateTestChain ¶ added in v0.1.3

func CreateTestChain(t *testing.T, ctx context.Context, client *ent.Client, chainID uint64) ent.Chain

func CreateTestEntClient ¶ added in v0.1.3

func CreateTestEntClient(t *testing.T) *ent.Client

func CreateXMsg ¶ added in v0.1.3

func CreateXMsg(t *testing.T, ctx context.Context, client *ent.Client, b ent.Block, destChainID uint64, streamOffset uint64) *ent.Msg

func NewPostgressClient ¶

func NewPostgressClient(dbURL string) (*ent.Client, error)

func NewSQLiteClient ¶

func NewSQLiteClient() (*ent.Client, error)