v1beta1

package
v1.17.0 Latest Latest
Warning

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

Go to latest
Published: Apr 28, 2024 License: Apache-2.0 Imports: 9 Imported by: 4

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)

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"`
	DeviceModelNamespace string `protobuf:"bytes,2,opt,name=deviceModelNamespace,proto3" json:"deviceModelNamespace,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) GetDeviceModelNamespace added in v1.16.0

func (x *CreateDeviceModelResponse) GetDeviceModelNamespace() string

func (*CreateDeviceModelResponse) ProtoMessage

func (*CreateDeviceModelResponse) ProtoMessage()

func (*CreateDeviceModelResponse) ProtoReflect

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]*any1.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]*any1.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"`
	Mysql     *DBMethodMySQL     `protobuf:"bytes,4,opt,name=mysql,proto3" json:"mysql,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) GetMysql added in v1.17.0

func (x *DBMethod) GetMysql() *DBMethodMySQL

func (*DBMethod) GetRedis added in v1.16.0

func (x *DBMethod) GetRedis() *DBMethodRedis

func (*DBMethod) GetTdengine added in v1.16.0

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 DBMethodMySQL added in v1.17.0

type DBMethodMySQL struct {
	MysqlClientConfig *MySQLClientConfig `protobuf:"bytes,1,opt,name=mysqlClientConfig,proto3" json:"mysqlClientConfig,omitempty"`
	// contains filtered or unexported fields
}

func (*DBMethodMySQL) Descriptor deprecated added in v1.17.0

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

Deprecated: Use DBMethodMySQL.ProtoReflect.Descriptor instead.

func (*DBMethodMySQL) GetMysqlClientConfig added in v1.17.0

func (x *DBMethodMySQL) GetMysqlClientConfig() *MySQLClientConfig

func (*DBMethodMySQL) ProtoMessage added in v1.17.0

func (*DBMethodMySQL) ProtoMessage()

func (*DBMethodMySQL) ProtoReflect added in v1.17.0

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

func (*DBMethodMySQL) Reset added in v1.17.0

func (x *DBMethodMySQL) Reset()

func (*DBMethodMySQL) String added in v1.17.0

func (x *DBMethodMySQL) String() string

type DBMethodRedis added in v1.16.0

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 added in v1.16.0

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

Deprecated: Use DBMethodRedis.ProtoReflect.Descriptor instead.

func (*DBMethodRedis) GetRedisClientConfig added in v1.16.0

func (x *DBMethodRedis) GetRedisClientConfig() *RedisClientConfig

func (*DBMethodRedis) ProtoMessage added in v1.16.0

func (*DBMethodRedis) ProtoMessage()

func (*DBMethodRedis) ProtoReflect added in v1.16.0

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

func (*DBMethodRedis) Reset added in v1.16.0

func (x *DBMethodRedis) Reset()

func (*DBMethodRedis) String added in v1.16.0

func (x *DBMethodRedis) String() string

type DBMethodTDEngine added in v1.16.0

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 added in v1.16.0

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

Deprecated: Use DBMethodTDEngine.ProtoReflect.Descriptor instead.

func (*DBMethodTDEngine) GetTdEngineClientConfig added in v1.16.0

func (x *DBMethodTDEngine) GetTdEngineClientConfig() *TDEngineClientConfig

func (*DBMethodTDEngine) ProtoMessage added in v1.16.0

func (*DBMethodTDEngine) ProtoMessage()

func (*DBMethodTDEngine) ProtoReflect added in v1.16.0

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

func (*DBMethodTDEngine) Reset added in v1.16.0

func (x *DBMethodTDEngine) Reset()

func (*DBMethodTDEngine) String added in v1.16.0

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"`
	// Namespace of the device.
	Namespace string `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,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) GetNamespace added in v1.16.0

func (x *Device) GetNamespace() 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.

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.

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"`
	// Namespace of the device model.
	Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,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) GetNamespace added in v1.16.0

func (x *DeviceModel) GetNamespace() 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"`
	DeviceNamespace string `protobuf:"bytes,2,opt,name=deviceNamespace,proto3" json:"deviceNamespace,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) GetDeviceNamespace added in v1.16.0

func (x *GetDeviceRequest) GetDeviceNamespace() 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 MySQLClientConfig added in v1.17.0

type MySQLClientConfig struct {

	// mysql address,like localhost:3306
	Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	// database name
	Database string `protobuf:"bytes,2,opt,name=database,proto3" json:"database,omitempty"`
	// user name
	UserName string `protobuf:"bytes,3,opt,name=userName,proto3" json:"userName,omitempty"`
	// contains filtered or unexported fields
}

func (*MySQLClientConfig) Descriptor deprecated added in v1.17.0

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

Deprecated: Use MySQLClientConfig.ProtoReflect.Descriptor instead.

func (*MySQLClientConfig) GetAddr added in v1.17.0

func (x *MySQLClientConfig) GetAddr() string

func (*MySQLClientConfig) GetDatabase added in v1.17.0

func (x *MySQLClientConfig) GetDatabase() string

func (*MySQLClientConfig) GetUserName added in v1.17.0

func (x *MySQLClientConfig) GetUserName() string

func (*MySQLClientConfig) ProtoMessage added in v1.17.0

func (*MySQLClientConfig) ProtoMessage()

func (*MySQLClientConfig) ProtoReflect added in v1.17.0

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

func (*MySQLClientConfig) Reset added in v1.17.0

func (x *MySQLClientConfig) Reset()

func (*MySQLClientConfig) String added in v1.17.0

func (x *MySQLClientConfig) 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 added in v1.16.0

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 added in v1.16.0

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

Deprecated: Use RedisClientConfig.ProtoReflect.Descriptor instead.

func (*RedisClientConfig) GetAddr added in v1.16.0

func (x *RedisClientConfig) GetAddr() string

func (*RedisClientConfig) GetDb added in v1.16.0

func (x *RedisClientConfig) GetDb() int32

func (*RedisClientConfig) GetMinIdleConns added in v1.16.0

func (x *RedisClientConfig) GetMinIdleConns() int32

func (*RedisClientConfig) GetPoolsize added in v1.16.0

func (x *RedisClientConfig) GetPoolsize() int32

func (*RedisClientConfig) ProtoMessage added in v1.16.0

func (*RedisClientConfig) ProtoMessage()

func (*RedisClientConfig) ProtoReflect added in v1.16.0

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

func (*RedisClientConfig) Reset added in v1.16.0

func (x *RedisClientConfig) Reset()

func (*RedisClientConfig) String added in v1.16.0

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"`
	DeviceNamespace string `protobuf:"bytes,2,opt,name=deviceNamespace,proto3" json:"deviceNamespace,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) GetDeviceNamespace added in v1.16.0

func (x *RegisterDeviceResponse) GetDeviceNamespace() 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"`
	ModelNamespace string `protobuf:"bytes,2,opt,name=modelNamespace,proto3" json:"modelNamespace,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) GetModelNamespace added in v1.16.0

func (x *RemoveDeviceModelRequest) GetModelNamespace() 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 (*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"`
	DeviceNamespace string `protobuf:"bytes,2,opt,name=deviceNamespace,proto3" json:"deviceNamespace,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) GetDeviceNamespace added in v1.16.0

func (x *RemoveDeviceRequest) GetDeviceNamespace() 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"`
	DeviceNamespace string        `protobuf:"bytes,3,opt,name=deviceNamespace,proto3" json:"deviceNamespace,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) GetDeviceNamespace added in v1.16.0

func (x *ReportDeviceStatusRequest) GetDeviceNamespace() string

func (*ReportDeviceStatusRequest) GetReportedDevice

func (x *ReportDeviceStatusRequest) GetReportedDevice() *DeviceStatus

func (*ReportDeviceStatusRequest) ProtoMessage

func (*ReportDeviceStatusRequest) ProtoMessage()

func (*ReportDeviceStatusRequest) ProtoReflect

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 (*ReportDeviceStatusResponse) Reset

func (x *ReportDeviceStatusResponse) Reset()

func (*ReportDeviceStatusResponse) String

func (x *ReportDeviceStatusResponse) String() string

type TDEngineClientConfig added in v1.16.0

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 added in v1.16.0

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

Deprecated: Use TDEngineClientConfig.ProtoReflect.Descriptor instead.

func (*TDEngineClientConfig) GetAddr added in v1.16.0

func (x *TDEngineClientConfig) GetAddr() string

func (*TDEngineClientConfig) GetDbname added in v1.16.0

func (x *TDEngineClientConfig) GetDbname() string

func (*TDEngineClientConfig) ProtoMessage added in v1.16.0

func (*TDEngineClientConfig) ProtoMessage()

func (*TDEngineClientConfig) ProtoReflect added in v1.16.0

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

func (*TDEngineClientConfig) Reset added in v1.16.0

func (x *TDEngineClientConfig) Reset()

func (*TDEngineClientConfig) String added in v1.16.0

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) ReportDeviceStatus

type UnimplementedDeviceMapperServiceServer

type UnimplementedDeviceMapperServiceServer struct {
}

UnimplementedDeviceMapperServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDeviceMapperServiceServer) CreateDeviceModel

func (UnimplementedDeviceMapperServiceServer) GetDevice

func (UnimplementedDeviceMapperServiceServer) RegisterDevice

func (UnimplementedDeviceMapperServiceServer) RemoveDevice

func (UnimplementedDeviceMapperServiceServer) RemoveDeviceModel

func (UnimplementedDeviceMapperServiceServer) UpdateDevice

func (UnimplementedDeviceMapperServiceServer) UpdateDeviceModel

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 (*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

Jump to

Keyboard shortcuts

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