notifs

package

v0.1.6 Latest Latest Go to latest Published: Sep 10, 2025 License: LGPL-2.1, LGPL-2.1-or-later Imports: 0 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

This section is empty.

type LBSMessage struct {
	DataStreamName string
	Info           map[string]interface{}
}

LBSMessage is the format in which the message should be written to LBS

type NotificationType int

Types of notifications sent to client.

const (
	StreamAdded NotificationType = iota
	StreamDisowned
	StreamExpired
)

type RecoverableRedisNotification[T any] struct {
	Type    NotificationType
	Payload T
}

RecoverableRedisNotification captures the type of notifications sent to client. These are captured by NotificationType enum.

func Make(value any, notifType NotificationType) RecoverableRedisNotification[any]