mq_util

Dec 2, 2024

Changes in this version

+ const CHANNEL_PREFIX

+ const CLIENT_CMD_ADD

+ const CLIENT_CMD_DEL

+ func GetPopPubSubChannel(popId string) string

+ type CLIENT_OP_CMD string

+ type ClientCacheInfo struct

+ ClientId string

+ IP string

+ PSK string

+ PublicKey string

+ Type uint8

+ func GetClientDelCmd(b64 string) (fullCmd string, clientCacheInfo *ClientCacheInfo, err error)

+ func ParseClientB64(b64 string) (decoded string, clientCacheInfo *ClientCacheInfo, err error)

+ func ParseClientCmd(fullCmd string) (string, *ClientCacheInfo)

+ func (c *ClientCacheInfo) GetClientAddCmd() (fullCmd, b64 string)

+ func (c *ClientCacheInfo) GetClientB64() (raw, b64 string)

+ func (c *ClientCacheInfo) GetClientWgPeer(toRemove bool) (peerConfig *wg_core.WgPeer, err error)

+ type MqPubSub struct

+ func NewMqPubSub(cache cache.Cache) *MqPubSub

+ func (c *MqPubSub) PublishCmd(popId, fullCmd string) error

+ type PopCacheInfo struct

+ LastActive time.Time