api

package
v0.0.0-...-dddc173 Latest Latest
Warning

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

 Go to latest Published: Nov 13, 2019 License: MIT Imports: 13 Imported by: 0

Documentation

Overview

Package api is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package api is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package api is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package api is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package api is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package api is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package api is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterDLT645_2007Handler 

func RegisterDLT645_2007Handler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterDLT645_2007Handler registers the http handlers for service DLT645_2007 to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterDLT645_2007HandlerClient 

func RegisterDLT645_2007HandlerClient(ctx context.Context, mux *runtime.ServeMux, client DLT645_2007Client) error

RegisterDLT645_2007Handler registers the http handlers for service DLT645_2007 to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "DLT645_2007Client". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "DLT645_2007Client" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "DLT645_2007Client" to call the correct interceptors.

func RegisterDLT645_2007HandlerFromEndpoint 

func RegisterDLT645_2007HandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterDLT645_2007HandlerFromEndpoint is same as RegisterDLT645_2007Handler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterDLT645_2007Server 

func RegisterDLT645_2007Server(s *grpc.Server, srv DLT645_2007Server)

func RegisterElectricMeterHandler 

func RegisterElectricMeterHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterElectricMeterHandler registers the http handlers for service ElectricMeter to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterElectricMeterHandlerClient 

func RegisterElectricMeterHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ElectricMeterClient) error

RegisterElectricMeterHandler registers the http handlers for service ElectricMeter to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ElectricMeterClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ElectricMeterClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ElectricMeterClient" to call the correct interceptors.

func RegisterElectricMeterHandlerFromEndpoint 

func RegisterElectricMeterHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterElectricMeterHandlerFromEndpoint is same as RegisterElectricMeterHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterElectricMeterServer 

func RegisterElectricMeterServer(s *grpc.Server, srv ElectricMeterServer)

func RegisterGatewayServiceHandler 

func RegisterGatewayServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterGatewayServiceHandler registers the http handlers for service GatewayService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterGatewayServiceHandlerClient 

func RegisterGatewayServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client GatewayServiceClient) error

RegisterGatewayServiceHandler registers the http handlers for service GatewayService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "GatewayServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "GatewayServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "GatewayServiceClient" to call the correct interceptors.

func RegisterGatewayServiceHandlerFromEndpoint 

func RegisterGatewayServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterGatewayServiceHandlerFromEndpoint is same as RegisterGatewayServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterGatewayServiceServer 

func RegisterGatewayServiceServer(s *grpc.Server, srv GatewayServiceServer)

func RegisterModbusRtuHandler 

func RegisterModbusRtuHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterModbusRtuHandler registers the http handlers for service ModbusRtu to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterModbusRtuHandlerClient 

func RegisterModbusRtuHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ModbusRtuClient) error

RegisterModbusRtuHandler registers the http handlers for service ModbusRtu to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ModbusRtuClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ModbusRtuClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ModbusRtuClient" to call the correct interceptors.

func RegisterModbusRtuHandlerFromEndpoint 

func RegisterModbusRtuHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterModbusRtuHandlerFromEndpoint is same as RegisterModbusRtuHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterModbusRtuServer 

func RegisterModbusRtuServer(s *grpc.Server, srv ModbusRtuServer)

func RegisterModbusTcpHandler 

func RegisterModbusTcpHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterModbusTcpHandler registers the http handlers for service ModbusTcp to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterModbusTcpHandlerClient 

func RegisterModbusTcpHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ModbusTcpClient) error

RegisterModbusTcpHandler registers the http handlers for service ModbusTcp to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ModbusTcpClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ModbusTcpClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ModbusTcpClient" to call the correct interceptors.

func RegisterModbusTcpHandlerFromEndpoint 

func RegisterModbusTcpHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterModbusTcpHandlerFromEndpoint is same as RegisterModbusTcpHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterModbusTcpServer 

func RegisterModbusTcpServer(s *grpc.Server, srv ModbusTcpServer)

func RegisterTC100R8Handler 

func RegisterTC100R8Handler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterTC100R8Handler registers the http handlers for service TC100R8 to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterTC100R8HandlerClient 

func RegisterTC100R8HandlerClient(ctx context.Context, mux *runtime.ServeMux, client TC100R8Client) error

RegisterTC100R8Handler registers the http handlers for service TC100R8 to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "TC100R8Client". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "TC100R8Client" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "TC100R8Client" to call the correct interceptors.

func RegisterTC100R8HandlerFromEndpoint 

func RegisterTC100R8HandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterTC100R8HandlerFromEndpoint is same as RegisterTC100R8Handler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterTC100R8Server 

func RegisterTC100R8Server(s *grpc.Server, srv TC100R8Server)

func RegisterWaterMeterHandler 

func RegisterWaterMeterHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterWaterMeterHandler registers the http handlers for service WaterMeter to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterWaterMeterHandlerClient 

func RegisterWaterMeterHandlerClient(ctx context.Context, mux *runtime.ServeMux, client WaterMeterClient) error

RegisterWaterMeterHandler registers the http handlers for service WaterMeter to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "WaterMeterClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "WaterMeterClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "WaterMeterClient" to call the correct interceptors.

func RegisterWaterMeterHandlerFromEndpoint 

func RegisterWaterMeterHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterWaterMeterHandlerFromEndpoint is same as RegisterWaterMeterHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterWaterMeterServer 

func RegisterWaterMeterServer(s *grpc.Server, srv WaterMeterServer)

Types

type DLT645_2007Client 

type DLT645_2007Client interface {
	// 添加或更新DLT645-2007标准协议表具设备
	Dtl645_2007Update(ctx context.Context, in *Dtl645_2007UpdateRequest, opts ...grpc.CallOption) (*Dtl645_2007UpdateResponse, error)
}

DLT645_2007Client is the client API for DLT645_2007 service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDLT645_2007Client 

func NewDLT645_2007Client(cc *grpc.ClientConn) DLT645_2007Client

type DLT645_2007Server 

type DLT645_2007Server interface {
	// 添加或更新DLT645-2007标准协议表具设备
	Dtl645_2007Update(context.Context, *Dtl645_2007UpdateRequest) (*Dtl645_2007UpdateResponse, error)
}

DLT645_2007Server is the server API for DLT645_2007 service.

type DelDevRequest 

type DelDevRequest struct {
	Devid                string   `protobuf:"bytes,1,opt,name=devid,proto3" json:"devid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DelDevRequest) Descriptor 

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

func (*DelDevRequest) GetDevid 

func (m *DelDevRequest) GetDevid() string

func (*DelDevRequest) ProtoMessage 

func (*DelDevRequest) ProtoMessage()

func (*DelDevRequest) Reset 

func (m *DelDevRequest) Reset()

func (*DelDevRequest) String 

func (m *DelDevRequest) String() string

func (*DelDevRequest) XXX_DiscardUnknown 

func (m *DelDevRequest) XXX_DiscardUnknown()

func (*DelDevRequest) XXX_Marshal 

func (m *DelDevRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DelDevRequest) XXX_Merge 

func (dst *DelDevRequest) XXX_Merge(src proto.Message)

func (*DelDevRequest) XXX_Size 

func (m *DelDevRequest) XXX_Size() int

func (*DelDevRequest) XXX_Unmarshal 

func (m *DelDevRequest) XXX_Unmarshal(b []byte) error

type DelDevResponse 

type DelDevResponse struct {
	Result               string   `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DelDevResponse) Descriptor 

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

func (*DelDevResponse) GetResult 

func (m *DelDevResponse) GetResult() string

func (*DelDevResponse) ProtoMessage 

func (*DelDevResponse) ProtoMessage()

func (*DelDevResponse) Reset 

func (m *DelDevResponse) Reset()

func (*DelDevResponse) String 

func (m *DelDevResponse) String() string

func (*DelDevResponse) XXX_DiscardUnknown 

func (m *DelDevResponse) XXX_DiscardUnknown()

func (*DelDevResponse) XXX_Marshal 

func (m *DelDevResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DelDevResponse) XXX_Merge 

func (dst *DelDevResponse) XXX_Merge(src proto.Message)

func (*DelDevResponse) XXX_Size 

func (m *DelDevResponse) XXX_Size() int

func (*DelDevResponse) XXX_Unmarshal 

func (m *DelDevResponse) XXX_Unmarshal(b []byte) error

type DevStruct 

type DevStruct struct {
	Devid                string            `protobuf:"bytes,1,opt,name=devid,proto3" json:"devid,omitempty"`
	Devtype              string            `protobuf:"bytes,2,opt,name=devtype,proto3" json:"devtype,omitempty"`
	Conn                 map[string]string `` /* 149-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*DevStruct) Descriptor 

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

func (*DevStruct) GetConn 

func (m *DevStruct) GetConn() map[string]string

func (*DevStruct) GetDevid 

func (m *DevStruct) GetDevid() string

func (*DevStruct) GetDevtype 

func (m *DevStruct) GetDevtype() string

func (*DevStruct) ProtoMessage 

func (*DevStruct) ProtoMessage()

func (*DevStruct) Reset 

func (m *DevStruct) Reset()

func (*DevStruct) String 

func (m *DevStruct) String() string

func (*DevStruct) XXX_DiscardUnknown 

func (m *DevStruct) XXX_DiscardUnknown()

func (*DevStruct) XXX_Marshal 

func (m *DevStruct) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DevStruct) XXX_Merge 

func (dst *DevStruct) XXX_Merge(src proto.Message)

func (*DevStruct) XXX_Size 

func (m *DevStruct) XXX_Size() int

func (*DevStruct) XXX_Unmarshal 

func (m *DevStruct) XXX_Unmarshal(b []byte) error

type DoGetHistoryRequest 

type DoGetHistoryRequest struct {
	Devid                string   `protobuf:"bytes,1,opt,name=devid,proto3" json:"devid,omitempty"`
	Cmdtype              string   `protobuf:"bytes,2,opt,name=cmdtype,proto3" json:"cmdtype,omitempty"`
	Since                string   `protobuf:"bytes,3,opt,name=since,proto3" json:"since,omitempty"`
	Until                string   `protobuf:"bytes,4,opt,name=until,proto3" json:"until,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DoGetHistoryRequest) Descriptor 

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

func (*DoGetHistoryRequest) GetCmdtype 

func (m *DoGetHistoryRequest) GetCmdtype() string

func (*DoGetHistoryRequest) GetDevid 

func (m *DoGetHistoryRequest) GetDevid() string

func (*DoGetHistoryRequest) GetSince 

func (m *DoGetHistoryRequest) GetSince() string

func (*DoGetHistoryRequest) GetUntil 

func (m *DoGetHistoryRequest) GetUntil() string

func (*DoGetHistoryRequest) ProtoMessage 

func (*DoGetHistoryRequest) ProtoMessage()

func (*DoGetHistoryRequest) Reset 

func (m *DoGetHistoryRequest) Reset()

func (*DoGetHistoryRequest) String 

func (m *DoGetHistoryRequest) String() string

func (*DoGetHistoryRequest) XXX_DiscardUnknown 

func (m *DoGetHistoryRequest) XXX_DiscardUnknown()

func (*DoGetHistoryRequest) XXX_Marshal 

func (m *DoGetHistoryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DoGetHistoryRequest) XXX_Merge 

func (dst *DoGetHistoryRequest) XXX_Merge(src proto.Message)

func (*DoGetHistoryRequest) XXX_Size 

func (m *DoGetHistoryRequest) XXX_Size() int

func (*DoGetHistoryRequest) XXX_Unmarshal 

func (m *DoGetHistoryRequest) XXX_Unmarshal(b []byte) error

type DoGetHistoryResponse 

type DoGetHistoryResponse struct {
	Data                 []*HistoryStuct `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*DoGetHistoryResponse) Descriptor 

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

func (*DoGetHistoryResponse) GetData 

func (m *DoGetHistoryResponse) GetData() []*HistoryStuct

func (*DoGetHistoryResponse) ProtoMessage 

func (*DoGetHistoryResponse) ProtoMessage()

func (*DoGetHistoryResponse) Reset 

func (m *DoGetHistoryResponse) Reset()

func (*DoGetHistoryResponse) String 

func (m *DoGetHistoryResponse) String() string

func (*DoGetHistoryResponse) XXX_DiscardUnknown 

func (m *DoGetHistoryResponse) XXX_DiscardUnknown()

func (*DoGetHistoryResponse) XXX_Marshal 

func (m *DoGetHistoryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DoGetHistoryResponse) XXX_Merge 

func (dst *DoGetHistoryResponse) XXX_Merge(src proto.Message)

func (*DoGetHistoryResponse) XXX_Size 

func (m *DoGetHistoryResponse) XXX_Size() int

func (*DoGetHistoryResponse) XXX_Unmarshal 

func (m *DoGetHistoryResponse) XXX_Unmarshal(b []byte) error

type DoGetValueRequest 

type DoGetValueRequest struct {
	Devid                string   `protobuf:"bytes,1,opt,name=devid,proto3" json:"devid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DoGetValueRequest) Descriptor 

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

func (*DoGetValueRequest) GetDevid 

func (m *DoGetValueRequest) GetDevid() string

func (*DoGetValueRequest) ProtoMessage 

func (*DoGetValueRequest) ProtoMessage()

func (*DoGetValueRequest) Reset 

func (m *DoGetValueRequest) Reset()

func (*DoGetValueRequest) String 

func (m *DoGetValueRequest) String() string

func (*DoGetValueRequest) XXX_DiscardUnknown 

func (m *DoGetValueRequest) XXX_DiscardUnknown()

func (*DoGetValueRequest) XXX_Marshal 

func (m *DoGetValueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DoGetValueRequest) XXX_Merge 

func (dst *DoGetValueRequest) XXX_Merge(src proto.Message)

func (*DoGetValueRequest) XXX_Size 

func (m *DoGetValueRequest) XXX_Size() int

func (*DoGetValueRequest) XXX_Unmarshal 

func (m *DoGetValueRequest) XXX_Unmarshal(b []byte) error

type DoGetValueResponse 

type DoGetValueResponse struct {
	Data                 map[string]string `` /* 149-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*DoGetValueResponse) Descriptor 

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

func (*DoGetValueResponse) GetData 

func (m *DoGetValueResponse) GetData() map[string]string

func (*DoGetValueResponse) ProtoMessage 

func (*DoGetValueResponse) ProtoMessage()

func (*DoGetValueResponse) Reset 

func (m *DoGetValueResponse) Reset()

func (*DoGetValueResponse) String 

func (m *DoGetValueResponse) String() string

func (*DoGetValueResponse) XXX_DiscardUnknown 

func (m *DoGetValueResponse) XXX_DiscardUnknown()

func (*DoGetValueResponse) XXX_Marshal 

func (m *DoGetValueResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DoGetValueResponse) XXX_Merge 

func (dst *DoGetValueResponse) XXX_Merge(src proto.Message)

func (*DoGetValueResponse) XXX_Size 

func (m *DoGetValueResponse) XXX_Size() int

func (*DoGetValueResponse) XXX_Unmarshal 

func (m *DoGetValueResponse) XXX_Unmarshal(b []byte) error

type Dtl645_2007UpdateRequest 

type Dtl645_2007UpdateRequest struct {
	Devid                string   `protobuf:"bytes,1,opt,name=devid,proto3" json:"devid,omitempty"`
	Devtype              string   `protobuf:"bytes,2,opt,name=devtype,proto3" json:"devtype,omitempty"`
	Devaddr              string   `protobuf:"bytes,3,opt,name=devaddr,proto3" json:"devaddr,omitempty"`
	Commif               string   `protobuf:"bytes,4,opt,name=commif,proto3" json:"commif,omitempty"`
	BaudRate             uint32   `protobuf:"varint,5,opt,name=baudRate,proto3" json:"baudRate,omitempty"`
	DataBits             uint32   `protobuf:"varint,6,opt,name=dataBits,proto3" json:"dataBits,omitempty"`
	StopBits             uint32   `protobuf:"varint,7,opt,name=stopBits,proto3" json:"stopBits,omitempty"`
	Parity               string   `protobuf:"bytes,8,opt,name=parity,proto3" json:"parity,omitempty"`
	Dname                string   `protobuf:"bytes,9,opt,name=dname,proto3" json:"dname,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Dtl645_2007UpdateRequest) Descriptor 

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

func (*Dtl645_2007UpdateRequest) GetBaudRate 

func (m *Dtl645_2007UpdateRequest) GetBaudRate() uint32

func (*Dtl645_2007UpdateRequest) GetCommif 

func (m *Dtl645_2007UpdateRequest) GetCommif() string

func (*Dtl645_2007UpdateRequest) GetDataBits 

func (m *Dtl645_2007UpdateRequest) GetDataBits() uint32

func (*Dtl645_2007UpdateRequest) GetDevaddr 

func (m *Dtl645_2007UpdateRequest) GetDevaddr() string

func (*Dtl645_2007UpdateRequest) GetDevid 

func (m *Dtl645_2007UpdateRequest) GetDevid() string

func (*Dtl645_2007UpdateRequest) GetDevtype 

func (m *Dtl645_2007UpdateRequest) GetDevtype() string

func (*Dtl645_2007UpdateRequest) GetDname 

func (m *Dtl645_2007UpdateRequest) GetDname() string

func (*Dtl645_2007UpdateRequest) GetParity 

func (m *Dtl645_2007UpdateRequest) GetParity() string

func (*Dtl645_2007UpdateRequest) GetStopBits 

func (m *Dtl645_2007UpdateRequest) GetStopBits() uint32

func (*Dtl645_2007UpdateRequest) ProtoMessage 

func (*Dtl645_2007UpdateRequest) ProtoMessage()

func (*Dtl645_2007UpdateRequest) Reset 

func (m *Dtl645_2007UpdateRequest) Reset()

func (*Dtl645_2007UpdateRequest) String 

func (m *Dtl645_2007UpdateRequest) String() string

func (*Dtl645_2007UpdateRequest) XXX_DiscardUnknown 

func (m *Dtl645_2007UpdateRequest) XXX_DiscardUnknown()

func (*Dtl645_2007UpdateRequest) XXX_Marshal 

func (m *Dtl645_2007UpdateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Dtl645_2007UpdateRequest) XXX_Merge 

func (dst *Dtl645_2007UpdateRequest) XXX_Merge(src proto.Message)

func (*Dtl645_2007UpdateRequest) XXX_Size 

func (m *Dtl645_2007UpdateRequest) XXX_Size() int

func (*Dtl645_2007UpdateRequest) XXX_Unmarshal 

func (m *Dtl645_2007UpdateRequest) XXX_Unmarshal(b []byte) error

type Dtl645_2007UpdateResponse 

type Dtl645_2007UpdateResponse struct {
	Result               string   `protobuf:"bytes,1,opt,name=Result,proto3" json:"Result,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Dtl645_2007UpdateResponse) Descriptor 

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

func (*Dtl645_2007UpdateResponse) GetResult 

func (m *Dtl645_2007UpdateResponse) GetResult() string

func (*Dtl645_2007UpdateResponse) ProtoMessage 

func (*Dtl645_2007UpdateResponse) ProtoMessage()

func (*Dtl645_2007UpdateResponse) Reset 

func (m *Dtl645_2007UpdateResponse) Reset()

func (*Dtl645_2007UpdateResponse) String 

func (m *Dtl645_2007UpdateResponse) String() string

func (*Dtl645_2007UpdateResponse) XXX_DiscardUnknown 

func (m *Dtl645_2007UpdateResponse) XXX_DiscardUnknown()

func (*Dtl645_2007UpdateResponse) XXX_Marshal 

func (m *Dtl645_2007UpdateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Dtl645_2007UpdateResponse) XXX_Merge 

func (dst *Dtl645_2007UpdateResponse) XXX_Merge(src proto.Message)

func (*Dtl645_2007UpdateResponse) XXX_Size 

func (m *Dtl645_2007UpdateResponse) XXX_Size() int

func (*Dtl645_2007UpdateResponse) XXX_Unmarshal 

func (m *Dtl645_2007UpdateResponse) XXX_Unmarshal(b []byte) error

type ElectricMeterClient 

type ElectricMeterClient interface {
	// 添加或更新电表设备
	ElectricMeterUpdate(ctx context.Context, in *ElectricMeterUpdateRequest, opts ...grpc.CallOption) (*ElectricMeterUpdateResponse, error)
}

ElectricMeterClient is the client API for ElectricMeter service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewElectricMeterClient 

func NewElectricMeterClient(cc *grpc.ClientConn) ElectricMeterClient

type ElectricMeterServer 

type ElectricMeterServer interface {
	// 添加或更新电表设备
	ElectricMeterUpdate(context.Context, *ElectricMeterUpdateRequest) (*ElectricMeterUpdateResponse, error)
}

ElectricMeterServer is the server API for ElectricMeter service.

type ElectricMeterUpdateRequest 

type ElectricMeterUpdateRequest struct {
	Devid                string   `protobuf:"bytes,1,opt,name=devid,proto3" json:"devid,omitempty"`
	Devtype              string   `protobuf:"bytes,2,opt,name=devtype,proto3" json:"devtype,omitempty"`
	Devaddr              string   `protobuf:"bytes,3,opt,name=devaddr,proto3" json:"devaddr,omitempty"`
	Commif               string   `protobuf:"bytes,4,opt,name=commif,proto3" json:"commif,omitempty"`
	Dname                string   `protobuf:"bytes,5,opt,name=dname,proto3" json:"dname,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ElectricMeterUpdateRequest) Descriptor 

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

func (*ElectricMeterUpdateRequest) GetCommif 

func (m *ElectricMeterUpdateRequest) GetCommif() string

func (*ElectricMeterUpdateRequest) GetDevaddr 

func (m *ElectricMeterUpdateRequest) GetDevaddr() string

func (*ElectricMeterUpdateRequest) GetDevid 

func (m *ElectricMeterUpdateRequest) GetDevid() string

func (*ElectricMeterUpdateRequest) GetDevtype 

func (m *ElectricMeterUpdateRequest) GetDevtype() string

func (*ElectricMeterUpdateRequest) GetDname 

func (m *ElectricMeterUpdateRequest) GetDname() string

func (*ElectricMeterUpdateRequest) ProtoMessage 

func (*ElectricMeterUpdateRequest) ProtoMessage()

func (*ElectricMeterUpdateRequest) Reset 

func (m *ElectricMeterUpdateRequest) Reset()

func (*ElectricMeterUpdateRequest) String 

func (m *ElectricMeterUpdateRequest) String() string

func (*ElectricMeterUpdateRequest) XXX_DiscardUnknown 

func (m *ElectricMeterUpdateRequest) XXX_DiscardUnknown()

func (*ElectricMeterUpdateRequest) XXX_Marshal 

func (m *ElectricMeterUpdateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ElectricMeterUpdateRequest) XXX_Merge 

func (dst *ElectricMeterUpdateRequest) XXX_Merge(src proto.Message)

func (*ElectricMeterUpdateRequest) XXX_Size 

func (m *ElectricMeterUpdateRequest) XXX_Size() int

func (*ElectricMeterUpdateRequest) XXX_Unmarshal 

func (m *ElectricMeterUpdateRequest) XXX_Unmarshal(b []byte) error

type ElectricMeterUpdateResponse 

type ElectricMeterUpdateResponse struct {
	Result               string   `protobuf:"bytes,1,opt,name=Result,proto3" json:"Result,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ElectricMeterUpdateResponse) Descriptor 

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

func (*ElectricMeterUpdateResponse) GetResult 

func (m *ElectricMeterUpdateResponse) GetResult() string

func (*ElectricMeterUpdateResponse) ProtoMessage 

func (*ElectricMeterUpdateResponse) ProtoMessage()

func (*ElectricMeterUpdateResponse) Reset 

func (m *ElectricMeterUpdateResponse) Reset()

func (*ElectricMeterUpdateResponse) String 

func (m *ElectricMeterUpdateResponse) String() string

func (*ElectricMeterUpdateResponse) XXX_DiscardUnknown 

func (m *ElectricMeterUpdateResponse) XXX_DiscardUnknown()

func (*ElectricMeterUpdateResponse) XXX_Marshal 

func (m *ElectricMeterUpdateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ElectricMeterUpdateResponse) XXX_Merge 

func (dst *ElectricMeterUpdateResponse) XXX_Merge(src proto.Message)

func (*ElectricMeterUpdateResponse) XXX_Size 

func (m *ElectricMeterUpdateResponse) XXX_Size() int

func (*ElectricMeterUpdateResponse) XXX_Unmarshal 

func (m *ElectricMeterUpdateResponse) XXX_Unmarshal(b []byte) error

type GatewayServiceClient 

type GatewayServiceClient interface {
	// 设置网关配置参数
	GatewaySet(ctx context.Context, in *SetGatewayManageRequest, opts ...grpc.CallOption) (*SetGatewayManageResponse, error)
	// 查看网关当前的配置
	GatewayGet(ctx context.Context, in *GetGatewayManageRequest, opts ...grpc.CallOption) (*GetGatewayManageResponse, error)
	// 查看网关支持的设备列表
	SuppotList(ctx context.Context, in *GetSuppotRequest, opts ...grpc.CallOption) (*GetSuppotResponse, error)
	// 设置网关自动上报的时间间隔(0为不自动上报)
	SetInterval(ctx context.Context, in *SetIntervalRequest, opts ...grpc.CallOption) (*SetIntervalResponse, error)
	// 设置网关SSL/TLS(http://xxx.xxx.xxx/...)
	SetTLSConfig(ctx context.Context, in *SetTLSConfigRequest, opts ...grpc.CallOption) (*SetTLSConfigResponse, error)
	// 修改用户名和密码
	ModifyUserPw(ctx context.Context, in *ModifyUserPwRequest, opts ...grpc.CallOption) (*ModifyUserPwResponse, error)
	// 查看已添加的设备列表
	DevList(ctx context.Context, in *GetDevListRequest, opts ...grpc.CallOption) (*GetDevListResponse, error)
	// 删除设备
	DevDelete(ctx context.Context, in *DelDevRequest, opts ...grpc.CallOption) (*DelDevResponse, error)
	// 更新网关系统(http://xxx.xxx.xxx/...)
	UpdateGatewaySystem(ctx context.Context, in *UpdateGatewaySystemRequest, opts ...grpc.CallOption) (*UpdateGatewaySystemResponse, error)
	// 读取设备当前的值
	DoGetValue(ctx context.Context, in *DoGetValueRequest, opts ...grpc.CallOption) (*DoGetValueResponse, error)
	// 读设备历史记录
	DoGetHistory(ctx context.Context, in *DoGetHistoryRequest, opts ...grpc.CallOption) (*DoGetHistoryResponse, error)
}

GatewayServiceClient is the client API for GatewayService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewGatewayServiceClient 

func NewGatewayServiceClient(cc *grpc.ClientConn) GatewayServiceClient

type GatewayServiceServer 

type GatewayServiceServer interface {
	// 设置网关配置参数
	GatewaySet(context.Context, *SetGatewayManageRequest) (*SetGatewayManageResponse, error)
	// 查看网关当前的配置
	GatewayGet(context.Context, *GetGatewayManageRequest) (*GetGatewayManageResponse, error)
	// 查看网关支持的设备列表
	SuppotList(context.Context, *GetSuppotRequest) (*GetSuppotResponse, error)
	// 设置网关自动上报的时间间隔(0为不自动上报)
	SetInterval(context.Context, *SetIntervalRequest) (*SetIntervalResponse, error)
	// 设置网关SSL/TLS(http://xxx.xxx.xxx/...)
	SetTLSConfig(context.Context, *SetTLSConfigRequest) (*SetTLSConfigResponse, error)
	// 修改用户名和密码
	ModifyUserPw(context.Context, *ModifyUserPwRequest) (*ModifyUserPwResponse, error)
	// 查看已添加的设备列表
	DevList(context.Context, *GetDevListRequest) (*GetDevListResponse, error)
	// 删除设备
	DevDelete(context.Context, *DelDevRequest) (*DelDevResponse, error)
	// 更新网关系统(http://xxx.xxx.xxx/...)
	UpdateGatewaySystem(context.Context, *UpdateGatewaySystemRequest) (*UpdateGatewaySystemResponse, error)
	// 读取设备当前的值
	DoGetValue(context.Context, *DoGetValueRequest) (*DoGetValueResponse, error)
	// 读设备历史记录
	DoGetHistory(context.Context, *DoGetHistoryRequest) (*DoGetHistoryResponse, error)
}

GatewayServiceServer is the server API for GatewayService service.

type GetDevListRequest 

type GetDevListRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetDevListRequest) Descriptor 

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

func (*GetDevListRequest) ProtoMessage 

func (*GetDevListRequest) ProtoMessage()

func (*GetDevListRequest) Reset 

func (m *GetDevListRequest) Reset()

func (*GetDevListRequest) String 

func (m *GetDevListRequest) String() string

func (*GetDevListRequest) XXX_DiscardUnknown 

func (m *GetDevListRequest) XXX_DiscardUnknown()

func (*GetDevListRequest) XXX_Marshal 

func (m *GetDevListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetDevListRequest) XXX_Merge 

func (dst *GetDevListRequest) XXX_Merge(src proto.Message)

func (*GetDevListRequest) XXX_Size 

func (m *GetDevListRequest) XXX_Size() int

func (*GetDevListRequest) XXX_Unmarshal 

func (m *GetDevListRequest) XXX_Unmarshal(b []byte) error

type GetDevListResponse 

type GetDevListResponse struct {
	Data                 []*DevStruct `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*GetDevListResponse) Descriptor 

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

func (*GetDevListResponse) GetData 

func (m *GetDevListResponse) GetData() []*DevStruct

func (*GetDevListResponse) ProtoMessage 

func (*GetDevListResponse) ProtoMessage()

func (*GetDevListResponse) Reset 

func (m *GetDevListResponse) Reset()

func (*GetDevListResponse) String 

func (m *GetDevListResponse) String() string

func (*GetDevListResponse) XXX_DiscardUnknown 

func (m *GetDevListResponse) XXX_DiscardUnknown()

func (*GetDevListResponse) XXX_Marshal 

func (m *GetDevListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetDevListResponse) XXX_Merge 

func (dst *GetDevListResponse) XXX_Merge(src proto.Message)

func (*GetDevListResponse) XXX_Size 

func (m *GetDevListResponse) XXX_Size() int

func (*GetDevListResponse) XXX_Unmarshal 

func (m *GetDevListResponse) XXX_Unmarshal(b []byte) error

type GetGatewayManageRequest 

type GetGatewayManageRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetGatewayManageRequest) Descriptor 

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

func (*GetGatewayManageRequest) ProtoMessage 

func (*GetGatewayManageRequest) ProtoMessage()

func (*GetGatewayManageRequest) Reset 

func (m *GetGatewayManageRequest) Reset()

func (*GetGatewayManageRequest) String 

func (m *GetGatewayManageRequest) String() string

func (*GetGatewayManageRequest) XXX_DiscardUnknown 

func (m *GetGatewayManageRequest) XXX_DiscardUnknown()

func (*GetGatewayManageRequest) XXX_Marshal 

func (m *GetGatewayManageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetGatewayManageRequest) XXX_Merge 

func (dst *GetGatewayManageRequest) XXX_Merge(src proto.Message)

func (*GetGatewayManageRequest) XXX_Size 

func (m *GetGatewayManageRequest) XXX_Size() int

func (*GetGatewayManageRequest) XXX_Unmarshal 

func (m *GetGatewayManageRequest) XXX_Unmarshal(b []byte) error

type GetGatewayManageResponse 

type GetGatewayManageResponse struct {
	ClientId             string   `protobuf:"bytes,1,opt,name=clientId,proto3" json:"clientId,omitempty"`
	ClientIp             string   `protobuf:"bytes,2,opt,name=clientIp,proto3" json:"clientIp,omitempty"`
	Netmask              string   `protobuf:"bytes,10,opt,name=netmask,proto3" json:"netmask,omitempty"`
	Gateway              string   `protobuf:"bytes,11,opt,name=gateway,proto3" json:"gateway,omitempty"`
	ServerIp             string   `protobuf:"bytes,3,opt,name=serverIp,proto3" json:"serverIp,omitempty"`
	ServerName           string   `protobuf:"bytes,4,opt,name=serverName,proto3" json:"serverName,omitempty"`
	ServerPort           string   `protobuf:"bytes,5,opt,name=serverPort,proto3" json:"serverPort,omitempty"`
	MqttUsername         string   `protobuf:"bytes,6,opt,name=mqttUsername,proto3" json:"mqttUsername,omitempty"`
	MqttPassword         string   `protobuf:"bytes,7,opt,name=mqttPassword,proto3" json:"mqttPassword,omitempty"`
	Interval             string   `protobuf:"bytes,8,opt,name=interval,proto3" json:"interval,omitempty"`
	MqttStatus           string   `protobuf:"bytes,9,opt,name=mqttStatus,proto3" json:"mqttStatus,omitempty"`
	Historydays          string   `protobuf:"bytes,12,opt,name=historydays,proto3" json:"historydays,omitempty"`
	SystemStat           string   `protobuf:"bytes,13,opt,name=systemStat,proto3" json:"systemStat,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetGatewayManageResponse) Descriptor 

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

func (*GetGatewayManageResponse) GetClientId 

func (m *GetGatewayManageResponse) GetClientId() string

func (*GetGatewayManageResponse) GetClientIp 

func (m *GetGatewayManageResponse) GetClientIp() string

func (*GetGatewayManageResponse) GetGateway 

func (m *GetGatewayManageResponse) GetGateway() string

func (*GetGatewayManageResponse) GetHistorydays 

func (m *GetGatewayManageResponse) GetHistorydays() string

func (*GetGatewayManageResponse) GetInterval 

func (m *GetGatewayManageResponse) GetInterval() string

func (*GetGatewayManageResponse) GetMqttPassword 

func (m *GetGatewayManageResponse) GetMqttPassword() string

func (*GetGatewayManageResponse) GetMqttStatus 

func (m *GetGatewayManageResponse) GetMqttStatus() string

func (*GetGatewayManageResponse) GetMqttUsername 

func (m *GetGatewayManageResponse) GetMqttUsername() string

func (*GetGatewayManageResponse) GetNetmask 

func (m *GetGatewayManageResponse) GetNetmask() string

func (*GetGatewayManageResponse) GetServerIp 

func (m *GetGatewayManageResponse) GetServerIp() string

func (*GetGatewayManageResponse) GetServerName 

func (m *GetGatewayManageResponse) GetServerName() string

func (*GetGatewayManageResponse) GetServerPort 

func (m *GetGatewayManageResponse) GetServerPort() string

func (*GetGatewayManageResponse) GetSystemStat 

func (m *GetGatewayManageResponse) GetSystemStat() string

func (*GetGatewayManageResponse) ProtoMessage 

func (*GetGatewayManageResponse) ProtoMessage()

func (*GetGatewayManageResponse) Reset 

func (m *GetGatewayManageResponse) Reset()

func (*GetGatewayManageResponse) String 

func (m *GetGatewayManageResponse) String() string

func (*GetGatewayManageResponse) XXX_DiscardUnknown 

func (m *GetGatewayManageResponse) XXX_DiscardUnknown()

func (*GetGatewayManageResponse) XXX_Marshal 

func (m *GetGatewayManageResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetGatewayManageResponse) XXX_Merge 

func (dst *GetGatewayManageResponse) XXX_Merge(src proto.Message)

func (*GetGatewayManageResponse) XXX_Size 

func (m *GetGatewayManageResponse) XXX_Size() int

func (*GetGatewayManageResponse) XXX_Unmarshal 

func (m *GetGatewayManageResponse) XXX_Unmarshal(b []byte) error

type GetSuppotRequest 

type GetSuppotRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetSuppotRequest) Descriptor 

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

func (*GetSuppotRequest) ProtoMessage 

func (*GetSuppotRequest) ProtoMessage()

func (*GetSuppotRequest) Reset 

func (m *GetSuppotRequest) Reset()

func (*GetSuppotRequest) String 

func (m *GetSuppotRequest) String() string

func (*GetSuppotRequest) XXX_DiscardUnknown 

func (m *GetSuppotRequest) XXX_DiscardUnknown()

func (*GetSuppotRequest) XXX_Marshal 

func (m *GetSuppotRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetSuppotRequest) XXX_Merge 

func (dst *GetSuppotRequest) XXX_Merge(src proto.Message)

func (*GetSuppotRequest) XXX_Size 

func (m *GetSuppotRequest) XXX_Size() int

func (*GetSuppotRequest) XXX_Unmarshal 

func (m *GetSuppotRequest) XXX_Unmarshal(b []byte) error

type GetSuppotResponse 

type GetSuppotResponse struct {
	Supportlist          []string `protobuf:"bytes,1,rep,name=supportlist,proto3" json:"supportlist,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetSuppotResponse) Descriptor 

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

func (*GetSuppotResponse) GetSupportlist 

func (m *GetSuppotResponse) GetSupportlist() []string

func (*GetSuppotResponse) ProtoMessage 

func (*GetSuppotResponse) ProtoMessage()

func (*GetSuppotResponse) Reset 

func (m *GetSuppotResponse) Reset()

func (*GetSuppotResponse) String 

func (m *GetSuppotResponse) String() string

func (*GetSuppotResponse) XXX_DiscardUnknown 

func (m *GetSuppotResponse) XXX_DiscardUnknown()

func (*GetSuppotResponse) XXX_Marshal 

func (m *GetSuppotResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetSuppotResponse) XXX_Merge 

func (dst *GetSuppotResponse) XXX_Merge(src proto.Message)

func (*GetSuppotResponse) XXX_Size 

func (m *GetSuppotResponse) XXX_Size() int

func (*GetSuppotResponse) XXX_Unmarshal 

func (m *GetSuppotResponse) XXX_Unmarshal(b []byte) error

type HistoryStuct 

type HistoryStuct struct {
	Cmdtype              string            `protobuf:"bytes,1,opt,name=cmdtype,proto3" json:"cmdtype,omitempty"`
	Timestamp            string            `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Value                map[string]string `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*HistoryStuct) Descriptor 

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

func (*HistoryStuct) GetCmdtype 

func (m *HistoryStuct) GetCmdtype() string

func (*HistoryStuct) GetTimestamp 

func (m *HistoryStuct) GetTimestamp() string

func (*HistoryStuct) GetValue 

func (m *HistoryStuct) GetValue() map[string]string

func (*HistoryStuct) ProtoMessage 

func (*HistoryStuct) ProtoMessage()

func (*HistoryStuct) Reset 

func (m *HistoryStuct) Reset()

func (*HistoryStuct) String 

func (m *HistoryStuct) String() string

func (*HistoryStuct) XXX_DiscardUnknown 

func (m *HistoryStuct) XXX_DiscardUnknown()

func (*HistoryStuct) XXX_Marshal 

func (m *HistoryStuct) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HistoryStuct) XXX_Merge 

func (dst *HistoryStuct) XXX_Merge(src proto.Message)

func (*HistoryStuct) XXX_Size 

func (m *HistoryStuct) XXX_Size() int

func (*HistoryStuct) XXX_Unmarshal 

func (m *HistoryStuct) XXX_Unmarshal(b []byte) error

type ModbusRtuClient 

type ModbusRtuClient interface {
	// 添加或更新ModbusRtu设备
	ModbusRtuUpdate(ctx context.Context, in *ModbusRtuUpdateRequest, opts ...grpc.CallOption) (*ModbusRtuUpdateResponse, error)
}

ModbusRtuClient is the client API for ModbusRtu service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewModbusRtuClient 

func NewModbusRtuClient(cc *grpc.ClientConn) ModbusRtuClient

type ModbusRtuServer 

type ModbusRtuServer interface {
	// 添加或更新ModbusRtu设备
	ModbusRtuUpdate(context.Context, *ModbusRtuUpdateRequest) (*ModbusRtuUpdateResponse, error)
}

ModbusRtuServer is the server API for ModbusRtu service.

type ModbusRtuUpdateRequest 

type ModbusRtuUpdateRequest struct {
	Devid                string   `protobuf:"bytes,1,opt,name=devid,proto3" json:"devid,omitempty"`
	Devaddr              string   `protobuf:"bytes,3,opt,name=devaddr,proto3" json:"devaddr,omitempty"`
	Commif               string   `protobuf:"bytes,4,opt,name=commif,proto3" json:"commif,omitempty"`
	BaudRate             uint32   `protobuf:"varint,5,opt,name=baudRate,proto3" json:"baudRate,omitempty"`
	DataBits             uint32   `protobuf:"varint,6,opt,name=dataBits,proto3" json:"dataBits,omitempty"`
	StopBits             uint32   `protobuf:"varint,7,opt,name=stopBits,proto3" json:"stopBits,omitempty"`
	Parity               string   `protobuf:"bytes,8,opt,name=parity,proto3" json:"parity,omitempty"`
	FunctionCode         uint32   `protobuf:"varint,9,opt,name=functionCode,proto3" json:"functionCode,omitempty"`
	StartingAddress      uint32   `protobuf:"varint,10,opt,name=startingAddress,proto3" json:"startingAddress,omitempty"`
	Quantity             uint32   `protobuf:"varint,11,opt,name=quantity,proto3" json:"quantity,omitempty"`
	Dname                string   `protobuf:"bytes,12,opt,name=dname,proto3" json:"dname,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ModbusRtuUpdateRequest) Descriptor 

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

func (*ModbusRtuUpdateRequest) GetBaudRate 

func (m *ModbusRtuUpdateRequest) GetBaudRate() uint32

func (*ModbusRtuUpdateRequest) GetCommif 

func (m *ModbusRtuUpdateRequest) GetCommif() string

func (*ModbusRtuUpdateRequest) GetDataBits 

func (m *ModbusRtuUpdateRequest) GetDataBits() uint32

func (*ModbusRtuUpdateRequest) GetDevaddr 

func (m *ModbusRtuUpdateRequest) GetDevaddr() string

func (*ModbusRtuUpdateRequest) GetDevid 

func (m *ModbusRtuUpdateRequest) GetDevid() string

func (*ModbusRtuUpdateRequest) GetDname 

func (m *ModbusRtuUpdateRequest) GetDname() string

func (*ModbusRtuUpdateRequest) GetFunctionCode 

func (m *ModbusRtuUpdateRequest) GetFunctionCode() uint32

func (*ModbusRtuUpdateRequest) GetParity 

func (m *ModbusRtuUpdateRequest) GetParity() string

func (*ModbusRtuUpdateRequest) GetQuantity 

func (m *ModbusRtuUpdateRequest) GetQuantity() uint32

func (*ModbusRtuUpdateRequest) GetStartingAddress 

func (m *ModbusRtuUpdateRequest) GetStartingAddress() uint32

func (*ModbusRtuUpdateRequest) GetStopBits 

func (m *ModbusRtuUpdateRequest) GetStopBits() uint32

func (*ModbusRtuUpdateRequest) ProtoMessage 

func (*ModbusRtuUpdateRequest) ProtoMessage()

func (*ModbusRtuUpdateRequest) Reset 

func (m *ModbusRtuUpdateRequest) Reset()

func (*ModbusRtuUpdateRequest) String 

func (m *ModbusRtuUpdateRequest) String() string

func (*ModbusRtuUpdateRequest) XXX_DiscardUnknown 

func (m *ModbusRtuUpdateRequest) XXX_DiscardUnknown()

func (*ModbusRtuUpdateRequest) XXX_Marshal 

func (m *ModbusRtuUpdateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ModbusRtuUpdateRequest) XXX_Merge 

func (dst *ModbusRtuUpdateRequest) XXX_Merge(src proto.Message)

func (*ModbusRtuUpdateRequest) XXX_Size 

func (m *ModbusRtuUpdateRequest) XXX_Size() int

func (*ModbusRtuUpdateRequest) XXX_Unmarshal 

func (m *ModbusRtuUpdateRequest) XXX_Unmarshal(b []byte) error

type ModbusRtuUpdateResponse 

type ModbusRtuUpdateResponse struct {
	Result               string   `protobuf:"bytes,1,opt,name=Result,proto3" json:"Result,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ModbusRtuUpdateResponse) Descriptor 

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

func (*ModbusRtuUpdateResponse) GetResult 

func (m *ModbusRtuUpdateResponse) GetResult() string

func (*ModbusRtuUpdateResponse) ProtoMessage 

func (*ModbusRtuUpdateResponse) ProtoMessage()

func (*ModbusRtuUpdateResponse) Reset 

func (m *ModbusRtuUpdateResponse) Reset()

func (*ModbusRtuUpdateResponse) String 

func (m *ModbusRtuUpdateResponse) String() string

func (*ModbusRtuUpdateResponse) XXX_DiscardUnknown 

func (m *ModbusRtuUpdateResponse) XXX_DiscardUnknown()

func (*ModbusRtuUpdateResponse) XXX_Marshal 

func (m *ModbusRtuUpdateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ModbusRtuUpdateResponse) XXX_Merge 

func (dst *ModbusRtuUpdateResponse) XXX_Merge(src proto.Message)

func (*ModbusRtuUpdateResponse) XXX_Size 

func (m *ModbusRtuUpdateResponse) XXX_Size() int

func (*ModbusRtuUpdateResponse) XXX_Unmarshal 

func (m *ModbusRtuUpdateResponse) XXX_Unmarshal(b []byte) error

type ModbusTcpClient 

type ModbusTcpClient interface {
	// 添加或更新ModbusTcp设备
	ModbusTCPUpdate(ctx context.Context, in *ModbusTcpUpdateRequest, opts ...grpc.CallOption) (*ModbusTcpUpdateResponse, error)
}

ModbusTcpClient is the client API for ModbusTcp service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewModbusTcpClient 

func NewModbusTcpClient(cc *grpc.ClientConn) ModbusTcpClient

type ModbusTcpServer 

type ModbusTcpServer interface {
	// 添加或更新ModbusTcp设备
	ModbusTCPUpdate(context.Context, *ModbusTcpUpdateRequest) (*ModbusTcpUpdateResponse, error)
}

ModbusTcpServer is the server API for ModbusTcp service.

type ModbusTcpUpdateRequest 

type ModbusTcpUpdateRequest struct {
	Devid                string   `protobuf:"bytes,1,opt,name=devid,proto3" json:"devid,omitempty"`
	Devaddr              string   `protobuf:"bytes,3,opt,name=devaddr,proto3" json:"devaddr,omitempty"`
	Commif               string   `protobuf:"bytes,4,opt,name=commif,proto3" json:"commif,omitempty"`
	FunctionCode         uint32   `protobuf:"varint,9,opt,name=functionCode,proto3" json:"functionCode,omitempty"`
	StartingAddress      uint32   `protobuf:"varint,10,opt,name=startingAddress,proto3" json:"startingAddress,omitempty"`
	Quantity             uint32   `protobuf:"varint,11,opt,name=quantity,proto3" json:"quantity,omitempty"`
	Dname                string   `protobuf:"bytes,12,opt,name=dname,proto3" json:"dname,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ModbusTcpUpdateRequest) Descriptor 

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

func (*ModbusTcpUpdateRequest) GetCommif 

func (m *ModbusTcpUpdateRequest) GetCommif() string

func (*ModbusTcpUpdateRequest) GetDevaddr 

func (m *ModbusTcpUpdateRequest) GetDevaddr() string

func (*ModbusTcpUpdateRequest) GetDevid 

func (m *ModbusTcpUpdateRequest) GetDevid() string

func (*ModbusTcpUpdateRequest) GetDname 

func (m *ModbusTcpUpdateRequest) GetDname() string

func (*ModbusTcpUpdateRequest) GetFunctionCode 

func (m *ModbusTcpUpdateRequest) GetFunctionCode() uint32

func (*ModbusTcpUpdateRequest) GetQuantity 

func (m *ModbusTcpUpdateRequest) GetQuantity() uint32

func (*ModbusTcpUpdateRequest) GetStartingAddress 

func (m *ModbusTcpUpdateRequest) GetStartingAddress() uint32

func (*ModbusTcpUpdateRequest) ProtoMessage 

func (*ModbusTcpUpdateRequest) ProtoMessage()

func (*ModbusTcpUpdateRequest) Reset 

func (m *ModbusTcpUpdateRequest) Reset()

func (*ModbusTcpUpdateRequest) String 

func (m *ModbusTcpUpdateRequest) String() string

func (*ModbusTcpUpdateRequest) XXX_DiscardUnknown 

func (m *ModbusTcpUpdateRequest) XXX_DiscardUnknown()

func (*ModbusTcpUpdateRequest) XXX_Marshal 

func (m *ModbusTcpUpdateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ModbusTcpUpdateRequest) XXX_Merge 

func (dst *ModbusTcpUpdateRequest) XXX_Merge(src proto.Message)

func (*ModbusTcpUpdateRequest) XXX_Size 

func (m *ModbusTcpUpdateRequest) XXX_Size() int

func (*ModbusTcpUpdateRequest) XXX_Unmarshal 

func (m *ModbusTcpUpdateRequest) XXX_Unmarshal(b []byte) error

type ModbusTcpUpdateResponse 

type ModbusTcpUpdateResponse struct {
	Result               string   `protobuf:"bytes,1,opt,name=Result,proto3" json:"Result,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ModbusTcpUpdateResponse) Descriptor 

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

func (*ModbusTcpUpdateResponse) GetResult 

func (m *ModbusTcpUpdateResponse) GetResult() string

func (*ModbusTcpUpdateResponse) ProtoMessage 

func (*ModbusTcpUpdateResponse) ProtoMessage()

func (*ModbusTcpUpdateResponse) Reset 

func (m *ModbusTcpUpdateResponse) Reset()

func (*ModbusTcpUpdateResponse) String 

func (m *ModbusTcpUpdateResponse) String() string

func (*ModbusTcpUpdateResponse) XXX_DiscardUnknown 

func (m *ModbusTcpUpdateResponse) XXX_DiscardUnknown()

func (*ModbusTcpUpdateResponse) XXX_Marshal 

func (m *ModbusTcpUpdateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ModbusTcpUpdateResponse) XXX_Merge 

func (dst *ModbusTcpUpdateResponse) XXX_Merge(src proto.Message)

func (*ModbusTcpUpdateResponse) XXX_Size 

func (m *ModbusTcpUpdateResponse) XXX_Size() int

func (*ModbusTcpUpdateResponse) XXX_Unmarshal 

func (m *ModbusTcpUpdateResponse) XXX_Unmarshal(b []byte) error

type ModifyUserPwRequest 

type ModifyUserPwRequest struct {
	Username             string   `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password             string   `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ModifyUserPwRequest) Descriptor 

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

func (*ModifyUserPwRequest) GetPassword 

func (m *ModifyUserPwRequest) GetPassword() string

func (*ModifyUserPwRequest) GetUsername 

func (m *ModifyUserPwRequest) GetUsername() string

func (*ModifyUserPwRequest) ProtoMessage 

func (*ModifyUserPwRequest) ProtoMessage()

func (*ModifyUserPwRequest) Reset 

func (m *ModifyUserPwRequest) Reset()

func (*ModifyUserPwRequest) String 

func (m *ModifyUserPwRequest) String() string

func (*ModifyUserPwRequest) XXX_DiscardUnknown 

func (m *ModifyUserPwRequest) XXX_DiscardUnknown()

func (*ModifyUserPwRequest) XXX_Marshal 

func (m *ModifyUserPwRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ModifyUserPwRequest) XXX_Merge 

func (dst *ModifyUserPwRequest) XXX_Merge(src proto.Message)

func (*ModifyUserPwRequest) XXX_Size 

func (m *ModifyUserPwRequest) XXX_Size() int

func (*ModifyUserPwRequest) XXX_Unmarshal 

func (m *ModifyUserPwRequest) XXX_Unmarshal(b []byte) error

type ModifyUserPwResponse 

type ModifyUserPwResponse struct {
	Result               string   `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ModifyUserPwResponse) Descriptor 

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

func (*ModifyUserPwResponse) GetResult 

func (m *ModifyUserPwResponse) GetResult() string

func (*ModifyUserPwResponse) ProtoMessage 

func (*ModifyUserPwResponse) ProtoMessage()

func (*ModifyUserPwResponse) Reset 

func (m *ModifyUserPwResponse) Reset()

func (*ModifyUserPwResponse) String 

func (m *ModifyUserPwResponse) String() string

func (*ModifyUserPwResponse) XXX_DiscardUnknown 

func (m *ModifyUserPwResponse) XXX_DiscardUnknown()

func (*ModifyUserPwResponse) XXX_Marshal 

func (m *ModifyUserPwResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ModifyUserPwResponse) XXX_Merge 

func (dst *ModifyUserPwResponse) XXX_Merge(src proto.Message)

func (*ModifyUserPwResponse) XXX_Size 

func (m *ModifyUserPwResponse) XXX_Size() int

func (*ModifyUserPwResponse) XXX_Unmarshal 

func (m *ModifyUserPwResponse) XXX_Unmarshal(b []byte) error

type SetGatewayManageRequest 

type SetGatewayManageRequest struct {
	// string clientId=1;
	ClientIp             string   `protobuf:"bytes,2,opt,name=clientIp,proto3" json:"clientIp,omitempty"`
	Inet                 string   `protobuf:"bytes,8,opt,name=inet,proto3" json:"inet,omitempty"`
	Netmask              string   `protobuf:"bytes,9,opt,name=netmask,proto3" json:"netmask,omitempty"`
	Gateway              string   `protobuf:"bytes,10,opt,name=gateway,proto3" json:"gateway,omitempty"`
	ServerIp             string   `protobuf:"bytes,3,opt,name=serverIp,proto3" json:"serverIp,omitempty"`
	ServerName           string   `protobuf:"bytes,4,opt,name=serverName,proto3" json:"serverName,omitempty"`
	ServerPort           string   `protobuf:"bytes,5,opt,name=serverPort,proto3" json:"serverPort,omitempty"`
	MqttUsername         string   `protobuf:"bytes,6,opt,name=mqttUsername,proto3" json:"mqttUsername,omitempty"`
	MqttPassword         string   `protobuf:"bytes,7,opt,name=mqttPassword,proto3" json:"mqttPassword,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetGatewayManageRequest) Descriptor 

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

func (*SetGatewayManageRequest) GetClientIp 

func (m *SetGatewayManageRequest) GetClientIp() string

func (*SetGatewayManageRequest) GetGateway 

func (m *SetGatewayManageRequest) GetGateway() string

func (*SetGatewayManageRequest) GetInet 

func (m *SetGatewayManageRequest) GetInet() string

func (*SetGatewayManageRequest) GetMqttPassword 

func (m *SetGatewayManageRequest) GetMqttPassword() string

func (*SetGatewayManageRequest) GetMqttUsername 

func (m *SetGatewayManageRequest) GetMqttUsername() string

func (*SetGatewayManageRequest) GetNetmask 

func (m *SetGatewayManageRequest) GetNetmask() string

func (*SetGatewayManageRequest) GetServerIp 

func (m *SetGatewayManageRequest) GetServerIp() string

func (*SetGatewayManageRequest) GetServerName 

func (m *SetGatewayManageRequest) GetServerName() string

func (*SetGatewayManageRequest) GetServerPort 

func (m *SetGatewayManageRequest) GetServerPort() string

func (*SetGatewayManageRequest) ProtoMessage 

func (*SetGatewayManageRequest) ProtoMessage()

func (*SetGatewayManageRequest) Reset 

func (m *SetGatewayManageRequest) Reset()

func (*SetGatewayManageRequest) String 

func (m *SetGatewayManageRequest) String() string

func (*SetGatewayManageRequest) XXX_DiscardUnknown 

func (m *SetGatewayManageRequest) XXX_DiscardUnknown()

func (*SetGatewayManageRequest) XXX_Marshal 

func (m *SetGatewayManageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetGatewayManageRequest) XXX_Merge 

func (dst *SetGatewayManageRequest) XXX_Merge(src proto.Message)

func (*SetGatewayManageRequest) XXX_Size 

func (m *SetGatewayManageRequest) XXX_Size() int

func (*SetGatewayManageRequest) XXX_Unmarshal 

func (m *SetGatewayManageRequest) XXX_Unmarshal(b []byte) error

type SetGatewayManageResponse 

type SetGatewayManageResponse struct {
	Result               string   `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetGatewayManageResponse) Descriptor 

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

func (*SetGatewayManageResponse) GetResult 

func (m *SetGatewayManageResponse) GetResult() string

func (*SetGatewayManageResponse) ProtoMessage 

func (*SetGatewayManageResponse) ProtoMessage()

func (*SetGatewayManageResponse) Reset 

func (m *SetGatewayManageResponse) Reset()

func (*SetGatewayManageResponse) String 

func (m *SetGatewayManageResponse) String() string

func (*SetGatewayManageResponse) XXX_DiscardUnknown 

func (m *SetGatewayManageResponse) XXX_DiscardUnknown()

func (*SetGatewayManageResponse) XXX_Marshal 

func (m *SetGatewayManageResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetGatewayManageResponse) XXX_Merge 

func (dst *SetGatewayManageResponse) XXX_Merge(src proto.Message)

func (*SetGatewayManageResponse) XXX_Size 

func (m *SetGatewayManageResponse) XXX_Size() int

func (*SetGatewayManageResponse) XXX_Unmarshal 

func (m *SetGatewayManageResponse) XXX_Unmarshal(b []byte) error

type SetIntervalRequest 

type SetIntervalRequest struct {
	Interval             int32    `protobuf:"varint,1,opt,name=interval,proto3" json:"interval,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetIntervalRequest) Descriptor 

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

func (*SetIntervalRequest) GetInterval 

func (m *SetIntervalRequest) GetInterval() int32

func (*SetIntervalRequest) ProtoMessage 

func (*SetIntervalRequest) ProtoMessage()

func (*SetIntervalRequest) Reset 

func (m *SetIntervalRequest) Reset()

func (*SetIntervalRequest) String 

func (m *SetIntervalRequest) String() string

func (*SetIntervalRequest) XXX_DiscardUnknown 

func (m *SetIntervalRequest) XXX_DiscardUnknown()

func (*SetIntervalRequest) XXX_Marshal 

func (m *SetIntervalRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetIntervalRequest) XXX_Merge 

func (dst *SetIntervalRequest) XXX_Merge(src proto.Message)

func (*SetIntervalRequest) XXX_Size 

func (m *SetIntervalRequest) XXX_Size() int

func (*SetIntervalRequest) XXX_Unmarshal 

func (m *SetIntervalRequest) XXX_Unmarshal(b []byte) error

type SetIntervalResponse 

type SetIntervalResponse struct {
	Result               string   `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetIntervalResponse) Descriptor 

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

func (*SetIntervalResponse) GetResult 

func (m *SetIntervalResponse) GetResult() string

func (*SetIntervalResponse) ProtoMessage 

func (*SetIntervalResponse) ProtoMessage()

func (*SetIntervalResponse) Reset 

func (m *SetIntervalResponse) Reset()

func (*SetIntervalResponse) String 

func (m *SetIntervalResponse) String() string

func (*SetIntervalResponse) XXX_DiscardUnknown 

func (m *SetIntervalResponse) XXX_DiscardUnknown()

func (*SetIntervalResponse) XXX_Marshal 

func (m *SetIntervalResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetIntervalResponse) XXX_Merge 

func (dst *SetIntervalResponse) XXX_Merge(src proto.Message)

func (*SetIntervalResponse) XXX_Size 

func (m *SetIntervalResponse) XXX_Size() int

func (*SetIntervalResponse) XXX_Unmarshal 

func (m *SetIntervalResponse) XXX_Unmarshal(b []byte) error

type SetTLSConfigRequest 

type SetTLSConfigRequest struct {
	Cafile               string   `protobuf:"bytes,1,opt,name=cafile,proto3" json:"cafile,omitempty"`
	Certfile             string   `protobuf:"bytes,2,opt,name=certfile,proto3" json:"certfile,omitempty"`
	Keyfile              string   `protobuf:"bytes,3,opt,name=keyfile,proto3" json:"keyfile,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetTLSConfigRequest) Descriptor 

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

func (*SetTLSConfigRequest) GetCafile 

func (m *SetTLSConfigRequest) GetCafile() string

func (*SetTLSConfigRequest) GetCertfile 

func (m *SetTLSConfigRequest) GetCertfile() string

func (*SetTLSConfigRequest) GetKeyfile 

func (m *SetTLSConfigRequest) GetKeyfile() string

func (*SetTLSConfigRequest) ProtoMessage 

func (*SetTLSConfigRequest) ProtoMessage()

func (*SetTLSConfigRequest) Reset 

func (m *SetTLSConfigRequest) Reset()

func (*SetTLSConfigRequest) String 

func (m *SetTLSConfigRequest) String() string

func (*SetTLSConfigRequest) XXX_DiscardUnknown 

func (m *SetTLSConfigRequest) XXX_DiscardUnknown()

func (*SetTLSConfigRequest) XXX_Marshal 

func (m *SetTLSConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetTLSConfigRequest) XXX_Merge 

func (dst *SetTLSConfigRequest) XXX_Merge(src proto.Message)

func (*SetTLSConfigRequest) XXX_Size 

func (m *SetTLSConfigRequest) XXX_Size() int

func (*SetTLSConfigRequest) XXX_Unmarshal 

func (m *SetTLSConfigRequest) XXX_Unmarshal(b []byte) error

type SetTLSConfigResponse 

type SetTLSConfigResponse struct {
	Result               string   `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetTLSConfigResponse) Descriptor 

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

func (*SetTLSConfigResponse) GetResult 

func (m *SetTLSConfigResponse) GetResult() string

func (*SetTLSConfigResponse) ProtoMessage 

func (*SetTLSConfigResponse) ProtoMessage()

func (*SetTLSConfigResponse) Reset 

func (m *SetTLSConfigResponse) Reset()

func (*SetTLSConfigResponse) String 

func (m *SetTLSConfigResponse) String() string

func (*SetTLSConfigResponse) XXX_DiscardUnknown 

func (m *SetTLSConfigResponse) XXX_DiscardUnknown()

func (*SetTLSConfigResponse) XXX_Marshal 

func (m *SetTLSConfigResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetTLSConfigResponse) XXX_Merge 

func (dst *SetTLSConfigResponse) XXX_Merge(src proto.Message)

func (*SetTLSConfigResponse) XXX_Size 

func (m *SetTLSConfigResponse) XXX_Size() int

func (*SetTLSConfigResponse) XXX_Unmarshal 

func (m *SetTLSConfigResponse) XXX_Unmarshal(b []byte) error

type TC100R8Client 

type TC100R8Client interface {
	// 添加或更新TC100R8控制器
	TcozzreUpdate(ctx context.Context, in *TcozzreUpdateRequest, opts ...grpc.CallOption) (*TcozzreUpdateResponse, error)
}

TC100R8Client is the client API for TC100R8 service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewTC100R8Client 

func NewTC100R8Client(cc *grpc.ClientConn) TC100R8Client

type TC100R8Server 

type TC100R8Server interface {
	// 添加或更新TC100R8控制器
	TcozzreUpdate(context.Context, *TcozzreUpdateRequest) (*TcozzreUpdateResponse, error)
}

TC100R8Server is the server API for TC100R8 service.

type TcozzreUpdateRequest 

type TcozzreUpdateRequest struct {
	Devid                string   `protobuf:"bytes,1,opt,name=devid,proto3" json:"devid,omitempty"`
	Devaddr              string   `protobuf:"bytes,3,opt,name=devaddr,proto3" json:"devaddr,omitempty"`
	Commif               string   `protobuf:"bytes,4,opt,name=commif,proto3" json:"commif,omitempty"`
	Dname                string   `protobuf:"bytes,5,opt,name=dname,proto3" json:"dname,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TcozzreUpdateRequest) Descriptor 

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

func (*TcozzreUpdateRequest) GetCommif 

func (m *TcozzreUpdateRequest) GetCommif() string

func (*TcozzreUpdateRequest) GetDevaddr 

func (m *TcozzreUpdateRequest) GetDevaddr() string

func (*TcozzreUpdateRequest) GetDevid 

func (m *TcozzreUpdateRequest) GetDevid() string

func (*TcozzreUpdateRequest) GetDname 

func (m *TcozzreUpdateRequest) GetDname() string

func (*TcozzreUpdateRequest) ProtoMessage 

func (*TcozzreUpdateRequest) ProtoMessage()

func (*TcozzreUpdateRequest) Reset 

func (m *TcozzreUpdateRequest) Reset()

func (*TcozzreUpdateRequest) String 

func (m *TcozzreUpdateRequest) String() string

func (*TcozzreUpdateRequest) XXX_DiscardUnknown 

func (m *TcozzreUpdateRequest) XXX_DiscardUnknown()

func (*TcozzreUpdateRequest) XXX_Marshal 

func (m *TcozzreUpdateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TcozzreUpdateRequest) XXX_Merge 

func (dst *TcozzreUpdateRequest) XXX_Merge(src proto.Message)

func (*TcozzreUpdateRequest) XXX_Size 

func (m *TcozzreUpdateRequest) XXX_Size() int

func (*TcozzreUpdateRequest) XXX_Unmarshal 

func (m *TcozzreUpdateRequest) XXX_Unmarshal(b []byte) error

type TcozzreUpdateResponse 

type TcozzreUpdateResponse struct {
	Result               string   `protobuf:"bytes,1,opt,name=Result,proto3" json:"Result,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TcozzreUpdateResponse) Descriptor 

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

func (*TcozzreUpdateResponse) GetResult 

func (m *TcozzreUpdateResponse) GetResult() string

func (*TcozzreUpdateResponse) ProtoMessage 

func (*TcozzreUpdateResponse) ProtoMessage()

func (*TcozzreUpdateResponse) Reset 

func (m *TcozzreUpdateResponse) Reset()

func (*TcozzreUpdateResponse) String 

func (m *TcozzreUpdateResponse) String() string

func (*TcozzreUpdateResponse) XXX_DiscardUnknown 

func (m *TcozzreUpdateResponse) XXX_DiscardUnknown()

func (*TcozzreUpdateResponse) XXX_Marshal 

func (m *TcozzreUpdateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TcozzreUpdateResponse) XXX_Merge 

func (dst *TcozzreUpdateResponse) XXX_Merge(src proto.Message)

func (*TcozzreUpdateResponse) XXX_Size 

func (m *TcozzreUpdateResponse) XXX_Size() int

func (*TcozzreUpdateResponse) XXX_Unmarshal 

func (m *TcozzreUpdateResponse) XXX_Unmarshal(b []byte) error

type UpdateGatewaySystemRequest 

type UpdateGatewaySystemRequest struct {
	Url                  string   `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateGatewaySystemRequest) Descriptor 

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

func (*UpdateGatewaySystemRequest) GetUrl 

func (m *UpdateGatewaySystemRequest) GetUrl() string

func (*UpdateGatewaySystemRequest) ProtoMessage 

func (*UpdateGatewaySystemRequest) ProtoMessage()

func (*UpdateGatewaySystemRequest) Reset 

func (m *UpdateGatewaySystemRequest) Reset()

func (*UpdateGatewaySystemRequest) String 

func (m *UpdateGatewaySystemRequest) String() string

func (*UpdateGatewaySystemRequest) XXX_DiscardUnknown 

func (m *UpdateGatewaySystemRequest) XXX_DiscardUnknown()

func (*UpdateGatewaySystemRequest) XXX_Marshal 

func (m *UpdateGatewaySystemRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateGatewaySystemRequest) XXX_Merge 

func (dst *UpdateGatewaySystemRequest) XXX_Merge(src proto.Message)

func (*UpdateGatewaySystemRequest) XXX_Size 

func (m *UpdateGatewaySystemRequest) XXX_Size() int

func (*UpdateGatewaySystemRequest) XXX_Unmarshal 

func (m *UpdateGatewaySystemRequest) XXX_Unmarshal(b []byte) error

type UpdateGatewaySystemResponse 

type UpdateGatewaySystemResponse struct {
	Result               string   `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateGatewaySystemResponse) Descriptor 

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

func (*UpdateGatewaySystemResponse) GetResult 

func (m *UpdateGatewaySystemResponse) GetResult() string

func (*UpdateGatewaySystemResponse) ProtoMessage 

func (*UpdateGatewaySystemResponse) ProtoMessage()

func (*UpdateGatewaySystemResponse) Reset 

func (m *UpdateGatewaySystemResponse) Reset()

func (*UpdateGatewaySystemResponse) String 

func (m *UpdateGatewaySystemResponse) String() string

func (*UpdateGatewaySystemResponse) XXX_DiscardUnknown 

func (m *UpdateGatewaySystemResponse) XXX_DiscardUnknown()

func (*UpdateGatewaySystemResponse) XXX_Marshal 

func (m *UpdateGatewaySystemResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateGatewaySystemResponse) XXX_Merge 

func (dst *UpdateGatewaySystemResponse) XXX_Merge(src proto.Message)

func (*UpdateGatewaySystemResponse) XXX_Size 

func (m *UpdateGatewaySystemResponse) XXX_Size() int

func (*UpdateGatewaySystemResponse) XXX_Unmarshal 

func (m *UpdateGatewaySystemResponse) XXX_Unmarshal(b []byte) error

type WaterMeterClient 

type WaterMeterClient interface {
	// 添加或更新水表设备
	WaterMeterUpdate(ctx context.Context, in *WaterMeterUpdateRequest, opts ...grpc.CallOption) (*WaterMeterUpdateResponse, error)
}

WaterMeterClient is the client API for WaterMeter service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewWaterMeterClient 

func NewWaterMeterClient(cc *grpc.ClientConn) WaterMeterClient

type WaterMeterServer 

type WaterMeterServer interface {
	// 添加或更新水表设备
	WaterMeterUpdate(context.Context, *WaterMeterUpdateRequest) (*WaterMeterUpdateResponse, error)
}

WaterMeterServer is the server API for WaterMeter service.

type WaterMeterUpdateRequest 

type WaterMeterUpdateRequest struct {
	Devid                string   `protobuf:"bytes,1,opt,name=devid,proto3" json:"devid,omitempty"`
	Devtype              string   `protobuf:"bytes,2,opt,name=devtype,proto3" json:"devtype,omitempty"`
	Devaddr              string   `protobuf:"bytes,3,opt,name=devaddr,proto3" json:"devaddr,omitempty"`
	Commif               string   `protobuf:"bytes,4,opt,name=commif,proto3" json:"commif,omitempty"`
	Fcode                string   `protobuf:"bytes,5,opt,name=fcode,proto3" json:"fcode,omitempty"`
	Dname                string   `protobuf:"bytes,6,opt,name=dname,proto3" json:"dname,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WaterMeterUpdateRequest) Descriptor 

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

func (*WaterMeterUpdateRequest) GetCommif 

func (m *WaterMeterUpdateRequest) GetCommif() string

func (*WaterMeterUpdateRequest) GetDevaddr 

func (m *WaterMeterUpdateRequest) GetDevaddr() string

func (*WaterMeterUpdateRequest) GetDevid 

func (m *WaterMeterUpdateRequest) GetDevid() string

func (*WaterMeterUpdateRequest) GetDevtype 

func (m *WaterMeterUpdateRequest) GetDevtype() string

func (*WaterMeterUpdateRequest) GetDname 

func (m *WaterMeterUpdateRequest) GetDname() string

func (*WaterMeterUpdateRequest) GetFcode 

func (m *WaterMeterUpdateRequest) GetFcode() string

func (*WaterMeterUpdateRequest) ProtoMessage 

func (*WaterMeterUpdateRequest) ProtoMessage()

func (*WaterMeterUpdateRequest) Reset 

func (m *WaterMeterUpdateRequest) Reset()

func (*WaterMeterUpdateRequest) String 

func (m *WaterMeterUpdateRequest) String() string

func (*WaterMeterUpdateRequest) XXX_DiscardUnknown 

func (m *WaterMeterUpdateRequest) XXX_DiscardUnknown()

func (*WaterMeterUpdateRequest) XXX_Marshal 

func (m *WaterMeterUpdateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WaterMeterUpdateRequest) XXX_Merge 

func (dst *WaterMeterUpdateRequest) XXX_Merge(src proto.Message)

func (*WaterMeterUpdateRequest) XXX_Size 

func (m *WaterMeterUpdateRequest) XXX_Size() int

func (*WaterMeterUpdateRequest) XXX_Unmarshal 

func (m *WaterMeterUpdateRequest) XXX_Unmarshal(b []byte) error

type WaterMeterUpdateResponse 

type WaterMeterUpdateResponse struct {
	Result               string   `protobuf:"bytes,1,opt,name=Result,proto3" json:"Result,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WaterMeterUpdateResponse) Descriptor 

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

func (*WaterMeterUpdateResponse) GetResult 

func (m *WaterMeterUpdateResponse) GetResult() string

func (*WaterMeterUpdateResponse) ProtoMessage 

func (*WaterMeterUpdateResponse) ProtoMessage()

func (*WaterMeterUpdateResponse) Reset 

func (m *WaterMeterUpdateResponse) Reset()

func (*WaterMeterUpdateResponse) String 

func (m *WaterMeterUpdateResponse) String() string

func (*WaterMeterUpdateResponse) XXX_DiscardUnknown 

func (m *WaterMeterUpdateResponse) XXX_DiscardUnknown()

func (*WaterMeterUpdateResponse) XXX_Marshal 

func (m *WaterMeterUpdateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WaterMeterUpdateResponse) XXX_Merge 

func (dst *WaterMeterUpdateResponse) XXX_Merge(src proto.Message)

func (*WaterMeterUpdateResponse) XXX_Size 

func (m *WaterMeterUpdateResponse) XXX_Size() int

func (*WaterMeterUpdateResponse) XXX_Unmarshal 

func (m *WaterMeterUpdateResponse) XXX_Unmarshal(b []byte) error

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.