modelRT/constants/subscription_business_code.go

// Package constants define constant variable
package constants

const (
	// SubStartAction define the real time subscription start action
	SubStartAction string = "start"
	// SubStopAction define the real time subscription stop action
	SubStopAction string = "stop"
	// SubAppendAction define the real time subscription append action
	SubAppendAction string = "append"
	// SubUpdateAction define the real time subscription update action
	SubUpdateAction string = "update"
)

// 定义状态常量
// TODO 从4位格式修改为5位格式
const (
	// SubSuccessCode define subscription success code
	SubSuccessCode = "1001"
	// SubFailedCode define subscription failed code
	SubFailedCode = "1002"
	// RTDSuccessCode define real time data return success code
	RTDSuccessCode = "1003"
	// RTDFailedCode define real time data return failed code
	RTDFailedCode = "1004"
	// CancelSubSuccessCode define cancel subscription success code
	CancelSubSuccessCode = "1005"
	// CancelSubFailedCode define cancel subscription failed code
	CancelSubFailedCode = "1006"
	// SubRepeatCode define subscription repeat code
	SubRepeatCode = "1007"
	// UpdateSubSuccessCode define update subscription success code
	UpdateSubSuccessCode = "1008"
	// UpdateSubFailedCode define update subscription failed code
	UpdateSubFailedCode = "1009"
)

const (
	// SysCtrlPrefix define to indicates the prefix for all system control directives,facilitating unified parsing within the sendDataStream goroutine
	SysCtrlPrefix = "SYS_CTRL_"

	// SysCtrlAllRemoved define to indicates that all active polling targets have been removed for the current client, and no further data streams are active
	SysCtrlAllRemoved = "SYS_CTRL_ALL_REMOVED"

	// SysCtrlSessionExpired define to indicates reserved for indicating that the current websocket session has timed out or is no longer valid
	SysCtrlSessionExpired = "SYS_CTRL_SESSION_EXPIRED"
)

const (
	// SubSuccessMsg define subscription success message
	SubSuccessMsg = "subscription success"
	// SubFailedMsg define subscription failed message
	SubFailedMsg = "subscription failed"
	// RTDSuccessMsg define real time data return success message
	RTDSuccessMsg = "real time data return success"
	// RTDFailedMsg define real time data return failed message
	RTDFailedMsg = "real time data return failed"
	// CancelSubSuccessMsg define cancel subscription success message
	CancelSubSuccessMsg = "cancel subscription success"
	// CancelSubFailedMsg define cancel subscription failed message
	CancelSubFailedMsg = "cancel subscription failed"
	// SubRepeatMsg define subscription repeat message
	SubRepeatMsg = "subscription repeat in target interval"
	// UpdateSubSuccessMsg define update subscription success message
	UpdateSubSuccessMsg = "update subscription success"
	// UpdateSubFailedMsg define update subscription failed message
	UpdateSubFailedMsg = "update subscription failed"
)

// TargetOperationType define constant to the target operation type
type TargetOperationType int

const (
	// OpAppend define append new target to the subscription list
	OpAppend TargetOperationType = iota
	// OpRemove define remove exist target from the subscription list
	OpRemove
	// OpUpdate define update exist target from the subscription list
	OpUpdate
)

const (
	// NoticeChanCap define real time data notice channel capacity
	NoticeChanCap = 10000
)