logstore

Documentation

Index

• type Config
• type DriverOpts
  • func MakeDriverOpts(cfg Config) (DriverOpts, error)
  • func (d *DriverOpts) Close() error
• type ListDeliveryRequest
• type ListEventRequest
• type ListEventResponse
• type LogStore
  • func NewLogStore(ctx context.Context, driverOpts DriverOpts) (LogStore, error)
  • func NewNoopLogStore() LogStore

Types

type Config

type Config struct {
	ClickHouse *clickhouse.ClickHouseConfig
	Postgres   *string
}

type DriverOpts

type DriverOpts struct {
	CH clickhouse.DB
	PG *pgxpool.Pool
}

func MakeDriverOpts

func MakeDriverOpts(cfg Config) (DriverOpts, error)

func (*DriverOpts) Close

func (d *DriverOpts) Close() error

type ListDeliveryRequest

type ListDeliveryRequest = driver.ListDeliveryRequest

type ListEventRequest

type ListEventRequest = driver.ListEventRequest

type ListEventResponse

type ListEventResponse = driver.ListEventResponse

type LogStore

type LogStore interface {
	ListEvent(context.Context, ListEventRequest) (ListEventResponse, error)
	RetrieveEvent(ctx context.Context, tenantID, eventID string) (*models.Event, error)
	RetrieveEventByDestination(ctx context.Context, tenantID, destinationID, eventID string) (*models.Event, error)
	ListDelivery(ctx context.Context, request ListDeliveryRequest) ([]*models.Delivery, error)
	InsertManyDeliveryEvent(context.Context, []*models.DeliveryEvent) error
}

func NewLogStore

func NewLogStore(ctx context.Context, driverOpts DriverOpts) (LogStore, error)

func NewNoopLogStore

func NewNoopLogStore() LogStore