Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterAttrServiceServer(s grpc.ServiceRegistrar, srv AttrServiceServer)
- func RegisterAuthServiceServer(s grpc.ServiceRegistrar, srv AuthServiceServer)
- func RegisterClassServiceServer(s grpc.ServiceRegistrar, srv ClassServiceServer)
- func RegisterConstServiceServer(s grpc.ServiceRegistrar, srv ConstServiceServer)
- func RegisterControlServiceServer(s grpc.ServiceRegistrar, srv ControlServiceServer)
- func RegisterDataServiceServer(s grpc.ServiceRegistrar, srv DataServiceServer)
- func RegisterDeviceServiceServer(s grpc.ServiceRegistrar, srv DeviceServiceServer)
- func RegisterFnServiceServer(s grpc.ServiceRegistrar, srv FnServiceServer)
- func RegisterLogicServiceServer(s grpc.ServiceRegistrar, srv LogicServiceServer)
- func RegisterSlotServiceServer(s grpc.ServiceRegistrar, srv SlotServiceServer)
- func RegisterSourceServiceServer(s grpc.ServiceRegistrar, srv SourceServiceServer)
- func RegisterSyncServiceServer(s grpc.ServiceRegistrar, srv SyncServiceServer)
- func RegisterTagServiceServer(s grpc.ServiceRegistrar, srv TagServiceServer)
- func RegisterUserServiceServer(s grpc.ServiceRegistrar, srv UserServiceServer)
- type AttrCloneRequest
- func (*AttrCloneRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AttrCloneRequest) GetClassId() string
- func (x *AttrCloneRequest) GetId() string
- func (*AttrCloneRequest) ProtoMessage()
- func (x *AttrCloneRequest) ProtoReflect() protoreflect.Message
- func (x *AttrCloneRequest) Reset()
- func (x *AttrCloneRequest) String() string
- type AttrListRequest
- func (*AttrListRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AttrListRequest) GetClassId() string
- func (x *AttrListRequest) GetPage() *pb.Page
- func (x *AttrListRequest) GetTags() string
- func (x *AttrListRequest) GetType() string
- func (*AttrListRequest) ProtoMessage()
- func (x *AttrListRequest) ProtoReflect() protoreflect.Message
- func (x *AttrListRequest) Reset()
- func (x *AttrListRequest) String() string
- type AttrListResponse
- func (*AttrListResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AttrListResponse) GetAttr() []*pb.Attr
- func (x *AttrListResponse) GetCount() uint32
- func (x *AttrListResponse) GetPage() *pb.Page
- func (*AttrListResponse) ProtoMessage()
- func (x *AttrListResponse) ProtoReflect() protoreflect.Message
- func (x *AttrListResponse) Reset()
- func (x *AttrListResponse) String() string
- type AttrPullRequest
- func (*AttrPullRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AttrPullRequest) GetAfter() int64
- func (x *AttrPullRequest) GetClassId() string
- func (x *AttrPullRequest) GetLimit() uint32
- func (x *AttrPullRequest) GetType() string
- func (*AttrPullRequest) ProtoMessage()
- func (x *AttrPullRequest) ProtoReflect() protoreflect.Message
- func (x *AttrPullRequest) Reset()
- func (x *AttrPullRequest) String() string
- type AttrPullResponse
- func (*AttrPullResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AttrPullResponse) GetAfter() int64
- func (x *AttrPullResponse) GetAttr() []*pb.Attr
- func (x *AttrPullResponse) GetLimit() uint32
- func (*AttrPullResponse) ProtoMessage()
- func (x *AttrPullResponse) ProtoReflect() protoreflect.Message
- func (x *AttrPullResponse) Reset()
- func (x *AttrPullResponse) String() string
- type AttrServiceClient
- type AttrServiceServer
- type AuthServiceClient
- type AuthServiceServer
- type ChangePassRequest
- func (*ChangePassRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ChangePassRequest) GetId() string
- func (x *ChangePassRequest) GetNewPass() string
- func (x *ChangePassRequest) GetOldPass() string
- func (*ChangePassRequest) ProtoMessage()
- func (x *ChangePassRequest) ProtoReflect() protoreflect.Message
- func (x *ChangePassRequest) Reset()
- func (x *ChangePassRequest) String() string
- type ClassCloneRequest
- type ClassLinkRequest
- func (*ClassLinkRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ClassLinkRequest) GetId() string
- func (x *ClassLinkRequest) GetStatus() int32
- func (*ClassLinkRequest) ProtoMessage()
- func (x *ClassLinkRequest) ProtoReflect() protoreflect.Message
- func (x *ClassLinkRequest) Reset()
- func (x *ClassLinkRequest) String() string
- type ClassListRequest
- func (*ClassListRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ClassListRequest) GetPage() *pb.Page
- func (x *ClassListRequest) GetTags() string
- func (x *ClassListRequest) GetType() string
- func (*ClassListRequest) ProtoMessage()
- func (x *ClassListRequest) ProtoReflect() protoreflect.Message
- func (x *ClassListRequest) Reset()
- func (x *ClassListRequest) String() string
- type ClassListResponse
- func (*ClassListResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ClassListResponse) GetClass() []*pb.Class
- func (x *ClassListResponse) GetCount() uint32
- func (x *ClassListResponse) GetPage() *pb.Page
- func (*ClassListResponse) ProtoMessage()
- func (x *ClassListResponse) ProtoReflect() protoreflect.Message
- func (x *ClassListResponse) Reset()
- func (x *ClassListResponse) String() string
- type ClassPullRequest
- func (*ClassPullRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ClassPullRequest) GetAfter() int64
- func (x *ClassPullRequest) GetLimit() uint32
- func (x *ClassPullRequest) GetType() string
- func (*ClassPullRequest) ProtoMessage()
- func (x *ClassPullRequest) ProtoReflect() protoreflect.Message
- func (x *ClassPullRequest) Reset()
- func (x *ClassPullRequest) String() string
- type ClassPullResponse
- func (*ClassPullResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ClassPullResponse) GetAfter() int64
- func (x *ClassPullResponse) GetClass() []*pb.Class
- func (x *ClassPullResponse) GetLimit() uint32
- func (*ClassPullResponse) ProtoMessage()
- func (x *ClassPullResponse) ProtoReflect() protoreflect.Message
- func (x *ClassPullResponse) Reset()
- func (x *ClassPullResponse) String() string
- type ClassServiceClient
- type ClassServiceServer
- type CloneFnRequest
- type ConstCloneRequest
- type ConstListRequest
- func (*ConstListRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ConstListRequest) GetPage() *pb.Page
- func (x *ConstListRequest) GetTags() string
- func (x *ConstListRequest) GetType() string
- func (*ConstListRequest) ProtoMessage()
- func (x *ConstListRequest) ProtoReflect() protoreflect.Message
- func (x *ConstListRequest) Reset()
- func (x *ConstListRequest) String() string
- type ConstListResponse
- func (*ConstListResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ConstListResponse) GetConst() []*pb.Const
- func (x *ConstListResponse) GetCount() uint32
- func (x *ConstListResponse) GetPage() *pb.Page
- func (*ConstListResponse) ProtoMessage()
- func (x *ConstListResponse) ProtoReflect() protoreflect.Message
- func (x *ConstListResponse) Reset()
- func (x *ConstListResponse) String() string
- type ConstPullRequest
- func (*ConstPullRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ConstPullRequest) GetAfter() int64
- func (x *ConstPullRequest) GetLimit() uint32
- func (x *ConstPullRequest) GetType() string
- func (*ConstPullRequest) ProtoMessage()
- func (x *ConstPullRequest) ProtoReflect() protoreflect.Message
- func (x *ConstPullRequest) Reset()
- func (x *ConstPullRequest) String() string
- type ConstPullResponse
- func (*ConstPullResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ConstPullResponse) GetAfter() int64
- func (x *ConstPullResponse) GetConst() []*pb.Const
- func (x *ConstPullResponse) GetLimit() uint32
- func (*ConstPullResponse) ProtoMessage()
- func (x *ConstPullResponse) ProtoReflect() protoreflect.Message
- func (x *ConstPullResponse) Reset()
- func (x *ConstPullResponse) String() string
- type ConstServiceClient
- type ConstServiceServer
- type ControlServiceClient
- type ControlServiceServer
- type DataQueryByIdRequest
- func (*DataQueryByIdRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DataQueryByIdRequest) GetId() string
- func (x *DataQueryByIdRequest) GetVars() map[string]string
- func (*DataQueryByIdRequest) ProtoMessage()
- func (x *DataQueryByIdRequest) ProtoReflect() protoreflect.Message
- func (x *DataQueryByIdRequest) Reset()
- func (x *DataQueryByIdRequest) String() string
- type DataQueryRequest
- func (*DataQueryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DataQueryRequest) GetFlux() string
- func (x *DataQueryRequest) GetVars() map[string]string
- func (*DataQueryRequest) ProtoMessage()
- func (x *DataQueryRequest) ProtoReflect() protoreflect.Message
- func (x *DataQueryRequest) Reset()
- func (x *DataQueryRequest) String() string
- type DataServiceClient
- type DataServiceServer
- type DataService_QueryByIdClient
- type DataService_QueryByIdServer
- type DataService_QueryClient
- type DataService_QueryServer
- type DataUploadRequest
- func (*DataUploadRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DataUploadRequest) GetContent() []byte
- func (x *DataUploadRequest) GetContentType() int32
- func (x *DataUploadRequest) GetId() string
- func (x *DataUploadRequest) GetRealtime() bool
- func (x *DataUploadRequest) GetSave() bool
- func (*DataUploadRequest) ProtoMessage()
- func (x *DataUploadRequest) ProtoReflect() protoreflect.Message
- func (x *DataUploadRequest) Reset()
- func (x *DataUploadRequest) String() string
- type DataUploadResponse
- func (*DataUploadResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DataUploadResponse) GetId() string
- func (x *DataUploadResponse) GetMessage() string
- func (*DataUploadResponse) ProtoMessage()
- func (x *DataUploadResponse) ProtoReflect() protoreflect.Message
- func (x *DataUploadResponse) Reset()
- func (x *DataUploadResponse) String() string
- type DeviceServiceClient
- type DeviceServiceServer
- type FnLinkRequest
- func (*FnLinkRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FnLinkRequest) GetId() string
- func (x *FnLinkRequest) GetStatus() int32
- func (*FnLinkRequest) ProtoMessage()
- func (x *FnLinkRequest) ProtoReflect() protoreflect.Message
- func (x *FnLinkRequest) Reset()
- func (x *FnLinkRequest) String() string
- type FnListRequest
- func (*FnListRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FnListRequest) GetExec() string
- func (x *FnListRequest) GetPage() *pb.Page
- func (x *FnListRequest) GetTags() string
- func (x *FnListRequest) GetType() string
- func (*FnListRequest) ProtoMessage()
- func (x *FnListRequest) ProtoReflect() protoreflect.Message
- func (x *FnListRequest) Reset()
- func (x *FnListRequest) String() string
- type FnListResponse
- func (*FnListResponse) Descriptor() ([]byte, []int)deprecated
- func (x *FnListResponse) GetCount() uint32
- func (x *FnListResponse) GetFn() []*pb.Fn
- func (x *FnListResponse) GetPage() *pb.Page
- func (*FnListResponse) ProtoMessage()
- func (x *FnListResponse) ProtoReflect() protoreflect.Message
- func (x *FnListResponse) Reset()
- func (x *FnListResponse) String() string
- type FnPullRequest
- func (*FnPullRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FnPullRequest) GetAfter() int64
- func (x *FnPullRequest) GetExec() string
- func (x *FnPullRequest) GetLimit() uint32
- func (*FnPullRequest) ProtoMessage()
- func (x *FnPullRequest) ProtoReflect() protoreflect.Message
- func (x *FnPullRequest) Reset()
- func (x *FnPullRequest) String() string
- type FnPullResponse
- func (*FnPullResponse) Descriptor() ([]byte, []int)deprecated
- func (x *FnPullResponse) GetAfter() int64
- func (x *FnPullResponse) GetFn() []*pb.Fn
- func (x *FnPullResponse) GetLimit() uint32
- func (*FnPullResponse) ProtoMessage()
- func (x *FnPullResponse) ProtoReflect() protoreflect.Message
- func (x *FnPullResponse) Reset()
- func (x *FnPullResponse) String() string
- type FnServiceClient
- type FnServiceServer
- type ForceChangePassRequest
- func (*ForceChangePassRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ForceChangePassRequest) GetId() string
- func (x *ForceChangePassRequest) GetNewPass() string
- func (*ForceChangePassRequest) ProtoMessage()
- func (x *ForceChangePassRequest) ProtoReflect() protoreflect.Message
- func (x *ForceChangePassRequest) Reset()
- func (x *ForceChangePassRequest) String() string
- type LinkLogicRequest
- func (*LinkLogicRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LinkLogicRequest) GetId() string
- func (x *LinkLogicRequest) GetStatus() int32
- func (*LinkLogicRequest) ProtoMessage()
- func (x *LinkLogicRequest) ProtoReflect() protoreflect.Message
- func (x *LinkLogicRequest) Reset()
- func (x *LinkLogicRequest) String() string
- type LogicCloneRequest
- type LogicListRequest
- func (*LogicListRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LogicListRequest) GetExec() string
- func (x *LogicListRequest) GetPage() *pb.Page
- func (x *LogicListRequest) GetTags() string
- func (x *LogicListRequest) GetType() string
- func (*LogicListRequest) ProtoMessage()
- func (x *LogicListRequest) ProtoReflect() protoreflect.Message
- func (x *LogicListRequest) Reset()
- func (x *LogicListRequest) String() string
- type LogicListResponse
- func (*LogicListResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LogicListResponse) GetCount() uint32
- func (x *LogicListResponse) GetLogic() []*pb.Logic
- func (x *LogicListResponse) GetPage() *pb.Page
- func (*LogicListResponse) ProtoMessage()
- func (x *LogicListResponse) ProtoReflect() protoreflect.Message
- func (x *LogicListResponse) Reset()
- func (x *LogicListResponse) String() string
- type LogicPullRequest
- func (*LogicPullRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LogicPullRequest) GetAfter() int64
- func (x *LogicPullRequest) GetExec() string
- func (x *LogicPullRequest) GetLimit() uint32
- func (*LogicPullRequest) ProtoMessage()
- func (x *LogicPullRequest) ProtoReflect() protoreflect.Message
- func (x *LogicPullRequest) Reset()
- func (x *LogicPullRequest) String() string
- type LogicPullResponse
- func (*LogicPullResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LogicPullResponse) GetAfter() int64
- func (x *LogicPullResponse) GetLimit() uint32
- func (x *LogicPullResponse) GetLogic() []*pb.Logic
- func (*LogicPullResponse) ProtoMessage()
- func (x *LogicPullResponse) ProtoReflect() protoreflect.Message
- func (x *LogicPullResponse) Reset()
- func (x *LogicPullResponse) String() string
- type LogicServiceClient
- type LogicServiceServer
- type LoginRequest
- func (*LoginRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LoginRequest) GetName() string
- func (x *LoginRequest) GetPass() string
- func (*LoginRequest) ProtoMessage()
- func (x *LoginRequest) ProtoReflect() protoreflect.Message
- func (x *LoginRequest) Reset()
- func (x *LoginRequest) String() string
- type LoginResponse
- type SlotCloneRequest
- type SlotLinkRequest
- func (*SlotLinkRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SlotLinkRequest) GetId() string
- func (x *SlotLinkRequest) GetStatus() int32
- func (*SlotLinkRequest) ProtoMessage()
- func (x *SlotLinkRequest) ProtoReflect() protoreflect.Message
- func (x *SlotLinkRequest) Reset()
- func (x *SlotLinkRequest) String() string
- type SlotListRequest
- func (*SlotListRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SlotListRequest) GetPage() *pb.Page
- func (x *SlotListRequest) GetTags() string
- func (x *SlotListRequest) GetType() string
- func (*SlotListRequest) ProtoMessage()
- func (x *SlotListRequest) ProtoReflect() protoreflect.Message
- func (x *SlotListRequest) Reset()
- func (x *SlotListRequest) String() string
- type SlotListResponse
- func (*SlotListResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SlotListResponse) GetCount() uint32
- func (x *SlotListResponse) GetPage() *pb.Page
- func (x *SlotListResponse) GetSlot() []*pb.Slot
- func (*SlotListResponse) ProtoMessage()
- func (x *SlotListResponse) ProtoReflect() protoreflect.Message
- func (x *SlotListResponse) Reset()
- func (x *SlotListResponse) String() string
- type SlotPullRequest
- func (*SlotPullRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SlotPullRequest) GetAfter() int64
- func (x *SlotPullRequest) GetLimit() uint32
- func (x *SlotPullRequest) GetType() string
- func (*SlotPullRequest) ProtoMessage()
- func (x *SlotPullRequest) ProtoReflect() protoreflect.Message
- func (x *SlotPullRequest) Reset()
- func (x *SlotPullRequest) String() string
- type SlotPullResponse
- func (*SlotPullResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SlotPullResponse) GetAfter() int64
- func (x *SlotPullResponse) GetLimit() uint32
- func (x *SlotPullResponse) GetSlot() []*pb.Slot
- func (*SlotPullResponse) ProtoMessage()
- func (x *SlotPullResponse) ProtoReflect() protoreflect.Message
- func (x *SlotPullResponse) Reset()
- func (x *SlotPullResponse) String() string
- type SlotServiceClient
- type SlotServiceServer
- type SourceCloneRequest
- type SourceLinkRequest
- func (*SourceLinkRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SourceLinkRequest) GetId() string
- func (x *SourceLinkRequest) GetStatus() int32
- func (*SourceLinkRequest) ProtoMessage()
- func (x *SourceLinkRequest) ProtoReflect() protoreflect.Message
- func (x *SourceLinkRequest) Reset()
- func (x *SourceLinkRequest) String() string
- type SourceListRequest
- func (*SourceListRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SourceListRequest) GetPage() *pb.Page
- func (x *SourceListRequest) GetSource() string
- func (x *SourceListRequest) GetTags() string
- func (x *SourceListRequest) GetType() string
- func (*SourceListRequest) ProtoMessage()
- func (x *SourceListRequest) ProtoReflect() protoreflect.Message
- func (x *SourceListRequest) Reset()
- func (x *SourceListRequest) String() string
- type SourceListResponse
- func (*SourceListResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SourceListResponse) GetCount() uint32
- func (x *SourceListResponse) GetPage() *pb.Page
- func (x *SourceListResponse) GetSource() []*pb.Source
- func (*SourceListResponse) ProtoMessage()
- func (x *SourceListResponse) ProtoReflect() protoreflect.Message
- func (x *SourceListResponse) Reset()
- func (x *SourceListResponse) String() string
- type SourcePullRequest
- func (*SourcePullRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SourcePullRequest) GetAfter() int64
- func (x *SourcePullRequest) GetLimit() uint32
- func (x *SourcePullRequest) GetSource() string
- func (x *SourcePullRequest) GetType() string
- func (*SourcePullRequest) ProtoMessage()
- func (x *SourcePullRequest) ProtoReflect() protoreflect.Message
- func (x *SourcePullRequest) Reset()
- func (x *SourcePullRequest) String() string
- type SourcePullResponse
- func (*SourcePullResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SourcePullResponse) GetAfter() int64
- func (x *SourcePullResponse) GetLimit() uint32
- func (x *SourcePullResponse) GetSource() []*pb.Source
- func (*SourcePullResponse) ProtoMessage()
- func (x *SourcePullResponse) ProtoReflect() protoreflect.Message
- func (x *SourcePullResponse) Reset()
- func (x *SourcePullResponse) String() string
- type SourceServiceClient
- type SourceServiceServer
- type SyncServiceClient
- type SyncServiceServer
- type SyncService_WaitDeviceUpdatedClient
- type SyncService_WaitDeviceUpdatedServer
- type SyncService_WaitTagValueUpdatedClient
- type SyncService_WaitTagValueUpdatedServer
- type SyncUpdated
- type TagCloneRequest
- func (*TagCloneRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TagCloneRequest) GetId() string
- func (x *TagCloneRequest) GetSourceId() string
- func (*TagCloneRequest) ProtoMessage()
- func (x *TagCloneRequest) ProtoReflect() protoreflect.Message
- func (x *TagCloneRequest) Reset()
- func (x *TagCloneRequest) String() string
- type TagListRequest
- func (*TagListRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TagListRequest) GetPage() *pb.Page
- func (x *TagListRequest) GetSourceId() string
- func (x *TagListRequest) GetTags() string
- func (x *TagListRequest) GetType() string
- func (*TagListRequest) ProtoMessage()
- func (x *TagListRequest) ProtoReflect() protoreflect.Message
- func (x *TagListRequest) Reset()
- func (x *TagListRequest) String() string
- type TagListResponse
- func (*TagListResponse) Descriptor() ([]byte, []int)deprecated
- func (x *TagListResponse) GetCount() uint32
- func (x *TagListResponse) GetPage() *pb.Page
- func (x *TagListResponse) GetTag() []*pb.Tag
- func (*TagListResponse) ProtoMessage()
- func (x *TagListResponse) ProtoReflect() protoreflect.Message
- func (x *TagListResponse) Reset()
- func (x *TagListResponse) String() string
- type TagPullRequest
- func (*TagPullRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TagPullRequest) GetAfter() int64
- func (x *TagPullRequest) GetLimit() uint32
- func (x *TagPullRequest) GetSourceId() string
- func (x *TagPullRequest) GetType() string
- func (*TagPullRequest) ProtoMessage()
- func (x *TagPullRequest) ProtoReflect() protoreflect.Message
- func (x *TagPullRequest) Reset()
- func (x *TagPullRequest) String() string
- type TagPullResponse
- func (*TagPullResponse) Descriptor() ([]byte, []int)deprecated
- func (x *TagPullResponse) GetAfter() int64
- func (x *TagPullResponse) GetLimit() uint32
- func (x *TagPullResponse) GetTag() []*pb.Tag
- func (*TagPullResponse) ProtoMessage()
- func (x *TagPullResponse) ProtoReflect() protoreflect.Message
- func (x *TagPullResponse) Reset()
- func (x *TagPullResponse) String() string
- type TagPullValueRequest
- func (*TagPullValueRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TagPullValueRequest) GetAfter() int64
- func (x *TagPullValueRequest) GetLimit() uint32
- func (x *TagPullValueRequest) GetSourceId() string
- func (*TagPullValueRequest) ProtoMessage()
- func (x *TagPullValueRequest) ProtoReflect() protoreflect.Message
- func (x *TagPullValueRequest) Reset()
- func (x *TagPullValueRequest) String() string
- type TagPullValueResponse
- func (*TagPullValueResponse) Descriptor() ([]byte, []int)deprecated
- func (x *TagPullValueResponse) GetAfter() int64
- func (x *TagPullValueResponse) GetLimit() uint32
- func (x *TagPullValueResponse) GetTag() []*pb.TagValueUpdated
- func (*TagPullValueResponse) ProtoMessage()
- func (x *TagPullValueResponse) ProtoReflect() protoreflect.Message
- func (x *TagPullValueResponse) Reset()
- func (x *TagPullValueResponse) String() string
- type TagServiceClient
- type TagServiceServer
- type UnimplementedAttrServiceServer
- func (UnimplementedAttrServiceServer) Clone(context.Context, *AttrCloneRequest) (*pb.MyBool, error)
- func (UnimplementedAttrServiceServer) Create(context.Context, *pb.Attr) (*pb.Attr, error)
- func (UnimplementedAttrServiceServer) Delete(context.Context, *pb.Id) (*pb.MyBool, error)
- func (UnimplementedAttrServiceServer) GetValue(context.Context, *pb.Id) (*pb.AttrValue, error)
- func (UnimplementedAttrServiceServer) GetValueByName(context.Context, *pb.Name) (*pb.AttrNameValue, error)
- func (UnimplementedAttrServiceServer) List(context.Context, *AttrListRequest) (*AttrListResponse, error)
- func (UnimplementedAttrServiceServer) Name(context.Context, *pb.Name) (*pb.Attr, error)
- func (UnimplementedAttrServiceServer) Pull(context.Context, *AttrPullRequest) (*AttrPullResponse, error)
- func (UnimplementedAttrServiceServer) SetValue(context.Context, *pb.AttrValue) (*pb.MyBool, error)
- func (UnimplementedAttrServiceServer) SetValueByName(context.Context, *pb.AttrNameValue) (*pb.MyBool, error)
- func (UnimplementedAttrServiceServer) SetValueByNameForce(context.Context, *pb.AttrNameValue) (*pb.MyBool, error)
- func (UnimplementedAttrServiceServer) SetValueForce(context.Context, *pb.AttrValue) (*pb.MyBool, error)
- func (UnimplementedAttrServiceServer) Sync(context.Context, *pb.Attr) (*pb.MyBool, error)
- func (UnimplementedAttrServiceServer) Update(context.Context, *pb.Attr) (*pb.Attr, error)
- func (UnimplementedAttrServiceServer) View(context.Context, *pb.Id) (*pb.Attr, error)
- func (UnimplementedAttrServiceServer) ViewWithDeleted(context.Context, *pb.Id) (*pb.Attr, error)
- type UnimplementedAuthServiceServer
- func (UnimplementedAuthServiceServer) ChangePass(context.Context, *ChangePassRequest) (*pb.Message, error)
- func (UnimplementedAuthServiceServer) ForceChangePass(context.Context, *ForceChangePassRequest) (*pb.Message, error)
- func (UnimplementedAuthServiceServer) Login(context.Context, *LoginRequest) (*LoginResponse, error)
- type UnimplementedClassServiceServer
- func (UnimplementedClassServiceServer) Clone(context.Context, *ClassCloneRequest) (*pb.MyBool, error)
- func (UnimplementedClassServiceServer) Create(context.Context, *pb.Class) (*pb.Class, error)
- func (UnimplementedClassServiceServer) Delete(context.Context, *pb.Id) (*pb.MyBool, error)
- func (UnimplementedClassServiceServer) List(context.Context, *ClassListRequest) (*ClassListResponse, error)
- func (UnimplementedClassServiceServer) Name(context.Context, *pb.Name) (*pb.Class, error)
- func (UnimplementedClassServiceServer) Pull(context.Context, *ClassPullRequest) (*ClassPullResponse, error)
- func (UnimplementedClassServiceServer) Sync(context.Context, *pb.Class) (*pb.MyBool, error)
- func (UnimplementedClassServiceServer) Update(context.Context, *pb.Class) (*pb.Class, error)
- func (UnimplementedClassServiceServer) View(context.Context, *pb.Id) (*pb.Class, error)
- func (UnimplementedClassServiceServer) ViewWithDeleted(context.Context, *pb.Id) (*pb.Class, error)
- type UnimplementedConstServiceServer
- func (UnimplementedConstServiceServer) Clone(context.Context, *ConstCloneRequest) (*pb.MyBool, error)
- func (UnimplementedConstServiceServer) Create(context.Context, *pb.Const) (*pb.Const, error)
- func (UnimplementedConstServiceServer) Delete(context.Context, *pb.Id) (*pb.MyBool, error)
- func (UnimplementedConstServiceServer) GetValue(context.Context, *pb.Id) (*pb.ConstValue, error)
- func (UnimplementedConstServiceServer) GetValueByName(context.Context, *pb.Name) (*pb.ConstNameValue, error)
- func (UnimplementedConstServiceServer) List(context.Context, *ConstListRequest) (*ConstListResponse, error)
- func (UnimplementedConstServiceServer) Name(context.Context, *pb.Name) (*pb.Const, error)
- func (UnimplementedConstServiceServer) Pull(context.Context, *ConstPullRequest) (*ConstPullResponse, error)
- func (UnimplementedConstServiceServer) SetValue(context.Context, *pb.ConstValue) (*pb.MyBool, error)
- func (UnimplementedConstServiceServer) SetValueByName(context.Context, *pb.ConstNameValue) (*pb.MyBool, error)
- func (UnimplementedConstServiceServer) SetValueByNameForce(context.Context, *pb.ConstNameValue) (*pb.MyBool, error)
- func (UnimplementedConstServiceServer) SetValueForce(context.Context, *pb.ConstValue) (*pb.MyBool, error)
- func (UnimplementedConstServiceServer) Sync(context.Context, *pb.Const) (*pb.MyBool, error)
- func (UnimplementedConstServiceServer) Update(context.Context, *pb.Const) (*pb.Const, error)
- func (UnimplementedConstServiceServer) View(context.Context, *pb.Id) (*pb.Const, error)
- func (UnimplementedConstServiceServer) ViewWithDeleted(context.Context, *pb.Id) (*pb.Const, error)
- type UnimplementedControlServiceServer
- type UnimplementedDataServiceServer
- func (UnimplementedDataServiceServer) Compile(context.Context, *DataQueryRequest) (*pb.Message, error)
- func (UnimplementedDataServiceServer) Query(*DataQueryRequest, DataService_QueryServer) error
- func (UnimplementedDataServiceServer) QueryById(*DataQueryByIdRequest, DataService_QueryByIdServer) error
- func (UnimplementedDataServiceServer) Upload(context.Context, *DataUploadRequest) (*DataUploadResponse, error)
- type UnimplementedDeviceServiceServer
- func (UnimplementedDeviceServiceServer) Destory(context.Context, *pb.MyEmpty) (*pb.MyBool, error)
- func (UnimplementedDeviceServiceServer) Sync(context.Context, *pb.Device) (*pb.MyBool, error)
- func (UnimplementedDeviceServiceServer) Update(context.Context, *pb.Device) (*pb.Device, error)
- func (UnimplementedDeviceServiceServer) View(context.Context, *pb.MyEmpty) (*pb.Device, error)
- func (UnimplementedDeviceServiceServer) ViewWithDeleted(context.Context, *pb.MyEmpty) (*pb.Device, error)
- type UnimplementedFnServiceServer
- func (UnimplementedFnServiceServer) Clone(context.Context, *CloneFnRequest) (*pb.MyBool, error)
- func (UnimplementedFnServiceServer) Create(context.Context, *pb.Fn) (*pb.Fn, error)
- func (UnimplementedFnServiceServer) Delete(context.Context, *pb.Id) (*pb.MyBool, error)
- func (UnimplementedFnServiceServer) Link(context.Context, *FnLinkRequest) (*pb.MyBool, error)
- func (UnimplementedFnServiceServer) List(context.Context, *FnListRequest) (*FnListResponse, error)
- func (UnimplementedFnServiceServer) Name(context.Context, *pb.Name) (*pb.Fn, error)
- func (UnimplementedFnServiceServer) Pull(context.Context, *FnPullRequest) (*FnPullResponse, error)
- func (UnimplementedFnServiceServer) Sync(context.Context, *pb.Fn) (*pb.MyBool, error)
- func (UnimplementedFnServiceServer) Update(context.Context, *pb.Fn) (*pb.Fn, error)
- func (UnimplementedFnServiceServer) View(context.Context, *pb.Id) (*pb.Fn, error)
- func (UnimplementedFnServiceServer) ViewWithDeleted(context.Context, *pb.Id) (*pb.Fn, error)
- type UnimplementedLogicServiceServer
- func (UnimplementedLogicServiceServer) Clone(context.Context, *LogicCloneRequest) (*pb.MyBool, error)
- func (UnimplementedLogicServiceServer) Create(context.Context, *pb.Logic) (*pb.Logic, error)
- func (UnimplementedLogicServiceServer) Delete(context.Context, *pb.Id) (*pb.MyBool, error)
- func (UnimplementedLogicServiceServer) List(context.Context, *LogicListRequest) (*LogicListResponse, error)
- func (UnimplementedLogicServiceServer) Name(context.Context, *pb.Name) (*pb.Logic, error)
- func (UnimplementedLogicServiceServer) Pull(context.Context, *LogicPullRequest) (*LogicPullResponse, error)
- func (UnimplementedLogicServiceServer) Sync(context.Context, *pb.Logic) (*pb.MyBool, error)
- func (UnimplementedLogicServiceServer) Update(context.Context, *pb.Logic) (*pb.Logic, error)
- func (UnimplementedLogicServiceServer) View(context.Context, *pb.Id) (*pb.Logic, error)
- func (UnimplementedLogicServiceServer) ViewWithDeleted(context.Context, *pb.Id) (*pb.Logic, error)
- type UnimplementedSlotServiceServer
- func (UnimplementedSlotServiceServer) Clone(context.Context, *SlotCloneRequest) (*pb.MyBool, error)
- func (UnimplementedSlotServiceServer) Create(context.Context, *pb.Slot) (*pb.Slot, error)
- func (UnimplementedSlotServiceServer) Delete(context.Context, *pb.Id) (*pb.MyBool, error)
- func (UnimplementedSlotServiceServer) Link(context.Context, *SlotLinkRequest) (*pb.MyBool, error)
- func (UnimplementedSlotServiceServer) List(context.Context, *SlotListRequest) (*SlotListResponse, error)
- func (UnimplementedSlotServiceServer) Name(context.Context, *pb.Name) (*pb.Slot, error)
- func (UnimplementedSlotServiceServer) Pull(context.Context, *SlotPullRequest) (*SlotPullResponse, error)
- func (UnimplementedSlotServiceServer) Sync(context.Context, *pb.Slot) (*pb.MyBool, error)
- func (UnimplementedSlotServiceServer) Update(context.Context, *pb.Slot) (*pb.Slot, error)
- func (UnimplementedSlotServiceServer) View(context.Context, *pb.Id) (*pb.Slot, error)
- func (UnimplementedSlotServiceServer) ViewWithDeleted(context.Context, *pb.Id) (*pb.Slot, error)
- type UnimplementedSourceServiceServer
- func (UnimplementedSourceServiceServer) Clone(context.Context, *SourceCloneRequest) (*pb.MyBool, error)
- func (UnimplementedSourceServiceServer) Create(context.Context, *pb.Source) (*pb.Source, error)
- func (UnimplementedSourceServiceServer) Delete(context.Context, *pb.Id) (*pb.MyBool, error)
- func (UnimplementedSourceServiceServer) Link(context.Context, *SourceLinkRequest) (*pb.MyBool, error)
- func (UnimplementedSourceServiceServer) List(context.Context, *SourceListRequest) (*SourceListResponse, error)
- func (UnimplementedSourceServiceServer) Name(context.Context, *pb.Name) (*pb.Source, error)
- func (UnimplementedSourceServiceServer) Pull(context.Context, *SourcePullRequest) (*SourcePullResponse, error)
- func (UnimplementedSourceServiceServer) Sync(context.Context, *pb.Source) (*pb.MyBool, error)
- func (UnimplementedSourceServiceServer) Update(context.Context, *pb.Source) (*pb.Source, error)
- func (UnimplementedSourceServiceServer) View(context.Context, *pb.Id) (*pb.Source, error)
- func (UnimplementedSourceServiceServer) ViewWithDeleted(context.Context, *pb.Id) (*pb.Source, error)
- type UnimplementedSyncServiceServer
- func (UnimplementedSyncServiceServer) GetAttrUpdated(context.Context, *pb.MyEmpty) (*SyncUpdated, error)
- func (UnimplementedSyncServiceServer) GetClassUpdated(context.Context, *pb.MyEmpty) (*SyncUpdated, error)
- func (UnimplementedSyncServiceServer) GetConstUpdated(context.Context, *pb.MyEmpty) (*SyncUpdated, error)
- func (UnimplementedSyncServiceServer) GetDeviceUpdated(context.Context, *pb.MyEmpty) (*SyncUpdated, error)
- func (UnimplementedSyncServiceServer) GetFnUpdated(context.Context, *pb.MyEmpty) (*SyncUpdated, error)
- func (UnimplementedSyncServiceServer) GetLogicUpdated(context.Context, *pb.MyEmpty) (*SyncUpdated, error)
- func (UnimplementedSyncServiceServer) GetOptionUpdated(context.Context, *pb.MyEmpty) (*SyncUpdated, error)
- func (UnimplementedSyncServiceServer) GetSourceUpdated(context.Context, *pb.MyEmpty) (*SyncUpdated, error)
- func (UnimplementedSyncServiceServer) GetTagUpdated(context.Context, *pb.MyEmpty) (*SyncUpdated, error)
- func (UnimplementedSyncServiceServer) GetTagValueUpdated(context.Context, *pb.MyEmpty) (*SyncUpdated, error)
- func (UnimplementedSyncServiceServer) SetAttrUpdated(context.Context, *SyncUpdated) (*pb.MyBool, error)
- func (UnimplementedSyncServiceServer) SetClassUpdated(context.Context, *SyncUpdated) (*pb.MyBool, error)
- func (UnimplementedSyncServiceServer) SetConstUpdated(context.Context, *SyncUpdated) (*pb.MyBool, error)
- func (UnimplementedSyncServiceServer) SetDeviceUpdated(context.Context, *SyncUpdated) (*pb.MyBool, error)
- func (UnimplementedSyncServiceServer) SetFnUpdated(context.Context, *SyncUpdated) (*pb.MyBool, error)
- func (UnimplementedSyncServiceServer) SetLogicUpdated(context.Context, *SyncUpdated) (*pb.MyBool, error)
- func (UnimplementedSyncServiceServer) SetOptionUpdated(context.Context, *SyncUpdated) (*pb.MyBool, error)
- func (UnimplementedSyncServiceServer) SetSourceUpdated(context.Context, *SyncUpdated) (*pb.MyBool, error)
- func (UnimplementedSyncServiceServer) SetTagUpdated(context.Context, *SyncUpdated) (*pb.MyBool, error)
- func (UnimplementedSyncServiceServer) SetTagValueUpdated(context.Context, *SyncUpdated) (*pb.MyBool, error)
- func (UnimplementedSyncServiceServer) WaitDeviceUpdated(*pb.MyEmpty, SyncService_WaitDeviceUpdatedServer) error
- func (UnimplementedSyncServiceServer) WaitTagValueUpdated(*pb.MyEmpty, SyncService_WaitTagValueUpdatedServer) error
- type UnimplementedTagServiceServer
- func (UnimplementedTagServiceServer) Clone(context.Context, *TagCloneRequest) (*pb.MyBool, error)
- func (UnimplementedTagServiceServer) Create(context.Context, *pb.Tag) (*pb.Tag, error)
- func (UnimplementedTagServiceServer) Delete(context.Context, *pb.Id) (*pb.MyBool, error)
- func (UnimplementedTagServiceServer) DeleteValue(context.Context, *pb.Id) (*pb.MyBool, error)
- func (UnimplementedTagServiceServer) GetValue(context.Context, *pb.Id) (*pb.TagValue, error)
- func (UnimplementedTagServiceServer) GetValueByName(context.Context, *pb.Name) (*pb.TagNameValue, error)
- func (UnimplementedTagServiceServer) List(context.Context, *TagListRequest) (*TagListResponse, error)
- func (UnimplementedTagServiceServer) Name(context.Context, *pb.Name) (*pb.Tag, error)
- func (UnimplementedTagServiceServer) Pull(context.Context, *TagPullRequest) (*TagPullResponse, error)
- func (UnimplementedTagServiceServer) PullValue(context.Context, *TagPullValueRequest) (*TagPullValueResponse, error)
- func (UnimplementedTagServiceServer) SetValue(context.Context, *pb.TagValue) (*pb.MyBool, error)
- func (UnimplementedTagServiceServer) SetValueByName(context.Context, *pb.TagNameValue) (*pb.MyBool, error)
- func (UnimplementedTagServiceServer) SetValueByNameForce(context.Context, *pb.TagNameValue) (*pb.MyBool, error)
- func (UnimplementedTagServiceServer) SetValueForce(context.Context, *pb.TagValue) (*pb.MyBool, error)
- func (UnimplementedTagServiceServer) Sync(context.Context, *pb.Tag) (*pb.MyBool, error)
- func (UnimplementedTagServiceServer) SyncValue(context.Context, *pb.TagValue) (*pb.MyBool, error)
- func (UnimplementedTagServiceServer) Update(context.Context, *pb.Tag) (*pb.Tag, error)
- func (UnimplementedTagServiceServer) View(context.Context, *pb.Id) (*pb.Tag, error)
- func (UnimplementedTagServiceServer) ViewValue(context.Context, *pb.Id) (*pb.TagValueUpdated, error)
- func (UnimplementedTagServiceServer) ViewWithDeleted(context.Context, *pb.Id) (*pb.Tag, error)
- type UnimplementedUserServiceServer
- func (UnimplementedUserServiceServer) Create(context.Context, *pb.User) (*pb.User, error)
- func (UnimplementedUserServiceServer) Delete(context.Context, *pb.Id) (*pb.MyBool, error)
- func (UnimplementedUserServiceServer) List(context.Context, *UserListRequest) (*UserListResponse, error)
- func (UnimplementedUserServiceServer) Name(context.Context, *pb.Name) (*pb.User, error)
- func (UnimplementedUserServiceServer) Pull(context.Context, *UserPullRequest) (*UserPullResponse, error)
- func (UnimplementedUserServiceServer) Update(context.Context, *pb.User) (*pb.User, error)
- func (UnimplementedUserServiceServer) View(context.Context, *pb.Id) (*pb.User, error)
- func (UnimplementedUserServiceServer) ViewWithDeleted(context.Context, *pb.Id) (*pb.User, error)
- type UnsafeAttrServiceServer
- type UnsafeAuthServiceServer
- type UnsafeClassServiceServer
- type UnsafeConstServiceServer
- type UnsafeControlServiceServer
- type UnsafeDataServiceServer
- type UnsafeDeviceServiceServer
- type UnsafeFnServiceServer
- type UnsafeLogicServiceServer
- type UnsafeSlotServiceServer
- type UnsafeSourceServiceServer
- type UnsafeSyncServiceServer
- type UnsafeTagServiceServer
- type UnsafeUserServiceServer
- type UserListRequest
- func (*UserListRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UserListRequest) GetPage() *pb.Page
- func (x *UserListRequest) GetTags() string
- func (x *UserListRequest) GetType() string
- func (*UserListRequest) ProtoMessage()
- func (x *UserListRequest) ProtoReflect() protoreflect.Message
- func (x *UserListRequest) Reset()
- func (x *UserListRequest) String() string
- type UserListResponse
- func (*UserListResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UserListResponse) GetCount() uint32
- func (x *UserListResponse) GetPage() *pb.Page
- func (x *UserListResponse) GetUser() []*pb.User
- func (*UserListResponse) ProtoMessage()
- func (x *UserListResponse) ProtoReflect() protoreflect.Message
- func (x *UserListResponse) Reset()
- func (x *UserListResponse) String() string
- type UserPullRequest
- func (*UserPullRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UserPullRequest) GetAfter() int64
- func (x *UserPullRequest) GetLimit() uint32
- func (*UserPullRequest) ProtoMessage()
- func (x *UserPullRequest) ProtoReflect() protoreflect.Message
- func (x *UserPullRequest) Reset()
- func (x *UserPullRequest) String() string
- type UserPullResponse
- func (*UserPullResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UserPullResponse) GetAfter() int64
- func (x *UserPullResponse) GetLimit() uint32
- func (x *UserPullResponse) GetUser() []*pb.User
- func (*UserPullResponse) ProtoMessage()
- func (x *UserPullResponse) ProtoReflect() protoreflect.Message
- func (x *UserPullResponse) Reset()
- func (x *UserPullResponse) String() string
- type UserServiceClient
- type UserServiceServer
Constants ¶
const ( AuthService_Login_FullMethodName = "/edges.AuthService/Login" AuthService_ChangePass_FullMethodName = "/edges.AuthService/ChangePass" AuthService_ForceChangePass_FullMethodName = "/edges.AuthService/ForceChangePass" )
const ( ClassService_Create_FullMethodName = "/edges.ClassService/Create" ClassService_Update_FullMethodName = "/edges.ClassService/Update" ClassService_View_FullMethodName = "/edges.ClassService/View" ClassService_Name_FullMethodName = "/edges.ClassService/Name" ClassService_Delete_FullMethodName = "/edges.ClassService/Delete" ClassService_List_FullMethodName = "/edges.ClassService/List" ClassService_Clone_FullMethodName = "/edges.ClassService/Clone" ClassService_ViewWithDeleted_FullMethodName = "/edges.ClassService/ViewWithDeleted" ClassService_Pull_FullMethodName = "/edges.ClassService/Pull" ClassService_Sync_FullMethodName = "/edges.ClassService/Sync" )
const ( AttrService_Create_FullMethodName = "/edges.AttrService/Create" AttrService_Update_FullMethodName = "/edges.AttrService/Update" AttrService_View_FullMethodName = "/edges.AttrService/View" AttrService_Name_FullMethodName = "/edges.AttrService/Name" AttrService_Delete_FullMethodName = "/edges.AttrService/Delete" AttrService_List_FullMethodName = "/edges.AttrService/List" AttrService_Clone_FullMethodName = "/edges.AttrService/Clone" AttrService_ViewWithDeleted_FullMethodName = "/edges.AttrService/ViewWithDeleted" AttrService_Pull_FullMethodName = "/edges.AttrService/Pull" AttrService_Sync_FullMethodName = "/edges.AttrService/Sync" AttrService_GetValue_FullMethodName = "/edges.AttrService/GetValue" AttrService_SetValue_FullMethodName = "/edges.AttrService/SetValue" AttrService_SetValueForce_FullMethodName = "/edges.AttrService/SetValueForce" AttrService_GetValueByName_FullMethodName = "/edges.AttrService/GetValueByName" AttrService_SetValueByName_FullMethodName = "/edges.AttrService/SetValueByName" AttrService_SetValueByNameForce_FullMethodName = "/edges.AttrService/SetValueByNameForce" )
const ( ConstService_Create_FullMethodName = "/edges.ConstService/Create" ConstService_Update_FullMethodName = "/edges.ConstService/Update" ConstService_View_FullMethodName = "/edges.ConstService/View" ConstService_Name_FullMethodName = "/edges.ConstService/Name" ConstService_Delete_FullMethodName = "/edges.ConstService/Delete" ConstService_List_FullMethodName = "/edges.ConstService/List" ConstService_Clone_FullMethodName = "/edges.ConstService/Clone" ConstService_ViewWithDeleted_FullMethodName = "/edges.ConstService/ViewWithDeleted" ConstService_Pull_FullMethodName = "/edges.ConstService/Pull" ConstService_Sync_FullMethodName = "/edges.ConstService/Sync" ConstService_GetValue_FullMethodName = "/edges.ConstService/GetValue" ConstService_SetValue_FullMethodName = "/edges.ConstService/SetValue" ConstService_SetValueForce_FullMethodName = "/edges.ConstService/SetValueForce" ConstService_GetValueByName_FullMethodName = "/edges.ConstService/GetValueByName" ConstService_SetValueByName_FullMethodName = "/edges.ConstService/SetValueByName" ConstService_SetValueByNameForce_FullMethodName = "/edges.ConstService/SetValueByNameForce" )
const ( ControlService_GetTagValue_FullMethodName = "/edges.ControlService/GetTagValue" ControlService_SetTagValue_FullMethodName = "/edges.ControlService/SetTagValue" )
const ( DataService_Upload_FullMethodName = "/edges.DataService/Upload" DataService_Compile_FullMethodName = "/edges.DataService/Compile" DataService_Query_FullMethodName = "/edges.DataService/Query" DataService_QueryById_FullMethodName = "/edges.DataService/QueryById" )
const ( DeviceService_Update_FullMethodName = "/edges.DeviceService/Update" DeviceService_View_FullMethodName = "/edges.DeviceService/View" DeviceService_Destory_FullMethodName = "/edges.DeviceService/Destory" DeviceService_ViewWithDeleted_FullMethodName = "/edges.DeviceService/ViewWithDeleted" DeviceService_Sync_FullMethodName = "/edges.DeviceService/Sync" )
const ( FnService_Create_FullMethodName = "/edges.FnService/Create" FnService_Update_FullMethodName = "/edges.FnService/Update" FnService_View_FullMethodName = "/edges.FnService/View" FnService_Name_FullMethodName = "/edges.FnService/Name" FnService_Delete_FullMethodName = "/edges.FnService/Delete" FnService_List_FullMethodName = "/edges.FnService/List" FnService_Link_FullMethodName = "/edges.FnService/Link" FnService_Clone_FullMethodName = "/edges.FnService/Clone" FnService_ViewWithDeleted_FullMethodName = "/edges.FnService/ViewWithDeleted" FnService_Pull_FullMethodName = "/edges.FnService/Pull" FnService_Sync_FullMethodName = "/edges.FnService/Sync" )
const ( LogicService_Create_FullMethodName = "/edges.LogicService/Create" LogicService_Update_FullMethodName = "/edges.LogicService/Update" LogicService_View_FullMethodName = "/edges.LogicService/View" LogicService_Name_FullMethodName = "/edges.LogicService/Name" LogicService_Delete_FullMethodName = "/edges.LogicService/Delete" LogicService_List_FullMethodName = "/edges.LogicService/List" LogicService_Clone_FullMethodName = "/edges.LogicService/Clone" LogicService_ViewWithDeleted_FullMethodName = "/edges.LogicService/ViewWithDeleted" LogicService_Pull_FullMethodName = "/edges.LogicService/Pull" LogicService_Sync_FullMethodName = "/edges.LogicService/Sync" )
const ( SlotService_Create_FullMethodName = "/edges.SlotService/Create" SlotService_Update_FullMethodName = "/edges.SlotService/Update" SlotService_View_FullMethodName = "/edges.SlotService/View" SlotService_Name_FullMethodName = "/edges.SlotService/Name" SlotService_Delete_FullMethodName = "/edges.SlotService/Delete" SlotService_List_FullMethodName = "/edges.SlotService/List" SlotService_Link_FullMethodName = "/edges.SlotService/Link" SlotService_Clone_FullMethodName = "/edges.SlotService/Clone" SlotService_ViewWithDeleted_FullMethodName = "/edges.SlotService/ViewWithDeleted" SlotService_Pull_FullMethodName = "/edges.SlotService/Pull" SlotService_Sync_FullMethodName = "/edges.SlotService/Sync" )
const ( SourceService_Create_FullMethodName = "/edges.SourceService/Create" SourceService_Update_FullMethodName = "/edges.SourceService/Update" SourceService_View_FullMethodName = "/edges.SourceService/View" SourceService_Name_FullMethodName = "/edges.SourceService/Name" SourceService_Delete_FullMethodName = "/edges.SourceService/Delete" SourceService_List_FullMethodName = "/edges.SourceService/List" SourceService_Link_FullMethodName = "/edges.SourceService/Link" SourceService_Clone_FullMethodName = "/edges.SourceService/Clone" SourceService_ViewWithDeleted_FullMethodName = "/edges.SourceService/ViewWithDeleted" SourceService_Pull_FullMethodName = "/edges.SourceService/Pull" SourceService_Sync_FullMethodName = "/edges.SourceService/Sync" )
const ( TagService_Create_FullMethodName = "/edges.TagService/Create" TagService_Update_FullMethodName = "/edges.TagService/Update" TagService_View_FullMethodName = "/edges.TagService/View" TagService_Name_FullMethodName = "/edges.TagService/Name" TagService_Delete_FullMethodName = "/edges.TagService/Delete" TagService_List_FullMethodName = "/edges.TagService/List" TagService_Clone_FullMethodName = "/edges.TagService/Clone" TagService_ViewWithDeleted_FullMethodName = "/edges.TagService/ViewWithDeleted" TagService_Pull_FullMethodName = "/edges.TagService/Pull" TagService_Sync_FullMethodName = "/edges.TagService/Sync" TagService_GetValue_FullMethodName = "/edges.TagService/GetValue" TagService_SetValue_FullMethodName = "/edges.TagService/SetValue" TagService_SetValueForce_FullMethodName = "/edges.TagService/SetValueForce" TagService_GetValueByName_FullMethodName = "/edges.TagService/GetValueByName" TagService_SetValueByName_FullMethodName = "/edges.TagService/SetValueByName" TagService_SetValueByNameForce_FullMethodName = "/edges.TagService/SetValueByNameForce" TagService_ViewValue_FullMethodName = "/edges.TagService/ViewValue" TagService_DeleteValue_FullMethodName = "/edges.TagService/DeleteValue" TagService_PullValue_FullMethodName = "/edges.TagService/PullValue" TagService_SyncValue_FullMethodName = "/edges.TagService/SyncValue" )
const ( SyncService_SetDeviceUpdated_FullMethodName = "/edges.SyncService/SetDeviceUpdated" SyncService_GetDeviceUpdated_FullMethodName = "/edges.SyncService/GetDeviceUpdated" SyncService_WaitDeviceUpdated_FullMethodName = "/edges.SyncService/WaitDeviceUpdated" SyncService_SetOptionUpdated_FullMethodName = "/edges.SyncService/SetOptionUpdated" SyncService_GetOptionUpdated_FullMethodName = "/edges.SyncService/GetOptionUpdated" SyncService_SetSourceUpdated_FullMethodName = "/edges.SyncService/SetSourceUpdated" SyncService_GetSourceUpdated_FullMethodName = "/edges.SyncService/GetSourceUpdated" SyncService_SetTagUpdated_FullMethodName = "/edges.SyncService/SetTagUpdated" SyncService_GetTagUpdated_FullMethodName = "/edges.SyncService/GetTagUpdated" SyncService_SetConstUpdated_FullMethodName = "/edges.SyncService/SetConstUpdated" SyncService_GetConstUpdated_FullMethodName = "/edges.SyncService/GetConstUpdated" SyncService_SetClassUpdated_FullMethodName = "/edges.SyncService/SetClassUpdated" SyncService_GetClassUpdated_FullMethodName = "/edges.SyncService/GetClassUpdated" SyncService_SetAttrUpdated_FullMethodName = "/edges.SyncService/SetAttrUpdated" SyncService_GetAttrUpdated_FullMethodName = "/edges.SyncService/GetAttrUpdated" SyncService_SetLogicUpdated_FullMethodName = "/edges.SyncService/SetLogicUpdated" SyncService_GetLogicUpdated_FullMethodName = "/edges.SyncService/GetLogicUpdated" SyncService_SetFnUpdated_FullMethodName = "/edges.SyncService/SetFnUpdated" SyncService_GetFnUpdated_FullMethodName = "/edges.SyncService/GetFnUpdated" SyncService_SetTagValueUpdated_FullMethodName = "/edges.SyncService/SetTagValueUpdated" SyncService_GetTagValueUpdated_FullMethodName = "/edges.SyncService/GetTagValueUpdated" SyncService_WaitTagValueUpdated_FullMethodName = "/edges.SyncService/WaitTagValueUpdated" )
const ( UserService_Create_FullMethodName = "/edges.UserService/Create" UserService_Update_FullMethodName = "/edges.UserService/Update" UserService_View_FullMethodName = "/edges.UserService/View" UserService_Name_FullMethodName = "/edges.UserService/Name" UserService_Delete_FullMethodName = "/edges.UserService/Delete" UserService_List_FullMethodName = "/edges.UserService/List" UserService_ViewWithDeleted_FullMethodName = "/edges.UserService/ViewWithDeleted" UserService_Pull_FullMethodName = "/edges.UserService/Pull" )
Variables ¶
var AttrService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "edges.AttrService", HandlerType: (*AttrServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Create", Handler: _AttrService_Create_Handler, }, { MethodName: "Update", Handler: _AttrService_Update_Handler, }, { MethodName: "View", Handler: _AttrService_View_Handler, }, { MethodName: "Name", Handler: _AttrService_Name_Handler, }, { MethodName: "Delete", Handler: _AttrService_Delete_Handler, }, { MethodName: "List", Handler: _AttrService_List_Handler, }, { MethodName: "Clone", Handler: _AttrService_Clone_Handler, }, { MethodName: "ViewWithDeleted", Handler: _AttrService_ViewWithDeleted_Handler, }, { MethodName: "Pull", Handler: _AttrService_Pull_Handler, }, { MethodName: "Sync", Handler: _AttrService_Sync_Handler, }, { MethodName: "GetValue", Handler: _AttrService_GetValue_Handler, }, { MethodName: "SetValue", Handler: _AttrService_SetValue_Handler, }, { MethodName: "SetValueForce", Handler: _AttrService_SetValueForce_Handler, }, { MethodName: "GetValueByName", Handler: _AttrService_GetValueByName_Handler, }, { MethodName: "SetValueByName", Handler: _AttrService_SetValueByName_Handler, }, { MethodName: "SetValueByNameForce", Handler: _AttrService_SetValueByNameForce_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "edges/class_service.proto", }
AttrService_ServiceDesc is the grpc.ServiceDesc for AttrService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var AuthService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "edges.AuthService", HandlerType: (*AuthServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Login", Handler: _AuthService_Login_Handler, }, { MethodName: "ChangePass", Handler: _AuthService_ChangePass_Handler, }, { MethodName: "ForceChangePass", Handler: _AuthService_ForceChangePass_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "edges/auth_service.proto", }
AuthService_ServiceDesc is the grpc.ServiceDesc for AuthService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var ClassService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "edges.ClassService", HandlerType: (*ClassServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Create", Handler: _ClassService_Create_Handler, }, { MethodName: "Update", Handler: _ClassService_Update_Handler, }, { MethodName: "View", Handler: _ClassService_View_Handler, }, { MethodName: "Name", Handler: _ClassService_Name_Handler, }, { MethodName: "Delete", Handler: _ClassService_Delete_Handler, }, { MethodName: "List", Handler: _ClassService_List_Handler, }, { MethodName: "Clone", Handler: _ClassService_Clone_Handler, }, { MethodName: "ViewWithDeleted", Handler: _ClassService_ViewWithDeleted_Handler, }, { MethodName: "Pull", Handler: _ClassService_Pull_Handler, }, { MethodName: "Sync", Handler: _ClassService_Sync_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "edges/class_service.proto", }
ClassService_ServiceDesc is the grpc.ServiceDesc for ClassService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var ConstService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "edges.ConstService", HandlerType: (*ConstServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Create", Handler: _ConstService_Create_Handler, }, { MethodName: "Update", Handler: _ConstService_Update_Handler, }, { MethodName: "View", Handler: _ConstService_View_Handler, }, { MethodName: "Name", Handler: _ConstService_Name_Handler, }, { MethodName: "Delete", Handler: _ConstService_Delete_Handler, }, { MethodName: "List", Handler: _ConstService_List_Handler, }, { MethodName: "Clone", Handler: _ConstService_Clone_Handler, }, { MethodName: "ViewWithDeleted", Handler: _ConstService_ViewWithDeleted_Handler, }, { MethodName: "Pull", Handler: _ConstService_Pull_Handler, }, { MethodName: "Sync", Handler: _ConstService_Sync_Handler, }, { MethodName: "GetValue", Handler: _ConstService_GetValue_Handler, }, { MethodName: "SetValue", Handler: _ConstService_SetValue_Handler, }, { MethodName: "SetValueForce", Handler: _ConstService_SetValueForce_Handler, }, { MethodName: "GetValueByName", Handler: _ConstService_GetValueByName_Handler, }, { MethodName: "SetValueByName", Handler: _ConstService_SetValueByName_Handler, }, { MethodName: "SetValueByNameForce", Handler: _ConstService_SetValueByNameForce_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "edges/const_service.proto", }
ConstService_ServiceDesc is the grpc.ServiceDesc for ConstService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var ControlService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "edges.ControlService", HandlerType: (*ControlServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetTagValue", Handler: _ControlService_GetTagValue_Handler, }, { MethodName: "SetTagValue", Handler: _ControlService_SetTagValue_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "edges/control_service.proto", }
ControlService_ServiceDesc is the grpc.ServiceDesc for ControlService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var DataService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "edges.DataService", HandlerType: (*DataServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Upload", Handler: _DataService_Upload_Handler, }, { MethodName: "Compile", Handler: _DataService_Compile_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "Query", Handler: _DataService_Query_Handler, ServerStreams: true, }, { StreamName: "QueryById", Handler: _DataService_QueryById_Handler, ServerStreams: true, }, }, Metadata: "edges/data_service.proto", }
DataService_ServiceDesc is the grpc.ServiceDesc for DataService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var DeviceService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "edges.DeviceService", HandlerType: (*DeviceServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Update", Handler: _DeviceService_Update_Handler, }, { MethodName: "View", Handler: _DeviceService_View_Handler, }, { MethodName: "Destory", Handler: _DeviceService_Destory_Handler, }, { MethodName: "ViewWithDeleted", Handler: _DeviceService_ViewWithDeleted_Handler, }, { MethodName: "Sync", Handler: _DeviceService_Sync_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "edges/device_service.proto", }
DeviceService_ServiceDesc is the grpc.ServiceDesc for DeviceService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_edges_auth_service_proto protoreflect.FileDescriptor
var File_edges_class_service_proto protoreflect.FileDescriptor
var File_edges_const_service_proto protoreflect.FileDescriptor
var File_edges_control_service_proto protoreflect.FileDescriptor
var File_edges_data_service_proto protoreflect.FileDescriptor
var File_edges_device_service_proto protoreflect.FileDescriptor
var File_edges_logic_service_proto protoreflect.FileDescriptor
var File_edges_slot_service_proto protoreflect.FileDescriptor
var File_edges_source_service_proto protoreflect.FileDescriptor
var File_edges_sync_service_proto protoreflect.FileDescriptor
var File_edges_user_service_proto protoreflect.FileDescriptor
var FnService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "edges.FnService", HandlerType: (*FnServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Create", Handler: _FnService_Create_Handler, }, { MethodName: "Update", Handler: _FnService_Update_Handler, }, { MethodName: "View", Handler: _FnService_View_Handler, }, { MethodName: "Name", Handler: _FnService_Name_Handler, }, { MethodName: "Delete", Handler: _FnService_Delete_Handler, }, { MethodName: "List", Handler: _FnService_List_Handler, }, { MethodName: "Link", Handler: _FnService_Link_Handler, }, { MethodName: "Clone", Handler: _FnService_Clone_Handler, }, { MethodName: "ViewWithDeleted", Handler: _FnService_ViewWithDeleted_Handler, }, { MethodName: "Pull", Handler: _FnService_Pull_Handler, }, { MethodName: "Sync", Handler: _FnService_Sync_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "edges/logic_service.proto", }
FnService_ServiceDesc is the grpc.ServiceDesc for FnService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var LogicService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "edges.LogicService", HandlerType: (*LogicServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Create", Handler: _LogicService_Create_Handler, }, { MethodName: "Update", Handler: _LogicService_Update_Handler, }, { MethodName: "View", Handler: _LogicService_View_Handler, }, { MethodName: "Name", Handler: _LogicService_Name_Handler, }, { MethodName: "Delete", Handler: _LogicService_Delete_Handler, }, { MethodName: "List", Handler: _LogicService_List_Handler, }, { MethodName: "Clone", Handler: _LogicService_Clone_Handler, }, { MethodName: "ViewWithDeleted", Handler: _LogicService_ViewWithDeleted_Handler, }, { MethodName: "Pull", Handler: _LogicService_Pull_Handler, }, { MethodName: "Sync", Handler: _LogicService_Sync_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "edges/logic_service.proto", }
LogicService_ServiceDesc is the grpc.ServiceDesc for LogicService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var SlotService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "edges.SlotService", HandlerType: (*SlotServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Create", Handler: _SlotService_Create_Handler, }, { MethodName: "Update", Handler: _SlotService_Update_Handler, }, { MethodName: "View", Handler: _SlotService_View_Handler, }, { MethodName: "Name", Handler: _SlotService_Name_Handler, }, { MethodName: "Delete", Handler: _SlotService_Delete_Handler, }, { MethodName: "List", Handler: _SlotService_List_Handler, }, { MethodName: "Link", Handler: _SlotService_Link_Handler, }, { MethodName: "Clone", Handler: _SlotService_Clone_Handler, }, { MethodName: "ViewWithDeleted", Handler: _SlotService_ViewWithDeleted_Handler, }, { MethodName: "Pull", Handler: _SlotService_Pull_Handler, }, { MethodName: "Sync", Handler: _SlotService_Sync_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "edges/slot_service.proto", }
SlotService_ServiceDesc is the grpc.ServiceDesc for SlotService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var SourceService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "edges.SourceService", HandlerType: (*SourceServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Create", Handler: _SourceService_Create_Handler, }, { MethodName: "Update", Handler: _SourceService_Update_Handler, }, { MethodName: "View", Handler: _SourceService_View_Handler, }, { MethodName: "Name", Handler: _SourceService_Name_Handler, }, { MethodName: "Delete", Handler: _SourceService_Delete_Handler, }, { MethodName: "List", Handler: _SourceService_List_Handler, }, { MethodName: "Link", Handler: _SourceService_Link_Handler, }, { MethodName: "Clone", Handler: _SourceService_Clone_Handler, }, { MethodName: "ViewWithDeleted", Handler: _SourceService_ViewWithDeleted_Handler, }, { MethodName: "Pull", Handler: _SourceService_Pull_Handler, }, { MethodName: "Sync", Handler: _SourceService_Sync_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "edges/source_service.proto", }
SourceService_ServiceDesc is the grpc.ServiceDesc for SourceService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var SyncService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "edges.SyncService", HandlerType: (*SyncServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "SetDeviceUpdated", Handler: _SyncService_SetDeviceUpdated_Handler, }, { MethodName: "GetDeviceUpdated", Handler: _SyncService_GetDeviceUpdated_Handler, }, { MethodName: "SetOptionUpdated", Handler: _SyncService_SetOptionUpdated_Handler, }, { MethodName: "GetOptionUpdated", Handler: _SyncService_GetOptionUpdated_Handler, }, { MethodName: "SetSourceUpdated", Handler: _SyncService_SetSourceUpdated_Handler, }, { MethodName: "GetSourceUpdated", Handler: _SyncService_GetSourceUpdated_Handler, }, { MethodName: "SetTagUpdated", Handler: _SyncService_SetTagUpdated_Handler, }, { MethodName: "GetTagUpdated", Handler: _SyncService_GetTagUpdated_Handler, }, { MethodName: "SetConstUpdated", Handler: _SyncService_SetConstUpdated_Handler, }, { MethodName: "GetConstUpdated", Handler: _SyncService_GetConstUpdated_Handler, }, { MethodName: "SetClassUpdated", Handler: _SyncService_SetClassUpdated_Handler, }, { MethodName: "GetClassUpdated", Handler: _SyncService_GetClassUpdated_Handler, }, { MethodName: "SetAttrUpdated", Handler: _SyncService_SetAttrUpdated_Handler, }, { MethodName: "GetAttrUpdated", Handler: _SyncService_GetAttrUpdated_Handler, }, { MethodName: "SetLogicUpdated", Handler: _SyncService_SetLogicUpdated_Handler, }, { MethodName: "GetLogicUpdated", Handler: _SyncService_GetLogicUpdated_Handler, }, { MethodName: "SetFnUpdated", Handler: _SyncService_SetFnUpdated_Handler, }, { MethodName: "GetFnUpdated", Handler: _SyncService_GetFnUpdated_Handler, }, { MethodName: "SetTagValueUpdated", Handler: _SyncService_SetTagValueUpdated_Handler, }, { MethodName: "GetTagValueUpdated", Handler: _SyncService_GetTagValueUpdated_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "WaitDeviceUpdated", Handler: _SyncService_WaitDeviceUpdated_Handler, ServerStreams: true, }, { StreamName: "WaitTagValueUpdated", Handler: _SyncService_WaitTagValueUpdated_Handler, ServerStreams: true, }, }, Metadata: "edges/sync_service.proto", }
SyncService_ServiceDesc is the grpc.ServiceDesc for SyncService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var TagService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "edges.TagService", HandlerType: (*TagServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Create", Handler: _TagService_Create_Handler, }, { MethodName: "Update", Handler: _TagService_Update_Handler, }, { MethodName: "View", Handler: _TagService_View_Handler, }, { MethodName: "Name", Handler: _TagService_Name_Handler, }, { MethodName: "Delete", Handler: _TagService_Delete_Handler, }, { MethodName: "List", Handler: _TagService_List_Handler, }, { MethodName: "Clone", Handler: _TagService_Clone_Handler, }, { MethodName: "ViewWithDeleted", Handler: _TagService_ViewWithDeleted_Handler, }, { MethodName: "Pull", Handler: _TagService_Pull_Handler, }, { MethodName: "Sync", Handler: _TagService_Sync_Handler, }, { MethodName: "GetValue", Handler: _TagService_GetValue_Handler, }, { MethodName: "SetValue", Handler: _TagService_SetValue_Handler, }, { MethodName: "SetValueForce", Handler: _TagService_SetValueForce_Handler, }, { MethodName: "GetValueByName", Handler: _TagService_GetValueByName_Handler, }, { MethodName: "SetValueByName", Handler: _TagService_SetValueByName_Handler, }, { MethodName: "SetValueByNameForce", Handler: _TagService_SetValueByNameForce_Handler, }, { MethodName: "ViewValue", Handler: _TagService_ViewValue_Handler, }, { MethodName: "DeleteValue", Handler: _TagService_DeleteValue_Handler, }, { MethodName: "PullValue", Handler: _TagService_PullValue_Handler, }, { MethodName: "SyncValue", Handler: _TagService_SyncValue_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "edges/source_service.proto", }
TagService_ServiceDesc is the grpc.ServiceDesc for TagService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var UserService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "edges.UserService", HandlerType: (*UserServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Create", Handler: _UserService_Create_Handler, }, { MethodName: "Update", Handler: _UserService_Update_Handler, }, { MethodName: "View", Handler: _UserService_View_Handler, }, { MethodName: "Name", Handler: _UserService_Name_Handler, }, { MethodName: "Delete", Handler: _UserService_Delete_Handler, }, { MethodName: "List", Handler: _UserService_List_Handler, }, { MethodName: "ViewWithDeleted", Handler: _UserService_ViewWithDeleted_Handler, }, { MethodName: "Pull", Handler: _UserService_Pull_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "edges/user_service.proto", }
UserService_ServiceDesc is the grpc.ServiceDesc for UserService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterAttrServiceServer ¶
func RegisterAttrServiceServer(s grpc.ServiceRegistrar, srv AttrServiceServer)
func RegisterAuthServiceServer ¶
func RegisterAuthServiceServer(s grpc.ServiceRegistrar, srv AuthServiceServer)
func RegisterClassServiceServer ¶
func RegisterClassServiceServer(s grpc.ServiceRegistrar, srv ClassServiceServer)
func RegisterConstServiceServer ¶
func RegisterConstServiceServer(s grpc.ServiceRegistrar, srv ConstServiceServer)
func RegisterControlServiceServer ¶
func RegisterControlServiceServer(s grpc.ServiceRegistrar, srv ControlServiceServer)
func RegisterDataServiceServer ¶
func RegisterDataServiceServer(s grpc.ServiceRegistrar, srv DataServiceServer)
func RegisterDeviceServiceServer ¶
func RegisterDeviceServiceServer(s grpc.ServiceRegistrar, srv DeviceServiceServer)
func RegisterFnServiceServer ¶
func RegisterFnServiceServer(s grpc.ServiceRegistrar, srv FnServiceServer)
func RegisterLogicServiceServer ¶
func RegisterLogicServiceServer(s grpc.ServiceRegistrar, srv LogicServiceServer)
func RegisterSlotServiceServer ¶
func RegisterSlotServiceServer(s grpc.ServiceRegistrar, srv SlotServiceServer)
func RegisterSourceServiceServer ¶
func RegisterSourceServiceServer(s grpc.ServiceRegistrar, srv SourceServiceServer)
func RegisterSyncServiceServer ¶
func RegisterSyncServiceServer(s grpc.ServiceRegistrar, srv SyncServiceServer)
func RegisterTagServiceServer ¶
func RegisterTagServiceServer(s grpc.ServiceRegistrar, srv TagServiceServer)
func RegisterUserServiceServer ¶
func RegisterUserServiceServer(s grpc.ServiceRegistrar, srv UserServiceServer)
Types ¶
type AttrCloneRequest ¶
type AttrCloneRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` ClassId string `protobuf:"bytes,2,opt,name=class_id,json=classId,proto3" json:"class_id,omitempty"` // contains filtered or unexported fields }
func (*AttrCloneRequest) Descriptor
deprecated
func (*AttrCloneRequest) Descriptor() ([]byte, []int)
Deprecated: Use AttrCloneRequest.ProtoReflect.Descriptor instead.
func (*AttrCloneRequest) GetClassId ¶
func (x *AttrCloneRequest) GetClassId() string
func (*AttrCloneRequest) GetId ¶
func (x *AttrCloneRequest) GetId() string
func (*AttrCloneRequest) ProtoMessage ¶
func (*AttrCloneRequest) ProtoMessage()
func (*AttrCloneRequest) ProtoReflect ¶
func (x *AttrCloneRequest) ProtoReflect() protoreflect.Message
func (*AttrCloneRequest) Reset ¶
func (x *AttrCloneRequest) Reset()
func (*AttrCloneRequest) String ¶
func (x *AttrCloneRequest) String() string
type AttrListRequest ¶
type AttrListRequest struct { Page *pb.Page `protobuf:"bytes,1,opt,name=page,proto3" json:"page,omitempty"` // string device_id = 2; ClassId string `protobuf:"bytes,3,opt,name=class_id,json=classId,proto3" json:"class_id,omitempty"` Tags string `protobuf:"bytes,4,opt,name=tags,proto3" json:"tags,omitempty"` Type string `protobuf:"bytes,5,opt,name=type,proto3" json:"type,omitempty"` // contains filtered or unexported fields }
attr
func (*AttrListRequest) Descriptor
deprecated
func (*AttrListRequest) Descriptor() ([]byte, []int)
Deprecated: Use AttrListRequest.ProtoReflect.Descriptor instead.
func (*AttrListRequest) GetClassId ¶
func (x *AttrListRequest) GetClassId() string
func (*AttrListRequest) GetPage ¶
func (x *AttrListRequest) GetPage() *pb.Page
func (*AttrListRequest) GetTags ¶
func (x *AttrListRequest) GetTags() string
func (*AttrListRequest) GetType ¶
func (x *AttrListRequest) GetType() string
func (*AttrListRequest) ProtoMessage ¶
func (*AttrListRequest) ProtoMessage()
func (*AttrListRequest) ProtoReflect ¶
func (x *AttrListRequest) ProtoReflect() protoreflect.Message
func (*AttrListRequest) Reset ¶
func (x *AttrListRequest) Reset()
func (*AttrListRequest) String ¶
func (x *AttrListRequest) String() string
type AttrListResponse ¶
type AttrListResponse struct { Page *pb.Page `protobuf:"bytes,1,opt,name=page,proto3" json:"page,omitempty"` Count uint32 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` Attr []*pb.Attr `protobuf:"bytes,3,rep,name=attr,proto3" json:"attr,omitempty"` // contains filtered or unexported fields }
func (*AttrListResponse) Descriptor
deprecated
func (*AttrListResponse) Descriptor() ([]byte, []int)
Deprecated: Use AttrListResponse.ProtoReflect.Descriptor instead.
func (*AttrListResponse) GetAttr ¶
func (x *AttrListResponse) GetAttr() []*pb.Attr
func (*AttrListResponse) GetCount ¶
func (x *AttrListResponse) GetCount() uint32
func (*AttrListResponse) GetPage ¶
func (x *AttrListResponse) GetPage() *pb.Page
func (*AttrListResponse) ProtoMessage ¶
func (*AttrListResponse) ProtoMessage()
func (*AttrListResponse) ProtoReflect ¶
func (x *AttrListResponse) ProtoReflect() protoreflect.Message
func (*AttrListResponse) Reset ¶
func (x *AttrListResponse) Reset()
func (*AttrListResponse) String ¶
func (x *AttrListResponse) String() string
type AttrPullRequest ¶
type AttrPullRequest struct { After int64 `protobuf:"varint,1,opt,name=after,proto3" json:"after,omitempty"` Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` // string device_id = 3; ClassId string `protobuf:"bytes,4,opt,name=class_id,json=classId,proto3" json:"class_id,omitempty"` Type string `protobuf:"bytes,5,opt,name=type,proto3" json:"type,omitempty"` // contains filtered or unexported fields }
func (*AttrPullRequest) Descriptor
deprecated
func (*AttrPullRequest) Descriptor() ([]byte, []int)
Deprecated: Use AttrPullRequest.ProtoReflect.Descriptor instead.
func (*AttrPullRequest) GetAfter ¶
func (x *AttrPullRequest) GetAfter() int64
func (*AttrPullRequest) GetClassId ¶
func (x *AttrPullRequest) GetClassId() string
func (*AttrPullRequest) GetLimit ¶
func (x *AttrPullRequest) GetLimit() uint32
func (*AttrPullRequest) GetType ¶
func (x *AttrPullRequest) GetType() string
func (*AttrPullRequest) ProtoMessage ¶
func (*AttrPullRequest) ProtoMessage()
func (*AttrPullRequest) ProtoReflect ¶
func (x *AttrPullRequest) ProtoReflect() protoreflect.Message
func (*AttrPullRequest) Reset ¶
func (x *AttrPullRequest) Reset()
func (*AttrPullRequest) String ¶
func (x *AttrPullRequest) String() string
type AttrPullResponse ¶
type AttrPullResponse struct { After int64 `protobuf:"varint,1,opt,name=after,proto3" json:"after,omitempty"` Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` Attr []*pb.Attr `protobuf:"bytes,3,rep,name=attr,proto3" json:"attr,omitempty"` // contains filtered or unexported fields }
func (*AttrPullResponse) Descriptor
deprecated
func (*AttrPullResponse) Descriptor() ([]byte, []int)
Deprecated: Use AttrPullResponse.ProtoReflect.Descriptor instead.
func (*AttrPullResponse) GetAfter ¶
func (x *AttrPullResponse) GetAfter() int64
func (*AttrPullResponse) GetAttr ¶
func (x *AttrPullResponse) GetAttr() []*pb.Attr
func (*AttrPullResponse) GetLimit ¶
func (x *AttrPullResponse) GetLimit() uint32
func (*AttrPullResponse) ProtoMessage ¶
func (*AttrPullResponse) ProtoMessage()
func (*AttrPullResponse) ProtoReflect ¶
func (x *AttrPullResponse) ProtoReflect() protoreflect.Message
func (*AttrPullResponse) Reset ¶
func (x *AttrPullResponse) Reset()
func (*AttrPullResponse) String ¶
func (x *AttrPullResponse) String() string
type AttrServiceClient ¶
type AttrServiceClient interface { Create(ctx context.Context, in *pb.Attr, opts ...grpc.CallOption) (*pb.Attr, error) Update(ctx context.Context, in *pb.Attr, opts ...grpc.CallOption) (*pb.Attr, error) View(ctx context.Context, in *pb.Id, opts ...grpc.CallOption) (*pb.Attr, error) Name(ctx context.Context, in *pb.Name, opts ...grpc.CallOption) (*pb.Attr, error) Delete(ctx context.Context, in *pb.Id, opts ...grpc.CallOption) (*pb.MyBool, error) List(ctx context.Context, in *AttrListRequest, opts ...grpc.CallOption) (*AttrListResponse, error) Clone(ctx context.Context, in *AttrCloneRequest, opts ...grpc.CallOption) (*pb.MyBool, error) ViewWithDeleted(ctx context.Context, in *pb.Id, opts ...grpc.CallOption) (*pb.Attr, error) Pull(ctx context.Context, in *AttrPullRequest, opts ...grpc.CallOption) (*AttrPullResponse, error) Sync(ctx context.Context, in *pb.Attr, opts ...grpc.CallOption) (*pb.MyBool, error) GetValue(ctx context.Context, in *pb.Id, opts ...grpc.CallOption) (*pb.AttrValue, error) SetValue(ctx context.Context, in *pb.AttrValue, opts ...grpc.CallOption) (*pb.MyBool, error) SetValueForce(ctx context.Context, in *pb.AttrValue, opts ...grpc.CallOption) (*pb.MyBool, error) GetValueByName(ctx context.Context, in *pb.Name, opts ...grpc.CallOption) (*pb.AttrNameValue, error) SetValueByName(ctx context.Context, in *pb.AttrNameValue, opts ...grpc.CallOption) (*pb.MyBool, error) SetValueByNameForce(ctx context.Context, in *pb.AttrNameValue, opts ...grpc.CallOption) (*pb.MyBool, error) }
AttrServiceClient is the client API for AttrService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewAttrServiceClient ¶
func NewAttrServiceClient(cc grpc.ClientConnInterface) AttrServiceClient
type AttrServiceServer ¶
type AttrServiceServer interface { Create(context.Context, *pb.Attr) (*pb.Attr, error) Update(context.Context, *pb.Attr) (*pb.Attr, error) View(context.Context, *pb.Id) (*pb.Attr, error) Name(context.Context, *pb.Name) (*pb.Attr, error) Delete(context.Context, *pb.Id) (*pb.MyBool, error) List(context.Context, *AttrListRequest) (*AttrListResponse, error) Clone(context.Context, *AttrCloneRequest) (*pb.MyBool, error) ViewWithDeleted(context.Context, *pb.Id) (*pb.Attr, error) Pull(context.Context, *AttrPullRequest) (*AttrPullResponse, error) Sync(context.Context, *pb.Attr) (*pb.MyBool, error) GetValue(context.Context, *pb.Id) (*pb.AttrValue, error) SetValue(context.Context, *pb.AttrValue) (*pb.MyBool, error) SetValueForce(context.Context, *pb.AttrValue) (*pb.MyBool, error) GetValueByName(context.Context, *pb.Name) (*pb.AttrNameValue, error) SetValueByName(context.Context, *pb.AttrNameValue) (*pb.MyBool, error) SetValueByNameForce(context.Context, *pb.AttrNameValue) (*pb.MyBool, error) // contains filtered or unexported methods }
AttrServiceServer is the server API for AttrService service. All implementations must embed UnimplementedAttrServiceServer for forward compatibility
type AuthServiceClient ¶
type AuthServiceClient interface { Login(ctx context.Context, in *LoginRequest, opts ...grpc.CallOption) (*LoginResponse, error) ChangePass(ctx context.Context, in *ChangePassRequest, opts ...grpc.CallOption) (*pb.Message, error) ForceChangePass(ctx context.Context, in *ForceChangePassRequest, opts ...grpc.CallOption) (*pb.Message, error) }
AuthServiceClient is the client API for AuthService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewAuthServiceClient ¶
func NewAuthServiceClient(cc grpc.ClientConnInterface) AuthServiceClient
type AuthServiceServer ¶
type AuthServiceServer interface { Login(context.Context, *LoginRequest) (*LoginResponse, error) ChangePass(context.Context, *ChangePassRequest) (*pb.Message, error) ForceChangePass(context.Context, *ForceChangePassRequest) (*pb.Message, error) // contains filtered or unexported methods }
AuthServiceServer is the server API for AuthService service. All implementations must embed UnimplementedAuthServiceServer for forward compatibility
type ChangePassRequest ¶
type ChangePassRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` OldPass string `protobuf:"bytes,2,opt,name=old_pass,json=oldPass,proto3" json:"old_pass,omitempty"` NewPass string `protobuf:"bytes,3,opt,name=new_pass,json=newPass,proto3" json:"new_pass,omitempty"` // contains filtered or unexported fields }
func (*ChangePassRequest) Descriptor
deprecated
func (*ChangePassRequest) Descriptor() ([]byte, []int)
Deprecated: Use ChangePassRequest.ProtoReflect.Descriptor instead.
func (*ChangePassRequest) GetId ¶
func (x *ChangePassRequest) GetId() string
func (*ChangePassRequest) GetNewPass ¶
func (x *ChangePassRequest) GetNewPass() string
func (*ChangePassRequest) GetOldPass ¶
func (x *ChangePassRequest) GetOldPass() string
func (*ChangePassRequest) ProtoMessage ¶
func (*ChangePassRequest) ProtoMessage()
func (*ChangePassRequest) ProtoReflect ¶
func (x *ChangePassRequest) ProtoReflect() protoreflect.Message
func (*ChangePassRequest) Reset ¶
func (x *ChangePassRequest) Reset()
func (*ChangePassRequest) String ¶
func (x *ChangePassRequest) String() string
type ClassCloneRequest ¶
type ClassCloneRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // string device_id = 2; // contains filtered or unexported fields }
func (*ClassCloneRequest) Descriptor
deprecated
func (*ClassCloneRequest) Descriptor() ([]byte, []int)
Deprecated: Use ClassCloneRequest.ProtoReflect.Descriptor instead.
func (*ClassCloneRequest) GetId ¶
func (x *ClassCloneRequest) GetId() string
func (*ClassCloneRequest) ProtoMessage ¶
func (*ClassCloneRequest) ProtoMessage()
func (*ClassCloneRequest) ProtoReflect ¶
func (x *ClassCloneRequest) ProtoReflect() protoreflect.Message
func (*ClassCloneRequest) Reset ¶
func (x *ClassCloneRequest) Reset()
func (*ClassCloneRequest) String ¶
func (x *ClassCloneRequest) String() string
type ClassLinkRequest ¶
type ClassLinkRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Status int32 `protobuf:"zigzag32,2,opt,name=status,proto3" json:"status,omitempty"` // contains filtered or unexported fields }
func (*ClassLinkRequest) Descriptor
deprecated
func (*ClassLinkRequest) Descriptor() ([]byte, []int)
Deprecated: Use ClassLinkRequest.ProtoReflect.Descriptor instead.
func (*ClassLinkRequest) GetId ¶
func (x *ClassLinkRequest) GetId() string
func (*ClassLinkRequest) GetStatus ¶
func (x *ClassLinkRequest) GetStatus() int32
func (*ClassLinkRequest) ProtoMessage ¶
func (*ClassLinkRequest) ProtoMessage()
func (*ClassLinkRequest) ProtoReflect ¶
func (x *ClassLinkRequest) ProtoReflect() protoreflect.Message
func (*ClassLinkRequest) Reset ¶
func (x *ClassLinkRequest) Reset()
func (*ClassLinkRequest) String ¶
func (x *ClassLinkRequest) String() string
type ClassListRequest ¶
type ClassListRequest struct { Page *pb.Page `protobuf:"bytes,1,opt,name=page,proto3" json:"page,omitempty"` // string device_id = 2; Tags string `protobuf:"bytes,3,opt,name=tags,proto3" json:"tags,omitempty"` Type string `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"` // contains filtered or unexported fields }
class
func (*ClassListRequest) Descriptor
deprecated
func (*ClassListRequest) Descriptor() ([]byte, []int)
Deprecated: Use ClassListRequest.ProtoReflect.Descriptor instead.
func (*ClassListRequest) GetPage ¶
func (x *ClassListRequest) GetPage() *pb.Page
func (*ClassListRequest) GetTags ¶
func (x *ClassListRequest) GetTags() string
func (*ClassListRequest) GetType ¶
func (x *ClassListRequest) GetType() string
func (*ClassListRequest) ProtoMessage ¶
func (*ClassListRequest) ProtoMessage()
func (*ClassListRequest) ProtoReflect ¶
func (x *ClassListRequest) ProtoReflect() protoreflect.Message
func (*ClassListRequest) Reset ¶
func (x *ClassListRequest) Reset()
func (*ClassListRequest) String ¶
func (x *ClassListRequest) String() string
type ClassListResponse ¶
type ClassListResponse struct { Page *pb.Page `protobuf:"bytes,1,opt,name=page,proto3" json:"page,omitempty"` Count uint32 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` Class []*pb.Class `protobuf:"bytes,3,rep,name=class,proto3" json:"class,omitempty"` // contains filtered or unexported fields }
func (*ClassListResponse) Descriptor
deprecated
func (*ClassListResponse) Descriptor() ([]byte, []int)
Deprecated: Use ClassListResponse.ProtoReflect.Descriptor instead.
func (*ClassListResponse) GetClass ¶
func (x *ClassListResponse) GetClass() []*pb.Class
func (*ClassListResponse) GetCount ¶
func (x *ClassListResponse) GetCount() uint32
func (*ClassListResponse) GetPage ¶
func (x *ClassListResponse) GetPage() *pb.Page
func (*ClassListResponse) ProtoMessage ¶
func (*ClassListResponse) ProtoMessage()
func (*ClassListResponse) ProtoReflect ¶
func (x *ClassListResponse) ProtoReflect() protoreflect.Message
func (*ClassListResponse) Reset ¶
func (x *ClassListResponse) Reset()
func (*ClassListResponse) String ¶
func (x *ClassListResponse) String() string
type ClassPullRequest ¶
type ClassPullRequest struct { After int64 `protobuf:"varint,1,opt,name=after,proto3" json:"after,omitempty"` Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` // string device_id = 3; Type string `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"` // contains filtered or unexported fields }
func (*ClassPullRequest) Descriptor
deprecated
func (*ClassPullRequest) Descriptor() ([]byte, []int)
Deprecated: Use ClassPullRequest.ProtoReflect.Descriptor instead.
func (*ClassPullRequest) GetAfter ¶
func (x *ClassPullRequest) GetAfter() int64
func (*ClassPullRequest) GetLimit ¶
func (x *ClassPullRequest) GetLimit() uint32
func (*ClassPullRequest) GetType ¶
func (x *ClassPullRequest) GetType() string
func (*ClassPullRequest) ProtoMessage ¶
func (*ClassPullRequest) ProtoMessage()
func (*ClassPullRequest) ProtoReflect ¶
func (x *ClassPullRequest) ProtoReflect() protoreflect.Message
func (*ClassPullRequest) Reset ¶
func (x *ClassPullRequest) Reset()
func (*ClassPullRequest) String ¶
func (x *ClassPullRequest) String() string
type ClassPullResponse ¶
type ClassPullResponse struct { After int64 `protobuf:"varint,1,opt,name=after,proto3" json:"after,omitempty"` Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` Class []*pb.Class `protobuf:"bytes,3,rep,name=class,proto3" json:"class,omitempty"` // contains filtered or unexported fields }
func (*ClassPullResponse) Descriptor
deprecated
func (*ClassPullResponse) Descriptor() ([]byte, []int)
Deprecated: Use ClassPullResponse.ProtoReflect.Descriptor instead.
func (*ClassPullResponse) GetAfter ¶
func (x *ClassPullResponse) GetAfter() int64
func (*ClassPullResponse) GetClass ¶
func (x *ClassPullResponse) GetClass() []*pb.Class
func (*ClassPullResponse) GetLimit ¶
func (x *ClassPullResponse) GetLimit() uint32
func (*ClassPullResponse) ProtoMessage ¶
func (*ClassPullResponse) ProtoMessage()
func (*ClassPullResponse) ProtoReflect ¶
func (x *ClassPullResponse) ProtoReflect() protoreflect.Message
func (*ClassPullResponse) Reset ¶
func (x *ClassPullResponse) Reset()
func (*ClassPullResponse) String ¶
func (x *ClassPullResponse) String() string
type ClassServiceClient ¶
type ClassServiceClient interface { Create(ctx context.Context, in *pb.Class, opts ...grpc.CallOption) (*pb.Class, error) Update(ctx context.Context, in *pb.Class, opts ...grpc.CallOption) (*pb.Class, error) View(ctx context.Context, in *pb.Id, opts ...grpc.CallOption) (*pb.Class, error) Name(ctx context.Context, in *pb.Name, opts ...grpc.CallOption) (*pb.Class, error) Delete(ctx context.Context, in *pb.Id, opts ...grpc.CallOption) (*pb.MyBool, error) List(ctx context.Context, in *ClassListRequest, opts ...grpc.CallOption) (*ClassListResponse, error) Clone(ctx context.Context, in *ClassCloneRequest, opts ...grpc.CallOption) (*pb.MyBool, error) ViewWithDeleted(ctx context.Context, in *pb.Id, opts ...grpc.CallOption) (*pb.Class, error) Pull(ctx context.Context, in *ClassPullRequest, opts ...grpc.CallOption) (*ClassPullResponse, error) Sync(ctx context.Context, in *pb.Class, opts ...grpc.CallOption) (*pb.MyBool, error) }
ClassServiceClient is the client API for ClassService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewClassServiceClient ¶
func NewClassServiceClient(cc grpc.ClientConnInterface) ClassServiceClient
type ClassServiceServer ¶
type ClassServiceServer interface { Create(context.Context, *pb.Class) (*pb.Class, error) Update(context.Context, *pb.Class) (*pb.Class, error) View(context.Context, *pb.Id) (*pb.Class, error) Name(context.Context, *pb.Name) (*pb.Class, error) Delete(context.Context, *pb.Id) (*pb.MyBool, error) List(context.Context, *ClassListRequest) (*ClassListResponse, error) Clone(context.Context, *ClassCloneRequest) (*pb.MyBool, error) ViewWithDeleted(context.Context, *pb.Id) (*pb.Class, error) Pull(context.Context, *ClassPullRequest) (*ClassPullResponse, error) Sync(context.Context, *pb.Class) (*pb.MyBool, error) // contains filtered or unexported methods }
ClassServiceServer is the server API for ClassService service. All implementations must embed UnimplementedClassServiceServer for forward compatibility
type CloneFnRequest ¶
type CloneFnRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // string device_id = 2; // contains filtered or unexported fields }
func (*CloneFnRequest) Descriptor
deprecated
func (*CloneFnRequest) Descriptor() ([]byte, []int)
Deprecated: Use CloneFnRequest.ProtoReflect.Descriptor instead.
func (*CloneFnRequest) GetId ¶
func (x *CloneFnRequest) GetId() string
func (*CloneFnRequest) ProtoMessage ¶
func (*CloneFnRequest) ProtoMessage()
func (*CloneFnRequest) ProtoReflect ¶
func (x *CloneFnRequest) ProtoReflect() protoreflect.Message
func (*CloneFnRequest) Reset ¶
func (x *CloneFnRequest) Reset()
func (*CloneFnRequest) String ¶
func (x *CloneFnRequest) String() string
type ConstCloneRequest ¶
type ConstCloneRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // string device_id = 2; // contains filtered or unexported fields }
func (*ConstCloneRequest) Descriptor
deprecated
func (*ConstCloneRequest) Descriptor() ([]byte, []int)
Deprecated: Use ConstCloneRequest.ProtoReflect.Descriptor instead.
func (*ConstCloneRequest) GetId ¶
func (x *ConstCloneRequest) GetId() string
func (*ConstCloneRequest) ProtoMessage ¶
func (*ConstCloneRequest) ProtoMessage()
func (*ConstCloneRequest) ProtoReflect ¶
func (x *ConstCloneRequest) ProtoReflect() protoreflect.Message
func (*ConstCloneRequest) Reset ¶
func (x *ConstCloneRequest) Reset()
func (*ConstCloneRequest) String ¶
func (x *ConstCloneRequest) String() string
type ConstListRequest ¶
type ConstListRequest struct { Page *pb.Page `protobuf:"bytes,1,opt,name=page,proto3" json:"page,omitempty"` // string device_id = 2; Tags string `protobuf:"bytes,3,opt,name=tags,proto3" json:"tags,omitempty"` Type string `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"` // contains filtered or unexported fields }
func (*ConstListRequest) Descriptor
deprecated
func (*ConstListRequest) Descriptor() ([]byte, []int)
Deprecated: Use ConstListRequest.ProtoReflect.Descriptor instead.
func (*ConstListRequest) GetPage ¶
func (x *ConstListRequest) GetPage() *pb.Page
func (*ConstListRequest) GetTags ¶
func (x *ConstListRequest) GetTags() string
func (*ConstListRequest) GetType ¶
func (x *ConstListRequest) GetType() string
func (*ConstListRequest) ProtoMessage ¶
func (*ConstListRequest) ProtoMessage()
func (*ConstListRequest) ProtoReflect ¶
func (x *ConstListRequest) ProtoReflect() protoreflect.Message
func (*ConstListRequest) Reset ¶
func (x *ConstListRequest) Reset()
func (*ConstListRequest) String ¶
func (x *ConstListRequest) String() string
type ConstListResponse ¶
type ConstListResponse struct { Page *pb.Page `protobuf:"bytes,1,opt,name=page,proto3" json:"page,omitempty"` Count uint32 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` Const []*pb.Const `protobuf:"bytes,3,rep,name=const,proto3" json:"const,omitempty"` // contains filtered or unexported fields }
func (*ConstListResponse) Descriptor
deprecated
func (*ConstListResponse) Descriptor() ([]byte, []int)
Deprecated: Use ConstListResponse.ProtoReflect.Descriptor instead.
func (*ConstListResponse) GetConst ¶
func (x *ConstListResponse) GetConst() []*pb.Const
func (*ConstListResponse) GetCount ¶
func (x *ConstListResponse) GetCount() uint32
func (*ConstListResponse) GetPage ¶
func (x *ConstListResponse) GetPage() *pb.Page
func (*ConstListResponse) ProtoMessage ¶
func (*ConstListResponse) ProtoMessage()
func (*ConstListResponse) ProtoReflect ¶
func (x *ConstListResponse) ProtoReflect() protoreflect.Message
func (*ConstListResponse) Reset ¶
func (x *ConstListResponse) Reset()
func (*ConstListResponse) String ¶
func (x *ConstListResponse) String() string
type ConstPullRequest ¶
type ConstPullRequest struct { After int64 `protobuf:"varint,1,opt,name=after,proto3" json:"after,omitempty"` Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` // string device_id = 3; Type string `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"` // contains filtered or unexported fields }
func (*ConstPullRequest) Descriptor
deprecated
func (*ConstPullRequest) Descriptor() ([]byte, []int)
Deprecated: Use ConstPullRequest.ProtoReflect.Descriptor instead.
func (*ConstPullRequest) GetAfter ¶
func (x *ConstPullRequest) GetAfter() int64
func (*ConstPullRequest) GetLimit ¶
func (x *ConstPullRequest) GetLimit() uint32
func (*ConstPullRequest) GetType ¶
func (x *ConstPullRequest) GetType() string
func (*ConstPullRequest) ProtoMessage ¶
func (*ConstPullRequest) ProtoMessage()
func (*ConstPullRequest) ProtoReflect ¶
func (x *ConstPullRequest) ProtoReflect() protoreflect.Message
func (*ConstPullRequest) Reset ¶
func (x *ConstPullRequest) Reset()
func (*ConstPullRequest) String ¶
func (x *ConstPullRequest) String() string
type ConstPullResponse ¶
type ConstPullResponse struct { After int64 `protobuf:"varint,1,opt,name=after,proto3" json:"after,omitempty"` Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` Const []*pb.Const `protobuf:"bytes,3,rep,name=const,proto3" json:"const,omitempty"` // contains filtered or unexported fields }
func (*ConstPullResponse) Descriptor
deprecated
func (*ConstPullResponse) Descriptor() ([]byte, []int)
Deprecated: Use ConstPullResponse.ProtoReflect.Descriptor instead.
func (*ConstPullResponse) GetAfter ¶
func (x *ConstPullResponse) GetAfter() int64
func (*ConstPullResponse) GetConst ¶
func (x *ConstPullResponse) GetConst() []*pb.Const
func (*ConstPullResponse) GetLimit ¶
func (x *ConstPullResponse) GetLimit() uint32
func (*ConstPullResponse) ProtoMessage ¶
func (*ConstPullResponse) ProtoMessage()
func (*ConstPullResponse) ProtoReflect ¶
func (x *ConstPullResponse) ProtoReflect() protoreflect.Message
func (*ConstPullResponse) Reset ¶
func (x *ConstPullResponse) Reset()
func (*ConstPullResponse) String ¶
func (x *ConstPullResponse) String() string
type ConstServiceClient ¶
type ConstServiceClient interface { Create(ctx context.Context, in *pb.Const, opts ...grpc.CallOption) (*pb.Const, error) Update(ctx context.Context, in *pb.Const, opts ...grpc.CallOption) (*pb.Const, error) View(ctx context.Context, in *pb.Id, opts ...grpc.CallOption) (*pb.Const, error) Name(ctx context.Context, in *pb.Name, opts ...grpc.CallOption) (*pb.Const, error) Delete(ctx context.Context, in *pb.Id, opts ...grpc.CallOption) (*pb.MyBool, error) List(ctx context.Context, in *ConstListRequest, opts ...grpc.CallOption) (*ConstListResponse, error) Clone(ctx context.Context, in *ConstCloneRequest, opts ...grpc.CallOption) (*pb.MyBool, error) ViewWithDeleted(ctx context.Context, in *pb.Id, opts ...grpc.CallOption) (*pb.Const, error) Pull(ctx context.Context, in *ConstPullRequest, opts ...grpc.CallOption) (*ConstPullResponse, error) Sync(ctx context.Context, in *pb.Const, opts ...grpc.CallOption) (*pb.MyBool, error) GetValue(ctx context.Context, in *pb.Id, opts ...grpc.CallOption) (*pb.ConstValue, error) SetValue(ctx context.Context, in *pb.ConstValue, opts ...grpc.CallOption) (*pb.MyBool, error) SetValueForce(ctx context.Context, in *pb.ConstValue, opts ...grpc.CallOption) (*pb.MyBool, error) GetValueByName(ctx context.Context, in *pb.Name, opts ...grpc.CallOption) (*pb.ConstNameValue, error) SetValueByName(ctx context.Context, in *pb.ConstNameValue, opts ...grpc.CallOption) (*pb.MyBool, error) SetValueByNameForce(ctx context.Context, in *pb.ConstNameValue, opts ...grpc.CallOption) (*pb.MyBool, error) }
ConstServiceClient is the client API for ConstService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewConstServiceClient ¶
func NewConstServiceClient(cc grpc.ClientConnInterface) ConstServiceClient
type ConstServiceServer ¶
type ConstServiceServer interface { Create(context.Context, *pb.Const) (*pb.Const, error) Update(context.Context, *pb.Const) (*pb.Const, error) View(context.Context, *pb.Id) (*pb.Const, error) Name(context.Context, *pb.Name) (*pb.Const, error) Delete(context.Context, *pb.Id) (*pb.MyBool, error) List(context.Context, *ConstListRequest) (*ConstListResponse, error) Clone(context.Context, *ConstCloneRequest) (*pb.MyBool, error) ViewWithDeleted(context.Context, *pb.Id) (*pb.Const, error) Pull(context.Context, *ConstPullRequest) (*ConstPullResponse, error) Sync(context.Context, *pb.Const) (*pb.MyBool, error) GetValue(context.Context, *pb.Id) (*pb.ConstValue, error) SetValue(context.Context, *pb.ConstValue) (*pb.MyBool, error) SetValueForce(context.Context, *pb.ConstValue) (*pb.MyBool, error) GetValueByName(context.Context, *pb.Name) (*pb.ConstNameValue, error) SetValueByName(context.Context, *pb.ConstNameValue) (*pb.MyBool, error) SetValueByNameForce(context.Context, *pb.ConstNameValue) (*pb.MyBool, error) // contains filtered or unexported methods }
ConstServiceServer is the server API for ConstService service. All implementations must embed UnimplementedConstServiceServer for forward compatibility
type ControlServiceClient ¶
type ControlServiceClient interface { GetTagValue(ctx context.Context, in *pb.Id, opts ...grpc.CallOption) (*pb.TagValue, error) SetTagValue(ctx context.Context, in *pb.TagValue, opts ...grpc.CallOption) (*pb.TagValue, error) }
ControlServiceClient is the client API for ControlService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewControlServiceClient ¶
func NewControlServiceClient(cc grpc.ClientConnInterface) ControlServiceClient
type ControlServiceServer ¶
type ControlServiceServer interface { GetTagValue(context.Context, *pb.Id) (*pb.TagValue, error) SetTagValue(context.Context, *pb.TagValue) (*pb.TagValue, error) // contains filtered or unexported methods }
ControlServiceServer is the server API for ControlService service. All implementations must embed UnimplementedControlServiceServer for forward compatibility
type DataQueryByIdRequest ¶
type DataQueryByIdRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Vars map[string]string `` /* 149-byte string literal not displayed */ // contains filtered or unexported fields }
func (*DataQueryByIdRequest) Descriptor
deprecated
func (*DataQueryByIdRequest) Descriptor() ([]byte, []int)
Deprecated: Use DataQueryByIdRequest.ProtoReflect.Descriptor instead.
func (*DataQueryByIdRequest) GetId ¶
func (x *DataQueryByIdRequest) GetId() string
func (*DataQueryByIdRequest) GetVars ¶
func (x *DataQueryByIdRequest) GetVars() map[string]string
func (*DataQueryByIdRequest) ProtoMessage ¶
func (*DataQueryByIdRequest) ProtoMessage()
func (*DataQueryByIdRequest) ProtoReflect ¶
func (x *DataQueryByIdRequest) ProtoReflect() protoreflect.Message
func (*DataQueryByIdRequest) Reset ¶
func (x *DataQueryByIdRequest) Reset()
func (*DataQueryByIdRequest) String ¶
func (x *DataQueryByIdRequest) String() string
type DataQueryRequest ¶
type DataQueryRequest struct { Flux string `protobuf:"bytes,1,opt,name=flux,proto3" json:"flux,omitempty"` Vars map[string]string `` /* 149-byte string literal not displayed */ // contains filtered or unexported fields }
func (*DataQueryRequest) Descriptor
deprecated
func (*DataQueryRequest) Descriptor() ([]byte, []int)
Deprecated: Use DataQueryRequest.ProtoReflect.Descriptor instead.
func (*DataQueryRequest) GetFlux ¶
func (x *DataQueryRequest) GetFlux() string
func (*DataQueryRequest) GetVars ¶
func (x *DataQueryRequest) GetVars() map[string]string
func (*DataQueryRequest) ProtoMessage ¶
func (*DataQueryRequest) ProtoMessage()
func (*DataQueryRequest) ProtoReflect ¶
func (x *DataQueryRequest) ProtoReflect() protoreflect.Message
func (*DataQueryRequest) Reset ¶
func (x *DataQueryRequest) Reset()
func (*DataQueryRequest) String ¶
func (x *DataQueryRequest) String() string
type DataServiceClient ¶
type DataServiceClient interface { Upload(ctx context.Context, in *DataUploadRequest, opts ...grpc.CallOption) (*DataUploadResponse, error) Compile(ctx context.Context, in *DataQueryRequest, opts ...grpc.CallOption) (*pb.Message, error) Query(ctx context.Context, in *DataQueryRequest, opts ...grpc.CallOption) (DataService_QueryClient, error) QueryById(ctx context.Context, in *DataQueryByIdRequest, opts ...grpc.CallOption) (DataService_QueryByIdClient, error) }
DataServiceClient is the client API for DataService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewDataServiceClient ¶
func NewDataServiceClient(cc grpc.ClientConnInterface) DataServiceClient
type DataServiceServer ¶
type DataServiceServer interface { Upload(context.Context, *DataUploadRequest) (*DataUploadResponse, error) Compile(context.Context, *DataQueryRequest) (*pb.Message, error) Query(*DataQueryRequest, DataService_QueryServer) error QueryById(*DataQueryByIdRequest, DataService_QueryByIdServer) error // contains filtered or unexported methods }
DataServiceServer is the server API for DataService service. All implementations must embed UnimplementedDataServiceServer for forward compatibility
type DataService_QueryByIdClient ¶
type DataService_QueryByIdClient interface { Recv() (*pb.Message, error) grpc.ClientStream }
type DataService_QueryByIdServer ¶
type DataService_QueryByIdServer interface { Send(*pb.Message) error grpc.ServerStream }
type DataService_QueryClient ¶
type DataService_QueryClient interface { Recv() (*pb.Message, error) grpc.ClientStream }
type DataService_QueryServer ¶
type DataService_QueryServer interface { Send(*pb.Message) error grpc.ServerStream }
type DataUploadRequest ¶
type DataUploadRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` ContentType int32 `protobuf:"varint,2,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"` Content []byte `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"` // string device_id = 4; Realtime bool `protobuf:"varint,5,opt,name=realtime,proto3" json:"realtime,omitempty"` Save bool `protobuf:"varint,6,opt,name=save,proto3" json:"save,omitempty"` // contains filtered or unexported fields }
func (*DataUploadRequest) Descriptor
deprecated
func (*DataUploadRequest) Descriptor() ([]byte, []int)
Deprecated: Use DataUploadRequest.ProtoReflect.Descriptor instead.
func (*DataUploadRequest) GetContent ¶
func (x *DataUploadRequest) GetContent() []byte
func (*DataUploadRequest) GetContentType ¶
func (x *DataUploadRequest) GetContentType() int32
func (*DataUploadRequest) GetId ¶
func (x *DataUploadRequest) GetId() string
func (*DataUploadRequest) GetRealtime ¶
func (x *DataUploadRequest) GetRealtime() bool
func (*DataUploadRequest) GetSave ¶
func (x *DataUploadRequest) GetSave() bool
func (*DataUploadRequest) ProtoMessage ¶
func (*DataUploadRequest) ProtoMessage()
func (*DataUploadRequest) ProtoReflect ¶
func (x *DataUploadRequest) ProtoReflect() protoreflect.Message
func (*DataUploadRequest) Reset ¶
func (x *DataUploadRequest) Reset()
func (*DataUploadRequest) String ¶
func (x *DataUploadRequest) String() string
type DataUploadResponse ¶
type DataUploadResponse struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*DataUploadResponse) Descriptor
deprecated
func (*DataUploadResponse) Descriptor() ([]byte, []int)
Deprecated: Use DataUploadResponse.ProtoReflect.Descriptor instead.
func (*DataUploadResponse) GetId ¶
func (x *DataUploadResponse) GetId() string
func (*DataUploadResponse) GetMessage ¶
func (x *DataUploadResponse) GetMessage() string
func (*DataUploadResponse) ProtoMessage ¶
func (*DataUploadResponse) ProtoMessage()
func (*DataUploadResponse) ProtoReflect ¶
func (x *DataUploadResponse) ProtoReflect() protoreflect.Message
func (*DataUploadResponse) Reset ¶
func (x *DataUploadResponse) Reset()
func (*DataUploadResponse) String ¶
func (x *DataUploadResponse) String() string
type DeviceServiceClient ¶
type DeviceServiceClient interface { Update(ctx context.Context, in *pb.Device, opts ...grpc.CallOption) (*pb.Device, error) View(ctx context.Context, in *pb.MyEmpty, opts ...grpc.CallOption) (*pb.Device, error) Destory(ctx context.Context, in *pb.MyEmpty, opts ...grpc.CallOption) (*pb.MyBool, error) ViewWithDeleted(ctx context.Context, in *pb.MyEmpty, opts ...grpc.CallOption) (*pb.Device, error) Sync(ctx context.Context, in *pb.Device, opts ...grpc.CallOption) (*pb.MyBool, error) }
DeviceServiceClient is the client API for DeviceService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewDeviceServiceClient ¶
func NewDeviceServiceClient(cc grpc.ClientConnInterface) DeviceServiceClient
type DeviceServiceServer ¶
type DeviceServiceServer interface { Update(context.Context, *pb.Device) (*pb.Device, error) View(context.Context, *pb.MyEmpty) (*pb.Device, error) Destory(context.Context, *pb.MyEmpty) (*pb.MyBool, error) ViewWithDeleted(context.Context, *pb.MyEmpty) (*pb.Device, error) Sync(context.Context, *pb.Device) (*pb.MyBool, error) // contains filtered or unexported methods }
DeviceServiceServer is the server API for DeviceService service. All implementations must embed UnimplementedDeviceServiceServer for forward compatibility
type FnLinkRequest ¶
type FnLinkRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Status int32 `protobuf:"zigzag32,2,opt,name=status,proto3" json:"status,omitempty"` // contains filtered or unexported fields }
func (*FnLinkRequest) Descriptor
deprecated
func (*FnLinkRequest) Descriptor() ([]byte, []int)
Deprecated: Use FnLinkRequest.ProtoReflect.Descriptor instead.
func (*FnLinkRequest) GetId ¶
func (x *FnLinkRequest) GetId() string
func (*FnLinkRequest) GetStatus ¶
func (x *FnLinkRequest) GetStatus() int32
func (*FnLinkRequest) ProtoMessage ¶
func (*FnLinkRequest) ProtoMessage()
func (*FnLinkRequest) ProtoReflect ¶
func (x *FnLinkRequest) ProtoReflect() protoreflect.Message
func (*FnLinkRequest) Reset ¶
func (x *FnLinkRequest) Reset()
func (*FnLinkRequest) String ¶
func (x *FnLinkRequest) String() string
type FnListRequest ¶
type FnListRequest struct { Page *pb.Page `protobuf:"bytes,1,opt,name=page,proto3" json:"page,omitempty"` // string device_id = 2; Tags string `protobuf:"bytes,3,opt,name=tags,proto3" json:"tags,omitempty"` Type string `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"` Exec string `protobuf:"bytes,5,opt,name=exec,proto3" json:"exec,omitempty"` // contains filtered or unexported fields }
func (*FnListRequest) Descriptor
deprecated
func (*FnListRequest) Descriptor() ([]byte, []int)
Deprecated: Use FnListRequest.ProtoReflect.Descriptor instead.
func (*FnListRequest) GetExec ¶
func (x *FnListRequest) GetExec() string
func (*FnListRequest) GetPage ¶
func (x *FnListRequest) GetPage() *pb.Page
func (*FnListRequest) GetTags ¶
func (x *FnListRequest) GetTags() string
func (*FnListRequest) GetType ¶
func (x *FnListRequest) GetType() string
func (*FnListRequest) ProtoMessage ¶
func (*FnListRequest) ProtoMessage()
func (*FnListRequest) ProtoReflect ¶
func (x *FnListRequest) ProtoReflect() protoreflect.Message
func (*FnListRequest) Reset ¶
func (x *FnListRequest) Reset()
func (*FnListRequest) String ¶
func (x *FnListRequest) String() string
type FnListResponse ¶
type FnListResponse struct { Page *pb.Page `protobuf:"bytes,1,opt,name=page,proto3" json:"page,omitempty"` Count uint32 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` Fn []*pb.Fn `protobuf:"bytes,3,rep,name=fn,proto3" json:"fn,omitempty"` // contains filtered or unexported fields }
func (*FnListResponse) Descriptor
deprecated
func (*FnListResponse) Descriptor() ([]byte, []int)
Deprecated: Use FnListResponse.ProtoReflect.Descriptor instead.
func (*FnListResponse) GetCount ¶
func (x *FnListResponse) GetCount() uint32
func (*FnListResponse) GetFn ¶
func (x *FnListResponse) GetFn() []*pb.Fn
func (*FnListResponse) GetPage ¶
func (x *FnListResponse) GetPage() *pb.Page
func (*FnListResponse) ProtoMessage ¶
func (*FnListResponse) ProtoMessage()
func (*FnListResponse) ProtoReflect ¶
func (x *FnListResponse) ProtoReflect() protoreflect.Message
func (*FnListResponse) Reset ¶
func (x *FnListResponse) Reset()
func (*FnListResponse) String ¶
func (x *FnListResponse) String() string
type FnPullRequest ¶
type FnPullRequest struct { After int64 `protobuf:"varint,1,opt,name=after,proto3" json:"after,omitempty"` Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` // string device_id = 3; Exec string `protobuf:"bytes,4,opt,name=exec,proto3" json:"exec,omitempty"` // contains filtered or unexported fields }
func (*FnPullRequest) Descriptor
deprecated
func (*FnPullRequest) Descriptor() ([]byte, []int)
Deprecated: Use FnPullRequest.ProtoReflect.Descriptor instead.
func (*FnPullRequest) GetAfter ¶
func (x *FnPullRequest) GetAfter() int64
func (*FnPullRequest) GetExec ¶
func (x *FnPullRequest) GetExec() string
func (*FnPullRequest) GetLimit ¶
func (x *FnPullRequest) GetLimit() uint32
func (*FnPullRequest) ProtoMessage ¶
func (*FnPullRequest) ProtoMessage()
func (*FnPullRequest) ProtoReflect ¶
func (x *FnPullRequest) ProtoReflect() protoreflect.Message
func (*FnPullRequest) Reset ¶
func (x *FnPullRequest) Reset()
func (*FnPullRequest) String ¶
func (x *FnPullRequest) String() string
type FnPullResponse ¶
type FnPullResponse struct { After int64 `protobuf:"varint,1,opt,name=after,proto3" json:"after,omitempty"` Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` Fn []*pb.Fn `protobuf:"bytes,3,rep,name=fn,proto3" json:"fn,omitempty"` // contains filtered or unexported fields }
func (*FnPullResponse) Descriptor
deprecated
func (*FnPullResponse) Descriptor() ([]byte, []int)
Deprecated: Use FnPullResponse.ProtoReflect.Descriptor instead.
func (*FnPullResponse) GetAfter ¶
func (x *FnPullResponse) GetAfter() int64
func (*FnPullResponse) GetFn ¶
func (x *FnPullResponse) GetFn() []*pb.Fn
func (*FnPullResponse) GetLimit ¶
func (x *FnPullResponse) GetLimit() uint32
func (*FnPullResponse) ProtoMessage ¶
func (*FnPullResponse) ProtoMessage()
func (*FnPullResponse) ProtoReflect ¶
func (x *FnPullResponse) ProtoReflect() protoreflect.Message
func (*FnPullResponse) Reset ¶
func (x *FnPullResponse) Reset()
func (*FnPullResponse) String ¶
func (x *FnPullResponse) String() string
type FnServiceClient ¶
type FnServiceClient interface { Create(ctx context.Context, in *pb.Fn, opts ...grpc.CallOption) (*pb.Fn, error) Update(ctx context.Context, in *pb.Fn, opts ...grpc.CallOption) (*pb.Fn, error) View(ctx context.Context, in *pb.Id, opts ...grpc.CallOption) (*pb.Fn, error) Name(ctx context.Context, in *pb.Name, opts ...grpc.CallOption) (*pb.Fn, error) Delete(ctx context.Context, in *pb.Id, opts ...grpc.CallOption) (*pb.MyBool, error) List(ctx context.Context, in *FnListRequest, opts ...grpc.CallOption) (*FnListResponse, error) Link(ctx context.Context, in *FnLinkRequest, opts ...grpc.CallOption) (*pb.MyBool, error) Clone(ctx context.Context, in *CloneFnRequest, opts ...grpc.CallOption) (*pb.MyBool, error) ViewWithDeleted(ctx context.Context, in *pb.Id, opts ...grpc.CallOption) (*pb.Fn, error) Pull(ctx context.Context, in *FnPullRequest, opts ...grpc.CallOption) (*FnPullResponse, error) Sync(ctx context.Context, in *pb.Fn, opts ...grpc.CallOption) (*pb.MyBool, error) }
FnServiceClient is the client API for FnService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewFnServiceClient ¶
func NewFnServiceClient(cc grpc.ClientConnInterface) FnServiceClient
type FnServiceServer ¶
type FnServiceServer interface { Create(context.Context, *pb.Fn) (*pb.Fn, error) Update(context.Context, *pb.Fn) (*pb.Fn, error) View(context.Context, *pb.Id) (*pb.Fn, error) Name(context.Context, *pb.Name) (*pb.Fn, error) Delete(context.Context, *pb.Id) (*pb.MyBool, error) List(context.Context, *FnListRequest) (*FnListResponse, error) Link(context.Context, *FnLinkRequest) (*pb.MyBool, error) Clone(context.Context, *CloneFnRequest) (*pb.MyBool, error) ViewWithDeleted(context.Context, *pb.Id) (*pb.Fn, error) Pull(context.Context, *FnPullRequest) (*FnPullResponse, error) Sync(context.Context, *pb.Fn) (*pb.MyBool, error) // contains filtered or unexported methods }
FnServiceServer is the server API for FnService service. All implementations must embed UnimplementedFnServiceServer for forward compatibility
type ForceChangePassRequest ¶
type ForceChangePassRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` NewPass string `protobuf:"bytes,2,opt,name=new_pass,json=newPass,proto3" json:"new_pass,omitempty"` // contains filtered or unexported fields }
func (*ForceChangePassRequest) Descriptor
deprecated
func (*ForceChangePassRequest) Descriptor() ([]byte, []int)
Deprecated: Use ForceChangePassRequest.ProtoReflect.Descriptor instead.
func (*ForceChangePassRequest) GetId ¶
func (x *ForceChangePassRequest) GetId() string
func (*ForceChangePassRequest) GetNewPass ¶
func (x *ForceChangePassRequest) GetNewPass() string
func (*ForceChangePassRequest) ProtoMessage ¶
func (*ForceChangePassRequest) ProtoMessage()
func (*ForceChangePassRequest) ProtoReflect ¶
func (x *ForceChangePassRequest) ProtoReflect() protoreflect.Message
func (*ForceChangePassRequest) Reset ¶
func (x *ForceChangePassRequest) Reset()
func (*ForceChangePassRequest) String ¶
func (x *ForceChangePassRequest) String() string
type LinkLogicRequest ¶
type LinkLogicRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Status int32 `protobuf:"zigzag32,2,opt,name=status,proto3" json:"status,omitempty"` // contains filtered or unexported fields }
func (*LinkLogicRequest) Descriptor
deprecated
func (*LinkLogicRequest) Descriptor() ([]byte, []int)
Deprecated: Use LinkLogicRequest.ProtoReflect.Descriptor instead.
func (*LinkLogicRequest) GetId ¶
func (x *LinkLogicRequest) GetId() string
func (*LinkLogicRequest) GetStatus ¶
func (x *LinkLogicRequest) GetStatus() int32
func (*LinkLogicRequest) ProtoMessage ¶
func (*LinkLogicRequest) ProtoMessage()
func (*LinkLogicRequest) ProtoReflect ¶
func (x *LinkLogicRequest) ProtoReflect() protoreflect.Message
func (*LinkLogicRequest) Reset ¶
func (x *LinkLogicRequest) Reset()
func (*LinkLogicRequest) String ¶
func (x *LinkLogicRequest) String() string
type LogicCloneRequest ¶
type LogicCloneRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // string device_id = 2; // contains filtered or unexported fields }
func (*LogicCloneRequest) Descriptor
deprecated
func (*LogicCloneRequest) Descriptor() ([]byte, []int)
Deprecated: Use LogicCloneRequest.ProtoReflect.Descriptor instead.
func (*LogicCloneRequest) GetId ¶
func (x *LogicCloneRequest) GetId() string
func (*LogicCloneRequest) ProtoMessage ¶
func (*LogicCloneRequest) ProtoMessage()
func (*LogicCloneRequest) ProtoReflect ¶
func (x *LogicCloneRequest) ProtoReflect() protoreflect.Message
func (*LogicCloneRequest) Reset ¶
func (x *LogicCloneRequest) Reset()
func (*LogicCloneRequest) String ¶
func (x *LogicCloneRequest) String() string
type LogicListRequest ¶
type LogicListRequest struct { Page *pb.Page `protobuf:"bytes,1,opt,name=page,proto3" json:"page,omitempty"` // string device_id = 2; Tags string `protobuf:"bytes,3,opt,name=tags,proto3" json:"tags,omitempty"` Type string `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"` Exec string `protobuf:"bytes,5,opt,name=exec,proto3" json:"exec,omitempty"` // contains filtered or unexported fields }
func (*LogicListRequest) Descriptor
deprecated
func (*LogicListRequest) Descriptor() ([]byte, []int)
Deprecated: Use LogicListRequest.ProtoReflect.Descriptor instead.
func (*LogicListRequest) GetExec ¶
func (x *LogicListRequest) GetExec() string
func (*LogicListRequest) GetPage ¶
func (x *LogicListRequest) GetPage() *pb.Page
func (*LogicListRequest) GetTags ¶
func (x *LogicListRequest) GetTags() string
func (*LogicListRequest) GetType ¶
func (x *LogicListRequest) GetType() string
func (*LogicListRequest) ProtoMessage ¶
func (*LogicListRequest) ProtoMessage()
func (*LogicListRequest) ProtoReflect ¶
func (x *LogicListRequest) ProtoReflect() protoreflect.Message
func (*LogicListRequest) Reset ¶
func (x *LogicListRequest) Reset()
func (*LogicListRequest) String ¶
func (x *LogicListRequest) String() string
type LogicListResponse ¶
type LogicListResponse struct { Page *pb.Page `protobuf:"bytes,1,opt,name=page,proto3" json:"page,omitempty"` Count uint32 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` Logic []*pb.Logic `protobuf:"bytes,3,rep,name=logic,proto3" json:"logic,omitempty"` // contains filtered or unexported fields }
func (*LogicListResponse) Descriptor
deprecated
func (*LogicListResponse) Descriptor() ([]byte, []int)
Deprecated: Use LogicListResponse.ProtoReflect.Descriptor instead.
func (*LogicListResponse) GetCount ¶
func (x *LogicListResponse) GetCount() uint32
func (*LogicListResponse) GetLogic ¶
func (x *LogicListResponse) GetLogic() []*pb.Logic
func (*LogicListResponse) GetPage ¶
func (x *LogicListResponse) GetPage() *pb.Page
func (*LogicListResponse) ProtoMessage ¶
func (*LogicListResponse) ProtoMessage()
func (*LogicListResponse) ProtoReflect ¶
func (x *LogicListResponse) ProtoReflect() protoreflect.Message
func (*LogicListResponse) Reset ¶
func (x *LogicListResponse) Reset()
func (*LogicListResponse) String ¶
func (x *LogicListResponse) String() string
type LogicPullRequest ¶
type LogicPullRequest struct { After int64 `protobuf:"varint,1,opt,name=after,proto3" json:"after,omitempty"` Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` // string device_id = 3; Exec string `protobuf:"bytes,4,opt,name=exec,proto3" json:"exec,omitempty"` // contains filtered or unexported fields }
func (*LogicPullRequest) Descriptor
deprecated
func (*LogicPullRequest) Descriptor() ([]byte, []int)
Deprecated: Use LogicPullRequest.ProtoReflect.Descriptor instead.
func (*LogicPullRequest) GetAfter ¶
func (x *LogicPullRequest) GetAfter() int64
func (*LogicPullRequest) GetExec ¶
func (x *LogicPullRequest) GetExec() string
func (*LogicPullRequest) GetLimit ¶
func (x *LogicPullRequest) GetLimit() uint32
func (*LogicPullRequest) ProtoMessage ¶
func (*LogicPullRequest) ProtoMessage()
func (*LogicPullRequest) ProtoReflect ¶
func (x *LogicPullRequest) ProtoReflect() protoreflect.Message
func (*LogicPullRequest) Reset ¶
func (x *LogicPullRequest) Reset()
func (*LogicPullRequest) String ¶
func (x *LogicPullRequest) String() string
type LogicPullResponse ¶
type LogicPullResponse struct { After int64 `protobuf:"varint,1,opt,name=after,proto3" json:"after,omitempty"` Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` Logic []*pb.Logic `protobuf:"bytes,3,rep,name=logic,proto3" json:"logic,omitempty"` // contains filtered or unexported fields }
func (*LogicPullResponse) Descriptor
deprecated
func (*LogicPullResponse) Descriptor() ([]byte, []int)
Deprecated: Use LogicPullResponse.ProtoReflect.Descriptor instead.
func (*LogicPullResponse) GetAfter ¶
func (x *LogicPullResponse) GetAfter() int64
func (*LogicPullResponse) GetLimit ¶
func (x *LogicPullResponse) GetLimit() uint32
func (*LogicPullResponse) GetLogic ¶
func (x *LogicPullResponse) GetLogic() []*pb.Logic
func (*LogicPullResponse) ProtoMessage ¶
func (*LogicPullResponse) ProtoMessage()
func (*LogicPullResponse) ProtoReflect ¶
func (x *LogicPullResponse) ProtoReflect() protoreflect.Message
func (*LogicPullResponse) Reset ¶
func (x *LogicPullResponse) Reset()
func (*LogicPullResponse) String ¶
func (x *LogicPullResponse) String() string
type LogicServiceClient ¶
type LogicServiceClient interface { Create(ctx context.Context, in *pb.Logic, opts ...grpc.CallOption) (*pb.Logic, error) Update(ctx context.Context, in *pb.Logic, opts ...grpc.CallOption) (*pb.Logic, error) View(ctx context.Context, in *pb.Id, opts ...grpc.CallOption) (*pb.Logic, error) Name(ctx context.Context, in *pb.Name, opts ...grpc.CallOption) (*pb.Logic, error) Delete(ctx context.Context, in *pb.Id, opts ...grpc.CallOption) (*pb.MyBool, error) List(ctx context.Context, in *LogicListRequest, opts ...grpc.CallOption) (*LogicListResponse, error) Clone(ctx context.Context, in *LogicCloneRequest, opts ...grpc.CallOption) (*pb.MyBool, error) ViewWithDeleted(ctx context.Context, in *pb.Id, opts ...grpc.CallOption) (*pb.Logic, error) Pull(ctx context.Context, in *LogicPullRequest, opts ...grpc.CallOption) (*LogicPullResponse, error) Sync(ctx context.Context, in *pb.Logic, opts ...grpc.CallOption) (*pb.MyBool, error) }
LogicServiceClient is the client API for LogicService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewLogicServiceClient ¶
func NewLogicServiceClient(cc grpc.ClientConnInterface) LogicServiceClient
type LogicServiceServer ¶
type LogicServiceServer interface { Create(context.Context, *pb.Logic) (*pb.Logic, error) Update(context.Context, *pb.Logic) (*pb.Logic, error) View(context.Context, *pb.Id) (*pb.Logic, error) Name(context.Context, *pb.Name) (*pb.Logic, error) Delete(context.Context, *pb.Id) (*pb.MyBool, error) List(context.Context, *LogicListRequest) (*LogicListResponse, error) Clone(context.Context, *LogicCloneRequest) (*pb.MyBool, error) ViewWithDeleted(context.Context, *pb.Id) (*pb.Logic, error) Pull(context.Context, *LogicPullRequest) (*LogicPullResponse, error) Sync(context.Context, *pb.Logic) (*pb.MyBool, error) // contains filtered or unexported methods }
LogicServiceServer is the server API for LogicService service. All implementations must embed UnimplementedLogicServiceServer for forward compatibility
type LoginRequest ¶
type LoginRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Pass string `protobuf:"bytes,2,opt,name=pass,proto3" json:"pass,omitempty"` // contains filtered or unexported fields }
func (*LoginRequest) Descriptor
deprecated
func (*LoginRequest) Descriptor() ([]byte, []int)
Deprecated: Use LoginRequest.ProtoReflect.Descriptor instead.
func (*LoginRequest) GetName ¶
func (x *LoginRequest) GetName() string
func (*LoginRequest) GetPass ¶
func (x *LoginRequest) GetPass() string
func (*LoginRequest) ProtoMessage ¶
func (*LoginRequest) ProtoMessage()
func (*LoginRequest) ProtoReflect ¶
func (x *LoginRequest) ProtoReflect() protoreflect.Message
func (*LoginRequest) Reset ¶
func (x *LoginRequest) Reset()
func (*LoginRequest) String ¶
func (x *LoginRequest) String() string
type LoginResponse ¶
type LoginResponse struct { User *pb.User `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` // contains filtered or unexported fields }
func (*LoginResponse) Descriptor
deprecated
func (*LoginResponse) Descriptor() ([]byte, []int)
Deprecated: Use LoginResponse.ProtoReflect.Descriptor instead.
func (*LoginResponse) GetUser ¶
func (x *LoginResponse) GetUser() *pb.User
func (*LoginResponse) ProtoMessage ¶
func (*LoginResponse) ProtoMessage()
func (*LoginResponse) ProtoReflect ¶
func (x *LoginResponse) ProtoReflect() protoreflect.Message
func (*LoginResponse) Reset ¶
func (x *LoginResponse) Reset()
func (*LoginResponse) String ¶
func (x *LoginResponse) String() string
type SlotCloneRequest ¶
type SlotCloneRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // string device_id = 2; // contains filtered or unexported fields }
func (*SlotCloneRequest) Descriptor
deprecated
func (*SlotCloneRequest) Descriptor() ([]byte, []int)
Deprecated: Use SlotCloneRequest.ProtoReflect.Descriptor instead.
func (*SlotCloneRequest) GetId ¶
func (x *SlotCloneRequest) GetId() string
func (*SlotCloneRequest) ProtoMessage ¶
func (*SlotCloneRequest) ProtoMessage()
func (*SlotCloneRequest) ProtoReflect ¶
func (x *SlotCloneRequest) ProtoReflect() protoreflect.Message
func (*SlotCloneRequest) Reset ¶
func (x *SlotCloneRequest) Reset()
func (*SlotCloneRequest) String ¶
func (x *SlotCloneRequest) String() string
type SlotLinkRequest ¶
type SlotLinkRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Status int32 `protobuf:"zigzag32,2,opt,name=status,proto3" json:"status,omitempty"` // contains filtered or unexported fields }
func (*SlotLinkRequest) Descriptor
deprecated
func (*SlotLinkRequest) Descriptor() ([]byte, []int)
Deprecated: Use SlotLinkRequest.ProtoReflect.Descriptor instead.
func (*SlotLinkRequest) GetId ¶
func (x *SlotLinkRequest) GetId() string
func (*SlotLinkRequest) GetStatus ¶
func (x *SlotLinkRequest) GetStatus() int32
func (*SlotLinkRequest) ProtoMessage ¶
func (*SlotLinkRequest) ProtoMessage()
func (*SlotLinkRequest) ProtoReflect ¶
func (x *SlotLinkRequest) ProtoReflect() protoreflect.Message
func (*SlotLinkRequest) Reset ¶
func (x *SlotLinkRequest) Reset()
func (*SlotLinkRequest) String ¶
func (x *SlotLinkRequest) String() string
type SlotListRequest ¶
type SlotListRequest struct { Page *pb.Page `protobuf:"bytes,1,opt,name=page,proto3" json:"page,omitempty"` // string device_id = 2; Tags string `protobuf:"bytes,3,opt,name=tags,proto3" json:"tags,omitempty"` Type string `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"` // contains filtered or unexported fields }
func (*SlotListRequest) Descriptor
deprecated
func (*SlotListRequest) Descriptor() ([]byte, []int)
Deprecated: Use SlotListRequest.ProtoReflect.Descriptor instead.
func (*SlotListRequest) GetPage ¶
func (x *SlotListRequest) GetPage() *pb.Page
func (*SlotListRequest) GetTags ¶
func (x *SlotListRequest) GetTags() string
func (*SlotListRequest) GetType ¶
func (x *SlotListRequest) GetType() string
func (*SlotListRequest) ProtoMessage ¶
func (*SlotListRequest) ProtoMessage()
func (*SlotListRequest) ProtoReflect ¶
func (x *SlotListRequest) ProtoReflect() protoreflect.Message
func (*SlotListRequest) Reset ¶
func (x *SlotListRequest) Reset()
func (*SlotListRequest) String ¶
func (x *SlotListRequest) String() string
type SlotListResponse ¶
type SlotListResponse struct { Page *pb.Page `protobuf:"bytes,1,opt,name=page,proto3" json:"page,omitempty"` Count uint32 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` Slot []*pb.Slot `protobuf:"bytes,3,rep,name=slot,proto3" json:"slot,omitempty"` // contains filtered or unexported fields }
func (*SlotListResponse) Descriptor
deprecated
func (*SlotListResponse) Descriptor() ([]byte, []int)
Deprecated: Use SlotListResponse.ProtoReflect.Descriptor instead.
func (*SlotListResponse) GetCount ¶
func (x *SlotListResponse) GetCount() uint32
func (*SlotListResponse) GetPage ¶
func (x *SlotListResponse) GetPage() *pb.Page
func (*SlotListResponse) GetSlot ¶
func (x *SlotListResponse) GetSlot() []*pb.Slot
func (*SlotListResponse) ProtoMessage ¶
func (*SlotListResponse) ProtoMessage()
func (*SlotListResponse) ProtoReflect ¶
func (x *SlotListResponse) ProtoReflect() protoreflect.Message
func (*SlotListResponse) Reset ¶
func (x *SlotListResponse) Reset()
func (*SlotListResponse) String ¶
func (x *SlotListResponse) String() string
type SlotPullRequest ¶
type SlotPullRequest struct { After int64 `protobuf:"varint,1,opt,name=after,proto3" json:"after,omitempty"` Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` // string device_id = 3; Type string `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"` // contains filtered or unexported fields }
func (*SlotPullRequest) Descriptor
deprecated
func (*SlotPullRequest) Descriptor() ([]byte, []int)
Deprecated: Use SlotPullRequest.ProtoReflect.Descriptor instead.
func (*SlotPullRequest) GetAfter ¶
func (x *SlotPullRequest) GetAfter() int64
func (*SlotPullRequest) GetLimit ¶
func (x *SlotPullRequest) GetLimit() uint32
func (*SlotPullRequest) GetType ¶
func (x *SlotPullRequest) GetType() string
func (*SlotPullRequest) ProtoMessage ¶
func (*SlotPullRequest) ProtoMessage()
func (*SlotPullRequest) ProtoReflect ¶
func (x *SlotPullRequest) ProtoReflect() protoreflect.Message
func (*SlotPullRequest) Reset ¶
func (x *SlotPullRequest) Reset()
func (*SlotPullRequest) String ¶
func (x *SlotPullRequest) String() string
type SlotPullResponse ¶
type SlotPullResponse struct { After int64 `protobuf:"varint,1,opt,name=after,proto3" json:"after,omitempty"` Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` Slot []*pb.Slot `protobuf:"bytes,3,rep,name=slot,proto3" json:"slot,omitempty"` // contains filtered or unexported fields }
func (*SlotPullResponse) Descriptor
deprecated
func (*SlotPullResponse) Descriptor() ([]byte, []int)
Deprecated: Use SlotPullResponse.ProtoReflect.Descriptor instead.
func (*SlotPullResponse) GetAfter ¶
func (x *SlotPullResponse) GetAfter() int64
func (*SlotPullResponse) GetLimit ¶
func (x *SlotPullResponse) GetLimit() uint32
func (*SlotPullResponse) GetSlot ¶
func (x *SlotPullResponse) GetSlot() []*pb.Slot
func (*SlotPullResponse) ProtoMessage ¶
func (*SlotPullResponse) ProtoMessage()
func (*SlotPullResponse) ProtoReflect ¶
func (x *SlotPullResponse) ProtoReflect() protoreflect.Message
func (*SlotPullResponse) Reset ¶
func (x *SlotPullResponse) Reset()
func (*SlotPullResponse) String ¶
func (x *SlotPullResponse) String() string
type SlotServiceClient ¶
type SlotServiceClient interface { Create(ctx context.Context, in *pb.Slot, opts ...grpc.CallOption) (*pb.Slot, error) Update(ctx context.Context, in *pb.Slot, opts ...grpc.CallOption) (*pb.Slot, error) View(ctx context.Context, in *pb.Id, opts ...grpc.CallOption) (*pb.Slot, error) Name(ctx context.Context, in *pb.Name, opts ...grpc.CallOption) (*pb.Slot, error) Delete(ctx context.Context, in *pb.Id, opts ...grpc.CallOption) (*pb.MyBool, error) List(ctx context.Context, in *SlotListRequest, opts ...grpc.CallOption) (*SlotListResponse, error) Link(ctx context.Context, in *SlotLinkRequest, opts ...grpc.CallOption) (*pb.MyBool, error) Clone(ctx context.Context, in *SlotCloneRequest, opts ...grpc.CallOption) (*pb.MyBool, error) ViewWithDeleted(ctx context.Context, in *pb.Id, opts ...grpc.CallOption) (*pb.Slot, error) Pull(ctx context.Context, in *SlotPullRequest, opts ...grpc.CallOption) (*SlotPullResponse, error) Sync(ctx context.Context, in *pb.Slot, opts ...grpc.CallOption) (*pb.MyBool, error) }
SlotServiceClient is the client API for SlotService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewSlotServiceClient ¶
func NewSlotServiceClient(cc grpc.ClientConnInterface) SlotServiceClient
type SlotServiceServer ¶
type SlotServiceServer interface { Create(context.Context, *pb.Slot) (*pb.Slot, error) Update(context.Context, *pb.Slot) (*pb.Slot, error) View(context.Context, *pb.Id) (*pb.Slot, error) Name(context.Context, *pb.Name) (*pb.Slot, error) Delete(context.Context, *pb.Id) (*pb.MyBool, error) List(context.Context, *SlotListRequest) (*SlotListResponse, error) Link(context.Context, *SlotLinkRequest) (*pb.MyBool, error) Clone(context.Context, *SlotCloneRequest) (*pb.MyBool, error) ViewWithDeleted(context.Context, *pb.Id) (*pb.Slot, error) Pull(context.Context, *SlotPullRequest) (*SlotPullResponse, error) Sync(context.Context, *pb.Slot) (*pb.MyBool, error) // contains filtered or unexported methods }
SlotServiceServer is the server API for SlotService service. All implementations must embed UnimplementedSlotServiceServer for forward compatibility
type SourceCloneRequest ¶
type SourceCloneRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // string device_id = 2; // contains filtered or unexported fields }
func (*SourceCloneRequest) Descriptor
deprecated
func (*SourceCloneRequest) Descriptor() ([]byte, []int)
Deprecated: Use SourceCloneRequest.ProtoReflect.Descriptor instead.
func (*SourceCloneRequest) GetId ¶
func (x *SourceCloneRequest) GetId() string
func (*SourceCloneRequest) ProtoMessage ¶
func (*SourceCloneRequest) ProtoMessage()
func (*SourceCloneRequest) ProtoReflect ¶
func (x *SourceCloneRequest) ProtoReflect() protoreflect.Message
func (*SourceCloneRequest) Reset ¶
func (x *SourceCloneRequest) Reset()
func (*SourceCloneRequest) String ¶
func (x *SourceCloneRequest) String() string
type SourceLinkRequest ¶
type SourceLinkRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Status int32 `protobuf:"zigzag32,2,opt,name=status,proto3" json:"status,omitempty"` // contains filtered or unexported fields }
func (*SourceLinkRequest) Descriptor
deprecated
func (*SourceLinkRequest) Descriptor() ([]byte, []int)
Deprecated: Use SourceLinkRequest.ProtoReflect.Descriptor instead.
func (*SourceLinkRequest) GetId ¶
func (x *SourceLinkRequest) GetId() string
func (*SourceLinkRequest) GetStatus ¶
func (x *SourceLinkRequest) GetStatus() int32
func (*SourceLinkRequest) ProtoMessage ¶
func (*SourceLinkRequest) ProtoMessage()
func (*SourceLinkRequest) ProtoReflect ¶
func (x *SourceLinkRequest) ProtoReflect() protoreflect.Message
func (*SourceLinkRequest) Reset ¶
func (x *SourceLinkRequest) Reset()
func (*SourceLinkRequest) String ¶
func (x *SourceLinkRequest) String() string
type SourceListRequest ¶
type SourceListRequest struct { Page *pb.Page `protobuf:"bytes,1,opt,name=page,proto3" json:"page,omitempty"` // string device_id = 2; Tags string `protobuf:"bytes,3,opt,name=tags,proto3" json:"tags,omitempty"` Type string `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"` Source string `protobuf:"bytes,5,opt,name=source,proto3" json:"source,omitempty"` // contains filtered or unexported fields }
source
func (*SourceListRequest) Descriptor
deprecated
func (*SourceListRequest) Descriptor() ([]byte, []int)
Deprecated: Use SourceListRequest.ProtoReflect.Descriptor instead.
func (*SourceListRequest) GetPage ¶
func (x *SourceListRequest) GetPage() *pb.Page
func (*SourceListRequest) GetSource ¶
func (x *SourceListRequest) GetSource() string
func (*SourceListRequest) GetTags ¶
func (x *SourceListRequest) GetTags() string
func (*SourceListRequest) GetType ¶
func (x *SourceListRequest) GetType() string
func (*SourceListRequest) ProtoMessage ¶
func (*SourceListRequest) ProtoMessage()
func (*SourceListRequest) ProtoReflect ¶
func (x *SourceListRequest) ProtoReflect() protoreflect.Message
func (*SourceListRequest) Reset ¶
func (x *SourceListRequest) Reset()
func (*SourceListRequest) String ¶
func (x *SourceListRequest) String() string
type SourceListResponse ¶
type SourceListResponse struct { Page *pb.Page `protobuf:"bytes,1,opt,name=page,proto3" json:"page,omitempty"` Count uint32 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` Source []*pb.Source `protobuf:"bytes,3,rep,name=source,proto3" json:"source,omitempty"` // contains filtered or unexported fields }
func (*SourceListResponse) Descriptor
deprecated
func (*SourceListResponse) Descriptor() ([]byte, []int)
Deprecated: Use SourceListResponse.ProtoReflect.Descriptor instead.
func (*SourceListResponse) GetCount ¶
func (x *SourceListResponse) GetCount() uint32
func (*SourceListResponse) GetPage ¶
func (x *SourceListResponse) GetPage() *pb.Page
func (*SourceListResponse) GetSource ¶
func (x *SourceListResponse) GetSource() []*pb.Source
func (*SourceListResponse) ProtoMessage ¶
func (*SourceListResponse) ProtoMessage()
func (*SourceListResponse) ProtoReflect ¶
func (x *SourceListResponse) ProtoReflect() protoreflect.Message
func (*SourceListResponse) Reset ¶
func (x *SourceListResponse) Reset()
func (*SourceListResponse) String ¶
func (x *SourceListResponse) String() string
type SourcePullRequest ¶
type SourcePullRequest struct { After int64 `protobuf:"varint,1,opt,name=after,proto3" json:"after,omitempty"` Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` // string device_id = 3; Type string `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"` Source string `protobuf:"bytes,5,opt,name=source,proto3" json:"source,omitempty"` // contains filtered or unexported fields }
func (*SourcePullRequest) Descriptor
deprecated
func (*SourcePullRequest) Descriptor() ([]byte, []int)
Deprecated: Use SourcePullRequest.ProtoReflect.Descriptor instead.
func (*SourcePullRequest) GetAfter ¶
func (x *SourcePullRequest) GetAfter() int64
func (*SourcePullRequest) GetLimit ¶
func (x *SourcePullRequest) GetLimit() uint32
func (*SourcePullRequest) GetSource ¶
func (x *SourcePullRequest) GetSource() string
func (*SourcePullRequest) GetType ¶
func (x *SourcePullRequest) GetType() string
func (*SourcePullRequest) ProtoMessage ¶
func (*SourcePullRequest) ProtoMessage()
func (*SourcePullRequest) ProtoReflect ¶
func (x *SourcePullRequest) ProtoReflect() protoreflect.Message
func (*SourcePullRequest) Reset ¶
func (x *SourcePullRequest) Reset()
func (*SourcePullRequest) String ¶
func (x *SourcePullRequest) String() string
type SourcePullResponse ¶
type SourcePullResponse struct { After int64 `protobuf:"varint,1,opt,name=after,proto3" json:"after,omitempty"` Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` Source []*pb.Source `protobuf:"bytes,3,rep,name=source,proto3" json:"source,omitempty"` // contains filtered or unexported fields }
func (*SourcePullResponse) Descriptor
deprecated
func (*SourcePullResponse) Descriptor() ([]byte, []int)
Deprecated: Use SourcePullResponse.ProtoReflect.Descriptor instead.
func (*SourcePullResponse) GetAfter ¶
func (x *SourcePullResponse) GetAfter() int64
func (*SourcePullResponse) GetLimit ¶
func (x *SourcePullResponse) GetLimit() uint32
func (*SourcePullResponse) GetSource ¶
func (x *SourcePullResponse) GetSource() []*pb.Source
func (*SourcePullResponse) ProtoMessage ¶
func (*SourcePullResponse) ProtoMessage()
func (*SourcePullResponse) ProtoReflect ¶
func (x *SourcePullResponse) ProtoReflect() protoreflect.Message
func (*SourcePullResponse) Reset ¶
func (x *SourcePullResponse) Reset()
func (*SourcePullResponse) String ¶
func (x *SourcePullResponse) String() string
type SourceServiceClient ¶
type SourceServiceClient interface { Create(ctx context.Context, in *pb.Source, opts ...grpc.CallOption) (*pb.Source, error) Update(ctx context.Context, in *pb.Source, opts ...grpc.CallOption) (*pb.Source, error) View(ctx context.Context, in *pb.Id, opts ...grpc.CallOption) (*pb.Source, error) Name(ctx context.Context, in *pb.Name, opts ...grpc.CallOption) (*pb.Source, error) Delete(ctx context.Context, in *pb.Id, opts ...grpc.CallOption) (*pb.MyBool, error) List(ctx context.Context, in *SourceListRequest, opts ...grpc.CallOption) (*SourceListResponse, error) Link(ctx context.Context, in *SourceLinkRequest, opts ...grpc.CallOption) (*pb.MyBool, error) Clone(ctx context.Context, in *SourceCloneRequest, opts ...grpc.CallOption) (*pb.MyBool, error) ViewWithDeleted(ctx context.Context, in *pb.Id, opts ...grpc.CallOption) (*pb.Source, error) Pull(ctx context.Context, in *SourcePullRequest, opts ...grpc.CallOption) (*SourcePullResponse, error) Sync(ctx context.Context, in *pb.Source, opts ...grpc.CallOption) (*pb.MyBool, error) }
SourceServiceClient is the client API for SourceService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewSourceServiceClient ¶
func NewSourceServiceClient(cc grpc.ClientConnInterface) SourceServiceClient
type SourceServiceServer ¶
type SourceServiceServer interface { Create(context.Context, *pb.Source) (*pb.Source, error) Update(context.Context, *pb.Source) (*pb.Source, error) View(context.Context, *pb.Id) (*pb.Source, error) Name(context.Context, *pb.Name) (*pb.Source, error) Delete(context.Context, *pb.Id) (*pb.MyBool, error) List(context.Context, *SourceListRequest) (*SourceListResponse, error) Link(context.Context, *SourceLinkRequest) (*pb.MyBool, error) Clone(context.Context, *SourceCloneRequest) (*pb.MyBool, error) ViewWithDeleted(context.Context, *pb.Id) (*pb.Source, error) Pull(context.Context, *SourcePullRequest) (*SourcePullResponse, error) Sync(context.Context, *pb.Source) (*pb.MyBool, error) // contains filtered or unexported methods }
SourceServiceServer is the server API for SourceService service. All implementations must embed UnimplementedSourceServiceServer for forward compatibility
type SyncServiceClient ¶
type SyncServiceClient interface { SetDeviceUpdated(ctx context.Context, in *SyncUpdated, opts ...grpc.CallOption) (*pb.MyBool, error) GetDeviceUpdated(ctx context.Context, in *pb.MyEmpty, opts ...grpc.CallOption) (*SyncUpdated, error) WaitDeviceUpdated(ctx context.Context, in *pb.MyEmpty, opts ...grpc.CallOption) (SyncService_WaitDeviceUpdatedClient, error) SetOptionUpdated(ctx context.Context, in *SyncUpdated, opts ...grpc.CallOption) (*pb.MyBool, error) GetOptionUpdated(ctx context.Context, in *pb.MyEmpty, opts ...grpc.CallOption) (*SyncUpdated, error) SetSourceUpdated(ctx context.Context, in *SyncUpdated, opts ...grpc.CallOption) (*pb.MyBool, error) GetSourceUpdated(ctx context.Context, in *pb.MyEmpty, opts ...grpc.CallOption) (*SyncUpdated, error) SetTagUpdated(ctx context.Context, in *SyncUpdated, opts ...grpc.CallOption) (*pb.MyBool, error) GetTagUpdated(ctx context.Context, in *pb.MyEmpty, opts ...grpc.CallOption) (*SyncUpdated, error) SetConstUpdated(ctx context.Context, in *SyncUpdated, opts ...grpc.CallOption) (*pb.MyBool, error) GetConstUpdated(ctx context.Context, in *pb.MyEmpty, opts ...grpc.CallOption) (*SyncUpdated, error) SetClassUpdated(ctx context.Context, in *SyncUpdated, opts ...grpc.CallOption) (*pb.MyBool, error) GetClassUpdated(ctx context.Context, in *pb.MyEmpty, opts ...grpc.CallOption) (*SyncUpdated, error) SetAttrUpdated(ctx context.Context, in *SyncUpdated, opts ...grpc.CallOption) (*pb.MyBool, error) GetAttrUpdated(ctx context.Context, in *pb.MyEmpty, opts ...grpc.CallOption) (*SyncUpdated, error) SetLogicUpdated(ctx context.Context, in *SyncUpdated, opts ...grpc.CallOption) (*pb.MyBool, error) GetLogicUpdated(ctx context.Context, in *pb.MyEmpty, opts ...grpc.CallOption) (*SyncUpdated, error) SetFnUpdated(ctx context.Context, in *SyncUpdated, opts ...grpc.CallOption) (*pb.MyBool, error) GetFnUpdated(ctx context.Context, in *pb.MyEmpty, opts ...grpc.CallOption) (*SyncUpdated, error) SetTagValueUpdated(ctx context.Context, in *SyncUpdated, opts ...grpc.CallOption) (*pb.MyBool, error) GetTagValueUpdated(ctx context.Context, in *pb.MyEmpty, opts ...grpc.CallOption) (*SyncUpdated, error) WaitTagValueUpdated(ctx context.Context, in *pb.MyEmpty, opts ...grpc.CallOption) (SyncService_WaitTagValueUpdatedClient, error) }
SyncServiceClient is the client API for SyncService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewSyncServiceClient ¶
func NewSyncServiceClient(cc grpc.ClientConnInterface) SyncServiceClient
type SyncServiceServer ¶
type SyncServiceServer interface { SetDeviceUpdated(context.Context, *SyncUpdated) (*pb.MyBool, error) GetDeviceUpdated(context.Context, *pb.MyEmpty) (*SyncUpdated, error) WaitDeviceUpdated(*pb.MyEmpty, SyncService_WaitDeviceUpdatedServer) error SetOptionUpdated(context.Context, *SyncUpdated) (*pb.MyBool, error) GetOptionUpdated(context.Context, *pb.MyEmpty) (*SyncUpdated, error) SetSourceUpdated(context.Context, *SyncUpdated) (*pb.MyBool, error) GetSourceUpdated(context.Context, *pb.MyEmpty) (*SyncUpdated, error) SetTagUpdated(context.Context, *SyncUpdated) (*pb.MyBool, error) GetTagUpdated(context.Context, *pb.MyEmpty) (*SyncUpdated, error) SetConstUpdated(context.Context, *SyncUpdated) (*pb.MyBool, error) GetConstUpdated(context.Context, *pb.MyEmpty) (*SyncUpdated, error) SetClassUpdated(context.Context, *SyncUpdated) (*pb.MyBool, error) GetClassUpdated(context.Context, *pb.MyEmpty) (*SyncUpdated, error) SetAttrUpdated(context.Context, *SyncUpdated) (*pb.MyBool, error) GetAttrUpdated(context.Context, *pb.MyEmpty) (*SyncUpdated, error) SetLogicUpdated(context.Context, *SyncUpdated) (*pb.MyBool, error) GetLogicUpdated(context.Context, *pb.MyEmpty) (*SyncUpdated, error) SetFnUpdated(context.Context, *SyncUpdated) (*pb.MyBool, error) GetFnUpdated(context.Context, *pb.MyEmpty) (*SyncUpdated, error) SetTagValueUpdated(context.Context, *SyncUpdated) (*pb.MyBool, error) GetTagValueUpdated(context.Context, *pb.MyEmpty) (*SyncUpdated, error) WaitTagValueUpdated(*pb.MyEmpty, SyncService_WaitTagValueUpdatedServer) error // contains filtered or unexported methods }
SyncServiceServer is the server API for SyncService service. All implementations must embed UnimplementedSyncServiceServer for forward compatibility
type SyncService_WaitDeviceUpdatedClient ¶
type SyncService_WaitDeviceUpdatedClient interface { Recv() (*pb.MyBool, error) grpc.ClientStream }
type SyncService_WaitDeviceUpdatedServer ¶
type SyncService_WaitDeviceUpdatedServer interface { Send(*pb.MyBool) error grpc.ServerStream }
type SyncService_WaitTagValueUpdatedClient ¶
type SyncService_WaitTagValueUpdatedClient interface { Recv() (*pb.MyBool, error) grpc.ClientStream }
type SyncService_WaitTagValueUpdatedServer ¶
type SyncService_WaitTagValueUpdatedServer interface { Send(*pb.MyBool) error grpc.ServerStream }
type SyncUpdated ¶
type SyncUpdated struct { // string id = 1; Updated int64 `protobuf:"varint,2,opt,name=updated,proto3" json:"updated,omitempty"` // contains filtered or unexported fields }
func (*SyncUpdated) Descriptor
deprecated
func (*SyncUpdated) Descriptor() ([]byte, []int)
Deprecated: Use SyncUpdated.ProtoReflect.Descriptor instead.
func (*SyncUpdated) GetUpdated ¶
func (x *SyncUpdated) GetUpdated() int64
func (*SyncUpdated) ProtoMessage ¶
func (*SyncUpdated) ProtoMessage()
func (*SyncUpdated) ProtoReflect ¶
func (x *SyncUpdated) ProtoReflect() protoreflect.Message
func (*SyncUpdated) Reset ¶
func (x *SyncUpdated) Reset()
func (*SyncUpdated) String ¶
func (x *SyncUpdated) String() string
type TagCloneRequest ¶
type TagCloneRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` SourceId string `protobuf:"bytes,2,opt,name=source_id,json=sourceId,proto3" json:"source_id,omitempty"` // contains filtered or unexported fields }
func (*TagCloneRequest) Descriptor
deprecated
func (*TagCloneRequest) Descriptor() ([]byte, []int)
Deprecated: Use TagCloneRequest.ProtoReflect.Descriptor instead.
func (*TagCloneRequest) GetId ¶
func (x *TagCloneRequest) GetId() string
func (*TagCloneRequest) GetSourceId ¶
func (x *TagCloneRequest) GetSourceId() string
func (*TagCloneRequest) ProtoMessage ¶
func (*TagCloneRequest) ProtoMessage()
func (*TagCloneRequest) ProtoReflect ¶
func (x *TagCloneRequest) ProtoReflect() protoreflect.Message
func (*TagCloneRequest) Reset ¶
func (x *TagCloneRequest) Reset()
func (*TagCloneRequest) String ¶
func (x *TagCloneRequest) String() string
type TagListRequest ¶
type TagListRequest struct { Page *pb.Page `protobuf:"bytes,1,opt,name=page,proto3" json:"page,omitempty"` // string device_id = 2; SourceId string `protobuf:"bytes,3,opt,name=source_id,json=sourceId,proto3" json:"source_id,omitempty"` Tags string `protobuf:"bytes,4,opt,name=tags,proto3" json:"tags,omitempty"` Type string `protobuf:"bytes,5,opt,name=type,proto3" json:"type,omitempty"` // contains filtered or unexported fields }
tag
func (*TagListRequest) Descriptor
deprecated
func (*TagListRequest) Descriptor() ([]byte, []int)
Deprecated: Use TagListRequest.ProtoReflect.Descriptor instead.
func (*TagListRequest) GetPage ¶
func (x *TagListRequest) GetPage() *pb.Page
func (*TagListRequest) GetSourceId ¶
func (x *TagListRequest) GetSourceId() string
func (*TagListRequest) GetTags ¶
func (x *TagListRequest) GetTags() string
func (*TagListRequest) GetType ¶
func (x *TagListRequest) GetType() string
func (*TagListRequest) ProtoMessage ¶
func (*TagListRequest) ProtoMessage()
func (*TagListRequest) ProtoReflect ¶
func (x *TagListRequest) ProtoReflect() protoreflect.Message
func (*TagListRequest) Reset ¶
func (x *TagListRequest) Reset()
func (*TagListRequest) String ¶
func (x *TagListRequest) String() string
type TagListResponse ¶
type TagListResponse struct { Page *pb.Page `protobuf:"bytes,1,opt,name=page,proto3" json:"page,omitempty"` Count uint32 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` Tag []*pb.Tag `protobuf:"bytes,3,rep,name=tag,proto3" json:"tag,omitempty"` // contains filtered or unexported fields }
func (*TagListResponse) Descriptor
deprecated
func (*TagListResponse) Descriptor() ([]byte, []int)
Deprecated: Use TagListResponse.ProtoReflect.Descriptor instead.
func (*TagListResponse) GetCount ¶
func (x *TagListResponse) GetCount() uint32
func (*TagListResponse) GetPage ¶
func (x *TagListResponse) GetPage() *pb.Page
func (*TagListResponse) GetTag ¶
func (x *TagListResponse) GetTag() []*pb.Tag
func (*TagListResponse) ProtoMessage ¶
func (*TagListResponse) ProtoMessage()
func (*TagListResponse) ProtoReflect ¶
func (x *TagListResponse) ProtoReflect() protoreflect.Message
func (*TagListResponse) Reset ¶
func (x *TagListResponse) Reset()
func (*TagListResponse) String ¶
func (x *TagListResponse) String() string
type TagPullRequest ¶
type TagPullRequest struct { After int64 `protobuf:"varint,1,opt,name=after,proto3" json:"after,omitempty"` Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` // string device_id = 3; SourceId string `protobuf:"bytes,4,opt,name=source_id,json=sourceId,proto3" json:"source_id,omitempty"` Type string `protobuf:"bytes,5,opt,name=type,proto3" json:"type,omitempty"` // contains filtered or unexported fields }
func (*TagPullRequest) Descriptor
deprecated
func (*TagPullRequest) Descriptor() ([]byte, []int)
Deprecated: Use TagPullRequest.ProtoReflect.Descriptor instead.
func (*TagPullRequest) GetAfter ¶
func (x *TagPullRequest) GetAfter() int64
func (*TagPullRequest) GetLimit ¶
func (x *TagPullRequest) GetLimit() uint32
func (*TagPullRequest) GetSourceId ¶
func (x *TagPullRequest) GetSourceId() string
func (*TagPullRequest) GetType ¶
func (x *TagPullRequest) GetType() string
func (*TagPullRequest) ProtoMessage ¶
func (*TagPullRequest) ProtoMessage()
func (*TagPullRequest) ProtoReflect ¶
func (x *TagPullRequest) ProtoReflect() protoreflect.Message
func (*TagPullRequest) Reset ¶
func (x *TagPullRequest) Reset()
func (*TagPullRequest) String ¶
func (x *TagPullRequest) String() string
type TagPullResponse ¶
type TagPullResponse struct { After int64 `protobuf:"varint,1,opt,name=after,proto3" json:"after,omitempty"` Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` Tag []*pb.Tag `protobuf:"bytes,3,rep,name=tag,proto3" json:"tag,omitempty"` // contains filtered or unexported fields }
func (*TagPullResponse) Descriptor
deprecated
func (*TagPullResponse) Descriptor() ([]byte, []int)
Deprecated: Use TagPullResponse.ProtoReflect.Descriptor instead.
func (*TagPullResponse) GetAfter ¶
func (x *TagPullResponse) GetAfter() int64
func (*TagPullResponse) GetLimit ¶
func (x *TagPullResponse) GetLimit() uint32
func (*TagPullResponse) GetTag ¶
func (x *TagPullResponse) GetTag() []*pb.Tag
func (*TagPullResponse) ProtoMessage ¶
func (*TagPullResponse) ProtoMessage()
func (*TagPullResponse) ProtoReflect ¶
func (x *TagPullResponse) ProtoReflect() protoreflect.Message
func (*TagPullResponse) Reset ¶
func (x *TagPullResponse) Reset()
func (*TagPullResponse) String ¶
func (x *TagPullResponse) String() string
type TagPullValueRequest ¶
type TagPullValueRequest struct { After int64 `protobuf:"varint,1,opt,name=after,proto3" json:"after,omitempty"` Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` // string device_id = 3; SourceId string `protobuf:"bytes,4,opt,name=source_id,json=sourceId,proto3" json:"source_id,omitempty"` // contains filtered or unexported fields }
func (*TagPullValueRequest) Descriptor
deprecated
func (*TagPullValueRequest) Descriptor() ([]byte, []int)
Deprecated: Use TagPullValueRequest.ProtoReflect.Descriptor instead.
func (*TagPullValueRequest) GetAfter ¶
func (x *TagPullValueRequest) GetAfter() int64
func (*TagPullValueRequest) GetLimit ¶
func (x *TagPullValueRequest) GetLimit() uint32
func (*TagPullValueRequest) GetSourceId ¶
func (x *TagPullValueRequest) GetSourceId() string
func (*TagPullValueRequest) ProtoMessage ¶
func (*TagPullValueRequest) ProtoMessage()
func (*TagPullValueRequest) ProtoReflect ¶
func (x *TagPullValueRequest) ProtoReflect() protoreflect.Message
func (*TagPullValueRequest) Reset ¶
func (x *TagPullValueRequest) Reset()
func (*TagPullValueRequest) String ¶
func (x *TagPullValueRequest) String() string
type TagPullValueResponse ¶
type TagPullValueResponse struct { After int64 `protobuf:"varint,1,opt,name=after,proto3" json:"after,omitempty"` Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` Tag []*pb.TagValueUpdated `protobuf:"bytes,3,rep,name=tag,proto3" json:"tag,omitempty"` // contains filtered or unexported fields }
func (*TagPullValueResponse) Descriptor
deprecated
func (*TagPullValueResponse) Descriptor() ([]byte, []int)
Deprecated: Use TagPullValueResponse.ProtoReflect.Descriptor instead.
func (*TagPullValueResponse) GetAfter ¶
func (x *TagPullValueResponse) GetAfter() int64
func (*TagPullValueResponse) GetLimit ¶
func (x *TagPullValueResponse) GetLimit() uint32
func (*TagPullValueResponse) GetTag ¶
func (x *TagPullValueResponse) GetTag() []*pb.TagValueUpdated
func (*TagPullValueResponse) ProtoMessage ¶
func (*TagPullValueResponse) ProtoMessage()
func (*TagPullValueResponse) ProtoReflect ¶
func (x *TagPullValueResponse) ProtoReflect() protoreflect.Message
func (*TagPullValueResponse) Reset ¶
func (x *TagPullValueResponse) Reset()
func (*TagPullValueResponse) String ¶
func (x *TagPullValueResponse) String() string
type TagServiceClient ¶
type TagServiceClient interface { Create(ctx context.Context, in *pb.Tag, opts ...grpc.CallOption) (*pb.Tag, error) Update(ctx context.Context, in *pb.Tag, opts ...grpc.CallOption) (*pb.Tag, error) View(ctx context.Context, in *pb.Id, opts ...grpc.CallOption) (*pb.Tag, error) Name(ctx context.Context, in *pb.Name, opts ...grpc.CallOption) (*pb.Tag, error) Delete(ctx context.Context, in *pb.Id, opts ...grpc.CallOption) (*pb.MyBool, error) List(ctx context.Context, in *TagListRequest, opts ...grpc.CallOption) (*TagListResponse, error) Clone(ctx context.Context, in *TagCloneRequest, opts ...grpc.CallOption) (*pb.MyBool, error) ViewWithDeleted(ctx context.Context, in *pb.Id, opts ...grpc.CallOption) (*pb.Tag, error) Pull(ctx context.Context, in *TagPullRequest, opts ...grpc.CallOption) (*TagPullResponse, error) Sync(ctx context.Context, in *pb.Tag, opts ...grpc.CallOption) (*pb.MyBool, error) GetValue(ctx context.Context, in *pb.Id, opts ...grpc.CallOption) (*pb.TagValue, error) SetValue(ctx context.Context, in *pb.TagValue, opts ...grpc.CallOption) (*pb.MyBool, error) SetValueForce(ctx context.Context, in *pb.TagValue, opts ...grpc.CallOption) (*pb.MyBool, error) GetValueByName(ctx context.Context, in *pb.Name, opts ...grpc.CallOption) (*pb.TagNameValue, error) SetValueByName(ctx context.Context, in *pb.TagNameValue, opts ...grpc.CallOption) (*pb.MyBool, error) SetValueByNameForce(ctx context.Context, in *pb.TagNameValue, opts ...grpc.CallOption) (*pb.MyBool, error) ViewValue(ctx context.Context, in *pb.Id, opts ...grpc.CallOption) (*pb.TagValueUpdated, error) DeleteValue(ctx context.Context, in *pb.Id, opts ...grpc.CallOption) (*pb.MyBool, error) PullValue(ctx context.Context, in *TagPullValueRequest, opts ...grpc.CallOption) (*TagPullValueResponse, error) SyncValue(ctx context.Context, in *pb.TagValue, opts ...grpc.CallOption) (*pb.MyBool, error) }
TagServiceClient is the client API for TagService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewTagServiceClient ¶
func NewTagServiceClient(cc grpc.ClientConnInterface) TagServiceClient
type TagServiceServer ¶
type TagServiceServer interface { Create(context.Context, *pb.Tag) (*pb.Tag, error) Update(context.Context, *pb.Tag) (*pb.Tag, error) View(context.Context, *pb.Id) (*pb.Tag, error) Name(context.Context, *pb.Name) (*pb.Tag, error) Delete(context.Context, *pb.Id) (*pb.MyBool, error) List(context.Context, *TagListRequest) (*TagListResponse, error) Clone(context.Context, *TagCloneRequest) (*pb.MyBool, error) ViewWithDeleted(context.Context, *pb.Id) (*pb.Tag, error) Pull(context.Context, *TagPullRequest) (*TagPullResponse, error) Sync(context.Context, *pb.Tag) (*pb.MyBool, error) GetValue(context.Context, *pb.Id) (*pb.TagValue, error) SetValue(context.Context, *pb.TagValue) (*pb.MyBool, error) SetValueForce(context.Context, *pb.TagValue) (*pb.MyBool, error) GetValueByName(context.Context, *pb.Name) (*pb.TagNameValue, error) SetValueByName(context.Context, *pb.TagNameValue) (*pb.MyBool, error) SetValueByNameForce(context.Context, *pb.TagNameValue) (*pb.MyBool, error) ViewValue(context.Context, *pb.Id) (*pb.TagValueUpdated, error) DeleteValue(context.Context, *pb.Id) (*pb.MyBool, error) PullValue(context.Context, *TagPullValueRequest) (*TagPullValueResponse, error) SyncValue(context.Context, *pb.TagValue) (*pb.MyBool, error) // contains filtered or unexported methods }
TagServiceServer is the server API for TagService service. All implementations must embed UnimplementedTagServiceServer for forward compatibility
type UnimplementedAttrServiceServer ¶
type UnimplementedAttrServiceServer struct { }
UnimplementedAttrServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedAttrServiceServer) Clone ¶
func (UnimplementedAttrServiceServer) Clone(context.Context, *AttrCloneRequest) (*pb.MyBool, error)
func (UnimplementedAttrServiceServer) GetValueByName ¶
func (UnimplementedAttrServiceServer) GetValueByName(context.Context, *pb.Name) (*pb.AttrNameValue, error)
func (UnimplementedAttrServiceServer) List ¶
func (UnimplementedAttrServiceServer) List(context.Context, *AttrListRequest) (*AttrListResponse, error)
func (UnimplementedAttrServiceServer) Pull ¶
func (UnimplementedAttrServiceServer) Pull(context.Context, *AttrPullRequest) (*AttrPullResponse, error)
func (UnimplementedAttrServiceServer) SetValueByName ¶
func (UnimplementedAttrServiceServer) SetValueByName(context.Context, *pb.AttrNameValue) (*pb.MyBool, error)
func (UnimplementedAttrServiceServer) SetValueByNameForce ¶
func (UnimplementedAttrServiceServer) SetValueByNameForce(context.Context, *pb.AttrNameValue) (*pb.MyBool, error)
func (UnimplementedAttrServiceServer) SetValueForce ¶
func (UnimplementedAttrServiceServer) ViewWithDeleted ¶
type UnimplementedAuthServiceServer ¶
type UnimplementedAuthServiceServer struct { }
UnimplementedAuthServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedAuthServiceServer) ChangePass ¶
func (UnimplementedAuthServiceServer) ChangePass(context.Context, *ChangePassRequest) (*pb.Message, error)
func (UnimplementedAuthServiceServer) ForceChangePass ¶
func (UnimplementedAuthServiceServer) ForceChangePass(context.Context, *ForceChangePassRequest) (*pb.Message, error)
func (UnimplementedAuthServiceServer) Login ¶
func (UnimplementedAuthServiceServer) Login(context.Context, *LoginRequest) (*LoginResponse, error)
type UnimplementedClassServiceServer ¶
type UnimplementedClassServiceServer struct { }
UnimplementedClassServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedClassServiceServer) Clone ¶
func (UnimplementedClassServiceServer) Clone(context.Context, *ClassCloneRequest) (*pb.MyBool, error)
func (UnimplementedClassServiceServer) List ¶
func (UnimplementedClassServiceServer) List(context.Context, *ClassListRequest) (*ClassListResponse, error)
func (UnimplementedClassServiceServer) Pull ¶
func (UnimplementedClassServiceServer) Pull(context.Context, *ClassPullRequest) (*ClassPullResponse, error)
func (UnimplementedClassServiceServer) ViewWithDeleted ¶
type UnimplementedConstServiceServer ¶
type UnimplementedConstServiceServer struct { }
UnimplementedConstServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedConstServiceServer) Clone ¶
func (UnimplementedConstServiceServer) Clone(context.Context, *ConstCloneRequest) (*pb.MyBool, error)
func (UnimplementedConstServiceServer) GetValue ¶
func (UnimplementedConstServiceServer) GetValue(context.Context, *pb.Id) (*pb.ConstValue, error)
func (UnimplementedConstServiceServer) GetValueByName ¶
func (UnimplementedConstServiceServer) GetValueByName(context.Context, *pb.Name) (*pb.ConstNameValue, error)
func (UnimplementedConstServiceServer) List ¶
func (UnimplementedConstServiceServer) List(context.Context, *ConstListRequest) (*ConstListResponse, error)
func (UnimplementedConstServiceServer) Pull ¶
func (UnimplementedConstServiceServer) Pull(context.Context, *ConstPullRequest) (*ConstPullResponse, error)
func (UnimplementedConstServiceServer) SetValue ¶
func (UnimplementedConstServiceServer) SetValue(context.Context, *pb.ConstValue) (*pb.MyBool, error)
func (UnimplementedConstServiceServer) SetValueByName ¶
func (UnimplementedConstServiceServer) SetValueByName(context.Context, *pb.ConstNameValue) (*pb.MyBool, error)
func (UnimplementedConstServiceServer) SetValueByNameForce ¶
func (UnimplementedConstServiceServer) SetValueByNameForce(context.Context, *pb.ConstNameValue) (*pb.MyBool, error)
func (UnimplementedConstServiceServer) SetValueForce ¶
func (UnimplementedConstServiceServer) SetValueForce(context.Context, *pb.ConstValue) (*pb.MyBool, error)
func (UnimplementedConstServiceServer) ViewWithDeleted ¶
type UnimplementedControlServiceServer ¶
type UnimplementedControlServiceServer struct { }
UnimplementedControlServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedControlServiceServer) GetTagValue ¶
func (UnimplementedControlServiceServer) SetTagValue ¶
type UnimplementedDataServiceServer ¶
type UnimplementedDataServiceServer struct { }
UnimplementedDataServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedDataServiceServer) Compile ¶
func (UnimplementedDataServiceServer) Compile(context.Context, *DataQueryRequest) (*pb.Message, error)
func (UnimplementedDataServiceServer) Query ¶
func (UnimplementedDataServiceServer) Query(*DataQueryRequest, DataService_QueryServer) error
func (UnimplementedDataServiceServer) QueryById ¶
func (UnimplementedDataServiceServer) QueryById(*DataQueryByIdRequest, DataService_QueryByIdServer) error
func (UnimplementedDataServiceServer) Upload ¶
func (UnimplementedDataServiceServer) Upload(context.Context, *DataUploadRequest) (*DataUploadResponse, error)
type UnimplementedDeviceServiceServer ¶
type UnimplementedDeviceServiceServer struct { }
UnimplementedDeviceServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedDeviceServiceServer) ViewWithDeleted ¶
type UnimplementedFnServiceServer ¶
type UnimplementedFnServiceServer struct { }
UnimplementedFnServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedFnServiceServer) Clone ¶
func (UnimplementedFnServiceServer) Clone(context.Context, *CloneFnRequest) (*pb.MyBool, error)
func (UnimplementedFnServiceServer) Link ¶
func (UnimplementedFnServiceServer) Link(context.Context, *FnLinkRequest) (*pb.MyBool, error)
func (UnimplementedFnServiceServer) List ¶
func (UnimplementedFnServiceServer) List(context.Context, *FnListRequest) (*FnListResponse, error)
func (UnimplementedFnServiceServer) Pull ¶
func (UnimplementedFnServiceServer) Pull(context.Context, *FnPullRequest) (*FnPullResponse, error)
func (UnimplementedFnServiceServer) ViewWithDeleted ¶
type UnimplementedLogicServiceServer ¶
type UnimplementedLogicServiceServer struct { }
UnimplementedLogicServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedLogicServiceServer) Clone ¶
func (UnimplementedLogicServiceServer) Clone(context.Context, *LogicCloneRequest) (*pb.MyBool, error)
func (UnimplementedLogicServiceServer) List ¶
func (UnimplementedLogicServiceServer) List(context.Context, *LogicListRequest) (*LogicListResponse, error)
func (UnimplementedLogicServiceServer) Pull ¶
func (UnimplementedLogicServiceServer) Pull(context.Context, *LogicPullRequest) (*LogicPullResponse, error)
func (UnimplementedLogicServiceServer) ViewWithDeleted ¶
type UnimplementedSlotServiceServer ¶
type UnimplementedSlotServiceServer struct { }
UnimplementedSlotServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedSlotServiceServer) Clone ¶
func (UnimplementedSlotServiceServer) Clone(context.Context, *SlotCloneRequest) (*pb.MyBool, error)
func (UnimplementedSlotServiceServer) Link ¶
func (UnimplementedSlotServiceServer) Link(context.Context, *SlotLinkRequest) (*pb.MyBool, error)
func (UnimplementedSlotServiceServer) List ¶
func (UnimplementedSlotServiceServer) List(context.Context, *SlotListRequest) (*SlotListResponse, error)
func (UnimplementedSlotServiceServer) Pull ¶
func (UnimplementedSlotServiceServer) Pull(context.Context, *SlotPullRequest) (*SlotPullResponse, error)
func (UnimplementedSlotServiceServer) ViewWithDeleted ¶
type UnimplementedSourceServiceServer ¶
type UnimplementedSourceServiceServer struct { }
UnimplementedSourceServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedSourceServiceServer) Clone ¶
func (UnimplementedSourceServiceServer) Clone(context.Context, *SourceCloneRequest) (*pb.MyBool, error)
func (UnimplementedSourceServiceServer) Link ¶
func (UnimplementedSourceServiceServer) Link(context.Context, *SourceLinkRequest) (*pb.MyBool, error)
func (UnimplementedSourceServiceServer) List ¶
func (UnimplementedSourceServiceServer) List(context.Context, *SourceListRequest) (*SourceListResponse, error)
func (UnimplementedSourceServiceServer) Pull ¶
func (UnimplementedSourceServiceServer) Pull(context.Context, *SourcePullRequest) (*SourcePullResponse, error)
func (UnimplementedSourceServiceServer) ViewWithDeleted ¶
type UnimplementedSyncServiceServer ¶
type UnimplementedSyncServiceServer struct { }
UnimplementedSyncServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedSyncServiceServer) GetAttrUpdated ¶
func (UnimplementedSyncServiceServer) GetAttrUpdated(context.Context, *pb.MyEmpty) (*SyncUpdated, error)
func (UnimplementedSyncServiceServer) GetClassUpdated ¶
func (UnimplementedSyncServiceServer) GetClassUpdated(context.Context, *pb.MyEmpty) (*SyncUpdated, error)
func (UnimplementedSyncServiceServer) GetConstUpdated ¶
func (UnimplementedSyncServiceServer) GetConstUpdated(context.Context, *pb.MyEmpty) (*SyncUpdated, error)
func (UnimplementedSyncServiceServer) GetDeviceUpdated ¶
func (UnimplementedSyncServiceServer) GetDeviceUpdated(context.Context, *pb.MyEmpty) (*SyncUpdated, error)
func (UnimplementedSyncServiceServer) GetFnUpdated ¶
func (UnimplementedSyncServiceServer) GetFnUpdated(context.Context, *pb.MyEmpty) (*SyncUpdated, error)
func (UnimplementedSyncServiceServer) GetLogicUpdated ¶
func (UnimplementedSyncServiceServer) GetLogicUpdated(context.Context, *pb.MyEmpty) (*SyncUpdated, error)
func (UnimplementedSyncServiceServer) GetOptionUpdated ¶
func (UnimplementedSyncServiceServer) GetOptionUpdated(context.Context, *pb.MyEmpty) (*SyncUpdated, error)
func (UnimplementedSyncServiceServer) GetSourceUpdated ¶
func (UnimplementedSyncServiceServer) GetSourceUpdated(context.Context, *pb.MyEmpty) (*SyncUpdated, error)
func (UnimplementedSyncServiceServer) GetTagUpdated ¶
func (UnimplementedSyncServiceServer) GetTagUpdated(context.Context, *pb.MyEmpty) (*SyncUpdated, error)
func (UnimplementedSyncServiceServer) GetTagValueUpdated ¶
func (UnimplementedSyncServiceServer) GetTagValueUpdated(context.Context, *pb.MyEmpty) (*SyncUpdated, error)
func (UnimplementedSyncServiceServer) SetAttrUpdated ¶
func (UnimplementedSyncServiceServer) SetAttrUpdated(context.Context, *SyncUpdated) (*pb.MyBool, error)
func (UnimplementedSyncServiceServer) SetClassUpdated ¶
func (UnimplementedSyncServiceServer) SetClassUpdated(context.Context, *SyncUpdated) (*pb.MyBool, error)
func (UnimplementedSyncServiceServer) SetConstUpdated ¶
func (UnimplementedSyncServiceServer) SetConstUpdated(context.Context, *SyncUpdated) (*pb.MyBool, error)
func (UnimplementedSyncServiceServer) SetDeviceUpdated ¶
func (UnimplementedSyncServiceServer) SetDeviceUpdated(context.Context, *SyncUpdated) (*pb.MyBool, error)
func (UnimplementedSyncServiceServer) SetFnUpdated ¶
func (UnimplementedSyncServiceServer) SetFnUpdated(context.Context, *SyncUpdated) (*pb.MyBool, error)
func (UnimplementedSyncServiceServer) SetLogicUpdated ¶
func (UnimplementedSyncServiceServer) SetLogicUpdated(context.Context, *SyncUpdated) (*pb.MyBool, error)
func (UnimplementedSyncServiceServer) SetOptionUpdated ¶
func (UnimplementedSyncServiceServer) SetOptionUpdated(context.Context, *SyncUpdated) (*pb.MyBool, error)
func (UnimplementedSyncServiceServer) SetSourceUpdated ¶
func (UnimplementedSyncServiceServer) SetSourceUpdated(context.Context, *SyncUpdated) (*pb.MyBool, error)
func (UnimplementedSyncServiceServer) SetTagUpdated ¶
func (UnimplementedSyncServiceServer) SetTagUpdated(context.Context, *SyncUpdated) (*pb.MyBool, error)
func (UnimplementedSyncServiceServer) SetTagValueUpdated ¶
func (UnimplementedSyncServiceServer) SetTagValueUpdated(context.Context, *SyncUpdated) (*pb.MyBool, error)
func (UnimplementedSyncServiceServer) WaitDeviceUpdated ¶
func (UnimplementedSyncServiceServer) WaitDeviceUpdated(*pb.MyEmpty, SyncService_WaitDeviceUpdatedServer) error
func (UnimplementedSyncServiceServer) WaitTagValueUpdated ¶
func (UnimplementedSyncServiceServer) WaitTagValueUpdated(*pb.MyEmpty, SyncService_WaitTagValueUpdatedServer) error
type UnimplementedTagServiceServer ¶
type UnimplementedTagServiceServer struct { }
UnimplementedTagServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedTagServiceServer) Clone ¶
func (UnimplementedTagServiceServer) Clone(context.Context, *TagCloneRequest) (*pb.MyBool, error)
func (UnimplementedTagServiceServer) DeleteValue ¶
func (UnimplementedTagServiceServer) GetValueByName ¶
func (UnimplementedTagServiceServer) GetValueByName(context.Context, *pb.Name) (*pb.TagNameValue, error)
func (UnimplementedTagServiceServer) List ¶
func (UnimplementedTagServiceServer) List(context.Context, *TagListRequest) (*TagListResponse, error)
func (UnimplementedTagServiceServer) Pull ¶
func (UnimplementedTagServiceServer) Pull(context.Context, *TagPullRequest) (*TagPullResponse, error)
func (UnimplementedTagServiceServer) PullValue ¶
func (UnimplementedTagServiceServer) PullValue(context.Context, *TagPullValueRequest) (*TagPullValueResponse, error)
func (UnimplementedTagServiceServer) SetValueByName ¶
func (UnimplementedTagServiceServer) SetValueByName(context.Context, *pb.TagNameValue) (*pb.MyBool, error)
func (UnimplementedTagServiceServer) SetValueByNameForce ¶
func (UnimplementedTagServiceServer) SetValueByNameForce(context.Context, *pb.TagNameValue) (*pb.MyBool, error)
func (UnimplementedTagServiceServer) SetValueForce ¶
func (UnimplementedTagServiceServer) ViewValue ¶
func (UnimplementedTagServiceServer) ViewValue(context.Context, *pb.Id) (*pb.TagValueUpdated, error)
func (UnimplementedTagServiceServer) ViewWithDeleted ¶
type UnimplementedUserServiceServer ¶
type UnimplementedUserServiceServer struct { }
UnimplementedUserServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedUserServiceServer) List ¶
func (UnimplementedUserServiceServer) List(context.Context, *UserListRequest) (*UserListResponse, error)
func (UnimplementedUserServiceServer) Pull ¶
func (UnimplementedUserServiceServer) Pull(context.Context, *UserPullRequest) (*UserPullResponse, error)
func (UnimplementedUserServiceServer) ViewWithDeleted ¶
type UnsafeAttrServiceServer ¶
type UnsafeAttrServiceServer interface {
// contains filtered or unexported methods
}
UnsafeAttrServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AttrServiceServer will result in compilation errors.
type UnsafeAuthServiceServer ¶
type UnsafeAuthServiceServer interface {
// contains filtered or unexported methods
}
UnsafeAuthServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AuthServiceServer will result in compilation errors.
type UnsafeClassServiceServer ¶
type UnsafeClassServiceServer interface {
// contains filtered or unexported methods
}
UnsafeClassServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ClassServiceServer will result in compilation errors.
type UnsafeConstServiceServer ¶
type UnsafeConstServiceServer interface {
// contains filtered or unexported methods
}
UnsafeConstServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ConstServiceServer will result in compilation errors.
type UnsafeControlServiceServer ¶
type UnsafeControlServiceServer interface {
// contains filtered or unexported methods
}
UnsafeControlServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ControlServiceServer will result in compilation errors.
type UnsafeDataServiceServer ¶
type UnsafeDataServiceServer interface {
// contains filtered or unexported methods
}
UnsafeDataServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DataServiceServer will result in compilation errors.
type UnsafeDeviceServiceServer ¶
type UnsafeDeviceServiceServer interface {
// contains filtered or unexported methods
}
UnsafeDeviceServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DeviceServiceServer will result in compilation errors.
type UnsafeFnServiceServer ¶
type UnsafeFnServiceServer interface {
// contains filtered or unexported methods
}
UnsafeFnServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FnServiceServer will result in compilation errors.
type UnsafeLogicServiceServer ¶
type UnsafeLogicServiceServer interface {
// contains filtered or unexported methods
}
UnsafeLogicServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LogicServiceServer will result in compilation errors.
type UnsafeSlotServiceServer ¶
type UnsafeSlotServiceServer interface {
// contains filtered or unexported methods
}
UnsafeSlotServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SlotServiceServer will result in compilation errors.
type UnsafeSourceServiceServer ¶
type UnsafeSourceServiceServer interface {
// contains filtered or unexported methods
}
UnsafeSourceServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SourceServiceServer will result in compilation errors.
type UnsafeSyncServiceServer ¶
type UnsafeSyncServiceServer interface {
// contains filtered or unexported methods
}
UnsafeSyncServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SyncServiceServer will result in compilation errors.
type UnsafeTagServiceServer ¶
type UnsafeTagServiceServer interface {
// contains filtered or unexported methods
}
UnsafeTagServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TagServiceServer will result in compilation errors.
type UnsafeUserServiceServer ¶
type UnsafeUserServiceServer interface {
// contains filtered or unexported methods
}
UnsafeUserServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to UserServiceServer will result in compilation errors.
type UserListRequest ¶
type UserListRequest struct { Page *pb.Page `protobuf:"bytes,1,opt,name=page,proto3" json:"page,omitempty"` Tags string `protobuf:"bytes,2,opt,name=tags,proto3" json:"tags,omitempty"` Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"` // contains filtered or unexported fields }
user
func (*UserListRequest) Descriptor
deprecated
func (*UserListRequest) Descriptor() ([]byte, []int)
Deprecated: Use UserListRequest.ProtoReflect.Descriptor instead.
func (*UserListRequest) GetPage ¶
func (x *UserListRequest) GetPage() *pb.Page
func (*UserListRequest) GetTags ¶
func (x *UserListRequest) GetTags() string
func (*UserListRequest) GetType ¶
func (x *UserListRequest) GetType() string
func (*UserListRequest) ProtoMessage ¶
func (*UserListRequest) ProtoMessage()
func (*UserListRequest) ProtoReflect ¶
func (x *UserListRequest) ProtoReflect() protoreflect.Message
func (*UserListRequest) Reset ¶
func (x *UserListRequest) Reset()
func (*UserListRequest) String ¶
func (x *UserListRequest) String() string
type UserListResponse ¶
type UserListResponse struct { Page *pb.Page `protobuf:"bytes,1,opt,name=page,proto3" json:"page,omitempty"` Count uint32 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` User []*pb.User `protobuf:"bytes,3,rep,name=user,proto3" json:"user,omitempty"` // contains filtered or unexported fields }
func (*UserListResponse) Descriptor
deprecated
func (*UserListResponse) Descriptor() ([]byte, []int)
Deprecated: Use UserListResponse.ProtoReflect.Descriptor instead.
func (*UserListResponse) GetCount ¶
func (x *UserListResponse) GetCount() uint32
func (*UserListResponse) GetPage ¶
func (x *UserListResponse) GetPage() *pb.Page
func (*UserListResponse) GetUser ¶
func (x *UserListResponse) GetUser() []*pb.User
func (*UserListResponse) ProtoMessage ¶
func (*UserListResponse) ProtoMessage()
func (*UserListResponse) ProtoReflect ¶
func (x *UserListResponse) ProtoReflect() protoreflect.Message
func (*UserListResponse) Reset ¶
func (x *UserListResponse) Reset()
func (*UserListResponse) String ¶
func (x *UserListResponse) String() string
type UserPullRequest ¶
type UserPullRequest struct { After int64 `protobuf:"varint,1,opt,name=after,proto3" json:"after,omitempty"` Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` // contains filtered or unexported fields }
func (*UserPullRequest) Descriptor
deprecated
func (*UserPullRequest) Descriptor() ([]byte, []int)
Deprecated: Use UserPullRequest.ProtoReflect.Descriptor instead.
func (*UserPullRequest) GetAfter ¶
func (x *UserPullRequest) GetAfter() int64
func (*UserPullRequest) GetLimit ¶
func (x *UserPullRequest) GetLimit() uint32
func (*UserPullRequest) ProtoMessage ¶
func (*UserPullRequest) ProtoMessage()
func (*UserPullRequest) ProtoReflect ¶
func (x *UserPullRequest) ProtoReflect() protoreflect.Message
func (*UserPullRequest) Reset ¶
func (x *UserPullRequest) Reset()
func (*UserPullRequest) String ¶
func (x *UserPullRequest) String() string
type UserPullResponse ¶
type UserPullResponse struct { After int64 `protobuf:"varint,1,opt,name=after,proto3" json:"after,omitempty"` Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` User []*pb.User `protobuf:"bytes,3,rep,name=user,proto3" json:"user,omitempty"` // contains filtered or unexported fields }
func (*UserPullResponse) Descriptor
deprecated
func (*UserPullResponse) Descriptor() ([]byte, []int)
Deprecated: Use UserPullResponse.ProtoReflect.Descriptor instead.
func (*UserPullResponse) GetAfter ¶
func (x *UserPullResponse) GetAfter() int64
func (*UserPullResponse) GetLimit ¶
func (x *UserPullResponse) GetLimit() uint32
func (*UserPullResponse) GetUser ¶
func (x *UserPullResponse) GetUser() []*pb.User
func (*UserPullResponse) ProtoMessage ¶
func (*UserPullResponse) ProtoMessage()
func (*UserPullResponse) ProtoReflect ¶
func (x *UserPullResponse) ProtoReflect() protoreflect.Message
func (*UserPullResponse) Reset ¶
func (x *UserPullResponse) Reset()
func (*UserPullResponse) String ¶
func (x *UserPullResponse) String() string
type UserServiceClient ¶
type UserServiceClient interface { Create(ctx context.Context, in *pb.User, opts ...grpc.CallOption) (*pb.User, error) Update(ctx context.Context, in *pb.User, opts ...grpc.CallOption) (*pb.User, error) View(ctx context.Context, in *pb.Id, opts ...grpc.CallOption) (*pb.User, error) Name(ctx context.Context, in *pb.Name, opts ...grpc.CallOption) (*pb.User, error) Delete(ctx context.Context, in *pb.Id, opts ...grpc.CallOption) (*pb.MyBool, error) List(ctx context.Context, in *UserListRequest, opts ...grpc.CallOption) (*UserListResponse, error) ViewWithDeleted(ctx context.Context, in *pb.Id, opts ...grpc.CallOption) (*pb.User, error) Pull(ctx context.Context, in *UserPullRequest, opts ...grpc.CallOption) (*UserPullResponse, error) }
UserServiceClient is the client API for UserService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewUserServiceClient ¶
func NewUserServiceClient(cc grpc.ClientConnInterface) UserServiceClient
type UserServiceServer ¶
type UserServiceServer interface { Create(context.Context, *pb.User) (*pb.User, error) Update(context.Context, *pb.User) (*pb.User, error) View(context.Context, *pb.Id) (*pb.User, error) Name(context.Context, *pb.Name) (*pb.User, error) Delete(context.Context, *pb.Id) (*pb.MyBool, error) List(context.Context, *UserListRequest) (*UserListResponse, error) ViewWithDeleted(context.Context, *pb.Id) (*pb.User, error) Pull(context.Context, *UserPullRequest) (*UserPullResponse, error) // contains filtered or unexported methods }
UserServiceServer is the server API for UserService service. All implementations must embed UnimplementedUserServiceServer for forward compatibility
Source Files ¶
- auth_service.pb.go
- auth_service_grpc.pb.go
- class_service.pb.go
- class_service_grpc.pb.go
- const_service.pb.go
- const_service_grpc.pb.go
- control_service.pb.go
- control_service_grpc.pb.go
- data_service.pb.go
- data_service_grpc.pb.go
- device_service.pb.go
- device_service_grpc.pb.go
- logic_service.pb.go
- logic_service_grpc.pb.go
- slot_service.pb.go
- slot_service_grpc.pb.go
- source_service.pb.go
- source_service_grpc.pb.go
- sync_service.pb.go
- sync_service_grpc.pb.go
- user_service.pb.go
- user_service_grpc.pb.go