INNER CODE UNIT · Go

NewCloudProtocol

unitedrhino/things · sdk/protocol/cloudProtocol.go:53

func NewCloudProtocol[pConf ConfImp](c conf.EventConf, pi *dm.ProtocolInfo, pc *CloudProtocolConf[pConf]) (*CloudProtocol[pConf], error) {
	lp, err := NewCoreProtocol(c, pi, &CoreProtocolConf{
		ServerName: pc.ServerName,
		DmClient:   pc.DmClient,
		TimedM:     pc.TimedM,
		NodeID:     pc.NodeID,
	})
	if err != nil {
		return nil, err
	}
	return &CloudProtocol[pConf]{
		CoreProtocol: lp,
		ConfMap:      map[string]ConfInfo[pConf]{},
	}, nil
}

func (p *CloudProtocol[pConf]) Start() error {
	ctx := context.Background()

View source record →