channelAPI

package
v1.0.0 Latest Latest
Warning

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

Go to latest
Published: Oct 13, 2024 License: GPL-3.0 Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ChannelClientAPI

type ChannelClientAPI struct {
	Execute       IChannelServerExecute       // 执行主从半双工操作:上位机向设备问询,并等待设备的回答,直到设备响应或者超时
	Publish       IChannelServerPublish       // 执行发布操作:上位机向设备单向发送报文,不需要等待设备的返
	Report        IChannelServerReport        // 设备的主动上报消息:设备向上位机
	OpenChannel   IChannelServerOpenChannel   // 打开通道
	CloseChannel  IChannelServerCloseChannel  // 关闭通道
	ManageChannel IChannelServerManageChannel // 对通道进行管理操作
}
var (
	ChannelService *ChannelClientAPI
)

type IChannelServerCloseChannel

type IChannelServerCloseChannel interface {
	CloseChannel(channelName string, channelParam map[string]interface{}) error
}

type IChannelServerExecute

type IChannelServerExecute interface {
	Execute(requestVO *commRedisRpc.ChannelRequestVO) (*commRedisRpc.ChannelRespondVO, error)
}

type IChannelServerManageChannel

type IChannelServerManageChannel interface {
	ManageChannel(requestVO *commRedisRpc.ChannelRequestVO) (*commRedisRpc.ChannelRespondVO, error)
}

type IChannelServerOpenChannel

type IChannelServerOpenChannel interface {
	OpenChannel(channelName string, channelParam map[string]interface{}) error
}

type IChannelServerPublish

type IChannelServerPublish interface {
	Publish(requestVO *commRedisRpc.ChannelRequestVO) error
}

type IChannelServerReport

type IChannelServerReport interface {
	Report() ([]*commRedisRpc.ChannelRespondVO, error)
}

Jump to

Keyboard shortcuts

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