notifs

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(mutexKey string) (LBSInfo, error)

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

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 NotificationBroker ¶ added in v0.3.2

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

func NewNotificationBroker(output chan<- RecoverableRedisNotification, bufferSize int) *NotificationBroker

func (b *NotificationBroker) Close()

func (b *NotificationBroker) Send(ctx context.Context, m RecoverableRedisNotification) bool

type NotificationType ¶

type NotificationType int

Types of notifications sent to client.

const (
	StreamAdded NotificationType = iota
	StreamDisowned
	StreamExpired
	StreamTerminated
)

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(notifType NotificationType, lbsInfo LBSInfo, additionalInfo map[string]any) RecoverableRedisNotification

func MakeStreamTerminatedNotif(info string) RecoverableRedisNotification