eventslog

type ActorEvent struct {
	EventType EventType
	Level     Level
	ActorId   string
	Event     any
	Timestamp time.Time
}

type ClickhouseEventsLog struct {
	sync.Mutex
	appbase.Service
	// contains filtered or unexported fields
}

type DummyEventsLogService struct{}

type EventStatus string

type EventType string

type EventsLogConfig struct {
	ClickhouseHost     string `mapstructure:"CLICKHOUSE_HOST"`
	ClickhouseDatabase string `mapstructure:"CLICKHOUSE_DATABASE"`
	ClickhouseUsername string `mapstructure:"CLICKHOUSE_USERNAME"`
	ClickhousePassword string `mapstructure:"CLICKHOUSE_PASSWORD"`
	ClickhouseSSL      bool   `mapstructure:"CLICKHOUSE_SSL"`
}

type EventsLogFilter struct {
	Start    time.Time
	End      time.Time
	BeforeId EventsLogRecordId
	Filter   func(event any) bool
}

type EventsLogRecord struct {
	Id      EventsLogRecordId `json:"id"`
	Date    time.Time         `json:"date"`
	Content any               `json:"content"`
}

type EventsLogRecordId string

type EventsLogService interface {
	io.Closer
	// PostEvent posts event to the events log
	// actorId – id of entity of event origin. E.g. for 'incoming' event - id of site, for 'processed' event - id of destination
	PostEvent(event *ActorEvent) (id EventsLogRecordId, err error)

	PostAsync(event *ActorEvent)

	GetEvents(eventType EventType, actorId string, level string, filter *EventsLogFilter, limit int) ([]EventsLogRecord, error)
}

type Level string

type MultiEventsLogService struct {
	Services []EventsLogService
}

type RedisEventsLog struct {
	sync.Mutex
	appbase.Service
	// contains filtered or unexported fields
}