ledger

type AccountsQuery struct {
	PageSize     uint
	Offset       uint
	AfterAddress string
	Filters      AccountsQueryFilters
}

type AccountsQueryFilters struct {
	Address         string
	Balance         string
	BalanceOperator BalanceOperator
	Metadata        map[string]string
	BalanceAsset    string
}

type AggregatedBalancesQuery struct {
	PageSize     uint
	Offset       uint
	AfterAddress string
	Filters      AggregatedBalancesQueryFilters
}

type AggregatedBalancesQueryFilters struct {
	AddressRegexp string
}

type BalanceOperator string

type BalancesQuery struct {
	PageSize     uint
	Offset       uint
	AfterAddress string
	Filters      BalancesQueryFilters
}

type BalancesQueryFilters struct {
	AddressRegexp []string
}

type ConflictError struct{}

type InsufficientFundError struct {
	Asset string
}

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

type LedgerOption = func(*Ledger)

type LockError struct {
	Err error
}

type LogsQuery struct {
	AfterID  uint64
	PageSize uint

	Filters LogsQueryFilters
}

type LogsQueryFilters struct {
	EndTime   time.Time
	StartTime time.Time
}

type Monitor interface {
	CommittedTransactions(ctx context.Context, ledger string, res ...core.ExpandedTransaction)
	SavedMetadata(ctx context.Context, ledger, targetType, id string, metadata core.Metadata)
	UpdatedMapping(ctx context.Context, ledger string, mapping core.Mapping)
	RevertedTransaction(ctx context.Context, ledger string, reverted, revert *core.ExpandedTransaction)
}

type NotFoundError struct {
	Msg string
}

type ResolveOptionFn func(r *Resolver) error

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

type ResolverOption interface {
	// contains filtered or unexported methods
}

type ScriptError struct {
	Code    string
	Message string
}

type Stats struct {
	Transactions uint64 `json:"transactions"`
	Accounts     uint64 `json:"accounts"`
}

type Store interface {
	GetLastTransaction(ctx context.Context) (*core.ExpandedTransaction, error)
	CountTransactions(context.Context, TransactionsQuery) (uint64, error)
	GetTransactions(context.Context, TransactionsQuery) (api.Cursor[core.ExpandedTransaction], error)
	GetTransaction(ctx context.Context, txid uint64) (*core.ExpandedTransaction, error)
	GetAccount(ctx context.Context, accountAddress string) (*core.Account, error)
	GetAssetsVolumes(ctx context.Context, accountAddress string) (core.AssetsVolumes, error)
	GetAccountWithVolumes(ctx context.Context, account string) (*core.AccountWithVolumes, error)
	CountAccounts(context.Context, AccountsQuery) (uint64, error)
	GetAccounts(context.Context, AccountsQuery) (api.Cursor[core.Account], error)
	GetBalances(context.Context, BalancesQuery) (api.Cursor[core.AccountsBalances], error)
	GetBalancesAggregated(context.Context, AggregatedBalancesQuery) (core.AssetsBalances, error)
	GetLastLog(context.Context) (*core.Log, error)
	GetLogs(context.Context, *LogsQuery) (api.Cursor[core.Log], error)
	LoadMapping(context.Context) (*core.Mapping, error)
	GetMigrationsAvailable() ([]core.MigrationInfo, error)
	GetMigrationsDone(context.Context) ([]core.MigrationInfo, error)

	UpdateTransactionMetadata(ctx context.Context, txid uint64, metadata core.Metadata, at time.Time) error
	UpdateAccountMetadata(ctx context.Context, address string, metadata core.Metadata, at time.Time) error
	Commit(ctx context.Context, txs ...core.ExpandedTransaction) error
	SaveMapping(ctx context.Context, m core.Mapping) error
	Name() string
	Initialize(context.Context) (bool, error)
	Close(context.Context) error
}

type TransactionCommitError struct {
	TXIndex int   `json:"index"`
	Err     error `json:"error"`
}

type TransactionsQuery struct {
	PageSize  uint
	AfterTxID uint64
	Filters   TransactionsQueryFilters
}

type TransactionsQueryFilters struct {
	Reference   string
	Destination string
	Source      string
	Account     string
	EndTime     time.Time
	StartTime   time.Time
	Metadata    map[string]string
}

type TxVolumeAggregator struct {
	PreCommitVolumes  core.AccountsAssetsVolumes
	PostCommitVolumes core.AccountsAssetsVolumes
	// contains filtered or unexported fields
}

type ValidationError struct {
	Msg string
}

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