Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

transfer

package

Go to main page

Versions in this module

v0

v0.5.2

Jun 10, 2026

v0.5.1

Jun 8, 2026

v0.5.0

Jun 8, 2026

Changes in this version

+ var ErrCacheFull = errors.New("cache is full")

+ var ErrTransferExpired = errors.New("transfer expired")

+ var ErrTransferNotFound = errors.New("transfer not found")

+ func RegisterRoutes(r chi.Router, svc Service, logger *zap.Logger)

+ type CacheMetrics struct

+ GetsTotal *prometheus.CounterVec

+ PutsTotal *prometheus.CounterVec

+ func NewCacheMetrics(reg sharedmetrics.NamespacedRegisterer) *CacheMetrics

+ func NewNopCacheMetrics() *CacheMetrics

+ type ExecuteRequest struct

+ Signature string

+ SignedBy string

+ TransferID string

+ type ExecuteResponse struct

+ Status string

+ type IncomingTransfer struct

+ Amount string

+ ContractAddress string

+ ContractID string

+ Decimals int

+ InstrumentAdmin string

+ InstrumentID string

+ Name string

+ ReceiverPartyID string

+ SenderPartyID string

+ Symbol string

+ type IncomingTransfersList struct

+ HasMore bool

+ Items []IncomingTransfer

+ Limit int

+ Page int

+ Total int64

+ type InstrumentedCache struct

+ func NewInstrumentedCache(inner TransferCache, metrics *CacheMetrics) *InstrumentedCache

+ func (c *InstrumentedCache) GetAndDelete(transferID string) (*token.PreparedTransfer, error)

+ func (c *InstrumentedCache) Put(transfer *token.PreparedTransfer) error

+ type PendingOfferLister interface

+ GetPendingOffersForParty func(ctx context.Context, partyID string, p indexer.Pagination) (*indexer.Page[indexer.PendingOffer], error)

+ type PrepareAcceptRequest struct

+ InstrumentAdmin string

+ type PrepareRequest struct

+ Amount string

+ To string

+ Token string

+ type PrepareResponse struct

+ ExpiresAt string

+ PartyID string

+ TransactionHash string

+ TransferID string

+ type PreparedTransferCache struct

+ func NewPreparedTransferCache(ttl time.Duration, maxSize int) *PreparedTransferCache

+ func (c *PreparedTransferCache) GetAndDelete(transferID string) (*token.PreparedTransfer, error)

+ func (c *PreparedTransferCache) Put(transfer *token.PreparedTransfer) error

+ func (c *PreparedTransferCache) Start(ctx context.Context)

+ type Service interface

+ Execute func(ctx context.Context, senderEVMAddr string, req *ExecuteRequest) (*ExecuteResponse, error)

+ ExecuteAccept func(ctx context.Context, evmAddr string, req *ExecuteRequest) (*ExecuteResponse, error)

+ ListIncoming func(ctx context.Context, evmAddr string, p indexer.Pagination) (*IncomingTransfersList, error)

+ Prepare func(ctx context.Context, senderEVMAddr string, req *PrepareRequest) (*PrepareResponse, error)

+ PrepareAccept func(ctx context.Context, evmAddr, contractID string, req *PrepareAcceptRequest) (*PrepareResponse, error)

+ func NewLog(svc Service, logger *zap.Logger) Service

+ type TransferCache interface

+ GetAndDelete func(transferID string) (*token.PreparedTransfer, error)

+ Put func(transfer *token.PreparedTransfer) error

+ type TransferService struct

+ func NewTransferService(cantonToken token.Token, userStore UserStore, cache TransferCache, ...) *TransferService

+ func (s *TransferService) Execute(ctx context.Context, senderEVMAddr string, req *ExecuteRequest) (*ExecuteResponse, error)

+ func (s *TransferService) ExecuteAccept(ctx context.Context, evmAddr string, req *ExecuteRequest) (*ExecuteResponse, error)

+ func (s *TransferService) ListIncoming(ctx context.Context, evmAddr string, p indexer.Pagination) (*IncomingTransfersList, error)

+ func (s *TransferService) Prepare(ctx context.Context, senderEVMAddr string, req *PrepareRequest) (*PrepareResponse, error)

+ func (s *TransferService) PrepareAccept(ctx context.Context, evmAddr, contractID string, req *PrepareAcceptRequest) (*PrepareResponse, error)

+ type UserStore interface

+ GetUserByEVMAddress func(ctx context.Context, evmAddress string) (*user.User, error)

v0.4.2

May 26, 2026

v0.4.1

May 20, 2026

v0.4.0

May 12, 2026