services

Documentation

Index

• Constants
• Variables
• func InitConfigFile()
• func UseConfigFile()
• func UseGateWayToken()
• func WriteConfigFile(ConfigMode *models.GatewayConfig, path string) (err error)
• type GatewayCtl
  • func (gm *GatewayCtl) AddServer(token string) (err error)
  • func (gm *GatewayCtl) DelServer(runid string) (err error)
  • func (gm *GatewayCtl) Loged() bool
• type ServerSession
  • func (ss *ServerSession) CheckSessionStatus()
  • func (ss *ServerSession) LoginServer() (err error)
  • func (ss *ServerSession) LoopStream()
  • func (ss *ServerSession) Task()

Constants

const ConfigFileName = "gateway-go.yaml"

const GRpcAddr = ""

const GrpcPort = 0

const IoTManagerAddr = "api.iot-manager.iothub.cloud:8881"

Variables

var ConfigFilePath = fmt.Sprintf("%s%s", "./", ConfigFileName)

var ConfigMode = &models.GatewayConfig{
	GatewayUUID: uuid.Must(uuid.NewV4()).String(),
	LogConfig: &models.LogConfig{
		EnableStdout: true,
		LogFilePath:  "",
	},
	LoginWithTokenMap: make(map[string]string),
}

var GatewayLoginToken = ""

var GatewayManager = &GatewayCtl{serverSession: make(map[string]*ServerSession)}

Functions

func InitConfigFile

func InitConfigFile()

func UseConfigFile

func UseConfigFile()

func UseGateWayToken

func UseGateWayToken()

func WriteConfigFile

func WriteConfigFile(ConfigMode *models.GatewayConfig, path string) (err error)

将配置写入指定的路径的文件

Types

type GatewayCtl

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

func (*GatewayCtl) AddServer

func (gm *GatewayCtl) AddServer(token string) (err error)

func (*GatewayCtl) DelServer

func (gm *GatewayCtl) DelServer(runid string) (err error)

func (*GatewayCtl) Loged

func (gm *GatewayCtl) Loged() bool

type ServerSession

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

func (*ServerSession) CheckSessionStatus

func (ss *ServerSession) CheckSessionStatus()

func (*ServerSession) LoginServer

func (ss *ServerSession) LoginServer() (err error)

func (*ServerSession) LoopStream

func (ss *ServerSession) LoopStream()

func (*ServerSession) Task

func (ss *ServerSession) Task()