database

Documentation

Index

• type DatabaseEventProducer
  • func NewDatabaseEventProducer(cfg DatabaseEventProducerConfig) (eventProducer *DatabaseEventProducer)
  • func (e *DatabaseEventProducer) Invalidations() <-chan events.Invalidation
  • func (e *DatabaseEventProducer) Run() error
  • func (e *DatabaseEventProducer) Saves() <-chan events.Save
• type DatabaseEventProducerConfig

Types

type DatabaseEventProducer

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

func NewDatabaseEventProducer

func NewDatabaseEventProducer(cfg DatabaseEventProducerConfig) (eventProducer *DatabaseEventProducer)

func (*DatabaseEventProducer) Invalidations

func (e *DatabaseEventProducer) Invalidations() <-chan events.Invalidation

func (*DatabaseEventProducer) Run

func (e *DatabaseEventProducer) Run() error

func (*DatabaseEventProducer) Saves

func (e *DatabaseEventProducer) Saves() <-chan events.Save

type DatabaseEventProducerConfig

type DatabaseEventProducerConfig struct {
	Provider           db_provider.DbProvider
	RequestType        config.DataType
	CacheInitQuery     string
	CacheInitTimeout   time.Duration
	CacheUpdateQuery   string
	CacheUpdateTimeout time.Duration
	MetricsEngine      metrics.MetricsEngine
}