clickhouse

Documentation

Index

• type EntryRepository
  • func NewEntryRepository(db *database.DB, logger tracelog.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)

Types

type EntryRepository

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

func NewEntryRepository

func NewEntryRepository(
	db *database.DB,
	logger tracelog.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)