blnk

package module

Go to main page

Versions in this module

v0

v0.13.2

Feb 12, 2026

Changes in this version

type Blnk

+ func (b *Blnk) RecoverQueuedTransactions(ctx context.Context, threshold time.Duration) (int, error)

+ func (l *Blnk) GetAllAccountsWithFilter(ctx context.Context, filters *filter.QueryFilterSet, limit, offset int) ([]model.Account, error)

+ func (l *Blnk) GetAllAccountsWithFilterAndOptions(ctx context.Context, filters *filter.QueryFilterSet, opts *filter.QueryOptions, ...) ([]model.Account, *int64, error)

+ func (l *Blnk) GetAllBalancesWithFilter(ctx context.Context, filters *filter.QueryFilterSet, limit, offset int) ([]model.Balance, error)

+ func (l *Blnk) GetAllBalancesWithFilterAndOptions(ctx context.Context, filters *filter.QueryFilterSet, opts *filter.QueryOptions, ...) ([]model.Balance, *int64, error)

+ func (l *Blnk) GetAllIdentitiesWithFilter(ctx context.Context, filters *filter.QueryFilterSet, limit, offset int) ([]model.Identity, error)

+ func (l *Blnk) GetAllIdentitiesWithFilterAndOptions(ctx context.Context, filters *filter.QueryFilterSet, opts *filter.QueryOptions, ...) ([]model.Identity, *int64, error)

+ func (l *Blnk) GetAllLedgersWithFilter(ctx context.Context, filters *filter.QueryFilterSet, limit, offset int) ([]model.Ledger, error)

+ func (l *Blnk) GetAllLedgersWithFilterAndOptions(ctx context.Context, filters *filter.QueryFilterSet, opts *filter.QueryOptions, ...) ([]model.Ledger, *int64, error)

+ func (l *Blnk) GetAllTransactionsWithFilter(ctx context.Context, filters *filter.QueryFilterSet, limit, offset int) ([]model.Transaction, error)

+ func (l *Blnk) GetAllTransactionsWithFilterAndOptions(ctx context.Context, filters *filter.QueryFilterSet, opts *filter.QueryOptions, ...) ([]model.Transaction, *int64, error)

+ type QueuedTransactionRecoveryProcessor struct

+ func NewQueuedTransactionRecoveryProcessor(blnk *Blnk) *QueuedTransactionRecoveryProcessor

+ func (p *QueuedTransactionRecoveryProcessor) IsRunning() bool

+ func (p *QueuedTransactionRecoveryProcessor) Start(ctx context.Context)

+ func (p *QueuedTransactionRecoveryProcessor) Stop()

v0.13.1

Feb 3, 2026

Changes in this version

type Blnk

+ func (b *Blnk) GetDataSource() database.IDataSource

+ func (b *Blnk) GetSearchClient() *search.TypesenseClient

v0.13.0

Jan 27, 2026

Changes in this version

+ const AllocationFIFO

+ const AllocationLIFO

+ const AllocationProp

+ const LineageFundAllocation

+ const LineageProviderKey

+ type Allocation struct

+ Amount *big.Int

+ BalanceID string

+ type BalanceLineage struct

+ AggregateBalanceID string

+ BalanceID string

+ Providers []ProviderBreakdown

+ TotalWithLineage *big.Int

type Blnk

+ func (b *Blnk) Config() *config.Configuration

+ func (l *Blnk) GetBalanceLineage(ctx context.Context, balanceID string) (*BalanceLineage, error)

+ func (l *Blnk) GetTransactionLineage(ctx context.Context, transactionID string) (*TransactionLineage, error)

+ func (l *Blnk) PrepareLineageOutbox(ctx context.Context, txn *model.Transaction, ...) *model.LineageOutbox

+ func (l *Blnk) ProcessLineageFromOutbox(ctx context.Context, entry model.LineageOutbox) error

+ type LineageOutboxPayload struct

+ Amount float64

+ Currency string

+ Inflight bool

+ PreciseAmount string

+ Precision float64

+ Reference string

+ SkipQueue bool

+ type LineageOutboxProcessor struct

+ func NewLineageOutboxProcessor(blnk *Blnk) *LineageOutboxProcessor

+ func (p *LineageOutboxProcessor) IsRunning() bool

+ func (p *LineageOutboxProcessor) Start(ctx context.Context)

+ func (p *LineageOutboxProcessor) Stop()

+ func (p *LineageOutboxProcessor) WithBatchSize(size int) *LineageOutboxProcessor

+ func (p *LineageOutboxProcessor) WithLockDuration(duration time.Duration) *LineageOutboxProcessor

+ func (p *LineageOutboxProcessor) WithPollInterval(interval time.Duration) *LineageOutboxProcessor

+ type LineageSource struct

+ Balance *big.Int

+ BalanceID string

+ CreatedAt time.Time

+ type ProviderBreakdown struct

+ Amount *big.Int

+ Available *big.Int

+ BalanceID string

+ Provider string

+ Spent *big.Int

+ type TransactionLineage struct

+ FundAllocation []map[string]interface{}

+ ShadowTransactions []model.Transaction

+ TransactionID string

v0.12.2

Jan 13, 2026

v0.12.1

Jan 7, 2026

v0.12.0

Dec 8, 2025

v0.11.6

Nov 29, 2025

v0.11.5

Nov 28, 2025

v0.11.4

Nov 26, 2025

v0.11.3

Nov 20, 2025

v0.11.2

Oct 8, 2025

v0.11.1

Sep 30, 2025

Changes in this version

+ const GeneralLedgerID

+ const StatusApplied

+ const StatusCommit

+ const StatusCompleted

+ const StatusFailed

+ const StatusInProgress

+ const StatusInflight

+ const StatusQueued

+ const StatusRejected

+ const StatusScheduled

+ const StatusStarted

+ const StatusVoid

+ var SQLFiles embed.FS

+ func IsInflightTransaction(transaction *model.Transaction) bool

+ func NewBalanceTracker() *model.BalanceTracker

+ type BatchJobResult struct

+ Error error

+ Txn *model.Transaction

+ type Blnk struct

+ Hooks hooks.HookManager

+ func NewBlnk(db database.IDataSource) (*Blnk, error)

+ func (b *Blnk) Close() error

+ func (b *Blnk) ProcessWebhook(_ context.Context, task *asynq.Task) error

+ func (b *Blnk) SendWebhook(newWebhook NewWebhook) error

+ func (l *Blnk) CommitInflightTransaction(ctx context.Context, transactionID string, amount *big.Int) (*model.Transaction, error)

+ func (l *Blnk) CommitInflightTransactionWithQueue(ctx context.Context, transactionID string, amount *big.Int) (*model.Transaction, error)

+ func (l *Blnk) CommitWorker(ctx context.Context, jobs <-chan *model.Transaction, ...)

+ func (l *Blnk) CreateAPIKey(ctx context.Context, name, ownerID string, scopes []string, ...) (*model.APIKey, error)

+ func (l *Blnk) CreateAccount(account model.Account) (model.Account, error)

+ func (l *Blnk) CreateBalance(ctx context.Context, balance model.Balance) (model.Balance, error)

+ func (l *Blnk) CreateBulkTransactions(ctx context.Context, req *model.BulkTransactionRequest) (*model.BulkTransactionResult, error)

+ func (l *Blnk) CreateIdentity(identity model.Identity) (model.Identity, error)

+ func (l *Blnk) CreateLedger(ledger model.Ledger) (model.Ledger, error)

+ func (l *Blnk) CreateMonitor(ctx context.Context, monitor model.BalanceMonitor) (model.BalanceMonitor, error)

+ func (l *Blnk) DeleteIdentity(id string) error

+ func (l *Blnk) DeleteMonitor(ctx context.Context, id string) error

+ func (l *Blnk) DetokenizeIdentity(identityID string) (map[string]string, error)

+ func (l *Blnk) DetokenizeIdentityField(identityID, fieldName string) (string, error)

+ func (l *Blnk) GetAPIKeyByKey(ctx context.Context, key string) (*model.APIKey, error)

+ func (l *Blnk) GetAccount(id string, include []string) (*model.Account, error)

+ func (l *Blnk) GetAccountByNumber(id string) (*model.Account, error)

+ func (l *Blnk) GetAllAccounts() ([]model.Account, error)

+ func (l *Blnk) GetAllBalances(ctx context.Context, limit, offset int) ([]model.Balance, error)

+ func (l *Blnk) GetAllIdentities() ([]model.Identity, error)

+ func (l *Blnk) GetAllLedgers(limit, offset int) ([]model.Ledger, error)

+ func (l *Blnk) GetAllMonitors(ctx context.Context) ([]model.BalanceMonitor, error)

+ func (l *Blnk) GetAllTransactions(limit, offset int) ([]model.Transaction, error)

+ func (l *Blnk) GetBalanceAtTime(ctx context.Context, balanceID string, targetTime time.Time, fromSource bool) (*model.Balance, error)

+ func (l *Blnk) GetBalanceByID(ctx context.Context, id string, include []string, withQueued bool) (*model.Balance, error)

+ func (l *Blnk) GetBalanceByIndicator(ctx context.Context, indicator, currency string) (*model.Balance, error)

+ func (l *Blnk) GetBalanceMonitors(ctx context.Context, balanceID string) ([]model.BalanceMonitor, error)

+ func (l *Blnk) GetDetokenizedIdentity(identityID string) (*model.Identity, error)

+ func (l *Blnk) GetIdentity(id string) (*model.Identity, error)

+ func (l *Blnk) GetInflightTransactionsByParentID(ctx context.Context, parentTransactionID string, batchSize int, offset int64) ([]*model.Transaction, error)

+ func (l *Blnk) GetLedgerByID(id string) (*model.Ledger, error)

+ func (l *Blnk) GetMonitorByID(ctx context.Context, id string) (*model.BalanceMonitor, error)

+ func (l *Blnk) GetRefundableTransactionsByParentID(ctx context.Context, parentTransactionID string, batchSize int, offset int64) ([]*model.Transaction, error)

+ func (l *Blnk) GetTransaction(ctx context.Context, TransactionID string) (*model.Transaction, error)

+ func (l *Blnk) GetTransactionByRef(ctx context.Context, reference string) (model.Transaction, error)

+ func (l *Blnk) ListAPIKeys(ctx context.Context, ownerID string) ([]*model.APIKey, error)

+ func (l *Blnk) MultiSearch(searchParams *api.MultiSearchSearchesParameter) (*api.MultiSearchResult, error)

+ func (l *Blnk) ProcessTransactionInBatches(ctx context.Context, parentTransactionID string, amount *big.Int, ...) ([]*model.Transaction, error)

+ func (l *Blnk) QueueTransaction(ctx context.Context, transaction *model.Transaction) (*model.Transaction, error)

+ func (l *Blnk) RecordTransaction(ctx context.Context, transaction *model.Transaction) (*model.Transaction, error)

+ func (l *Blnk) RefundTransaction(ctx context.Context, transactionID string, skipQueue bool) (*model.Transaction, error)

+ func (l *Blnk) RefundWorker(ctx context.Context, jobs <-chan *model.Transaction, ...)

+ func (l *Blnk) RejectTransaction(ctx context.Context, transaction *model.Transaction, reason string) (*model.Transaction, error)

+ func (l *Blnk) RevokeAPIKey(ctx context.Context, id, ownerID string) error

+ func (l *Blnk) Search(collection string, query *api.SearchCollectionParams) (interface{}, error)

+ func (l *Blnk) TakeBalanceSnapshots(ctx context.Context, batchSize int)

+ func (l *Blnk) TokenizeAllPII(identityID string) error

+ func (l *Blnk) TokenizeIdentity(identityID string, fields []string) error

+ func (l *Blnk) TokenizeIdentityField(identityID, fieldName string) error

+ func (l *Blnk) UpdateBalanceIdentity(balanceID, identityID string) error

+ func (l *Blnk) UpdateIdentity(identity *model.Identity) error

+ func (l *Blnk) UpdateLastUsed(ctx context.Context, id string) error

+ func (l *Blnk) UpdateLedger(id, name string) (*model.Ledger, error)

+ func (l *Blnk) UpdateMetadata(ctx context.Context, entityID string, newMetadata map[string]interface{}) (map[string]interface{}, error)

+ func (l *Blnk) UpdateMonitor(ctx context.Context, monitor *model.BalanceMonitor) error

+ func (l *Blnk) UpdateTransactionStatus(ctx context.Context, id string, status string) error

+ func (l *Blnk) VoidInflightTransaction(ctx context.Context, transactionID string) (*model.Transaction, error)

+ func (l *Blnk) VoidWorker(ctx context.Context, jobs <-chan *model.Transaction, ...)

+ func (s *Blnk) CreateMatchingRule(ctx context.Context, rule model.MatchingRule) (*model.MatchingRule, error)

+ func (s *Blnk) DeleteMatchingRule(ctx context.Context, id string) error

+ func (s *Blnk) GetMatchingRule(ctx context.Context, id string) (*model.MatchingRule, error)

+ func (s *Blnk) GetReconciliation(ctx context.Context, reconciliationID string) (*model.Reconciliation, error)

+ func (s *Blnk) ListMatchingRules(ctx context.Context) ([]*model.MatchingRule, error)

+ func (s *Blnk) StartInstantReconciliation(ctx context.Context, externalTransactions []model.ExternalTransaction, ...) (string, error)

+ func (s *Blnk) StartReconciliation(ctx context.Context, uploadID string, strategy string, groupCriteria string, ...) (string, error)

+ func (s *Blnk) UpdateMatchingRule(ctx context.Context, rule model.MatchingRule) (*model.MatchingRule, error)

+ func (s *Blnk) UploadExternalData(ctx context.Context, source string, reader io.Reader, filename string) (string, int, error)

+ type MockBlnk struct

+ func (m *MockBlnk) GetTransaction(id string) (*model.Transaction, error)

+ type MultiSearchRequest struct

+ Searches []api.MultiSearchSearchesParameter

+ type NewWebhook struct

+ Event string

+ Payload interface{}

+ type NotificationPayload struct

+ Data map[string]interface{}

+ Table string

+ type Queue struct

+ Client *asynq.Client

+ Inspector *asynq.Inspector

+ func NewQueue(conf *config.Configuration) *Queue

+ func (q *Queue) Enqueue(ctx context.Context, transaction *model.Transaction) error

+ func (q *Queue) GetTransactionFromQueue(transactionID string) (*model.Transaction, error)

+ func (q *Queue) QueueInflightExpiry(ctx context.Context, transaction *model.Transaction) error

+ type TransactionTypePayload struct

+ Data model.Transaction

+ type TypesenseClient struct

+ Client *typesense.Client

+ func NewTypesenseClient(apiKey string, hosts []string) *TypesenseClient

+ func (t *TypesenseClient) CreateCollection(ctx context.Context, schema *api.CollectionSchema) (*api.CollectionResponse, error)

+ func (t *TypesenseClient) EnsureCollectionsExist(ctx context.Context) error

+ func (t *TypesenseClient) HandleNotification(table string, data map[string]interface{}) error

+ func (t *TypesenseClient) MigrateTypeSenseSchema(ctx context.Context, collectionName string) error

+ func (t *TypesenseClient) MultiSearch(ctx context.Context, searchRequests api.MultiSearchSearchesParameter) (*api.MultiSearchResult, error)

+ func (t *TypesenseClient) Search(ctx context.Context, collection string, ...) (*api.SearchResult, error)

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