ingestor

type BulkCreateEventOpts struct {
	TenantId uuid.UUID `validate:"required"`
	Events   []*CreateEventOpts
}

type CreateEventOpts struct {
	ReplayedEvent         *uuid.UUID `validate:"omitempty"`
	Priority              *int32     `validate:"omitempty,min=1,max=3"`
	Scope                 *string    `validate:"omitempty"`
	TriggeringWebhookName *string    `validate:"omitempty"`
	TenantId              uuid.UUID  `validate:"required"`
	Key                   string     `validate:"required"`
	Data                  []byte
	AdditionalMetadata    []byte
}

type EventResult struct {
	TenantId           uuid.UUID
	EventId            string
	EventKey           string
	Data               string
	AdditionalMetadata string
}

type Ingestor interface {
	contracts.EventsServiceServer
	IngestEvent(ctx context.Context, tenant *sqlcv1.Tenant, eventName string, data []byte, metadata []byte, priority *int32, scope, triggeringWebhookName *string) (*sqlcv1.Event, error)
	IngestWebhookValidationFailure(ctx context.Context, tenant *sqlcv1.Tenant, webhookName, errorText string) error
	BulkIngestEvent(ctx context.Context, tenant *sqlcv1.Tenant, eventOpts []*CreateEventOpts) ([]*sqlcv1.Event, error)
	IngestReplayedEvent(ctx context.Context, tenant *sqlcv1.Tenant, replayedEvent *sqlcv1.Event) (*sqlcv1.Event, error)
	IngestCELEvaluationFailure(ctx context.Context, tenantId uuid.UUID, errorText string, source sqlcv1.V1CelEvaluationFailureSource) error
	Cleanup() error
}

type IngestorImpl struct {
	contracts.UnimplementedEventsServiceServer
	// contains filtered or unexported fields
}

type IngestorOptFunc func(*IngestorOpts)

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