notifs

package

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

Documentation ¶

Index ¶

type LBSInfo
- func CreateByKspNotification(mutexKey string) (LBSInfo, error)
- func CreateByParts(dataStreamName string, idInLBS string) (LBSInfo, error)
- func (l *LBSInfo) FormMutexKey() string
type LBSInputMessage
type NotificationType
type RecoverableRedisNotification
- func Make(notifType NotificationType, lbsInfo LBSInfo, additionalInfo map[string]any) RecoverableRedisNotification

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type LBSInfo ¶ added in v0.2.0

type LBSInfo struct {
	DataStreamName string
	IDInLBS        string
}

LBSInfo contains information about a data stream in LBS. It's an internal data structure.

func CreateByKspNotification ¶ added in v0.2.0

func CreateByKspNotification(mutexKey string) (LBSInfo, error)

func CreateByParts ¶ added in v0.2.0

func CreateByParts(dataStreamName string, idInLBS string) (LBSInfo, error)

func (*LBSInfo) FormMutexKey ¶ added in v0.2.0

func (l *LBSInfo) FormMutexKey() string

type LBSInputMessage ¶ added in v0.2.0

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

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

type NotificationType ¶

type NotificationType int

Types of notifications sent to client.

const (
	StreamAdded NotificationType = iota
	StreamDisowned
	StreamExpired
)

type RecoverableRedisNotification ¶

type RecoverableRedisNotification struct {
	Type    NotificationType
	Payload LBSInfo
	// AdditionalInfo is an echo from any additional data seeded in LBSInputMessage
	AdditionalInfo map[string]any
}

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

func Make ¶

func Make(notifType NotificationType, lbsInfo LBSInfo, additionalInfo map[string]any) RecoverableRedisNotification

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL