postgres

Documentation

Index

• type PostgresEventProducer
  • func NewPostgresEventProducer(cfg PostgresEventProducerConfig) (eventProducer *PostgresEventProducer)
  • func (e *PostgresEventProducer) Invalidations() <-chan events.Invalidation
  • func (e *PostgresEventProducer) Run() error
  • func (e *PostgresEventProducer) Saves() <-chan events.Save
• type PostgresEventProducerConfig

Types

type PostgresEventProducer

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

func NewPostgresEventProducer

func NewPostgresEventProducer(cfg PostgresEventProducerConfig) (eventProducer *PostgresEventProducer)

func (*PostgresEventProducer) Invalidations

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

func (*PostgresEventProducer) Run

func (e *PostgresEventProducer) Run() error

func (*PostgresEventProducer) Saves

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

type PostgresEventProducerConfig

type PostgresEventProducerConfig struct {
	DB                 *sql.DB
	RequestType        config.DataType
	CacheInitQuery     string
	CacheInitTimeout   time.Duration
	CacheUpdateQuery   string
	CacheUpdateTimeout time.Duration
	MetricsEngine      metrics.MetricsEngine
}