Documentation ¶
Index ¶
- Variables
- func NewOpcServiceEndpoints() []*api.Endpoint
- func RegisterOpcServiceHandler(s server.Server, hdlr OpcServiceHandler, opts ...server.HandlerOption) error
- type FileReq
- type Group
- type Groups
- type GrpQuery
- type GrpReq
- type Item
- func (*Item) Descriptor() ([]byte, []int)deprecated
- func (x *Item) GetAddress() string
- func (x *Item) GetClientAccess() string
- func (x *Item) GetDatatype() string
- func (x *Item) GetGroupID() uint32
- func (x *Item) GetItemID() uint32
- func (x *Item) GetName() string
- func (x *Item) GetRespectDataType() uint32
- func (x *Item) GetScanRate() uint32
- func (*Item) ProtoMessage()
- func (x *Item) ProtoReflect() protoreflect.Message
- func (x *Item) Reset()
- func (x *Item) String() string
- type ItemFilter
- func (*ItemFilter) Descriptor() ([]byte, []int)deprecated
- func (x *ItemFilter) GetAddressLike() []string
- func (x *ItemFilter) GetAnd() []*ItemFilter
- func (x *ItemFilter) GetGroupIn() []uint32
- func (x *ItemFilter) GetItemIn() []uint32
- func (x *ItemFilter) GetNameLike() []string
- func (x *ItemFilter) GetOr() []*ItemFilter
- func (*ItemFilter) ProtoMessage()
- func (x *ItemFilter) ProtoReflect() protoreflect.Message
- func (x *ItemFilter) Reset()
- func (x *ItemFilter) String() string
- type ItemQuery
- func (*ItemQuery) Descriptor() ([]byte, []int)deprecated
- func (x *ItemQuery) GetFilter() *ItemFilter
- func (x *ItemQuery) GetPage() uint32
- func (x *ItemQuery) GetPerPage() uint32
- func (*ItemQuery) ProtoMessage()
- func (x *ItemQuery) ProtoReflect() protoreflect.Message
- func (x *ItemQuery) Reset()
- func (x *ItemQuery) String() string
- type ItemReq
- type ItemValueReq
- func (*ItemValueReq) Descriptor() ([]byte, []int)deprecated
- func (x *ItemValueReq) GetGroupID() uint32
- func (x *ItemValueReq) GetItemID() uint32
- func (x *ItemValueReq) GetValue() int32
- func (*ItemValueReq) ProtoMessage()
- func (x *ItemValueReq) ProtoReflect() protoreflect.Message
- func (x *ItemValueReq) Reset()
- func (x *ItemValueReq) String() string
- type ItemValueResp
- func (*ItemValueResp) Descriptor() ([]byte, []int)deprecated
- func (x *ItemValueResp) GetQuality() bool
- func (x *ItemValueResp) GetValue() int32
- func (*ItemValueResp) ProtoMessage()
- func (x *ItemValueResp) ProtoReflect() protoreflect.Message
- func (x *ItemValueResp) Reset()
- func (x *ItemValueResp) String() string
- type Items
- type LogLevelRequest
- type LogResponse
- type Loglevel
- type OpcService
- type OpcServiceHandler
- type Response
- type Server
- type Servers
- type SrvQuery
- type SrvReq
Constants ¶
This section is empty.
Variables ¶
View Source
var File_proto_opc_opc_proto protoreflect.FileDescriptor
Functions ¶
func NewOpcServiceEndpoints ¶
func RegisterOpcServiceHandler ¶
func RegisterOpcServiceHandler(s server.Server, hdlr OpcServiceHandler, opts ...server.HandlerOption) error
Types ¶
type FileReq ¶
type FileReq struct { GroupID uint32 `protobuf:"varint,1,opt,name=groupID,proto3" json:"groupID,omitempty"` Filebytes []byte `protobuf:"bytes,2,opt,name=filebytes,proto3" json:"filebytes,omitempty"` // contains filtered or unexported fields }
func (*FileReq) Descriptor
deprecated
func (*FileReq) GetFilebytes ¶
func (*FileReq) GetGroupID ¶
func (*FileReq) ProtoMessage ¶
func (*FileReq) ProtoMessage()
func (*FileReq) ProtoReflect ¶
func (x *FileReq) ProtoReflect() protoreflect.Message
type Group ¶
type Group struct { GroupID uint32 `protobuf:"varint,1,opt,name=groupID,proto3" json:"groupID,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Tag string `protobuf:"bytes,3,opt,name=tag,proto3" json:"tag,omitempty"` // contains filtered or unexported fields }
func (*Group) Descriptor
deprecated
func (*Group) GetGroupID ¶
func (*Group) ProtoMessage ¶
func (*Group) ProtoMessage()
func (*Group) ProtoReflect ¶
func (x *Group) ProtoReflect() protoreflect.Message
type Groups ¶
type Groups struct { Group []*Group `protobuf:"bytes,1,rep,name=group,proto3" json:"group,omitempty"` TotalCount uint32 `protobuf:"varint,2,opt,name=totalCount,proto3" json:"totalCount,omitempty"` // contains filtered or unexported fields }
func (*Groups) Descriptor
deprecated
func (*Groups) GetTotalCount ¶
func (*Groups) ProtoMessage ¶
func (*Groups) ProtoMessage()
func (*Groups) ProtoReflect ¶
func (x *Groups) ProtoReflect() protoreflect.Message
type GrpQuery ¶
type GrpQuery struct { Page uint32 `protobuf:"varint,1,opt,name=page,proto3" json:"page,omitempty"` PerPage uint32 `protobuf:"varint,2,opt,name=perPage,proto3" json:"perPage,omitempty"` // contains filtered or unexported fields }
func (*GrpQuery) Descriptor
deprecated
func (*GrpQuery) GetPerPage ¶
func (*GrpQuery) ProtoMessage ¶
func (*GrpQuery) ProtoMessage()
func (*GrpQuery) ProtoReflect ¶
func (x *GrpQuery) ProtoReflect() protoreflect.Message
type GrpReq ¶
type GrpReq struct { GroupID uint32 `protobuf:"varint,1,opt,name=groupID,proto3" json:"groupID,omitempty"` // contains filtered or unexported fields }
func (*GrpReq) Descriptor
deprecated
func (*GrpReq) GetGroupID ¶
func (*GrpReq) ProtoMessage ¶
func (*GrpReq) ProtoMessage()
func (*GrpReq) ProtoReflect ¶
func (x *GrpReq) ProtoReflect() protoreflect.Message
type Item ¶
type Item struct { GroupID uint32 `protobuf:"varint,1,opt,name=groupID,proto3" json:"groupID,omitempty"` ItemID uint32 `protobuf:"varint,2,opt,name=itemID,proto3" json:"itemID,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` Address string `protobuf:"bytes,4,opt,name=address,proto3" json:"address,omitempty"` Datatype string `protobuf:"bytes,5,opt,name=datatype,proto3" json:"datatype,omitempty"` RespectDataType uint32 `protobuf:"varint,6,opt,name=respectDataType,proto3" json:"respectDataType,omitempty"` ClientAccess string `protobuf:"bytes,7,opt,name=clientAccess,proto3" json:"clientAccess,omitempty"` ScanRate uint32 `protobuf:"varint,8,opt,name=scanRate,proto3" json:"scanRate,omitempty"` // contains filtered or unexported fields }
func (*Item) Descriptor
deprecated
func (*Item) GetAddress ¶
func (*Item) GetClientAccess ¶
func (*Item) GetDatatype ¶
func (*Item) GetGroupID ¶
func (*Item) GetRespectDataType ¶
func (*Item) GetScanRate ¶
func (*Item) ProtoMessage ¶
func (*Item) ProtoMessage()
func (*Item) ProtoReflect ¶
func (x *Item) ProtoReflect() protoreflect.Message
type ItemFilter ¶
type ItemFilter struct { And []*ItemFilter `protobuf:"bytes,1,rep,name=and,proto3" json:"and,omitempty"` Or []*ItemFilter `protobuf:"bytes,2,rep,name=or,proto3" json:"or,omitempty"` GroupIn []uint32 `protobuf:"varint,3,rep,packed,name=groupIn,proto3" json:"groupIn,omitempty"` ItemIn []uint32 `protobuf:"varint,4,rep,packed,name=itemIn,proto3" json:"itemIn,omitempty"` NameLike []string `protobuf:"bytes,5,rep,name=nameLike,proto3" json:"nameLike,omitempty"` AddressLike []string `protobuf:"bytes,6,rep,name=addressLike,proto3" json:"addressLike,omitempty"` // contains filtered or unexported fields }
func (*ItemFilter) Descriptor
deprecated
func (*ItemFilter) Descriptor() ([]byte, []int)
Deprecated: Use ItemFilter.ProtoReflect.Descriptor instead.
func (*ItemFilter) GetAddressLike ¶
func (x *ItemFilter) GetAddressLike() []string
func (*ItemFilter) GetAnd ¶
func (x *ItemFilter) GetAnd() []*ItemFilter
func (*ItemFilter) GetGroupIn ¶
func (x *ItemFilter) GetGroupIn() []uint32
func (*ItemFilter) GetItemIn ¶
func (x *ItemFilter) GetItemIn() []uint32
func (*ItemFilter) GetNameLike ¶
func (x *ItemFilter) GetNameLike() []string
func (*ItemFilter) GetOr ¶
func (x *ItemFilter) GetOr() []*ItemFilter
func (*ItemFilter) ProtoMessage ¶
func (*ItemFilter) ProtoMessage()
func (*ItemFilter) ProtoReflect ¶
func (x *ItemFilter) ProtoReflect() protoreflect.Message
func (*ItemFilter) Reset ¶
func (x *ItemFilter) Reset()
func (*ItemFilter) String ¶
func (x *ItemFilter) String() string
type ItemQuery ¶
type ItemQuery struct { Page uint32 `protobuf:"varint,1,opt,name=page,proto3" json:"page,omitempty"` PerPage uint32 `protobuf:"varint,2,opt,name=perPage,proto3" json:"perPage,omitempty"` Filter *ItemFilter `protobuf:"bytes,3,opt,name=filter,proto3" json:"filter,omitempty"` // contains filtered or unexported fields }
func (*ItemQuery) Descriptor
deprecated
func (*ItemQuery) GetFilter ¶
func (x *ItemQuery) GetFilter() *ItemFilter
func (*ItemQuery) GetPerPage ¶
func (*ItemQuery) ProtoMessage ¶
func (*ItemQuery) ProtoMessage()
func (*ItemQuery) ProtoReflect ¶
func (x *ItemQuery) ProtoReflect() protoreflect.Message
type ItemReq ¶
type ItemReq struct { GroupID uint32 `protobuf:"varint,1,opt,name=groupID,proto3" json:"groupID,omitempty"` ItemID uint32 `protobuf:"varint,2,opt,name=itemID,proto3" json:"itemID,omitempty"` // contains filtered or unexported fields }
func (*ItemReq) Descriptor
deprecated
func (*ItemReq) GetGroupID ¶
func (*ItemReq) ProtoMessage ¶
func (*ItemReq) ProtoMessage()
func (*ItemReq) ProtoReflect ¶
func (x *ItemReq) ProtoReflect() protoreflect.Message
type ItemValueReq ¶
type ItemValueReq struct { GroupID uint32 `protobuf:"varint,1,opt,name=groupID,proto3" json:"groupID,omitempty"` ItemID uint32 `protobuf:"varint,2,opt,name=itemID,proto3" json:"itemID,omitempty"` Value int32 `protobuf:"varint,3,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*ItemValueReq) Descriptor
deprecated
func (*ItemValueReq) Descriptor() ([]byte, []int)
Deprecated: Use ItemValueReq.ProtoReflect.Descriptor instead.
func (*ItemValueReq) GetGroupID ¶
func (x *ItemValueReq) GetGroupID() uint32
func (*ItemValueReq) GetItemID ¶
func (x *ItemValueReq) GetItemID() uint32
func (*ItemValueReq) GetValue ¶
func (x *ItemValueReq) GetValue() int32
func (*ItemValueReq) ProtoMessage ¶
func (*ItemValueReq) ProtoMessage()
func (*ItemValueReq) ProtoReflect ¶
func (x *ItemValueReq) ProtoReflect() protoreflect.Message
func (*ItemValueReq) Reset ¶
func (x *ItemValueReq) Reset()
func (*ItemValueReq) String ¶
func (x *ItemValueReq) String() string
type ItemValueResp ¶
type ItemValueResp struct { Value int32 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` Quality bool `protobuf:"varint,2,opt,name=quality,proto3" json:"quality,omitempty"` // contains filtered or unexported fields }
func (*ItemValueResp) Descriptor
deprecated
func (*ItemValueResp) Descriptor() ([]byte, []int)
Deprecated: Use ItemValueResp.ProtoReflect.Descriptor instead.
func (*ItemValueResp) GetQuality ¶
func (x *ItemValueResp) GetQuality() bool
func (*ItemValueResp) GetValue ¶
func (x *ItemValueResp) GetValue() int32
func (*ItemValueResp) ProtoMessage ¶
func (*ItemValueResp) ProtoMessage()
func (*ItemValueResp) ProtoReflect ¶
func (x *ItemValueResp) ProtoReflect() protoreflect.Message
func (*ItemValueResp) Reset ¶
func (x *ItemValueResp) Reset()
func (*ItemValueResp) String ¶
func (x *ItemValueResp) String() string
type Items ¶
type Items struct { Item []*Item `protobuf:"bytes,1,rep,name=item,proto3" json:"item,omitempty"` TotalCount uint32 `protobuf:"varint,2,opt,name=totalCount,proto3" json:"totalCount,omitempty"` // contains filtered or unexported fields }
func (*Items) Descriptor
deprecated
func (*Items) GetTotalCount ¶
func (*Items) ProtoMessage ¶
func (*Items) ProtoMessage()
func (*Items) ProtoReflect ¶
func (x *Items) ProtoReflect() protoreflect.Message
type LogLevelRequest ¶
type LogLevelRequest struct {
// contains filtered or unexported fields
}
func (*LogLevelRequest) Descriptor
deprecated
func (*LogLevelRequest) Descriptor() ([]byte, []int)
Deprecated: Use LogLevelRequest.ProtoReflect.Descriptor instead.
func (*LogLevelRequest) ProtoMessage ¶
func (*LogLevelRequest) ProtoMessage()
func (*LogLevelRequest) ProtoReflect ¶
func (x *LogLevelRequest) ProtoReflect() protoreflect.Message
func (*LogLevelRequest) Reset ¶
func (x *LogLevelRequest) Reset()
func (*LogLevelRequest) String ¶
func (x *LogLevelRequest) String() string
type LogResponse ¶
type LogResponse struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*LogResponse) Descriptor
deprecated
func (*LogResponse) Descriptor() ([]byte, []int)
Deprecated: Use LogResponse.ProtoReflect.Descriptor instead.
func (*LogResponse) GetName ¶
func (x *LogResponse) GetName() string
func (*LogResponse) ProtoMessage ¶
func (*LogResponse) ProtoMessage()
func (*LogResponse) ProtoReflect ¶
func (x *LogResponse) ProtoReflect() protoreflect.Message
func (*LogResponse) Reset ¶
func (x *LogResponse) Reset()
func (*LogResponse) String ¶
func (x *LogResponse) String() string
type Loglevel ¶
type Loglevel struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Level uint32 `protobuf:"varint,2,opt,name=level,proto3" json:"level,omitempty"` // contains filtered or unexported fields }
func (*Loglevel) Descriptor
deprecated
func (*Loglevel) ProtoMessage ¶
func (*Loglevel) ProtoMessage()
func (*Loglevel) ProtoReflect ¶
func (x *Loglevel) ProtoReflect() protoreflect.Message
type OpcService ¶
type OpcService interface { UpdateServer(ctx context.Context, in *Server, opts ...client.CallOption) (*Response, error) GetServer(ctx context.Context, in *SrvReq, opts ...client.CallOption) (*Server, error) GetGroup(ctx context.Context, in *GrpReq, opts ...client.CallOption) (*Group, error) GetGroups(ctx context.Context, in *GrpQuery, opts ...client.CallOption) (*Groups, error) AddGroup(ctx context.Context, in *Group, opts ...client.CallOption) (*Response, error) UpdateGroup(ctx context.Context, in *Group, opts ...client.CallOption) (*Response, error) DeleteGroup(ctx context.Context, in *Group, opts ...client.CallOption) (*Response, error) GetItem(ctx context.Context, in *ItemReq, opts ...client.CallOption) (*Item, error) GetItems(ctx context.Context, in *ItemQuery, opts ...client.CallOption) (*Items, error) AddItem(ctx context.Context, in *Item, opts ...client.CallOption) (*Response, error) UpdateItem(ctx context.Context, in *Item, opts ...client.CallOption) (*Response, error) DeleteItem(ctx context.Context, in *Item, opts ...client.CallOption) (*Response, error) WriteItem(ctx context.Context, in *ItemValueReq, opts ...client.CallOption) (*Response, error) ReadItem(ctx context.Context, in *ItemReq, opts ...client.CallOption) (*ItemValueResp, error) UpdateFile(ctx context.Context, in *FileReq, opts ...client.CallOption) (*Response, error) //获取服务日志等级 GetLogLevel(ctx context.Context, in *LogLevelRequest, opts ...client.CallOption) (*Loglevel, error) //设置服务日志等级 SetLogLevel(ctx context.Context, in *Loglevel, opts ...client.CallOption) (*LogResponse, error) }
func NewOpcService ¶
func NewOpcService(name string, c client.Client) OpcService
type OpcServiceHandler ¶
type OpcServiceHandler interface { UpdateServer(context.Context, *Server, *Response) error GetServer(context.Context, *SrvReq, *Server) error GetGroup(context.Context, *GrpReq, *Group) error GetGroups(context.Context, *GrpQuery, *Groups) error AddGroup(context.Context, *Group, *Response) error UpdateGroup(context.Context, *Group, *Response) error DeleteGroup(context.Context, *Group, *Response) error GetItem(context.Context, *ItemReq, *Item) error GetItems(context.Context, *ItemQuery, *Items) error AddItem(context.Context, *Item, *Response) error UpdateItem(context.Context, *Item, *Response) error DeleteItem(context.Context, *Item, *Response) error WriteItem(context.Context, *ItemValueReq, *Response) error ReadItem(context.Context, *ItemReq, *ItemValueResp) error UpdateFile(context.Context, *FileReq, *Response) error //获取服务日志等级 GetLogLevel(context.Context, *LogLevelRequest, *Loglevel) error //设置服务日志等级 SetLogLevel(context.Context, *Loglevel, *LogResponse) error }
type Response ¶
type Response struct {
// contains filtered or unexported fields
}
func (*Response) Descriptor
deprecated
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
func (*Response) ProtoReflect ¶
func (x *Response) ProtoReflect() protoreflect.Message
type Server ¶
type Server struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Ip string `protobuf:"bytes,2,opt,name=ip,proto3" json:"ip,omitempty"` Tag string `protobuf:"bytes,3,opt,name=tag,proto3" json:"tag,omitempty"` // contains filtered or unexported fields }
func (*Server) Descriptor
deprecated
func (*Server) ProtoMessage ¶
func (*Server) ProtoMessage()
func (*Server) ProtoReflect ¶
func (x *Server) ProtoReflect() protoreflect.Message
type Servers ¶
type Servers struct { Server []*Server `protobuf:"bytes,1,rep,name=server,proto3" json:"server,omitempty"` TotalCount uint32 `protobuf:"varint,2,opt,name=totalCount,proto3" json:"totalCount,omitempty"` // contains filtered or unexported fields }
func (*Servers) Descriptor
deprecated
func (*Servers) GetTotalCount ¶
func (*Servers) ProtoMessage ¶
func (*Servers) ProtoMessage()
func (*Servers) ProtoReflect ¶
func (x *Servers) ProtoReflect() protoreflect.Message
type SrvQuery ¶
type SrvQuery struct { Page uint32 `protobuf:"varint,1,opt,name=page,proto3" json:"page,omitempty"` PerPage uint32 `protobuf:"varint,2,opt,name=perPage,proto3" json:"perPage,omitempty"` // contains filtered or unexported fields }
func (*SrvQuery) Descriptor
deprecated
func (*SrvQuery) GetPerPage ¶
func (*SrvQuery) ProtoMessage ¶
func (*SrvQuery) ProtoMessage()
func (*SrvQuery) ProtoReflect ¶
func (x *SrvQuery) ProtoReflect() protoreflect.Message
type SrvReq ¶
type SrvReq struct {
// contains filtered or unexported fields
}
func (*SrvReq) Descriptor
deprecated
func (*SrvReq) ProtoMessage ¶
func (*SrvReq) ProtoMessage()
func (*SrvReq) ProtoReflect ¶
func (x *SrvReq) ProtoReflect() protoreflect.Message
Click to show internal directories.
Click to hide internal directories.