app

Mar 15, 2024

Changes in this version

+ type TableSchema struct

+ Columns []Column

+ Table string

Feb 9, 2024

Changes in this version

+ var ErrNotFoundInCache = errors.New("not found in cache")

Jan 19, 2024

Changes in this version

+ type RetrieveEventParams struct

+ CID cid.Cid

+ Timeout int64

+ type Retriever struct

+ func NewRetriever(provider VaultsProvider, cache bool, timeout int64) *Retriever

+ func (r *Retriever) Retrieve(ctx context.Context, c cid.Cid, output string) error

type VaultsProvider

+ RetrieveEvent func(context.Context, RetrieveEventParams, io.Writer) (string, error)

type WriteVaultEventParams

+ Filename string

Dec 19, 2023

Changes in this version

+ type VaultsProvider interface

+ CreateVault func(context.Context, CreateVaultParams) error

+ ListVaultEvents func(context.Context, ListVaultEventsParams) ([]EventInfo, error)

+ ListVaults func(context.Context, ListVaultsParams) ([]Vault, error)

+ WriteVaultEvent func(context.Context, WriteVaultEventParams) error

+ type VaultsStreamer struct

+ func NewVaultsStreamer(ns string, r Replicator, dbm *DBManager) *VaultsStreamer

+ func (b *VaultsStreamer) Run(ctx context.Context) error

+ type VaultsUploader struct

+ func NewVaultsUploader(ns string, rel string, bp VaultsProvider, pk *ecdsa.PrivateKey) *VaultsUploader

+ func (bu *VaultsUploader) Upload(ctx context.Context, filepath string, progress io.Writer, ts Timestamp, ...) error

Dec 14, 2023

Changes in this version

+ type Account struct

+ func NewAccount(address string) (*Account, error)

+ func (a *Account) Hex() string

+ type BasinProvider interface

+ CreateVault func(context.Context, CreateVaultParams) error

+ ListVaultEvents func(context.Context, ListVaultEventsParams) ([]EventInfo, error)

+ ListVaults func(context.Context, ListVaultsParams) ([]Vault, error)

+ WriteVaultEvent func(context.Context, WriteVaultEventParams) error

+ type BasinStreamer struct

+ func NewBasinStreamer(ns string, r Replicator, dbm *DBManager) *BasinStreamer

+ func (b *BasinStreamer) Run(ctx context.Context) error

+ type BasinUploader struct

+ func NewBasinUploader(ns string, rel string, bp BasinProvider, pk *ecdsa.PrivateKey) *BasinUploader

+ func (bu *BasinUploader) Upload(ctx context.Context, filepath string, progress io.Writer, ts Timestamp, ...) error

+ type CacheDuration uint32

+ type Column struct

+ IsNull bool

+ IsPrimary bool

+ Name string

+ Typ string

+ type CreateVaultParams struct

+ Account *Account

+ CacheDuration CacheDuration

+ Vault Vault

+ type DBManager struct

+ func NewDBManager(dbDir, table string, cols []Column, winSize time.Duration, ...) *DBManager

+ func (dbm *DBManager) Close() error

+ func (dbm *DBManager) Export(ctx context.Context, exportPath string) error

+ func (dbm *DBManager) NewDB(ctx context.Context) error

+ func (dbm *DBManager) Replay(ctx context.Context, tx *pgrepl.Tx) error

+ func (dbm *DBManager) UploadAll(ctx context.Context) error

+ func (dbm *DBManager) UploadAt(ctx context.Context, exportPath string) error

+ type EventInfo struct

+ CID string

+ CacheExpiry string

+ IsArchived bool

+ Size uint32

+ Timestamp int64

+ type ListVaultEventsParams struct

+ After Timestamp

+ Before Timestamp

+ Limit uint32

+ Offset uint32

+ Vault Vault

+ type ListVaultsParams struct

+ Account *Account

+ type Replicator interface

+ Commit func(ctx context.Context, lsn pglogrepl.LSN) error

+ Shutdown func()

+ StartReplication func(ctx context.Context) (chan *pgrepl.Tx, string, error)

+ type Signer struct

+ func NewSigner(pk *ecdsa.PrivateKey) *Signer

+ func (s *Signer) Sign() ([]byte, error)

+ func (s *Signer) SignFile(filename string) ([]byte, error)

+ func (s *Signer) Sum(chunk []byte)

+ type Timestamp struct

+ func NewTimestamp(t time.Time) Timestamp

+ func ParseTimestamp(ts string) (Timestamp, error)

+ func (t *Timestamp) Seconds() int64

+ type Vault string

+ type WriteVaultEventParams struct

+ Content io.Reader

+ ProgressBar io.Writer

+ Signature string

+ Size int64

+ Timestamp Timestamp

+ Vault Vault