clickhouse

Documentation

Index

• type EntryRepository
  • func NewEntryRepository(db *sqlx.DB, logger Logger, capacity int, period time.Duration) *EntryRepository
  • func (r *EntryRepository) Ping(ctx context.Context) error
  • func (r *EntryRepository) Run(ctx context.Context) error
  • func (r *EntryRepository) Stop()
  • func (r *EntryRepository) StoreEntryList(ctx context.Context, list []*domain.Entry) (err error)
• type Logger

Types

type EntryRepository

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

func NewEntryRepository

func NewEntryRepository(
	db *sqlx.DB,
	logger Logger,
	capacity int,
	period time.Duration,
) *EntryRepository

func (*EntryRepository) Ping

func (r *EntryRepository) Ping(ctx context.Context) error

func (*EntryRepository) Run

func (r *EntryRepository) Run(ctx context.Context) error

func (*EntryRepository) Stop

func (r *EntryRepository) Stop()

func (*EntryRepository) StoreEntryList

func (r *EntryRepository) StoreEntryList(ctx context.Context, list []*domain.Entry) (err error)

type Logger

type Logger interface {
	Debug(ctx context.Context, args ...interface{})
	Debugf(ctx context.Context, template string, args ...interface{})
	Info(ctx context.Context, args ...interface{})
	Infof(ctx context.Context, template string, args ...interface{})
	Warn(ctx context.Context, args ...interface{})
	Warnf(ctx context.Context, template string, args ...interface{})
	Error(ctx context.Context, args ...interface{})
	Errorf(ctx context.Context, template string, args ...interface{})
}