store

Documentation

Index

• type MongoCollection
• type MongoDriverClient
• type Queue
  • func NewQueue(ctx *cli.Context) (Queue, error)

Types

type MongoCollection

type MongoCollection interface {
	InsertOne(ctx context.Context, document interface{}, opts ...*options.InsertOneOptions) (*mongo.InsertOneResult, error)
	UpdateOne(ctx context.Context, filter interface{}, update interface{}, opts ...*options.UpdateOptions) (*mongo.UpdateResult, error)
	FindOne(ctx context.Context, filter interface{}, opts ...*options.FindOneOptions) *mongo.SingleResult
}

type MongoDriverClient

type MongoDriverClient interface {
	Database(name string, opts ...*options.DatabaseOptions) *mongo.Database
	Disconnect(context.Context) error
}

type Queue

type Queue interface {
	Enqueue(*bindings.RIP7755OutboxCrossChainCallRequested) error
	ReadCheckpoint(checkpointId string) (uint64, error)
	WriteCheckpoint(checkpointId string, blockNumber uint64) error
	Close() error
}

func NewQueue

func NewQueue(ctx *cli.Context) (Queue, error)