transactions

Documentation

Index

• Constants
• type Cache
  • func New() *Cache
  • func NewWithCleanupPeriod(cleanupPeriod time.Duration) *Cache
  • func (t *Cache) AddTransaction(accessToken, txnID string, res *util.JSONResponse)
  • func (t *Cache) FetchTransaction(accessToken, txnID string) (*util.JSONResponse, bool)
• type CacheKey

Constants

const DefaultCleanupPeriod time.Duration = 30 * time.Minute

DefaultCleanupPeriod represents the default time duration after which cacheCleanService runs.

Types

type Cache

type Cache struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Cache represents a temporary store for response entries. Entries are evicted after a certain period, defined by cleanupPeriod. This works by keeping two maps of entries, and cycling the maps after the cleanupPeriod.

func New

func New() *Cache

New is a wrapper which calls NewWithCleanupPeriod with DefaultCleanupPeriod as argument.

func NewWithCleanupPeriod

func NewWithCleanupPeriod(cleanupPeriod time.Duration) *Cache

NewWithCleanupPeriod creates a new Cache object, starts cacheCleanService. Takes cleanupPeriod as argument. Returns a reference to newly created Cache.

func (*Cache) AddTransaction

func (t *Cache) AddTransaction(accessToken, txnID string, res *util.JSONResponse)

AddTransaction adds an entry for the (accessToken, txnID) tuple in Cache. Adds to the front txnMap.

func (*Cache) FetchTransaction

func (t *Cache) FetchTransaction(accessToken, txnID string) (*util.JSONResponse, bool)

FetchTransaction looks up an entry for the (accessToken, txnID) tuple in Cache. Looks in both the txnMaps. Returns (JSON response, true) if txnID is found, else the returned bool is false.

type CacheKey

type CacheKey struct {
	AccessToken string
	TxnID       string
}

CacheKey is the type for the key in a transactions cache. This is needed because the spec requires transaction IDs to have a per-access token scope.