storage

Documentation

Index

• Variables
• type Adapter
• type Callback
• type ClickhouseWorker
  • func NewClickhouseWorker[T any](source string, conn *sql.DB, adapter Adapter[T], maxBatchSize uint, ...) *ClickhouseWorker[T]
  • func (w *ClickhouseWorker[T]) RegisterCallback(cb Callback)
  • func (w *ClickhouseWorker[T]) Start(ctx context.Context) error
  • func (w *ClickhouseWorker[T]) Store(group uint32, items ...T) error
• type GroupState

Variables

var (
	ErrWorkerIsNotActive = errors.New("storage worker is not active")
)

Types

type Adapter

type Adapter[T any] interface {
	GetInsertQuery() string
	Values(T) []any
	GetCategoryID(T) uint32
}

type Callback

type Callback func(map[uint32]GroupState)

type ClickhouseWorker

type ClickhouseWorker[T any] struct {
	// contains filtered or unexported fields
}

func NewClickhouseWorker

func NewClickhouseWorker[T any](source string, conn *sql.DB, adapter Adapter[T], maxBatchSize uint, maxBatchDuration time.Duration) *ClickhouseWorker[T]

func (*ClickhouseWorker[T]) RegisterCallback

func (w *ClickhouseWorker[T]) RegisterCallback(cb Callback)

func (*ClickhouseWorker[T]) Start

func (w *ClickhouseWorker[T]) Start(ctx context.Context) error

func (*ClickhouseWorker[T]) Store

func (w *ClickhouseWorker[T]) Store(group uint32, items ...T) error

type GroupState

type GroupState uint8

const (
	Pending GroupState = iota + 1
	Committed
	Failed
)