Documentation ¶
Index ¶
- func MigrateEnvelope(db *sql.DB, up bool) (int, error)
- func MigrateIndexer(db *sql.DB, up bool) (int, error)
- func MigratePublicKey(db *sql.DB, up bool) (int, error)
- func NewConnection(user, password, databaseName, host, sslmode string, port int) (*sqlx.DB, error)
- func NewPublicKeyStore(db *sqlx.DB) (datastore.PublicKeyStore, error)
- func NewSyncStore(db *sqlx.DB) (datastore.SyncStore, error)
- func NewTransactionStore(db *sqlx.DB) (datastore.TransactionStore, error)
- type PublicKeyStore
- type SyncStore
- type TransactionStore
- func (s *TransactionStore) GetTransactionsFrom(ctx context.Context, protocol, network string, address []byte) ([]datastore.Transaction, error)
- func (s *TransactionStore) GetTransactionsTo(ctx context.Context, protocol, network string, address []byte) ([]datastore.Transaction, error)
- func (s *TransactionStore) PutTransaction(ctx context.Context, protocol, network string, hash []byte, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewConnection ¶
func NewPublicKeyStore ¶
func NewPublicKeyStore(db *sqlx.DB) (datastore.PublicKeyStore, error)
PublicKeyStore create new pointer to postgres database
func NewSyncStore ¶
NewSyncStore create new postgres database
func NewTransactionStore ¶
func NewTransactionStore(db *sqlx.DB) (datastore.TransactionStore, error)
Types ¶
type PublicKeyStore ¶
type PublicKeyStore struct {
// contains filtered or unexported fields
}
PublicKeyStore database connection object
func (PublicKeyStore) GetPublicKey ¶
func (PublicKeyStore) PutPublicKey ¶
type SyncStore ¶
type SyncStore struct {
// contains filtered or unexported fields
}
SyncStore database connection object
func (SyncStore) GetBlockNumber ¶
type TransactionStore ¶
type TransactionStore struct {
// contains filtered or unexported fields
}
func (*TransactionStore) GetTransactionsFrom ¶
func (s *TransactionStore) GetTransactionsFrom(ctx context.Context, protocol, network string, address []byte) ([]datastore.Transaction, error)
func (*TransactionStore) GetTransactionsTo ¶
func (s *TransactionStore) GetTransactionsTo(ctx context.Context, protocol, network string, address []byte) ([]datastore.Transaction, error)
func (*TransactionStore) PutTransaction ¶
func (s *TransactionStore) PutTransaction(ctx context.Context, protocol, network string, hash []byte, tx *datastore.Transaction) error
Click to show internal directories.
Click to hide internal directories.