ingest

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

type EventCatalog interface {
	ByTopic(ctx context.Context, topic string) ([]*models.EventDefinition, error)
}

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

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

type KafkaMessage struct {
	Topic     string
	Partition int
	Offset    int64
	Key       []byte
	Value     []byte
	Headers   map[string]string
	Timestamp time.Time
}

type KafkaReader interface {
	FetchMessage(ctx context.Context) (kafka.Message, error)
	CommitMessages(ctx context.Context, messages ...kafka.Message) error
	Close() error
}

type KafkaTopics interface {
	KafkaTopics(ctx context.Context) ([]string, error)
}

type KafkaTriggers interface {
	KafkaTriggers(ctx context.Context, topic string) ([]models.TriggerNodeMatch, error)
	EventTriggers(ctx context.Context, eventKey, tenantID string) ([]models.TriggerNodeMatch, error)
}

type Resumer interface {
	ResumeIf(ctx context.Context, executionID, nodeID string, data map[string]any, allowed func(models.NodeResult) bool) error
}

type SchemaRegistry struct {
	URL      string
	Username string
	Password string
}

type Starter interface {
	Start(ctx context.Context, execution *models.ExecutionContext, job models.Job) error
}

type Triggers interface {
	WebhookTriggers(ctx context.Context, tenantID, path string) ([]models.TriggerNodeMatch, error)
}

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