eventstore

Documentation

Index

• type ClickhouseService
  • func (cs *ClickhouseService) StoreCustom(_ context.Context, ev *event.Custom) error
  • func (cs *ClickhouseService) StorePageView(_ context.Context, ev *event.PageView) error
• type Service
  • func ProvideClickhouseService(ch clickhouse.Ch, logger zerolog.Logger, teardownService teardown.Service) Service

Types

type ClickhouseService

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

func (*ClickhouseService) StoreCustom

func (cs *ClickhouseService) StoreCustom(_ context.Context, ev *event.Custom) error

StoreCustom implements Service.

func (*ClickhouseService) StorePageView

func (cs *ClickhouseService) StorePageView(_ context.Context, ev *event.PageView) error

StorePageView implements Service.

type Service

type Service interface {
	StorePageView(context.Context, *event.PageView) error
	StoreCustom(context.Context, *event.Custom) error
}

Service define an event storage service.

func ProvideClickhouseService

func ProvideClickhouseService(
	ch clickhouse.Ch,
	logger zerolog.Logger,
	teardownService teardown.Service,
) Service

ProvideClickhouseService is a wire provider for a clickhouse based event storage service.