app

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

type CacheDuration uint32

type Column struct {
	Name, Typ         string
	IsNull, IsPrimary bool
}

type CreateVaultParams struct {
	Vault         Vault
	Account       *Account
	CacheDuration CacheDuration
}

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

type EventInfo struct {
	CID         string `json:"cid"`
	Timestamp   int64  `json:"timestamp"`
	IsArchived  bool   `json:"is_archived"`
	CacheExpiry string `json:"cache_expiry"`
}

type ListVaultEventsParams struct {
	Vault  Vault
	Limit  uint32
	Offset uint32
	Before Timestamp
	After  Timestamp
}

type ListVaultsParams struct {
	Account *Account
}

type Replicator interface {
	StartReplication(ctx context.Context) (chan *pgrepl.Tx, []string, error)
	Commit(ctx context.Context, lsn pglogrepl.LSN) error
	Shutdown()
}

type RetrieveEventParams struct {
	Timeout int64
	CID     cid.Cid
}

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

type TableSchema struct {
	Table   string
	Columns []Column
}

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

type Vault string

type VaultsProvider interface {
	CreateVault(context.Context, CreateVaultParams) error
	ListVaults(context.Context, ListVaultsParams) ([]Vault, error)
	ListVaultEvents(context.Context, ListVaultEventsParams) ([]EventInfo, error)
	WriteVaultEvent(context.Context, WriteVaultEventParams) error
	RetrieveEvent(context.Context, RetrieveEventParams, io.Writer) (string, error)
}

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

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

type WriteVaultEventParams struct {
	Vault       Vault
	Signature   string
	Filename    string
	Timestamp   Timestamp
	Content     io.Reader
	ProgressBar io.Writer
	Size        int64
}