sqlstorage

type AccPaginationToken struct {
	PageSize              uint                    `json:"page_size"`
	Offset                uint                    `json:"offset"`
	AfterAddress          string                  `json:"after,omitempty"`
	AddressRegexpFilter   string                  `json:"address,omitempty"`
	MetadataFilter        map[string]string       `json:"metadata,omitempty"`
	BalanceFilter         string                  `json:"balance,omitempty"`
	BalanceOperatorFilter storage.BalanceOperator `json:"balance_operator,omitempty"`
}

type BalancesPaginationToken struct {
	PageSize            uint   `json:"page_size"`
	Offset              uint   `json:"offset"`
	AfterAddress        string `json:"after,omitempty"`
	AddressRegexpFilter string `json:"address,omitempty"`
}

type DB interface {
	Initialize(ctx context.Context) error
	Schema(ctx context.Context, name string) (Schema, error)
	Close(ctx context.Context) error
}

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

type Flavor sqlbuilder.Flavor

type HandlersByEngine map[string][]MigrationFunc

type Migration struct {
	Number   string
	Name     string
	Handlers HandlersByEngine
}

type MigrationFunc func(ctx context.Context, schema Schema, tx *sql.Tx) error

type Migrations []Migration

type ModuleConfig struct {
	StorageDriver  string
	SQLiteConfig   *SQLiteConfig
	PostgresConfig *PostgresConfig
}

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

type PostgresConfig struct {
	ConnString string
}

type SQLiteConfig struct {
	Dir    string
	DBName string
}

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

type Schema interface {
	Initialize(ctx context.Context) error
	Table(name string) string
	Close(ctx context.Context) error
	BeginTx(ctx context.Context, s *sql.TxOptions) (*sql.Tx, error)
	Flavor() sqlbuilder.Flavor
	Name() string
	Delete(ctx context.Context) error
	// contains filtered or unexported methods
}

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

type TxsPaginationToken struct {
	AfterTxID         uint64            `json:"after"`
	ReferenceFilter   string            `json:"reference,omitempty"`
	AccountFilter     string            `json:"account,omitempty"`
	SourceFilter      string            `json:"source,omitempty"`
	DestinationFilter string            `json:"destination,omitempty"`
	StartTime         time.Time         `json:"start_time,omitempty"`
	EndTime           time.Time         `json:"end_time,omitempty"`
	MetadataFilter    map[string]string `json:"metadata,omitempty"`
	PageSize          uint              `json:"page_size,omitempty"`
}