push

type HandlerError struct {
	Operation            ProcessorOperation
	PushNotificationName string
	Reason               string
	Err                  error
}

type NotificationHandler interface {
	// HandlePushNotification processes a push notification with context information.
	// The handlerCtx provides information about the client, connection pool, and connection
	// on which the notification was received, allowing handlers to make informed decisions.
	// Returns an error if the notification could not be handled.
	HandlePushNotification(ctx context.Context, handlerCtx NotificationHandlerContext, notification []interface{}) error
}

type NotificationHandlerContext struct {
	// Client is the Redis client instance that received the notification.
	// It is interface to both allow for future expansion and to avoid
	// circular dependencies. The developer is responsible for type assertion.
	// It can be one of the following types:
	// - *redis.baseClient
	// - *redis.Client
	// - *redis.ClusterClient
	// - *redis.Conn
	Client interface{}

	// ConnPool is the connection pool from which the connection was obtained.
	// It is interface to both allow for future expansion and to avoid
	// circular dependencies. The developer is responsible for type assertion.
	// It can be one of the following types:
	// - *pool.ConnPool
	// - *pool.SingleConnPool
	// - *pool.StickyConnPool
	ConnPool interface{}

	// PubSub is the PubSub instance that received the notification.
	// It is interface to both allow for future expansion and to avoid
	// circular dependencies. The developer is responsible for type assertion.
	// It can be one of the following types:
	// - *redis.PubSub
	PubSub interface{}

	// Conn is the specific connection on which the notification was received.
	// It is interface to both allow for future expansion and to avoid
	// circular dependencies. The developer is responsible for type assertion.
	// It can be one of the following types:
	// - *pool.Conn
	Conn interface{}

	// IsBlocking indicates if the notification was received on a blocking connection.
	IsBlocking bool
}

type NotificationProcessor interface {
	// GetHandler returns the handler for a specific push notification name.
	GetHandler(pushNotificationName string) NotificationHandler
	// ProcessPendingNotifications checks for and processes any pending push notifications.
	// To be used when it is known that there are notifications on the socket.
	// It will try to read from the socket and if it is empty - it may block.
	ProcessPendingNotifications(ctx context.Context, handlerCtx NotificationHandlerContext, rd *proto.Reader) error
	// RegisterHandler registers a handler for a specific push notification name.
	RegisterHandler(pushNotificationName string, handler NotificationHandler, protected bool) error
	// UnregisterHandler removes a handler for a specific push notification name.
	UnregisterHandler(pushNotificationName string) error
}

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

type ProcessorError struct {
	ProcessorType        ProcessorType      // "processor", "void_processor"
	Operation            ProcessorOperation // "process", "register", "unregister"
	PushNotificationName string             // Name of the push notification involved
	Reason               string
	Err                  error
}

type ProcessorOperation string

type ProcessorType string

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

type VoidProcessor struct{}