mq_util

package
v0.0.12 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 5, 2024 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source
const (
	CHANNEL_PREFIX string = "sdp-wg-channel"
)

Variables

This section is empty.

Functions

func GetClientDelCmd

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

func GetPopPubSubChannel

func GetPopPubSubChannel(popId string) string

func ParseClientB64

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

func ParseClientCmd

func ParseClientCmd(fullCmd string) (string, *control_dto.ClientCacheInfo)

Types

type MqPubSub

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

func NewMqPubSub

func NewMqPubSub(cache cache.Cache) *MqPubSub

func (*MqPubSub) PublishCmd

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

type PopCacheInfo

type PopCacheInfo struct {
	LastActive time.Time // check status

}

pop info can get from db

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL