storage

type BuiltInFactory struct {
	Driver Driver
}

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

type Code string

type Driver interface {
	Initialize(ctx context.Context) error
	NewStore(name string) (Store, error)
	Close(ctx context.Context) error
	Name() string
}

type Error struct {
	Code          Code
	OriginalError error
}

type Factory interface {
	GetStore(name string) (Store, error)
	Close(ctx context.Context) error
}

type RememberConfigStorageFactory struct {
	Factory
	// contains filtered or unexported fields
}

type Store interface {
	LastTransaction(context.Context) (*core.Transaction, error)
	LastMetaID(context.Context) (int64, error)
	SaveTransactions(context.Context, []core.Transaction) (map[int]error, error)
	CountTransactions(context.Context) (int64, error)
	FindTransactions(context.Context, query.Query) (query.Cursor, error)
	GetTransaction(context.Context, string) (core.Transaction, error)
	AggregateBalances(context.Context, string) (map[string]int64, error)
	AggregateVolumes(context.Context, string) (map[string]map[string]int64, error)
	CountAccounts(context.Context) (int64, error)
	FindAccounts(context.Context, query.Query) (query.Cursor, error)
	SaveMeta(context.Context, int64, string, string, string, string, string) error
	GetMeta(context.Context, string, string) (core.Metadata, error)
	CountMeta(context.Context) (int64, error)
	LoadMapping(ctx context.Context) (*core.Mapping, error)
	SaveMapping(ctx context.Context, m core.Mapping) error
	Initialize(context.Context) error
	Name() string
	Close(context.Context) error
}