proto

package
v0.0.0-...-71516e3 Latest Latest
Warning

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

Go to latest
Published: Nov 28, 2024 License: AGPL-3.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source
const (
	BotService_PopBotTask_FullMethodName           = "/bot.BotService/PopBotTask"
	BotService_PushBotMarkers_FullMethodName       = "/bot.BotService/PushBotMarkers"
	BotService_PushBotEvent_FullMethodName         = "/bot.BotService/PushBotEvent"
	BotService_PushBotEventBlocking_FullMethodName = "/bot.BotService/PushBotEventBlocking"
)
View Source
const (
	EndpointService_StartEndpointServe_FullMethodName     = "/endpoint.EndpointService/StartEndpointServe"
	EndpointService_StopEndpointServe_FullMethodName      = "/endpoint.EndpointService/StopEndpointServe"
	EndpointService_EndpointServeKeepAlive_FullMethodName = "/endpoint.EndpointService/EndpointServeKeepAlive"
)
View Source
const (
	FunctionService_FunctionInvoke_FullMethodName    = "/function.FunctionService/FunctionInvoke"
	FunctionService_FunctionGetArgs_FullMethodName   = "/function.FunctionService/FunctionGetArgs"
	FunctionService_FunctionSetResult_FullMethodName = "/function.FunctionService/FunctionSetResult"
	FunctionService_FunctionMonitor_FullMethodName   = "/function.FunctionService/FunctionMonitor"
	FunctionService_FunctionSchedule_FullMethodName  = "/function.FunctionService/FunctionSchedule"
)
View Source
const (
	GatewayService_Authorize_FullMethodName            = "/gateway.GatewayService/Authorize"
	GatewayService_SignPayload_FullMethodName          = "/gateway.GatewayService/SignPayload"
	GatewayService_HeadObject_FullMethodName           = "/gateway.GatewayService/HeadObject"
	GatewayService_PutObject_FullMethodName            = "/gateway.GatewayService/PutObject"
	GatewayService_PutObjectStream_FullMethodName      = "/gateway.GatewayService/PutObjectStream"
	GatewayService_ReplaceObjectContent_FullMethodName = "/gateway.GatewayService/ReplaceObjectContent"
	GatewayService_ListContainers_FullMethodName       = "/gateway.GatewayService/ListContainers"
	GatewayService_StopContainer_FullMethodName        = "/gateway.GatewayService/StopContainer"
	GatewayService_StartTask_FullMethodName            = "/gateway.GatewayService/StartTask"
	GatewayService_EndTask_FullMethodName              = "/gateway.GatewayService/EndTask"
	GatewayService_StopTasks_FullMethodName            = "/gateway.GatewayService/StopTasks"
	GatewayService_ListTasks_FullMethodName            = "/gateway.GatewayService/ListTasks"
	GatewayService_GetOrCreateStub_FullMethodName      = "/gateway.GatewayService/GetOrCreateStub"
	GatewayService_DeployStub_FullMethodName           = "/gateway.GatewayService/DeployStub"
	GatewayService_GetURL_FullMethodName               = "/gateway.GatewayService/GetURL"
	GatewayService_ListDeployments_FullMethodName      = "/gateway.GatewayService/ListDeployments"
	GatewayService_StopDeployment_FullMethodName       = "/gateway.GatewayService/StopDeployment"
	GatewayService_DeleteDeployment_FullMethodName     = "/gateway.GatewayService/DeleteDeployment"
	GatewayService_ListPools_FullMethodName            = "/gateway.GatewayService/ListPools"
	GatewayService_ListMachines_FullMethodName         = "/gateway.GatewayService/ListMachines"
	GatewayService_CreateMachine_FullMethodName        = "/gateway.GatewayService/CreateMachine"
	GatewayService_DeleteMachine_FullMethodName        = "/gateway.GatewayService/DeleteMachine"
	GatewayService_ListTokens_FullMethodName           = "/gateway.GatewayService/ListTokens"
	GatewayService_CreateToken_FullMethodName          = "/gateway.GatewayService/CreateToken"
	GatewayService_ToggleToken_FullMethodName          = "/gateway.GatewayService/ToggleToken"
	GatewayService_DeleteToken_FullMethodName          = "/gateway.GatewayService/DeleteToken"
	GatewayService_ListWorkers_FullMethodName          = "/gateway.GatewayService/ListWorkers"
	GatewayService_CordonWorker_FullMethodName         = "/gateway.GatewayService/CordonWorker"
	GatewayService_UncordonWorker_FullMethodName       = "/gateway.GatewayService/UncordonWorker"
	GatewayService_DrainWorker_FullMethodName          = "/gateway.GatewayService/DrainWorker"
)
View Source
const (
	ImageService_VerifyImageBuild_FullMethodName = "/image.ImageService/VerifyImageBuild"
	ImageService_BuildImage_FullMethodName       = "/image.ImageService/BuildImage"
)
View Source
const (
	MapService_MapSet_FullMethodName    = "/map.MapService/MapSet"
	MapService_MapGet_FullMethodName    = "/map.MapService/MapGet"
	MapService_MapDelete_FullMethodName = "/map.MapService/MapDelete"
	MapService_MapCount_FullMethodName  = "/map.MapService/MapCount"
	MapService_MapKeys_FullMethodName   = "/map.MapService/MapKeys"
)
View Source
const (
	OutputService_OutputSaveStream_FullMethodName = "/output.OutputService/OutputSaveStream"
	OutputService_OutputStat_FullMethodName       = "/output.OutputService/OutputStat"
	OutputService_OutputPublicURL_FullMethodName  = "/output.OutputService/OutputPublicURL"
)
View Source
const (
	SimpleQueueService_SimpleQueuePut_FullMethodName   = "/simplequeue.SimpleQueueService/SimpleQueuePut"
	SimpleQueueService_SimpleQueuePop_FullMethodName   = "/simplequeue.SimpleQueueService/SimpleQueuePop"
	SimpleQueueService_SimpleQueuePeek_FullMethodName  = "/simplequeue.SimpleQueueService/SimpleQueuePeek"
	SimpleQueueService_SimpleQueueEmpty_FullMethodName = "/simplequeue.SimpleQueueService/SimpleQueueEmpty"
	SimpleQueueService_SimpleQueueSize_FullMethodName  = "/simplequeue.SimpleQueueService/SimpleQueueSize"
)
View Source
const (
	Scheduler_GetVersion_FullMethodName   = "/scheduler.Scheduler/GetVersion"
	Scheduler_RunContainer_FullMethodName = "/scheduler.Scheduler/RunContainer"
)
View Source
const (
	SecretService_CreateSecret_FullMethodName = "/secret.SecretService/CreateSecret"
	SecretService_DeleteSecret_FullMethodName = "/secret.SecretService/DeleteSecret"
	SecretService_UpdateSecret_FullMethodName = "/secret.SecretService/UpdateSecret"
	SecretService_GetSecret_FullMethodName    = "/secret.SecretService/GetSecret"
	SecretService_ListSecrets_FullMethodName  = "/secret.SecretService/ListSecrets"
)
View Source
const (
	SignalService_SignalSet_FullMethodName     = "/signal.SignalService/SignalSet"
	SignalService_SignalClear_FullMethodName   = "/signal.SignalService/SignalClear"
	SignalService_SignalMonitor_FullMethodName = "/signal.SignalService/SignalMonitor"
)
View Source
const (
	TaskQueueService_TaskQueuePut_FullMethodName            = "/taskqueue.TaskQueueService/TaskQueuePut"
	TaskQueueService_TaskQueuePop_FullMethodName            = "/taskqueue.TaskQueueService/TaskQueuePop"
	TaskQueueService_TaskQueueMonitor_FullMethodName        = "/taskqueue.TaskQueueService/TaskQueueMonitor"
	TaskQueueService_TaskQueueComplete_FullMethodName       = "/taskqueue.TaskQueueService/TaskQueueComplete"
	TaskQueueService_TaskQueueLength_FullMethodName         = "/taskqueue.TaskQueueService/TaskQueueLength"
	TaskQueueService_StartTaskQueueServe_FullMethodName     = "/taskqueue.TaskQueueService/StartTaskQueueServe"
	TaskQueueService_StopTaskQueueServe_FullMethodName      = "/taskqueue.TaskQueueService/StopTaskQueueServe"
	TaskQueueService_TaskQueueServeKeepAlive_FullMethodName = "/taskqueue.TaskQueueService/TaskQueueServeKeepAlive"
)
View Source
const (
	VolumeService_GetOrCreateVolume_FullMethodName = "/volume.VolumeService/GetOrCreateVolume"
	VolumeService_DeleteVolume_FullMethodName      = "/volume.VolumeService/DeleteVolume"
	VolumeService_ListVolumes_FullMethodName       = "/volume.VolumeService/ListVolumes"
	VolumeService_ListPath_FullMethodName          = "/volume.VolumeService/ListPath"
	VolumeService_DeletePath_FullMethodName        = "/volume.VolumeService/DeletePath"
	VolumeService_CopyPathStream_FullMethodName    = "/volume.VolumeService/CopyPathStream"
	VolumeService_MovePath_FullMethodName          = "/volume.VolumeService/MovePath"
)
View Source
const (
	RunCService_RunCKill_FullMethodName       = "/runc.RunCService/RunCKill"
	RunCService_RunCExec_FullMethodName       = "/runc.RunCService/RunCExec"
	RunCService_RunCStatus_FullMethodName     = "/runc.RunCService/RunCStatus"
	RunCService_RunCStreamLogs_FullMethodName = "/runc.RunCService/RunCStreamLogs"
	RunCService_RunCArchive_FullMethodName    = "/runc.RunCService/RunCArchive"
)
View Source
const (
	ContainerService_ExecuteCommand_FullMethodName = "/container.ContainerService/ExecuteCommand"
)
View Source
const (
	MachineService_GetGPUAvailability_FullMethodName = "/machine.MachineService/GetGPUAvailability"
)

Variables

View Source
var (
	ReplaceObjectContentOperation_name = map[int32]string{
		0: "WRITE",
		1: "DELETE",
		2: "MOVED",
	}
	ReplaceObjectContentOperation_value = map[string]int32{
		"WRITE":  0,
		"DELETE": 1,
		"MOVED":  2,
	}
)

Enum value maps for ReplaceObjectContentOperation.

View Source
var BotService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "bot.BotService",
	HandlerType: (*BotServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PopBotTask",
			Handler:    _BotService_PopBotTask_Handler,
		},
		{
			MethodName: "PushBotMarkers",
			Handler:    _BotService_PushBotMarkers_Handler,
		},
		{
			MethodName: "PushBotEvent",
			Handler:    _BotService_PushBotEvent_Handler,
		},
		{
			MethodName: "PushBotEventBlocking",
			Handler:    _BotService_PushBotEventBlocking_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "bot.proto",
}

BotService_ServiceDesc is the grpc.ServiceDesc for BotService 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 ContainerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "container.ContainerService",
	HandlerType: (*ContainerServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ExecuteCommand",
			Handler:       _ContainerService_ExecuteCommand_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "container.proto",
}

ContainerService_ServiceDesc is the grpc.ServiceDesc for ContainerService 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 EndpointService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "endpoint.EndpointService",
	HandlerType: (*EndpointServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "StopEndpointServe",
			Handler:    _EndpointService_StopEndpointServe_Handler,
		},
		{
			MethodName: "EndpointServeKeepAlive",
			Handler:    _EndpointService_EndpointServeKeepAlive_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StartEndpointServe",
			Handler:       _EndpointService_StartEndpointServe_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "endpoint.proto",
}

EndpointService_ServiceDesc is the grpc.ServiceDesc for EndpointService 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_container_proto protoreflect.FileDescriptor
View Source
var File_endpoint_proto protoreflect.FileDescriptor
View Source
var File_function_proto protoreflect.FileDescriptor
View Source
var File_gateway_proto protoreflect.FileDescriptor
View Source
var File_image_proto protoreflect.FileDescriptor
View Source
var File_machine_proto protoreflect.FileDescriptor
View Source
var File_output_proto protoreflect.FileDescriptor
View Source
var File_queue_proto protoreflect.FileDescriptor
View Source
var File_scheduler_proto protoreflect.FileDescriptor
View Source
var File_secret_proto protoreflect.FileDescriptor
View Source
var File_signal_proto protoreflect.FileDescriptor
View Source
var File_taskqueue_proto protoreflect.FileDescriptor
View Source
var File_volume_proto protoreflect.FileDescriptor
View Source
var File_worker_proto protoreflect.FileDescriptor
View Source
var FunctionService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "function.FunctionService",
	HandlerType: (*FunctionServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "FunctionGetArgs",
			Handler:    _FunctionService_FunctionGetArgs_Handler,
		},
		{
			MethodName: "FunctionSetResult",
			Handler:    _FunctionService_FunctionSetResult_Handler,
		},
		{
			MethodName: "FunctionSchedule",
			Handler:    _FunctionService_FunctionSchedule_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "FunctionInvoke",
			Handler:       _FunctionService_FunctionInvoke_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "FunctionMonitor",
			Handler:       _FunctionService_FunctionMonitor_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "function.proto",
}

FunctionService_ServiceDesc is the grpc.ServiceDesc for FunctionService 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 GatewayService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gateway.GatewayService",
	HandlerType: (*GatewayServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Authorize",
			Handler:    _GatewayService_Authorize_Handler,
		},
		{
			MethodName: "SignPayload",
			Handler:    _GatewayService_SignPayload_Handler,
		},
		{
			MethodName: "HeadObject",
			Handler:    _GatewayService_HeadObject_Handler,
		},
		{
			MethodName: "PutObject",
			Handler:    _GatewayService_PutObject_Handler,
		},
		{
			MethodName: "ReplaceObjectContent",
			Handler:    _GatewayService_ReplaceObjectContent_Handler,
		},
		{
			MethodName: "ListContainers",
			Handler:    _GatewayService_ListContainers_Handler,
		},
		{
			MethodName: "StopContainer",
			Handler:    _GatewayService_StopContainer_Handler,
		},
		{
			MethodName: "StartTask",
			Handler:    _GatewayService_StartTask_Handler,
		},
		{
			MethodName: "EndTask",
			Handler:    _GatewayService_EndTask_Handler,
		},
		{
			MethodName: "StopTasks",
			Handler:    _GatewayService_StopTasks_Handler,
		},
		{
			MethodName: "ListTasks",
			Handler:    _GatewayService_ListTasks_Handler,
		},
		{
			MethodName: "GetOrCreateStub",
			Handler:    _GatewayService_GetOrCreateStub_Handler,
		},
		{
			MethodName: "DeployStub",
			Handler:    _GatewayService_DeployStub_Handler,
		},
		{
			MethodName: "GetURL",
			Handler:    _GatewayService_GetURL_Handler,
		},
		{
			MethodName: "ListDeployments",
			Handler:    _GatewayService_ListDeployments_Handler,
		},
		{
			MethodName: "StopDeployment",
			Handler:    _GatewayService_StopDeployment_Handler,
		},
		{
			MethodName: "DeleteDeployment",
			Handler:    _GatewayService_DeleteDeployment_Handler,
		},
		{
			MethodName: "ListPools",
			Handler:    _GatewayService_ListPools_Handler,
		},
		{
			MethodName: "ListMachines",
			Handler:    _GatewayService_ListMachines_Handler,
		},
		{
			MethodName: "CreateMachine",
			Handler:    _GatewayService_CreateMachine_Handler,
		},
		{
			MethodName: "DeleteMachine",
			Handler:    _GatewayService_DeleteMachine_Handler,
		},
		{
			MethodName: "ListTokens",
			Handler:    _GatewayService_ListTokens_Handler,
		},
		{
			MethodName: "CreateToken",
			Handler:    _GatewayService_CreateToken_Handler,
		},
		{
			MethodName: "ToggleToken",
			Handler:    _GatewayService_ToggleToken_Handler,
		},
		{
			MethodName: "DeleteToken",
			Handler:    _GatewayService_DeleteToken_Handler,
		},
		{
			MethodName: "ListWorkers",
			Handler:    _GatewayService_ListWorkers_Handler,
		},
		{
			MethodName: "CordonWorker",
			Handler:    _GatewayService_CordonWorker_Handler,
		},
		{
			MethodName: "UncordonWorker",
			Handler:    _GatewayService_UncordonWorker_Handler,
		},
		{
			MethodName: "DrainWorker",
			Handler:    _GatewayService_DrainWorker_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "PutObjectStream",
			Handler:       _GatewayService_PutObjectStream_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "gateway.proto",
}

GatewayService_ServiceDesc is the grpc.ServiceDesc for GatewayService 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 ImageService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "image.ImageService",
	HandlerType: (*ImageServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "VerifyImageBuild",
			Handler:    _ImageService_VerifyImageBuild_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "BuildImage",
			Handler:       _ImageService_BuildImage_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "image.proto",
}

ImageService_ServiceDesc is the grpc.ServiceDesc for ImageService 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 MachineService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "machine.MachineService",
	HandlerType: (*MachineServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetGPUAvailability",
			Handler:    _MachineService_GetGPUAvailability_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "machine.proto",
}

MachineService_ServiceDesc is the grpc.ServiceDesc for MachineService 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 MapService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "map.MapService",
	HandlerType: (*MapServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "MapSet",
			Handler:    _MapService_MapSet_Handler,
		},
		{
			MethodName: "MapGet",
			Handler:    _MapService_MapGet_Handler,
		},
		{
			MethodName: "MapDelete",
			Handler:    _MapService_MapDelete_Handler,
		},
		{
			MethodName: "MapCount",
			Handler:    _MapService_MapCount_Handler,
		},
		{
			MethodName: "MapKeys",
			Handler:    _MapService_MapKeys_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "map.proto",
}

MapService_ServiceDesc is the grpc.ServiceDesc for MapService 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 OutputService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "output.OutputService",
	HandlerType: (*OutputServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "OutputStat",
			Handler:    _OutputService_OutputStat_Handler,
		},
		{
			MethodName: "OutputPublicURL",
			Handler:    _OutputService_OutputPublicURL_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "OutputSaveStream",
			Handler:       _OutputService_OutputSaveStream_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "output.proto",
}

OutputService_ServiceDesc is the grpc.ServiceDesc for OutputService 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 RunCService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "runc.RunCService",
	HandlerType: (*RunCServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RunCKill",
			Handler:    _RunCService_RunCKill_Handler,
		},
		{
			MethodName: "RunCExec",
			Handler:    _RunCService_RunCExec_Handler,
		},
		{
			MethodName: "RunCStatus",
			Handler:    _RunCService_RunCStatus_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "RunCStreamLogs",
			Handler:       _RunCService_RunCStreamLogs_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "RunCArchive",
			Handler:       _RunCService_RunCArchive_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "worker.proto",
}

RunCService_ServiceDesc is the grpc.ServiceDesc for RunCService 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 Scheduler_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "scheduler.Scheduler",
	HandlerType: (*SchedulerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetVersion",
			Handler:    _Scheduler_GetVersion_Handler,
		},
		{
			MethodName: "RunContainer",
			Handler:    _Scheduler_RunContainer_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "scheduler.proto",
}

Scheduler_ServiceDesc is the grpc.ServiceDesc for Scheduler 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 SecretService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "secret.SecretService",
	HandlerType: (*SecretServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateSecret",
			Handler:    _SecretService_CreateSecret_Handler,
		},
		{
			MethodName: "DeleteSecret",
			Handler:    _SecretService_DeleteSecret_Handler,
		},
		{
			MethodName: "UpdateSecret",
			Handler:    _SecretService_UpdateSecret_Handler,
		},
		{
			MethodName: "GetSecret",
			Handler:    _SecretService_GetSecret_Handler,
		},
		{
			MethodName: "ListSecrets",
			Handler:    _SecretService_ListSecrets_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "secret.proto",
}

SecretService_ServiceDesc is the grpc.ServiceDesc for SecretService 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 SignalService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "signal.SignalService",
	HandlerType: (*SignalServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SignalSet",
			Handler:    _SignalService_SignalSet_Handler,
		},
		{
			MethodName: "SignalClear",
			Handler:    _SignalService_SignalClear_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SignalMonitor",
			Handler:       _SignalService_SignalMonitor_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "signal.proto",
}

SignalService_ServiceDesc is the grpc.ServiceDesc for SignalService 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 SimpleQueueService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "simplequeue.SimpleQueueService",
	HandlerType: (*SimpleQueueServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SimpleQueuePut",
			Handler:    _SimpleQueueService_SimpleQueuePut_Handler,
		},
		{
			MethodName: "SimpleQueuePop",
			Handler:    _SimpleQueueService_SimpleQueuePop_Handler,
		},
		{
			MethodName: "SimpleQueuePeek",
			Handler:    _SimpleQueueService_SimpleQueuePeek_Handler,
		},
		{
			MethodName: "SimpleQueueEmpty",
			Handler:    _SimpleQueueService_SimpleQueueEmpty_Handler,
		},
		{
			MethodName: "SimpleQueueSize",
			Handler:    _SimpleQueueService_SimpleQueueSize_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "queue.proto",
}

SimpleQueueService_ServiceDesc is the grpc.ServiceDesc for SimpleQueueService 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 TaskQueueService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "taskqueue.TaskQueueService",
	HandlerType: (*TaskQueueServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "TaskQueuePut",
			Handler:    _TaskQueueService_TaskQueuePut_Handler,
		},
		{
			MethodName: "TaskQueuePop",
			Handler:    _TaskQueueService_TaskQueuePop_Handler,
		},
		{
			MethodName: "TaskQueueComplete",
			Handler:    _TaskQueueService_TaskQueueComplete_Handler,
		},
		{
			MethodName: "TaskQueueLength",
			Handler:    _TaskQueueService_TaskQueueLength_Handler,
		},
		{
			MethodName: "StopTaskQueueServe",
			Handler:    _TaskQueueService_StopTaskQueueServe_Handler,
		},
		{
			MethodName: "TaskQueueServeKeepAlive",
			Handler:    _TaskQueueService_TaskQueueServeKeepAlive_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "TaskQueueMonitor",
			Handler:       _TaskQueueService_TaskQueueMonitor_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "StartTaskQueueServe",
			Handler:       _TaskQueueService_StartTaskQueueServe_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "taskqueue.proto",
}

TaskQueueService_ServiceDesc is the grpc.ServiceDesc for TaskQueueService 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 VolumeService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "volume.VolumeService",
	HandlerType: (*VolumeServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetOrCreateVolume",
			Handler:    _VolumeService_GetOrCreateVolume_Handler,
		},
		{
			MethodName: "DeleteVolume",
			Handler:    _VolumeService_DeleteVolume_Handler,
		},
		{
			MethodName: "ListVolumes",
			Handler:    _VolumeService_ListVolumes_Handler,
		},
		{
			MethodName: "ListPath",
			Handler:    _VolumeService_ListPath_Handler,
		},
		{
			MethodName: "DeletePath",
			Handler:    _VolumeService_DeletePath_Handler,
		},
		{
			MethodName: "MovePath",
			Handler:    _VolumeService_MovePath_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "CopyPathStream",
			Handler:       _VolumeService_CopyPathStream_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "volume.proto",
}

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

Functions

func RegisterBotServiceServer

func RegisterBotServiceServer(s grpc.ServiceRegistrar, srv BotServiceServer)

func RegisterContainerServiceServer

func RegisterContainerServiceServer(s grpc.ServiceRegistrar, srv ContainerServiceServer)

func RegisterEndpointServiceServer

func RegisterEndpointServiceServer(s grpc.ServiceRegistrar, srv EndpointServiceServer)

func RegisterFunctionServiceServer

func RegisterFunctionServiceServer(s grpc.ServiceRegistrar, srv FunctionServiceServer)

func RegisterGatewayServiceServer

func RegisterGatewayServiceServer(s grpc.ServiceRegistrar, srv GatewayServiceServer)

func RegisterImageServiceServer

func RegisterImageServiceServer(s grpc.ServiceRegistrar, srv ImageServiceServer)

func RegisterMachineServiceServer

func RegisterMachineServiceServer(s grpc.ServiceRegistrar, srv MachineServiceServer)

func RegisterMapServiceServer

func RegisterMapServiceServer(s grpc.ServiceRegistrar, srv MapServiceServer)

func RegisterOutputServiceServer

func RegisterOutputServiceServer(s grpc.ServiceRegistrar, srv OutputServiceServer)

func RegisterRunCServiceServer

func RegisterRunCServiceServer(s grpc.ServiceRegistrar, srv RunCServiceServer)

func RegisterSchedulerServer

func RegisterSchedulerServer(s grpc.ServiceRegistrar, srv SchedulerServer)

func RegisterSecretServiceServer

func RegisterSecretServiceServer(s grpc.ServiceRegistrar, srv SecretServiceServer)

func RegisterSignalServiceServer

func RegisterSignalServiceServer(s grpc.ServiceRegistrar, srv SignalServiceServer)

func RegisterSimpleQueueServiceServer

func RegisterSimpleQueueServiceServer(s grpc.ServiceRegistrar, srv SimpleQueueServiceServer)

func RegisterTaskQueueServiceServer

func RegisterTaskQueueServiceServer(s grpc.ServiceRegistrar, srv TaskQueueServiceServer)

func RegisterVolumeServiceServer

func RegisterVolumeServiceServer(s grpc.ServiceRegistrar, srv VolumeServiceServer)

Types

type AuthorizeRequest

type AuthorizeRequest struct {
	// contains filtered or unexported fields
}

func (*AuthorizeRequest) Descriptor deprecated

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

Deprecated: Use AuthorizeRequest.ProtoReflect.Descriptor instead.

func (*AuthorizeRequest) ProtoMessage

func (*AuthorizeRequest) ProtoMessage()

func (*AuthorizeRequest) ProtoReflect

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

func (*AuthorizeRequest) Reset

func (x *AuthorizeRequest) Reset()

func (*AuthorizeRequest) String

func (x *AuthorizeRequest) String() string

type AuthorizeResponse

type AuthorizeResponse struct {
	Ok          bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	WorkspaceId string `protobuf:"bytes,2,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	NewToken    string `protobuf:"bytes,3,opt,name=new_token,json=newToken,proto3" json:"new_token,omitempty"`
	ErrorMsg    string `protobuf:"bytes,4,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
	// contains filtered or unexported fields
}

func (*AuthorizeResponse) Descriptor deprecated

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

Deprecated: Use AuthorizeResponse.ProtoReflect.Descriptor instead.

func (*AuthorizeResponse) GetErrorMsg

func (x *AuthorizeResponse) GetErrorMsg() string

func (*AuthorizeResponse) GetNewToken

func (x *AuthorizeResponse) GetNewToken() string

func (*AuthorizeResponse) GetOk

func (x *AuthorizeResponse) GetOk() bool

func (*AuthorizeResponse) GetWorkspaceId

func (x *AuthorizeResponse) GetWorkspaceId() string

func (*AuthorizeResponse) ProtoMessage

func (*AuthorizeResponse) ProtoMessage()

func (*AuthorizeResponse) ProtoReflect

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

func (*AuthorizeResponse) Reset

func (x *AuthorizeResponse) Reset()

func (*AuthorizeResponse) String

func (x *AuthorizeResponse) String() string

type Autoscaler

type Autoscaler struct {
	Type              string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	MaxContainers     uint32 `protobuf:"varint,2,opt,name=max_containers,json=maxContainers,proto3" json:"max_containers,omitempty"`
	TasksPerContainer uint32 `protobuf:"varint,3,opt,name=tasks_per_container,json=tasksPerContainer,proto3" json:"tasks_per_container,omitempty"`
	// contains filtered or unexported fields
}

func (*Autoscaler) Descriptor deprecated

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

Deprecated: Use Autoscaler.ProtoReflect.Descriptor instead.

func (*Autoscaler) GetMaxContainers

func (x *Autoscaler) GetMaxContainers() uint32

func (*Autoscaler) GetTasksPerContainer

func (x *Autoscaler) GetTasksPerContainer() uint32

func (*Autoscaler) GetType

func (x *Autoscaler) GetType() string

func (*Autoscaler) ProtoMessage

func (*Autoscaler) ProtoMessage()

func (*Autoscaler) ProtoReflect

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

func (*Autoscaler) Reset

func (x *Autoscaler) Reset()

func (*Autoscaler) String

func (x *Autoscaler) String() string

type BotEvent

type BotEvent struct {
	Type     string            `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Value    string            `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*BotEvent) Descriptor deprecated

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

Deprecated: Use BotEvent.ProtoReflect.Descriptor instead.

func (*BotEvent) GetMetadata

func (x *BotEvent) GetMetadata() map[string]string

func (*BotEvent) GetType

func (x *BotEvent) GetType() string

func (*BotEvent) GetValue

func (x *BotEvent) GetValue() string

func (*BotEvent) ProtoMessage

func (*BotEvent) ProtoMessage()

func (*BotEvent) ProtoReflect

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

func (*BotEvent) Reset

func (x *BotEvent) Reset()

func (*BotEvent) String

func (x *BotEvent) String() string

type BotServiceClient

type BotServiceClient interface {
	PopBotTask(ctx context.Context, in *PopBotTaskRequest, opts ...grpc.CallOption) (*PopBotTaskResponse, error)
	PushBotMarkers(ctx context.Context, in *PushBotMarkersRequest, opts ...grpc.CallOption) (*PushBotMarkersResponse, error)
	PushBotEvent(ctx context.Context, in *PushBotEventRequest, opts ...grpc.CallOption) (*PushBotEventResponse, error)
	PushBotEventBlocking(ctx context.Context, in *PushBotEventBlockingRequest, opts ...grpc.CallOption) (*PushBotEventBlockingResponse, error)
}

BotServiceClient is the client API for BotService 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 NewBotServiceClient

func NewBotServiceClient(cc grpc.ClientConnInterface) BotServiceClient

type BotServiceServer

type BotServiceServer interface {
	PopBotTask(context.Context, *PopBotTaskRequest) (*PopBotTaskResponse, error)
	PushBotMarkers(context.Context, *PushBotMarkersRequest) (*PushBotMarkersResponse, error)
	PushBotEvent(context.Context, *PushBotEventRequest) (*PushBotEventResponse, error)
	PushBotEventBlocking(context.Context, *PushBotEventBlockingRequest) (*PushBotEventBlockingResponse, error)
	// contains filtered or unexported methods
}

BotServiceServer is the server API for BotService service. All implementations must embed UnimplementedBotServiceServer for forward compatibility

type BuildImageRequest

type BuildImageRequest struct {

	// These parameters are used for a "beta9" managed image
	PythonVersion  string   `protobuf:"bytes,1,opt,name=python_version,json=pythonVersion,proto3" json:"python_version,omitempty"`
	PythonPackages []string `protobuf:"bytes,2,rep,name=python_packages,json=pythonPackages,proto3" json:"python_packages,omitempty"`
	Commands       []string `protobuf:"bytes,3,rep,name=commands,proto3" json:"commands,omitempty"`
	// These parameters are used for an existing image
	ExistingImageUri   string            `protobuf:"bytes,4,opt,name=existing_image_uri,json=existingImageUri,proto3" json:"existing_image_uri,omitempty"` // URI for an existing image in the format
	ExistingImageCreds map[string]string ``                                                                                                                /* 205-byte string literal not displayed */
	BuildSteps         []*BuildStep      `protobuf:"bytes,6,rep,name=build_steps,json=buildSteps,proto3" json:"build_steps,omitempty"`
	EnvVars            []string          `protobuf:"bytes,7,rep,name=env_vars,json=envVars,proto3" json:"env_vars,omitempty"`
	// contains filtered or unexported fields
}

func (*BuildImageRequest) Descriptor deprecated

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

Deprecated: Use BuildImageRequest.ProtoReflect.Descriptor instead.

func (*BuildImageRequest) GetBuildSteps

func (x *BuildImageRequest) GetBuildSteps() []*BuildStep

func (*BuildImageRequest) GetCommands

func (x *BuildImageRequest) GetCommands() []string

func (*BuildImageRequest) GetEnvVars

func (x *BuildImageRequest) GetEnvVars() []string

func (*BuildImageRequest) GetExistingImageCreds

func (x *BuildImageRequest) GetExistingImageCreds() map[string]string

func (*BuildImageRequest) GetExistingImageUri

func (x *BuildImageRequest) GetExistingImageUri() string

func (*BuildImageRequest) GetPythonPackages

func (x *BuildImageRequest) GetPythonPackages() []string

func (*BuildImageRequest) GetPythonVersion

func (x *BuildImageRequest) GetPythonVersion() string

func (*BuildImageRequest) ProtoMessage

func (*BuildImageRequest) ProtoMessage()

func (*BuildImageRequest) ProtoReflect

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

func (*BuildImageRequest) Reset

func (x *BuildImageRequest) Reset()

func (*BuildImageRequest) String

func (x *BuildImageRequest) String() string

type BuildImageResponse

type BuildImageResponse struct {
	ImageId string `protobuf:"bytes,1,opt,name=image_id,json=imageId,proto3" json:"image_id,omitempty"`
	Msg     string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Done    bool   `protobuf:"varint,3,opt,name=done,proto3" json:"done,omitempty"`
	Success bool   `protobuf:"varint,4,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*BuildImageResponse) Descriptor deprecated

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

Deprecated: Use BuildImageResponse.ProtoReflect.Descriptor instead.

func (*BuildImageResponse) GetDone

func (x *BuildImageResponse) GetDone() bool

func (*BuildImageResponse) GetImageId

func (x *BuildImageResponse) GetImageId() string

func (*BuildImageResponse) GetMsg

func (x *BuildImageResponse) GetMsg() string

func (*BuildImageResponse) GetSuccess

func (x *BuildImageResponse) GetSuccess() bool

func (*BuildImageResponse) ProtoMessage

func (*BuildImageResponse) ProtoMessage()

func (*BuildImageResponse) ProtoReflect

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

func (*BuildImageResponse) Reset

func (x *BuildImageResponse) Reset()

func (*BuildImageResponse) String

func (x *BuildImageResponse) String() string

type BuildStep

type BuildStep struct {
	Type    string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Command string `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"`
	// contains filtered or unexported fields
}

func (*BuildStep) Descriptor deprecated

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

Deprecated: Use BuildStep.ProtoReflect.Descriptor instead.

func (*BuildStep) GetCommand

func (x *BuildStep) GetCommand() string

func (*BuildStep) GetType

func (x *BuildStep) GetType() string

func (*BuildStep) ProtoMessage

func (*BuildStep) ProtoMessage()

func (*BuildStep) ProtoReflect

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

func (*BuildStep) Reset

func (x *BuildStep) Reset()

func (*BuildStep) String

func (x *BuildStep) String() string

type CommandExecutionRequest

type CommandExecutionRequest struct {
	StubId  string `protobuf:"bytes,1,opt,name=stub_id,json=stubId,proto3" json:"stub_id,omitempty"`
	Command []byte `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandExecutionRequest) Descriptor deprecated

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

Deprecated: Use CommandExecutionRequest.ProtoReflect.Descriptor instead.

func (*CommandExecutionRequest) GetCommand

func (x *CommandExecutionRequest) GetCommand() []byte

func (*CommandExecutionRequest) GetStubId

func (x *CommandExecutionRequest) GetStubId() string

func (*CommandExecutionRequest) ProtoMessage

func (*CommandExecutionRequest) ProtoMessage()

func (*CommandExecutionRequest) ProtoReflect

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

func (*CommandExecutionRequest) Reset

func (x *CommandExecutionRequest) Reset()

func (*CommandExecutionRequest) String

func (x *CommandExecutionRequest) String() string

type CommandExecutionResponse

type CommandExecutionResponse struct {
	TaskId   string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Output   string `protobuf:"bytes,2,opt,name=output,proto3" json:"output,omitempty"`
	Done     bool   `protobuf:"varint,3,opt,name=done,proto3" json:"done,omitempty"`
	ExitCode int32  `protobuf:"varint,4,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandExecutionResponse) Descriptor deprecated

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

Deprecated: Use CommandExecutionResponse.ProtoReflect.Descriptor instead.

func (*CommandExecutionResponse) GetDone

func (x *CommandExecutionResponse) GetDone() bool

func (*CommandExecutionResponse) GetExitCode

func (x *CommandExecutionResponse) GetExitCode() int32

func (*CommandExecutionResponse) GetOutput

func (x *CommandExecutionResponse) GetOutput() string

func (*CommandExecutionResponse) GetTaskId

func (x *CommandExecutionResponse) GetTaskId() string

func (*CommandExecutionResponse) ProtoMessage

func (*CommandExecutionResponse) ProtoMessage()

func (*CommandExecutionResponse) ProtoReflect

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

func (*CommandExecutionResponse) Reset

func (x *CommandExecutionResponse) Reset()

func (*CommandExecutionResponse) String

func (x *CommandExecutionResponse) String() string

type Container

type Container struct {
	ContainerId string                 `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	StubId      string                 `protobuf:"bytes,2,opt,name=stub_id,json=stubId,proto3" json:"stub_id,omitempty"`
	Status      string                 `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	ScheduledAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=scheduled_at,json=scheduledAt,proto3" json:"scheduled_at,omitempty"`
	WorkspaceId string                 `protobuf:"bytes,5,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	WorkerId    string                 `protobuf:"bytes,6,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	MachineId   string                 `protobuf:"bytes,7,opt,name=machine_id,json=machineId,proto3" json:"machine_id,omitempty"`
	// contains filtered or unexported fields
}

func (*Container) Descriptor deprecated

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

Deprecated: Use Container.ProtoReflect.Descriptor instead.

func (*Container) GetContainerId

func (x *Container) GetContainerId() string

func (*Container) GetMachineId

func (x *Container) GetMachineId() string

func (*Container) GetScheduledAt

func (x *Container) GetScheduledAt() *timestamppb.Timestamp

func (*Container) GetStatus

func (x *Container) GetStatus() string

func (*Container) GetStubId

func (x *Container) GetStubId() string

func (*Container) GetWorkerId

func (x *Container) GetWorkerId() string

func (*Container) GetWorkspaceId

func (x *Container) GetWorkspaceId() string

func (*Container) ProtoMessage

func (*Container) ProtoMessage()

func (*Container) ProtoReflect

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

func (*Container) Reset

func (x *Container) Reset()

func (*Container) String

func (x *Container) String() string

type ContainerServiceClient

type ContainerServiceClient interface {
	ExecuteCommand(ctx context.Context, in *CommandExecutionRequest, opts ...grpc.CallOption) (ContainerService_ExecuteCommandClient, error)
}

ContainerServiceClient is the client API for ContainerService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type ContainerServiceServer

type ContainerServiceServer interface {
	ExecuteCommand(*CommandExecutionRequest, ContainerService_ExecuteCommandServer) error
	// contains filtered or unexported methods
}

ContainerServiceServer is the server API for ContainerService service. All implementations must embed UnimplementedContainerServiceServer for forward compatibility

type ContainerService_ExecuteCommandClient

type ContainerService_ExecuteCommandClient interface {
	Recv() (*CommandExecutionResponse, error)
	grpc.ClientStream
}

type ContainerService_ExecuteCommandServer

type ContainerService_ExecuteCommandServer interface {
	Send(*CommandExecutionResponse) error
	grpc.ServerStream
}

type ContainerTaskStatusUpdateRequest

type ContainerTaskStatusUpdateRequest struct {
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*ContainerTaskStatusUpdateRequest) Descriptor deprecated

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

Deprecated: Use ContainerTaskStatusUpdateRequest.ProtoReflect.Descriptor instead.

func (*ContainerTaskStatusUpdateRequest) GetStatus

func (*ContainerTaskStatusUpdateRequest) GetTaskId

func (*ContainerTaskStatusUpdateRequest) ProtoMessage

func (*ContainerTaskStatusUpdateRequest) ProtoMessage()

func (*ContainerTaskStatusUpdateRequest) ProtoReflect

func (*ContainerTaskStatusUpdateRequest) Reset

func (*ContainerTaskStatusUpdateRequest) String

type ContainerTaskStatusUpdateResponse

type ContainerTaskStatusUpdateResponse struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*ContainerTaskStatusUpdateResponse) Descriptor deprecated

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

Deprecated: Use ContainerTaskStatusUpdateResponse.ProtoReflect.Descriptor instead.

func (*ContainerTaskStatusUpdateResponse) GetOk

func (*ContainerTaskStatusUpdateResponse) ProtoMessage

func (*ContainerTaskStatusUpdateResponse) ProtoMessage()

func (*ContainerTaskStatusUpdateResponse) ProtoReflect

func (*ContainerTaskStatusUpdateResponse) Reset

func (*ContainerTaskStatusUpdateResponse) String

type CopyPathRequest

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

func (*CopyPathRequest) Descriptor deprecated

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

Deprecated: Use CopyPathRequest.ProtoReflect.Descriptor instead.

func (*CopyPathRequest) GetContent

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

func (*CopyPathRequest) GetPath

func (x *CopyPathRequest) GetPath() string

func (*CopyPathRequest) ProtoMessage

func (*CopyPathRequest) ProtoMessage()

func (*CopyPathRequest) ProtoReflect

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

func (*CopyPathRequest) Reset

func (x *CopyPathRequest) Reset()

func (*CopyPathRequest) String

func (x *CopyPathRequest) String() string

type CopyPathResponse

type CopyPathResponse struct {
	Ok       bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ObjectId string `protobuf:"bytes,2,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"`
	ErrMsg   string `protobuf:"bytes,3,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	// contains filtered or unexported fields
}

func (*CopyPathResponse) Descriptor deprecated

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

Deprecated: Use CopyPathResponse.ProtoReflect.Descriptor instead.

func (*CopyPathResponse) GetErrMsg

func (x *CopyPathResponse) GetErrMsg() string

func (*CopyPathResponse) GetObjectId

func (x *CopyPathResponse) GetObjectId() string

func (*CopyPathResponse) GetOk

func (x *CopyPathResponse) GetOk() bool

func (*CopyPathResponse) ProtoMessage

func (*CopyPathResponse) ProtoMessage()

func (*CopyPathResponse) ProtoReflect

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

func (*CopyPathResponse) Reset

func (x *CopyPathResponse) Reset()

func (*CopyPathResponse) String

func (x *CopyPathResponse) String() string

type CordonWorkerRequest

type CordonWorkerRequest struct {
	WorkerId string `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CordonWorkerRequest) Descriptor deprecated

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

Deprecated: Use CordonWorkerRequest.ProtoReflect.Descriptor instead.

func (*CordonWorkerRequest) GetWorkerId

func (x *CordonWorkerRequest) GetWorkerId() string

func (*CordonWorkerRequest) ProtoMessage

func (*CordonWorkerRequest) ProtoMessage()

func (*CordonWorkerRequest) ProtoReflect

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

func (*CordonWorkerRequest) Reset

func (x *CordonWorkerRequest) Reset()

func (*CordonWorkerRequest) String

func (x *CordonWorkerRequest) String() string

type CordonWorkerResponse

type CordonWorkerResponse struct {
	Ok     bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrMsg string `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	// contains filtered or unexported fields
}

func (*CordonWorkerResponse) Descriptor deprecated

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

Deprecated: Use CordonWorkerResponse.ProtoReflect.Descriptor instead.

func (*CordonWorkerResponse) GetErrMsg

func (x *CordonWorkerResponse) GetErrMsg() string

func (*CordonWorkerResponse) GetOk

func (x *CordonWorkerResponse) GetOk() bool

func (*CordonWorkerResponse) ProtoMessage

func (*CordonWorkerResponse) ProtoMessage()

func (*CordonWorkerResponse) ProtoReflect

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

func (*CordonWorkerResponse) Reset

func (x *CordonWorkerResponse) Reset()

func (*CordonWorkerResponse) String

func (x *CordonWorkerResponse) String() string

type CreateMachineRequest

type CreateMachineRequest struct {
	PoolName string `protobuf:"bytes,1,opt,name=pool_name,json=poolName,proto3" json:"pool_name,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateMachineRequest) Descriptor deprecated

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

Deprecated: Use CreateMachineRequest.ProtoReflect.Descriptor instead.

func (*CreateMachineRequest) GetPoolName

func (x *CreateMachineRequest) GetPoolName() string

func (*CreateMachineRequest) ProtoMessage

func (*CreateMachineRequest) ProtoMessage()

func (*CreateMachineRequest) ProtoReflect

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

func (*CreateMachineRequest) Reset

func (x *CreateMachineRequest) Reset()

func (*CreateMachineRequest) String

func (x *CreateMachineRequest) String() string

type CreateMachineResponse

type CreateMachineResponse struct {
	Ok      bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrMsg  string   `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	Machine *Machine `protobuf:"bytes,3,opt,name=machine,proto3" json:"machine,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateMachineResponse) Descriptor deprecated

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

Deprecated: Use CreateMachineResponse.ProtoReflect.Descriptor instead.

func (*CreateMachineResponse) GetErrMsg

func (x *CreateMachineResponse) GetErrMsg() string

func (*CreateMachineResponse) GetMachine

func (x *CreateMachineResponse) GetMachine() *Machine

func (*CreateMachineResponse) GetOk

func (x *CreateMachineResponse) GetOk() bool

func (*CreateMachineResponse) ProtoMessage

func (*CreateMachineResponse) ProtoMessage()

func (*CreateMachineResponse) ProtoReflect

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

func (*CreateMachineResponse) Reset

func (x *CreateMachineResponse) Reset()

func (*CreateMachineResponse) String

func (x *CreateMachineResponse) String() string

type CreateSecretRequest

type CreateSecretRequest struct {
	Name  string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateSecretRequest) Descriptor deprecated

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

Deprecated: Use CreateSecretRequest.ProtoReflect.Descriptor instead.

func (*CreateSecretRequest) GetName

func (x *CreateSecretRequest) GetName() string

func (*CreateSecretRequest) GetValue

func (x *CreateSecretRequest) GetValue() string

func (*CreateSecretRequest) ProtoMessage

func (*CreateSecretRequest) ProtoMessage()

func (*CreateSecretRequest) ProtoReflect

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

func (*CreateSecretRequest) Reset

func (x *CreateSecretRequest) Reset()

func (*CreateSecretRequest) String

func (x *CreateSecretRequest) String() string

type CreateSecretResponse

type CreateSecretResponse struct {
	Ok     bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrMsg string `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	Id     string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	Name   string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateSecretResponse) Descriptor deprecated

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

Deprecated: Use CreateSecretResponse.ProtoReflect.Descriptor instead.

func (*CreateSecretResponse) GetErrMsg

func (x *CreateSecretResponse) GetErrMsg() string

func (*CreateSecretResponse) GetId

func (x *CreateSecretResponse) GetId() string

func (*CreateSecretResponse) GetName

func (x *CreateSecretResponse) GetName() string

func (*CreateSecretResponse) GetOk

func (x *CreateSecretResponse) GetOk() bool

func (*CreateSecretResponse) ProtoMessage

func (*CreateSecretResponse) ProtoMessage()

func (*CreateSecretResponse) ProtoReflect

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

func (*CreateSecretResponse) Reset

func (x *CreateSecretResponse) Reset()

func (*CreateSecretResponse) String

func (x *CreateSecretResponse) String() string

type CreateTokenRequest

type CreateTokenRequest struct {
	// contains filtered or unexported fields
}

func (*CreateTokenRequest) Descriptor deprecated

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

Deprecated: Use CreateTokenRequest.ProtoReflect.Descriptor instead.

func (*CreateTokenRequest) ProtoMessage

func (*CreateTokenRequest) ProtoMessage()

func (*CreateTokenRequest) ProtoReflect

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

func (*CreateTokenRequest) Reset

func (x *CreateTokenRequest) Reset()

func (*CreateTokenRequest) String

func (x *CreateTokenRequest) String() string

type CreateTokenResponse

type CreateTokenResponse struct {
	Ok     bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrMsg string `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	Token  *Token `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTokenResponse) Descriptor deprecated

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

Deprecated: Use CreateTokenResponse.ProtoReflect.Descriptor instead.

func (*CreateTokenResponse) GetErrMsg

func (x *CreateTokenResponse) GetErrMsg() string

func (*CreateTokenResponse) GetOk

func (x *CreateTokenResponse) GetOk() bool

func (*CreateTokenResponse) GetToken

func (x *CreateTokenResponse) GetToken() *Token

func (*CreateTokenResponse) ProtoMessage

func (*CreateTokenResponse) ProtoMessage()

func (*CreateTokenResponse) ProtoReflect

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

func (*CreateTokenResponse) Reset

func (x *CreateTokenResponse) Reset()

func (*CreateTokenResponse) String

func (x *CreateTokenResponse) String() string

type DeleteDeploymentRequest

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

func (*DeleteDeploymentRequest) Descriptor deprecated

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

Deprecated: Use DeleteDeploymentRequest.ProtoReflect.Descriptor instead.

func (*DeleteDeploymentRequest) GetId

func (x *DeleteDeploymentRequest) GetId() string

func (*DeleteDeploymentRequest) ProtoMessage

func (*DeleteDeploymentRequest) ProtoMessage()

func (*DeleteDeploymentRequest) ProtoReflect

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

func (*DeleteDeploymentRequest) Reset

func (x *DeleteDeploymentRequest) Reset()

func (*DeleteDeploymentRequest) String

func (x *DeleteDeploymentRequest) String() string

type DeleteDeploymentResponse

type DeleteDeploymentResponse struct {
	Ok     bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrMsg string `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteDeploymentResponse) Descriptor deprecated

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

Deprecated: Use DeleteDeploymentResponse.ProtoReflect.Descriptor instead.

func (*DeleteDeploymentResponse) GetErrMsg

func (x *DeleteDeploymentResponse) GetErrMsg() string

func (*DeleteDeploymentResponse) GetOk

func (x *DeleteDeploymentResponse) GetOk() bool

func (*DeleteDeploymentResponse) ProtoMessage

func (*DeleteDeploymentResponse) ProtoMessage()

func (*DeleteDeploymentResponse) ProtoReflect

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

func (*DeleteDeploymentResponse) Reset

func (x *DeleteDeploymentResponse) Reset()

func (*DeleteDeploymentResponse) String

func (x *DeleteDeploymentResponse) String() string

type DeleteMachineRequest

type DeleteMachineRequest struct {
	MachineId string `protobuf:"bytes,1,opt,name=machine_id,json=machineId,proto3" json:"machine_id,omitempty"`
	PoolName  string `protobuf:"bytes,2,opt,name=pool_name,json=poolName,proto3" json:"pool_name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteMachineRequest) Descriptor deprecated

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

Deprecated: Use DeleteMachineRequest.ProtoReflect.Descriptor instead.

func (*DeleteMachineRequest) GetMachineId

func (x *DeleteMachineRequest) GetMachineId() string

func (*DeleteMachineRequest) GetPoolName

func (x *DeleteMachineRequest) GetPoolName() string

func (*DeleteMachineRequest) ProtoMessage

func (*DeleteMachineRequest) ProtoMessage()

func (*DeleteMachineRequest) ProtoReflect

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

func (*DeleteMachineRequest) Reset

func (x *DeleteMachineRequest) Reset()

func (*DeleteMachineRequest) String

func (x *DeleteMachineRequest) String() string

type DeleteMachineResponse

type DeleteMachineResponse struct {
	Ok     bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrMsg string `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteMachineResponse) Descriptor deprecated

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

Deprecated: Use DeleteMachineResponse.ProtoReflect.Descriptor instead.

func (*DeleteMachineResponse) GetErrMsg

func (x *DeleteMachineResponse) GetErrMsg() string

func (*DeleteMachineResponse) GetOk

func (x *DeleteMachineResponse) GetOk() bool

func (*DeleteMachineResponse) ProtoMessage

func (*DeleteMachineResponse) ProtoMessage()

func (*DeleteMachineResponse) ProtoReflect

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

func (*DeleteMachineResponse) Reset

func (x *DeleteMachineResponse) Reset()

func (*DeleteMachineResponse) String

func (x *DeleteMachineResponse) String() string

type DeletePathRequest

type DeletePathRequest struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*DeletePathRequest) Descriptor deprecated

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

Deprecated: Use DeletePathRequest.ProtoReflect.Descriptor instead.

func (*DeletePathRequest) GetPath

func (x *DeletePathRequest) GetPath() string

func (*DeletePathRequest) ProtoMessage

func (*DeletePathRequest) ProtoMessage()

func (*DeletePathRequest) ProtoReflect

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

func (*DeletePathRequest) Reset

func (x *DeletePathRequest) Reset()

func (*DeletePathRequest) String

func (x *DeletePathRequest) String() string

type DeletePathResponse

type DeletePathResponse struct {
	Ok      bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrMsg  string   `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	Deleted []string `protobuf:"bytes,3,rep,name=deleted,proto3" json:"deleted,omitempty"`
	// contains filtered or unexported fields
}

func (*DeletePathResponse) Descriptor deprecated

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

Deprecated: Use DeletePathResponse.ProtoReflect.Descriptor instead.

func (*DeletePathResponse) GetDeleted

func (x *DeletePathResponse) GetDeleted() []string

func (*DeletePathResponse) GetErrMsg

func (x *DeletePathResponse) GetErrMsg() string

func (*DeletePathResponse) GetOk

func (x *DeletePathResponse) GetOk() bool

func (*DeletePathResponse) ProtoMessage

func (*DeletePathResponse) ProtoMessage()

func (*DeletePathResponse) ProtoReflect

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

func (*DeletePathResponse) Reset

func (x *DeletePathResponse) Reset()

func (*DeletePathResponse) String

func (x *DeletePathResponse) String() string

type DeleteSecretRequest

type DeleteSecretRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteSecretRequest) Descriptor deprecated

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

Deprecated: Use DeleteSecretRequest.ProtoReflect.Descriptor instead.

func (*DeleteSecretRequest) GetName

func (x *DeleteSecretRequest) GetName() string

func (*DeleteSecretRequest) ProtoMessage

func (*DeleteSecretRequest) ProtoMessage()

func (*DeleteSecretRequest) ProtoReflect

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

func (*DeleteSecretRequest) Reset

func (x *DeleteSecretRequest) Reset()

func (*DeleteSecretRequest) String

func (x *DeleteSecretRequest) String() string

type DeleteSecretResponse

type DeleteSecretResponse struct {
	Ok     bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrMsg string `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteSecretResponse) Descriptor deprecated

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

Deprecated: Use DeleteSecretResponse.ProtoReflect.Descriptor instead.

func (*DeleteSecretResponse) GetErrMsg

func (x *DeleteSecretResponse) GetErrMsg() string

func (*DeleteSecretResponse) GetOk

func (x *DeleteSecretResponse) GetOk() bool

func (*DeleteSecretResponse) ProtoMessage

func (*DeleteSecretResponse) ProtoMessage()

func (*DeleteSecretResponse) ProtoReflect

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

func (*DeleteSecretResponse) Reset

func (x *DeleteSecretResponse) Reset()

func (*DeleteSecretResponse) String

func (x *DeleteSecretResponse) String() string

type DeleteTokenRequest

type DeleteTokenRequest struct {
	TokenId string `protobuf:"bytes,1,opt,name=token_id,json=tokenId,proto3" json:"token_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteTokenRequest) Descriptor deprecated

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

Deprecated: Use DeleteTokenRequest.ProtoReflect.Descriptor instead.

func (*DeleteTokenRequest) GetTokenId

func (x *DeleteTokenRequest) GetTokenId() string

func (*DeleteTokenRequest) ProtoMessage

func (*DeleteTokenRequest) ProtoMessage()

func (*DeleteTokenRequest) ProtoReflect

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

func (*DeleteTokenRequest) Reset

func (x *DeleteTokenRequest) Reset()

func (*DeleteTokenRequest) String

func (x *DeleteTokenRequest) String() string

type DeleteTokenResponse

type DeleteTokenResponse struct {
	Ok     bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrMsg string `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteTokenResponse) Descriptor deprecated

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

Deprecated: Use DeleteTokenResponse.ProtoReflect.Descriptor instead.

func (*DeleteTokenResponse) GetErrMsg

func (x *DeleteTokenResponse) GetErrMsg() string

func (*DeleteTokenResponse) GetOk

func (x *DeleteTokenResponse) GetOk() bool

func (*DeleteTokenResponse) ProtoMessage

func (*DeleteTokenResponse) ProtoMessage()

func (*DeleteTokenResponse) ProtoReflect

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

func (*DeleteTokenResponse) Reset

func (x *DeleteTokenResponse) Reset()

func (*DeleteTokenResponse) String

func (x *DeleteTokenResponse) String() string

type DeleteVolumeRequest

type DeleteVolumeRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteVolumeRequest) Descriptor deprecated

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

Deprecated: Use DeleteVolumeRequest.ProtoReflect.Descriptor instead.

func (*DeleteVolumeRequest) GetName

func (x *DeleteVolumeRequest) GetName() string

func (*DeleteVolumeRequest) ProtoMessage

func (*DeleteVolumeRequest) ProtoMessage()

func (*DeleteVolumeRequest) ProtoReflect

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

func (*DeleteVolumeRequest) Reset

func (x *DeleteVolumeRequest) Reset()

func (*DeleteVolumeRequest) String

func (x *DeleteVolumeRequest) String() string

type DeleteVolumeResponse

type DeleteVolumeResponse struct {
	Ok     bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrMsg string `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteVolumeResponse) Descriptor deprecated

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

Deprecated: Use DeleteVolumeResponse.ProtoReflect.Descriptor instead.

func (*DeleteVolumeResponse) GetErrMsg

func (x *DeleteVolumeResponse) GetErrMsg() string

func (*DeleteVolumeResponse) GetOk

func (x *DeleteVolumeResponse) GetOk() bool

func (*DeleteVolumeResponse) ProtoMessage

func (*DeleteVolumeResponse) ProtoMessage()

func (*DeleteVolumeResponse) ProtoReflect

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

func (*DeleteVolumeResponse) Reset

func (x *DeleteVolumeResponse) Reset()

func (*DeleteVolumeResponse) String

func (x *DeleteVolumeResponse) String() string

type DeployStubRequest

type DeployStubRequest struct {
	StubId string `protobuf:"bytes,1,opt,name=stub_id,json=stubId,proto3" json:"stub_id,omitempty"`
	Name   string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeployStubRequest) Descriptor deprecated

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

Deprecated: Use DeployStubRequest.ProtoReflect.Descriptor instead.

func (*DeployStubRequest) GetName

func (x *DeployStubRequest) GetName() string

func (*DeployStubRequest) GetStubId

func (x *DeployStubRequest) GetStubId() string

func (*DeployStubRequest) ProtoMessage

func (*DeployStubRequest) ProtoMessage()

func (*DeployStubRequest) ProtoReflect

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

func (*DeployStubRequest) Reset

func (x *DeployStubRequest) Reset()

func (*DeployStubRequest) String

func (x *DeployStubRequest) String() string

type DeployStubResponse

type DeployStubResponse struct {
	Ok           bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	DeploymentId string `protobuf:"bytes,2,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"`
	Version      uint32 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	InvokeUrl    string `protobuf:"bytes,4,opt,name=invoke_url,json=invokeUrl,proto3" json:"invoke_url,omitempty"`
	// contains filtered or unexported fields
}

func (*DeployStubResponse) Descriptor deprecated

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

Deprecated: Use DeployStubResponse.ProtoReflect.Descriptor instead.

func (*DeployStubResponse) GetDeploymentId

func (x *DeployStubResponse) GetDeploymentId() string

func (*DeployStubResponse) GetInvokeUrl

func (x *DeployStubResponse) GetInvokeUrl() string

func (*DeployStubResponse) GetOk

func (x *DeployStubResponse) GetOk() bool

func (*DeployStubResponse) GetVersion

func (x *DeployStubResponse) GetVersion() uint32

func (*DeployStubResponse) ProtoMessage

func (*DeployStubResponse) ProtoMessage()

func (*DeployStubResponse) ProtoReflect

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

func (*DeployStubResponse) Reset

func (x *DeployStubResponse) Reset()

func (*DeployStubResponse) String

func (x *DeployStubResponse) String() string

type Deployment

type Deployment struct {
	Id            string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name          string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Active        bool                   `protobuf:"varint,3,opt,name=active,proto3" json:"active,omitempty"`
	StubId        string                 `protobuf:"bytes,4,opt,name=stub_id,json=stubId,proto3" json:"stub_id,omitempty"`
	StubType      string                 `protobuf:"bytes,5,opt,name=stub_type,json=stubType,proto3" json:"stub_type,omitempty"`
	StubName      string                 `protobuf:"bytes,6,opt,name=stub_name,json=stubName,proto3" json:"stub_name,omitempty"`
	Version       uint32                 `protobuf:"varint,7,opt,name=version,proto3" json:"version,omitempty"`
	WorkspaceId   string                 `protobuf:"bytes,8,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	WorkspaceName string                 `protobuf:"bytes,9,opt,name=workspace_name,json=workspaceName,proto3" json:"workspace_name,omitempty"`
	CreatedAt     *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt     *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Deployment) Descriptor deprecated

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

Deprecated: Use Deployment.ProtoReflect.Descriptor instead.

func (*Deployment) GetActive

func (x *Deployment) GetActive() bool

func (*Deployment) GetCreatedAt

func (x *Deployment) GetCreatedAt() *timestamppb.Timestamp

func (*Deployment) GetId

func (x *Deployment) GetId() string

func (*Deployment) GetName

func (x *Deployment) GetName() string

func (*Deployment) GetStubId

func (x *Deployment) GetStubId() string

func (*Deployment) GetStubName

func (x *Deployment) GetStubName() string

func (*Deployment) GetStubType

func (x *Deployment) GetStubType() string

func (*Deployment) GetUpdatedAt

func (x *Deployment) GetUpdatedAt() *timestamppb.Timestamp

func (*Deployment) GetVersion

func (x *Deployment) GetVersion() uint32

func (*Deployment) GetWorkspaceId

func (x *Deployment) GetWorkspaceId() string

func (*Deployment) GetWorkspaceName

func (x *Deployment) GetWorkspaceName() string

func (*Deployment) ProtoMessage

func (*Deployment) ProtoMessage()

func (*Deployment) ProtoReflect

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

func (*Deployment) Reset

func (x *Deployment) Reset()

func (*Deployment) String

func (x *Deployment) String() string

type DrainWorkerRequest

type DrainWorkerRequest struct {
	WorkerId string `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DrainWorkerRequest) Descriptor deprecated

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

Deprecated: Use DrainWorkerRequest.ProtoReflect.Descriptor instead.

func (*DrainWorkerRequest) GetWorkerId

func (x *DrainWorkerRequest) GetWorkerId() string

func (*DrainWorkerRequest) ProtoMessage

func (*DrainWorkerRequest) ProtoMessage()

func (*DrainWorkerRequest) ProtoReflect

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

func (*DrainWorkerRequest) Reset

func (x *DrainWorkerRequest) Reset()

func (*DrainWorkerRequest) String

func (x *DrainWorkerRequest) String() string

type DrainWorkerResponse

type DrainWorkerResponse struct {
	Ok     bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrMsg string `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	// contains filtered or unexported fields
}

func (*DrainWorkerResponse) Descriptor deprecated

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

Deprecated: Use DrainWorkerResponse.ProtoReflect.Descriptor instead.

func (*DrainWorkerResponse) GetErrMsg

func (x *DrainWorkerResponse) GetErrMsg() string

func (*DrainWorkerResponse) GetOk

func (x *DrainWorkerResponse) GetOk() bool

func (*DrainWorkerResponse) ProtoMessage

func (*DrainWorkerResponse) ProtoMessage()

func (*DrainWorkerResponse) ProtoReflect

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

func (*DrainWorkerResponse) Reset

func (x *DrainWorkerResponse) Reset()

func (*DrainWorkerResponse) String

func (x *DrainWorkerResponse) String() string

type EndTaskRequest

type EndTaskRequest struct {
	TaskId            string  `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	TaskDuration      float32 `protobuf:"fixed32,2,opt,name=task_duration,json=taskDuration,proto3" json:"task_duration,omitempty"`
	TaskStatus        string  `protobuf:"bytes,3,opt,name=task_status,json=taskStatus,proto3" json:"task_status,omitempty"`
	ContainerId       string  `protobuf:"bytes,4,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	ContainerHostname string  `protobuf:"bytes,5,opt,name=container_hostname,json=containerHostname,proto3" json:"container_hostname,omitempty"`
	KeepWarmSeconds   float32 `protobuf:"fixed32,6,opt,name=keep_warm_seconds,json=keepWarmSeconds,proto3" json:"keep_warm_seconds,omitempty"`
	// contains filtered or unexported fields
}

func (*EndTaskRequest) Descriptor deprecated

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

Deprecated: Use EndTaskRequest.ProtoReflect.Descriptor instead.

func (*EndTaskRequest) GetContainerHostname

func (x *EndTaskRequest) GetContainerHostname() string

func (*EndTaskRequest) GetContainerId

func (x *EndTaskRequest) GetContainerId() string

func (*EndTaskRequest) GetKeepWarmSeconds

func (x *EndTaskRequest) GetKeepWarmSeconds() float32

func (*EndTaskRequest) GetTaskDuration

func (x *EndTaskRequest) GetTaskDuration() float32

func (*EndTaskRequest) GetTaskId

func (x *EndTaskRequest) GetTaskId() string

func (*EndTaskRequest) GetTaskStatus

func (x *EndTaskRequest) GetTaskStatus() string

func (*EndTaskRequest) ProtoMessage

func (*EndTaskRequest) ProtoMessage()

func (*EndTaskRequest) ProtoReflect

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

func (*EndTaskRequest) Reset

func (x *EndTaskRequest) Reset()

func (*EndTaskRequest) String

func (x *EndTaskRequest) String() string

type EndTaskResponse

type EndTaskResponse struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*EndTaskResponse) Descriptor deprecated

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

Deprecated: Use EndTaskResponse.ProtoReflect.Descriptor instead.

func (*EndTaskResponse) GetOk

func (x *EndTaskResponse) GetOk() bool

func (*EndTaskResponse) ProtoMessage

func (*EndTaskResponse) ProtoMessage()

func (*EndTaskResponse) ProtoReflect

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

func (*EndTaskResponse) Reset

func (x *EndTaskResponse) Reset()

func (*EndTaskResponse) String

func (x *EndTaskResponse) String() string

type EndpointServeKeepAliveRequest

type EndpointServeKeepAliveRequest struct {
	StubId  string `protobuf:"bytes,1,opt,name=stub_id,json=stubId,proto3" json:"stub_id,omitempty"`
	Timeout int32  `protobuf:"varint,2,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*EndpointServeKeepAliveRequest) Descriptor deprecated

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

Deprecated: Use EndpointServeKeepAliveRequest.ProtoReflect.Descriptor instead.

func (*EndpointServeKeepAliveRequest) GetStubId

func (x *EndpointServeKeepAliveRequest) GetStubId() string

func (*EndpointServeKeepAliveRequest) GetTimeout

func (x *EndpointServeKeepAliveRequest) GetTimeout() int32

func (*EndpointServeKeepAliveRequest) ProtoMessage

func (*EndpointServeKeepAliveRequest) ProtoMessage()

func (*EndpointServeKeepAliveRequest) ProtoReflect

func (*EndpointServeKeepAliveRequest) Reset

func (x *EndpointServeKeepAliveRequest) Reset()

func (*EndpointServeKeepAliveRequest) String

type EndpointServeKeepAliveResponse

type EndpointServeKeepAliveResponse struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*EndpointServeKeepAliveResponse) Descriptor deprecated

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

Deprecated: Use EndpointServeKeepAliveResponse.ProtoReflect.Descriptor instead.

func (*EndpointServeKeepAliveResponse) GetOk

func (*EndpointServeKeepAliveResponse) ProtoMessage

func (*EndpointServeKeepAliveResponse) ProtoMessage()

func (*EndpointServeKeepAliveResponse) ProtoReflect

func (*EndpointServeKeepAliveResponse) Reset

func (x *EndpointServeKeepAliveResponse) Reset()

func (*EndpointServeKeepAliveResponse) String

type EndpointServiceClient

type EndpointServiceClient interface {
	StartEndpointServe(ctx context.Context, in *StartEndpointServeRequest, opts ...grpc.CallOption) (EndpointService_StartEndpointServeClient, error)
	StopEndpointServe(ctx context.Context, in *StopEndpointServeRequest, opts ...grpc.CallOption) (*StopEndpointServeResponse, error)
	EndpointServeKeepAlive(ctx context.Context, in *EndpointServeKeepAliveRequest, opts ...grpc.CallOption) (*EndpointServeKeepAliveResponse, error)
}

EndpointServiceClient is the client API for EndpointService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type EndpointServiceServer

type EndpointServiceServer interface {
	StartEndpointServe(*StartEndpointServeRequest, EndpointService_StartEndpointServeServer) error
	StopEndpointServe(context.Context, *StopEndpointServeRequest) (*StopEndpointServeResponse, error)
	EndpointServeKeepAlive(context.Context, *EndpointServeKeepAliveRequest) (*EndpointServeKeepAliveResponse, error)
	// contains filtered or unexported methods
}

EndpointServiceServer is the server API for EndpointService service. All implementations must embed UnimplementedEndpointServiceServer for forward compatibility

type EndpointService_StartEndpointServeClient

type EndpointService_StartEndpointServeClient interface {
	Recv() (*StartEndpointServeResponse, error)
	grpc.ClientStream
}

type EndpointService_StartEndpointServeServer

type EndpointService_StartEndpointServeServer interface {
	Send(*StartEndpointServeResponse) error
	grpc.ServerStream
}

type FunctionGetArgsRequest

type FunctionGetArgsRequest struct {
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// contains filtered or unexported fields
}

func (*FunctionGetArgsRequest) Descriptor deprecated

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

Deprecated: Use FunctionGetArgsRequest.ProtoReflect.Descriptor instead.

func (*FunctionGetArgsRequest) GetTaskId

func (x *FunctionGetArgsRequest) GetTaskId() string

func (*FunctionGetArgsRequest) ProtoMessage

func (*FunctionGetArgsRequest) ProtoMessage()

func (*FunctionGetArgsRequest) ProtoReflect

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

func (*FunctionGetArgsRequest) Reset

func (x *FunctionGetArgsRequest) Reset()

func (*FunctionGetArgsRequest) String

func (x *FunctionGetArgsRequest) String() string

type FunctionGetArgsResponse

type FunctionGetArgsResponse struct {
	Ok   bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Args []byte `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty"`
	// contains filtered or unexported fields
}

func (*FunctionGetArgsResponse) Descriptor deprecated

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

Deprecated: Use FunctionGetArgsResponse.ProtoReflect.Descriptor instead.

func (*FunctionGetArgsResponse) GetArgs

func (x *FunctionGetArgsResponse) GetArgs() []byte

func (*FunctionGetArgsResponse) GetOk

func (x *FunctionGetArgsResponse) GetOk() bool

func (*FunctionGetArgsResponse) ProtoMessage

func (*FunctionGetArgsResponse) ProtoMessage()

func (*FunctionGetArgsResponse) ProtoReflect

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

func (*FunctionGetArgsResponse) Reset

func (x *FunctionGetArgsResponse) Reset()

func (*FunctionGetArgsResponse) String

func (x *FunctionGetArgsResponse) String() string

type FunctionInvokeRequest

type FunctionInvokeRequest struct {
	StubId string `protobuf:"bytes,1,opt,name=stub_id,json=stubId,proto3" json:"stub_id,omitempty"`
	Args   []byte `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty"`
	// contains filtered or unexported fields
}

func (*FunctionInvokeRequest) Descriptor deprecated

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

Deprecated: Use FunctionInvokeRequest.ProtoReflect.Descriptor instead.

func (*FunctionInvokeRequest) GetArgs

func (x *FunctionInvokeRequest) GetArgs() []byte

func (*FunctionInvokeRequest) GetStubId

func (x *FunctionInvokeRequest) GetStubId() string

func (*FunctionInvokeRequest) ProtoMessage

func (*FunctionInvokeRequest) ProtoMessage()

func (*FunctionInvokeRequest) ProtoReflect

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

func (*FunctionInvokeRequest) Reset

func (x *FunctionInvokeRequest) Reset()

func (*FunctionInvokeRequest) String

func (x *FunctionInvokeRequest) String() string

type FunctionInvokeResponse

type FunctionInvokeResponse struct {
	TaskId   string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Output   string `protobuf:"bytes,2,opt,name=output,proto3" json:"output,omitempty"`
	Done     bool   `protobuf:"varint,3,opt,name=done,proto3" json:"done,omitempty"`
	ExitCode int32  `protobuf:"varint,4,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	Result   []byte `protobuf:"bytes,5,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*FunctionInvokeResponse) Descriptor deprecated

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

Deprecated: Use FunctionInvokeResponse.ProtoReflect.Descriptor instead.

func (*FunctionInvokeResponse) GetDone

func (x *FunctionInvokeResponse) GetDone() bool

func (*FunctionInvokeResponse) GetExitCode

func (x *FunctionInvokeResponse) GetExitCode() int32

func (*FunctionInvokeResponse) GetOutput

func (x *FunctionInvokeResponse) GetOutput() string

func (*FunctionInvokeResponse) GetResult

func (x *FunctionInvokeResponse) GetResult() []byte

func (*FunctionInvokeResponse) GetTaskId

func (x *FunctionInvokeResponse) GetTaskId() string

func (*FunctionInvokeResponse) ProtoMessage

func (*FunctionInvokeResponse) ProtoMessage()

func (*FunctionInvokeResponse) ProtoReflect

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

func (*FunctionInvokeResponse) Reset

func (x *FunctionInvokeResponse) Reset()

func (*FunctionInvokeResponse) String

func (x *FunctionInvokeResponse) String() string

type FunctionMonitorRequest

type FunctionMonitorRequest struct {
	TaskId      string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	StubId      string `protobuf:"bytes,2,opt,name=stub_id,json=stubId,proto3" json:"stub_id,omitempty"`
	ContainerId string `protobuf:"bytes,3,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// contains filtered or unexported fields
}

func (*FunctionMonitorRequest) Descriptor deprecated

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

Deprecated: Use FunctionMonitorRequest.ProtoReflect.Descriptor instead.

func (*FunctionMonitorRequest) GetContainerId

func (x *FunctionMonitorRequest) GetContainerId() string

func (*FunctionMonitorRequest) GetStubId

func (x *FunctionMonitorRequest) GetStubId() string

func (*FunctionMonitorRequest) GetTaskId

func (x *FunctionMonitorRequest) GetTaskId() string

func (*FunctionMonitorRequest) ProtoMessage

func (*FunctionMonitorRequest) ProtoMessage()

func (*FunctionMonitorRequest) ProtoReflect

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

func (*FunctionMonitorRequest) Reset

func (x *FunctionMonitorRequest) Reset()

func (*FunctionMonitorRequest) String

func (x *FunctionMonitorRequest) String() string

type FunctionMonitorResponse

type FunctionMonitorResponse struct {
	Ok        bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Cancelled bool `protobuf:"varint,2,opt,name=cancelled,proto3" json:"cancelled,omitempty"`
	Complete  bool `protobuf:"varint,3,opt,name=complete,proto3" json:"complete,omitempty"`
	TimedOut  bool `protobuf:"varint,4,opt,name=timed_out,json=timedOut,proto3" json:"timed_out,omitempty"`
	// contains filtered or unexported fields
}

func (*FunctionMonitorResponse) Descriptor deprecated

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

Deprecated: Use FunctionMonitorResponse.ProtoReflect.Descriptor instead.

func (*FunctionMonitorResponse) GetCancelled

func (x *FunctionMonitorResponse) GetCancelled() bool

func (*FunctionMonitorResponse) GetComplete

func (x *FunctionMonitorResponse) GetComplete() bool

func (*FunctionMonitorResponse) GetOk

func (x *FunctionMonitorResponse) GetOk() bool

func (*FunctionMonitorResponse) GetTimedOut

func (x *FunctionMonitorResponse) GetTimedOut() bool

func (*FunctionMonitorResponse) ProtoMessage

func (*FunctionMonitorResponse) ProtoMessage()

func (*FunctionMonitorResponse) ProtoReflect

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

func (*FunctionMonitorResponse) Reset

func (x *FunctionMonitorResponse) Reset()

func (*FunctionMonitorResponse) String

func (x *FunctionMonitorResponse) String() string

type FunctionScheduleRequest

type FunctionScheduleRequest struct {
	StubId       string `protobuf:"bytes,1,opt,name=stub_id,json=stubId,proto3" json:"stub_id,omitempty"`
	When         string `protobuf:"bytes,2,opt,name=when,proto3" json:"when,omitempty"`
	DeploymentId string `protobuf:"bytes,3,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"`
	// contains filtered or unexported fields
}

func (*FunctionScheduleRequest) Descriptor deprecated

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

Deprecated: Use FunctionScheduleRequest.ProtoReflect.Descriptor instead.

func (*FunctionScheduleRequest) GetDeploymentId

func (x *FunctionScheduleRequest) GetDeploymentId() string

func (*FunctionScheduleRequest) GetStubId

func (x *FunctionScheduleRequest) GetStubId() string

func (*FunctionScheduleRequest) GetWhen

func (x *FunctionScheduleRequest) GetWhen() string

func (*FunctionScheduleRequest) ProtoMessage

func (*FunctionScheduleRequest) ProtoMessage()

func (*FunctionScheduleRequest) ProtoReflect

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

func (*FunctionScheduleRequest) Reset

func (x *FunctionScheduleRequest) Reset()

func (*FunctionScheduleRequest) String

func (x *FunctionScheduleRequest) String() string

type FunctionScheduleResponse

type FunctionScheduleResponse struct {
	Ok             bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrMsg         string `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	ScheduledJobId string `protobuf:"bytes,3,opt,name=scheduled_job_id,json=scheduledJobId,proto3" json:"scheduled_job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*FunctionScheduleResponse) Descriptor deprecated

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

Deprecated: Use FunctionScheduleResponse.ProtoReflect.Descriptor instead.

func (*FunctionScheduleResponse) GetErrMsg

func (x *FunctionScheduleResponse) GetErrMsg() string

func (*FunctionScheduleResponse) GetOk

func (x *FunctionScheduleResponse) GetOk() bool

func (*FunctionScheduleResponse) GetScheduledJobId

func (x *FunctionScheduleResponse) GetScheduledJobId() string

func (*FunctionScheduleResponse) ProtoMessage

func (*FunctionScheduleResponse) ProtoMessage()

func (*FunctionScheduleResponse) ProtoReflect

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

func (*FunctionScheduleResponse) Reset

func (x *FunctionScheduleResponse) Reset()

func (*FunctionScheduleResponse) String

func (x *FunctionScheduleResponse) String() string

type FunctionServiceClient

FunctionServiceClient is the client API for FunctionService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type FunctionServiceServer

FunctionServiceServer is the server API for FunctionService service. All implementations must embed UnimplementedFunctionServiceServer for forward compatibility

type FunctionService_FunctionInvokeClient

type FunctionService_FunctionInvokeClient interface {
	Recv() (*FunctionInvokeResponse, error)
	grpc.ClientStream
}

type FunctionService_FunctionInvokeServer

type FunctionService_FunctionInvokeServer interface {
	Send(*FunctionInvokeResponse) error
	grpc.ServerStream
}

type FunctionService_FunctionMonitorClient

type FunctionService_FunctionMonitorClient interface {
	Recv() (*FunctionMonitorResponse, error)
	grpc.ClientStream
}

type FunctionService_FunctionMonitorServer

type FunctionService_FunctionMonitorServer interface {
	Send(*FunctionMonitorResponse) error
	grpc.ServerStream
}

type FunctionSetResultRequest

type FunctionSetResultRequest struct {
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Result []byte `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*FunctionSetResultRequest) Descriptor deprecated

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

Deprecated: Use FunctionSetResultRequest.ProtoReflect.Descriptor instead.

func (*FunctionSetResultRequest) GetResult

func (x *FunctionSetResultRequest) GetResult() []byte

func (*FunctionSetResultRequest) GetTaskId

func (x *FunctionSetResultRequest) GetTaskId() string

func (*FunctionSetResultRequest) ProtoMessage

func (*FunctionSetResultRequest) ProtoMessage()

func (*FunctionSetResultRequest) ProtoReflect

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

func (*FunctionSetResultRequest) Reset

func (x *FunctionSetResultRequest) Reset()

func (*FunctionSetResultRequest) String

func (x *FunctionSetResultRequest) String() string

type FunctionSetResultResponse

type FunctionSetResultResponse struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*FunctionSetResultResponse) Descriptor deprecated

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

Deprecated: Use FunctionSetResultResponse.ProtoReflect.Descriptor instead.

func (*FunctionSetResultResponse) GetOk

func (x *FunctionSetResultResponse) GetOk() bool

func (*FunctionSetResultResponse) ProtoMessage

func (*FunctionSetResultResponse) ProtoMessage()

func (*FunctionSetResultResponse) ProtoReflect

func (*FunctionSetResultResponse) Reset

func (x *FunctionSetResultResponse) Reset()

func (*FunctionSetResultResponse) String

func (x *FunctionSetResultResponse) String() string

type GatewayServiceClient

type GatewayServiceClient interface {
	// Auth
	Authorize(ctx context.Context, in *AuthorizeRequest, opts ...grpc.CallOption) (*AuthorizeResponse, error)
	SignPayload(ctx context.Context, in *SignPayloadRequest, opts ...grpc.CallOption) (*SignPayloadResponse, error)
	// Objects
	HeadObject(ctx context.Context, in *HeadObjectRequest, opts ...grpc.CallOption) (*HeadObjectResponse, error)
	PutObject(ctx context.Context, in *PutObjectRequest, opts ...grpc.CallOption) (*PutObjectResponse, error)
	PutObjectStream(ctx context.Context, opts ...grpc.CallOption) (GatewayService_PutObjectStreamClient, error)
	ReplaceObjectContent(ctx context.Context, in *ReplaceObjectContentRequest, opts ...grpc.CallOption) (*ReplaceObjectContentResponse, error)
	// Containers
	ListContainers(ctx context.Context, in *ListContainersRequest, opts ...grpc.CallOption) (*ListContainersResponse, error)
	StopContainer(ctx context.Context, in *StopContainerRequest, opts ...grpc.CallOption) (*StopContainerResponse, error)
	// Tasks
	StartTask(ctx context.Context, in *StartTaskRequest, opts ...grpc.CallOption) (*StartTaskResponse, error)
	EndTask(ctx context.Context, in *EndTaskRequest, opts ...grpc.CallOption) (*EndTaskResponse, error)
	StopTasks(ctx context.Context, in *StopTasksRequest, opts ...grpc.CallOption) (*StopTasksResponse, error)
	ListTasks(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error)
	// Stubs
	GetOrCreateStub(ctx context.Context, in *GetOrCreateStubRequest, opts ...grpc.CallOption) (*GetOrCreateStubResponse, error)
	DeployStub(ctx context.Context, in *DeployStubRequest, opts ...grpc.CallOption) (*DeployStubResponse, error)
	GetURL(ctx context.Context, in *GetURLRequest, opts ...grpc.CallOption) (*GetURLResponse, error)
	// Deployments
	ListDeployments(ctx context.Context, in *ListDeploymentsRequest, opts ...grpc.CallOption) (*ListDeploymentsResponse, error)
	StopDeployment(ctx context.Context, in *StopDeploymentRequest, opts ...grpc.CallOption) (*StopDeploymentResponse, error)
	DeleteDeployment(ctx context.Context, in *DeleteDeploymentRequest, opts ...grpc.CallOption) (*DeleteDeploymentResponse, error)
	// Pools
	ListPools(ctx context.Context, in *ListPoolsRequest, opts ...grpc.CallOption) (*ListPoolsResponse, error)
	// Machines
	ListMachines(ctx context.Context, in *ListMachinesRequest, opts ...grpc.CallOption) (*ListMachinesResponse, error)
	CreateMachine(ctx context.Context, in *CreateMachineRequest, opts ...grpc.CallOption) (*CreateMachineResponse, error)
	DeleteMachine(ctx context.Context, in *DeleteMachineRequest, opts ...grpc.CallOption) (*DeleteMachineResponse, error)
	// Tokens
	ListTokens(ctx context.Context, in *ListTokensRequest, opts ...grpc.CallOption) (*ListTokensResponse, error)
	CreateToken(ctx context.Context, in *CreateTokenRequest, opts ...grpc.CallOption) (*CreateTokenResponse, error)
	ToggleToken(ctx context.Context, in *ToggleTokenRequest, opts ...grpc.CallOption) (*ToggleTokenResponse, error)
	DeleteToken(ctx context.Context, in *DeleteTokenRequest, opts ...grpc.CallOption) (*DeleteTokenResponse, error)
	// Workers
	ListWorkers(ctx context.Context, in *ListWorkersRequest, opts ...grpc.CallOption) (*ListWorkersResponse, error)
	CordonWorker(ctx context.Context, in *CordonWorkerRequest, opts ...grpc.CallOption) (*CordonWorkerResponse, error)
	UncordonWorker(ctx context.Context, in *UncordonWorkerRequest, opts ...grpc.CallOption) (*UncordonWorkerResponse, error)
	DrainWorker(ctx context.Context, in *DrainWorkerRequest, opts ...grpc.CallOption) (*DrainWorkerResponse, error)
}

GatewayServiceClient is the client API for GatewayService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type GatewayServiceServer

type GatewayServiceServer interface {
	// Auth
	Authorize(context.Context, *AuthorizeRequest) (*AuthorizeResponse, error)
	SignPayload(context.Context, *SignPayloadRequest) (*SignPayloadResponse, error)
	// Objects
	HeadObject(context.Context, *HeadObjectRequest) (*HeadObjectResponse, error)
	PutObject(context.Context, *PutObjectRequest) (*PutObjectResponse, error)
	PutObjectStream(GatewayService_PutObjectStreamServer) error
	ReplaceObjectContent(context.Context, *ReplaceObjectContentRequest) (*ReplaceObjectContentResponse, error)
	// Containers
	ListContainers(context.Context, *ListContainersRequest) (*ListContainersResponse, error)
	StopContainer(context.Context, *StopContainerRequest) (*StopContainerResponse, error)
	// Tasks
	StartTask(context.Context, *StartTaskRequest) (*StartTaskResponse, error)
	EndTask(context.Context, *EndTaskRequest) (*EndTaskResponse, error)
	StopTasks(context.Context, *StopTasksRequest) (*StopTasksResponse, error)
	ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error)
	// Stubs
	GetOrCreateStub(context.Context, *GetOrCreateStubRequest) (*GetOrCreateStubResponse, error)
	DeployStub(context.Context, *DeployStubRequest) (*DeployStubResponse, error)
	GetURL(context.Context, *GetURLRequest) (*GetURLResponse, error)
	// Deployments
	ListDeployments(context.Context, *ListDeploymentsRequest) (*ListDeploymentsResponse, error)
	StopDeployment(context.Context, *StopDeploymentRequest) (*StopDeploymentResponse, error)
	DeleteDeployment(context.Context, *DeleteDeploymentRequest) (*DeleteDeploymentResponse, error)
	// Pools
	ListPools(context.Context, *ListPoolsRequest) (*ListPoolsResponse, error)
	// Machines
	ListMachines(context.Context, *ListMachinesRequest) (*ListMachinesResponse, error)
	CreateMachine(context.Context, *CreateMachineRequest) (*CreateMachineResponse, error)
	DeleteMachine(context.Context, *DeleteMachineRequest) (*DeleteMachineResponse, error)
	// Tokens
	ListTokens(context.Context, *ListTokensRequest) (*ListTokensResponse, error)
	CreateToken(context.Context, *CreateTokenRequest) (*CreateTokenResponse, error)
	ToggleToken(context.Context, *ToggleTokenRequest) (*ToggleTokenResponse, error)
	DeleteToken(context.Context, *DeleteTokenRequest) (*DeleteTokenResponse, error)
	// Workers
	ListWorkers(context.Context, *ListWorkersRequest) (*ListWorkersResponse, error)
	CordonWorker(context.Context, *CordonWorkerRequest) (*CordonWorkerResponse, error)
	UncordonWorker(context.Context, *UncordonWorkerRequest) (*UncordonWorkerResponse, error)
	DrainWorker(context.Context, *DrainWorkerRequest) (*DrainWorkerResponse, error)
	// contains filtered or unexported methods
}

GatewayServiceServer is the server API for GatewayService service. All implementations must embed UnimplementedGatewayServiceServer for forward compatibility

type GatewayService_PutObjectStreamClient

type GatewayService_PutObjectStreamClient interface {
	Send(*PutObjectRequest) error
	CloseAndRecv() (*PutObjectResponse, error)
	grpc.ClientStream
}

type GatewayService_PutObjectStreamServer

type GatewayService_PutObjectStreamServer interface {
	SendAndClose(*PutObjectResponse) error
	Recv() (*PutObjectRequest, error)
	grpc.ServerStream
}

type GetGPUAvailabilityRequest

type GetGPUAvailabilityRequest struct {
	// contains filtered or unexported fields
}

func (*GetGPUAvailabilityRequest) Descriptor deprecated

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

Deprecated: Use GetGPUAvailabilityRequest.ProtoReflect.Descriptor instead.

func (*GetGPUAvailabilityRequest) ProtoMessage

func (*GetGPUAvailabilityRequest) ProtoMessage()

func (*GetGPUAvailabilityRequest) ProtoReflect

func (*GetGPUAvailabilityRequest) Reset

func (x *GetGPUAvailabilityRequest) Reset()

func (*GetGPUAvailabilityRequest) String

func (x *GetGPUAvailabilityRequest) String() string

type GetGPUAvailabilityResponse

type GetGPUAvailabilityResponse struct {
	Ok        bool            `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrMsg    string          `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	Available map[string]bool `` /* 160-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetGPUAvailabilityResponse) Descriptor deprecated

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

Deprecated: Use GetGPUAvailabilityResponse.ProtoReflect.Descriptor instead.

func (*GetGPUAvailabilityResponse) GetAvailable

func (x *GetGPUAvailabilityResponse) GetAvailable() map[string]bool

func (*GetGPUAvailabilityResponse) GetErrMsg

func (x *GetGPUAvailabilityResponse) GetErrMsg() string

func (*GetGPUAvailabilityResponse) GetOk

func (x *GetGPUAvailabilityResponse) GetOk() bool

func (*GetGPUAvailabilityResponse) ProtoMessage

func (*GetGPUAvailabilityResponse) ProtoMessage()

func (*GetGPUAvailabilityResponse) ProtoReflect

func (*GetGPUAvailabilityResponse) Reset

func (x *GetGPUAvailabilityResponse) Reset()

func (*GetGPUAvailabilityResponse) String

func (x *GetGPUAvailabilityResponse) String() string

type GetOrCreateStubRequest

type GetOrCreateStubRequest struct {
	ObjectId           string       `protobuf:"bytes,1,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"`
	ImageId            string       `protobuf:"bytes,2,opt,name=image_id,json=imageId,proto3" json:"image_id,omitempty"`
	StubType           string       `protobuf:"bytes,3,opt,name=stub_type,json=stubType,proto3" json:"stub_type,omitempty"`
	Name               string       `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	PythonVersion      string       `protobuf:"bytes,5,opt,name=python_version,json=pythonVersion,proto3" json:"python_version,omitempty"`
	Cpu                int64        `protobuf:"varint,6,opt,name=cpu,proto3" json:"cpu,omitempty"`
	Memory             int64        `protobuf:"varint,7,opt,name=memory,proto3" json:"memory,omitempty"`
	Gpu                string       `protobuf:"bytes,8,opt,name=gpu,proto3" json:"gpu,omitempty"`
	Handler            string       `protobuf:"bytes,9,opt,name=handler,proto3" json:"handler,omitempty"`
	Retries            uint32       `protobuf:"varint,10,opt,name=retries,proto3" json:"retries,omitempty"`
	Timeout            int64        `protobuf:"varint,11,opt,name=timeout,proto3" json:"timeout,omitempty"`
	KeepWarmSeconds    float32      `protobuf:"fixed32,12,opt,name=keep_warm_seconds,json=keepWarmSeconds,proto3" json:"keep_warm_seconds,omitempty"`
	Workers            uint32       `protobuf:"varint,13,opt,name=workers,proto3" json:"workers,omitempty"`
	MaxPendingTasks    uint32       `protobuf:"varint,15,opt,name=max_pending_tasks,json=maxPendingTasks,proto3" json:"max_pending_tasks,omitempty"`
	Volumes            []*Volume    `protobuf:"bytes,16,rep,name=volumes,proto3" json:"volumes,omitempty"`
	ForceCreate        bool         `protobuf:"varint,17,opt,name=force_create,json=forceCreate,proto3" json:"force_create,omitempty"`
	OnStart            string       `protobuf:"bytes,18,opt,name=on_start,json=onStart,proto3" json:"on_start,omitempty"`
	CallbackUrl        string       `protobuf:"bytes,19,opt,name=callback_url,json=callbackUrl,proto3" json:"callback_url,omitempty"`
	Authorized         bool         `protobuf:"varint,20,opt,name=authorized,proto3" json:"authorized,omitempty"`
	Secrets            []*SecretVar `protobuf:"bytes,21,rep,name=secrets,proto3" json:"secrets,omitempty"`
	Autoscaler         *Autoscaler  `protobuf:"bytes,22,opt,name=autoscaler,proto3" json:"autoscaler,omitempty"`
	TaskPolicy         *TaskPolicy  `protobuf:"bytes,23,opt,name=task_policy,json=taskPolicy,proto3" json:"task_policy,omitempty"`
	ConcurrentRequests uint32       `protobuf:"varint,24,opt,name=concurrent_requests,json=concurrentRequests,proto3" json:"concurrent_requests,omitempty"`
	Extra              string       `protobuf:"bytes,25,opt,name=extra,proto3" json:"extra,omitempty"`
	// contains filtered or unexported fields
}

func (*GetOrCreateStubRequest) Descriptor deprecated

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

Deprecated: Use GetOrCreateStubRequest.ProtoReflect.Descriptor instead.

func (*GetOrCreateStubRequest) GetAuthorized

func (x *GetOrCreateStubRequest) GetAuthorized() bool

func (*GetOrCreateStubRequest) GetAutoscaler

func (x *GetOrCreateStubRequest) GetAutoscaler() *Autoscaler

func (*GetOrCreateStubRequest) GetCallbackUrl

func (x *GetOrCreateStubRequest) GetCallbackUrl() string

func (*GetOrCreateStubRequest) GetConcurrentRequests

func (x *GetOrCreateStubRequest) GetConcurrentRequests() uint32

func (*GetOrCreateStubRequest) GetCpu

func (x *GetOrCreateStubRequest) GetCpu() int64

func (*GetOrCreateStubRequest) GetExtra

func (x *GetOrCreateStubRequest) GetExtra() string

func (*GetOrCreateStubRequest) GetForceCreate

func (x *GetOrCreateStubRequest) GetForceCreate() bool

func (*GetOrCreateStubRequest) GetGpu

func (x *GetOrCreateStubRequest) GetGpu() string

func (*GetOrCreateStubRequest) GetHandler

func (x *GetOrCreateStubRequest) GetHandler() string

func (*GetOrCreateStubRequest) GetImageId

func (x *GetOrCreateStubRequest) GetImageId() string

func (*GetOrCreateStubRequest) GetKeepWarmSeconds

func (x *GetOrCreateStubRequest) GetKeepWarmSeconds() float32

func (*GetOrCreateStubRequest) GetMaxPendingTasks

func (x *GetOrCreateStubRequest) GetMaxPendingTasks() uint32

func (*GetOrCreateStubRequest) GetMemory

func (x *GetOrCreateStubRequest) GetMemory() int64

func (*GetOrCreateStubRequest) GetName

func (x *GetOrCreateStubRequest) GetName() string

func (*GetOrCreateStubRequest) GetObjectId

func (x *GetOrCreateStubRequest) GetObjectId() string

func (*GetOrCreateStubRequest) GetOnStart

func (x *GetOrCreateStubRequest) GetOnStart() string

func (*GetOrCreateStubRequest) GetPythonVersion

func (x *GetOrCreateStubRequest) GetPythonVersion() string

func (*GetOrCreateStubRequest) GetRetries

func (x *GetOrCreateStubRequest) GetRetries() uint32

func (*GetOrCreateStubRequest) GetSecrets

func (x *GetOrCreateStubRequest) GetSecrets() []*SecretVar

func (*GetOrCreateStubRequest) GetStubType

func (x *GetOrCreateStubRequest) GetStubType() string

func (*GetOrCreateStubRequest) GetTaskPolicy

func (x *GetOrCreateStubRequest) GetTaskPolicy() *TaskPolicy

func (*GetOrCreateStubRequest) GetTimeout

func (x *GetOrCreateStubRequest) GetTimeout() int64

func (*GetOrCreateStubRequest) GetVolumes

func (x *GetOrCreateStubRequest) GetVolumes() []*Volume

func (*GetOrCreateStubRequest) GetWorkers

func (x *GetOrCreateStubRequest) GetWorkers() uint32

func (*GetOrCreateStubRequest) ProtoMessage

func (*GetOrCreateStubRequest) ProtoMessage()

func (*GetOrCreateStubRequest) ProtoReflect

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

func (*GetOrCreateStubRequest) Reset

func (x *GetOrCreateStubRequest) Reset()

func (*GetOrCreateStubRequest) String

func (x *GetOrCreateStubRequest) String() string

type GetOrCreateStubResponse

type GetOrCreateStubResponse struct {
	Ok      bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	StubId  string `protobuf:"bytes,2,opt,name=stub_id,json=stubId,proto3" json:"stub_id,omitempty"`
	ErrMsg  string `protobuf:"bytes,3,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	WarnMsg string `protobuf:"bytes,4,opt,name=warn_msg,json=warnMsg,proto3" json:"warn_msg,omitempty"`
	// contains filtered or unexported fields
}

func (*GetOrCreateStubResponse) Descriptor deprecated

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

Deprecated: Use GetOrCreateStubResponse.ProtoReflect.Descriptor instead.

func (*GetOrCreateStubResponse) GetErrMsg

func (x *GetOrCreateStubResponse) GetErrMsg() string

func (*GetOrCreateStubResponse) GetOk

func (x *GetOrCreateStubResponse) GetOk() bool

func (*GetOrCreateStubResponse) GetStubId

func (x *GetOrCreateStubResponse) GetStubId() string

func (*GetOrCreateStubResponse) GetWarnMsg

func (x *GetOrCreateStubResponse) GetWarnMsg() string

func (*GetOrCreateStubResponse) ProtoMessage

func (*GetOrCreateStubResponse) ProtoMessage()

func (*GetOrCreateStubResponse) ProtoReflect

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

func (*GetOrCreateStubResponse) Reset

func (x *GetOrCreateStubResponse) Reset()

func (*GetOrCreateStubResponse) String

func (x *GetOrCreateStubResponse) String() string

type GetOrCreateVolumeRequest

type GetOrCreateVolumeRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetOrCreateVolumeRequest) Descriptor deprecated

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

Deprecated: Use GetOrCreateVolumeRequest.ProtoReflect.Descriptor instead.

func (*GetOrCreateVolumeRequest) GetName

func (x *GetOrCreateVolumeRequest) GetName() string

func (*GetOrCreateVolumeRequest) ProtoMessage

func (*GetOrCreateVolumeRequest) ProtoMessage()

func (*GetOrCreateVolumeRequest) ProtoReflect

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

func (*GetOrCreateVolumeRequest) Reset

func (x *GetOrCreateVolumeRequest) Reset()

func (*GetOrCreateVolumeRequest) String

func (x *GetOrCreateVolumeRequest) String() string

type GetOrCreateVolumeResponse

type GetOrCreateVolumeResponse struct {
	Ok     bool            `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrMsg string          `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	Volume *VolumeInstance `protobuf:"bytes,3,opt,name=volume,proto3" json:"volume,omitempty"`
	// contains filtered or unexported fields
}

func (*GetOrCreateVolumeResponse) Descriptor deprecated

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

Deprecated: Use GetOrCreateVolumeResponse.ProtoReflect.Descriptor instead.

func (*GetOrCreateVolumeResponse) GetErrMsg

func (x *GetOrCreateVolumeResponse) GetErrMsg() string

func (*GetOrCreateVolumeResponse) GetOk

func (x *GetOrCreateVolumeResponse) GetOk() bool

func (*GetOrCreateVolumeResponse) GetVolume

func (x *GetOrCreateVolumeResponse) GetVolume() *VolumeInstance

func (*GetOrCreateVolumeResponse) ProtoMessage

func (*GetOrCreateVolumeResponse) ProtoMessage()

func (*GetOrCreateVolumeResponse) ProtoReflect

func (*GetOrCreateVolumeResponse) Reset

func (x *GetOrCreateVolumeResponse) Reset()

func (*GetOrCreateVolumeResponse) String

func (x *GetOrCreateVolumeResponse) String() string

type GetSecretRequest

type GetSecretRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSecretRequest) Descriptor deprecated

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

Deprecated: Use GetSecretRequest.ProtoReflect.Descriptor instead.

func (*GetSecretRequest) GetName

func (x *GetSecretRequest) GetName() string

func (*GetSecretRequest) ProtoMessage

func (*GetSecretRequest) ProtoMessage()

func (*GetSecretRequest) ProtoReflect

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

func (*GetSecretRequest) Reset

func (x *GetSecretRequest) Reset()

func (*GetSecretRequest) String

func (x *GetSecretRequest) String() string

type GetSecretResponse

type GetSecretResponse struct {
	Ok     bool    `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrMsg string  `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	Secret *Secret `protobuf:"bytes,3,opt,name=secret,proto3" json:"secret,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSecretResponse) Descriptor deprecated

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

Deprecated: Use GetSecretResponse.ProtoReflect.Descriptor instead.

func (*GetSecretResponse) GetErrMsg

func (x *GetSecretResponse) GetErrMsg() string

func (*GetSecretResponse) GetOk

func (x *GetSecretResponse) GetOk() bool

func (*GetSecretResponse) GetSecret

func (x *GetSecretResponse) GetSecret() *Secret

func (*GetSecretResponse) ProtoMessage

func (*GetSecretResponse) ProtoMessage()

func (*GetSecretResponse) ProtoReflect

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

func (*GetSecretResponse) Reset

func (x *GetSecretResponse) Reset()

func (*GetSecretResponse) String

func (x *GetSecretResponse) String() string

type GetURLRequest

type GetURLRequest struct {
	StubId       string `protobuf:"bytes,1,opt,name=stub_id,json=stubId,proto3" json:"stub_id,omitempty"`
	DeploymentId string `protobuf:"bytes,2,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"`
	UrlType      string `protobuf:"bytes,3,opt,name=url_type,json=urlType,proto3" json:"url_type,omitempty"`
	// contains filtered or unexported fields
}

func (*GetURLRequest) Descriptor deprecated

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

Deprecated: Use GetURLRequest.ProtoReflect.Descriptor instead.

func (*GetURLRequest) GetDeploymentId

func (x *GetURLRequest) GetDeploymentId() string

func (*GetURLRequest) GetStubId

func (x *GetURLRequest) GetStubId() string

func (*GetURLRequest) GetUrlType

func (x *GetURLRequest) GetUrlType() string

func (*GetURLRequest) ProtoMessage

func (*GetURLRequest) ProtoMessage()

func (*GetURLRequest) ProtoReflect

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

func (*GetURLRequest) Reset

func (x *GetURLRequest) Reset()

func (*GetURLRequest) String

func (x *GetURLRequest) String() string

type GetURLResponse

type GetURLResponse struct {
	Ok     bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrMsg string `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	Url    string `protobuf:"bytes,3,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

func (*GetURLResponse) Descriptor deprecated

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

Deprecated: Use GetURLResponse.ProtoReflect.Descriptor instead.

func (*GetURLResponse) GetErrMsg

func (x *GetURLResponse) GetErrMsg() string

func (*GetURLResponse) GetOk

func (x *GetURLResponse) GetOk() bool

func (*GetURLResponse) GetUrl

func (x *GetURLResponse) GetUrl() string

func (*GetURLResponse) ProtoMessage

func (*GetURLResponse) ProtoMessage()

func (*GetURLResponse) ProtoReflect

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

func (*GetURLResponse) Reset

func (x *GetURLResponse) Reset()

func (*GetURLResponse) String

func (x *GetURLResponse) String() string

type HeadObjectRequest

type HeadObjectRequest struct {
	Hash string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	// contains filtered or unexported fields
}

func (*HeadObjectRequest) Descriptor deprecated

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

Deprecated: Use HeadObjectRequest.ProtoReflect.Descriptor instead.

func (*HeadObjectRequest) GetHash

func (x *HeadObjectRequest) GetHash() string

func (*HeadObjectRequest) ProtoMessage

func (*HeadObjectRequest) ProtoMessage()

func (*HeadObjectRequest) ProtoReflect

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

func (*HeadObjectRequest) Reset

func (x *HeadObjectRequest) Reset()

func (*HeadObjectRequest) String

func (x *HeadObjectRequest) String() string

type HeadObjectResponse

type HeadObjectResponse struct {
	Ok             bool            `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Exists         bool            `protobuf:"varint,2,opt,name=exists,proto3" json:"exists,omitempty"`
	ObjectId       string          `protobuf:"bytes,3,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"`
	ObjectMetadata *ObjectMetadata `protobuf:"bytes,4,opt,name=object_metadata,json=objectMetadata,proto3" json:"object_metadata,omitempty"`
	ErrorMsg       string          `protobuf:"bytes,5,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
	// contains filtered or unexported fields
}

func (*HeadObjectResponse) Descriptor deprecated

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

Deprecated: Use HeadObjectResponse.ProtoReflect.Descriptor instead.

func (*HeadObjectResponse) GetErrorMsg

func (x *HeadObjectResponse) GetErrorMsg() string

func (*HeadObjectResponse) GetExists

func (x *HeadObjectResponse) GetExists() bool

func (*HeadObjectResponse) GetObjectId

func (x *HeadObjectResponse) GetObjectId() string

func (*HeadObjectResponse) GetObjectMetadata

func (x *HeadObjectResponse) GetObjectMetadata() *ObjectMetadata

func (*HeadObjectResponse) GetOk

func (x *HeadObjectResponse) GetOk() bool

func (*HeadObjectResponse) ProtoMessage

func (*HeadObjectResponse) ProtoMessage()

func (*HeadObjectResponse) ProtoReflect

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

func (*HeadObjectResponse) Reset

func (x *HeadObjectResponse) Reset()

func (*HeadObjectResponse) String

func (x *HeadObjectResponse) String() string

type ImageServiceClient

type ImageServiceClient interface {
	VerifyImageBuild(ctx context.Context, in *VerifyImageBuildRequest, opts ...grpc.CallOption) (*VerifyImageBuildResponse, error)
	BuildImage(ctx context.Context, in *BuildImageRequest, opts ...grpc.CallOption) (ImageService_BuildImageClient, error)
}

ImageServiceClient is the client API for ImageService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type ImageServiceServer

type ImageServiceServer interface {
	VerifyImageBuild(context.Context, *VerifyImageBuildRequest) (*VerifyImageBuildResponse, error)
	BuildImage(*BuildImageRequest, ImageService_BuildImageServer) error
	// contains filtered or unexported methods
}

ImageServiceServer is the server API for ImageService service. All implementations must embed UnimplementedImageServiceServer for forward compatibility

type ImageService_BuildImageClient

type ImageService_BuildImageClient interface {
	Recv() (*BuildImageResponse, error)
	grpc.ClientStream
}

type ImageService_BuildImageServer

type ImageService_BuildImageServer interface {
	Send(*BuildImageResponse) error
	grpc.ServerStream
}

type ListContainersRequest

type ListContainersRequest struct {
	// contains filtered or unexported fields
}

func (*ListContainersRequest) Descriptor deprecated

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

Deprecated: Use ListContainersRequest.ProtoReflect.Descriptor instead.

func (*ListContainersRequest) ProtoMessage

func (*ListContainersRequest) ProtoMessage()

func (*ListContainersRequest) ProtoReflect

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

func (*ListContainersRequest) Reset

func (x *ListContainersRequest) Reset()

func (*ListContainersRequest) String

func (x *ListContainersRequest) String() string

type ListContainersResponse

type ListContainersResponse struct {
	Containers []*Container `protobuf:"bytes,1,rep,name=containers,proto3" json:"containers,omitempty"`
	Ok         bool         `protobuf:"varint,2,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrorMsg   string       `protobuf:"bytes,3,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
	// contains filtered or unexported fields
}

func (*ListContainersResponse) Descriptor deprecated

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

Deprecated: Use ListContainersResponse.ProtoReflect.Descriptor instead.

func (*ListContainersResponse) GetContainers

func (x *ListContainersResponse) GetContainers() []*Container

func (*ListContainersResponse) GetErrorMsg

func (x *ListContainersResponse) GetErrorMsg() string

func (*ListContainersResponse) GetOk

func (x *ListContainersResponse) GetOk() bool

func (*ListContainersResponse) ProtoMessage

func (*ListContainersResponse) ProtoMessage()

func (*ListContainersResponse) ProtoReflect

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

func (*ListContainersResponse) Reset

func (x *ListContainersResponse) Reset()

func (*ListContainersResponse) String

func (x *ListContainersResponse) String() string

type ListDeploymentsRequest

type ListDeploymentsRequest struct {
	Filters map[string]*StringList `` /* 155-byte string literal not displayed */
	Limit   uint32                 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*ListDeploymentsRequest) Descriptor deprecated

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

Deprecated: Use ListDeploymentsRequest.ProtoReflect.Descriptor instead.

func (*ListDeploymentsRequest) GetFilters

func (x *ListDeploymentsRequest) GetFilters() map[string]*StringList

func (*ListDeploymentsRequest) GetLimit

func (x *ListDeploymentsRequest) GetLimit() uint32

func (*ListDeploymentsRequest) ProtoMessage

func (*ListDeploymentsRequest) ProtoMessage()

func (*ListDeploymentsRequest) ProtoReflect

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

func (*ListDeploymentsRequest) Reset

func (x *ListDeploymentsRequest) Reset()

func (*ListDeploymentsRequest) String

func (x *ListDeploymentsRequest) String() string

type ListDeploymentsResponse

type ListDeploymentsResponse struct {
	Ok          bool          `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrMsg      string        `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	Deployments []*Deployment `protobuf:"bytes,3,rep,name=deployments,proto3" json:"deployments,omitempty"`
	// contains filtered or unexported fields
}

func (*ListDeploymentsResponse) Descriptor deprecated

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

Deprecated: Use ListDeploymentsResponse.ProtoReflect.Descriptor instead.

func (*ListDeploymentsResponse) GetDeployments

func (x *ListDeploymentsResponse) GetDeployments() []*Deployment

func (*ListDeploymentsResponse) GetErrMsg

func (x *ListDeploymentsResponse) GetErrMsg() string

func (*ListDeploymentsResponse) GetOk

func (x *ListDeploymentsResponse) GetOk() bool

func (*ListDeploymentsResponse) ProtoMessage

func (*ListDeploymentsResponse) ProtoMessage()

func (*ListDeploymentsResponse) ProtoReflect

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

func (*ListDeploymentsResponse) Reset

func (x *ListDeploymentsResponse) Reset()

func (*ListDeploymentsResponse) String

func (x *ListDeploymentsResponse) String() string

type ListMachinesRequest

type ListMachinesRequest struct {
	PoolName string `protobuf:"bytes,1,opt,name=pool_name,json=poolName,proto3" json:"pool_name,omitempty"`
	Limit    uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*ListMachinesRequest) Descriptor deprecated

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

Deprecated: Use ListMachinesRequest.ProtoReflect.Descriptor instead.

func (*ListMachinesRequest) GetLimit

func (x *ListMachinesRequest) GetLimit() uint32

func (*ListMachinesRequest) GetPoolName

func (x *ListMachinesRequest) GetPoolName() string

func (*ListMachinesRequest) ProtoMessage

func (*ListMachinesRequest) ProtoMessage()

func (*ListMachinesRequest) ProtoReflect

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

func (*ListMachinesRequest) Reset

func (x *ListMachinesRequest) Reset()

func (*ListMachinesRequest) String

func (x *ListMachinesRequest) String() string

type ListMachinesResponse

type ListMachinesResponse struct {
	Ok       bool            `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrMsg   string          `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	Machines []*Machine      `protobuf:"bytes,3,rep,name=machines,proto3" json:"machines,omitempty"`
	Gpus     map[string]bool `` /* 150-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListMachinesResponse) Descriptor deprecated

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

Deprecated: Use ListMachinesResponse.ProtoReflect.Descriptor instead.

func (*ListMachinesResponse) GetErrMsg

func (x *ListMachinesResponse) GetErrMsg() string

func (*ListMachinesResponse) GetGpus

func (x *ListMachinesResponse) GetGpus() map[string]bool

func (*ListMachinesResponse) GetMachines

func (x *ListMachinesResponse) GetMachines() []*Machine

func (*ListMachinesResponse) GetOk

func (x *ListMachinesResponse) GetOk() bool

func (*ListMachinesResponse) ProtoMessage

func (*ListMachinesResponse) ProtoMessage()

func (*ListMachinesResponse) ProtoReflect

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

func (*ListMachinesResponse) Reset

func (x *ListMachinesResponse) Reset()

func (*ListMachinesResponse) String

func (x *ListMachinesResponse) String() string

type ListPathRequest

type ListPathRequest struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*ListPathRequest) Descriptor deprecated

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

Deprecated: Use ListPathRequest.ProtoReflect.Descriptor instead.

func (*ListPathRequest) GetPath

func (x *ListPathRequest) GetPath() string

func (*ListPathRequest) ProtoMessage

func (*ListPathRequest) ProtoMessage()

func (*ListPathRequest) ProtoReflect

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

func (*ListPathRequest) Reset

func (x *ListPathRequest) Reset()

func (*ListPathRequest) String

func (x *ListPathRequest) String() string

type ListPathResponse

type ListPathResponse struct {
	Ok        bool        `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrMsg    string      `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	PathInfos []*PathInfo `protobuf:"bytes,3,rep,name=path_infos,json=pathInfos,proto3" json:"path_infos,omitempty"`
	// contains filtered or unexported fields
}

func (*ListPathResponse) Descriptor deprecated

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

Deprecated: Use ListPathResponse.ProtoReflect.Descriptor instead.

func (*ListPathResponse) GetErrMsg

func (x *ListPathResponse) GetErrMsg() string

func (*ListPathResponse) GetOk

func (x *ListPathResponse) GetOk() bool

func (*ListPathResponse) GetPathInfos

func (x *ListPathResponse) GetPathInfos() []*PathInfo

func (*ListPathResponse) ProtoMessage

func (*ListPathResponse) ProtoMessage()

func (*ListPathResponse) ProtoReflect

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

func (*ListPathResponse) Reset

func (x *ListPathResponse) Reset()

func (*ListPathResponse) String

func (x *ListPathResponse) String() string

type ListPoolsRequest

type ListPoolsRequest struct {
	Filters map[string]*StringList `` /* 155-byte string literal not displayed */
	Limit   uint32                 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*ListPoolsRequest) Descriptor deprecated

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

Deprecated: Use ListPoolsRequest.ProtoReflect.Descriptor instead.

func (*ListPoolsRequest) GetFilters

func (x *ListPoolsRequest) GetFilters() map[string]*StringList

func (*ListPoolsRequest) GetLimit

func (x *ListPoolsRequest) GetLimit() uint32

func (*ListPoolsRequest) ProtoMessage

func (*ListPoolsRequest) ProtoMessage()

func (*ListPoolsRequest) ProtoReflect

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

func (*ListPoolsRequest) Reset

func (x *ListPoolsRequest) Reset()

func (*ListPoolsRequest) String

func (x *ListPoolsRequest) String() string

type ListPoolsResponse

type ListPoolsResponse struct {
	Ok     bool    `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrMsg string  `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	Pools  []*Pool `protobuf:"bytes,3,rep,name=pools,proto3" json:"pools,omitempty"`
	// contains filtered or unexported fields
}

func (*ListPoolsResponse) Descriptor deprecated

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

Deprecated: Use ListPoolsResponse.ProtoReflect.Descriptor instead.

func (*ListPoolsResponse) GetErrMsg

func (x *ListPoolsResponse) GetErrMsg() string

func (*ListPoolsResponse) GetOk

func (x *ListPoolsResponse) GetOk() bool

func (*ListPoolsResponse) GetPools

func (x *ListPoolsResponse) GetPools() []*Pool

func (*ListPoolsResponse) ProtoMessage

func (*ListPoolsResponse) ProtoMessage()

func (*ListPoolsResponse) ProtoReflect

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

func (*ListPoolsResponse) Reset

func (x *ListPoolsResponse) Reset()

func (*ListPoolsResponse) String

func (x *ListPoolsResponse) String() string

type ListSecretsRequest

type ListSecretsRequest struct {
	// contains filtered or unexported fields
}

func (*ListSecretsRequest) Descriptor deprecated

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

Deprecated: Use ListSecretsRequest.ProtoReflect.Descriptor instead.

func (*ListSecretsRequest) ProtoMessage

func (*ListSecretsRequest) ProtoMessage()

func (*ListSecretsRequest) ProtoReflect

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

func (*ListSecretsRequest) Reset

func (x *ListSecretsRequest) Reset()

func (*ListSecretsRequest) String

func (x *ListSecretsRequest) String() string

type ListSecretsResponse

type ListSecretsResponse struct {
	Ok      bool      `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrMsg  string    `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	Secrets []*Secret `protobuf:"bytes,3,rep,name=secrets,proto3" json:"secrets,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSecretsResponse) Descriptor deprecated

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

Deprecated: Use ListSecretsResponse.ProtoReflect.Descriptor instead.

func (*ListSecretsResponse) GetErrMsg

func (x *ListSecretsResponse) GetErrMsg() string

func (*ListSecretsResponse) GetOk

func (x *ListSecretsResponse) GetOk() bool

func (*ListSecretsResponse) GetSecrets

func (x *ListSecretsResponse) GetSecrets() []*Secret

func (*ListSecretsResponse) ProtoMessage

func (*ListSecretsResponse) ProtoMessage()

func (*ListSecretsResponse) ProtoReflect

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

func (*ListSecretsResponse) Reset

func (x *ListSecretsResponse) Reset()

func (*ListSecretsResponse) String

func (x *ListSecretsResponse) String() string

type ListTasksRequest

type ListTasksRequest struct {
	Filters map[string]*StringList `` /* 155-byte string literal not displayed */
	Limit   uint32                 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTasksRequest) Descriptor deprecated

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

Deprecated: Use ListTasksRequest.ProtoReflect.Descriptor instead.

func (*ListTasksRequest) GetFilters

func (x *ListTasksRequest) GetFilters() map[string]*StringList

func (*ListTasksRequest) GetLimit

func (x *ListTasksRequest) GetLimit() uint32

func (*ListTasksRequest) ProtoMessage

func (*ListTasksRequest) ProtoMessage()

func (*ListTasksRequest) ProtoReflect

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

func (*ListTasksRequest) Reset

func (x *ListTasksRequest) Reset()

func (*ListTasksRequest) String

func (x *ListTasksRequest) String() string

type ListTasksResponse

type ListTasksResponse struct {
	Ok     bool    `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrMsg string  `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	Tasks  []*Task `protobuf:"bytes,3,rep,name=tasks,proto3" json:"tasks,omitempty"`
	Total  int32   `protobuf:"varint,4,opt,name=total,proto3" json:"total,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTasksResponse) Descriptor deprecated

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

Deprecated: Use ListTasksResponse.ProtoReflect.Descriptor instead.

func (*ListTasksResponse) GetErrMsg

func (x *ListTasksResponse) GetErrMsg() string

func (*ListTasksResponse) GetOk

func (x *ListTasksResponse) GetOk() bool

func (*ListTasksResponse) GetTasks

func (x *ListTasksResponse) GetTasks() []*Task

func (*ListTasksResponse) GetTotal

func (x *ListTasksResponse) GetTotal() int32

func (*ListTasksResponse) ProtoMessage

func (*ListTasksResponse) ProtoMessage()

func (*ListTasksResponse) ProtoReflect

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

func (*ListTasksResponse) Reset

func (x *ListTasksResponse) Reset()

func (*ListTasksResponse) String

func (x *ListTasksResponse) String() string

type ListTokensRequest

type ListTokensRequest struct {
	// contains filtered or unexported fields
}

func (*ListTokensRequest) Descriptor deprecated

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

Deprecated: Use ListTokensRequest.ProtoReflect.Descriptor instead.

func (*ListTokensRequest) ProtoMessage

func (*ListTokensRequest) ProtoMessage()

func (*ListTokensRequest) ProtoReflect

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

func (*ListTokensRequest) Reset

func (x *ListTokensRequest) Reset()

func (*ListTokensRequest) String

func (x *ListTokensRequest) String() string

type ListTokensResponse

type ListTokensResponse struct {
	Ok     bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrMsg string   `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	Tokens []*Token `protobuf:"bytes,3,rep,name=tokens,proto3" json:"tokens,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTokensResponse) Descriptor deprecated

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

Deprecated: Use ListTokensResponse.ProtoReflect.Descriptor instead.

func (*ListTokensResponse) GetErrMsg

func (x *ListTokensResponse) GetErrMsg() string

func (*ListTokensResponse) GetOk

func (x *ListTokensResponse) GetOk() bool

func (*ListTokensResponse) GetTokens

func (x *ListTokensResponse) GetTokens() []*Token

func (*ListTokensResponse) ProtoMessage

func (*ListTokensResponse) ProtoMessage()

func (*ListTokensResponse) ProtoReflect

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

func (*ListTokensResponse) Reset

func (x *ListTokensResponse) Reset()

func (*ListTokensResponse) String

func (x *ListTokensResponse) String() string

type ListVolumesRequest

type ListVolumesRequest struct {
	// contains filtered or unexported fields
}

func (*ListVolumesRequest) Descriptor deprecated

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

Deprecated: Use ListVolumesRequest.ProtoReflect.Descriptor instead.

func (*ListVolumesRequest) ProtoMessage

func (*ListVolumesRequest) ProtoMessage()

func (*ListVolumesRequest) ProtoReflect

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

func (*ListVolumesRequest) Reset

func (x *ListVolumesRequest) Reset()

func (*ListVolumesRequest) String

func (x *ListVolumesRequest) String() string

type ListVolumesResponse

type ListVolumesResponse struct {
	Ok      bool              `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrMsg  string            `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	Volumes []*VolumeInstance `protobuf:"bytes,3,rep,name=volumes,proto3" json:"volumes,omitempty"`
	// contains filtered or unexported fields
}

func (*ListVolumesResponse) Descriptor deprecated

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

Deprecated: Use ListVolumesResponse.ProtoReflect.Descriptor instead.

func (*ListVolumesResponse) GetErrMsg

func (x *ListVolumesResponse) GetErrMsg() string

func (*ListVolumesResponse) GetOk

func (x *ListVolumesResponse) GetOk() bool

func (*ListVolumesResponse) GetVolumes

func (x *ListVolumesResponse) GetVolumes() []*VolumeInstance

func (*ListVolumesResponse) ProtoMessage

func (*ListVolumesResponse) ProtoMessage()

func (*ListVolumesResponse) ProtoReflect

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

func (*ListVolumesResponse) Reset

func (x *ListVolumesResponse) Reset()

func (*ListVolumesResponse) String

func (x *ListVolumesResponse) String() string

type ListWorkersRequest

type ListWorkersRequest struct {
	// contains filtered or unexported fields
}

func (*ListWorkersRequest) Descriptor deprecated

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

Deprecated: Use ListWorkersRequest.ProtoReflect.Descriptor instead.

func (*ListWorkersRequest) ProtoMessage

func (*ListWorkersRequest) ProtoMessage()

func (*ListWorkersRequest) ProtoReflect

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

func (*ListWorkersRequest) Reset

func (x *ListWorkersRequest) Reset()

func (*ListWorkersRequest) String

func (x *ListWorkersRequest) String() string

type ListWorkersResponse

type ListWorkersResponse struct {
	Ok      bool      `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrMsg  string    `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	Workers []*Worker `protobuf:"bytes,3,rep,name=workers,proto3" json:"workers,omitempty"`
	// contains filtered or unexported fields
}

func (*ListWorkersResponse) Descriptor deprecated

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

Deprecated: Use ListWorkersResponse.ProtoReflect.Descriptor instead.

func (*ListWorkersResponse) GetErrMsg

func (x *ListWorkersResponse) GetErrMsg() string

func (*ListWorkersResponse) GetOk

func (x *ListWorkersResponse) GetOk() bool

func (*ListWorkersResponse) GetWorkers

func (x *ListWorkersResponse) GetWorkers() []*Worker

func (*ListWorkersResponse) ProtoMessage

func (*ListWorkersResponse) ProtoMessage()

func (*ListWorkersResponse) ProtoReflect

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

func (*ListWorkersResponse) Reset

func (x *ListWorkersResponse) Reset()

func (*ListWorkersResponse) String

func (x *ListWorkersResponse) String() string

type Machine

type Machine struct {
	Id                string          `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Cpu               int64           `protobuf:"varint,2,opt,name=cpu,proto3" json:"cpu,omitempty"`
	Memory            int64           `protobuf:"varint,3,opt,name=memory,proto3" json:"memory,omitempty"`
	Gpu               string          `protobuf:"bytes,4,opt,name=gpu,proto3" json:"gpu,omitempty"`
	GpuCount          uint32          `protobuf:"varint,5,opt,name=gpu_count,json=gpuCount,proto3" json:"gpu_count,omitempty"`
	Status            string          `protobuf:"bytes,6,opt,name=status,proto3" json:"status,omitempty"`
	PoolName          string          `protobuf:"bytes,7,opt,name=pool_name,json=poolName,proto3" json:"pool_name,omitempty"`
	ProviderName      string          `protobuf:"bytes,8,opt,name=provider_name,json=providerName,proto3" json:"provider_name,omitempty"`
	RegistrationToken string          `protobuf:"bytes,9,opt,name=registration_token,json=registrationToken,proto3" json:"registration_token,omitempty"`
	TailscaleUrl      string          `protobuf:"bytes,10,opt,name=tailscale_url,json=tailscaleUrl,proto3" json:"tailscale_url,omitempty"`
	TailscaleAuth     string          `protobuf:"bytes,11,opt,name=tailscale_auth,json=tailscaleAuth,proto3" json:"tailscale_auth,omitempty"`
	LastKeepalive     string          `protobuf:"bytes,12,opt,name=last_keepalive,json=lastKeepalive,proto3" json:"last_keepalive,omitempty"`
	Created           string          `protobuf:"bytes,13,opt,name=created,proto3" json:"created,omitempty"`
	AgentVersion      string          `protobuf:"bytes,14,opt,name=agent_version,json=agentVersion,proto3" json:"agent_version,omitempty"`
	MachineMetrics    *MachineMetrics `protobuf:"bytes,15,opt,name=machine_metrics,json=machineMetrics,proto3" json:"machine_metrics,omitempty"`
	UserData          string          `protobuf:"bytes,16,opt,name=user_data,json=userData,proto3" json:"user_data,omitempty"`
	// contains filtered or unexported fields
}

func (*Machine) Descriptor deprecated

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

Deprecated: Use Machine.ProtoReflect.Descriptor instead.

func (*Machine) GetAgentVersion

func (x *Machine) GetAgentVersion() string

func (*Machine) GetCpu

func (x *Machine) GetCpu() int64

func (*Machine) GetCreated

func (x *Machine) GetCreated() string

func (*Machine) GetGpu

func (x *Machine) GetGpu() string

func (*Machine) GetGpuCount

func (x *Machine) GetGpuCount() uint32

func (*Machine) GetId

func (x *Machine) GetId() string

func (*Machine) GetLastKeepalive

func (x *Machine) GetLastKeepalive() string

func (*Machine) GetMachineMetrics

func (x *Machine) GetMachineMetrics() *MachineMetrics

func (*Machine) GetMemory

func (x *Machine) GetMemory() int64

func (*Machine) GetPoolName

func (x *Machine) GetPoolName() string

func (*Machine) GetProviderName

func (x *Machine) GetProviderName() string

func (*Machine) GetRegistrationToken

func (x *Machine) GetRegistrationToken() string

func (*Machine) GetStatus

func (x *Machine) GetStatus() string

func (*Machine) GetTailscaleAuth

func (x *Machine) GetTailscaleAuth() string

func (*Machine) GetTailscaleUrl

func (x *Machine) GetTailscaleUrl() string

func (*Machine) GetUserData

func (x *Machine) GetUserData() string

func (*Machine) ProtoMessage

func (*Machine) ProtoMessage()

func (*Machine) ProtoReflect

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

func (*Machine) Reset

func (x *Machine) Reset()

func (*Machine) String

func (x *Machine) String() string

type MachineMetrics

type MachineMetrics struct {
	TotalCpuAvailable    int32   `protobuf:"varint,1,opt,name=total_cpu_available,json=totalCpuAvailable,proto3" json:"total_cpu_available,omitempty"`
	TotalMemoryAvailable int32   `protobuf:"varint,2,opt,name=total_memory_available,json=totalMemoryAvailable,proto3" json:"total_memory_available,omitempty"`
	CpuUtilizationPct    float32 `protobuf:"fixed32,3,opt,name=cpu_utilization_pct,json=cpuUtilizationPct,proto3" json:"cpu_utilization_pct,omitempty"`
	MemoryUtilizationPct float32 `protobuf:"fixed32,4,opt,name=memory_utilization_pct,json=memoryUtilizationPct,proto3" json:"memory_utilization_pct,omitempty"`
	WorkerCount          int32   `protobuf:"varint,5,opt,name=worker_count,json=workerCount,proto3" json:"worker_count,omitempty"`
	ContainerCount       int32   `protobuf:"varint,6,opt,name=container_count,json=containerCount,proto3" json:"container_count,omitempty"`
	FreeGpuCount         int32   `protobuf:"varint,7,opt,name=free_gpu_count,json=freeGpuCount,proto3" json:"free_gpu_count,omitempty"`
	CacheUsagePct        float32 `protobuf:"fixed32,8,opt,name=cache_usage_pct,json=cacheUsagePct,proto3" json:"cache_usage_pct,omitempty"`
	CacheCapacity        int32   `protobuf:"varint,9,opt,name=cache_capacity,json=cacheCapacity,proto3" json:"cache_capacity,omitempty"`
	CacheMemoryUsage     int32   `protobuf:"varint,10,opt,name=cache_memory_usage,json=cacheMemoryUsage,proto3" json:"cache_memory_usage,omitempty"`
	CacheCpuUsage        float32 `protobuf:"fixed32,11,opt,name=cache_cpu_usage,json=cacheCpuUsage,proto3" json:"cache_cpu_usage,omitempty"`
	// contains filtered or unexported fields
}

func (*MachineMetrics) Descriptor deprecated

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

Deprecated: Use MachineMetrics.ProtoReflect.Descriptor instead.

func (*MachineMetrics) GetCacheCapacity

func (x *MachineMetrics) GetCacheCapacity() int32

func (*MachineMetrics) GetCacheCpuUsage

func (x *MachineMetrics) GetCacheCpuUsage() float32

func (*MachineMetrics) GetCacheMemoryUsage

func (x *MachineMetrics) GetCacheMemoryUsage() int32

func (*MachineMetrics) GetCacheUsagePct

func (x *MachineMetrics) GetCacheUsagePct() float32

func (*MachineMetrics) GetContainerCount

func (x *MachineMetrics) GetContainerCount() int32

func (*MachineMetrics) GetCpuUtilizationPct

func (x *MachineMetrics) GetCpuUtilizationPct() float32

func (*MachineMetrics) GetFreeGpuCount

func (x *MachineMetrics) GetFreeGpuCount() int32

func (*MachineMetrics) GetMemoryUtilizationPct

func (x *MachineMetrics) GetMemoryUtilizationPct() float32

func (*MachineMetrics) GetTotalCpuAvailable

func (x *MachineMetrics) GetTotalCpuAvailable() int32

func (*MachineMetrics) GetTotalMemoryAvailable

func (x *MachineMetrics) GetTotalMemoryAvailable() int32

func (*MachineMetrics) GetWorkerCount

func (x *MachineMetrics) GetWorkerCount() int32

func (*MachineMetrics) ProtoMessage

func (*MachineMetrics) ProtoMessage()

func (*MachineMetrics) ProtoReflect

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

func (*MachineMetrics) Reset

func (x *MachineMetrics) Reset()

func (*MachineMetrics) String

func (x *MachineMetrics) String() string

type MachineServiceClient

type MachineServiceClient interface {
	GetGPUAvailability(ctx context.Context, in *GetGPUAvailabilityRequest, opts ...grpc.CallOption) (*GetGPUAvailabilityResponse, error)
}

MachineServiceClient is the client API for MachineService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type MachineServiceServer

type MachineServiceServer interface {
	GetGPUAvailability(context.Context, *GetGPUAvailabilityRequest) (*GetGPUAvailabilityResponse, error)
	// contains filtered or unexported methods
}

MachineServiceServer is the server API for MachineService service. All implementations must embed UnimplementedMachineServiceServer for forward compatibility

type MapCountRequest

type MapCountRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*MapCountRequest) Descriptor deprecated

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

Deprecated: Use MapCountRequest.ProtoReflect.Descriptor instead.

func (*MapCountRequest) GetName

func (x *MapCountRequest) GetName() string

func (*MapCountRequest) ProtoMessage

func (*MapCountRequest) ProtoMessage()

func (*MapCountRequest) ProtoReflect

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

func (*MapCountRequest) Reset

func (x *MapCountRequest) Reset()

func (*MapCountRequest) String

func (x *MapCountRequest) String() string

type MapCountResponse

type MapCountResponse struct {
	Ok    bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Count uint32 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*MapCountResponse) Descriptor deprecated

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

Deprecated: Use MapCountResponse.ProtoReflect.Descriptor instead.

func (*MapCountResponse) GetCount

func (x *MapCountResponse) GetCount() uint32

func (*MapCountResponse) GetOk

func (x *MapCountResponse) GetOk() bool

func (*MapCountResponse) ProtoMessage

func (*MapCountResponse) ProtoMessage()

func (*MapCountResponse) ProtoReflect

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

func (*MapCountResponse) Reset

func (x *MapCountResponse) Reset()

func (*MapCountResponse) String

func (x *MapCountResponse) String() string

type MapDeleteRequest

type MapDeleteRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Key  string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*MapDeleteRequest) Descriptor deprecated

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

Deprecated: Use MapDeleteRequest.ProtoReflect.Descriptor instead.

func (*MapDeleteRequest) GetKey

func (x *MapDeleteRequest) GetKey() string

func (*MapDeleteRequest) GetName

func (x *MapDeleteRequest) GetName() string

func (*MapDeleteRequest) ProtoMessage

func (*MapDeleteRequest) ProtoMessage()

func (*MapDeleteRequest) ProtoReflect

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

func (*MapDeleteRequest) Reset

func (x *MapDeleteRequest) Reset()

func (*MapDeleteRequest) String

func (x *MapDeleteRequest) String() string

type MapDeleteResponse

type MapDeleteResponse struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*MapDeleteResponse) Descriptor deprecated

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

Deprecated: Use MapDeleteResponse.ProtoReflect.Descriptor instead.

func (*MapDeleteResponse) GetOk

func (x *MapDeleteResponse) GetOk() bool

func (*MapDeleteResponse) ProtoMessage

func (*MapDeleteResponse) ProtoMessage()

func (*MapDeleteResponse) ProtoReflect

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

func (*MapDeleteResponse) Reset

func (x *MapDeleteResponse) Reset()

func (*MapDeleteResponse) String

func (x *MapDeleteResponse) String() string

type MapGetRequest

type MapGetRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Key  string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*MapGetRequest) Descriptor deprecated

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

Deprecated: Use MapGetRequest.ProtoReflect.Descriptor instead.

func (*MapGetRequest) GetKey

func (x *MapGetRequest) GetKey() string

func (*MapGetRequest) GetName

func (x *MapGetRequest) GetName() string

func (*MapGetRequest) ProtoMessage

func (*MapGetRequest) ProtoMessage()

func (*MapGetRequest) ProtoReflect

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

func (*MapGetRequest) Reset

func (x *MapGetRequest) Reset()

func (*MapGetRequest) String

func (x *MapGetRequest) String() string

type MapGetResponse

type MapGetResponse struct {
	Ok    bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*MapGetResponse) Descriptor deprecated

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

Deprecated: Use MapGetResponse.ProtoReflect.Descriptor instead.

func (*MapGetResponse) GetOk

func (x *MapGetResponse) GetOk() bool

func (*MapGetResponse) GetValue

func (x *MapGetResponse) GetValue() []byte

func (*MapGetResponse) ProtoMessage

func (*MapGetResponse) ProtoMessage()

func (*MapGetResponse) ProtoReflect

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

func (*MapGetResponse) Reset

func (x *MapGetResponse) Reset()

func (*MapGetResponse) String

func (x *MapGetResponse) String() string

type MapKeysRequest

type MapKeysRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*MapKeysRequest) Descriptor deprecated

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

Deprecated: Use MapKeysRequest.ProtoReflect.Descriptor instead.

func (*MapKeysRequest) GetName

func (x *MapKeysRequest) GetName() string

func (*MapKeysRequest) ProtoMessage

func (*MapKeysRequest) ProtoMessage()

func (*MapKeysRequest) ProtoReflect

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

func (*MapKeysRequest) Reset

func (x *MapKeysRequest) Reset()

func (*MapKeysRequest) String

func (x *MapKeysRequest) String() string

type MapKeysResponse

type MapKeysResponse struct {
	Ok   bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Keys []string `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*MapKeysResponse) Descriptor deprecated

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

Deprecated: Use MapKeysResponse.ProtoReflect.Descriptor instead.

func (*MapKeysResponse) GetKeys

func (x *MapKeysResponse) GetKeys() []string

func (*MapKeysResponse) GetOk

func (x *MapKeysResponse) GetOk() bool

func (*MapKeysResponse) ProtoMessage

func (*MapKeysResponse) ProtoMessage()

func (*MapKeysResponse) ProtoReflect

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

func (*MapKeysResponse) Reset

func (x *MapKeysResponse) Reset()

func (*MapKeysResponse) String

func (x *MapKeysResponse) String() string

type MapServiceClient

type MapServiceClient interface {
	MapSet(ctx context.Context, in *MapSetRequest, opts ...grpc.CallOption) (*MapSetResponse, error)
	MapGet(ctx context.Context, in *MapGetRequest, opts ...grpc.CallOption) (*MapGetResponse, error)
	MapDelete(ctx context.Context, in *MapDeleteRequest, opts ...grpc.CallOption) (*MapDeleteResponse, error)
	MapCount(ctx context.Context, in *MapCountRequest, opts ...grpc.CallOption) (*MapCountResponse, error)
	MapKeys(ctx context.Context, in *MapKeysRequest, opts ...grpc.CallOption) (*MapKeysResponse, error)
}

MapServiceClient is the client API for MapService 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 NewMapServiceClient

func NewMapServiceClient(cc grpc.ClientConnInterface) MapServiceClient

type MapServiceServer

type MapServiceServer interface {
	MapSet(context.Context, *MapSetRequest) (*MapSetResponse, error)
	MapGet(context.Context, *MapGetRequest) (*MapGetResponse, error)
	MapDelete(context.Context, *MapDeleteRequest) (*MapDeleteResponse, error)
	MapCount(context.Context, *MapCountRequest) (*MapCountResponse, error)
	MapKeys(context.Context, *MapKeysRequest) (*MapKeysResponse, error)
	// contains filtered or unexported methods
}

MapServiceServer is the server API for MapService service. All implementations must embed UnimplementedMapServiceServer for forward compatibility

type MapSetRequest

type MapSetRequest struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Key   string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Ttl   int64  `protobuf:"varint,4,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// contains filtered or unexported fields
}

func (*MapSetRequest) Descriptor deprecated

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

Deprecated: Use MapSetRequest.ProtoReflect.Descriptor instead.

func (*MapSetRequest) GetKey

func (x *MapSetRequest) GetKey() string

func (*MapSetRequest) GetName

func (x *MapSetRequest) GetName() string

func (*MapSetRequest) GetTtl

func (x *MapSetRequest) GetTtl() int64

func (*MapSetRequest) GetValue

func (x *MapSetRequest) GetValue() []byte

func (*MapSetRequest) ProtoMessage

func (*MapSetRequest) ProtoMessage()

func (*MapSetRequest) ProtoReflect

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

func (*MapSetRequest) Reset

func (x *MapSetRequest) Reset()

func (*MapSetRequest) String

func (x *MapSetRequest) String() string

type MapSetResponse

type MapSetResponse struct {
	Ok     bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrMsg string `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	// contains filtered or unexported fields
}

func (*MapSetResponse) Descriptor deprecated

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

Deprecated: Use MapSetResponse.ProtoReflect.Descriptor instead.

func (*MapSetResponse) GetErrMsg

func (x *MapSetResponse) GetErrMsg() string

func (*MapSetResponse) GetOk

func (x *MapSetResponse) GetOk() bool

func (*MapSetResponse) ProtoMessage

func (*MapSetResponse) ProtoMessage()

func (*MapSetResponse) ProtoReflect

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

func (*MapSetResponse) Reset

func (x *MapSetResponse) Reset()

func (*MapSetResponse) String

func (x *MapSetResponse) String() string

type Marker

type Marker struct {
	LocationName string         `protobuf:"bytes,1,opt,name=location_name,json=locationName,proto3" json:"location_name,omitempty"`
	Fields       []*MarkerField `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"`
	SourceTaskId string         `protobuf:"bytes,3,opt,name=source_task_id,json=sourceTaskId,proto3" json:"source_task_id,omitempty"`
	// contains filtered or unexported fields
}

func (*Marker) Descriptor deprecated

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

Deprecated: Use Marker.ProtoReflect.Descriptor instead.

func (*Marker) GetFields

func (x *Marker) GetFields() []*MarkerField

func (*Marker) GetLocationName

func (x *Marker) GetLocationName() string

func (*Marker) GetSourceTaskId

func (x *Marker) GetSourceTaskId() string

func (*Marker) ProtoMessage

func (*Marker) ProtoMessage()

func (*Marker) ProtoReflect

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

func (*Marker) Reset

func (x *Marker) Reset()

func (*Marker) String

func (x *Marker) String() string

type MarkerField

type MarkerField struct {
	FieldName  string `protobuf:"bytes,1,opt,name=field_name,json=fieldName,proto3" json:"field_name,omitempty"`
	FieldValue string `protobuf:"bytes,2,opt,name=field_value,json=fieldValue,proto3" json:"field_value,omitempty"`
	// contains filtered or unexported fields
}

func (*MarkerField) Descriptor deprecated

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

Deprecated: Use MarkerField.ProtoReflect.Descriptor instead.

func (*MarkerField) GetFieldName

func (x *MarkerField) GetFieldName() string

func (*MarkerField) GetFieldValue

func (x *MarkerField) GetFieldValue() string

func (*MarkerField) ProtoMessage

func (*MarkerField) ProtoMessage()

func (*MarkerField) ProtoReflect

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

func (*MarkerField) Reset

func (x *MarkerField) Reset()

func (*MarkerField) String

func (x *MarkerField) String() string

type MountPointConfig

type MountPointConfig struct {
	BucketName  string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	AccessKey   string `protobuf:"bytes,2,opt,name=access_key,json=accessKey,proto3" json:"access_key,omitempty"`
	SecretKey   string `protobuf:"bytes,3,opt,name=secret_key,json=secretKey,proto3" json:"secret_key,omitempty"`
	EndpointUrl string `protobuf:"bytes,4,opt,name=endpoint_url,json=endpointUrl,proto3" json:"endpoint_url,omitempty"`
	Region      string `protobuf:"bytes,5,opt,name=region,proto3" json:"region,omitempty"`
	ReadOnly    bool   `protobuf:"varint,6,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
	// contains filtered or unexported fields
}

func (*MountPointConfig) Descriptor deprecated

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

Deprecated: Use MountPointConfig.ProtoReflect.Descriptor instead.

func (*MountPointConfig) GetAccessKey

func (x *MountPointConfig) GetAccessKey() string

func (*MountPointConfig) GetBucketName

func (x *MountPointConfig) GetBucketName() string

func (*MountPointConfig) GetEndpointUrl

func (x *MountPointConfig) GetEndpointUrl() string

func (*MountPointConfig) GetReadOnly

func (x *MountPointConfig) GetReadOnly() bool

func (*MountPointConfig) GetRegion

func (x *MountPointConfig) GetRegion() string

func (*MountPointConfig) GetSecretKey

func (x *MountPointConfig) GetSecretKey() string

func (*MountPointConfig) ProtoMessage

func (*MountPointConfig) ProtoMessage()

func (*MountPointConfig) ProtoReflect

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

func (*MountPointConfig) Reset

func (x *MountPointConfig) Reset()

func (*MountPointConfig) String

func (x *MountPointConfig) String() string

type MovePathRequest

type MovePathRequest struct {
	OriginalPath string `protobuf:"bytes,1,opt,name=original_path,json=originalPath,proto3" json:"original_path,omitempty"`
	NewPath      string `protobuf:"bytes,2,opt,name=new_path,json=newPath,proto3" json:"new_path,omitempty"`
	// contains filtered or unexported fields
}

func (*MovePathRequest) Descriptor deprecated

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

Deprecated: Use MovePathRequest.ProtoReflect.Descriptor instead.

func (*MovePathRequest) GetNewPath

func (x *MovePathRequest) GetNewPath() string

func (*MovePathRequest) GetOriginalPath

func (x *MovePathRequest) GetOriginalPath() string

func (*MovePathRequest) ProtoMessage

func (*MovePathRequest) ProtoMessage()

func (*MovePathRequest) ProtoReflect

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

func (*MovePathRequest) Reset

func (x *MovePathRequest) Reset()

func (*MovePathRequest) String

func (x *MovePathRequest) String() string

type MovePathResponse

type MovePathResponse struct {
	Ok      bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrMsg  string `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	NewPath string `protobuf:"bytes,3,opt,name=new_path,json=newPath,proto3" json:"new_path,omitempty"`
	// contains filtered or unexported fields
}

func (*MovePathResponse) Descriptor deprecated

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

Deprecated: Use MovePathResponse.ProtoReflect.Descriptor instead.

func (*MovePathResponse) GetErrMsg

func (x *MovePathResponse) GetErrMsg() string

func (*MovePathResponse) GetNewPath

func (x *MovePathResponse) GetNewPath() string

func (*MovePathResponse) GetOk

func (x *MovePathResponse) GetOk() bool

func (*MovePathResponse) ProtoMessage

func (*MovePathResponse) ProtoMessage()

func (*MovePathResponse) ProtoReflect

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

func (*MovePathResponse) Reset

func (x *MovePathResponse) Reset()

func (*MovePathResponse) String

func (x *MovePathResponse) String() string

type ObjectMetadata

type ObjectMetadata struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Size int64  `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*ObjectMetadata) Descriptor deprecated

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

Deprecated: Use ObjectMetadata.ProtoReflect.Descriptor instead.

func (*ObjectMetadata) GetName

func (x *ObjectMetadata) GetName() string

func (*ObjectMetadata) GetSize

func (x *ObjectMetadata) GetSize() int64

func (*ObjectMetadata) ProtoMessage

func (*ObjectMetadata) ProtoMessage()

func (*ObjectMetadata) ProtoReflect

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

func (*ObjectMetadata) Reset

func (x *ObjectMetadata) Reset()

func (*ObjectMetadata) String

func (x *ObjectMetadata) String() string

type OutputPublicURLRequest

type OutputPublicURLRequest struct {
	Id       string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	TaskId   string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Filename string `protobuf:"bytes,3,opt,name=filename,proto3" json:"filename,omitempty"`
	Expires  uint32 `protobuf:"varint,4,opt,name=expires,proto3" json:"expires,omitempty"`
	// contains filtered or unexported fields
}

func (*OutputPublicURLRequest) Descriptor deprecated

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

Deprecated: Use OutputPublicURLRequest.ProtoReflect.Descriptor instead.

func (*OutputPublicURLRequest) GetExpires

func (x *OutputPublicURLRequest) GetExpires() uint32

func (*OutputPublicURLRequest) GetFilename

func (x *OutputPublicURLRequest) GetFilename() string

func (*OutputPublicURLRequest) GetId

func (x *OutputPublicURLRequest) GetId() string

func (*OutputPublicURLRequest) GetTaskId

func (x *OutputPublicURLRequest) GetTaskId() string

func (*OutputPublicURLRequest) ProtoMessage

func (*OutputPublicURLRequest) ProtoMessage()

func (*OutputPublicURLRequest) ProtoReflect

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

func (*OutputPublicURLRequest) Reset

func (x *OutputPublicURLRequest) Reset()

func (*OutputPublicURLRequest) String

func (x *OutputPublicURLRequest) String() string

type OutputPublicURLResponse

type OutputPublicURLResponse struct {
	Ok        bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrMsg    string `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	PublicUrl string `protobuf:"bytes,3,opt,name=public_url,json=publicUrl,proto3" json:"public_url,omitempty"`
	// contains filtered or unexported fields
}

func (*OutputPublicURLResponse) Descriptor deprecated

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

Deprecated: Use OutputPublicURLResponse.ProtoReflect.Descriptor instead.

func (*OutputPublicURLResponse) GetErrMsg

func (x *OutputPublicURLResponse) GetErrMsg() string

func (*OutputPublicURLResponse) GetOk

func (x *OutputPublicURLResponse) GetOk() bool

func (*OutputPublicURLResponse) GetPublicUrl

func (x *OutputPublicURLResponse) GetPublicUrl() string

func (*OutputPublicURLResponse) ProtoMessage

func (*OutputPublicURLResponse) ProtoMessage()

func (*OutputPublicURLResponse) ProtoReflect

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

func (*OutputPublicURLResponse) Reset

func (x *OutputPublicURLResponse) Reset()

func (*OutputPublicURLResponse) String

func (x *OutputPublicURLResponse) String() string

type OutputSaveRequest

type OutputSaveRequest struct {
	TaskId   string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Filename string `protobuf:"bytes,2,opt,name=filename,proto3" json:"filename,omitempty"`
	Content  []byte `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

func (*OutputSaveRequest) Descriptor deprecated

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

Deprecated: Use OutputSaveRequest.ProtoReflect.Descriptor instead.

func (*OutputSaveRequest) GetContent

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

func (*OutputSaveRequest) GetFilename

func (x *OutputSaveRequest) GetFilename() string

func (*OutputSaveRequest) GetTaskId

func (x *OutputSaveRequest) GetTaskId() string

func (*OutputSaveRequest) ProtoMessage

func (*OutputSaveRequest) ProtoMessage()

func (*OutputSaveRequest) ProtoReflect

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

func (*OutputSaveRequest) Reset

func (x *OutputSaveRequest) Reset()

func (*OutputSaveRequest) String

func (x *OutputSaveRequest) String() string

type OutputSaveResponse

type OutputSaveResponse struct {
	Ok     bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrMsg string `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	Id     string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*OutputSaveResponse) Descriptor deprecated

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

Deprecated: Use OutputSaveResponse.ProtoReflect.Descriptor instead.

func (*OutputSaveResponse) GetErrMsg

func (x *OutputSaveResponse) GetErrMsg() string

func (*OutputSaveResponse) GetId

func (x *OutputSaveResponse) GetId() string

func (*OutputSaveResponse) GetOk

func (x *OutputSaveResponse) GetOk() bool

func (*OutputSaveResponse) ProtoMessage

func (*OutputSaveResponse) ProtoMessage()

func (*OutputSaveResponse) ProtoReflect

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

func (*OutputSaveResponse) Reset

func (x *OutputSaveResponse) Reset()

func (*OutputSaveResponse) String

func (x *OutputSaveResponse) String() string

type OutputServiceClient

type OutputServiceClient interface {
	OutputSaveStream(ctx context.Context, opts ...grpc.CallOption) (OutputService_OutputSaveStreamClient, error)
	OutputStat(ctx context.Context, in *OutputStatRequest, opts ...grpc.CallOption) (*OutputStatResponse, error)
	OutputPublicURL(ctx context.Context, in *OutputPublicURLRequest, opts ...grpc.CallOption) (*OutputPublicURLResponse, error)
}

OutputServiceClient is the client API for OutputService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type OutputServiceServer

type OutputServiceServer interface {
	OutputSaveStream(OutputService_OutputSaveStreamServer) error
	OutputStat(context.Context, *OutputStatRequest) (*OutputStatResponse, error)
	OutputPublicURL(context.Context, *OutputPublicURLRequest) (*OutputPublicURLResponse, error)
	// contains filtered or unexported methods
}

OutputServiceServer is the server API for OutputService service. All implementations must embed UnimplementedOutputServiceServer for forward compatibility

type OutputService_OutputSaveStreamClient

type OutputService_OutputSaveStreamClient interface {
	Send(*OutputSaveRequest) error
	CloseAndRecv() (*OutputSaveResponse, error)
	grpc.ClientStream
}

type OutputService_OutputSaveStreamServer

type OutputService_OutputSaveStreamServer interface {
	SendAndClose(*OutputSaveResponse) error
	Recv() (*OutputSaveRequest, error)
	grpc.ServerStream
}

type OutputStat

type OutputStat struct {
	Mode  string                 `protobuf:"bytes,1,opt,name=mode,proto3" json:"mode,omitempty"`
	Size  int64                  `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	Atime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=atime,proto3" json:"atime,omitempty"`
	Mtime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=mtime,proto3" json:"mtime,omitempty"`
	// contains filtered or unexported fields
}

func (*OutputStat) Descriptor deprecated

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

Deprecated: Use OutputStat.ProtoReflect.Descriptor instead.

func (*OutputStat) GetAtime

func (x *OutputStat) GetAtime() *timestamppb.Timestamp

func (*OutputStat) GetMode

func (x *OutputStat) GetMode() string

func (*OutputStat) GetMtime

func (x *OutputStat) GetMtime() *timestamppb.Timestamp

func (*OutputStat) GetSize

func (x *OutputStat) GetSize() int64

func (*OutputStat) ProtoMessage

func (*OutputStat) ProtoMessage()

func (*OutputStat) ProtoReflect

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

func (*OutputStat) Reset

func (x *OutputStat) Reset()

func (*OutputStat) String

func (x *OutputStat) String() string

type OutputStatRequest

type OutputStatRequest struct {
	Id       string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	TaskId   string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Filename string `protobuf:"bytes,3,opt,name=filename,proto3" json:"filename,omitempty"`
	// contains filtered or unexported fields
}

func (*OutputStatRequest) Descriptor deprecated

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

Deprecated: Use OutputStatRequest.ProtoReflect.Descriptor instead.

func (*OutputStatRequest) GetFilename

func (x *OutputStatRequest) GetFilename() string

func (*OutputStatRequest) GetId

func (x *OutputStatRequest) GetId() string

func (*OutputStatRequest) GetTaskId

func (x *OutputStatRequest) GetTaskId() string

func (*OutputStatRequest) ProtoMessage

func (*OutputStatRequest) ProtoMessage()

func (*OutputStatRequest) ProtoReflect

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

func (*OutputStatRequest) Reset

func (x *OutputStatRequest) Reset()

func (*OutputStatRequest) String

func (x *OutputStatRequest) String() string

type OutputStatResponse

type OutputStatResponse struct {
	Ok     bool        `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrMsg string      `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	Stat   *OutputStat `protobuf:"bytes,3,opt,name=stat,proto3" json:"stat,omitempty"`
	// contains filtered or unexported fields
}

func (*OutputStatResponse) Descriptor deprecated

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

Deprecated: Use OutputStatResponse.ProtoReflect.Descriptor instead.

func (*OutputStatResponse) GetErrMsg

func (x *OutputStatResponse) GetErrMsg() string

func (*OutputStatResponse) GetOk

func (x *OutputStatResponse) GetOk() bool

func (*OutputStatResponse) GetStat

func (x *OutputStatResponse) GetStat() *OutputStat

func (*OutputStatResponse) ProtoMessage

func (*OutputStatResponse) ProtoMessage()

func (*OutputStatResponse) ProtoReflect

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

func (*OutputStatResponse) Reset

func (x *OutputStatResponse) Reset()

func (*OutputStatResponse) String

func (x *OutputStatResponse) String() string

type PathInfo

type PathInfo struct {
	Path    string                 `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Size    uint64                 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	ModTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=mod_time,json=modTime,proto3" json:"mod_time,omitempty"`
	IsDir   bool                   `protobuf:"varint,4,opt,name=is_dir,json=isDir,proto3" json:"is_dir,omitempty"`
	// contains filtered or unexported fields
}

func (*PathInfo) Descriptor deprecated

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

Deprecated: Use PathInfo.ProtoReflect.Descriptor instead.

func (*PathInfo) GetIsDir

func (x *PathInfo) GetIsDir() bool

func (*PathInfo) GetModTime

func (x *PathInfo) GetModTime() *timestamppb.Timestamp

func (*PathInfo) GetPath

func (x *PathInfo) GetPath() string

func (*PathInfo) GetSize

func (x *PathInfo) GetSize() uint64

func (*PathInfo) ProtoMessage

func (*PathInfo) ProtoMessage()

func (*PathInfo) ProtoReflect

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

func (*PathInfo) Reset

func (x *PathInfo) Reset()

func (*PathInfo) String

func (x *PathInfo) String() string

type Pool

type Pool struct {
	Name                  string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Active                bool   `protobuf:"varint,3,opt,name=active,proto3" json:"active,omitempty"`
	Gpu                   string `protobuf:"bytes,4,opt,name=gpu,proto3" json:"gpu,omitempty"`
	MinFreeGpu            string `protobuf:"bytes,5,opt,name=minFreeGpu,proto3" json:"minFreeGpu,omitempty"`
	MinFreeCpu            string `protobuf:"bytes,6,opt,name=minFreeCpu,proto3" json:"minFreeCpu,omitempty"`
	MinFreeMemory         string `protobuf:"bytes,7,opt,name=minFreeMemory,proto3" json:"minFreeMemory,omitempty"`
	DefaultWorkerCpu      string `protobuf:"bytes,8,opt,name=defaultWorkerCpu,proto3" json:"defaultWorkerCpu,omitempty"`
	DefaultWorkerMemory   string `protobuf:"bytes,9,opt,name=defaultWorkerMemory,proto3" json:"defaultWorkerMemory,omitempty"`
	DefaultWorkerGpuCount string `protobuf:"bytes,10,opt,name=defaultWorkerGpuCount,proto3" json:"defaultWorkerGpuCount,omitempty"`
	// contains filtered or unexported fields
}

func (*Pool) Descriptor deprecated

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

Deprecated: Use Pool.ProtoReflect.Descriptor instead.

func (*Pool) GetActive

func (x *Pool) GetActive() bool

func (*Pool) GetDefaultWorkerCpu

func (x *Pool) GetDefaultWorkerCpu() string

func (*Pool) GetDefaultWorkerGpuCount

func (x *Pool) GetDefaultWorkerGpuCount() string

func (*Pool) GetDefaultWorkerMemory

func (x *Pool) GetDefaultWorkerMemory() string

func (*Pool) GetGpu

func (x *Pool) GetGpu() string

func (*Pool) GetMinFreeCpu

func (x *Pool) GetMinFreeCpu() string

func (*Pool) GetMinFreeGpu

func (x *Pool) GetMinFreeGpu() string

func (*Pool) GetMinFreeMemory

func (x *Pool) GetMinFreeMemory() string

func (*Pool) GetName

func (x *Pool) GetName() string

func (*Pool) ProtoMessage

func (*Pool) ProtoMessage()

func (*Pool) ProtoReflect

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

func (*Pool) Reset

func (x *Pool) Reset()

func (*Pool) String

func (x *Pool) String() string

type PopBotTaskRequest

type PopBotTaskRequest struct {
	StubId         string `protobuf:"bytes,1,opt,name=stub_id,json=stubId,proto3" json:"stub_id,omitempty"`
	SessionId      string `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	TransitionName string `protobuf:"bytes,3,opt,name=transition_name,json=transitionName,proto3" json:"transition_name,omitempty"`
	TaskId         string `protobuf:"bytes,4,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// contains filtered or unexported fields
}

func (*PopBotTaskRequest) Descriptor deprecated

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

Deprecated: Use PopBotTaskRequest.ProtoReflect.Descriptor instead.

func (*PopBotTaskRequest) GetSessionId

func (x *PopBotTaskRequest) GetSessionId() string

func (*PopBotTaskRequest) GetStubId

func (x *PopBotTaskRequest) GetStubId() string

func (*PopBotTaskRequest) GetTaskId

func (x *PopBotTaskRequest) GetTaskId() string

func (*PopBotTaskRequest) GetTransitionName

func (x *PopBotTaskRequest) GetTransitionName() string

func (*PopBotTaskRequest) ProtoMessage

func (*PopBotTaskRequest) ProtoMessage()

func (*PopBotTaskRequest) ProtoReflect

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

func (*PopBotTaskRequest) Reset

func (x *PopBotTaskRequest) Reset()

func (*PopBotTaskRequest) String

func (x *PopBotTaskRequest) String() string

type PopBotTaskResponse

type PopBotTaskResponse struct {
	Ok      bool                                      `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Markers map[string]*PopBotTaskResponse_MarkerList `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PopBotTaskResponse) Descriptor deprecated

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

Deprecated: Use PopBotTaskResponse.ProtoReflect.Descriptor instead.

func (*PopBotTaskResponse) GetMarkers

func (*PopBotTaskResponse) GetOk

func (x *PopBotTaskResponse) GetOk() bool

func (*PopBotTaskResponse) ProtoMessage

func (*PopBotTaskResponse) ProtoMessage()

func (*PopBotTaskResponse) ProtoReflect

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

func (*PopBotTaskResponse) Reset

func (x *PopBotTaskResponse) Reset()

func (*PopBotTaskResponse) String

func (x *PopBotTaskResponse) String() string

type PopBotTaskResponse_MarkerList

type PopBotTaskResponse_MarkerList struct {
	Markers []*Marker `protobuf:"bytes,1,rep,name=markers,proto3" json:"markers,omitempty"`
	// contains filtered or unexported fields
}

func (*PopBotTaskResponse_MarkerList) Descriptor deprecated

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

Deprecated: Use PopBotTaskResponse_MarkerList.ProtoReflect.Descriptor instead.

func (*PopBotTaskResponse_MarkerList) GetMarkers

func (x *PopBotTaskResponse_MarkerList) GetMarkers() []*Marker

func (*PopBotTaskResponse_MarkerList) ProtoMessage

func (*PopBotTaskResponse_MarkerList) ProtoMessage()

func (*PopBotTaskResponse_MarkerList) ProtoReflect

func (*PopBotTaskResponse_MarkerList) Reset

func (x *PopBotTaskResponse_MarkerList) Reset()

func (*PopBotTaskResponse_MarkerList) String

type PushBotEventBlockingRequest

type PushBotEventBlockingRequest struct {
	StubId         string            `protobuf:"bytes,1,opt,name=stub_id,json=stubId,proto3" json:"stub_id,omitempty"`
	SessionId      string            `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	EventType      string            `protobuf:"bytes,3,opt,name=event_type,json=eventType,proto3" json:"event_type,omitempty"`
	EventValue     string            `protobuf:"bytes,4,opt,name=event_value,json=eventValue,proto3" json:"event_value,omitempty"`
	Metadata       map[string]string `` /* 157-byte string literal not displayed */
	TimeoutSeconds int32             `protobuf:"varint,6,opt,name=timeout_seconds,json=timeoutSeconds,proto3" json:"timeout_seconds,omitempty"`
	// contains filtered or unexported fields
}

func (*PushBotEventBlockingRequest) Descriptor deprecated

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

Deprecated: Use PushBotEventBlockingRequest.ProtoReflect.Descriptor instead.

func (*PushBotEventBlockingRequest) GetEventType

func (x *PushBotEventBlockingRequest) GetEventType() string

func (*PushBotEventBlockingRequest) GetEventValue

func (x *PushBotEventBlockingRequest) GetEventValue() string

func (*PushBotEventBlockingRequest) GetMetadata

func (x *PushBotEventBlockingRequest) GetMetadata() map[string]string

func (*PushBotEventBlockingRequest) GetSessionId

func (x *PushBotEventBlockingRequest) GetSessionId() string

func (*PushBotEventBlockingRequest) GetStubId

func (x *PushBotEventBlockingRequest) GetStubId() string

func (*PushBotEventBlockingRequest) GetTimeoutSeconds

func (x *PushBotEventBlockingRequest) GetTimeoutSeconds() int32

func (*PushBotEventBlockingRequest) ProtoMessage

func (*PushBotEventBlockingRequest) ProtoMessage()

func (*PushBotEventBlockingRequest) ProtoReflect

func (*PushBotEventBlockingRequest) Reset

func (x *PushBotEventBlockingRequest) Reset()

func (*PushBotEventBlockingRequest) String

func (x *PushBotEventBlockingRequest) String() string

type PushBotEventBlockingResponse

type PushBotEventBlockingResponse struct {
	Ok    bool      `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Event *BotEvent `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*PushBotEventBlockingResponse) Descriptor deprecated

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

Deprecated: Use PushBotEventBlockingResponse.ProtoReflect.Descriptor instead.

func (*PushBotEventBlockingResponse) GetEvent

func (x *PushBotEventBlockingResponse) GetEvent() *BotEvent

func (*PushBotEventBlockingResponse) GetOk

func (*PushBotEventBlockingResponse) ProtoMessage

func (*PushBotEventBlockingResponse) ProtoMessage()

func (*PushBotEventBlockingResponse) ProtoReflect

func (*PushBotEventBlockingResponse) Reset

func (x *PushBotEventBlockingResponse) Reset()

func (*PushBotEventBlockingResponse) String

type PushBotEventRequest

type PushBotEventRequest struct {
	StubId     string            `protobuf:"bytes,1,opt,name=stub_id,json=stubId,proto3" json:"stub_id,omitempty"`
	SessionId  string            `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	EventType  string            `protobuf:"bytes,3,opt,name=event_type,json=eventType,proto3" json:"event_type,omitempty"`
	EventValue string            `protobuf:"bytes,4,opt,name=event_value,json=eventValue,proto3" json:"event_value,omitempty"`
	Metadata   map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PushBotEventRequest) Descriptor deprecated

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

Deprecated: Use PushBotEventRequest.ProtoReflect.Descriptor instead.

func (*PushBotEventRequest) GetEventType

func (x *PushBotEventRequest) GetEventType() string

func (*PushBotEventRequest) GetEventValue

func (x *PushBotEventRequest) GetEventValue() string

func (*PushBotEventRequest) GetMetadata

func (x *PushBotEventRequest) GetMetadata() map[string]string

func (*PushBotEventRequest) GetSessionId

func (x *PushBotEventRequest) GetSessionId() string

func (*PushBotEventRequest) GetStubId

func (x *PushBotEventRequest) GetStubId() string

func (*PushBotEventRequest) ProtoMessage

func (*PushBotEventRequest) ProtoMessage()

func (*PushBotEventRequest) ProtoReflect

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

func (*PushBotEventRequest) Reset

func (x *PushBotEventRequest) Reset()

func (*PushBotEventRequest) String

func (x *PushBotEventRequest) String() string

type PushBotEventResponse

type PushBotEventResponse struct {
	Ok      bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	EventId string `protobuf:"bytes,2,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	// contains filtered or unexported fields
}

func (*PushBotEventResponse) Descriptor deprecated

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

Deprecated: Use PushBotEventResponse.ProtoReflect.Descriptor instead.

func (*PushBotEventResponse) GetEventId

func (x *PushBotEventResponse) GetEventId() string

func (*PushBotEventResponse) GetOk

func (x *PushBotEventResponse) GetOk() bool

func (*PushBotEventResponse) ProtoMessage

func (*PushBotEventResponse) ProtoMessage()

func (*PushBotEventResponse) ProtoReflect

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

func (*PushBotEventResponse) Reset

func (x *PushBotEventResponse) Reset()

func (*PushBotEventResponse) String

func (x *PushBotEventResponse) String() string

type PushBotMarkersRequest

type PushBotMarkersRequest struct {
	StubId       string                                       `protobuf:"bytes,1,opt,name=stub_id,json=stubId,proto3" json:"stub_id,omitempty"`
	SessionId    string                                       `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Markers      map[string]*PushBotMarkersRequest_MarkerList `` /* 155-byte string literal not displayed */
	SourceTaskId string                                       `protobuf:"bytes,5,opt,name=source_task_id,json=sourceTaskId,proto3" json:"source_task_id,omitempty"`
	// contains filtered or unexported fields
}

func (*PushBotMarkersRequest) Descriptor deprecated

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

Deprecated: Use PushBotMarkersRequest.ProtoReflect.Descriptor instead.

func (*PushBotMarkersRequest) GetMarkers

func (*PushBotMarkersRequest) GetSessionId

func (x *PushBotMarkersRequest) GetSessionId() string

func (*PushBotMarkersRequest) GetSourceTaskId

func (x *PushBotMarkersRequest) GetSourceTaskId() string

func (*PushBotMarkersRequest) GetStubId

func (x *PushBotMarkersRequest) GetStubId() string

func (*PushBotMarkersRequest) ProtoMessage

func (*PushBotMarkersRequest) ProtoMessage()

func (*PushBotMarkersRequest) ProtoReflect

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

func (*PushBotMarkersRequest) Reset

func (x *PushBotMarkersRequest) Reset()

func (*PushBotMarkersRequest) String

func (x *PushBotMarkersRequest) String() string

type PushBotMarkersRequest_MarkerList

type PushBotMarkersRequest_MarkerList struct {
	Markers []*Marker `protobuf:"bytes,4,rep,name=markers,proto3" json:"markers,omitempty"`
	// contains filtered or unexported fields
}

func (*PushBotMarkersRequest_MarkerList) Descriptor deprecated

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

Deprecated: Use PushBotMarkersRequest_MarkerList.ProtoReflect.Descriptor instead.

func (*PushBotMarkersRequest_MarkerList) GetMarkers

func (x *PushBotMarkersRequest_MarkerList) GetMarkers() []*Marker

func (*PushBotMarkersRequest_MarkerList) ProtoMessage

func (*PushBotMarkersRequest_MarkerList) ProtoMessage()

func (*PushBotMarkersRequest_MarkerList) ProtoReflect

func (*PushBotMarkersRequest_MarkerList) Reset

func (*PushBotMarkersRequest_MarkerList) String

type PushBotMarkersResponse

type PushBotMarkersResponse struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*PushBotMarkersResponse) Descriptor deprecated

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

Deprecated: Use PushBotMarkersResponse.ProtoReflect.Descriptor instead.

func (*PushBotMarkersResponse) GetOk

func (x *PushBotMarkersResponse) GetOk() bool

func (*PushBotMarkersResponse) ProtoMessage

func (*PushBotMarkersResponse) ProtoMessage()

func (*PushBotMarkersResponse) ProtoReflect

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

func (*PushBotMarkersResponse) Reset

func (x *PushBotMarkersResponse) Reset()

func (*PushBotMarkersResponse) String

func (x *PushBotMarkersResponse) String() string

type PutObjectRequest

type PutObjectRequest struct {
	ObjectContent  []byte          `protobuf:"bytes,1,opt,name=object_content,json=objectContent,proto3" json:"object_content,omitempty"`
	ObjectMetadata *ObjectMetadata `protobuf:"bytes,2,opt,name=object_metadata,json=objectMetadata,proto3" json:"object_metadata,omitempty"`
	Hash           string          `protobuf:"bytes,3,opt,name=hash,proto3" json:"hash,omitempty"`
	Overwrite      bool            `protobuf:"varint,4,opt,name=overwrite,proto3" json:"overwrite,omitempty"`
	// contains filtered or unexported fields
}

func (*PutObjectRequest) Descriptor deprecated

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

Deprecated: Use PutObjectRequest.ProtoReflect.Descriptor instead.

func (*PutObjectRequest) GetHash

func (x *PutObjectRequest) GetHash() string

func (*PutObjectRequest) GetObjectContent

func (x *PutObjectRequest) GetObjectContent() []byte

func (*PutObjectRequest) GetObjectMetadata

func (x *PutObjectRequest) GetObjectMetadata() *ObjectMetadata

func (*PutObjectRequest) GetOverwrite

func (x *PutObjectRequest) GetOverwrite() bool

func (*PutObjectRequest) ProtoMessage

func (*PutObjectRequest) ProtoMessage()

func (*PutObjectRequest) ProtoReflect

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

func (*PutObjectRequest) Reset

func (x *PutObjectRequest) Reset()

func (*PutObjectRequest) String

func (x *PutObjectRequest) String() string

type PutObjectResponse

type PutObjectResponse struct {
	Ok       bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ObjectId string `protobuf:"bytes,2,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"`
	ErrorMsg string `protobuf:"bytes,3,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
	// contains filtered or unexported fields
}

func (*PutObjectResponse) Descriptor deprecated

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

Deprecated: Use PutObjectResponse.ProtoReflect.Descriptor instead.

func (*PutObjectResponse) GetErrorMsg

func (x *PutObjectResponse) GetErrorMsg() string

func (*PutObjectResponse) GetObjectId

func (x *PutObjectResponse) GetObjectId() string

func (*PutObjectResponse) GetOk

func (x *PutObjectResponse) GetOk() bool

func (*PutObjectResponse) ProtoMessage

func (*PutObjectResponse) ProtoMessage()

func (*PutObjectResponse) ProtoReflect

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

func (*PutObjectResponse) Reset

func (x *PutObjectResponse) Reset()

func (*PutObjectResponse) String

func (x *PutObjectResponse) String() string

type ReplaceObjectContentOperation

type ReplaceObjectContentOperation int32
const (
	ReplaceObjectContentOperation_WRITE  ReplaceObjectContentOperation = 0
	ReplaceObjectContentOperation_DELETE ReplaceObjectContentOperation = 1
	ReplaceObjectContentOperation_MOVED  ReplaceObjectContentOperation = 2
)

func (ReplaceObjectContentOperation) Descriptor

func (ReplaceObjectContentOperation) Enum

func (ReplaceObjectContentOperation) EnumDescriptor deprecated

func (ReplaceObjectContentOperation) EnumDescriptor() ([]byte, []int)

Deprecated: Use ReplaceObjectContentOperation.Descriptor instead.

func (ReplaceObjectContentOperation) Number

func (ReplaceObjectContentOperation) String

func (ReplaceObjectContentOperation) Type

type ReplaceObjectContentRequest

type ReplaceObjectContentRequest struct {
	ObjectId string                        `protobuf:"bytes,1,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"`
	Path     string                        `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	NewPath  string                        `protobuf:"bytes,3,opt,name=new_path,json=newPath,proto3" json:"new_path,omitempty"`
	IsDir    bool                          `protobuf:"varint,4,opt,name=is_dir,json=isDir,proto3" json:"is_dir,omitempty"`
	Data     []byte                        `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"`
	Op       ReplaceObjectContentOperation `protobuf:"varint,6,opt,name=op,proto3,enum=gateway.ReplaceObjectContentOperation" json:"op,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceObjectContentRequest) Descriptor deprecated

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

Deprecated: Use ReplaceObjectContentRequest.ProtoReflect.Descriptor instead.

func (*ReplaceObjectContentRequest) GetData

func (x *ReplaceObjectContentRequest) GetData() []byte

func (*ReplaceObjectContentRequest) GetIsDir

func (x *ReplaceObjectContentRequest) GetIsDir() bool

func (*ReplaceObjectContentRequest) GetNewPath

func (x *ReplaceObjectContentRequest) GetNewPath() string

func (*ReplaceObjectContentRequest) GetObjectId

func (x *ReplaceObjectContentRequest) GetObjectId() string

func (*ReplaceObjectContentRequest) GetOp

func (*ReplaceObjectContentRequest) GetPath

func (x *ReplaceObjectContentRequest) GetPath() string

func (*ReplaceObjectContentRequest) ProtoMessage

func (*ReplaceObjectContentRequest) ProtoMessage()

func (*ReplaceObjectContentRequest) ProtoReflect

func (*ReplaceObjectContentRequest) Reset

func (x *ReplaceObjectContentRequest) Reset()

func (*ReplaceObjectContentRequest) String

func (x *ReplaceObjectContentRequest) String() string

type ReplaceObjectContentResponse

type ReplaceObjectContentResponse struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceObjectContentResponse) Descriptor deprecated

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

Deprecated: Use ReplaceObjectContentResponse.ProtoReflect.Descriptor instead.

func (*ReplaceObjectContentResponse) GetOk

func (*ReplaceObjectContentResponse) ProtoMessage

func (*ReplaceObjectContentResponse) ProtoMessage()

func (*ReplaceObjectContentResponse) ProtoReflect

func (*ReplaceObjectContentResponse) Reset

func (x *ReplaceObjectContentResponse) Reset()

func (*ReplaceObjectContentResponse) String

type RunCArchiveRequest

type RunCArchiveRequest struct {
	ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	ImageId     string `protobuf:"bytes,2,opt,name=image_id,json=imageId,proto3" json:"image_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RunCArchiveRequest) Descriptor deprecated

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

Deprecated: Use RunCArchiveRequest.ProtoReflect.Descriptor instead.

func (*RunCArchiveRequest) GetContainerId

func (x *RunCArchiveRequest) GetContainerId() string

func (*RunCArchiveRequest) GetImageId

func (x *RunCArchiveRequest) GetImageId() string

func (*RunCArchiveRequest) ProtoMessage

func (*RunCArchiveRequest) ProtoMessage()

func (*RunCArchiveRequest) ProtoReflect

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

func (*RunCArchiveRequest) Reset

func (x *RunCArchiveRequest) Reset()

func (*RunCArchiveRequest) String

func (x *RunCArchiveRequest) String() string

type RunCArchiveResponse

type RunCArchiveResponse struct {
	Done     bool   `protobuf:"varint,1,opt,name=done,proto3" json:"done,omitempty"`
	Success  bool   `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	Progress int32  `protobuf:"varint,3,opt,name=progress,proto3" json:"progress,omitempty"`
	ErrorMsg string `protobuf:"bytes,4,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
	// contains filtered or unexported fields
}

func (*RunCArchiveResponse) Descriptor deprecated

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

Deprecated: Use RunCArchiveResponse.ProtoReflect.Descriptor instead.

func (*RunCArchiveResponse) GetDone

func (x *RunCArchiveResponse) GetDone() bool

func (*RunCArchiveResponse) GetErrorMsg

func (x *RunCArchiveResponse) GetErrorMsg() string

func (*RunCArchiveResponse) GetProgress

func (x *RunCArchiveResponse) GetProgress() int32

func (*RunCArchiveResponse) GetSuccess

func (x *RunCArchiveResponse) GetSuccess() bool

func (*RunCArchiveResponse) ProtoMessage

func (*RunCArchiveResponse) ProtoMessage()

func (*RunCArchiveResponse) ProtoReflect

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

func (*RunCArchiveResponse) Reset

func (x *RunCArchiveResponse) Reset()

func (*RunCArchiveResponse) String

func (x *RunCArchiveResponse) String() string

type RunCExecRequest

type RunCExecRequest struct {
	ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	Cmd         string `protobuf:"bytes,2,opt,name=cmd,proto3" json:"cmd,omitempty"`
	// contains filtered or unexported fields
}

func (*RunCExecRequest) Descriptor deprecated

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

Deprecated: Use RunCExecRequest.ProtoReflect.Descriptor instead.

func (*RunCExecRequest) GetCmd

func (x *RunCExecRequest) GetCmd() string

func (*RunCExecRequest) GetContainerId

func (x *RunCExecRequest) GetContainerId() string

func (*RunCExecRequest) ProtoMessage

func (*RunCExecRequest) ProtoMessage()

func (*RunCExecRequest) ProtoReflect

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

func (*RunCExecRequest) Reset

func (x *RunCExecRequest) Reset()

func (*RunCExecRequest) String

func (x *RunCExecRequest) String() string

type RunCExecResponse

type RunCExecResponse struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*RunCExecResponse) Descriptor deprecated

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

Deprecated: Use RunCExecResponse.ProtoReflect.Descriptor instead.

func (*RunCExecResponse) GetOk

func (x *RunCExecResponse) GetOk() bool

func (*RunCExecResponse) ProtoMessage

func (*RunCExecResponse) ProtoMessage()

func (*RunCExecResponse) ProtoReflect

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

func (*RunCExecResponse) Reset

func (x *RunCExecResponse) Reset()

func (*RunCExecResponse) String

func (x *RunCExecResponse) String() string

type RunCKillRequest

type RunCKillRequest struct {
	ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RunCKillRequest) Descriptor deprecated

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

Deprecated: Use RunCKillRequest.ProtoReflect.Descriptor instead.

func (*RunCKillRequest) GetContainerId

func (x *RunCKillRequest) GetContainerId() string

func (*RunCKillRequest) ProtoMessage

func (*RunCKillRequest) ProtoMessage()

func (*RunCKillRequest) ProtoReflect

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

func (*RunCKillRequest) Reset

func (x *RunCKillRequest) Reset()

func (*RunCKillRequest) String

func (x *RunCKillRequest) String() string

type RunCKillResponse

type RunCKillResponse struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*RunCKillResponse) Descriptor deprecated

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

Deprecated: Use RunCKillResponse.ProtoReflect.Descriptor instead.

func (*RunCKillResponse) GetOk

func (x *RunCKillResponse) GetOk() bool

func (*RunCKillResponse) ProtoMessage

func (*RunCKillResponse) ProtoMessage()

func (*RunCKillResponse) ProtoReflect

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

func (*RunCKillResponse) Reset

func (x *RunCKillResponse) Reset()

func (*RunCKillResponse) String

func (x *RunCKillResponse) String() string

type RunCLogEntry

type RunCLogEntry struct {
	Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*RunCLogEntry) Descriptor deprecated

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

Deprecated: Use RunCLogEntry.ProtoReflect.Descriptor instead.

func (*RunCLogEntry) GetMsg

func (x *RunCLogEntry) GetMsg() string

func (*RunCLogEntry) ProtoMessage

func (*RunCLogEntry) ProtoMessage()

func (*RunCLogEntry) ProtoReflect

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

func (*RunCLogEntry) Reset

func (x *RunCLogEntry) Reset()

func (*RunCLogEntry) String

func (x *RunCLogEntry) String() string

type RunCServiceClient

type RunCServiceClient interface {
	RunCKill(ctx context.Context, in *RunCKillRequest, opts ...grpc.CallOption) (*RunCKillResponse, error)
	RunCExec(ctx context.Context, in *RunCExecRequest, opts ...grpc.CallOption) (*RunCExecResponse, error)
	RunCStatus(ctx context.Context, in *RunCStatusRequest, opts ...grpc.CallOption) (*RunCStatusResponse, error)
	RunCStreamLogs(ctx context.Context, in *RunCStreamLogsRequest, opts ...grpc.CallOption) (RunCService_RunCStreamLogsClient, error)
	RunCArchive(ctx context.Context, in *RunCArchiveRequest, opts ...grpc.CallOption) (RunCService_RunCArchiveClient, error)
}

RunCServiceClient is the client API for RunCService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type RunCServiceServer

type RunCServiceServer interface {
	RunCKill(context.Context, *RunCKillRequest) (*RunCKillResponse, error)
	RunCExec(context.Context, *RunCExecRequest) (*RunCExecResponse, error)
	RunCStatus(context.Context, *RunCStatusRequest) (*RunCStatusResponse, error)
	RunCStreamLogs(*RunCStreamLogsRequest, RunCService_RunCStreamLogsServer) error
	RunCArchive(*RunCArchiveRequest, RunCService_RunCArchiveServer) error
	// contains filtered or unexported methods
}

RunCServiceServer is the server API for RunCService service. All implementations must embed UnimplementedRunCServiceServer for forward compatibility

type RunCService_RunCArchiveClient

type RunCService_RunCArchiveClient interface {
	Recv() (*RunCArchiveResponse, error)
	grpc.ClientStream
}

type RunCService_RunCArchiveServer

type RunCService_RunCArchiveServer interface {
	Send(*RunCArchiveResponse) error
	grpc.ServerStream
}

type RunCService_RunCStreamLogsClient

type RunCService_RunCStreamLogsClient interface {
	Recv() (*RunCLogEntry, error)
	grpc.ClientStream
}

type RunCService_RunCStreamLogsServer

type RunCService_RunCStreamLogsServer interface {
	Send(*RunCLogEntry) error
	grpc.ServerStream
}

type RunCStatusRequest

type RunCStatusRequest struct {
	ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RunCStatusRequest) Descriptor deprecated

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

Deprecated: Use RunCStatusRequest.ProtoReflect.Descriptor instead.

func (*RunCStatusRequest) GetContainerId

func (x *RunCStatusRequest) GetContainerId() string

func (*RunCStatusRequest) ProtoMessage

func (*RunCStatusRequest) ProtoMessage()

func (*RunCStatusRequest) ProtoReflect

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

func (*RunCStatusRequest) Reset

func (x *RunCStatusRequest) Reset()

func (*RunCStatusRequest) String

func (x *RunCStatusRequest) String() string

type RunCStatusResponse

type RunCStatusResponse struct {
	Running bool `protobuf:"varint,1,opt,name=running,proto3" json:"running,omitempty"`
	// contains filtered or unexported fields
}

func (*RunCStatusResponse) Descriptor deprecated

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

Deprecated: Use RunCStatusResponse.ProtoReflect.Descriptor instead.

func (*RunCStatusResponse) GetRunning

func (x *RunCStatusResponse) GetRunning() bool

func (*RunCStatusResponse) ProtoMessage

func (*RunCStatusResponse) ProtoMessage()

func (*RunCStatusResponse) ProtoReflect

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

func (*RunCStatusResponse) Reset

func (x *RunCStatusResponse) Reset()

func (*RunCStatusResponse) String

func (x *RunCStatusResponse) String() string

type RunCStreamLogsRequest

type RunCStreamLogsRequest struct {
	ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RunCStreamLogsRequest) Descriptor deprecated

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

Deprecated: Use RunCStreamLogsRequest.ProtoReflect.Descriptor instead.

func (*RunCStreamLogsRequest) GetContainerId

func (x *RunCStreamLogsRequest) GetContainerId() string

func (*RunCStreamLogsRequest) ProtoMessage

func (*RunCStreamLogsRequest) ProtoMessage()

func (*RunCStreamLogsRequest) ProtoReflect

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

func (*RunCStreamLogsRequest) Reset

func (x *RunCStreamLogsRequest) Reset()

func (*RunCStreamLogsRequest) String

func (x *RunCStreamLogsRequest) String() string

type RunContainerRequest

type RunContainerRequest struct {
	ContainerId     string   `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	Env             []string `protobuf:"bytes,2,rep,name=env,proto3" json:"env,omitempty"`
	EntryPoint      []string `protobuf:"bytes,3,rep,name=entry_point,json=entryPoint,proto3" json:"entry_point,omitempty"`
	Cpu             string   `protobuf:"bytes,4,opt,name=cpu,proto3" json:"cpu,omitempty"`
	Memory          string   `protobuf:"bytes,5,opt,name=memory,proto3" json:"memory,omitempty"`
	Gpu             string   `protobuf:"bytes,6,opt,name=gpu,proto3" json:"gpu,omitempty"`
	ImageId         string   `protobuf:"bytes,10,opt,name=image_id,json=imageId,proto3" json:"image_id,omitempty"`
	ScheduleTimeout float32  `protobuf:"fixed32,12,opt,name=schedule_timeout,json=scheduleTimeout,proto3" json:"schedule_timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*RunContainerRequest) Descriptor deprecated

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

Deprecated: Use RunContainerRequest.ProtoReflect.Descriptor instead.

func (*RunContainerRequest) GetContainerId

func (x *RunContainerRequest) GetContainerId() string

func (*RunContainerRequest) GetCpu

func (x *RunContainerRequest) GetCpu() string

func (*RunContainerRequest) GetEntryPoint

func (x *RunContainerRequest) GetEntryPoint() []string

func (*RunContainerRequest) GetEnv

func (x *RunContainerRequest) GetEnv() []string

func (*RunContainerRequest) GetGpu

func (x *RunContainerRequest) GetGpu() string

func (*RunContainerRequest) GetImageId

func (x *RunContainerRequest) GetImageId() string

func (*RunContainerRequest) GetMemory

func (x *RunContainerRequest) GetMemory() string

func (*RunContainerRequest) GetScheduleTimeout

func (x *RunContainerRequest) GetScheduleTimeout() float32

func (*RunContainerRequest) ProtoMessage

func (*RunContainerRequest) ProtoMessage()

func (*RunContainerRequest) ProtoReflect

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

func (*RunContainerRequest) Reset

func (x *RunContainerRequest) Reset()

func (*RunContainerRequest) String

func (x *RunContainerRequest) String() string

type RunContainerResponse

type RunContainerResponse struct {
	Success bool   `protobuf:"varint,3,opt,name=success,proto3" json:"success,omitempty"`
	Error   string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*RunContainerResponse) Descriptor deprecated

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

Deprecated: Use RunContainerResponse.ProtoReflect.Descriptor instead.

func (*RunContainerResponse) GetError

func (x *RunContainerResponse) GetError() string

func (*RunContainerResponse) GetSuccess

func (x *RunContainerResponse) GetSuccess() bool

func (*RunContainerResponse) ProtoMessage

func (*RunContainerResponse) ProtoMessage()

func (*RunContainerResponse) ProtoReflect

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

func (*RunContainerResponse) Reset

func (x *RunContainerResponse) Reset()

func (*RunContainerResponse) String

func (x *RunContainerResponse) String() string

type SchedulerClient

type SchedulerClient interface {
	GetVersion(ctx context.Context, in *VersionRequest, opts ...grpc.CallOption) (*VersionResponse, error)
	RunContainer(ctx context.Context, in *RunContainerRequest, opts ...grpc.CallOption) (*RunContainerResponse, error)
}

SchedulerClient is the client API for Scheduler 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 NewSchedulerClient

func NewSchedulerClient(cc grpc.ClientConnInterface) SchedulerClient

type SchedulerServer

type SchedulerServer interface {
	GetVersion(context.Context, *VersionRequest) (*VersionResponse, error)
	RunContainer(context.Context, *RunContainerRequest) (*RunContainerResponse, error)
	// contains filtered or unexported methods
}

SchedulerServer is the server API for Scheduler service. All implementations must embed UnimplementedSchedulerServer for forward compatibility

type Secret

type Secret struct {
	Id            string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name          string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Value         string                 `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	LastUpdatedBy string                 `protobuf:"bytes,5,opt,name=last_updated_by,json=lastUpdatedBy,proto3" json:"last_updated_by,omitempty"`
	CreatedAt     *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt     *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Secret) Descriptor deprecated

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

Deprecated: Use Secret.ProtoReflect.Descriptor instead.

func (*Secret) GetCreatedAt

func (x *Secret) GetCreatedAt() *timestamppb.Timestamp

func (*Secret) GetId

func (x *Secret) GetId() string

func (*Secret) GetLastUpdatedBy

func (x *Secret) GetLastUpdatedBy() string

func (*Secret) GetName

func (x *Secret) GetName() string

func (*Secret) GetUpdatedAt

func (x *Secret) GetUpdatedAt() *timestamppb.Timestamp

func (*Secret) GetValue

func (x *Secret) GetValue() string

func (*Secret) ProtoMessage

func (*Secret) ProtoMessage()

func (*Secret) ProtoReflect

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

func (*Secret) Reset

func (x *Secret) Reset()

func (*Secret) String

func (x *Secret) String() string

type SecretServiceClient

type SecretServiceClient interface {
	CreateSecret(ctx context.Context, in *CreateSecretRequest, opts ...grpc.CallOption) (*CreateSecretResponse, error)
	DeleteSecret(ctx context.Context, in *DeleteSecretRequest, opts ...grpc.CallOption) (*DeleteSecretResponse, error)
	UpdateSecret(ctx context.Context, in *UpdateSecretRequest, opts ...grpc.CallOption) (*UpdateSecretResponse, error)
	GetSecret(ctx context.Context, in *GetSecretRequest, opts ...grpc.CallOption) (*GetSecretResponse, error)
	ListSecrets(ctx context.Context, in *ListSecretsRequest, opts ...grpc.CallOption) (*ListSecretsResponse, error)
}

SecretServiceClient is the client API for SecretService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type SecretServiceServer

type SecretServiceServer interface {
	CreateSecret(context.Context, *CreateSecretRequest) (*CreateSecretResponse, error)
	DeleteSecret(context.Context, *DeleteSecretRequest) (*DeleteSecretResponse, error)
	UpdateSecret(context.Context, *UpdateSecretRequest) (*UpdateSecretResponse, error)
	GetSecret(context.Context, *GetSecretRequest) (*GetSecretResponse, error)
	ListSecrets(context.Context, *ListSecretsRequest) (*ListSecretsResponse, error)
	// contains filtered or unexported methods
}

SecretServiceServer is the server API for SecretService service. All implementations must embed UnimplementedSecretServiceServer for forward compatibility

type SecretVar

type SecretVar struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*SecretVar) Descriptor deprecated

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

Deprecated: Use SecretVar.ProtoReflect.Descriptor instead.

func (*SecretVar) GetName

func (x *SecretVar) GetName() string

func (*SecretVar) ProtoMessage

func (*SecretVar) ProtoMessage()

func (*SecretVar) ProtoReflect

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

func (*SecretVar) Reset

func (x *SecretVar) Reset()

func (*SecretVar) String

func (x *SecretVar) String() string

type SignPayloadRequest

type SignPayloadRequest struct {
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*SignPayloadRequest) Descriptor deprecated

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

Deprecated: Use SignPayloadRequest.ProtoReflect.Descriptor instead.

func (*SignPayloadRequest) GetPayload

func (x *SignPayloadRequest) GetPayload() []byte

func (*SignPayloadRequest) ProtoMessage

func (*SignPayloadRequest) ProtoMessage()

func (*SignPayloadRequest) ProtoReflect

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

func (*SignPayloadRequest) Reset

func (x *SignPayloadRequest) Reset()

func (*SignPayloadRequest) String

func (x *SignPayloadRequest) String() string

type SignPayloadResponse

type SignPayloadResponse struct {
	Ok        bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Signature string `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	Timestamp int64  `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	ErrorMsg  string `protobuf:"bytes,4,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
	// contains filtered or unexported fields
}

func (*SignPayloadResponse) Descriptor deprecated

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

Deprecated: Use SignPayloadResponse.ProtoReflect.Descriptor instead.

func (*SignPayloadResponse) GetErrorMsg

func (x *SignPayloadResponse) GetErrorMsg() string

func (*SignPayloadResponse) GetOk

func (x *SignPayloadResponse) GetOk() bool

func (*SignPayloadResponse) GetSignature

func (x *SignPayloadResponse) GetSignature() string

func (*SignPayloadResponse) GetTimestamp

func (x *SignPayloadResponse) GetTimestamp() int64

func (*SignPayloadResponse) ProtoMessage

func (*SignPayloadResponse) ProtoMessage()

func (*SignPayloadResponse) ProtoReflect

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

func (*SignPayloadResponse) Reset

func (x *SignPayloadResponse) Reset()

func (*SignPayloadResponse) String

func (x *SignPayloadResponse) String() string

type SignalClearRequest

type SignalClearRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*SignalClearRequest) Descriptor deprecated

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

Deprecated: Use SignalClearRequest.ProtoReflect.Descriptor instead.

func (*SignalClearRequest) GetName

func (x *SignalClearRequest) GetName() string

func (*SignalClearRequest) ProtoMessage

func (*SignalClearRequest) ProtoMessage()

func (*SignalClearRequest) ProtoReflect

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

func (*SignalClearRequest) Reset

func (x *SignalClearRequest) Reset()

func (*SignalClearRequest) String

func (x *SignalClearRequest) String() string

type SignalClearResponse

type SignalClearResponse struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*SignalClearResponse) Descriptor deprecated

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

Deprecated: Use SignalClearResponse.ProtoReflect.Descriptor instead.

func (*SignalClearResponse) GetOk

func (x *SignalClearResponse) GetOk() bool

func (*SignalClearResponse) ProtoMessage

func (*SignalClearResponse) ProtoMessage()

func (*SignalClearResponse) ProtoReflect

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

func (*SignalClearResponse) Reset

func (x *SignalClearResponse) Reset()

func (*SignalClearResponse) String

func (x *SignalClearResponse) String() string

type SignalMonitorRequest

type SignalMonitorRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*SignalMonitorRequest) Descriptor deprecated

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

Deprecated: Use SignalMonitorRequest.ProtoReflect.Descriptor instead.

func (*SignalMonitorRequest) GetName

func (x *SignalMonitorRequest) GetName() string

func (*SignalMonitorRequest) ProtoMessage

func (*SignalMonitorRequest) ProtoMessage()

func (*SignalMonitorRequest) ProtoReflect

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

func (*SignalMonitorRequest) Reset

func (x *SignalMonitorRequest) Reset()

func (*SignalMonitorRequest) String

func (x *SignalMonitorRequest) String() string

type SignalMonitorResponse

type SignalMonitorResponse struct {
	Ok  bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Set bool `protobuf:"varint,2,opt,name=set,proto3" json:"set,omitempty"`
	// contains filtered or unexported fields
}

func (*SignalMonitorResponse) Descriptor deprecated

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

Deprecated: Use SignalMonitorResponse.ProtoReflect.Descriptor instead.

func (*SignalMonitorResponse) GetOk

func (x *SignalMonitorResponse) GetOk() bool

func (*SignalMonitorResponse) GetSet

func (x *SignalMonitorResponse) GetSet() bool

func (*SignalMonitorResponse) ProtoMessage

func (*SignalMonitorResponse) ProtoMessage()

func (*SignalMonitorResponse) ProtoReflect

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

func (*SignalMonitorResponse) Reset

func (x *SignalMonitorResponse) Reset()

func (*SignalMonitorResponse) String

func (x *SignalMonitorResponse) String() string

type SignalServiceClient

type SignalServiceClient interface {
	SignalSet(ctx context.Context, in *SignalSetRequest, opts ...grpc.CallOption) (*SignalSetResponse, error)
	SignalClear(ctx context.Context, in *SignalClearRequest, opts ...grpc.CallOption) (*SignalClearResponse, error)
	SignalMonitor(ctx context.Context, in *SignalMonitorRequest, opts ...grpc.CallOption) (SignalService_SignalMonitorClient, error)
}

SignalServiceClient is the client API for SignalService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type SignalServiceServer

type SignalServiceServer interface {
	SignalSet(context.Context, *SignalSetRequest) (*SignalSetResponse, error)
	SignalClear(context.Context, *SignalClearRequest) (*SignalClearResponse, error)
	SignalMonitor(*SignalMonitorRequest, SignalService_SignalMonitorServer) error
	// contains filtered or unexported methods
}

SignalServiceServer is the server API for SignalService service. All implementations must embed UnimplementedSignalServiceServer for forward compatibility

type SignalService_SignalMonitorClient

type SignalService_SignalMonitorClient interface {
	Recv() (*SignalMonitorResponse, error)
	grpc.ClientStream
}

type SignalService_SignalMonitorServer

type SignalService_SignalMonitorServer interface {
	Send(*SignalMonitorResponse) error
	grpc.ServerStream
}

type SignalSetRequest

type SignalSetRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Ttl  int64  `protobuf:"varint,2,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// contains filtered or unexported fields
}

func (*SignalSetRequest) Descriptor deprecated

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

Deprecated: Use SignalSetRequest.ProtoReflect.Descriptor instead.

func (*SignalSetRequest) GetName

func (x *SignalSetRequest) GetName() string

func (*SignalSetRequest) GetTtl

func (x *SignalSetRequest) GetTtl() int64

func (*SignalSetRequest) ProtoMessage

func (*SignalSetRequest) ProtoMessage()

func (*SignalSetRequest) ProtoReflect

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

func (*SignalSetRequest) Reset

func (x *SignalSetRequest) Reset()

func (*SignalSetRequest) String

func (x *SignalSetRequest) String() string

type SignalSetResponse

type SignalSetResponse struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*SignalSetResponse) Descriptor deprecated

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

Deprecated: Use SignalSetResponse.ProtoReflect.Descriptor instead.

func (*SignalSetResponse) GetOk

func (x *SignalSetResponse) GetOk() bool

func (*SignalSetResponse) ProtoMessage

func (*SignalSetResponse) ProtoMessage()

func (*SignalSetResponse) ProtoReflect

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

func (*SignalSetResponse) Reset

func (x *SignalSetResponse) Reset()

func (*SignalSetResponse) String

func (x *SignalSetResponse) String() string

type SimpleQueueEmptyResponse

type SimpleQueueEmptyResponse struct {
	Ok    bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Empty bool `protobuf:"varint,2,opt,name=empty,proto3" json:"empty,omitempty"`
	// contains filtered or unexported fields
}

func (*SimpleQueueEmptyResponse) Descriptor deprecated

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

Deprecated: Use SimpleQueueEmptyResponse.ProtoReflect.Descriptor instead.

func (*SimpleQueueEmptyResponse) GetEmpty

func (x *SimpleQueueEmptyResponse) GetEmpty() bool

func (*SimpleQueueEmptyResponse) GetOk

func (x *SimpleQueueEmptyResponse) GetOk() bool

func (*SimpleQueueEmptyResponse) ProtoMessage

func (*SimpleQueueEmptyResponse) ProtoMessage()

func (*SimpleQueueEmptyResponse) ProtoReflect

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

func (*SimpleQueueEmptyResponse) Reset

func (x *SimpleQueueEmptyResponse) Reset()

func (*SimpleQueueEmptyResponse) String

func (x *SimpleQueueEmptyResponse) String() string

type SimpleQueuePeekResponse

type SimpleQueuePeekResponse struct {
	Ok    bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*SimpleQueuePeekResponse) Descriptor deprecated

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

Deprecated: Use SimpleQueuePeekResponse.ProtoReflect.Descriptor instead.

func (*SimpleQueuePeekResponse) GetOk

func (x *SimpleQueuePeekResponse) GetOk() bool

func (*SimpleQueuePeekResponse) GetValue

func (x *SimpleQueuePeekResponse) GetValue() []byte

func (*SimpleQueuePeekResponse) ProtoMessage

func (*SimpleQueuePeekResponse) ProtoMessage()

func (*SimpleQueuePeekResponse) ProtoReflect

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

func (*SimpleQueuePeekResponse) Reset

func (x *SimpleQueuePeekResponse) Reset()

func (*SimpleQueuePeekResponse) String

func (x *SimpleQueuePeekResponse) String() string

type SimpleQueuePopRequest

type SimpleQueuePopRequest struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*SimpleQueuePopRequest) Descriptor deprecated

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

Deprecated: Use SimpleQueuePopRequest.ProtoReflect.Descriptor instead.

func (*SimpleQueuePopRequest) GetName

func (x *SimpleQueuePopRequest) GetName() string

func (*SimpleQueuePopRequest) GetValue

func (x *SimpleQueuePopRequest) GetValue() []byte

func (*SimpleQueuePopRequest) ProtoMessage

func (*SimpleQueuePopRequest) ProtoMessage()

func (*SimpleQueuePopRequest) ProtoReflect

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

func (*SimpleQueuePopRequest) Reset

func (x *SimpleQueuePopRequest) Reset()

func (*SimpleQueuePopRequest) String

func (x *SimpleQueuePopRequest) String() string

type SimpleQueuePopResponse

type SimpleQueuePopResponse struct {
	Ok    bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*SimpleQueuePopResponse) Descriptor deprecated

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

Deprecated: Use SimpleQueuePopResponse.ProtoReflect.Descriptor instead.

func (*SimpleQueuePopResponse) GetOk

func (x *SimpleQueuePopResponse) GetOk() bool

func (*SimpleQueuePopResponse) GetValue

func (x *SimpleQueuePopResponse) GetValue() []byte

func (*SimpleQueuePopResponse) ProtoMessage

func (*SimpleQueuePopResponse) ProtoMessage()

func (*SimpleQueuePopResponse) ProtoReflect

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

func (*SimpleQueuePopResponse) Reset

func (x *SimpleQueuePopResponse) Reset()

func (*SimpleQueuePopResponse) String

func (x *SimpleQueuePopResponse) String() string

type SimpleQueuePutRequest

type SimpleQueuePutRequest struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*SimpleQueuePutRequest) Descriptor deprecated

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

Deprecated: Use SimpleQueuePutRequest.ProtoReflect.Descriptor instead.

func (*SimpleQueuePutRequest) GetName

func (x *SimpleQueuePutRequest) GetName() string

func (*SimpleQueuePutRequest) GetValue

func (x *SimpleQueuePutRequest) GetValue() []byte

func (*SimpleQueuePutRequest) ProtoMessage

func (*SimpleQueuePutRequest) ProtoMessage()

func (*SimpleQueuePutRequest) ProtoReflect

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

func (*SimpleQueuePutRequest) Reset

func (x *SimpleQueuePutRequest) Reset()

func (*SimpleQueuePutRequest) String

func (x *SimpleQueuePutRequest) String() string

type SimpleQueuePutResponse

type SimpleQueuePutResponse struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*SimpleQueuePutResponse) Descriptor deprecated

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

Deprecated: Use SimpleQueuePutResponse.ProtoReflect.Descriptor instead.

func (*SimpleQueuePutResponse) GetOk

func (x *SimpleQueuePutResponse) GetOk() bool

func (*SimpleQueuePutResponse) ProtoMessage

func (*SimpleQueuePutResponse) ProtoMessage()

func (*SimpleQueuePutResponse) ProtoReflect

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

func (*SimpleQueuePutResponse) Reset

func (x *SimpleQueuePutResponse) Reset()

func (*SimpleQueuePutResponse) String

func (x *SimpleQueuePutResponse) String() string

type SimpleQueueRequest

type SimpleQueueRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*SimpleQueueRequest) Descriptor deprecated

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

Deprecated: Use SimpleQueueRequest.ProtoReflect.Descriptor instead.

func (*SimpleQueueRequest) GetName

func (x *SimpleQueueRequest) GetName() string

func (*SimpleQueueRequest) ProtoMessage

func (*SimpleQueueRequest) ProtoMessage()

func (*SimpleQueueRequest) ProtoReflect

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

func (*SimpleQueueRequest) Reset

func (x *SimpleQueueRequest) Reset()

func (*SimpleQueueRequest) String

func (x *SimpleQueueRequest) String() string

type SimpleQueueServiceClient

type SimpleQueueServiceClient interface {
	SimpleQueuePut(ctx context.Context, in *SimpleQueuePutRequest, opts ...grpc.CallOption) (*SimpleQueuePutResponse, error)
	SimpleQueuePop(ctx context.Context, in *SimpleQueuePopRequest, opts ...grpc.CallOption) (*SimpleQueuePopResponse, error)
	SimpleQueuePeek(ctx context.Context, in *SimpleQueueRequest, opts ...grpc.CallOption) (*SimpleQueuePeekResponse, error)
	SimpleQueueEmpty(ctx context.Context, in *SimpleQueueRequest, opts ...grpc.CallOption) (*SimpleQueueEmptyResponse, error)
	SimpleQueueSize(ctx context.Context, in *SimpleQueueRequest, opts ...grpc.CallOption) (*SimpleQueueSizeResponse, error)
}

SimpleQueueServiceClient is the client API for SimpleQueueService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type SimpleQueueServiceServer

type SimpleQueueServiceServer interface {
	SimpleQueuePut(context.Context, *SimpleQueuePutRequest) (*SimpleQueuePutResponse, error)
	SimpleQueuePop(context.Context, *SimpleQueuePopRequest) (*SimpleQueuePopResponse, error)
	SimpleQueuePeek(context.Context, *SimpleQueueRequest) (*SimpleQueuePeekResponse, error)
	SimpleQueueEmpty(context.Context, *SimpleQueueRequest) (*SimpleQueueEmptyResponse, error)
	SimpleQueueSize(context.Context, *SimpleQueueRequest) (*SimpleQueueSizeResponse, error)
	// contains filtered or unexported methods
}

SimpleQueueServiceServer is the server API for SimpleQueueService service. All implementations must embed UnimplementedSimpleQueueServiceServer for forward compatibility

type SimpleQueueSizeResponse

type SimpleQueueSizeResponse struct {
	Ok   bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Size uint64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*SimpleQueueSizeResponse) Descriptor deprecated

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

Deprecated: Use SimpleQueueSizeResponse.ProtoReflect.Descriptor instead.

func (*SimpleQueueSizeResponse) GetOk

func (x *SimpleQueueSizeResponse) GetOk() bool

func (*SimpleQueueSizeResponse) GetSize

func (x *SimpleQueueSizeResponse) GetSize() uint64

func (*SimpleQueueSizeResponse) ProtoMessage

func (*SimpleQueueSizeResponse) ProtoMessage()

func (*SimpleQueueSizeResponse) ProtoReflect

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

func (*SimpleQueueSizeResponse) Reset

func (x *SimpleQueueSizeResponse) Reset()

func (*SimpleQueueSizeResponse) String

func (x *SimpleQueueSizeResponse) String() string

type StartEndpointServeRequest

type StartEndpointServeRequest struct {
	StubId  string `protobuf:"bytes,1,opt,name=stub_id,json=stubId,proto3" json:"stub_id,omitempty"`
	Timeout int32  `protobuf:"varint,2,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*StartEndpointServeRequest) Descriptor deprecated

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

Deprecated: Use StartEndpointServeRequest.ProtoReflect.Descriptor instead.

func (*StartEndpointServeRequest) GetStubId

func (x *StartEndpointServeRequest) GetStubId() string

func (*StartEndpointServeRequest) GetTimeout

func (x *StartEndpointServeRequest) GetTimeout() int32

func (*StartEndpointServeRequest) ProtoMessage

func (*StartEndpointServeRequest) ProtoMessage()

func (*StartEndpointServeRequest) ProtoReflect

func (*StartEndpointServeRequest) Reset

func (x *StartEndpointServeRequest) Reset()

func (*StartEndpointServeRequest) String

func (x *StartEndpointServeRequest) String() string

type StartEndpointServeResponse

type StartEndpointServeResponse struct {
	Output   string `protobuf:"bytes,1,opt,name=output,proto3" json:"output,omitempty"`
	Done     bool   `protobuf:"varint,2,opt,name=done,proto3" json:"done,omitempty"`
	ExitCode int32  `protobuf:"varint,3,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	// contains filtered or unexported fields
}

func (*StartEndpointServeResponse) Descriptor deprecated

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

Deprecated: Use StartEndpointServeResponse.ProtoReflect.Descriptor instead.

func (*StartEndpointServeResponse) GetDone

func (x *StartEndpointServeResponse) GetDone() bool

func (*StartEndpointServeResponse) GetExitCode

func (x *StartEndpointServeResponse) GetExitCode() int32

func (*StartEndpointServeResponse) GetOutput

func (x *StartEndpointServeResponse) GetOutput() string

func (*StartEndpointServeResponse) ProtoMessage

func (*StartEndpointServeResponse) ProtoMessage()

func (*StartEndpointServeResponse) ProtoReflect

func (*StartEndpointServeResponse) Reset

func (x *StartEndpointServeResponse) Reset()

func (*StartEndpointServeResponse) String

func (x *StartEndpointServeResponse) String() string

type StartTaskQueueServeRequest

type StartTaskQueueServeRequest struct {
	StubId  string `protobuf:"bytes,1,opt,name=stub_id,json=stubId,proto3" json:"stub_id,omitempty"`
	Timeout int32  `protobuf:"varint,2,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*StartTaskQueueServeRequest) Descriptor deprecated

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

Deprecated: Use StartTaskQueueServeRequest.ProtoReflect.Descriptor instead.

func (*StartTaskQueueServeRequest) GetStubId

func (x *StartTaskQueueServeRequest) GetStubId() string

func (*StartTaskQueueServeRequest) GetTimeout

func (x *StartTaskQueueServeRequest) GetTimeout() int32

func (*StartTaskQueueServeRequest) ProtoMessage

func (*StartTaskQueueServeRequest) ProtoMessage()

func (*StartTaskQueueServeRequest) ProtoReflect

func (*StartTaskQueueServeRequest) Reset

func (x *StartTaskQueueServeRequest) Reset()

func (*StartTaskQueueServeRequest) String

func (x *StartTaskQueueServeRequest) String() string

type StartTaskQueueServeResponse

type StartTaskQueueServeResponse struct {
	Output   string `protobuf:"bytes,1,opt,name=output,proto3" json:"output,omitempty"`
	Done     bool   `protobuf:"varint,2,opt,name=done,proto3" json:"done,omitempty"`
	ExitCode int32  `protobuf:"varint,3,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	// contains filtered or unexported fields
}

func (*StartTaskQueueServeResponse) Descriptor deprecated

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

Deprecated: Use StartTaskQueueServeResponse.ProtoReflect.Descriptor instead.

func (*StartTaskQueueServeResponse) GetDone

func (x *StartTaskQueueServeResponse) GetDone() bool

func (*StartTaskQueueServeResponse) GetExitCode

func (x *StartTaskQueueServeResponse) GetExitCode() int32

func (*StartTaskQueueServeResponse) GetOutput

func (x *StartTaskQueueServeResponse) GetOutput() string

func (*StartTaskQueueServeResponse) ProtoMessage

func (*StartTaskQueueServeResponse) ProtoMessage()

func (*StartTaskQueueServeResponse) ProtoReflect

func (*StartTaskQueueServeResponse) Reset

func (x *StartTaskQueueServeResponse) Reset()

func (*StartTaskQueueServeResponse) String

func (x *StartTaskQueueServeResponse) String() string

type StartTaskRequest

type StartTaskRequest struct {
	TaskId      string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// contains filtered or unexported fields
}

Task messages

func (*StartTaskRequest) Descriptor deprecated

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

Deprecated: Use StartTaskRequest.ProtoReflect.Descriptor instead.

func (*StartTaskRequest) GetContainerId

func (x *StartTaskRequest) GetContainerId() string

func (*StartTaskRequest) GetTaskId

func (x *StartTaskRequest) GetTaskId() string

func (*StartTaskRequest) ProtoMessage

func (*StartTaskRequest) ProtoMessage()

func (*StartTaskRequest) ProtoReflect

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

func (*StartTaskRequest) Reset

func (x *StartTaskRequest) Reset()

func (*StartTaskRequest) String

func (x *StartTaskRequest) String() string

type StartTaskResponse

type StartTaskResponse struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*StartTaskResponse) Descriptor deprecated

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

Deprecated: Use StartTaskResponse.ProtoReflect.Descriptor instead.

func (*StartTaskResponse) GetOk

func (x *StartTaskResponse) GetOk() bool

func (*StartTaskResponse) ProtoMessage

func (*StartTaskResponse) ProtoMessage()

func (*StartTaskResponse) ProtoReflect

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

func (*StartTaskResponse) Reset

func (x *StartTaskResponse) Reset()

func (*StartTaskResponse) String

func (x *StartTaskResponse) String() string

type StopContainerRequest

type StopContainerRequest struct {
	ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StopContainerRequest) Descriptor deprecated

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

Deprecated: Use StopContainerRequest.ProtoReflect.Descriptor instead.

func (*StopContainerRequest) GetContainerId

func (x *StopContainerRequest) GetContainerId() string

func (*StopContainerRequest) ProtoMessage

func (*StopContainerRequest) ProtoMessage()

func (*StopContainerRequest) ProtoReflect

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

func (*StopContainerRequest) Reset

func (x *StopContainerRequest) Reset()

func (*StopContainerRequest) String

func (x *StopContainerRequest) String() string

type StopContainerResponse

type StopContainerResponse struct {
	Ok       bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrorMsg string `protobuf:"bytes,2,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
	// contains filtered or unexported fields
}

func (*StopContainerResponse) Descriptor deprecated

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

Deprecated: Use StopContainerResponse.ProtoReflect.Descriptor instead.

func (*StopContainerResponse) GetErrorMsg

func (x *StopContainerResponse) GetErrorMsg() string

func (*StopContainerResponse) GetOk

func (x *StopContainerResponse) GetOk() bool

func (*StopContainerResponse) ProtoMessage

func (*StopContainerResponse) ProtoMessage()

func (*StopContainerResponse) ProtoReflect

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

func (*StopContainerResponse) Reset

func (x *StopContainerResponse) Reset()

func (*StopContainerResponse) String

func (x *StopContainerResponse) String() string

type StopDeploymentRequest

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

func (*StopDeploymentRequest) Descriptor deprecated

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

Deprecated: Use StopDeploymentRequest.ProtoReflect.Descriptor instead.

func (*StopDeploymentRequest) GetId

func (x *StopDeploymentRequest) GetId() string

func (*StopDeploymentRequest) ProtoMessage

func (*StopDeploymentRequest) ProtoMessage()

func (*StopDeploymentRequest) ProtoReflect

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

func (*StopDeploymentRequest) Reset

func (x *StopDeploymentRequest) Reset()

func (*StopDeploymentRequest) String

func (x *StopDeploymentRequest) String() string

type StopDeploymentResponse

type StopDeploymentResponse struct {
	Ok     bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrMsg string `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	// contains filtered or unexported fields
}

func (*StopDeploymentResponse) Descriptor deprecated

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

Deprecated: Use StopDeploymentResponse.ProtoReflect.Descriptor instead.

func (*StopDeploymentResponse) GetErrMsg

func (x *StopDeploymentResponse) GetErrMsg() string

func (*StopDeploymentResponse) GetOk

func (x *StopDeploymentResponse) GetOk() bool

func (*StopDeploymentResponse) ProtoMessage

func (*StopDeploymentResponse) ProtoMessage()

func (*StopDeploymentResponse) ProtoReflect

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

func (*StopDeploymentResponse) Reset

func (x *StopDeploymentResponse) Reset()

func (*StopDeploymentResponse) String

func (x *StopDeploymentResponse) String() string

type StopEndpointServeRequest

type StopEndpointServeRequest struct {
	StubId string `protobuf:"bytes,1,opt,name=stub_id,json=stubId,proto3" json:"stub_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StopEndpointServeRequest) Descriptor deprecated

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

Deprecated: Use StopEndpointServeRequest.ProtoReflect.Descriptor instead.

func (*StopEndpointServeRequest) GetStubId

func (x *StopEndpointServeRequest) GetStubId() string

func (*StopEndpointServeRequest) ProtoMessage

func (*StopEndpointServeRequest) ProtoMessage()

func (*StopEndpointServeRequest) ProtoReflect

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

func (*StopEndpointServeRequest) Reset

func (x *StopEndpointServeRequest) Reset()

func (*StopEndpointServeRequest) String

func (x *StopEndpointServeRequest) String() string

type StopEndpointServeResponse

type StopEndpointServeResponse struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*StopEndpointServeResponse) Descriptor deprecated

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

Deprecated: Use StopEndpointServeResponse.ProtoReflect.Descriptor instead.

func (*StopEndpointServeResponse) GetOk

func (x *StopEndpointServeResponse) GetOk() bool

func (*StopEndpointServeResponse) ProtoMessage

func (*StopEndpointServeResponse) ProtoMessage()

func (*StopEndpointServeResponse) ProtoReflect

func (*StopEndpointServeResponse) Reset

func (x *StopEndpointServeResponse) Reset()

func (*StopEndpointServeResponse) String

func (x *StopEndpointServeResponse) String() string

type StopTaskQueueServeRequest

type StopTaskQueueServeRequest struct {
	StubId string `protobuf:"bytes,1,opt,name=stub_id,json=stubId,proto3" json:"stub_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StopTaskQueueServeRequest) Descriptor deprecated

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

Deprecated: Use StopTaskQueueServeRequest.ProtoReflect.Descriptor instead.

func (*StopTaskQueueServeRequest) GetStubId

func (x *StopTaskQueueServeRequest) GetStubId() string

func (*StopTaskQueueServeRequest) ProtoMessage

func (*StopTaskQueueServeRequest) ProtoMessage()

func (*StopTaskQueueServeRequest) ProtoReflect

func (*StopTaskQueueServeRequest) Reset

func (x *StopTaskQueueServeRequest) Reset()

func (*StopTaskQueueServeRequest) String

func (x *StopTaskQueueServeRequest) String() string

type StopTaskQueueServeResponse

type StopTaskQueueServeResponse struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*StopTaskQueueServeResponse) Descriptor deprecated

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

Deprecated: Use StopTaskQueueServeResponse.ProtoReflect.Descriptor instead.

func (*StopTaskQueueServeResponse) GetOk

func (x *StopTaskQueueServeResponse) GetOk() bool

func (*StopTaskQueueServeResponse) ProtoMessage

func (*StopTaskQueueServeResponse) ProtoMessage()

func (*StopTaskQueueServeResponse) ProtoReflect

func (*StopTaskQueueServeResponse) Reset

func (x *StopTaskQueueServeResponse) Reset()

func (*StopTaskQueueServeResponse) String

func (x *StopTaskQueueServeResponse) String() string

type StopTasksRequest

type StopTasksRequest struct {
	TaskIds []string `protobuf:"bytes,1,rep,name=task_ids,json=taskIds,proto3" json:"task_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*StopTasksRequest) Descriptor deprecated

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

Deprecated: Use StopTasksRequest.ProtoReflect.Descriptor instead.

func (*StopTasksRequest) GetTaskIds

func (x *StopTasksRequest) GetTaskIds() []string

func (*StopTasksRequest) ProtoMessage

func (*StopTasksRequest) ProtoMessage()

func (*StopTasksRequest) ProtoReflect

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

func (*StopTasksRequest) Reset

func (x *StopTasksRequest) Reset()

func (*StopTasksRequest) String

func (x *StopTasksRequest) String() string

type StopTasksResponse

type StopTasksResponse struct {
	Ok     bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrMsg string `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	// contains filtered or unexported fields
}

func (*StopTasksResponse) Descriptor deprecated

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

Deprecated: Use StopTasksResponse.ProtoReflect.Descriptor instead.

func (*StopTasksResponse) GetErrMsg

func (x *StopTasksResponse) GetErrMsg() string

func (*StopTasksResponse) GetOk

func (x *StopTasksResponse) GetOk() bool

func (*StopTasksResponse) ProtoMessage

func (*StopTasksResponse) ProtoMessage()

func (*StopTasksResponse) ProtoReflect

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

func (*StopTasksResponse) Reset

func (x *StopTasksResponse) Reset()

func (*StopTasksResponse) String

func (x *StopTasksResponse) String() string

type StringList

type StringList struct {
	Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*StringList) Descriptor deprecated

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

Deprecated: Use StringList.ProtoReflect.Descriptor instead.

func (*StringList) GetValues

func (x *StringList) GetValues() []string

func (*StringList) ProtoMessage

func (*StringList) ProtoMessage()

func (*StringList) ProtoReflect

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

func (*StringList) Reset

func (x *StringList) Reset()

func (*StringList) String

func (x *StringList) String() string

type Task

type Task struct {
	Id            string                 `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Status        string                 `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	ContainerId   string                 `protobuf:"bytes,4,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	StartedAt     *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	EndedAt       *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=ended_at,json=endedAt,proto3" json:"ended_at,omitempty"`
	StubId        string                 `protobuf:"bytes,7,opt,name=stub_id,json=stubId,proto3" json:"stub_id,omitempty"`
	StubName      string                 `protobuf:"bytes,8,opt,name=stub_name,json=stubName,proto3" json:"stub_name,omitempty"`
	WorkspaceId   string                 `protobuf:"bytes,9,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	WorkspaceName string                 `protobuf:"bytes,10,opt,name=workspace_name,json=workspaceName,proto3" json:"workspace_name,omitempty"`
	CreatedAt     *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt     *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Task) Descriptor deprecated

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetContainerId

func (x *Task) GetContainerId() string

func (*Task) GetCreatedAt

func (x *Task) GetCreatedAt() *timestamppb.Timestamp

func (*Task) GetEndedAt

func (x *Task) GetEndedAt() *timestamppb.Timestamp

func (*Task) GetId

func (x *Task) GetId() string

func (*Task) GetStartedAt

func (x *Task) GetStartedAt() *timestamppb.Timestamp

func (*Task) GetStatus

func (x *Task) GetStatus() string

func (*Task) GetStubId

func (x *Task) GetStubId() string

func (*Task) GetStubName

func (x *Task) GetStubName() string

func (*Task) GetUpdatedAt

func (x *Task) GetUpdatedAt() *timestamppb.Timestamp

func (*Task) GetWorkspaceId

func (x *Task) GetWorkspaceId() string

func (*Task) GetWorkspaceName

func (x *Task) GetWorkspaceName() string

func (*Task) ProtoMessage

func (*Task) ProtoMessage()

func (*Task) ProtoReflect

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

func (*Task) Reset

func (x *Task) Reset()

func (*Task) String

func (x *Task) String() string

type TaskPolicy

type TaskPolicy struct {
	Timeout    int64  `protobuf:"varint,1,opt,name=timeout,proto3" json:"timeout,omitempty"`
	MaxRetries uint32 `protobuf:"varint,2,opt,name=max_retries,json=maxRetries,proto3" json:"max_retries,omitempty"`
	Ttl        uint32 `protobuf:"varint,3,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskPolicy) Descriptor deprecated

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

Deprecated: Use TaskPolicy.ProtoReflect.Descriptor instead.

func (*TaskPolicy) GetMaxRetries

func (x *TaskPolicy) GetMaxRetries() uint32

func (*TaskPolicy) GetTimeout

func (x *TaskPolicy) GetTimeout() int64

func (*TaskPolicy) GetTtl

func (x *TaskPolicy) GetTtl() uint32

func (*TaskPolicy) ProtoMessage

func (*TaskPolicy) ProtoMessage()

func (*TaskPolicy) ProtoReflect

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

func (*TaskPolicy) Reset

func (x *TaskPolicy) Reset()

func (*TaskPolicy) String

func (x *TaskPolicy) String() string

type TaskQueueCompleteRequest

type TaskQueueCompleteRequest struct {
	TaskId            string  `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	StubId            string  `protobuf:"bytes,2,opt,name=stub_id,json=stubId,proto3" json:"stub_id,omitempty"`
	TaskDuration      float32 `protobuf:"fixed32,3,opt,name=task_duration,json=taskDuration,proto3" json:"task_duration,omitempty"`
	TaskStatus        string  `protobuf:"bytes,4,opt,name=task_status,json=taskStatus,proto3" json:"task_status,omitempty"`
	ContainerId       string  `protobuf:"bytes,5,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	ContainerHostname string  `protobuf:"bytes,6,opt,name=container_hostname,json=containerHostname,proto3" json:"container_hostname,omitempty"`
	KeepWarmSeconds   float32 `protobuf:"fixed32,7,opt,name=keep_warm_seconds,json=keepWarmSeconds,proto3" json:"keep_warm_seconds,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueCompleteRequest) Descriptor deprecated

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

Deprecated: Use TaskQueueCompleteRequest.ProtoReflect.Descriptor instead.

func (*TaskQueueCompleteRequest) GetContainerHostname

func (x *TaskQueueCompleteRequest) GetContainerHostname() string

func (*TaskQueueCompleteRequest) GetContainerId

func (x *TaskQueueCompleteRequest) GetContainerId() string

func (*TaskQueueCompleteRequest) GetKeepWarmSeconds

func (x *TaskQueueCompleteRequest) GetKeepWarmSeconds() float32

func (*TaskQueueCompleteRequest) GetStubId

func (x *TaskQueueCompleteRequest) GetStubId() string

func (*TaskQueueCompleteRequest) GetTaskDuration

func (x *TaskQueueCompleteRequest) GetTaskDuration() float32

func (*TaskQueueCompleteRequest) GetTaskId

func (x *TaskQueueCompleteRequest) GetTaskId() string

func (*TaskQueueCompleteRequest) GetTaskStatus

func (x *TaskQueueCompleteRequest) GetTaskStatus() string

func (*TaskQueueCompleteRequest) ProtoMessage

func (*TaskQueueCompleteRequest) ProtoMessage()

func (*TaskQueueCompleteRequest) ProtoReflect

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

func (*TaskQueueCompleteRequest) Reset

func (x *TaskQueueCompleteRequest) Reset()

func (*TaskQueueCompleteRequest) String

func (x *TaskQueueCompleteRequest) String() string

type TaskQueueCompleteResponse

type TaskQueueCompleteResponse struct {
	Ok      bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueCompleteResponse) Descriptor deprecated

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

Deprecated: Use TaskQueueCompleteResponse.ProtoReflect.Descriptor instead.

func (*TaskQueueCompleteResponse) GetMessage

func (x *TaskQueueCompleteResponse) GetMessage() string

func (*TaskQueueCompleteResponse) GetOk

func (x *TaskQueueCompleteResponse) GetOk() bool

func (*TaskQueueCompleteResponse) ProtoMessage

func (*TaskQueueCompleteResponse) ProtoMessage()

func (*TaskQueueCompleteResponse) ProtoReflect

func (*TaskQueueCompleteResponse) Reset

func (x *TaskQueueCompleteResponse) Reset()

func (*TaskQueueCompleteResponse) String

func (x *TaskQueueCompleteResponse) String() string

type TaskQueueLengthRequest

type TaskQueueLengthRequest struct {
	StubId string `protobuf:"bytes,1,opt,name=stub_id,json=stubId,proto3" json:"stub_id,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueLengthRequest) Descriptor deprecated

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

Deprecated: Use TaskQueueLengthRequest.ProtoReflect.Descriptor instead.

func (*TaskQueueLengthRequest) GetStubId

func (x *TaskQueueLengthRequest) GetStubId() string

func (*TaskQueueLengthRequest) ProtoMessage

func (*TaskQueueLengthRequest) ProtoMessage()

func (*TaskQueueLengthRequest) ProtoReflect

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

func (*TaskQueueLengthRequest) Reset

func (x *TaskQueueLengthRequest) Reset()

func (*TaskQueueLengthRequest) String

func (x *TaskQueueLengthRequest) String() string

type TaskQueueLengthResponse

type TaskQueueLengthResponse struct {
	Ok     bool  `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Length int64 `protobuf:"varint,2,opt,name=length,proto3" json:"length,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueLengthResponse) Descriptor deprecated

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

Deprecated: Use TaskQueueLengthResponse.ProtoReflect.Descriptor instead.

func (*TaskQueueLengthResponse) GetLength

func (x *TaskQueueLengthResponse) GetLength() int64

func (*TaskQueueLengthResponse) GetOk

func (x *TaskQueueLengthResponse) GetOk() bool

func (*TaskQueueLengthResponse) ProtoMessage

func (*TaskQueueLengthResponse) ProtoMessage()

func (*TaskQueueLengthResponse) ProtoReflect

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

func (*TaskQueueLengthResponse) Reset

func (x *TaskQueueLengthResponse) Reset()

func (*TaskQueueLengthResponse) String

func (x *TaskQueueLengthResponse) String() string

type TaskQueueMonitorRequest

type TaskQueueMonitorRequest struct {
	TaskId      string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	StubId      string `protobuf:"bytes,2,opt,name=stub_id,json=stubId,proto3" json:"stub_id,omitempty"`
	ContainerId string `protobuf:"bytes,3,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueMonitorRequest) Descriptor deprecated

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

Deprecated: Use TaskQueueMonitorRequest.ProtoReflect.Descriptor instead.

func (*TaskQueueMonitorRequest) GetContainerId

func (x *TaskQueueMonitorRequest) GetContainerId() string

func (*TaskQueueMonitorRequest) GetStubId

func (x *TaskQueueMonitorRequest) GetStubId() string

func (*TaskQueueMonitorRequest) GetTaskId

func (x *TaskQueueMonitorRequest) GetTaskId() string

func (*TaskQueueMonitorRequest) ProtoMessage

func (*TaskQueueMonitorRequest) ProtoMessage()

func (*TaskQueueMonitorRequest) ProtoReflect

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

func (*TaskQueueMonitorRequest) Reset

func (x *TaskQueueMonitorRequest) Reset()

func (*TaskQueueMonitorRequest) String

func (x *TaskQueueMonitorRequest) String() string

type TaskQueueMonitorResponse

type TaskQueueMonitorResponse struct {
	Ok        bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Cancelled bool `protobuf:"varint,2,opt,name=cancelled,proto3" json:"cancelled,omitempty"`
	Complete  bool `protobuf:"varint,3,opt,name=complete,proto3" json:"complete,omitempty"`
	TimedOut  bool `protobuf:"varint,4,opt,name=timed_out,json=timedOut,proto3" json:"timed_out,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueMonitorResponse) Descriptor deprecated

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

Deprecated: Use TaskQueueMonitorResponse.ProtoReflect.Descriptor instead.

func (*TaskQueueMonitorResponse) GetCancelled

func (x *TaskQueueMonitorResponse) GetCancelled() bool

func (*TaskQueueMonitorResponse) GetComplete

func (x *TaskQueueMonitorResponse) GetComplete() bool

func (*TaskQueueMonitorResponse) GetOk

func (x *TaskQueueMonitorResponse) GetOk() bool

func (*TaskQueueMonitorResponse) GetTimedOut

func (x *TaskQueueMonitorResponse) GetTimedOut() bool

func (*TaskQueueMonitorResponse) ProtoMessage

func (*TaskQueueMonitorResponse) ProtoMessage()

func (*TaskQueueMonitorResponse) ProtoReflect

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

func (*TaskQueueMonitorResponse) Reset

func (x *TaskQueueMonitorResponse) Reset()

func (*TaskQueueMonitorResponse) String

func (x *TaskQueueMonitorResponse) String() string

type TaskQueuePopRequest

type TaskQueuePopRequest struct {
	StubId      string `protobuf:"bytes,1,opt,name=stub_id,json=stubId,proto3" json:"stub_id,omitempty"`
	ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueuePopRequest) Descriptor deprecated

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

Deprecated: Use TaskQueuePopRequest.ProtoReflect.Descriptor instead.

func (*TaskQueuePopRequest) GetContainerId

func (x *TaskQueuePopRequest) GetContainerId() string

func (*TaskQueuePopRequest) GetStubId

func (x *TaskQueuePopRequest) GetStubId() string

func (*TaskQueuePopRequest) ProtoMessage

func (*TaskQueuePopRequest) ProtoMessage()

func (*TaskQueuePopRequest) ProtoReflect

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

func (*TaskQueuePopRequest) Reset

func (x *TaskQueuePopRequest) Reset()

func (*TaskQueuePopRequest) String

func (x *TaskQueuePopRequest) String() string

type TaskQueuePopResponse

type TaskQueuePopResponse struct {
	Ok      bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	TaskMsg []byte `protobuf:"bytes,2,opt,name=task_msg,json=taskMsg,proto3" json:"task_msg,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueuePopResponse) Descriptor deprecated

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

Deprecated: Use TaskQueuePopResponse.ProtoReflect.Descriptor instead.

func (*TaskQueuePopResponse) GetOk

func (x *TaskQueuePopResponse) GetOk() bool

func (*TaskQueuePopResponse) GetTaskMsg

func (x *TaskQueuePopResponse) GetTaskMsg() []byte

func (*TaskQueuePopResponse) ProtoMessage

func (*TaskQueuePopResponse) ProtoMessage()

func (*TaskQueuePopResponse) ProtoReflect

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

func (*TaskQueuePopResponse) Reset

func (x *TaskQueuePopResponse) Reset()

func (*TaskQueuePopResponse) String

func (x *TaskQueuePopResponse) String() string

type TaskQueuePutRequest

type TaskQueuePutRequest struct {
	StubId  string `protobuf:"bytes,1,opt,name=stub_id,json=stubId,proto3" json:"stub_id,omitempty"`
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueuePutRequest) Descriptor deprecated

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

Deprecated: Use TaskQueuePutRequest.ProtoReflect.Descriptor instead.

func (*TaskQueuePutRequest) GetPayload

func (x *TaskQueuePutRequest) GetPayload() []byte

func (*TaskQueuePutRequest) GetStubId

func (x *TaskQueuePutRequest) GetStubId() string

func (*TaskQueuePutRequest) ProtoMessage

func (*TaskQueuePutRequest) ProtoMessage()

func (*TaskQueuePutRequest) ProtoReflect

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

func (*TaskQueuePutRequest) Reset

func (x *TaskQueuePutRequest) Reset()

func (*TaskQueuePutRequest) String

func (x *TaskQueuePutRequest) String() string

type TaskQueuePutResponse

type TaskQueuePutResponse struct {
	Ok     bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueuePutResponse) Descriptor deprecated

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

Deprecated: Use TaskQueuePutResponse.ProtoReflect.Descriptor instead.

func (*TaskQueuePutResponse) GetOk

func (x *TaskQueuePutResponse) GetOk() bool

func (*TaskQueuePutResponse) GetTaskId

func (x *TaskQueuePutResponse) GetTaskId() string

func (*TaskQueuePutResponse) ProtoMessage

func (*TaskQueuePutResponse) ProtoMessage()

func (*TaskQueuePutResponse) ProtoReflect

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

func (*TaskQueuePutResponse) Reset

func (x *TaskQueuePutResponse) Reset()

func (*TaskQueuePutResponse) String

func (x *TaskQueuePutResponse) String() string

type TaskQueueServeKeepAliveRequest

type TaskQueueServeKeepAliveRequest struct {
	StubId  string `protobuf:"bytes,1,opt,name=stub_id,json=stubId,proto3" json:"stub_id,omitempty"`
	Timeout int32  `protobuf:"varint,2,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueServeKeepAliveRequest) Descriptor deprecated

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

Deprecated: Use TaskQueueServeKeepAliveRequest.ProtoReflect.Descriptor instead.

func (*TaskQueueServeKeepAliveRequest) GetStubId

func (x *TaskQueueServeKeepAliveRequest) GetStubId() string

func (*TaskQueueServeKeepAliveRequest) GetTimeout

func (x *TaskQueueServeKeepAliveRequest) GetTimeout() int32

func (*TaskQueueServeKeepAliveRequest) ProtoMessage

func (*TaskQueueServeKeepAliveRequest) ProtoMessage()

func (*TaskQueueServeKeepAliveRequest) ProtoReflect

func (*TaskQueueServeKeepAliveRequest) Reset

func (x *TaskQueueServeKeepAliveRequest) Reset()

func (*TaskQueueServeKeepAliveRequest) String

type TaskQueueServeKeepAliveResponse

type TaskQueueServeKeepAliveResponse struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueServeKeepAliveResponse) Descriptor deprecated

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

Deprecated: Use TaskQueueServeKeepAliveResponse.ProtoReflect.Descriptor instead.

func (*TaskQueueServeKeepAliveResponse) GetOk

func (*TaskQueueServeKeepAliveResponse) ProtoMessage

func (*TaskQueueServeKeepAliveResponse) ProtoMessage()

func (*TaskQueueServeKeepAliveResponse) ProtoReflect

func (*TaskQueueServeKeepAliveResponse) Reset

func (*TaskQueueServeKeepAliveResponse) String

type TaskQueueServiceClient

TaskQueueServiceClient is the client API for TaskQueueService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type TaskQueueServiceServer

TaskQueueServiceServer is the server API for TaskQueueService service. All implementations must embed UnimplementedTaskQueueServiceServer for forward compatibility

type TaskQueueService_StartTaskQueueServeClient

type TaskQueueService_StartTaskQueueServeClient interface {
	Recv() (*StartTaskQueueServeResponse, error)
	grpc.ClientStream
}

type TaskQueueService_StartTaskQueueServeServer

type TaskQueueService_StartTaskQueueServeServer interface {
	Send(*StartTaskQueueServeResponse) error
	grpc.ServerStream
}

type TaskQueueService_TaskQueueMonitorClient

type TaskQueueService_TaskQueueMonitorClient interface {
	Recv() (*TaskQueueMonitorResponse, error)
	grpc.ClientStream
}

type TaskQueueService_TaskQueueMonitorServer

type TaskQueueService_TaskQueueMonitorServer interface {
	Send(*TaskQueueMonitorResponse) error
	grpc.ServerStream
}

type ToggleTokenRequest

type ToggleTokenRequest struct {
	TokenId string `protobuf:"bytes,1,opt,name=token_id,json=tokenId,proto3" json:"token_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ToggleTokenRequest) Descriptor deprecated

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

Deprecated: Use ToggleTokenRequest.ProtoReflect.Descriptor instead.

func (*ToggleTokenRequest) GetTokenId

func (x *ToggleTokenRequest) GetTokenId() string

func (*ToggleTokenRequest) ProtoMessage

func (*ToggleTokenRequest) ProtoMessage()

func (*ToggleTokenRequest) ProtoReflect

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

func (*ToggleTokenRequest) Reset

func (x *ToggleTokenRequest) Reset()

func (*ToggleTokenRequest) String

func (x *ToggleTokenRequest) String() string

type ToggleTokenResponse

type ToggleTokenResponse struct {
	Ok     bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrMsg string `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	Token  *Token `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*ToggleTokenResponse) Descriptor deprecated

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

Deprecated: Use ToggleTokenResponse.ProtoReflect.Descriptor instead.

func (*ToggleTokenResponse) GetErrMsg

func (x *ToggleTokenResponse) GetErrMsg() string

func (*ToggleTokenResponse) GetOk

func (x *ToggleTokenResponse) GetOk() bool

func (*ToggleTokenResponse) GetToken

func (x *ToggleTokenResponse) GetToken() *Token

func (*ToggleTokenResponse) ProtoMessage

func (*ToggleTokenResponse) ProtoMessage()

func (*ToggleTokenResponse) ProtoReflect

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

func (*ToggleTokenResponse) Reset

func (x *ToggleTokenResponse) Reset()

func (*ToggleTokenResponse) String

func (x *ToggleTokenResponse) String() string

type Token

type Token struct {
	TokenId     string                 `protobuf:"bytes,1,opt,name=token_id,json=tokenId,proto3" json:"token_id,omitempty"`
	Key         string                 `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Active      bool                   `protobuf:"varint,3,opt,name=active,proto3" json:"active,omitempty"`
	Reusable    bool                   `protobuf:"varint,4,opt,name=reusable,proto3" json:"reusable,omitempty"`
	WorkspaceId *uint32                `protobuf:"varint,5,opt,name=workspace_id,json=workspaceId,proto3,oneof" json:"workspace_id,omitempty"`
	TokenType   string                 `protobuf:"bytes,6,opt,name=token_type,json=tokenType,proto3" json:"token_type,omitempty"`
	CreatedAt   *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt   *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Token) Descriptor deprecated

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

Deprecated: Use Token.ProtoReflect.Descriptor instead.

func (*Token) GetActive

func (x *Token) GetActive() bool

func (*Token) GetCreatedAt

func (x *Token) GetCreatedAt() *timestamppb.Timestamp

func (*Token) GetKey

func (x *Token) GetKey() string

func (*Token) GetReusable

func (x *Token) GetReusable() bool

func (*Token) GetTokenId

func (x *Token) GetTokenId() string

func (*Token) GetTokenType

func (x *Token) GetTokenType() string

func (*Token) GetUpdatedAt

func (x *Token) GetUpdatedAt() *timestamppb.Timestamp

func (*Token) GetWorkspaceId

func (x *Token) GetWorkspaceId() uint32

func (*Token) ProtoMessage

func (*Token) ProtoMessage()

func (*Token) ProtoReflect

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

func (*Token) Reset

func (x *Token) Reset()

func (*Token) String

func (x *Token) String() string

type UncordonWorkerRequest

type UncordonWorkerRequest struct {
	WorkerId string `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	// contains filtered or unexported fields
}

func (*UncordonWorkerRequest) Descriptor deprecated

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

Deprecated: Use UncordonWorkerRequest.ProtoReflect.Descriptor instead.

func (*UncordonWorkerRequest) GetWorkerId

func (x *UncordonWorkerRequest) GetWorkerId() string

func (*UncordonWorkerRequest) ProtoMessage

func (*UncordonWorkerRequest) ProtoMessage()

func (*UncordonWorkerRequest) ProtoReflect

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

func (*UncordonWorkerRequest) Reset

func (x *UncordonWorkerRequest) Reset()

func (*UncordonWorkerRequest) String

func (x *UncordonWorkerRequest) String() string

type UncordonWorkerResponse

type UncordonWorkerResponse struct {
	Ok     bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrMsg string `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	// contains filtered or unexported fields
}

func (*UncordonWorkerResponse) Descriptor deprecated

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

Deprecated: Use UncordonWorkerResponse.ProtoReflect.Descriptor instead.

func (*UncordonWorkerResponse) GetErrMsg

func (x *UncordonWorkerResponse) GetErrMsg() string

func (*UncordonWorkerResponse) GetOk

func (x *UncordonWorkerResponse) GetOk() bool

func (*UncordonWorkerResponse) ProtoMessage

func (*UncordonWorkerResponse) ProtoMessage()

func (*UncordonWorkerResponse) ProtoReflect

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

func (*UncordonWorkerResponse) Reset

func (x *UncordonWorkerResponse) Reset()

func (*UncordonWorkerResponse) String

func (x *UncordonWorkerResponse) String() string

type UnimplementedBotServiceServer

type UnimplementedBotServiceServer struct {
}

UnimplementedBotServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedBotServiceServer) PopBotTask

func (UnimplementedBotServiceServer) PushBotEvent

func (UnimplementedBotServiceServer) PushBotMarkers

type UnimplementedContainerServiceServer

type UnimplementedContainerServiceServer struct {
}

UnimplementedContainerServiceServer must be embedded to have forward compatible implementations.

type UnimplementedEndpointServiceServer

type UnimplementedEndpointServiceServer struct {
}

UnimplementedEndpointServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedEndpointServiceServer) StopEndpointServe

type UnimplementedFunctionServiceServer

type UnimplementedFunctionServiceServer struct {
}

UnimplementedFunctionServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedFunctionServiceServer) FunctionGetArgs

func (UnimplementedFunctionServiceServer) FunctionSchedule

func (UnimplementedFunctionServiceServer) FunctionSetResult

type UnimplementedGatewayServiceServer

type UnimplementedGatewayServiceServer struct {
}

UnimplementedGatewayServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedGatewayServiceServer) Authorize

func (UnimplementedGatewayServiceServer) CordonWorker

func (UnimplementedGatewayServiceServer) CreateMachine

func (UnimplementedGatewayServiceServer) CreateToken

func (UnimplementedGatewayServiceServer) DeleteDeployment

func (UnimplementedGatewayServiceServer) DeleteMachine

func (UnimplementedGatewayServiceServer) DeleteToken

func (UnimplementedGatewayServiceServer) DeployStub

func (UnimplementedGatewayServiceServer) DrainWorker

func (UnimplementedGatewayServiceServer) EndTask

func (UnimplementedGatewayServiceServer) GetOrCreateStub

func (UnimplementedGatewayServiceServer) GetURL

func (UnimplementedGatewayServiceServer) HeadObject

func (UnimplementedGatewayServiceServer) ListContainers

func (UnimplementedGatewayServiceServer) ListDeployments

func (UnimplementedGatewayServiceServer) ListMachines

func (UnimplementedGatewayServiceServer) ListPools

func (UnimplementedGatewayServiceServer) ListTasks

func (UnimplementedGatewayServiceServer) ListTokens

func (UnimplementedGatewayServiceServer) ListWorkers

func (UnimplementedGatewayServiceServer) PutObject

func (UnimplementedGatewayServiceServer) PutObjectStream

func (UnimplementedGatewayServiceServer) SignPayload

func (UnimplementedGatewayServiceServer) StartTask

func (UnimplementedGatewayServiceServer) StopContainer

func (UnimplementedGatewayServiceServer) StopDeployment

func (UnimplementedGatewayServiceServer) StopTasks

func (UnimplementedGatewayServiceServer) ToggleToken

func (UnimplementedGatewayServiceServer) UncordonWorker

type UnimplementedImageServiceServer

type UnimplementedImageServiceServer struct {
}

UnimplementedImageServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedImageServiceServer) BuildImage

func (UnimplementedImageServiceServer) VerifyImageBuild

type UnimplementedMachineServiceServer

type UnimplementedMachineServiceServer struct {
}

UnimplementedMachineServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedMachineServiceServer) GetGPUAvailability

type UnimplementedMapServiceServer

type UnimplementedMapServiceServer struct {
}

UnimplementedMapServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedMapServiceServer) MapCount

func (UnimplementedMapServiceServer) MapDelete

func (UnimplementedMapServiceServer) MapGet

func (UnimplementedMapServiceServer) MapKeys

func (UnimplementedMapServiceServer) MapSet

type UnimplementedOutputServiceServer

type UnimplementedOutputServiceServer struct {
}

UnimplementedOutputServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedOutputServiceServer) OutputPublicURL

func (UnimplementedOutputServiceServer) OutputSaveStream

func (UnimplementedOutputServiceServer) OutputStat

type UnimplementedRunCServiceServer

type UnimplementedRunCServiceServer struct {
}

UnimplementedRunCServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedRunCServiceServer) RunCArchive

func (UnimplementedRunCServiceServer) RunCExec

func (UnimplementedRunCServiceServer) RunCKill

func (UnimplementedRunCServiceServer) RunCStatus

func (UnimplementedRunCServiceServer) RunCStreamLogs

type UnimplementedSchedulerServer

type UnimplementedSchedulerServer struct {
}

UnimplementedSchedulerServer must be embedded to have forward compatible implementations.

func (UnimplementedSchedulerServer) GetVersion

func (UnimplementedSchedulerServer) RunContainer

type UnimplementedSecretServiceServer

type UnimplementedSecretServiceServer struct {
}

UnimplementedSecretServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSecretServiceServer) CreateSecret

func (UnimplementedSecretServiceServer) DeleteSecret

func (UnimplementedSecretServiceServer) GetSecret

func (UnimplementedSecretServiceServer) ListSecrets

func (UnimplementedSecretServiceServer) UpdateSecret

type UnimplementedSignalServiceServer

type UnimplementedSignalServiceServer struct {
}

UnimplementedSignalServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSignalServiceServer) SignalClear

func (UnimplementedSignalServiceServer) SignalMonitor

func (UnimplementedSignalServiceServer) SignalSet

type UnimplementedSimpleQueueServiceServer

type UnimplementedSimpleQueueServiceServer struct {
}

UnimplementedSimpleQueueServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSimpleQueueServiceServer) SimpleQueueEmpty

func (UnimplementedSimpleQueueServiceServer) SimpleQueuePeek

func (UnimplementedSimpleQueueServiceServer) SimpleQueuePop

func (UnimplementedSimpleQueueServiceServer) SimpleQueuePut

func (UnimplementedSimpleQueueServiceServer) SimpleQueueSize

type UnimplementedTaskQueueServiceServer

type UnimplementedTaskQueueServiceServer struct {
}

UnimplementedTaskQueueServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTaskQueueServiceServer) StopTaskQueueServe

func (UnimplementedTaskQueueServiceServer) TaskQueueComplete

func (UnimplementedTaskQueueServiceServer) TaskQueueLength

func (UnimplementedTaskQueueServiceServer) TaskQueuePop

func (UnimplementedTaskQueueServiceServer) TaskQueuePut

type UnimplementedVolumeServiceServer

type UnimplementedVolumeServiceServer struct {
}

UnimplementedVolumeServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedVolumeServiceServer) CopyPathStream

func (UnimplementedVolumeServiceServer) DeletePath

func (UnimplementedVolumeServiceServer) DeleteVolume

func (UnimplementedVolumeServiceServer) GetOrCreateVolume

func (UnimplementedVolumeServiceServer) ListPath

func (UnimplementedVolumeServiceServer) ListVolumes

func (UnimplementedVolumeServiceServer) MovePath

type UnsafeBotServiceServer

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

UnsafeBotServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to BotServiceServer will result in compilation errors.

type UnsafeContainerServiceServer

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

UnsafeContainerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ContainerServiceServer will result in compilation errors.

type UnsafeEndpointServiceServer

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

UnsafeEndpointServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EndpointServiceServer will result in compilation errors.

type UnsafeFunctionServiceServer

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

UnsafeFunctionServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FunctionServiceServer will result in compilation errors.

type UnsafeGatewayServiceServer

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

UnsafeGatewayServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to GatewayServiceServer will result in compilation errors.

type UnsafeImageServiceServer

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

UnsafeImageServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ImageServiceServer will result in compilation errors.

type UnsafeMachineServiceServer

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

UnsafeMachineServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MachineServiceServer will result in compilation errors.

type UnsafeMapServiceServer

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

UnsafeMapServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MapServiceServer will result in compilation errors.

type UnsafeOutputServiceServer

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

UnsafeOutputServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to OutputServiceServer will result in compilation errors.

type UnsafeRunCServiceServer

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

UnsafeRunCServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RunCServiceServer will result in compilation errors.

type UnsafeSchedulerServer

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

UnsafeSchedulerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SchedulerServer will result in compilation errors.

type UnsafeSecretServiceServer

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

UnsafeSecretServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SecretServiceServer will result in compilation errors.

type UnsafeSignalServiceServer

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

UnsafeSignalServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SignalServiceServer will result in compilation errors.

type UnsafeSimpleQueueServiceServer

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

UnsafeSimpleQueueServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SimpleQueueServiceServer will result in compilation errors.

type UnsafeTaskQueueServiceServer

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

UnsafeTaskQueueServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TaskQueueServiceServer will result in compilation errors.

type UnsafeVolumeServiceServer

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

UnsafeVolumeServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to VolumeServiceServer will result in compilation errors.

type UpdateSecretRequest

type UpdateSecretRequest struct {
	Name  string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSecretRequest) Descriptor deprecated

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

Deprecated: Use UpdateSecretRequest.ProtoReflect.Descriptor instead.

func (*UpdateSecretRequest) GetName

func (x *UpdateSecretRequest) GetName() string

func (*UpdateSecretRequest) GetValue

func (x *UpdateSecretRequest) GetValue() string

func (*UpdateSecretRequest) ProtoMessage

func (*UpdateSecretRequest) ProtoMessage()

func (*UpdateSecretRequest) ProtoReflect

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

func (*UpdateSecretRequest) Reset

func (x *UpdateSecretRequest) Reset()

func (*UpdateSecretRequest) String

func (x *UpdateSecretRequest) String() string

type UpdateSecretResponse

type UpdateSecretResponse struct {
	Ok     bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ErrMsg string `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSecretResponse) Descriptor deprecated

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

Deprecated: Use UpdateSecretResponse.ProtoReflect.Descriptor instead.

func (*UpdateSecretResponse) GetErrMsg

func (x *UpdateSecretResponse) GetErrMsg() string

func (*UpdateSecretResponse) GetOk

func (x *UpdateSecretResponse) GetOk() bool

func (*UpdateSecretResponse) ProtoMessage

func (*UpdateSecretResponse) ProtoMessage()

func (*UpdateSecretResponse) ProtoReflect

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

func (*UpdateSecretResponse) Reset

func (x *UpdateSecretResponse) Reset()

func (*UpdateSecretResponse) String

func (x *UpdateSecretResponse) String() string

type VerifyImageBuildRequest

type VerifyImageBuildRequest struct {
	PythonVersion    string       `protobuf:"bytes,1,opt,name=python_version,json=pythonVersion,proto3" json:"python_version,omitempty"`
	PythonPackages   []string     `protobuf:"bytes,2,rep,name=python_packages,json=pythonPackages,proto3" json:"python_packages,omitempty"`
	Commands         []string     `protobuf:"bytes,3,rep,name=commands,proto3" json:"commands,omitempty"`
	ForceRebuild     bool         `protobuf:"varint,4,opt,name=force_rebuild,json=forceRebuild,proto3" json:"force_rebuild,omitempty"`
	ExistingImageUri string       `protobuf:"bytes,5,opt,name=existing_image_uri,json=existingImageUri,proto3" json:"existing_image_uri,omitempty"`
	BuildSteps       []*BuildStep `protobuf:"bytes,6,rep,name=build_steps,json=buildSteps,proto3" json:"build_steps,omitempty"`
	EnvVars          []string     `protobuf:"bytes,7,rep,name=env_vars,json=envVars,proto3" json:"env_vars,omitempty"`
	// contains filtered or unexported fields
}

func (*VerifyImageBuildRequest) Descriptor deprecated

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

Deprecated: Use VerifyImageBuildRequest.ProtoReflect.Descriptor instead.

func (*VerifyImageBuildRequest) GetBuildSteps

func (x *VerifyImageBuildRequest) GetBuildSteps() []*BuildStep

func (*VerifyImageBuildRequest) GetCommands

func (x *VerifyImageBuildRequest) GetCommands() []string

func (*VerifyImageBuildRequest) GetEnvVars

func (x *VerifyImageBuildRequest) GetEnvVars() []string

func (*VerifyImageBuildRequest) GetExistingImageUri

func (x *VerifyImageBuildRequest) GetExistingImageUri() string

func (*VerifyImageBuildRequest) GetForceRebuild

func (x *VerifyImageBuildRequest) GetForceRebuild() bool

func (*VerifyImageBuildRequest) GetPythonPackages

func (x *VerifyImageBuildRequest) GetPythonPackages() []string

func (*VerifyImageBuildRequest) GetPythonVersion

func (x *VerifyImageBuildRequest) GetPythonVersion() string

func (*VerifyImageBuildRequest) ProtoMessage

func (*VerifyImageBuildRequest) ProtoMessage()

func (*VerifyImageBuildRequest) ProtoReflect

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

func (*VerifyImageBuildRequest) Reset

func (x *VerifyImageBuildRequest) Reset()

func (*VerifyImageBuildRequest) String

func (x *VerifyImageBuildRequest) String() string

type VerifyImageBuildResponse

type VerifyImageBuildResponse struct {
	ImageId string `protobuf:"bytes,1,opt,name=image_id,json=imageId,proto3" json:"image_id,omitempty"`
	Valid   bool   `protobuf:"varint,2,opt,name=valid,proto3" json:"valid,omitempty"`
	Exists  bool   `protobuf:"varint,3,opt,name=exists,proto3" json:"exists,omitempty"`
	// contains filtered or unexported fields
}

func (*VerifyImageBuildResponse) Descriptor deprecated

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

Deprecated: Use VerifyImageBuildResponse.ProtoReflect.Descriptor instead.

func (*VerifyImageBuildResponse) GetExists

func (x *VerifyImageBuildResponse) GetExists() bool

func (*VerifyImageBuildResponse) GetImageId

func (x *VerifyImageBuildResponse) GetImageId() string

func (*VerifyImageBuildResponse) GetValid

func (x *VerifyImageBuildResponse) GetValid() bool

func (*VerifyImageBuildResponse) ProtoMessage

func (*VerifyImageBuildResponse) ProtoMessage()

func (*VerifyImageBuildResponse) ProtoReflect

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

func (*VerifyImageBuildResponse) Reset

func (x *VerifyImageBuildResponse) Reset()

func (*VerifyImageBuildResponse) String

func (x *VerifyImageBuildResponse) String() string

type VersionRequest

type VersionRequest struct {
	// contains filtered or unexported fields
}

func (*VersionRequest) Descriptor deprecated

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

Deprecated: Use VersionRequest.ProtoReflect.Descriptor instead.

func (*VersionRequest) ProtoMessage

func (*VersionRequest) ProtoMessage()

func (*VersionRequest) ProtoReflect

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

func (*VersionRequest) Reset

func (x *VersionRequest) Reset()

func (*VersionRequest) String

func (x *VersionRequest) String() string

type VersionResponse

type VersionResponse struct {
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*VersionResponse) Descriptor deprecated

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

Deprecated: Use VersionResponse.ProtoReflect.Descriptor instead.

func (*VersionResponse) GetVersion

func (x *VersionResponse) GetVersion() string

func (*VersionResponse) ProtoMessage

func (*VersionResponse) ProtoMessage()

func (*VersionResponse) ProtoReflect

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

func (*VersionResponse) Reset

func (x *VersionResponse) Reset()

func (*VersionResponse) String

func (x *VersionResponse) String() string

type Volume

type Volume struct {
	Id        string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	MountPath string            `protobuf:"bytes,2,opt,name=mount_path,json=mountPath,proto3" json:"mount_path,omitempty"`
	Config    *MountPointConfig `protobuf:"bytes,3,opt,name=config,proto3,oneof" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*Volume) Descriptor deprecated

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

Deprecated: Use Volume.ProtoReflect.Descriptor instead.

func (*Volume) GetConfig

func (x *Volume) GetConfig() *MountPointConfig

func (*Volume) GetId

func (x *Volume) GetId() string

func (*Volume) GetMountPath

func (x *Volume) GetMountPath() string

func (*Volume) ProtoMessage

func (*Volume) ProtoMessage()

func (*Volume) ProtoReflect

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

func (*Volume) Reset

func (x *Volume) Reset()

func (*Volume) String

func (x *Volume) String() string

type VolumeInstance

type VolumeInstance struct {
	Id            string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name          string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Size          uint64                 `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	CreatedAt     *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt     *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	WorkspaceId   string                 `protobuf:"bytes,6,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	WorkspaceName string                 `protobuf:"bytes,7,opt,name=workspace_name,json=workspaceName,proto3" json:"workspace_name,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeInstance) Descriptor deprecated

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

Deprecated: Use VolumeInstance.ProtoReflect.Descriptor instead.

func (*VolumeInstance) GetCreatedAt

func (x *VolumeInstance) GetCreatedAt() *timestamppb.Timestamp

func (*VolumeInstance) GetId

func (x *VolumeInstance) GetId() string

func (*VolumeInstance) GetName

func (x *VolumeInstance) GetName() string

func (*VolumeInstance) GetSize

func (x *VolumeInstance) GetSize() uint64

func (*VolumeInstance) GetUpdatedAt

func (x *VolumeInstance) GetUpdatedAt() *timestamppb.Timestamp

func (*VolumeInstance) GetWorkspaceId

func (x *VolumeInstance) GetWorkspaceId() string

func (*VolumeInstance) GetWorkspaceName

func (x *VolumeInstance) GetWorkspaceName() string

func (*VolumeInstance) ProtoMessage

func (*VolumeInstance) ProtoMessage()

func (*VolumeInstance) ProtoReflect

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

func (*VolumeInstance) Reset

func (x *VolumeInstance) Reset()

func (*VolumeInstance) String

func (x *VolumeInstance) String() string

type VolumeServiceClient

type VolumeServiceClient interface {
	GetOrCreateVolume(ctx context.Context, in *GetOrCreateVolumeRequest, opts ...grpc.CallOption) (*GetOrCreateVolumeResponse, error)
	DeleteVolume(ctx context.Context, in *DeleteVolumeRequest, opts ...grpc.CallOption) (*DeleteVolumeResponse, error)
	ListVolumes(ctx context.Context, in *ListVolumesRequest, opts ...grpc.CallOption) (*ListVolumesResponse, error)
	ListPath(ctx context.Context, in *ListPathRequest, opts ...grpc.CallOption) (*ListPathResponse, error)
	DeletePath(ctx context.Context, in *DeletePathRequest, opts ...grpc.CallOption) (*DeletePathResponse, error)
	CopyPathStream(ctx context.Context, opts ...grpc.CallOption) (VolumeService_CopyPathStreamClient, error)
	MovePath(ctx context.Context, in *MovePathRequest, opts ...grpc.CallOption) (*MovePathResponse, error)
}

VolumeServiceClient is the client API for VolumeService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type VolumeServiceServer

VolumeServiceServer is the server API for VolumeService service. All implementations must embed UnimplementedVolumeServiceServer for forward compatibility

type VolumeService_CopyPathStreamClient

type VolumeService_CopyPathStreamClient interface {
	Send(*CopyPathRequest) error
	CloseAndRecv() (*CopyPathResponse, error)
	grpc.ClientStream
}

type VolumeService_CopyPathStreamServer

type VolumeService_CopyPathStreamServer interface {
	SendAndClose(*CopyPathResponse) error
	Recv() (*CopyPathRequest, error)
	grpc.ServerStream
}

type Worker

type Worker struct {
	Id               string       `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Status           string       `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	Gpu              string       `protobuf:"bytes,3,opt,name=gpu,proto3" json:"gpu,omitempty"`
	PoolName         string       `protobuf:"bytes,4,opt,name=pool_name,json=poolName,proto3" json:"pool_name,omitempty"`
	MachineId        string       `protobuf:"bytes,5,opt,name=machine_id,json=machineId,proto3" json:"machine_id,omitempty"`
	Priority         int32        `protobuf:"varint,6,opt,name=priority,proto3" json:"priority,omitempty"`
	TotalCpu         int64        `protobuf:"varint,7,opt,name=total_cpu,json=totalCpu,proto3" json:"total_cpu,omitempty"`
	TotalMemory      int64        `protobuf:"varint,8,opt,name=total_memory,json=totalMemory,proto3" json:"total_memory,omitempty"`
	TotalGpuCount    uint32       `protobuf:"varint,9,opt,name=total_gpu_count,json=totalGpuCount,proto3" json:"total_gpu_count,omitempty"`
	FreeCpu          int64        `protobuf:"varint,10,opt,name=free_cpu,json=freeCpu,proto3" json:"free_cpu,omitempty"`
	FreeMemory       int64        `protobuf:"varint,11,opt,name=free_memory,json=freeMemory,proto3" json:"free_memory,omitempty"`
	FreeGpuCount     uint32       `protobuf:"varint,12,opt,name=free_gpu_count,json=freeGpuCount,proto3" json:"free_gpu_count,omitempty"`
	ActiveContainers []*Container `protobuf:"bytes,13,rep,name=active_containers,json=activeContainers,proto3" json:"active_containers,omitempty"`
	BuildVersion     string       `protobuf:"bytes,14,opt,name=build_version,json=buildVersion,proto3" json:"build_version,omitempty"`
	// contains filtered or unexported fields
}

func (*Worker) Descriptor deprecated

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

Deprecated: Use Worker.ProtoReflect.Descriptor instead.

func (*Worker) GetActiveContainers

func (x *Worker) GetActiveContainers() []*Container

func (*Worker) GetBuildVersion

func (x *Worker) GetBuildVersion() string

func (*Worker) GetFreeCpu

func (x *Worker) GetFreeCpu() int64

func (*Worker) GetFreeGpuCount

func (x *Worker) GetFreeGpuCount() uint32

func (*Worker) GetFreeMemory

func (x *Worker) GetFreeMemory() int64

func (*Worker) GetGpu

func (x *Worker) GetGpu() string

func (*Worker) GetId

func (x *Worker) GetId() string

func (*Worker) GetMachineId

func (x *Worker) GetMachineId() string

func (*Worker) GetPoolName

func (x *Worker) GetPoolName() string

func (*Worker) GetPriority

func (x *Worker) GetPriority() int32

func (*Worker) GetStatus

func (x *Worker) GetStatus() string

func (*Worker) GetTotalCpu

func (x *Worker) GetTotalCpu() int64

func (*Worker) GetTotalGpuCount

func (x *Worker) GetTotalGpuCount() uint32

func (*Worker) GetTotalMemory

func (x *Worker) GetTotalMemory() int64

func (*Worker) ProtoMessage

func (*Worker) ProtoMessage()

func (*Worker) ProtoReflect

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

func (*Worker) Reset

func (x *Worker) Reset()

func (*Worker) String

func (x *Worker) String() string

Jump to

Keyboard shortcuts

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