mq_util

Documentation

Index

• Constants
• func GetClientDelCmd(b64 string) (fullCmd string, clientCacheInfo *control_dto.ClientCacheInfo, err error)
• func GetPopPubSubChannel(popId string) string
• func ParseClientB64(b64 string) (decoded string, clientCacheInfo *control_dto.ClientCacheInfo, err error)
• func ParseClientCmd(fullCmd string) (string, *control_dto.ClientCacheInfo)
• type MqPubSub
  • func NewMqPubSub(cache cache.Cache) *MqPubSub
  • func (c *MqPubSub) PublishCmd(popId, fullCmd string) error
• type PopCacheInfo

Constants

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

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