streams

Documentation

Index

• Constants
• Variables

Constants

const (
	StreamBroadcastEvent string = "BroadcastEvent"

	SubjectBroadcastEvent               = "BROADCAST_EVENT.Event"
	SubjectBroadcastMessage             = "BROADCAST_EVENT.BroadcastMessage.>"
	SubjectBroadcastMessageDynamic      = "BROADCAST_EVENT.BroadcastMessage.%d"
	SubjectBroadcastNotification        = "BROADCAST_EVENT.BroadcastNotification.>"
	SubjectBroadcastNotificationDynamic = "BROADCAST_EVENT.BroadcastNotification.%d"

	RetentionPolicyBroadcastEvent = nats.InterestPolicy

	DuplicateFilterWindowBroadcastEvent = 0
)

const (
	StreamChat string = "Chat"

	// we set the actual value for the subject to `>` so that we can dynamically create
	// new subjects using the chat id that we are subscribing to - the `>` means
	// all subjects within the stream `CHAT`
	SubjectChatMessages        = "CHAT.MESSAGES.>"
	SubjectChatMessagesDynamic = "CHAT.MESSAGES.%d"

	SubjectChatNewChat        = "CHAT.NEW_CHAT.>"
	SubjectChatNewChatDynamic = "CHAT.NEW_CHAT.%d"

	SubjectChatKick        = "CHAT.KICK.>"
	SubjectChatKickDynamic = "CHAT.KICK.%d"

	SubjectChatUpdated        = "CHAT.UPDATED.>"
	SubjectChatUpdatedDynamic = "CHAT.UPDATED.%d"

	RetentionPolicyChat = nats.InterestPolicy

	DuplicateFilterWindowChat = 0
)

const (
	StreamNemesis            = "Nemesis"
	SubjectNemesisStatChange = "NEMESIS.StatChange"

	RetentionPolicyNemesis = nats.WorkQueuePolicy

	DuplicateFilterWindowNemesis = time.Second * 10
)

const (
	StreamMisc string = "Misc"

	SubjectMiscSessionCleanKeys = "MISC.SessionCleanKeys"
	SubjectMiscUserFreePremium  = "MISC.UserFreePremium"

	RetentionPolicyMisc = nats.WorkQueuePolicy

	DuplicateFilterWindowMisc = 0
)

const (
	StreamStreakXP = "Streak"

	SubjectStreakAddXP      = "STREAK.AddXp"
	SubjectStreakExpiration = "STREAK.ExpirationRemoval"
	SubjectDayRollover      = "STREAK.DayRollover"
	SubjectPremiumFreeze    = "STREAK.PremiumFreeze"

	RetentionPolicyStreak = nats.WorkQueuePolicy

	DuplicateFilterWindowStreak = time.Second * 10
)

const (
	StreamTailscale string = "Tailscale"

	SubjectTailscaleAgent      = "TAILSCALE.Agent"
	SubjectTailscaleConnection = "TAILSCALE.Connection"

	RetentionPolicyTailscale = nats.InterestPolicy

	DuplicateFilterWindowTailscale = 0
)

const (
	StreamWorkspace string = "Workspace"

	SubjectWorkspaceCreate  = "WORKSPACE.Create"
	SubjectWorkspaceStart   = "WORKSPACE.Start"
	SubjectWorkspaceStop    = "WORKSPACE.Stop"
	SubjectWorkspaceDestroy = "WORKSPACE.Destroy"
	SubjectWorkspaceDelete  = "WORKSPACE.Delete"

	RetentionPolicyWorkspace = nats.WorkQueuePolicy

	DuplicateFilterWindowWorkspace = time.Second * 10
)

const (
	StreamWorkspaceStatus string = "WorkspaceStatus"

	// we set the actual value for the subject to `>` so that we can dynamically create
	// new subjects using the workspace id that we are subscribing to - the `>` means
	// all subjects within the stream `WORKSPACE_STATUS`
	SubjectWorkspaceStatusUpdate        = "WORKSPACE_STATUS.>"
	SubjectWorkspaceStatusUpdateDynamic = "WORKSPACE_STATUS.%d"

	RetentionPolicyWorkspaceStatus = nats.InterestPolicy

	DuplicateFilterWindowWorkspaceStatus = 0
)

const (
	StreamWsConnCache        = "WsConnCache"
	SubjectWsConnCacheForget = "WSCONNCACHE.Forget"

	RetentionPolicyWsConnCache = nats.InterestPolicy

	DuplicateFilterWindowWsConnCache = time.Second * 10
)

Variables

var StreamSubjectsBroadcastEvent = []string{
	SubjectBroadcastEvent,
	SubjectBroadcastMessage,
	SubjectBroadcastNotification,
}

var StreamSubjectsChat = []string{
	SubjectChatMessages,
	SubjectChatNewChat,
	SubjectChatKick,
	SubjectChatUpdated,
}

var StreamSubjectsMisc = []string{
	SubjectMiscSessionCleanKeys,
	SubjectMiscUserFreePremium,
}

var StreamSubjectsNemesis = []string{
	SubjectNemesisStatChange,
}

var StreamSubjectsStreak = []string{
	SubjectStreakAddXP,
	SubjectStreakExpiration,
	SubjectDayRollover,
	SubjectPremiumFreeze,
}

var StreamSubjectsTailscale = []string{
	SubjectTailscaleAgent,
	SubjectTailscaleConnection,
}

var StreamSubjectsWorkspace = []string{
	SubjectWorkspaceCreate,
	SubjectWorkspaceStart,
	SubjectWorkspaceStop,
	SubjectWorkspaceDestroy,
	SubjectWorkspaceDelete,
}

var StreamSubjectsWorkspaceStatus = []string{
	SubjectWorkspaceStatusUpdate,
}

var StreamSubjectsWsConnCache = []string{
	SubjectWsConnCacheForget,
}