nodes

package
v0.0.0-...-886a5b3 Latest Latest
Warning

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

 Go to latest Published: May 23, 2024 License: BSD-3-Clause Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ClassService_Create_FullMethodName          = "/nodes.ClassService/Create"
	ClassService_Update_FullMethodName          = "/nodes.ClassService/Update"
	ClassService_View_FullMethodName            = "/nodes.ClassService/View"
	ClassService_Name_FullMethodName            = "/nodes.ClassService/Name"
	ClassService_Delete_FullMethodName          = "/nodes.ClassService/Delete"
	ClassService_List_FullMethodName            = "/nodes.ClassService/List"
	ClassService_ViewWithDeleted_FullMethodName = "/nodes.ClassService/ViewWithDeleted"
	ClassService_Pull_FullMethodName            = "/nodes.ClassService/Pull"
	ClassService_Sync_FullMethodName            = "/nodes.ClassService/Sync"
)
View Source 
const (
	AttrService_Create_FullMethodName              = "/nodes.AttrService/Create"
	AttrService_Update_FullMethodName              = "/nodes.AttrService/Update"
	AttrService_View_FullMethodName                = "/nodes.AttrService/View"
	AttrService_Name_FullMethodName                = "/nodes.AttrService/Name"
	AttrService_Delete_FullMethodName              = "/nodes.AttrService/Delete"
	AttrService_List_FullMethodName                = "/nodes.AttrService/List"
	AttrService_ViewWithDeleted_FullMethodName     = "/nodes.AttrService/ViewWithDeleted"
	AttrService_Pull_FullMethodName                = "/nodes.AttrService/Pull"
	AttrService_Sync_FullMethodName                = "/nodes.AttrService/Sync"
	AttrService_GetValue_FullMethodName            = "/nodes.AttrService/GetValue"
	AttrService_SetValue_FullMethodName            = "/nodes.AttrService/SetValue"
	AttrService_SetValueForce_FullMethodName       = "/nodes.AttrService/SetValueForce"
	AttrService_GetValueByName_FullMethodName      = "/nodes.AttrService/GetValueByName"
	AttrService_SetValueByName_FullMethodName      = "/nodes.AttrService/SetValueByName"
	AttrService_SetValueByNameForce_FullMethodName = "/nodes.AttrService/SetValueByNameForce"
	AttrService_Upload_FullMethodName              = "/nodes.AttrService/Upload"
)
View Source 
const (
	ConstService_Create_FullMethodName              = "/nodes.ConstService/Create"
	ConstService_Update_FullMethodName              = "/nodes.ConstService/Update"
	ConstService_View_FullMethodName                = "/nodes.ConstService/View"
	ConstService_Name_FullMethodName                = "/nodes.ConstService/Name"
	ConstService_Delete_FullMethodName              = "/nodes.ConstService/Delete"
	ConstService_List_FullMethodName                = "/nodes.ConstService/List"
	ConstService_ViewWithDeleted_FullMethodName     = "/nodes.ConstService/ViewWithDeleted"
	ConstService_Pull_FullMethodName                = "/nodes.ConstService/Pull"
	ConstService_Sync_FullMethodName                = "/nodes.ConstService/Sync"
	ConstService_GetValue_FullMethodName            = "/nodes.ConstService/GetValue"
	ConstService_SetValue_FullMethodName            = "/nodes.ConstService/SetValue"
	ConstService_SetValueForce_FullMethodName       = "/nodes.ConstService/SetValueForce"
	ConstService_GetValueByName_FullMethodName      = "/nodes.ConstService/GetValueByName"
	ConstService_SetValueByName_FullMethodName      = "/nodes.ConstService/SetValueByName"
	ConstService_SetValueByNameForce_FullMethodName = "/nodes.ConstService/SetValueByNameForce"
)
View Source 
const (
	DataService_Upload_FullMethodName    = "/nodes.DataService/Upload"
	DataService_Compile_FullMethodName   = "/nodes.DataService/Compile"
	DataService_Query_FullMethodName     = "/nodes.DataService/Query"
	DataService_QueryById_FullMethodName = "/nodes.DataService/QueryById"
)
View Source 
const (
	DeviceService_Login_FullMethodName           = "/nodes.DeviceService/Login"
	DeviceService_Update_FullMethodName          = "/nodes.DeviceService/Update"
	DeviceService_View_FullMethodName            = "/nodes.DeviceService/View"
	DeviceService_Link_FullMethodName            = "/nodes.DeviceService/Link"
	DeviceService_ViewWithDeleted_FullMethodName = "/nodes.DeviceService/ViewWithDeleted"
	DeviceService_Sync_FullMethodName            = "/nodes.DeviceService/Sync"
)
View Source 
const (
	FnService_Create_FullMethodName          = "/nodes.FnService/Create"
	FnService_Update_FullMethodName          = "/nodes.FnService/Update"
	FnService_View_FullMethodName            = "/nodes.FnService/View"
	FnService_Name_FullMethodName            = "/nodes.FnService/Name"
	FnService_Delete_FullMethodName          = "/nodes.FnService/Delete"
	FnService_List_FullMethodName            = "/nodes.FnService/List"
	FnService_Link_FullMethodName            = "/nodes.FnService/Link"
	FnService_ViewWithDeleted_FullMethodName = "/nodes.FnService/ViewWithDeleted"
	FnService_Pull_FullMethodName            = "/nodes.FnService/Pull"
	FnService_Sync_FullMethodName            = "/nodes.FnService/Sync"
)
View Source 
const (
	LogicService_Create_FullMethodName          = "/nodes.LogicService/Create"
	LogicService_Update_FullMethodName          = "/nodes.LogicService/Update"
	LogicService_View_FullMethodName            = "/nodes.LogicService/View"
	LogicService_Name_FullMethodName            = "/nodes.LogicService/Name"
	LogicService_Delete_FullMethodName          = "/nodes.LogicService/Delete"
	LogicService_List_FullMethodName            = "/nodes.LogicService/List"
	LogicService_ViewWithDeleted_FullMethodName = "/nodes.LogicService/ViewWithDeleted"
	LogicService_Pull_FullMethodName            = "/nodes.LogicService/Pull"
	LogicService_Sync_FullMethodName            = "/nodes.LogicService/Sync"
)
View Source 
const (
	SlotService_Create_FullMethodName          = "/nodes.SlotService/Create"
	SlotService_Update_FullMethodName          = "/nodes.SlotService/Update"
	SlotService_View_FullMethodName            = "/nodes.SlotService/View"
	SlotService_Name_FullMethodName            = "/nodes.SlotService/Name"
	SlotService_Delete_FullMethodName          = "/nodes.SlotService/Delete"
	SlotService_List_FullMethodName            = "/nodes.SlotService/List"
	SlotService_Link_FullMethodName            = "/nodes.SlotService/Link"
	SlotService_ViewWithDeleted_FullMethodName = "/nodes.SlotService/ViewWithDeleted"
	SlotService_Pull_FullMethodName            = "/nodes.SlotService/Pull"
	SlotService_Sync_FullMethodName            = "/nodes.SlotService/Sync"
)
View Source 
const (
	SourceService_Create_FullMethodName          = "/nodes.SourceService/Create"
	SourceService_Update_FullMethodName          = "/nodes.SourceService/Update"
	SourceService_View_FullMethodName            = "/nodes.SourceService/View"
	SourceService_Name_FullMethodName            = "/nodes.SourceService/Name"
	SourceService_Delete_FullMethodName          = "/nodes.SourceService/Delete"
	SourceService_List_FullMethodName            = "/nodes.SourceService/List"
	SourceService_Link_FullMethodName            = "/nodes.SourceService/Link"
	SourceService_ViewWithDeleted_FullMethodName = "/nodes.SourceService/ViewWithDeleted"
	SourceService_Pull_FullMethodName            = "/nodes.SourceService/Pull"
	SourceService_Sync_FullMethodName            = "/nodes.SourceService/Sync"
)
View Source 
const (
	TagService_Create_FullMethodName              = "/nodes.TagService/Create"
	TagService_Update_FullMethodName              = "/nodes.TagService/Update"
	TagService_View_FullMethodName                = "/nodes.TagService/View"
	TagService_Name_FullMethodName                = "/nodes.TagService/Name"
	TagService_Delete_FullMethodName              = "/nodes.TagService/Delete"
	TagService_List_FullMethodName                = "/nodes.TagService/List"
	TagService_Pull_FullMethodName                = "/nodes.TagService/Pull"
	TagService_ViewWithDeleted_FullMethodName     = "/nodes.TagService/ViewWithDeleted"
	TagService_Sync_FullMethodName                = "/nodes.TagService/Sync"
	TagService_GetValue_FullMethodName            = "/nodes.TagService/GetValue"
	TagService_SetValue_FullMethodName            = "/nodes.TagService/SetValue"
	TagService_SetValueForce_FullMethodName       = "/nodes.TagService/SetValueForce"
	TagService_GetValueByName_FullMethodName      = "/nodes.TagService/GetValueByName"
	TagService_SetValueByName_FullMethodName      = "/nodes.TagService/SetValueByName"
	TagService_SetValueByNameForce_FullMethodName = "/nodes.TagService/SetValueByNameForce"
	TagService_ViewValue_FullMethodName           = "/nodes.TagService/ViewValue"
	TagService_DeleteValue_FullMethodName         = "/nodes.TagService/DeleteValue"
	TagService_PullValue_FullMethodName           = "/nodes.TagService/PullValue"
	TagService_SyncValue_FullMethodName           = "/nodes.TagService/SyncValue"
)
View Source 
const (
	SyncService_SetDeviceUpdated_FullMethodName    = "/nodes.SyncService/SetDeviceUpdated"
	SyncService_GetDeviceUpdated_FullMethodName    = "/nodes.SyncService/GetDeviceUpdated"
	SyncService_WaitDeviceUpdated_FullMethodName   = "/nodes.SyncService/WaitDeviceUpdated"
	SyncService_SetTagValueUpdated_FullMethodName  = "/nodes.SyncService/SetTagValueUpdated"
	SyncService_GetTagValueUpdated_FullMethodName  = "/nodes.SyncService/GetTagValueUpdated"
	SyncService_WaitTagValueUpdated_FullMethodName = "/nodes.SyncService/WaitTagValueUpdated"
)
View Source 
const (
	SyncGlobalService_SetUpdated_FullMethodName  = "/nodes.SyncGlobalService/SetUpdated"
	SyncGlobalService_GetUpdated_FullMethodName  = "/nodes.SyncGlobalService/GetUpdated"
	SyncGlobalService_WaitUpdated_FullMethodName = "/nodes.SyncGlobalService/WaitUpdated"
)
View Source 
const (
	UserService_View_FullMethodName            = "/nodes.UserService/View"
	UserService_Name_FullMethodName            = "/nodes.UserService/Name"
	UserService_List_FullMethodName            = "/nodes.UserService/List"
	UserService_ViewWithDeleted_FullMethodName = "/nodes.UserService/ViewWithDeleted"
	UserService_Pull_FullMethodName            = "/nodes.UserService/Pull"
)
View Source 
const (
	AuthService_Login_FullMethodName = "/nodes.AuthService/Login"
)

Variables

View Source 
var AttrService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "nodes.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: "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,
		},
		{
			MethodName: "Upload",
			Handler:    _AttrService_Upload_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "nodes/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)

View Source 
var AuthService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "nodes.AuthService",
	HandlerType: (*AuthServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Login",
			Handler:    _AuthService_Login_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "nodes/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)

View Source 
var ClassService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "nodes.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: "ViewWithDeleted",
			Handler:    _ClassService_ViewWithDeleted_Handler,
		},
		{
			MethodName: "Pull",
			Handler:    _ClassService_Pull_Handler,
		},
		{
			MethodName: "Sync",
			Handler:    _ClassService_Sync_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "nodes/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)

View Source 
var ConstService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "nodes.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: "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: "nodes/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)

View Source 
var DataService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "nodes.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: "nodes/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)

View Source 
var DeviceService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "nodes.DeviceService",
	HandlerType: (*DeviceServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Login",
			Handler:    _DeviceService_Login_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _DeviceService_Update_Handler,
		},
		{
			MethodName: "View",
			Handler:    _DeviceService_View_Handler,
		},
		{
			MethodName: "Link",
			Handler:    _DeviceService_Link_Handler,
		},
		{
			MethodName: "ViewWithDeleted",
			Handler:    _DeviceService_ViewWithDeleted_Handler,
		},
		{
			MethodName: "Sync",
			Handler:    _DeviceService_Sync_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "nodes/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)

View Source 
var File_nodes_auth_service_proto protoreflect.FileDescriptor
View Source 
var File_nodes_class_service_proto protoreflect.FileDescriptor
View Source 
var File_nodes_const_service_proto protoreflect.FileDescriptor
View Source 
var File_nodes_data_service_proto protoreflect.FileDescriptor
View Source 
var File_nodes_device_service_proto protoreflect.FileDescriptor
View Source 
var File_nodes_logic_service_proto protoreflect.FileDescriptor
View Source 
var File_nodes_slot_service_proto protoreflect.FileDescriptor
View Source 
var File_nodes_source_service_proto protoreflect.FileDescriptor
View Source 
var File_nodes_sync_service_proto protoreflect.FileDescriptor
View Source 
var File_nodes_user_service_proto protoreflect.FileDescriptor
View Source 
var FnService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "nodes.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: "ViewWithDeleted",
			Handler:    _FnService_ViewWithDeleted_Handler,
		},
		{
			MethodName: "Pull",
			Handler:    _FnService_Pull_Handler,
		},
		{
			MethodName: "Sync",
			Handler:    _FnService_Sync_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "nodes/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)

View Source 
var LogicService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "nodes.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: "ViewWithDeleted",
			Handler:    _LogicService_ViewWithDeleted_Handler,
		},
		{
			MethodName: "Pull",
			Handler:    _LogicService_Pull_Handler,
		},
		{
			MethodName: "Sync",
			Handler:    _LogicService_Sync_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "nodes/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)

View Source 
var SlotService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "nodes.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: "ViewWithDeleted",
			Handler:    _SlotService_ViewWithDeleted_Handler,
		},
		{
			MethodName: "Pull",
			Handler:    _SlotService_Pull_Handler,
		},
		{
			MethodName: "Sync",
			Handler:    _SlotService_Sync_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "nodes/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)

View Source 
var SourceService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "nodes.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: "ViewWithDeleted",
			Handler:    _SourceService_ViewWithDeleted_Handler,
		},
		{
			MethodName: "Pull",
			Handler:    _SourceService_Pull_Handler,
		},
		{
			MethodName: "Sync",
			Handler:    _SourceService_Sync_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "nodes/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)

View Source 
var SyncGlobalService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "nodes.SyncGlobalService",
	HandlerType: (*SyncGlobalServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SetUpdated",
			Handler:    _SyncGlobalService_SetUpdated_Handler,
		},
		{
			MethodName: "GetUpdated",
			Handler:    _SyncGlobalService_GetUpdated_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "WaitUpdated",
			Handler:       _SyncGlobalService_WaitUpdated_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "nodes/sync_service.proto",
}

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

View Source 
var SyncService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "nodes.SyncService",
	HandlerType: (*SyncServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SetDeviceUpdated",
			Handler:    _SyncService_SetDeviceUpdated_Handler,
		},
		{
			MethodName: "GetDeviceUpdated",
			Handler:    _SyncService_GetDeviceUpdated_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: "nodes/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)

View Source 
var TagService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "nodes.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: "Pull",
			Handler:    _TagService_Pull_Handler,
		},
		{
			MethodName: "ViewWithDeleted",
			Handler:    _TagService_ViewWithDeleted_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: "nodes/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)

View Source 
var UserService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "nodes.UserService",
	HandlerType: (*UserServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "View",
			Handler:    _UserService_View_Handler,
		},
		{
			MethodName: "Name",
			Handler:    _UserService_Name_Handler,
		},
		{
			MethodName: "List",
			Handler:    _UserService_List_Handler,
		},
		{
			MethodName: "ViewWithDeleted",
			Handler:    _UserService_ViewWithDeleted_Handler,
		},
		{
			MethodName: "Pull",
			Handler:    _UserService_Pull_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "nodes/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 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 RegisterSyncGlobalServiceServer 

func RegisterSyncGlobalServiceServer(s grpc.ServiceRegistrar, srv SyncGlobalServiceServer)

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 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)
	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)
	Upload(ctx context.Context, in *AttrValueUploadRequest, opts ...grpc.CallOption) (*AttrValueUploadResponse, 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)
	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)
	Upload(context.Context, *AttrValueUploadRequest) (*AttrValueUploadResponse, error)
	// contains filtered or unexported methods
}

AttrServiceServer is the server API for AttrService service. All implementations must embed UnimplementedAttrServiceServer for forward compatibility

type AttrValueUploadRequest 

type AttrValueUploadRequest struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Content []byte `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

func (*AttrValueUploadRequest) Descriptor deprecated 

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

Deprecated: Use AttrValueUploadRequest.ProtoReflect.Descriptor instead.

func (*AttrValueUploadRequest) GetContent 

func (x *AttrValueUploadRequest) GetContent() []byte

func (*AttrValueUploadRequest) GetId 

func (x *AttrValueUploadRequest) GetId() string

func (*AttrValueUploadRequest) ProtoMessage 

func (*AttrValueUploadRequest) ProtoMessage()

func (*AttrValueUploadRequest) ProtoReflect 

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

func (*AttrValueUploadRequest) Reset 

func (x *AttrValueUploadRequest) Reset()

func (*AttrValueUploadRequest) String 

func (x *AttrValueUploadRequest) String() string

type AttrValueUploadResponse 

type AttrValueUploadResponse 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 (*AttrValueUploadResponse) Descriptor deprecated 

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

Deprecated: Use AttrValueUploadResponse.ProtoReflect.Descriptor instead.

func (*AttrValueUploadResponse) GetId 

func (x *AttrValueUploadResponse) GetId() string

func (*AttrValueUploadResponse) GetMessage 

func (x *AttrValueUploadResponse) GetMessage() string

func (*AttrValueUploadResponse) ProtoMessage 

func (*AttrValueUploadResponse) ProtoMessage()

func (*AttrValueUploadResponse) ProtoReflect 

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

func (*AttrValueUploadResponse) Reset 

func (x *AttrValueUploadResponse) Reset()

func (*AttrValueUploadResponse) String 

func (x *AttrValueUploadResponse) String() string

type AuthServiceClient 

type AuthServiceClient interface {
	Login(ctx context.Context, in *LoginRequest, opts ...grpc.CallOption) (*LoginResponse, 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)
	// contains filtered or unexported methods
}

AuthServiceServer is the server API for AuthService service. All implementations must embed UnimplementedAuthServiceServer for forward compatibility

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

type DeviceLinkRequest struct {

	// string id = 1;
	Status int32 `protobuf:"zigzag32,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceLinkRequest) Descriptor deprecated 

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

Deprecated: Use DeviceLinkRequest.ProtoReflect.Descriptor instead.

func (*DeviceLinkRequest) GetStatus 

func (x *DeviceLinkRequest) GetStatus() int32

func (*DeviceLinkRequest) ProtoMessage 

func (*DeviceLinkRequest) ProtoMessage()

func (*DeviceLinkRequest) ProtoReflect 

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

func (*DeviceLinkRequest) Reset 

func (x *DeviceLinkRequest) Reset()

func (*DeviceLinkRequest) String 

func (x *DeviceLinkRequest) String() string

type DeviceLoginReply 

type DeviceLoginReply struct {
	Id    string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceLoginReply) Descriptor deprecated 

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

Deprecated: Use DeviceLoginReply.ProtoReflect.Descriptor instead.

func (*DeviceLoginReply) GetId 

func (x *DeviceLoginReply) GetId() string

func (*DeviceLoginReply) GetToken 

func (x *DeviceLoginReply) GetToken() string

func (*DeviceLoginReply) ProtoMessage 

func (*DeviceLoginReply) ProtoMessage()

func (*DeviceLoginReply) ProtoReflect 

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

func (*DeviceLoginReply) Reset 

func (x *DeviceLoginReply) Reset()

func (*DeviceLoginReply) String 

func (x *DeviceLoginReply) String() string

type DeviceLoginRequest 

type DeviceLoginRequest struct {
	Id     string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Access string `protobuf:"bytes,2,opt,name=access,proto3" json:"access,omitempty"`
	Secret string `protobuf:"bytes,3,opt,name=secret,proto3" json:"secret,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceLoginRequest) Descriptor deprecated 

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

Deprecated: Use DeviceLoginRequest.ProtoReflect.Descriptor instead.

func (*DeviceLoginRequest) GetAccess 

func (x *DeviceLoginRequest) GetAccess() string

func (*DeviceLoginRequest) GetId 

func (x *DeviceLoginRequest) GetId() string

func (*DeviceLoginRequest) GetSecret 

func (x *DeviceLoginRequest) GetSecret() string

func (*DeviceLoginRequest) ProtoMessage 

func (*DeviceLoginRequest) ProtoMessage()

func (*DeviceLoginRequest) ProtoReflect 

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

func (*DeviceLoginRequest) Reset 

func (x *DeviceLoginRequest) Reset()

func (*DeviceLoginRequest) String 

func (x *DeviceLoginRequest) String() string

type DeviceServiceClient 

type DeviceServiceClient interface {
	Login(ctx context.Context, in *DeviceLoginRequest, opts ...grpc.CallOption) (*DeviceLoginReply, error)
	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)
	Link(ctx context.Context, in *DeviceLinkRequest, 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 {
	Login(context.Context, *DeviceLoginRequest) (*DeviceLoginReply, error)
	Update(context.Context, *pb.Device) (*pb.Device, error)
	View(context.Context, *pb.MyEmpty) (*pb.Device, error)
	Link(context.Context, *DeviceLinkRequest) (*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)
	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)
	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 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 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)
	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)
	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 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)
	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)
	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 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)
	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)
	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 SyncGlobalServiceClient 

type SyncGlobalServiceClient interface {
	SetUpdated(ctx context.Context, in *SyncUpdated, opts ...grpc.CallOption) (*pb.MyBool, error)
	GetUpdated(ctx context.Context, in *pb.Id, opts ...grpc.CallOption) (*SyncUpdated, error)
	WaitUpdated(ctx context.Context, in *pb.Id, opts ...grpc.CallOption) (SyncGlobalService_WaitUpdatedClient, error)
}

SyncGlobalServiceClient is the client API for SyncGlobalService 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 NewSyncGlobalServiceClient 

func NewSyncGlobalServiceClient(cc grpc.ClientConnInterface) SyncGlobalServiceClient

type SyncGlobalServiceServer 

type SyncGlobalServiceServer interface {
	SetUpdated(context.Context, *SyncUpdated) (*pb.MyBool, error)
	GetUpdated(context.Context, *pb.Id) (*SyncUpdated, error)
	WaitUpdated(*pb.Id, SyncGlobalService_WaitUpdatedServer) error
	// contains filtered or unexported methods
}

SyncGlobalServiceServer is the server API for SyncGlobalService service. All implementations must embed UnimplementedSyncGlobalServiceServer for forward compatibility

type SyncGlobalService_WaitUpdatedClient 

type SyncGlobalService_WaitUpdatedClient interface {
	Recv() (*pb.MyBool, error)
	grpc.ClientStream
}

type SyncGlobalService_WaitUpdatedServer 

type SyncGlobalService_WaitUpdatedServer interface {
	Send(*pb.MyBool) error
	grpc.ServerStream
}

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)
	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
	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 {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	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) GetId 

func (x *SyncUpdated) GetId() string

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 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)
	Pull(ctx context.Context, in *TagPullRequest, opts ...grpc.CallOption) (*TagPullResponse, error)
	ViewWithDeleted(ctx context.Context, in *pb.Id, opts ...grpc.CallOption) (*pb.Tag, 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)
	Pull(context.Context, *TagPullRequest) (*TagPullResponse, error)
	ViewWithDeleted(context.Context, *pb.Id) (*pb.Tag, 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) Create 

func (UnimplementedAttrServiceServer) Create(context.Context, *pb.Attr) (*pb.Attr, error)

func (UnimplementedAttrServiceServer) Delete 

func (UnimplementedAttrServiceServer) Delete(context.Context, *pb.Id) (*pb.MyBool, error)

func (UnimplementedAttrServiceServer) GetValue 

func (UnimplementedAttrServiceServer) GetValue(context.Context, *pb.Id) (*pb.AttrValue, 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) Name 

func (UnimplementedAttrServiceServer) Name(context.Context, *pb.Name) (*pb.Attr, error)

func (UnimplementedAttrServiceServer) Pull 

func (UnimplementedAttrServiceServer) Pull(context.Context, *AttrPullRequest) (*AttrPullResponse, error)

func (UnimplementedAttrServiceServer) SetValue 

func (UnimplementedAttrServiceServer) SetValue(context.Context, *pb.AttrValue) (*pb.MyBool, 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) SetValueForce(context.Context, *pb.AttrValue) (*pb.MyBool, error)

func (UnimplementedAttrServiceServer) Sync 

func (UnimplementedAttrServiceServer) Sync(context.Context, *pb.Attr) (*pb.MyBool, error)

func (UnimplementedAttrServiceServer) Update 

func (UnimplementedAttrServiceServer) Update(context.Context, *pb.Attr) (*pb.Attr, error)

func (UnimplementedAttrServiceServer) Upload 

func (UnimplementedAttrServiceServer) Upload(context.Context, *AttrValueUploadRequest) (*AttrValueUploadResponse, error)

func (UnimplementedAttrServiceServer) View 

func (UnimplementedAttrServiceServer) View(context.Context, *pb.Id) (*pb.Attr, error)

func (UnimplementedAttrServiceServer) ViewWithDeleted 

func (UnimplementedAttrServiceServer) ViewWithDeleted(context.Context, *pb.Id) (*pb.Attr, error)

type UnimplementedAuthServiceServer 

type UnimplementedAuthServiceServer struct {
}

UnimplementedAuthServiceServer must be embedded to have forward compatible implementations.

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

func (UnimplementedClassServiceServer) Create(context.Context, *pb.Class) (*pb.Class, error)

func (UnimplementedClassServiceServer) Delete 

func (UnimplementedClassServiceServer) Delete(context.Context, *pb.Id) (*pb.MyBool, error)

func (UnimplementedClassServiceServer) List 

func (UnimplementedClassServiceServer) List(context.Context, *ClassListRequest) (*ClassListResponse, error)

func (UnimplementedClassServiceServer) Name 

func (UnimplementedClassServiceServer) Name(context.Context, *pb.Name) (*pb.Class, error)

func (UnimplementedClassServiceServer) Pull 

func (UnimplementedClassServiceServer) Pull(context.Context, *ClassPullRequest) (*ClassPullResponse, error)

func (UnimplementedClassServiceServer) Sync 

func (UnimplementedClassServiceServer) Sync(context.Context, *pb.Class) (*pb.MyBool, error)

func (UnimplementedClassServiceServer) Update 

func (UnimplementedClassServiceServer) Update(context.Context, *pb.Class) (*pb.Class, error)

func (UnimplementedClassServiceServer) View 

func (UnimplementedClassServiceServer) View(context.Context, *pb.Id) (*pb.Class, error)

func (UnimplementedClassServiceServer) ViewWithDeleted 

func (UnimplementedClassServiceServer) ViewWithDeleted(context.Context, *pb.Id) (*pb.Class, error)

type UnimplementedConstServiceServer 

type UnimplementedConstServiceServer struct {
}

UnimplementedConstServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedConstServiceServer) Create 

func (UnimplementedConstServiceServer) Create(context.Context, *pb.Const) (*pb.Const, error)

func (UnimplementedConstServiceServer) Delete 

func (UnimplementedConstServiceServer) Delete(context.Context, *pb.Id) (*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) Name 

func (UnimplementedConstServiceServer) Name(context.Context, *pb.Name) (*pb.Const, 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) Sync 

func (UnimplementedConstServiceServer) Sync(context.Context, *pb.Const) (*pb.MyBool, error)

func (UnimplementedConstServiceServer) Update 

func (UnimplementedConstServiceServer) Update(context.Context, *pb.Const) (*pb.Const, error)

func (UnimplementedConstServiceServer) View 

func (UnimplementedConstServiceServer) View(context.Context, *pb.Id) (*pb.Const, error)

func (UnimplementedConstServiceServer) ViewWithDeleted 

func (UnimplementedConstServiceServer) ViewWithDeleted(context.Context, *pb.Id) (*pb.Const, error)

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) Link(context.Context, *DeviceLinkRequest) (*pb.MyBool, error)

func (UnimplementedDeviceServiceServer) Login 

func (UnimplementedDeviceServiceServer) Login(context.Context, *DeviceLoginRequest) (*DeviceLoginReply, error)

func (UnimplementedDeviceServiceServer) Sync 

func (UnimplementedDeviceServiceServer) Sync(context.Context, *pb.Device) (*pb.MyBool, error)

func (UnimplementedDeviceServiceServer) Update 

func (UnimplementedDeviceServiceServer) Update(context.Context, *pb.Device) (*pb.Device, error)

func (UnimplementedDeviceServiceServer) View 

func (UnimplementedDeviceServiceServer) View(context.Context, *pb.MyEmpty) (*pb.Device, error)

func (UnimplementedDeviceServiceServer) ViewWithDeleted 

func (UnimplementedDeviceServiceServer) ViewWithDeleted(context.Context, *pb.MyEmpty) (*pb.Device, error)

type UnimplementedFnServiceServer 

type UnimplementedFnServiceServer struct {
}

UnimplementedFnServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedFnServiceServer) Create 

func (UnimplementedFnServiceServer) Create(context.Context, *pb.Fn) (*pb.Fn, error)

func (UnimplementedFnServiceServer) Delete 

func (UnimplementedFnServiceServer) Delete(context.Context, *pb.Id) (*pb.MyBool, error)
func (UnimplementedFnServiceServer) Link(context.Context, *FnLinkRequest) (*pb.MyBool, error)

func (UnimplementedFnServiceServer) List 

func (UnimplementedFnServiceServer) List(context.Context, *FnListRequest) (*FnListResponse, error)

func (UnimplementedFnServiceServer) Name 

func (UnimplementedFnServiceServer) Name(context.Context, *pb.Name) (*pb.Fn, error)

func (UnimplementedFnServiceServer) Pull 

func (UnimplementedFnServiceServer) Pull(context.Context, *FnPullRequest) (*FnPullResponse, error)

func (UnimplementedFnServiceServer) Sync 

func (UnimplementedFnServiceServer) Sync(context.Context, *pb.Fn) (*pb.MyBool, error)

func (UnimplementedFnServiceServer) Update 

func (UnimplementedFnServiceServer) Update(context.Context, *pb.Fn) (*pb.Fn, error)

func (UnimplementedFnServiceServer) View 

func (UnimplementedFnServiceServer) View(context.Context, *pb.Id) (*pb.Fn, error)

func (UnimplementedFnServiceServer) ViewWithDeleted 

func (UnimplementedFnServiceServer) ViewWithDeleted(context.Context, *pb.Id) (*pb.Fn, error)

type UnimplementedLogicServiceServer 

type UnimplementedLogicServiceServer struct {
}

UnimplementedLogicServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedLogicServiceServer) Create 

func (UnimplementedLogicServiceServer) Create(context.Context, *pb.Logic) (*pb.Logic, error)

func (UnimplementedLogicServiceServer) Delete 

func (UnimplementedLogicServiceServer) Delete(context.Context, *pb.Id) (*pb.MyBool, error)

func (UnimplementedLogicServiceServer) List 

func (UnimplementedLogicServiceServer) List(context.Context, *LogicListRequest) (*LogicListResponse, error)

func (UnimplementedLogicServiceServer) Name 

func (UnimplementedLogicServiceServer) Name(context.Context, *pb.Name) (*pb.Logic, error)

func (UnimplementedLogicServiceServer) Pull 

func (UnimplementedLogicServiceServer) Pull(context.Context, *LogicPullRequest) (*LogicPullResponse, error)

func (UnimplementedLogicServiceServer) Sync 

func (UnimplementedLogicServiceServer) Sync(context.Context, *pb.Logic) (*pb.MyBool, error)

func (UnimplementedLogicServiceServer) Update 

func (UnimplementedLogicServiceServer) Update(context.Context, *pb.Logic) (*pb.Logic, error)

func (UnimplementedLogicServiceServer) View 

func (UnimplementedLogicServiceServer) View(context.Context, *pb.Id) (*pb.Logic, error)

func (UnimplementedLogicServiceServer) ViewWithDeleted 

func (UnimplementedLogicServiceServer) ViewWithDeleted(context.Context, *pb.Id) (*pb.Logic, error)

type UnimplementedSlotServiceServer 

type UnimplementedSlotServiceServer struct {
}

UnimplementedSlotServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSlotServiceServer) Create 

func (UnimplementedSlotServiceServer) Create(context.Context, *pb.Slot) (*pb.Slot, error)

func (UnimplementedSlotServiceServer) Delete 

func (UnimplementedSlotServiceServer) Delete(context.Context, *pb.Id) (*pb.MyBool, error)
func (UnimplementedSlotServiceServer) Link(context.Context, *SlotLinkRequest) (*pb.MyBool, error)

func (UnimplementedSlotServiceServer) List 

func (UnimplementedSlotServiceServer) List(context.Context, *SlotListRequest) (*SlotListResponse, error)

func (UnimplementedSlotServiceServer) Name 

func (UnimplementedSlotServiceServer) Name(context.Context, *pb.Name) (*pb.Slot, error)

func (UnimplementedSlotServiceServer) Pull 

func (UnimplementedSlotServiceServer) Pull(context.Context, *SlotPullRequest) (*SlotPullResponse, error)

func (UnimplementedSlotServiceServer) Sync 

func (UnimplementedSlotServiceServer) Sync(context.Context, *pb.Slot) (*pb.MyBool, error)

func (UnimplementedSlotServiceServer) Update 

func (UnimplementedSlotServiceServer) Update(context.Context, *pb.Slot) (*pb.Slot, error)

func (UnimplementedSlotServiceServer) View 

func (UnimplementedSlotServiceServer) View(context.Context, *pb.Id) (*pb.Slot, error)

func (UnimplementedSlotServiceServer) ViewWithDeleted 

func (UnimplementedSlotServiceServer) ViewWithDeleted(context.Context, *pb.Id) (*pb.Slot, error)

type UnimplementedSourceServiceServer 

type UnimplementedSourceServiceServer struct {
}

UnimplementedSourceServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSourceServiceServer) Create 

func (UnimplementedSourceServiceServer) Create(context.Context, *pb.Source) (*pb.Source, error)

func (UnimplementedSourceServiceServer) Delete 

func (UnimplementedSourceServiceServer) Delete(context.Context, *pb.Id) (*pb.MyBool, error)
func (UnimplementedSourceServiceServer) Link(context.Context, *SourceLinkRequest) (*pb.MyBool, error)

func (UnimplementedSourceServiceServer) List 

func (UnimplementedSourceServiceServer) List(context.Context, *SourceListRequest) (*SourceListResponse, error)

func (UnimplementedSourceServiceServer) Name 

func (UnimplementedSourceServiceServer) Name(context.Context, *pb.Name) (*pb.Source, error)

func (UnimplementedSourceServiceServer) Pull 

func (UnimplementedSourceServiceServer) Pull(context.Context, *SourcePullRequest) (*SourcePullResponse, error)

func (UnimplementedSourceServiceServer) Sync 

func (UnimplementedSourceServiceServer) Sync(context.Context, *pb.Source) (*pb.MyBool, error)

func (UnimplementedSourceServiceServer) Update 

func (UnimplementedSourceServiceServer) Update(context.Context, *pb.Source) (*pb.Source, error)

func (UnimplementedSourceServiceServer) View 

func (UnimplementedSourceServiceServer) View(context.Context, *pb.Id) (*pb.Source, error)

func (UnimplementedSourceServiceServer) ViewWithDeleted 

func (UnimplementedSourceServiceServer) ViewWithDeleted(context.Context, *pb.Id) (*pb.Source, error)

type UnimplementedSyncGlobalServiceServer 

type UnimplementedSyncGlobalServiceServer struct {
}

UnimplementedSyncGlobalServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSyncGlobalServiceServer) GetUpdated 

func (UnimplementedSyncGlobalServiceServer) GetUpdated(context.Context, *pb.Id) (*SyncUpdated, error)

func (UnimplementedSyncGlobalServiceServer) SetUpdated 

func (UnimplementedSyncGlobalServiceServer) SetUpdated(context.Context, *SyncUpdated) (*pb.MyBool, error)

func (UnimplementedSyncGlobalServiceServer) WaitUpdated 

func (UnimplementedSyncGlobalServiceServer) WaitUpdated(*pb.Id, SyncGlobalService_WaitUpdatedServer) error

type UnimplementedSyncServiceServer 

type UnimplementedSyncServiceServer struct {
}

UnimplementedSyncServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSyncServiceServer) GetDeviceUpdated 

func (UnimplementedSyncServiceServer) GetDeviceUpdated(context.Context, *pb.MyEmpty) (*SyncUpdated, error)

func (UnimplementedSyncServiceServer) GetTagValueUpdated 

func (UnimplementedSyncServiceServer) GetTagValueUpdated(context.Context, *pb.MyEmpty) (*SyncUpdated, error)

func (UnimplementedSyncServiceServer) SetDeviceUpdated 

func (UnimplementedSyncServiceServer) SetDeviceUpdated(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) Create 

func (UnimplementedTagServiceServer) Create(context.Context, *pb.Tag) (*pb.Tag, error)

func (UnimplementedTagServiceServer) Delete 

func (UnimplementedTagServiceServer) Delete(context.Context, *pb.Id) (*pb.MyBool, error)

func (UnimplementedTagServiceServer) DeleteValue 

func (UnimplementedTagServiceServer) DeleteValue(context.Context, *pb.Id) (*pb.MyBool, error)

func (UnimplementedTagServiceServer) GetValue 

func (UnimplementedTagServiceServer) GetValue(context.Context, *pb.Id) (*pb.TagValue, error)

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

func (UnimplementedTagServiceServer) Name(context.Context, *pb.Name) (*pb.Tag, 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) SetValue 

func (UnimplementedTagServiceServer) SetValue(context.Context, *pb.TagValue) (*pb.MyBool, 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) SetValueForce(context.Context, *pb.TagValue) (*pb.MyBool, error)

func (UnimplementedTagServiceServer) Sync 

func (UnimplementedTagServiceServer) Sync(context.Context, *pb.Tag) (*pb.MyBool, error)

func (UnimplementedTagServiceServer) SyncValue 

func (UnimplementedTagServiceServer) SyncValue(context.Context, *pb.TagValue) (*pb.MyBool, error)

func (UnimplementedTagServiceServer) Update 

func (UnimplementedTagServiceServer) Update(context.Context, *pb.Tag) (*pb.Tag, error)

func (UnimplementedTagServiceServer) View 

func (UnimplementedTagServiceServer) View(context.Context, *pb.Id) (*pb.Tag, error)

func (UnimplementedTagServiceServer) ViewValue 

func (UnimplementedTagServiceServer) ViewValue(context.Context, *pb.Id) (*pb.TagValueUpdated, error)

func (UnimplementedTagServiceServer) ViewWithDeleted 

func (UnimplementedTagServiceServer) ViewWithDeleted(context.Context, *pb.Id) (*pb.Tag, error)

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

func (UnimplementedUserServiceServer) Name(context.Context, *pb.Name) (*pb.User, error)

func (UnimplementedUserServiceServer) Pull 

func (UnimplementedUserServiceServer) Pull(context.Context, *UserPullRequest) (*UserPullResponse, error)

func (UnimplementedUserServiceServer) View 

func (UnimplementedUserServiceServer) View(context.Context, *pb.Id) (*pb.User, error)

func (UnimplementedUserServiceServer) ViewWithDeleted 

func (UnimplementedUserServiceServer) ViewWithDeleted(context.Context, *pb.Id) (*pb.User, error)

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 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 UnsafeSyncGlobalServiceServer 

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

UnsafeSyncGlobalServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SyncGlobalServiceServer 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"`
	Type  string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,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) GetType 

func (x *UserPullRequest) GetType() string

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 {
	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)
	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 {
	View(context.Context, *pb.Id) (*pb.User, error)
	Name(context.Context, *pb.Name) (*pb.User, 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

View all Source files

Jump to

Keyboard shortcuts

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