broker

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

type Publisher interface {
	// Publish publishes a CloudEvent to the specified topic with context
	Publish(ctx context.Context, topic string, event *event.Event) 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
}