sqlstorage

type AccPaginationToken struct {
	PageSize              uint                   `json:"pageSize"`
	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 ledger.BalanceOperator `json:"balanceOperator,omitempty"`
}

type BalancesPaginationToken struct {
	PageSize            uint     `json:"pageSize"`
	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 DefaultStorageDriver struct {
	*Driver
}

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

type Flavor sqlbuilder.Flavor

type HandlersByEngine map[string][]MigrationFunc

type IdempotencyStorageDriver struct {
	*Driver
}

type LedgerStorageDriver struct {
	*Driver
}

type LogsPaginationToken struct {
	AfterID   uint64    `json:"after"`
	PageSize  uint      `json:"pageSize,omitempty"`
	StartTime time.Time `json:"startTime,omitempty"`
	EndTime   time.Time `json:"endTime,omitempty"`
}

type Migration struct {
	core.MigrationInfo `json:"inline"`
	Handlers           HandlersByEngine `json:"-"`
}

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

type Migrations []Migration

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

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 SystemStore 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:"startTime,omitempty"`
	EndTime           time.Time         `json:"endTime,omitempty"`
	MetadataFilter    map[string]string `json:"metadata,omitempty"`
	PageSize          uint              `json:"pageSize,omitempty"`
}