broker

type HandlerFunc func(ctx context.Context, event *event.Event) error

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

type Publisher interface {
	// Publish publishes a CloudEvent to the specified topic with context
	Publish(ctx context.Context, topic string, event *event.Event) error
	// Health checks if the underlying broker connection is healthy.
	// Returns nil if healthy, or an error describing the failure.
	// The provided context controls the deadline/cancellation of the check.
	Health(ctx context.Context) error
	// Close closes the underlying publisher
	Close() error
}

type Subscriber interface {
	// Subscribe subscribes to a topic and processes messages with the provided handler
	Subscribe(ctx context.Context, topic string, handler HandlerFunc) error
	// Errors returns a channel that receives errors from background operations.
	// The channel is buffered to prevent blocking the subscriber.
	// The channel is closed when Close() is called.
	// Consumers SHOULD drain this channel to prevent memory leaks.
	Errors() <-chan *SubscriberError
	// Close closes the underlying subscriber
	Close() error
}

type SubscriberError struct {
	// Op is the operation that failed: "router", "connect", "receive"
	Op string

	// Topic where the error occurred
	Topic string

	// SubscriptionID of the subscriber
	SubscriptionID string

	// Err is the underlying error
	Err error

	// Timestamp is when the error occurred
	Timestamp time.Time

	// Fatal indicates if the subscriber has stopped and cannot continue operating.
	// If true, the subscriber needs to be recreated.
	Fatal bool
}