events

Documentation

Index

• type BufferMetrics
• type CHStorage
  • func NewCHRepo(conn clickhouse.ChConn, storageMetrics StorageMetrics, ...) *CHStorage
  • func (r *CHStorage) GetTransaction(ctx context.Context) (*sql.Tx, error)
  • func (r *CHStorage) ProcessInsertEvents(ctx context.Context, events []*entities.EventDTO) error
  • func (r *CHStorage) StartQueueProducing()
  • func (r *CHStorage) StopQueueProducing() error
• type StorageMetrics

Types

type BufferMetrics

type BufferMetrics interface {
	BufferWriteIOInc()
	BufferReadIOInc()
}

type CHStorage

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

func NewCHRepo

func NewCHRepo(conn clickhouse.ChConn, storageMetrics StorageMetrics, bufferMetrics BufferMetrics, bufferCfg clickhouse.BufferConfig) *CHStorage

func (*CHStorage) GetTransaction

func (r *CHStorage) GetTransaction(ctx context.Context) (*sql.Tx, error)

func (*CHStorage) ProcessInsertEvents

func (r *CHStorage) ProcessInsertEvents(ctx context.Context, events []*entities.EventDTO) error

func (*CHStorage) StartQueueProducing

func (r *CHStorage) StartQueueProducing()

func (*CHStorage) StopQueueProducing

func (r *CHStorage) StopQueueProducing() error

type StorageMetrics

type StorageMetrics interface {
	QueryDuration(duration time.Duration, labels ...string)
}