store

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

type ActiveContractStoreInterface interface {
	// Get returns the active contract for the given instance address.
	Get(address contracts.InstanceAddress) (*apiv2.ActiveContract, bool)
	// GetByTemplateId returns the active contracts for the given party and template ID.
	GetByTemplateId(party types.PARTY, templateId contracts.TemplateID) ([]*apiv2.ActiveContract, bool)
	// GetByContractId returns the active contract for the given contract ID.
	GetByContractId(contractId types.CONTRACT_ID) (*apiv2.ActiveContract, bool)
	// RegisterTemplates registers templates to be tracked by the store.
	RegisterTemplates(templates ...RegisteredTemplate)
}

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

type FiltersByParty map[string]*apiv2.Filters

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

type InstrumentHoldingStoreInterface interface {
	// GetHolding returns the active holdings for the given party and instrument ID.
	GetHolding(party types.PARTY, instrumentId splice_api_token_holding_v1.InstrumentId) ([]*apiv2.ActiveContract, bool)
	// ListHoldings returns all active holdings for the given instrument ID.
	ListHoldings(instrumentId splice_api_token_holding_v1.InstrumentId) ([]*apiv2.ActiveContract, error)
	// RegisterParty registers parties whose holdings should be tracked by the store.
	RegisterParty(parties ...string)
}

type Metrics interface {
	IncrementStoreSubscriptionUptime(ctx context.Context)
	IncrementStoreUpdatesCounter(ctx context.Context)
	RecordStoreLedgerEndGauge(ctx context.Context, ledgerEnd int64)
}

type RegisteredTemplate struct {
	TemplateID contracts.TemplateID
	PartyID    string
}

type RunOption func(o *runOptions)

type StreamConfig struct {
	MaxRetries    int           // 0 means unlimited retries
	BackoffMin    time.Duration // default 100ms
	BackoffMax    time.Duration // default 3s
	BackoffFactor float64       // default 2
}