persistence

Documentation

Index

• type BoltPersistenceLayer
  • func NewBoltPersistenceLayer(config BoltPersistenceLayerConfig) (*BoltPersistenceLayer, error)
  • func (persistenceLayer *BoltPersistenceLayer) LoadFacts(ticker sec.Ticker) (*sec.CompanyFacts, error)
  • func (persistenceLayer *BoltPersistenceLayer) SaveFacts(ticker sec.Ticker, facts *sec.CompanyFacts) error
• type BoltPersistenceLayerConfig
• type PersistedCompanyFacts

Types

type BoltPersistenceLayer

type BoltPersistenceLayer struct {
	Db *bbolt.DB
	// contains filtered or unexported fields
}

func NewBoltPersistenceLayer

func NewBoltPersistenceLayer(config BoltPersistenceLayerConfig) (*BoltPersistenceLayer, error)

func (*BoltPersistenceLayer) LoadFacts

func (persistenceLayer *BoltPersistenceLayer) LoadFacts(ticker sec.Ticker) (*sec.CompanyFacts, error)

func (*BoltPersistenceLayer) SaveFacts

func (persistenceLayer *BoltPersistenceLayer) SaveFacts(ticker sec.Ticker, facts *sec.CompanyFacts) error

type BoltPersistenceLayerConfig

type BoltPersistenceLayerConfig struct {
	Path         string
	ExpiresAfter time.Duration
	ReduceSize   bool
}

type PersistedCompanyFacts

type PersistedCompanyFacts struct {
	Timestamp int64
	Facts     sec.CompanyFacts
}

PersistedCompanyFacts A representation of company facts with appended Timestamp