EdgeCommon/pkg/messageconfigs/messages.go

package messageconfigs

type MessageCode = string

const (
	MessageCodeConnectedAPINode    MessageCode = "connectedAPINode"    // 边缘节点连接API节点成功
	MessageCodeWriteCache          MessageCode = "writeCache"          // 写入缓存
	MessageCodeReadCache           MessageCode = "readCache"           // 读取缓存
	MessageCodeStatCache           MessageCode = "statCache"           // 统计缓存
	MessageCodePurgeCache          MessageCode = "purgeCache"          // 删除缓存
	MessageCodeCleanCache          MessageCode = "cleanCache"          // 清理缓存
	MessageCodePreheatCache        MessageCode = "preheatCache"        // 预热缓存
	MessageCodeCheckSystemdService MessageCode = "checkSystemdService" // 检查Systemd服务
	MessageCodeNewNodeTask         MessageCode = "NewNodeTask"         // 有新的节点任务产生
)

// 连接API节点成功
type ConnectedAPINodeMessage struct {
	APINodeId int64 `json:"apiNodeId"`
}

// 写入缓存
type WriteCacheMessage struct {
	CachePolicyJSON []byte `json:"cachePolicyJSON"`
	Key             string `json:"key"`
	Value           []byte `json:"value"`
	LifeSeconds     int64  `json:"lifeSeconds"`
}

// 读取缓存
type ReadCacheMessage struct {
	CachePolicyJSON []byte `json:"cachePolicyJSON"`
	Key             string `json:"key"`
}

// 统计缓存
type StatCacheMessage struct {
	CachePolicyJSON []byte `json:"cachePolicyJSON"`
}

// 清除缓存

type CleanCacheMessage struct {
	CachePolicyJSON []byte `json:"cachePolicyJSON"`
}

// 删除缓存
type PurgeCacheMessageType = string

const (
	PurgeCacheMessageTypeFile PurgeCacheMessageType = "file"
	PurgeCacheMessageTypeDir  PurgeCacheMessageType = "dir"
)

type PurgeCacheMessage struct {
	CachePolicyJSON []byte                `json:"cachePolicyJSON"`
	Keys            []string              `json:"keys"`
	Type            PurgeCacheMessageType `json:"type"` // 清理类型
}

// 预热缓存
type PreheatCacheMessage struct {
	CachePolicyJSON []byte   `json:"cachePolicyJSON"`
	Keys            []string `json:"keys"`
}

// Systemd服务
type CheckSystemdServiceMessage struct {
}

// 有新的节点任务
type NewNodeTaskMessage struct {
}