store

package

Go to main page

Versions in this module

v0

v0.4.0

Nov 8, 2026

Changes in this version

+ const IdempotencyTTL

+ const WebhookMaxAttempts

+ const WebhookRetention

type Store

+ func (s *Store) ClaimWebhook(ctx context.Context, now time.Time) (WebhookAttempt, error)

+ func (s *Store) CreateConnectionOnce(ctx context.Context, c ranjit.Connection, tokenHash any, deadline time.Time, ...) (ranjit.Connection, time.Time, error)

+ func (s *Store) EnableWebhooks(destination string)

+ func (s *Store) FinishWebhook(ctx context.Context, attempt WebhookAttempt, statusCode int, now time.Time) error

+ func (s *Store) Queues(ctx context.Context, now time.Time) (ranjit.QueueStatus, ranjit.QueueStatus, error)

+ func (s *Store) ReplayConnection(ctx context.Context, key, fingerprint string, now time.Time) (ranjit.Connection, time.Time, error)

+ func (s *Store) RetryWebhook(ctx context.Context, id string, now time.Time) error

+ func (s *Store) WebhookDeliveries(ctx context.Context, cursor string, limit int) (ranjit.Page[ranjit.WebhookDelivery], error)

+ type WebhookAttempt struct

+ Attempts int

+ ID string

+ LeaseToken string

+ Payload []byte

v0.3.0

Nov 7, 2026

Changes in this version

+ func IsPostgres(value string) bool

v0.2.0

Nov 7, 2026

Changes in this version

+ func BackupStopped(ctx context.Context, path, destination string) (func(), error)

+ func Restore(ctx context.Context, source, destination string, replace bool) (string, error)

+ type Search struct

+ Account string

+ Cursor string

+ Customer string

+ From string

+ Limit int

+ Query string

+ Through string

type Store

+ func (s *Store) Backup(ctx context.Context, destination string) error

+ func (s *Store) Pause(ctx context.Context, id string, now time.Time) error

+ func (s *Store) PreviewImport(ctx context.Context, customer, account string, input statement.Statement, ...) (ranjit.ImportResult, error)

+ func (s *Store) Renew(ctx context.Context, id, binding string, deadline, now time.Time) (ranjit.Connection, error)

+ func (s *Store) SearchTransactions(ctx context.Context, f Search, now time.Time) (ranjit.Page[ranjit.Transaction], error)

v0.1.0

Nov 7, 2026

Changes in this version

+ const MaxAttempts

+ type Checkpoint struct

+ Job ranjit.Job

+ Now func() time.Time

+ Store *Store

+ func (c Checkpoint) Load(ctx context.Context, endpoint string) ([]byte, error)

+ func (c Checkpoint) Save(ctx context.Context, endpoint string, body []byte) error

+ type Store struct

+ func Open(ctx context.Context, path string) (*Store, error)

+ func (s *Store) Accounts(ctx context.Context, id, cursor string, limit int, now time.Time) (ranjit.Page[ranjit.Account], error)

+ func (s *Store) Claim(ctx context.Context, now time.Time, lease time.Duration) (ranjit.Job, error)

+ func (s *Store) ClaimSelected(ctx context.Context, now time.Time, lease time.Duration, ...) (ranjit.Job, error)

+ func (s *Store) Close() error

+ func (s *Store) Complete(ctx context.Context, j ranjit.Job, batch provider.Snapshot, now time.Time) error

+ func (s *Store) ConfiguredConnections(ctx context.Context, institutions []string) (map[string]bool, error)

+ func (s *Store) Connection(ctx context.Context, id string, now time.Time) (ranjit.Connection, error)

+ func (s *Store) Connections(ctx context.Context, customer, cursor string, limit int, now time.Time) (ranjit.Page[ranjit.Connection], error)

+ func (s *Store) CreateAuthorizedConnection(ctx context.Context, c ranjit.Connection) error

+ func (s *Store) CreateConnection(ctx context.Context, c ranjit.Connection, tokenHash string, deadline time.Time) error

+ func (s *Store) Decide(ctx context.Context, hash string, approve bool, now time.Time) (ranjit.Connection, error)

+ func (s *Store) Enqueue(ctx context.Context, id string, now time.Time) (ranjit.Job, error)

+ func (s *Store) Expire(ctx context.Context, now time.Time) error

+ func (s *Store) Fail(ctx context.Context, j ranjit.Job, code string, now time.Time) error

+ func (s *Store) FailAfter(ctx context.Context, j ranjit.Job, code string, now time.Time, ...) error

+ func (s *Store) Import(ctx context.Context, customer, account string, input statement.Statement, ...) (ranjit.ImportResult, error)

+ func (s *Store) Job(ctx context.Context, id string) (ranjit.Job, error)

+ func (s *Store) PendingConsent(ctx context.Context, hash string, now time.Time) (ranjit.Connection, error)

+ func (s *Store) Ping(ctx context.Context) error

+ func (s *Store) Revoke(ctx context.Context, id string, now time.Time) error

+ func (s *Store) Schedule(ctx context.Context, now time.Time, interval time.Duration) error

+ func (s *Store) ScheduleSelected(ctx context.Context, now time.Time, interval time.Duration, ...) error

+ func (s *Store) Status(ctx context.Context, id string, now time.Time) (ranjit.ConnectionStatus, error)

+ func (s *Store) Transactions(ctx context.Context, accountID, cursor string, limit int, now time.Time) (ranjit.Page[ranjit.Transaction], error)

+ func (s *Store) Yield(ctx context.Context, j ranjit.Job, now time.Time) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL