ch

README

clickhouse-batcher

asynchronous sending batches to clickhouse

Documentation

Index

• func UpMigrations(ctx context.Context, dsn string) error
• type Logger
• type Repository
  • func NewRepository(log Logger, enabled bool) *Repository
  • func (repo *Repository) Connect(ctx context.Context, cfg app.Clickhouse) error
  • func (repo *Repository) ProcessHashes(ctx context.Context, saveInterval time.Duration)
  • func (repo *Repository) SaveAsync(_ context.Context, hashEntity any)

Functions

func UpMigrations

func UpMigrations(ctx context.Context, dsn string) error

Types

type Logger

type Logger interface {
	Errorf(format string, args ...interface{})
	Infof(format string, args ...interface{})
	Debugf(format string, args ...interface{})
	Debugw(msg string, keysAndValues ...interface{})
}

type Repository

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

func NewRepository

func NewRepository(log Logger, enabled bool) *Repository

func (*Repository) Connect

func (repo *Repository) Connect(ctx context.Context, cfg app.Clickhouse) error

func (*Repository) ProcessHashes

func (repo *Repository) ProcessHashes(ctx context.Context, saveInterval time.Duration)

func (*Repository) SaveAsync

func (repo *Repository) SaveAsync(_ context.Context, hashEntity any)