v1beta1

package
v1.19.0 Latest Latest
Warning

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

 Go to latest Published: Nov 6, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DeviceManagerService_MapperRegister_FullMethodName     = "/v1beta1.DeviceManagerService/MapperRegister"
	DeviceManagerService_ReportDeviceStatus_FullMethodName = "/v1beta1.DeviceManagerService/ReportDeviceStatus"
)
View Source 
const (
	DeviceMapperService_RegisterDevice_FullMethodName    = "/v1beta1.DeviceMapperService/RegisterDevice"
	DeviceMapperService_RemoveDevice_FullMethodName      = "/v1beta1.DeviceMapperService/RemoveDevice"
	DeviceMapperService_UpdateDevice_FullMethodName      = "/v1beta1.DeviceMapperService/UpdateDevice"
	DeviceMapperService_CreateDeviceModel_FullMethodName = "/v1beta1.DeviceMapperService/CreateDeviceModel"
	DeviceMapperService_RemoveDeviceModel_FullMethodName = "/v1beta1.DeviceMapperService/RemoveDeviceModel"
	DeviceMapperService_UpdateDeviceModel_FullMethodName = "/v1beta1.DeviceMapperService/UpdateDeviceModel"
	DeviceMapperService_GetDevice_FullMethodName         = "/v1beta1.DeviceMapperService/GetDevice"
)

Variables

View Source 
var DeviceManagerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v1beta1.DeviceManagerService",
	HandlerType: (*DeviceManagerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "MapperRegister",
			Handler:    _DeviceManagerService_MapperRegister_Handler,
		},
		{
			MethodName: "ReportDeviceStatus",
			Handler:    _DeviceManagerService_ReportDeviceStatus_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api.proto",
}

DeviceManagerService_ServiceDesc is the grpc.ServiceDesc for DeviceManagerService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var DeviceMapperService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v1beta1.DeviceMapperService",
	HandlerType: (*DeviceMapperServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegisterDevice",
			Handler:    _DeviceMapperService_RegisterDevice_Handler,
		},
		{
			MethodName: "RemoveDevice",
			Handler:    _DeviceMapperService_RemoveDevice_Handler,
		},
		{
			MethodName: "UpdateDevice",
			Handler:    _DeviceMapperService_UpdateDevice_Handler,
		},
		{
			MethodName: "CreateDeviceModel",
			Handler:    _DeviceMapperService_CreateDeviceModel_Handler,
		},
		{
			MethodName: "RemoveDeviceModel",
			Handler:    _DeviceMapperService_RemoveDeviceModel_Handler,
		},
		{
			MethodName: "UpdateDeviceModel",
			Handler:    _DeviceMapperService_UpdateDeviceModel_Handler,
		},
		{
			MethodName: "GetDevice",
			Handler:    _DeviceMapperService_GetDevice_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api.proto",
}

DeviceMapperService_ServiceDesc is the grpc.ServiceDesc for DeviceMapperService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_api_proto protoreflect.FileDescriptor

Functions

func RegisterDeviceManagerServiceServer 

func RegisterDeviceManagerServiceServer(s grpc.ServiceRegistrar, srv DeviceManagerServiceServer)

func RegisterDeviceMapperServiceServer 

func RegisterDeviceMapperServiceServer(s grpc.ServiceRegistrar, srv DeviceMapperServiceServer)

Types

type CreateDeviceModelRequest 

type CreateDeviceModelRequest struct {
	Model *DeviceModel `protobuf:"bytes,1,opt,name=model,proto3" json:"model,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateDeviceModelRequest) Descriptor deprecated 

func (*CreateDeviceModelRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateDeviceModelRequest.ProtoReflect.Descriptor instead.

func (*CreateDeviceModelRequest) GetModel 

func (x *CreateDeviceModelRequest) GetModel() *DeviceModel

func (*CreateDeviceModelRequest) ProtoMessage 

func (*CreateDeviceModelRequest) ProtoMessage()

func (*CreateDeviceModelRequest) ProtoReflect 

func (x *CreateDeviceModelRequest) ProtoReflect() protoreflect.Message

func (*CreateDeviceModelRequest) Reset 

func (x *CreateDeviceModelRequest) Reset()

func (*CreateDeviceModelRequest) String 

func (x *CreateDeviceModelRequest) String() string

type CreateDeviceModelResponse 

type CreateDeviceModelResponse struct {
	DeviceModelName string `protobuf:"bytes,1,opt,name=deviceModelName,proto3" json:"deviceModelName,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateDeviceModelResponse) Descriptor deprecated 

func (*CreateDeviceModelResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateDeviceModelResponse.ProtoReflect.Descriptor instead.

func (*CreateDeviceModelResponse) GetDeviceModelName 

func (x *CreateDeviceModelResponse) GetDeviceModelName() string

func (*CreateDeviceModelResponse) ProtoMessage 

func (*CreateDeviceModelResponse) ProtoMessage()

func (*CreateDeviceModelResponse) ProtoReflect 

func (x *CreateDeviceModelResponse) ProtoReflect() protoreflect.Message

func (*CreateDeviceModelResponse) Reset 

func (x *CreateDeviceModelResponse) Reset()

func (*CreateDeviceModelResponse) String 

func (x *CreateDeviceModelResponse) String() string

type CustomizedValue 

type CustomizedValue struct {

	// data is the customized value and it can be any form.
	Data map[string]*anypb.Any `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

CustomizedValue is the customized value for developers.

func (*CustomizedValue) Descriptor deprecated 

func (*CustomizedValue) Descriptor() ([]byte, []int)

Deprecated: Use CustomizedValue.ProtoReflect.Descriptor instead.

func (*CustomizedValue) GetData 

func (x *CustomizedValue) GetData() map[string]*anypb.Any

func (*CustomizedValue) ProtoMessage 

func (*CustomizedValue) ProtoMessage()

func (*CustomizedValue) ProtoReflect 

func (x *CustomizedValue) ProtoReflect() protoreflect.Message

func (*CustomizedValue) Reset 

func (x *CustomizedValue) Reset()

func (*CustomizedValue) String 

func (x *CustomizedValue) String() string

type DBMethod 

type DBMethod struct {

	// the config of database .
	Influxdb2 *DBMethodInfluxdb2 `protobuf:"bytes,1,opt,name=influxdb2,proto3" json:"influxdb2,omitempty"`
	Redis     *DBMethodRedis     `protobuf:"bytes,2,opt,name=redis,proto3" json:"redis,omitempty"`
	Tdengine  *DBMethodTDEngine  `protobuf:"bytes,3,opt,name=tdengine,proto3" json:"tdengine,omitempty"`
	// contains filtered or unexported fields
}

func (*DBMethod) Descriptor deprecated 

func (*DBMethod) Descriptor() ([]byte, []int)

Deprecated: Use DBMethod.ProtoReflect.Descriptor instead.

func (*DBMethod) GetInfluxdb2 

func (x *DBMethod) GetInfluxdb2() *DBMethodInfluxdb2

func (*DBMethod) GetRedis 

func (x *DBMethod) GetRedis() *DBMethodRedis

func (*DBMethod) GetTdengine 

func (x *DBMethod) GetTdengine() *DBMethodTDEngine

func (*DBMethod) ProtoMessage 

func (*DBMethod) ProtoMessage()

func (*DBMethod) ProtoReflect 

func (x *DBMethod) ProtoReflect() protoreflect.Message

func (*DBMethod) Reset 

func (x *DBMethod) Reset()

func (*DBMethod) String 

func (x *DBMethod) String() string

type DBMethodInfluxdb2 

type DBMethodInfluxdb2 struct {

	// the config of influx database.
	Influxdb2ClientConfig *Influxdb2ClientConfig `protobuf:"bytes,1,opt,name=influxdb2ClientConfig,proto3" json:"influxdb2ClientConfig,omitempty"`
	Influxdb2DataConfig   *Influxdb2DataConfig   `protobuf:"bytes,2,opt,name=influxdb2DataConfig,proto3" json:"influxdb2DataConfig,omitempty"`
	// contains filtered or unexported fields
}

func (*DBMethodInfluxdb2) Descriptor deprecated 

func (*DBMethodInfluxdb2) Descriptor() ([]byte, []int)

Deprecated: Use DBMethodInfluxdb2.ProtoReflect.Descriptor instead.

func (*DBMethodInfluxdb2) GetInfluxdb2ClientConfig 

func (x *DBMethodInfluxdb2) GetInfluxdb2ClientConfig() *Influxdb2ClientConfig

func (*DBMethodInfluxdb2) GetInfluxdb2DataConfig 

func (x *DBMethodInfluxdb2) GetInfluxdb2DataConfig() *Influxdb2DataConfig

func (*DBMethodInfluxdb2) ProtoMessage 

func (*DBMethodInfluxdb2) ProtoMessage()

func (*DBMethodInfluxdb2) ProtoReflect 

func (x *DBMethodInfluxdb2) ProtoReflect() protoreflect.Message

func (*DBMethodInfluxdb2) Reset 

func (x *DBMethodInfluxdb2) Reset()

func (*DBMethodInfluxdb2) String 

func (x *DBMethodInfluxdb2) String() string

type DBMethodRedis 

type DBMethodRedis struct {

	// data config when push data to redis
	RedisClientConfig *RedisClientConfig `protobuf:"bytes,1,opt,name=redisClientConfig,proto3" json:"redisClientConfig,omitempty"`
	// contains filtered or unexported fields
}

func (*DBMethodRedis) Descriptor deprecated 

func (*DBMethodRedis) Descriptor() ([]byte, []int)

Deprecated: Use DBMethodRedis.ProtoReflect.Descriptor instead.

func (*DBMethodRedis) GetRedisClientConfig 

func (x *DBMethodRedis) GetRedisClientConfig() *RedisClientConfig

func (*DBMethodRedis) ProtoMessage 

func (*DBMethodRedis) ProtoMessage()

func (*DBMethodRedis) ProtoReflect 

func (x *DBMethodRedis) ProtoReflect() protoreflect.Message

func (*DBMethodRedis) Reset 

func (x *DBMethodRedis) Reset()

func (*DBMethodRedis) String 

func (x *DBMethodRedis) String() string

type DBMethodTDEngine 

type DBMethodTDEngine struct {

	// data config when push data to tdengine
	TdEngineClientConfig *TDEngineClientConfig `protobuf:"bytes,1,opt,name=tdEngineClientConfig,proto3" json:"tdEngineClientConfig,omitempty"`
	// contains filtered or unexported fields
}

func (*DBMethodTDEngine) Descriptor deprecated 

func (*DBMethodTDEngine) Descriptor() ([]byte, []int)

Deprecated: Use DBMethodTDEngine.ProtoReflect.Descriptor instead.

func (*DBMethodTDEngine) GetTdEngineClientConfig 

func (x *DBMethodTDEngine) GetTdEngineClientConfig() *TDEngineClientConfig

func (*DBMethodTDEngine) ProtoMessage 

func (*DBMethodTDEngine) ProtoMessage()

func (*DBMethodTDEngine) ProtoReflect 

func (x *DBMethodTDEngine) ProtoReflect() protoreflect.Message

func (*DBMethodTDEngine) Reset 

func (x *DBMethodTDEngine) Reset()

func (*DBMethodTDEngine) String 

func (x *DBMethodTDEngine) String() string

type Device 

type Device struct {

	// Name of the device.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Specification of the device.
	Spec *DeviceSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// Status of the device.
	Status *DeviceStatus `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

Device is the description of a device instance.

func (*Device) Descriptor deprecated 

func (*Device) Descriptor() ([]byte, []int)

Deprecated: Use Device.ProtoReflect.Descriptor instead.

func (*Device) GetName 

func (x *Device) GetName() string

func (*Device) GetSpec 

func (x *Device) GetSpec() *DeviceSpec

func (*Device) GetStatus 

func (x *Device) GetStatus() *DeviceStatus

func (*Device) ProtoMessage 

func (*Device) ProtoMessage()

func (*Device) ProtoReflect 

func (x *Device) ProtoReflect() protoreflect.Message

func (*Device) Reset 

func (x *Device) Reset()

func (*Device) String 

func (x *Device) String() string

type DeviceCommand 

type DeviceCommand struct {

	// Name of the command.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Url of the command to access.
	Url string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	// Method of the command.
	Method string `protobuf:"bytes,3,opt,name=method,proto3" json:"method,omitempty"`
	// Status code list which the command can return.
	StatusCode []string `protobuf:"bytes,4,rep,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	// Parameter list which the command carries.
	Parameters []string `protobuf:"bytes,5,rep,name=parameters,proto3" json:"parameters,omitempty"`
	// Response examples of the command.
	Response []byte `protobuf:"bytes,6,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

DeviceCommond is the description of a command which the device supports.

func (*DeviceCommand) Descriptor deprecated 

func (*DeviceCommand) Descriptor() ([]byte, []int)

Deprecated: Use DeviceCommand.ProtoReflect.Descriptor instead.

func (*DeviceCommand) GetMethod 

func (x *DeviceCommand) GetMethod() string

func (*DeviceCommand) GetName 

func (x *DeviceCommand) GetName() string

func (*DeviceCommand) GetParameters 

func (x *DeviceCommand) GetParameters() []string

func (*DeviceCommand) GetResponse 

func (x *DeviceCommand) GetResponse() []byte

func (*DeviceCommand) GetStatusCode 

func (x *DeviceCommand) GetStatusCode() []string

func (*DeviceCommand) GetUrl 

func (x *DeviceCommand) GetUrl() string

func (*DeviceCommand) ProtoMessage 

func (*DeviceCommand) ProtoMessage()

func (*DeviceCommand) ProtoReflect 

func (x *DeviceCommand) ProtoReflect() protoreflect.Message

func (*DeviceCommand) Reset 

func (x *DeviceCommand) Reset()

func (*DeviceCommand) String 

func (x *DeviceCommand) String() string

type DeviceManagerServiceClient 

type DeviceManagerServiceClient interface {
	// MapperRegister registers the information of the mapper to device manager
	// when the mapper is online. Device manager returns the list of devices and device models which
	// this mapper should manage.
	MapperRegister(ctx context.Context, in *MapperRegisterRequest, opts ...grpc.CallOption) (*MapperRegisterResponse, error)
	// ReportDeviceStatus reports the status of devices to device manager.
	// When the mapper collects some properties of a device, it can make them a map of device twins
	// and report it to the device manager through the interface of ReportDeviceStatus.
	ReportDeviceStatus(ctx context.Context, in *ReportDeviceStatusRequest, opts ...grpc.CallOption) (*ReportDeviceStatusResponse, error)
}

DeviceManagerServiceClient is the client API for DeviceManagerService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDeviceManageClient 

func NewDeviceManageClient(cc grpc.ClientConnInterface) DeviceManagerServiceClient

func NewDeviceManagerServiceClient 

func NewDeviceManagerServiceClient(cc grpc.ClientConnInterface) DeviceManagerServiceClient

type DeviceManagerServiceServer 

type DeviceManagerServiceServer interface {
	// MapperRegister registers the information of the mapper to device manager
	// when the mapper is online. Device manager returns the list of devices and device models which
	// this mapper should manage.
	MapperRegister(context.Context, *MapperRegisterRequest) (*MapperRegisterResponse, error)
	// ReportDeviceStatus reports the status of devices to device manager.
	// When the mapper collects some properties of a device, it can make them a map of device twins
	// and report it to the device manager through the interface of ReportDeviceStatus.
	ReportDeviceStatus(context.Context, *ReportDeviceStatusRequest) (*ReportDeviceStatusResponse, error)
	// contains filtered or unexported methods
}

DeviceManagerServiceServer is the server API for DeviceManagerService service. All implementations must embed UnimplementedDeviceManagerServiceServer for forward compatibility

type DeviceMapperServiceClient 

type DeviceMapperServiceClient interface {
	// RegisterDevice registers a device to the device mapper.
	// Device manager registers a device instance with the information of device
	// to the mapper through the interface of RegisterDevice.
	// When the mapper gets the request of register with device information,
	// it should add the device to the device list and connect to the real physical device via the specific protocol.
	RegisterDevice(ctx context.Context, in *RegisterDeviceRequest, opts ...grpc.CallOption) (*RegisterDeviceResponse, error)
	// RemoveDevice unregisters a device to the device mapper.
	// Device manager unregisters a device instance with the name of device
	// to the mapper through the interface of RemoveDevice.
	// When the mapper gets the request of unregister with device name,
	// it should remove the device from the device list and disconnect to the real physical device.
	RemoveDevice(ctx context.Context, in *RemoveDeviceRequest, opts ...grpc.CallOption) (*RemoveDeviceResponse, error)
	// UpdateDevice updates a device to the device mapper
	// Device manager updates the information of a device used by the mapper
	// through the interface of UpdateDevice.
	// The information of a device includes the meta data and the status data of a device.
	// When the mapper gets the request of updating with the information of a device,
	// it should update the device of the device list and connect to the real physical device via the updated information.
	UpdateDevice(ctx context.Context, in *UpdateDeviceRequest, opts ...grpc.CallOption) (*UpdateDeviceResponse, error)
	// CreateDeviceModel creates a device model to the device mapper.
	// Device manager sends the information of device model to the mapper
	// through the interface of CreateDeviceModel.
	// When the mapper gets the request of creating with the information of device model,
	// it should create a new device model to the list of device models.
	CreateDeviceModel(ctx context.Context, in *CreateDeviceModelRequest, opts ...grpc.CallOption) (*CreateDeviceModelResponse, error)
	// RemoveDeviceModel remove a device model to the device mapper.
	// Device manager sends the name of device model to the mapper
	// through the interface of RemoveDeviceModel.
	// When the mapper gets the request of removing with the name of device model,
	// it should remove the device model to the list of device models.
	RemoveDeviceModel(ctx context.Context, in *RemoveDeviceModelRequest, opts ...grpc.CallOption) (*RemoveDeviceModelResponse, error)
	// UpdateDeviceModel update a device model to the device mapper.
	// Device manager sends the information of device model to the mapper
	// through the interface of UpdateDeviceModel.
	// When the mapper gets the request of updating with the information of device model,
	// it should update the device model to the list of device models.
	UpdateDeviceModel(ctx context.Context, in *UpdateDeviceModelRequest, opts ...grpc.CallOption) (*UpdateDeviceModelResponse, error)
	// GetDevice get the information of a device from the device mapper.
	// Device sends the request of querying device information with the device name to the mapper
	// through the interface of GetDevice.
	// When the mapper gets the request of querying with the device name,
	// it should return the device information.
	GetDevice(ctx context.Context, in *GetDeviceRequest, opts ...grpc.CallOption) (*GetDeviceResponse, error)
}

DeviceMapperServiceClient is the client API for DeviceMapperService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDeviceMapperServiceClient 

func NewDeviceMapperServiceClient(cc grpc.ClientConnInterface) DeviceMapperServiceClient

func NewMapperClient 

func NewMapperClient(cc grpc.ClientConnInterface) DeviceMapperServiceClient

type DeviceMapperServiceServer 

type DeviceMapperServiceServer interface {
	// RegisterDevice registers a device to the device mapper.
	// Device manager registers a device instance with the information of device
	// to the mapper through the interface of RegisterDevice.
	// When the mapper gets the request of register with device information,
	// it should add the device to the device list and connect to the real physical device via the specific protocol.
	RegisterDevice(context.Context, *RegisterDeviceRequest) (*RegisterDeviceResponse, error)
	// RemoveDevice unregisters a device to the device mapper.
	// Device manager unregisters a device instance with the name of device
	// to the mapper through the interface of RemoveDevice.
	// When the mapper gets the request of unregister with device name,
	// it should remove the device from the device list and disconnect to the real physical device.
	RemoveDevice(context.Context, *RemoveDeviceRequest) (*RemoveDeviceResponse, error)
	// UpdateDevice updates a device to the device mapper
	// Device manager updates the information of a device used by the mapper
	// through the interface of UpdateDevice.
	// The information of a device includes the meta data and the status data of a device.
	// When the mapper gets the request of updating with the information of a device,
	// it should update the device of the device list and connect to the real physical device via the updated information.
	UpdateDevice(context.Context, *UpdateDeviceRequest) (*UpdateDeviceResponse, error)
	// CreateDeviceModel creates a device model to the device mapper.
	// Device manager sends the information of device model to the mapper
	// through the interface of CreateDeviceModel.
	// When the mapper gets the request of creating with the information of device model,
	// it should create a new device model to the list of device models.
	CreateDeviceModel(context.Context, *CreateDeviceModelRequest) (*CreateDeviceModelResponse, error)
	// RemoveDeviceModel remove a device model to the device mapper.
	// Device manager sends the name of device model to the mapper
	// through the interface of RemoveDeviceModel.
	// When the mapper gets the request of removing with the name of device model,
	// it should remove the device model to the list of device models.
	RemoveDeviceModel(context.Context, *RemoveDeviceModelRequest) (*RemoveDeviceModelResponse, error)
	// UpdateDeviceModel update a device model to the device mapper.
	// Device manager sends the information of device model to the mapper
	// through the interface of UpdateDeviceModel.
	// When the mapper gets the request of updating with the information of device model,
	// it should update the device model to the list of device models.
	UpdateDeviceModel(context.Context, *UpdateDeviceModelRequest) (*UpdateDeviceModelResponse, error)
	// GetDevice get the information of a device from the device mapper.
	// Device sends the request of querying device information with the device name to the mapper
	// through the interface of GetDevice.
	// When the mapper gets the request of querying with the device name,
	// it should return the device information.
	GetDevice(context.Context, *GetDeviceRequest) (*GetDeviceResponse, error)
	// contains filtered or unexported methods
}

DeviceMapperServiceServer is the server API for DeviceMapperService service. All implementations must embed UnimplementedDeviceMapperServiceServer for forward compatibility

type DeviceModel 

type DeviceModel struct {

	// Name of a device model.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Specification of a device model.
	Spec *DeviceModelSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

DeviceModel specifies the information of a device model.

func (*DeviceModel) Descriptor deprecated 

func (*DeviceModel) Descriptor() ([]byte, []int)

Deprecated: Use DeviceModel.ProtoReflect.Descriptor instead.

func (*DeviceModel) GetName 

func (x *DeviceModel) GetName() string

func (*DeviceModel) GetSpec 

func (x *DeviceModel) GetSpec() *DeviceModelSpec

func (*DeviceModel) ProtoMessage 

func (*DeviceModel) ProtoMessage()

func (*DeviceModel) ProtoReflect 

func (x *DeviceModel) ProtoReflect() protoreflect.Message

func (*DeviceModel) Reset 

func (x *DeviceModel) Reset()

func (*DeviceModel) String 

func (x *DeviceModel) String() string

type DeviceModelSpec 

type DeviceModelSpec struct {

	// The properties provided by the device of this device model.
	Properties []*ModelProperty `protobuf:"bytes,1,rep,name=properties,proto3" json:"properties,omitempty"`
	// The commands executed by the device of this device model.
	Commands []*DeviceCommand `protobuf:"bytes,2,rep,name=commands,proto3" json:"commands,omitempty"`
	// contains filtered or unexported fields
}

DeviceModelSpec is the specification of a device model.

func (*DeviceModelSpec) Descriptor deprecated 

func (*DeviceModelSpec) Descriptor() ([]byte, []int)

Deprecated: Use DeviceModelSpec.ProtoReflect.Descriptor instead.

func (*DeviceModelSpec) GetCommands 

func (x *DeviceModelSpec) GetCommands() []*DeviceCommand

func (*DeviceModelSpec) GetProperties 

func (x *DeviceModelSpec) GetProperties() []*ModelProperty

func (*DeviceModelSpec) ProtoMessage 

func (*DeviceModelSpec) ProtoMessage()

func (*DeviceModelSpec) ProtoReflect 

func (x *DeviceModelSpec) ProtoReflect() protoreflect.Message

func (*DeviceModelSpec) Reset 

func (x *DeviceModelSpec) Reset()

func (*DeviceModelSpec) String 

func (x *DeviceModelSpec) String() string

type DeviceProperty 

type DeviceProperty struct {

	// The device property name to be accessed. It must be unique.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// the desired value of the property configured by device manager.
	Desired *TwinProperty `protobuf:"bytes,2,opt,name=desired,proto3" json:"desired,omitempty"`
	// Visitors are intended to be consumed by device mappers which connect to devices
	// and collect data / perform actions on the device.
	Visitors *VisitorConfig `protobuf:"bytes,3,opt,name=visitors,proto3" json:"visitors,omitempty"`
	// Define how frequent mapper will report the value.
	ReportCycle int64 `protobuf:"varint,4,opt,name=reportCycle,proto3" json:"reportCycle,omitempty"`
	// Define how frequent mapper will collect from device.
	CollectCycle int64 `protobuf:"varint,5,opt,name=collectCycle,proto3" json:"collectCycle,omitempty"`
	// whether be reported to the cloud
	ReportToCloud bool `protobuf:"varint,6,opt,name=reportToCloud,proto3" json:"reportToCloud,omitempty"`
	// PushMethod represents the protocol used to push data,
	PushMethod *PushMethod `protobuf:"bytes,7,opt,name=pushMethod,proto3" json:"pushMethod,omitempty"`
	// contains filtered or unexported fields
}

DeviceProperty describes the specifics all the properties of the device.

func (*DeviceProperty) Descriptor deprecated 

func (*DeviceProperty) Descriptor() ([]byte, []int)

Deprecated: Use DeviceProperty.ProtoReflect.Descriptor instead.

func (*DeviceProperty) GetCollectCycle 

func (x *DeviceProperty) GetCollectCycle() int64

func (*DeviceProperty) GetDesired 

func (x *DeviceProperty) GetDesired() *TwinProperty

func (*DeviceProperty) GetName 

func (x *DeviceProperty) GetName() string

func (*DeviceProperty) GetPushMethod 

func (x *DeviceProperty) GetPushMethod() *PushMethod

func (*DeviceProperty) GetReportCycle 

func (x *DeviceProperty) GetReportCycle() int64

func (*DeviceProperty) GetReportToCloud 

func (x *DeviceProperty) GetReportToCloud() bool

func (*DeviceProperty) GetVisitors 

func (x *DeviceProperty) GetVisitors() *VisitorConfig

func (*DeviceProperty) ProtoMessage 

func (*DeviceProperty) ProtoMessage()

func (*DeviceProperty) ProtoReflect 

func (x *DeviceProperty) ProtoReflect() protoreflect.Message

func (*DeviceProperty) Reset 

func (x *DeviceProperty) Reset()

func (*DeviceProperty) String 

func (x *DeviceProperty) String() string

type DeviceSpec 

type DeviceSpec struct {

	// The device model which the device references.
	DeviceModelReference string `protobuf:"bytes,1,opt,name=deviceModelReference,proto3" json:"deviceModelReference,omitempty"`
	// The specific config of the protocol to access to the device.
	Protocol *ProtocolConfig `protobuf:"bytes,2,opt,name=protocol,proto3" json:"protocol,omitempty"`
	// List of properties which describe the device properties.
	Properties []*DeviceProperty `protobuf:"bytes,3,rep,name=properties,proto3" json:"properties,omitempty"`
	// contains filtered or unexported fields
}

DeviceSpec is the specification of the device.

func (*DeviceSpec) Descriptor deprecated 

func (*DeviceSpec) Descriptor() ([]byte, []int)

Deprecated: Use DeviceSpec.ProtoReflect.Descriptor instead.

func (*DeviceSpec) GetDeviceModelReference 

func (x *DeviceSpec) GetDeviceModelReference() string

func (*DeviceSpec) GetProperties 

func (x *DeviceSpec) GetProperties() []*DeviceProperty

func (*DeviceSpec) GetProtocol 

func (x *DeviceSpec) GetProtocol() *ProtocolConfig

func (*DeviceSpec) ProtoMessage 

func (*DeviceSpec) ProtoMessage()

func (*DeviceSpec) ProtoReflect 

func (x *DeviceSpec) ProtoReflect() protoreflect.Message

func (*DeviceSpec) Reset 

func (x *DeviceSpec) Reset()

func (*DeviceSpec) String 

func (x *DeviceSpec) String() string

type DeviceStatus 

type DeviceStatus struct {

	// the device twins of the device.
	Twins []*Twin `protobuf:"bytes,1,rep,name=twins,proto3" json:"twins,omitempty"`
	// contains filtered or unexported fields
}

DeviceStatus is the status of the device.

func (*DeviceStatus) Descriptor deprecated 

func (*DeviceStatus) Descriptor() ([]byte, []int)

Deprecated: Use DeviceStatus.ProtoReflect.Descriptor instead.

func (*DeviceStatus) GetTwins 

func (x *DeviceStatus) GetTwins() []*Twin

func (*DeviceStatus) ProtoMessage 

func (*DeviceStatus) ProtoMessage()

func (*DeviceStatus) ProtoReflect 

func (x *DeviceStatus) ProtoReflect() protoreflect.Message

func (*DeviceStatus) Reset 

func (x *DeviceStatus) Reset()

func (*DeviceStatus) String 

func (x *DeviceStatus) String() string

type GetDeviceRequest 

type GetDeviceRequest struct {
	DeviceName string `protobuf:"bytes,1,opt,name=deviceName,proto3" json:"deviceName,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDeviceRequest) Descriptor deprecated 

func (*GetDeviceRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetDeviceRequest.ProtoReflect.Descriptor instead.

func (*GetDeviceRequest) GetDeviceName 

func (x *GetDeviceRequest) GetDeviceName() string

func (*GetDeviceRequest) ProtoMessage 

func (*GetDeviceRequest) ProtoMessage()

func (*GetDeviceRequest) ProtoReflect 

func (x *GetDeviceRequest) ProtoReflect() protoreflect.Message

func (*GetDeviceRequest) Reset 

func (x *GetDeviceRequest) Reset()

func (*GetDeviceRequest) String 

func (x *GetDeviceRequest) String() string

type GetDeviceResponse 

type GetDeviceResponse struct {
	Device *Device `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDeviceResponse) Descriptor deprecated 

func (*GetDeviceResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetDeviceResponse.ProtoReflect.Descriptor instead.

func (*GetDeviceResponse) GetDevice 

func (x *GetDeviceResponse) GetDevice() *Device

func (*GetDeviceResponse) ProtoMessage 

func (*GetDeviceResponse) ProtoMessage()

func (*GetDeviceResponse) ProtoReflect 

func (x *GetDeviceResponse) ProtoReflect() protoreflect.Message

func (*GetDeviceResponse) Reset 

func (x *GetDeviceResponse) Reset()

func (*GetDeviceResponse) String 

func (x *GetDeviceResponse) String() string

type Influxdb2ClientConfig 

type Influxdb2ClientConfig struct {

	// influx database url
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// usr org in influx database
	Org string `protobuf:"bytes,2,opt,name=org,proto3" json:"org,omitempty"`
	// usr bucket in influx database
	Bucket string `protobuf:"bytes,3,opt,name=bucket,proto3" json:"bucket,omitempty"`
	// contains filtered or unexported fields
}

func (*Influxdb2ClientConfig) Descriptor deprecated 

func (*Influxdb2ClientConfig) Descriptor() ([]byte, []int)

Deprecated: Use Influxdb2ClientConfig.ProtoReflect.Descriptor instead.

func (*Influxdb2ClientConfig) GetBucket 

func (x *Influxdb2ClientConfig) GetBucket() string

func (*Influxdb2ClientConfig) GetOrg 

func (x *Influxdb2ClientConfig) GetOrg() string

func (*Influxdb2ClientConfig) GetUrl 

func (x *Influxdb2ClientConfig) GetUrl() string

func (*Influxdb2ClientConfig) ProtoMessage 

func (*Influxdb2ClientConfig) ProtoMessage()

func (*Influxdb2ClientConfig) ProtoReflect 

func (x *Influxdb2ClientConfig) ProtoReflect() protoreflect.Message

func (*Influxdb2ClientConfig) Reset 

func (x *Influxdb2ClientConfig) Reset()

func (*Influxdb2ClientConfig) String 

func (x *Influxdb2ClientConfig) String() string

type Influxdb2DataConfig 

type Influxdb2DataConfig struct {

	// data config when push data to influx
	Measurement string            `protobuf:"bytes,1,opt,name=measurement,proto3" json:"measurement,omitempty"`
	Tag         map[string]string `` /* 147-byte string literal not displayed */
	FieldKey    string            `protobuf:"bytes,3,opt,name=fieldKey,proto3" json:"fieldKey,omitempty"`
	// contains filtered or unexported fields
}

func (*Influxdb2DataConfig) Descriptor deprecated 

func (*Influxdb2DataConfig) Descriptor() ([]byte, []int)

Deprecated: Use Influxdb2DataConfig.ProtoReflect.Descriptor instead.

func (*Influxdb2DataConfig) GetFieldKey 

func (x *Influxdb2DataConfig) GetFieldKey() string

func (*Influxdb2DataConfig) GetMeasurement 

func (x *Influxdb2DataConfig) GetMeasurement() string

func (*Influxdb2DataConfig) GetTag 

func (x *Influxdb2DataConfig) GetTag() map[string]string

func (*Influxdb2DataConfig) ProtoMessage 

func (*Influxdb2DataConfig) ProtoMessage()

func (*Influxdb2DataConfig) ProtoReflect 

func (x *Influxdb2DataConfig) ProtoReflect() protoreflect.Message

func (*Influxdb2DataConfig) Reset 

func (x *Influxdb2DataConfig) Reset()

func (*Influxdb2DataConfig) String 

func (x *Influxdb2DataConfig) String() string

type MapperInfo 

type MapperInfo struct {

	// name of the mapper.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// version of the mapper.
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// api version of the mapper.
	ApiVersion string `protobuf:"bytes,3,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"`
	// the protocol of the mapper.
	Protocol string `protobuf:"bytes,4,opt,name=protocol,proto3" json:"protocol,omitempty"`
	// the address of the mapper. it is a unix domain socket of grpc.
	Address []byte `protobuf:"bytes,5,opt,name=address,proto3" json:"address,omitempty"`
	// the state of the mapper.
	State string `protobuf:"bytes,6,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

MapperInfo is the information of mapper.

func (*MapperInfo) Descriptor deprecated 

func (*MapperInfo) Descriptor() ([]byte, []int)

Deprecated: Use MapperInfo.ProtoReflect.Descriptor instead.

func (*MapperInfo) GetAddress 

func (x *MapperInfo) GetAddress() []byte

func (*MapperInfo) GetApiVersion 

func (x *MapperInfo) GetApiVersion() string

func (*MapperInfo) GetName 

func (x *MapperInfo) GetName() string

func (*MapperInfo) GetProtocol 

func (x *MapperInfo) GetProtocol() string

func (*MapperInfo) GetState 

func (x *MapperInfo) GetState() string

func (*MapperInfo) GetVersion 

func (x *MapperInfo) GetVersion() string

func (*MapperInfo) ProtoMessage 

func (*MapperInfo) ProtoMessage()

func (*MapperInfo) ProtoReflect 

func (x *MapperInfo) ProtoReflect() protoreflect.Message

func (*MapperInfo) Reset 

func (x *MapperInfo) Reset()

func (*MapperInfo) String 

func (x *MapperInfo) String() string

type MapperRegisterRequest 

type MapperRegisterRequest struct {

	// The flag to show how device manager returns.
	// True means device manager should return the device list in the response.
	// False means device manager should just return nothing.
	WithData bool `protobuf:"varint,1,opt,name=withData,proto3" json:"withData,omitempty"`
	// Mapper information to be registered to the device manager.
	Mapper *MapperInfo `protobuf:"bytes,2,opt,name=mapper,proto3" json:"mapper,omitempty"`
	// contains filtered or unexported fields
}

func (*MapperRegisterRequest) Descriptor deprecated 

func (*MapperRegisterRequest) Descriptor() ([]byte, []int)

Deprecated: Use MapperRegisterRequest.ProtoReflect.Descriptor instead.

func (*MapperRegisterRequest) GetMapper 

func (x *MapperRegisterRequest) GetMapper() *MapperInfo

func (*MapperRegisterRequest) GetWithData 

func (x *MapperRegisterRequest) GetWithData() bool

func (*MapperRegisterRequest) ProtoMessage 

func (*MapperRegisterRequest) ProtoMessage()

func (*MapperRegisterRequest) ProtoReflect 

func (x *MapperRegisterRequest) ProtoReflect() protoreflect.Message

func (*MapperRegisterRequest) Reset 

func (x *MapperRegisterRequest) Reset()

func (*MapperRegisterRequest) String 

func (x *MapperRegisterRequest) String() string

type MapperRegisterResponse 

type MapperRegisterResponse struct {

	// List of device models which the mapper maintains.
	ModelList []*DeviceModel `protobuf:"bytes,1,rep,name=modelList,proto3" json:"modelList,omitempty"`
	// List of devices which the mapper maintains.
	DeviceList []*Device `protobuf:"bytes,2,rep,name=deviceList,proto3" json:"deviceList,omitempty"`
	// contains filtered or unexported fields
}

func (*MapperRegisterResponse) Descriptor deprecated 

func (*MapperRegisterResponse) Descriptor() ([]byte, []int)

Deprecated: Use MapperRegisterResponse.ProtoReflect.Descriptor instead.

func (*MapperRegisterResponse) GetDeviceList 

func (x *MapperRegisterResponse) GetDeviceList() []*Device

func (*MapperRegisterResponse) GetModelList 

func (x *MapperRegisterResponse) GetModelList() []*DeviceModel

func (*MapperRegisterResponse) ProtoMessage 

func (*MapperRegisterResponse) ProtoMessage()

func (*MapperRegisterResponse) ProtoReflect 

func (x *MapperRegisterResponse) ProtoReflect() protoreflect.Message

func (*MapperRegisterResponse) Reset 

func (x *MapperRegisterResponse) Reset()

func (*MapperRegisterResponse) String 

func (x *MapperRegisterResponse) String() string

type ModelProperty 

type ModelProperty struct {

	// The name of this property.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The description of this property.
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// The specific type of this property.
	Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	// The access mode of this property, ReadOnly or ReadWrite.
	AccessMode string `protobuf:"bytes,4,opt,name=accessMode,proto3" json:"accessMode,omitempty"`
	// The minimum value of this property.
	Minimum string `protobuf:"bytes,5,opt,name=minimum,proto3" json:"minimum,omitempty"`
	// The maximum value of this property.
	Maximum string `protobuf:"bytes,6,opt,name=maximum,proto3" json:"maximum,omitempty"`
	// The unit of this property.
	Unit string `protobuf:"bytes,7,opt,name=unit,proto3" json:"unit,omitempty"`
	// contains filtered or unexported fields
}

ModelProperty is the property of a device.

func (*ModelProperty) Descriptor deprecated 

func (*ModelProperty) Descriptor() ([]byte, []int)

Deprecated: Use ModelProperty.ProtoReflect.Descriptor instead.

func (*ModelProperty) GetAccessMode 

func (x *ModelProperty) GetAccessMode() string

func (*ModelProperty) GetDescription 

func (x *ModelProperty) GetDescription() string

func (*ModelProperty) GetMaximum 

func (x *ModelProperty) GetMaximum() string

func (*ModelProperty) GetMinimum 

func (x *ModelProperty) GetMinimum() string

func (*ModelProperty) GetName 

func (x *ModelProperty) GetName() string

func (*ModelProperty) GetType 

func (x *ModelProperty) GetType() string

func (*ModelProperty) GetUnit 

func (x *ModelProperty) GetUnit() string

func (*ModelProperty) ProtoMessage 

func (*ModelProperty) ProtoMessage()

func (*ModelProperty) ProtoReflect 

func (x *ModelProperty) ProtoReflect() protoreflect.Message

func (*ModelProperty) Reset 

func (x *ModelProperty) Reset()

func (*ModelProperty) String 

func (x *ModelProperty) String() string

type ProtocolConfig 

type ProtocolConfig struct {

	// the name of the customized protocol.
	ProtocolName string `protobuf:"bytes,1,opt,name=protocolName,proto3" json:"protocolName,omitempty"`
	// the config data of the customized protocol.
	ConfigData *CustomizedValue `protobuf:"bytes,2,opt,name=configData,proto3" json:"configData,omitempty"`
	// contains filtered or unexported fields
}

ProtocolConfig is the specific config of the protocol to access to the device.

func (*ProtocolConfig) Descriptor deprecated 

func (*ProtocolConfig) Descriptor() ([]byte, []int)

Deprecated: Use ProtocolConfig.ProtoReflect.Descriptor instead.

func (*ProtocolConfig) GetConfigData 

func (x *ProtocolConfig) GetConfigData() *CustomizedValue

func (*ProtocolConfig) GetProtocolName 

func (x *ProtocolConfig) GetProtocolName() string

func (*ProtocolConfig) ProtoMessage 

func (*ProtocolConfig) ProtoMessage()

func (*ProtocolConfig) ProtoReflect 

func (x *ProtocolConfig) ProtoReflect() protoreflect.Message

func (*ProtocolConfig) Reset 

func (x *ProtocolConfig) Reset()

func (*ProtocolConfig) String 

func (x *ProtocolConfig) String() string

type PushMethod 

type PushMethod struct {
	Http     *PushMethodHTTP `protobuf:"bytes,1,opt,name=http,proto3" json:"http,omitempty"`
	Mqtt     *PushMethodMQTT `protobuf:"bytes,2,opt,name=mqtt,proto3" json:"mqtt,omitempty"`
	DBMethod *DBMethod       `protobuf:"bytes,3,opt,name=dbMethod,proto3" json:"dbMethod,omitempty"`
	// contains filtered or unexported fields
}

func (*PushMethod) Descriptor deprecated 

func (*PushMethod) Descriptor() ([]byte, []int)

Deprecated: Use PushMethod.ProtoReflect.Descriptor instead.

func (*PushMethod) GetDBMethod 

func (x *PushMethod) GetDBMethod() *DBMethod

func (*PushMethod) GetHttp 

func (x *PushMethod) GetHttp() *PushMethodHTTP

func (*PushMethod) GetMqtt 

func (x *PushMethod) GetMqtt() *PushMethodMQTT

func (*PushMethod) ProtoMessage 

func (*PushMethod) ProtoMessage()

func (*PushMethod) ProtoReflect 

func (x *PushMethod) ProtoReflect() protoreflect.Message

func (*PushMethod) Reset 

func (x *PushMethod) Reset()

func (*PushMethod) String 

func (x *PushMethod) String() string

type PushMethodHTTP 

type PushMethodHTTP struct {
	Hostname    string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Port        int64  `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	Requestpath string `protobuf:"bytes,3,opt,name=requestpath,proto3" json:"requestpath,omitempty"`
	Timeout     int64  `protobuf:"varint,4,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*PushMethodHTTP) Descriptor deprecated 

func (*PushMethodHTTP) Descriptor() ([]byte, []int)

Deprecated: Use PushMethodHTTP.ProtoReflect.Descriptor instead.

func (*PushMethodHTTP) GetHostname 

func (x *PushMethodHTTP) GetHostname() string

func (*PushMethodHTTP) GetPort 

func (x *PushMethodHTTP) GetPort() int64

func (*PushMethodHTTP) GetRequestpath 

func (x *PushMethodHTTP) GetRequestpath() string

func (*PushMethodHTTP) GetTimeout 

func (x *PushMethodHTTP) GetTimeout() int64

func (*PushMethodHTTP) ProtoMessage 

func (*PushMethodHTTP) ProtoMessage()

func (*PushMethodHTTP) ProtoReflect 

func (x *PushMethodHTTP) ProtoReflect() protoreflect.Message

func (*PushMethodHTTP) Reset 

func (x *PushMethodHTTP) Reset()

func (*PushMethodHTTP) String 

func (x *PushMethodHTTP) String() string

type PushMethodMQTT 

type PushMethodMQTT struct {

	// broker address, like mqtt://127.0.0.1:1883
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// publish topic for mqtt
	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// qos of mqtt publish param
	Qos int32 `protobuf:"varint,3,opt,name=qos,proto3" json:"qos,omitempty"`
	// Is the message retained
	Retained bool `protobuf:"varint,4,opt,name=retained,proto3" json:"retained,omitempty"`
	// contains filtered or unexported fields
}

func (*PushMethodMQTT) Descriptor deprecated 

func (*PushMethodMQTT) Descriptor() ([]byte, []int)

Deprecated: Use PushMethodMQTT.ProtoReflect.Descriptor instead.

func (*PushMethodMQTT) GetAddress 

func (x *PushMethodMQTT) GetAddress() string

func (*PushMethodMQTT) GetQos 

func (x *PushMethodMQTT) GetQos() int32

func (*PushMethodMQTT) GetRetained 

func (x *PushMethodMQTT) GetRetained() bool

func (*PushMethodMQTT) GetTopic 

func (x *PushMethodMQTT) GetTopic() string

func (*PushMethodMQTT) ProtoMessage 

func (*PushMethodMQTT) ProtoMessage()

func (*PushMethodMQTT) ProtoReflect 

func (x *PushMethodMQTT) ProtoReflect() protoreflect.Message

func (*PushMethodMQTT) Reset 

func (x *PushMethodMQTT) Reset()

func (*PushMethodMQTT) String 

func (x *PushMethodMQTT) String() string

type RedisClientConfig 

type RedisClientConfig struct {

	// redis address
	Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	// number of redis db
	Db int32 `protobuf:"varint,2,opt,name=db,proto3" json:"db,omitempty"`
	// number of redis poolsize
	Poolsize int32 `protobuf:"varint,3,opt,name=poolsize,proto3" json:"poolsize,omitempty"`
	// number of redis minidleconns
	MinIdleConns int32 `protobuf:"varint,4,opt,name=minIdleConns,proto3" json:"minIdleConns,omitempty"`
	// contains filtered or unexported fields
}

func (*RedisClientConfig) Descriptor deprecated 

func (*RedisClientConfig) Descriptor() ([]byte, []int)

Deprecated: Use RedisClientConfig.ProtoReflect.Descriptor instead.

func (*RedisClientConfig) GetAddr 

func (x *RedisClientConfig) GetAddr() string

func (*RedisClientConfig) GetDb 

func (x *RedisClientConfig) GetDb() int32

func (*RedisClientConfig) GetMinIdleConns 

func (x *RedisClientConfig) GetMinIdleConns() int32

func (*RedisClientConfig) GetPoolsize 

func (x *RedisClientConfig) GetPoolsize() int32

func (*RedisClientConfig) ProtoMessage 

func (*RedisClientConfig) ProtoMessage()

func (*RedisClientConfig) ProtoReflect 

func (x *RedisClientConfig) ProtoReflect() protoreflect.Message

func (*RedisClientConfig) Reset 

func (x *RedisClientConfig) Reset()

func (*RedisClientConfig) String 

func (x *RedisClientConfig) String() string

type RegisterDeviceRequest 

type RegisterDeviceRequest struct {
	Device *Device `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterDeviceRequest) Descriptor deprecated 

func (*RegisterDeviceRequest) Descriptor() ([]byte, []int)

Deprecated: Use RegisterDeviceRequest.ProtoReflect.Descriptor instead.

func (*RegisterDeviceRequest) GetDevice 

func (x *RegisterDeviceRequest) GetDevice() *Device

func (*RegisterDeviceRequest) ProtoMessage 

func (*RegisterDeviceRequest) ProtoMessage()

func (*RegisterDeviceRequest) ProtoReflect 

func (x *RegisterDeviceRequest) ProtoReflect() protoreflect.Message

func (*RegisterDeviceRequest) Reset 

func (x *RegisterDeviceRequest) Reset()

func (*RegisterDeviceRequest) String 

func (x *RegisterDeviceRequest) String() string

type RegisterDeviceResponse 

type RegisterDeviceResponse struct {
	DeviceName string `protobuf:"bytes,1,opt,name=deviceName,proto3" json:"deviceName,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterDeviceResponse) Descriptor deprecated 

func (*RegisterDeviceResponse) Descriptor() ([]byte, []int)

Deprecated: Use RegisterDeviceResponse.ProtoReflect.Descriptor instead.

func (*RegisterDeviceResponse) GetDeviceName 

func (x *RegisterDeviceResponse) GetDeviceName() string

func (*RegisterDeviceResponse) ProtoMessage 

func (*RegisterDeviceResponse) ProtoMessage()

func (*RegisterDeviceResponse) ProtoReflect 

func (x *RegisterDeviceResponse) ProtoReflect() protoreflect.Message

func (*RegisterDeviceResponse) Reset 

func (x *RegisterDeviceResponse) Reset()

func (*RegisterDeviceResponse) String 

func (x *RegisterDeviceResponse) String() string

type RemoveDeviceModelRequest 

type RemoveDeviceModelRequest struct {
	ModelName string `protobuf:"bytes,1,opt,name=modelName,proto3" json:"modelName,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveDeviceModelRequest) Descriptor deprecated 

func (*RemoveDeviceModelRequest) Descriptor() ([]byte, []int)

Deprecated: Use RemoveDeviceModelRequest.ProtoReflect.Descriptor instead.

func (*RemoveDeviceModelRequest) GetModelName 

func (x *RemoveDeviceModelRequest) GetModelName() string

func (*RemoveDeviceModelRequest) ProtoMessage 

func (*RemoveDeviceModelRequest) ProtoMessage()

func (*RemoveDeviceModelRequest) ProtoReflect 

func (x *RemoveDeviceModelRequest) ProtoReflect() protoreflect.Message

func (*RemoveDeviceModelRequest) Reset 

func (x *RemoveDeviceModelRequest) Reset()

func (*RemoveDeviceModelRequest) String 

func (x *RemoveDeviceModelRequest) String() string

type RemoveDeviceModelResponse 

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

func (*RemoveDeviceModelResponse) Descriptor deprecated 

func (*RemoveDeviceModelResponse) Descriptor() ([]byte, []int)

Deprecated: Use RemoveDeviceModelResponse.ProtoReflect.Descriptor instead.

func (*RemoveDeviceModelResponse) ProtoMessage 

func (*RemoveDeviceModelResponse) ProtoMessage()

func (*RemoveDeviceModelResponse) ProtoReflect 

func (x *RemoveDeviceModelResponse) ProtoReflect() protoreflect.Message

func (*RemoveDeviceModelResponse) Reset 

func (x *RemoveDeviceModelResponse) Reset()

func (*RemoveDeviceModelResponse) String 

func (x *RemoveDeviceModelResponse) String() string

type RemoveDeviceRequest 

type RemoveDeviceRequest struct {
	DeviceName string `protobuf:"bytes,1,opt,name=deviceName,proto3" json:"deviceName,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveDeviceRequest) Descriptor deprecated 

func (*RemoveDeviceRequest) Descriptor() ([]byte, []int)

Deprecated: Use RemoveDeviceRequest.ProtoReflect.Descriptor instead.

func (*RemoveDeviceRequest) GetDeviceName 

func (x *RemoveDeviceRequest) GetDeviceName() string

func (*RemoveDeviceRequest) ProtoMessage 

func (*RemoveDeviceRequest) ProtoMessage()

func (*RemoveDeviceRequest) ProtoReflect 

func (x *RemoveDeviceRequest) ProtoReflect() protoreflect.Message

func (*RemoveDeviceRequest) Reset 

func (x *RemoveDeviceRequest) Reset()

func (*RemoveDeviceRequest) String 

func (x *RemoveDeviceRequest) String() string

type RemoveDeviceResponse 

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

func (*RemoveDeviceResponse) Descriptor deprecated 

func (*RemoveDeviceResponse) Descriptor() ([]byte, []int)

Deprecated: Use RemoveDeviceResponse.ProtoReflect.Descriptor instead.

func (*RemoveDeviceResponse) ProtoMessage 

func (*RemoveDeviceResponse) ProtoMessage()

func (*RemoveDeviceResponse) ProtoReflect 

func (x *RemoveDeviceResponse) ProtoReflect() protoreflect.Message

func (*RemoveDeviceResponse) Reset 

func (x *RemoveDeviceResponse) Reset()

func (*RemoveDeviceResponse) String 

func (x *RemoveDeviceResponse) String() string

type ReportDeviceStatusRequest 

type ReportDeviceStatusRequest struct {
	DeviceName     string        `protobuf:"bytes,1,opt,name=deviceName,proto3" json:"deviceName,omitempty"`
	ReportedDevice *DeviceStatus `protobuf:"bytes,2,opt,name=reportedDevice,proto3" json:"reportedDevice,omitempty"`
	// contains filtered or unexported fields
}

func (*ReportDeviceStatusRequest) Descriptor deprecated 

func (*ReportDeviceStatusRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReportDeviceStatusRequest.ProtoReflect.Descriptor instead.

func (*ReportDeviceStatusRequest) GetDeviceName 

func (x *ReportDeviceStatusRequest) GetDeviceName() string

func (*ReportDeviceStatusRequest) GetReportedDevice 

func (x *ReportDeviceStatusRequest) GetReportedDevice() *DeviceStatus

func (*ReportDeviceStatusRequest) ProtoMessage 

func (*ReportDeviceStatusRequest) ProtoMessage()

func (*ReportDeviceStatusRequest) ProtoReflect 

func (x *ReportDeviceStatusRequest) ProtoReflect() protoreflect.Message

func (*ReportDeviceStatusRequest) Reset 

func (x *ReportDeviceStatusRequest) Reset()

func (*ReportDeviceStatusRequest) String 

func (x *ReportDeviceStatusRequest) String() string

type ReportDeviceStatusResponse 

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

func (*ReportDeviceStatusResponse) Descriptor deprecated 

func (*ReportDeviceStatusResponse) Descriptor() ([]byte, []int)

Deprecated: Use ReportDeviceStatusResponse.ProtoReflect.Descriptor instead.

func (*ReportDeviceStatusResponse) ProtoMessage 

func (*ReportDeviceStatusResponse) ProtoMessage()

func (*ReportDeviceStatusResponse) ProtoReflect 

func (x *ReportDeviceStatusResponse) ProtoReflect() protoreflect.Message

func (*ReportDeviceStatusResponse) Reset 

func (x *ReportDeviceStatusResponse) Reset()

func (*ReportDeviceStatusResponse) String 

func (x *ReportDeviceStatusResponse) String() string

type TDEngineClientConfig 

type TDEngineClientConfig struct {

	// tdengine address,like 127.0.0.1:6041
	Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	// tdengine database name
	Dbname string `protobuf:"bytes,2,opt,name=dbname,proto3" json:"dbname,omitempty"`
	// contains filtered or unexported fields
}

func (*TDEngineClientConfig) Descriptor deprecated 

func (*TDEngineClientConfig) Descriptor() ([]byte, []int)

Deprecated: Use TDEngineClientConfig.ProtoReflect.Descriptor instead.

func (*TDEngineClientConfig) GetAddr 

func (x *TDEngineClientConfig) GetAddr() string

func (*TDEngineClientConfig) GetDbname 

func (x *TDEngineClientConfig) GetDbname() string

func (*TDEngineClientConfig) ProtoMessage 

func (*TDEngineClientConfig) ProtoMessage()

func (*TDEngineClientConfig) ProtoReflect 

func (x *TDEngineClientConfig) ProtoReflect() protoreflect.Message

func (*TDEngineClientConfig) Reset 

func (x *TDEngineClientConfig) Reset()

func (*TDEngineClientConfig) String 

func (x *TDEngineClientConfig) String() string

type Twin 

type Twin struct {

	// the name of the property.
	PropertyName string `protobuf:"bytes,1,opt,name=propertyName,proto3" json:"propertyName,omitempty"`
	// the observedDesired value of the property configured by mapper.
	ObservedDesired *TwinProperty `protobuf:"bytes,2,opt,name=observedDesired,proto3" json:"observedDesired,omitempty"`
	// the reported value of the property from the real device.
	Reported *TwinProperty `protobuf:"bytes,3,opt,name=reported,proto3" json:"reported,omitempty"`
	// contains filtered or unexported fields
}

Twin is the digital model of a device. It contains a series of properties.

func (*Twin) Descriptor deprecated 

func (*Twin) Descriptor() ([]byte, []int)

Deprecated: Use Twin.ProtoReflect.Descriptor instead.

func (*Twin) GetObservedDesired 

func (x *Twin) GetObservedDesired() *TwinProperty

func (*Twin) GetPropertyName 

func (x *Twin) GetPropertyName() string

func (*Twin) GetReported 

func (x *Twin) GetReported() *TwinProperty

func (*Twin) ProtoMessage 

func (*Twin) ProtoMessage()

func (*Twin) ProtoReflect 

func (x *Twin) ProtoReflect() protoreflect.Message

func (*Twin) Reset 

func (x *Twin) Reset()

func (*Twin) String 

func (x *Twin) String() string

type TwinProperty 

type TwinProperty struct {

	// the value of the property.
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// the metadata to describe this property.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

TwinProperty is the specification of the property.

func (*TwinProperty) Descriptor deprecated 

func (*TwinProperty) Descriptor() ([]byte, []int)

Deprecated: Use TwinProperty.ProtoReflect.Descriptor instead.

func (*TwinProperty) GetMetadata 

func (x *TwinProperty) GetMetadata() map[string]string

func (*TwinProperty) GetValue 

func (x *TwinProperty) GetValue() string

func (*TwinProperty) ProtoMessage 

func (*TwinProperty) ProtoMessage()

func (*TwinProperty) ProtoReflect 

func (x *TwinProperty) ProtoReflect() protoreflect.Message

func (*TwinProperty) Reset 

func (x *TwinProperty) Reset()

func (*TwinProperty) String 

func (x *TwinProperty) String() string

type UnimplementedDeviceManagerServiceServer 

type UnimplementedDeviceManagerServiceServer struct {
}

UnimplementedDeviceManagerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDeviceManagerServiceServer) MapperRegister 

func (UnimplementedDeviceManagerServiceServer) MapperRegister(context.Context, *MapperRegisterRequest) (*MapperRegisterResponse, error)

func (UnimplementedDeviceManagerServiceServer) ReportDeviceStatus 

func (UnimplementedDeviceManagerServiceServer) ReportDeviceStatus(context.Context, *ReportDeviceStatusRequest) (*ReportDeviceStatusResponse, error)

type UnimplementedDeviceMapperServiceServer 

type UnimplementedDeviceMapperServiceServer struct {
}

UnimplementedDeviceMapperServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDeviceMapperServiceServer) CreateDeviceModel 

func (UnimplementedDeviceMapperServiceServer) CreateDeviceModel(context.Context, *CreateDeviceModelRequest) (*CreateDeviceModelResponse, error)

func (UnimplementedDeviceMapperServiceServer) GetDevice 

func (UnimplementedDeviceMapperServiceServer) GetDevice(context.Context, *GetDeviceRequest) (*GetDeviceResponse, error)

func (UnimplementedDeviceMapperServiceServer) RegisterDevice 

func (UnimplementedDeviceMapperServiceServer) RegisterDevice(context.Context, *RegisterDeviceRequest) (*RegisterDeviceResponse, error)

func (UnimplementedDeviceMapperServiceServer) RemoveDevice 

func (UnimplementedDeviceMapperServiceServer) RemoveDevice(context.Context, *RemoveDeviceRequest) (*RemoveDeviceResponse, error)

func (UnimplementedDeviceMapperServiceServer) RemoveDeviceModel 

func (UnimplementedDeviceMapperServiceServer) RemoveDeviceModel(context.Context, *RemoveDeviceModelRequest) (*RemoveDeviceModelResponse, error)

func (UnimplementedDeviceMapperServiceServer) UpdateDevice 

func (UnimplementedDeviceMapperServiceServer) UpdateDevice(context.Context, *UpdateDeviceRequest) (*UpdateDeviceResponse, error)

func (UnimplementedDeviceMapperServiceServer) UpdateDeviceModel 

func (UnimplementedDeviceMapperServiceServer) UpdateDeviceModel(context.Context, *UpdateDeviceModelRequest) (*UpdateDeviceModelResponse, error)

type UnsafeDeviceManagerServiceServer 

type UnsafeDeviceManagerServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeDeviceManagerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DeviceManagerServiceServer will result in compilation errors.

type UnsafeDeviceMapperServiceServer 

type UnsafeDeviceMapperServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeDeviceMapperServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DeviceMapperServiceServer will result in compilation errors.

type UpdateDeviceModelRequest 

type UpdateDeviceModelRequest struct {
	Model *DeviceModel `protobuf:"bytes,1,opt,name=model,proto3" json:"model,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateDeviceModelRequest) Descriptor deprecated 

func (*UpdateDeviceModelRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateDeviceModelRequest.ProtoReflect.Descriptor instead.

func (*UpdateDeviceModelRequest) GetModel 

func (x *UpdateDeviceModelRequest) GetModel() *DeviceModel

func (*UpdateDeviceModelRequest) ProtoMessage 

func (*UpdateDeviceModelRequest) ProtoMessage()

func (*UpdateDeviceModelRequest) ProtoReflect 

func (x *UpdateDeviceModelRequest) ProtoReflect() protoreflect.Message

func (*UpdateDeviceModelRequest) Reset 

func (x *UpdateDeviceModelRequest) Reset()

func (*UpdateDeviceModelRequest) String 

func (x *UpdateDeviceModelRequest) String() string

type UpdateDeviceModelResponse 

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

func (*UpdateDeviceModelResponse) Descriptor deprecated 

func (*UpdateDeviceModelResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateDeviceModelResponse.ProtoReflect.Descriptor instead.

func (*UpdateDeviceModelResponse) ProtoMessage 

func (*UpdateDeviceModelResponse) ProtoMessage()

func (*UpdateDeviceModelResponse) ProtoReflect 

func (x *UpdateDeviceModelResponse) ProtoReflect() protoreflect.Message

func (*UpdateDeviceModelResponse) Reset 

func (x *UpdateDeviceModelResponse) Reset()

func (*UpdateDeviceModelResponse) String 

func (x *UpdateDeviceModelResponse) String() string

type UpdateDeviceRequest 

type UpdateDeviceRequest struct {
	Device *Device `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateDeviceRequest) Descriptor deprecated 

func (*UpdateDeviceRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateDeviceRequest.ProtoReflect.Descriptor instead.

func (*UpdateDeviceRequest) GetDevice 

func (x *UpdateDeviceRequest) GetDevice() *Device

func (*UpdateDeviceRequest) ProtoMessage 

func (*UpdateDeviceRequest) ProtoMessage()

func (*UpdateDeviceRequest) ProtoReflect 

func (x *UpdateDeviceRequest) ProtoReflect() protoreflect.Message

func (*UpdateDeviceRequest) Reset 

func (x *UpdateDeviceRequest) Reset()

func (*UpdateDeviceRequest) String 

func (x *UpdateDeviceRequest) String() string

type UpdateDeviceResponse 

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

func (*UpdateDeviceResponse) Descriptor deprecated 

func (*UpdateDeviceResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateDeviceResponse.ProtoReflect.Descriptor instead.

func (*UpdateDeviceResponse) ProtoMessage 

func (*UpdateDeviceResponse) ProtoMessage()

func (*UpdateDeviceResponse) ProtoReflect 

func (x *UpdateDeviceResponse) ProtoReflect() protoreflect.Message

func (*UpdateDeviceResponse) Reset 

func (x *UpdateDeviceResponse) Reset()

func (*UpdateDeviceResponse) String 

func (x *UpdateDeviceResponse) String() string

type VisitorConfig 

type VisitorConfig struct {

	// the name of the customized protocol.
	ProtocolName string `protobuf:"bytes,1,opt,name=protocolName,proto3" json:"protocolName,omitempty"`
	// the config data of the customized protocol.
	ConfigData *CustomizedValue `protobuf:"bytes,2,opt,name=configData,proto3" json:"configData,omitempty"`
	// contains filtered or unexported fields
}

the visitor to collect the properties of the device of customized protocol.

func (*VisitorConfig) Descriptor deprecated 

func (*VisitorConfig) Descriptor() ([]byte, []int)

Deprecated: Use VisitorConfig.ProtoReflect.Descriptor instead.

func (*VisitorConfig) GetConfigData 

func (x *VisitorConfig) GetConfigData() *CustomizedValue

func (*VisitorConfig) GetProtocolName 

func (x *VisitorConfig) GetProtocolName() string

func (*VisitorConfig) ProtoMessage 

func (*VisitorConfig) ProtoMessage()

func (*VisitorConfig) ProtoReflect 

func (x *VisitorConfig) ProtoReflect() protoreflect.Message

func (*VisitorConfig) Reset 

func (x *VisitorConfig) Reset()

func (*VisitorConfig) String 

func (x *VisitorConfig) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.