koko

Documentation

Index

• func GetStatusData() interface{}
• func KeepWsHeartbeat(jmsService *service.JMService)
• func MustJMService() *service.JMService
• func MustLoadValidAccessKey() model.AccessKey
• func MustRegisterTerminalAccount() (key model.AccessKey)
• func MustValidKey(key model.AccessKey) model.AccessKey
• func RunConnectTokensCheck(jmsService *service.JMService)
• func RunForever(confPath string)
• func ValidateRemainReplayFile(path string) error
• type Koko
  • func (k *Koko) Start()
  • func (k *Koko) Stop()
• type RemainFTPFile
• type RemainReplay

Functions

func GetStatusData

func GetStatusData() interface{}

func KeepWsHeartbeat

func KeepWsHeartbeat(jmsService *service.JMService)

func MustJMService

func MustJMService() *service.JMService

func MustLoadValidAccessKey

func MustLoadValidAccessKey() model.AccessKey

func MustRegisterTerminalAccount

func MustRegisterTerminalAccount() (key model.AccessKey)

func MustValidKey

func MustValidKey(key model.AccessKey) model.AccessKey

func RunConnectTokensCheck

func RunConnectTokensCheck(jmsService *service.JMService)

RunConnectTokensCheck every 5 minutes check token status

func RunForever

func RunForever(confPath string)

func ValidateRemainReplayFile

func ValidateRemainReplayFile(path string) error

Types

type Koko

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

func (*Koko) Start

func (k *Koko) Start()

func (*Koko) Stop

func (k *Koko) Stop()

type RemainFTPFile

type RemainFTPFile struct {
	Id string // FTP log id
}

type RemainReplay

type RemainReplay struct {
	Id      string // session id
	IsGzip  bool
	Version model.ReplayVersion
}