Versions in this module Expand all Collapse all v0 v0.1.1 Sep 2, 2022 v0.1.0 Aug 28, 2022 Changes in this version + var File_flex_proto protoreflect.FileDescriptor + var File_flex_service_proto protoreflect.FileDescriptor + var FlexService_ServiceDesc = grpc.ServiceDesc + var FlexletState_name = map[int32]string + var FlexletState_value = map[string]int32 + var GetJobOutputRequest_JobOutputType_name = map[int32]string + var GetJobOutputRequest_JobOutputType_value = map[string]int32 + var JobState_name = map[int32]string + var JobState_value = map[string]int32 + func RegisterFlexServiceServer(s grpc.ServiceRegistrar, srv FlexServiceServer) + type CancelJobRequest struct + Id int64 + func (*CancelJobRequest) Descriptor() ([]byte, []int) + func (*CancelJobRequest) ProtoMessage() + func (x *CancelJobRequest) GetId() int64 + func (x *CancelJobRequest) ProtoReflect() protoreflect.Message + func (x *CancelJobRequest) Reset() + func (x *CancelJobRequest) String() string + type CancelJobResponse struct + func (*CancelJobResponse) Descriptor() ([]byte, []int) + func (*CancelJobResponse) ProtoMessage() + func (x *CancelJobResponse) ProtoReflect() protoreflect.Message + func (x *CancelJobResponse) Reset() + func (x *CancelJobResponse) String() string + type FetchPackageRequest struct + Type isFetchPackageRequest_Type + func (*FetchPackageRequest) Descriptor() ([]byte, []int) + func (*FetchPackageRequest) ProtoMessage() + func (m *FetchPackageRequest) GetType() isFetchPackageRequest_Type + func (x *FetchPackageRequest) GetHash() string + func (x *FetchPackageRequest) GetTag() string + func (x *FetchPackageRequest) ProtoReflect() protoreflect.Message + func (x *FetchPackageRequest) Reset() + func (x *FetchPackageRequest) String() string + type FetchPackageRequest_Hash struct + Hash string + type FetchPackageRequest_Tag struct + Tag string + type FetchPackageResponse struct + Location *FileLocation + func (*FetchPackageResponse) Descriptor() ([]byte, []int) + func (*FetchPackageResponse) ProtoMessage() + func (x *FetchPackageResponse) GetLocation() *FileLocation + func (x *FetchPackageResponse) ProtoReflect() protoreflect.Message + func (x *FetchPackageResponse) Reset() + func (x *FetchPackageResponse) String() string + type FileLocation struct + CanonicalUrl string + PresignedUrl string + func (*FileLocation) Descriptor() ([]byte, []int) + func (*FileLocation) ProtoMessage() + func (x *FileLocation) GetCanonicalUrl() string + func (x *FileLocation) GetPresignedUrl() string + func (x *FileLocation) ProtoReflect() protoreflect.Message + func (x *FileLocation) Reset() + func (x *FileLocation) String() string + type FlexServiceClient interface + CancelJob func(ctx context.Context, in *CancelJobRequest, opts ...grpc.CallOption) (*CancelJobResponse, error) + FetchPackage func(ctx context.Context, in *FetchPackageRequest, opts ...grpc.CallOption) (*FetchPackageResponse, error) + GetJob func(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*GetJobResponse, error) + GetJobOutput func(ctx context.Context, in *GetJobOutputRequest, opts ...grpc.CallOption) (*GetJobOutputResponse, error) + GetPackage func(ctx context.Context, in *GetPackageRequest, opts ...grpc.CallOption) (*GetPackageResponse, error) + GetStats func(ctx context.Context, in *GetStatsRequest, opts ...grpc.CallOption) (*GetStatsResponse, error) + InsertPackage func(ctx context.Context, opts ...grpc.CallOption) (FlexService_InsertPackageClient, error) + ListFlexlets func(ctx context.Context, in *ListFlexletsRequest, opts ...grpc.CallOption) (*ListFlexletsResponse, error) + ListJobs func(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error) + ListTags func(ctx context.Context, in *ListTagsRequest, opts ...grpc.CallOption) (*ListTagsResponse, error) + SubmitJob func(ctx context.Context, in *SubmitJobRequest, opts ...grpc.CallOption) (*SubmitJobResponse, error) + UpdateJobLabels func(ctx context.Context, in *UpdateJobLabelsRequest, opts ...grpc.CallOption) (*UpdateJobLabelsResponse, error) + UpdateTag func(ctx context.Context, in *UpdateTagRequest, opts ...grpc.CallOption) (*UpdateTagResponse, error) + func NewFlexServiceClient(cc grpc.ClientConnInterface) FlexServiceClient + type FlexServiceServer interface + CancelJob func(context.Context, *CancelJobRequest) (*CancelJobResponse, error) + FetchPackage func(context.Context, *FetchPackageRequest) (*FetchPackageResponse, error) + GetJob func(context.Context, *GetJobRequest) (*GetJobResponse, error) + GetJobOutput func(context.Context, *GetJobOutputRequest) (*GetJobOutputResponse, error) + GetPackage func(context.Context, *GetPackageRequest) (*GetPackageResponse, error) + GetStats func(context.Context, *GetStatsRequest) (*GetStatsResponse, error) + InsertPackage func(FlexService_InsertPackageServer) error + ListFlexlets func(context.Context, *ListFlexletsRequest) (*ListFlexletsResponse, error) + ListJobs func(context.Context, *ListJobsRequest) (*ListJobsResponse, error) + ListTags func(context.Context, *ListTagsRequest) (*ListTagsResponse, error) + SubmitJob func(context.Context, *SubmitJobRequest) (*SubmitJobResponse, error) + UpdateJobLabels func(context.Context, *UpdateJobLabelsRequest) (*UpdateJobLabelsResponse, error) + UpdateTag func(context.Context, *UpdateTagRequest) (*UpdateTagResponse, error) + type FlexService_InsertPackageClient interface + CloseAndRecv func() (*InsertPackageResponse, error) + Send func(*InsertPackageRequest) error + type FlexService_InsertPackageServer interface + Recv func() (*InsertPackageRequest, error) + SendAndClose func(*InsertPackageResponse) error + type Flexlet struct + Name string + Spec *FlexletSpec + func (*Flexlet) Descriptor() ([]byte, []int) + func (*Flexlet) ProtoMessage() + func (x *Flexlet) GetName() string + func (x *Flexlet) GetSpec() *FlexletSpec + func (x *Flexlet) ProtoReflect() protoreflect.Message + func (x *Flexlet) Reset() + func (x *Flexlet) String() string + type FlexletSpec struct + Cores int32 + func (*FlexletSpec) Descriptor() ([]byte, []int) + func (*FlexletSpec) ProtoMessage() + func (x *FlexletSpec) GetCores() int32 + func (x *FlexletSpec) ProtoReflect() protoreflect.Message + func (x *FlexletSpec) Reset() + func (x *FlexletSpec) String() string + type FlexletState int32 + const FlexletState_OFFLINE + const FlexletState_ONLINE + func (FlexletState) Descriptor() protoreflect.EnumDescriptor + func (FlexletState) EnumDescriptor() ([]byte, []int) + func (FlexletState) Type() protoreflect.EnumType + func (x FlexletState) Enum() *FlexletState + func (x FlexletState) Number() protoreflect.EnumNumber + func (x FlexletState) String() string + type FlexletStats struct + BusyCores int32 + IdleCores int32 + OfflineFlexlets int32 + OnlineFlexlets int32 + func (*FlexletStats) Descriptor() ([]byte, []int) + func (*FlexletStats) ProtoMessage() + func (x *FlexletStats) GetBusyCores() int32 + func (x *FlexletStats) GetIdleCores() int32 + func (x *FlexletStats) GetOfflineFlexlets() int32 + func (x *FlexletStats) GetOnlineFlexlets() int32 + func (x *FlexletStats) ProtoReflect() protoreflect.Message + func (x *FlexletStats) Reset() + func (x *FlexletStats) String() string + type FlexletStatus struct + CurrentJobs []*Job + Flexlet *Flexlet + State FlexletState + func (*FlexletStatus) Descriptor() ([]byte, []int) + func (*FlexletStatus) ProtoMessage() + func (x *FlexletStatus) GetCurrentJobs() []*Job + func (x *FlexletStatus) GetFlexlet() *Flexlet + func (x *FlexletStatus) GetState() FlexletState + func (x *FlexletStatus) ProtoReflect() protoreflect.Message + func (x *FlexletStatus) Reset() + func (x *FlexletStatus) String() string + type GetJobOutputRequest struct + Id int64 + Type GetJobOutputRequest_JobOutputType + func (*GetJobOutputRequest) Descriptor() ([]byte, []int) + func (*GetJobOutputRequest) ProtoMessage() + func (x *GetJobOutputRequest) GetId() int64 + func (x *GetJobOutputRequest) GetType() GetJobOutputRequest_JobOutputType + func (x *GetJobOutputRequest) ProtoReflect() protoreflect.Message + func (x *GetJobOutputRequest) Reset() + func (x *GetJobOutputRequest) String() string + type GetJobOutputRequest_JobOutputType int32 + const GetJobOutputRequest_STDERR + const GetJobOutputRequest_STDOUT + func (GetJobOutputRequest_JobOutputType) Descriptor() protoreflect.EnumDescriptor + func (GetJobOutputRequest_JobOutputType) EnumDescriptor() ([]byte, []int) + func (GetJobOutputRequest_JobOutputType) Type() protoreflect.EnumType + func (x GetJobOutputRequest_JobOutputType) Enum() *GetJobOutputRequest_JobOutputType + func (x GetJobOutputRequest_JobOutputType) Number() protoreflect.EnumNumber + func (x GetJobOutputRequest_JobOutputType) String() string + type GetJobOutputResponse struct + Location *FileLocation + func (*GetJobOutputResponse) Descriptor() ([]byte, []int) + func (*GetJobOutputResponse) ProtoMessage() + func (x *GetJobOutputResponse) GetLocation() *FileLocation + func (x *GetJobOutputResponse) ProtoReflect() protoreflect.Message + func (x *GetJobOutputResponse) Reset() + func (x *GetJobOutputResponse) String() string + type GetJobRequest struct + Id int64 + func (*GetJobRequest) Descriptor() ([]byte, []int) + func (*GetJobRequest) ProtoMessage() + func (x *GetJobRequest) GetId() int64 + func (x *GetJobRequest) ProtoReflect() protoreflect.Message + func (x *GetJobRequest) Reset() + func (x *GetJobRequest) String() string + type GetJobResponse struct + Job *JobStatus + func (*GetJobResponse) Descriptor() ([]byte, []int) + func (*GetJobResponse) ProtoMessage() + func (x *GetJobResponse) GetJob() *JobStatus + func (x *GetJobResponse) ProtoReflect() protoreflect.Message + func (x *GetJobResponse) Reset() + func (x *GetJobResponse) String() string + type GetPackageRequest struct + Type isGetPackageRequest_Type + func (*GetPackageRequest) Descriptor() ([]byte, []int) + func (*GetPackageRequest) ProtoMessage() + func (m *GetPackageRequest) GetType() isGetPackageRequest_Type + func (x *GetPackageRequest) GetHash() string + func (x *GetPackageRequest) GetTag() string + func (x *GetPackageRequest) ProtoReflect() protoreflect.Message + func (x *GetPackageRequest) Reset() + func (x *GetPackageRequest) String() string + type GetPackageRequest_Hash struct + Hash string + type GetPackageRequest_Tag struct + Tag string + type GetPackageResponse struct + Package *Package + func (*GetPackageResponse) Descriptor() ([]byte, []int) + func (*GetPackageResponse) ProtoMessage() + func (x *GetPackageResponse) GetPackage() *Package + func (x *GetPackageResponse) ProtoReflect() protoreflect.Message + func (x *GetPackageResponse) Reset() + func (x *GetPackageResponse) String() string + type GetStatsRequest struct + func (*GetStatsRequest) Descriptor() ([]byte, []int) + func (*GetStatsRequest) ProtoMessage() + func (x *GetStatsRequest) ProtoReflect() protoreflect.Message + func (x *GetStatsRequest) Reset() + func (x *GetStatsRequest) String() string + type GetStatsResponse struct + Stats *Stats + func (*GetStatsResponse) Descriptor() ([]byte, []int) + func (*GetStatsResponse) ProtoMessage() + func (x *GetStatsResponse) GetStats() *Stats + func (x *GetStatsResponse) ProtoReflect() protoreflect.Message + func (x *GetStatsResponse) Reset() + func (x *GetStatsResponse) String() string + type InsertPackageRequest struct + Type isInsertPackageRequest_Type + func (*InsertPackageRequest) Descriptor() ([]byte, []int) + func (*InsertPackageRequest) ProtoMessage() + func (m *InsertPackageRequest) GetType() isInsertPackageRequest_Type + func (x *InsertPackageRequest) GetData() []byte + func (x *InsertPackageRequest) GetSpec() *PackageSpec + func (x *InsertPackageRequest) ProtoReflect() protoreflect.Message + func (x *InsertPackageRequest) Reset() + func (x *InsertPackageRequest) String() string + type InsertPackageRequest_Data struct + Data []byte + type InsertPackageRequest_Spec struct + Spec *PackageSpec + type InsertPackageResponse struct + Hash string + func (*InsertPackageResponse) Descriptor() ([]byte, []int) + func (*InsertPackageResponse) ProtoMessage() + func (x *InsertPackageResponse) GetHash() string + func (x *InsertPackageResponse) ProtoReflect() protoreflect.Message + func (x *InsertPackageResponse) Reset() + func (x *InsertPackageResponse) String() string + type Job struct + Id int64 + Spec *JobSpec + func (*Job) Descriptor() ([]byte, []int) + func (*Job) ProtoMessage() + func (x *Job) GetId() int64 + func (x *Job) GetSpec() *JobSpec + func (x *Job) ProtoReflect() protoreflect.Message + func (x *Job) Reset() + func (x *Job) String() string + type JobAnnotations struct + Labels []string + func (*JobAnnotations) Descriptor() ([]byte, []int) + func (*JobAnnotations) ProtoMessage() + func (x *JobAnnotations) GetLabels() []string + func (x *JobAnnotations) ProtoReflect() protoreflect.Message + func (x *JobAnnotations) Reset() + func (x *JobAnnotations) String() string + type JobCommand struct + Args []string + func (*JobCommand) Descriptor() ([]byte, []int) + func (*JobCommand) ProtoMessage() + func (x *JobCommand) GetArgs() []string + func (x *JobCommand) ProtoReflect() protoreflect.Message + func (x *JobCommand) Reset() + func (x *JobCommand) String() string + type JobConstraints struct + Priority int32 + func (*JobConstraints) Descriptor() ([]byte, []int) + func (*JobConstraints) ProtoMessage() + func (x *JobConstraints) GetPriority() int32 + func (x *JobConstraints) ProtoReflect() protoreflect.Message + func (x *JobConstraints) Reset() + func (x *JobConstraints) String() string + type JobInputs struct + Packages []*JobPackage + func (*JobInputs) Descriptor() ([]byte, []int) + func (*JobInputs) ProtoMessage() + func (x *JobInputs) GetPackages() []*JobPackage + func (x *JobInputs) ProtoReflect() protoreflect.Message + func (x *JobInputs) Reset() + func (x *JobInputs) String() string + type JobLimits struct + Time *durationpb.Duration + func (*JobLimits) Descriptor() ([]byte, []int) + func (*JobLimits) ProtoMessage() + func (x *JobLimits) GetTime() *durationpb.Duration + func (x *JobLimits) ProtoReflect() protoreflect.Message + func (x *JobLimits) Reset() + func (x *JobLimits) String() string + type JobPackage struct + Hash string + InstallDir string + Tag string + func (*JobPackage) Descriptor() ([]byte, []int) + func (*JobPackage) ProtoMessage() + func (x *JobPackage) GetHash() string + func (x *JobPackage) GetInstallDir() string + func (x *JobPackage) GetTag() string + func (x *JobPackage) ProtoReflect() protoreflect.Message + func (x *JobPackage) Reset() + func (x *JobPackage) String() string + type JobSpec struct + Annotations *JobAnnotations + Command *JobCommand + Constraints *JobConstraints + Inputs *JobInputs + Limits *JobLimits + func (*JobSpec) Descriptor() ([]byte, []int) + func (*JobSpec) ProtoMessage() + func (x *JobSpec) GetAnnotations() *JobAnnotations + func (x *JobSpec) GetCommand() *JobCommand + func (x *JobSpec) GetConstraints() *JobConstraints + func (x *JobSpec) GetInputs() *JobInputs + func (x *JobSpec) GetLimits() *JobLimits + func (x *JobSpec) ProtoReflect() protoreflect.Message + func (x *JobSpec) Reset() + func (x *JobSpec) String() string + type JobState int32 + const JobState_FINISHED + const JobState_PENDING + const JobState_RUNNING + const JobState_UNSPECIFIED + func (JobState) Descriptor() protoreflect.EnumDescriptor + func (JobState) EnumDescriptor() ([]byte, []int) + func (JobState) Type() protoreflect.EnumType + func (x JobState) Enum() *JobState + func (x JobState) Number() protoreflect.EnumNumber + func (x JobState) String() string + type JobStats struct + PendingJobs int32 + RunningJobs int32 + func (*JobStats) Descriptor() ([]byte, []int) + func (*JobStats) ProtoMessage() + func (x *JobStats) GetPendingJobs() int32 + func (x *JobStats) GetRunningJobs() int32 + func (x *JobStats) ProtoReflect() protoreflect.Message + func (x *JobStats) Reset() + func (x *JobStats) String() string + type JobStatus struct + Created *timestamppb.Timestamp + Finished *timestamppb.Timestamp + FlexletName string + Job *Job + Result *TaskResult + Started *timestamppb.Timestamp + State JobState + TaskId string + func (*JobStatus) Descriptor() ([]byte, []int) + func (*JobStatus) ProtoMessage() + func (x *JobStatus) GetCreated() *timestamppb.Timestamp + func (x *JobStatus) GetFinished() *timestamppb.Timestamp + func (x *JobStatus) GetFlexletName() string + func (x *JobStatus) GetJob() *Job + func (x *JobStatus) GetResult() *TaskResult + func (x *JobStatus) GetStarted() *timestamppb.Timestamp + func (x *JobStatus) GetState() JobState + func (x *JobStatus) GetTaskId() string + func (x *JobStatus) ProtoReflect() protoreflect.Message + func (x *JobStatus) Reset() + func (x *JobStatus) String() string + type ListFlexletsRequest struct + func (*ListFlexletsRequest) Descriptor() ([]byte, []int) + func (*ListFlexletsRequest) ProtoMessage() + func (x *ListFlexletsRequest) ProtoReflect() protoreflect.Message + func (x *ListFlexletsRequest) Reset() + func (x *ListFlexletsRequest) String() string + type ListFlexletsResponse struct + Flexlets []*FlexletStatus + func (*ListFlexletsResponse) Descriptor() ([]byte, []int) + func (*ListFlexletsResponse) ProtoMessage() + func (x *ListFlexletsResponse) GetFlexlets() []*FlexletStatus + func (x *ListFlexletsResponse) ProtoReflect() protoreflect.Message + func (x *ListFlexletsResponse) Reset() + func (x *ListFlexletsResponse) String() string + type ListJobsRequest struct + BeforeId int64 + Label string + Limit int64 + State JobState + func (*ListJobsRequest) Descriptor() ([]byte, []int) + func (*ListJobsRequest) ProtoMessage() + func (x *ListJobsRequest) GetBeforeId() int64 + func (x *ListJobsRequest) GetLabel() string + func (x *ListJobsRequest) GetLimit() int64 + func (x *ListJobsRequest) GetState() JobState + func (x *ListJobsRequest) ProtoReflect() protoreflect.Message + func (x *ListJobsRequest) Reset() + func (x *ListJobsRequest) String() string + type ListJobsResponse struct + Jobs []*JobStatus + func (*ListJobsResponse) Descriptor() ([]byte, []int) + func (*ListJobsResponse) ProtoMessage() + func (x *ListJobsResponse) GetJobs() []*JobStatus + func (x *ListJobsResponse) ProtoReflect() protoreflect.Message + func (x *ListJobsResponse) Reset() + func (x *ListJobsResponse) String() string + type ListTagsRequest struct + func (*ListTagsRequest) Descriptor() ([]byte, []int) + func (*ListTagsRequest) ProtoMessage() + func (x *ListTagsRequest) ProtoReflect() protoreflect.Message + func (x *ListTagsRequest) Reset() + func (x *ListTagsRequest) String() string + type ListTagsResponse struct + Tags []*Tag + func (*ListTagsResponse) Descriptor() ([]byte, []int) + func (*ListTagsResponse) ProtoMessage() + func (x *ListTagsResponse) GetTags() []*Tag + func (x *ListTagsResponse) ProtoReflect() protoreflect.Message + func (x *ListTagsResponse) Reset() + func (x *ListTagsResponse) String() string + type Package struct + Hash string + Spec *PackageSpec + func (*Package) Descriptor() ([]byte, []int) + func (*Package) ProtoMessage() + func (x *Package) GetHash() string + func (x *Package) GetSpec() *PackageSpec + func (x *Package) ProtoReflect() protoreflect.Message + func (x *Package) Reset() + func (x *Package) String() string + type PackageSpec struct + func (*PackageSpec) Descriptor() ([]byte, []int) + func (*PackageSpec) ProtoMessage() + func (x *PackageSpec) ProtoReflect() protoreflect.Message + func (x *PackageSpec) Reset() + func (x *PackageSpec) String() string + type Stats struct + Flexlet *FlexletStats + Job *JobStats + func (*Stats) Descriptor() ([]byte, []int) + func (*Stats) ProtoMessage() + func (x *Stats) GetFlexlet() *FlexletStats + func (x *Stats) GetJob() *JobStats + func (x *Stats) ProtoReflect() protoreflect.Message + func (x *Stats) Reset() + func (x *Stats) String() string + type SubmitJobRequest struct + Spec *JobSpec + func (*SubmitJobRequest) Descriptor() ([]byte, []int) + func (*SubmitJobRequest) ProtoMessage() + func (x *SubmitJobRequest) GetSpec() *JobSpec + func (x *SubmitJobRequest) ProtoReflect() protoreflect.Message + func (x *SubmitJobRequest) Reset() + func (x *SubmitJobRequest) String() string + type SubmitJobResponse struct + Id int64 + func (*SubmitJobResponse) Descriptor() ([]byte, []int) + func (*SubmitJobResponse) ProtoMessage() + func (x *SubmitJobResponse) GetId() int64 + func (x *SubmitJobResponse) ProtoReflect() protoreflect.Message + func (x *SubmitJobResponse) Reset() + func (x *SubmitJobResponse) String() string + type Tag struct + Hash string + Name string + func (*Tag) Descriptor() ([]byte, []int) + func (*Tag) ProtoMessage() + func (x *Tag) GetHash() string + func (x *Tag) GetName() string + func (x *Tag) ProtoReflect() protoreflect.Message + func (x *Tag) Reset() + func (x *Tag) String() string + type TaskResult struct + ExitCode int32 + Message string + Time *durationpb.Duration + func (*TaskResult) Descriptor() ([]byte, []int) + func (*TaskResult) ProtoMessage() + func (x *TaskResult) GetExitCode() int32 + func (x *TaskResult) GetMessage() string + func (x *TaskResult) GetTime() *durationpb.Duration + func (x *TaskResult) ProtoReflect() protoreflect.Message + func (x *TaskResult) Reset() + func (x *TaskResult) String() string + type UnimplementedFlexServiceServer struct + func (UnimplementedFlexServiceServer) CancelJob(context.Context, *CancelJobRequest) (*CancelJobResponse, error) + func (UnimplementedFlexServiceServer) FetchPackage(context.Context, *FetchPackageRequest) (*FetchPackageResponse, error) + func (UnimplementedFlexServiceServer) GetJob(context.Context, *GetJobRequest) (*GetJobResponse, error) + func (UnimplementedFlexServiceServer) GetJobOutput(context.Context, *GetJobOutputRequest) (*GetJobOutputResponse, error) + func (UnimplementedFlexServiceServer) GetPackage(context.Context, *GetPackageRequest) (*GetPackageResponse, error) + func (UnimplementedFlexServiceServer) GetStats(context.Context, *GetStatsRequest) (*GetStatsResponse, error) + func (UnimplementedFlexServiceServer) InsertPackage(FlexService_InsertPackageServer) error + func (UnimplementedFlexServiceServer) ListFlexlets(context.Context, *ListFlexletsRequest) (*ListFlexletsResponse, error) + func (UnimplementedFlexServiceServer) ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error) + func (UnimplementedFlexServiceServer) ListTags(context.Context, *ListTagsRequest) (*ListTagsResponse, error) + func (UnimplementedFlexServiceServer) SubmitJob(context.Context, *SubmitJobRequest) (*SubmitJobResponse, error) + func (UnimplementedFlexServiceServer) UpdateJobLabels(context.Context, *UpdateJobLabelsRequest) (*UpdateJobLabelsResponse, error) + func (UnimplementedFlexServiceServer) UpdateTag(context.Context, *UpdateTagRequest) (*UpdateTagResponse, error) + type UnsafeFlexServiceServer interface + type UpdateJobLabelsRequest struct + Adds []string + Dels []string + Id int64 + func (*UpdateJobLabelsRequest) Descriptor() ([]byte, []int) + func (*UpdateJobLabelsRequest) ProtoMessage() + func (x *UpdateJobLabelsRequest) GetAdds() []string + func (x *UpdateJobLabelsRequest) GetDels() []string + func (x *UpdateJobLabelsRequest) GetId() int64 + func (x *UpdateJobLabelsRequest) ProtoReflect() protoreflect.Message + func (x *UpdateJobLabelsRequest) Reset() + func (x *UpdateJobLabelsRequest) String() string + type UpdateJobLabelsResponse struct + func (*UpdateJobLabelsResponse) Descriptor() ([]byte, []int) + func (*UpdateJobLabelsResponse) ProtoMessage() + func (x *UpdateJobLabelsResponse) ProtoReflect() protoreflect.Message + func (x *UpdateJobLabelsResponse) Reset() + func (x *UpdateJobLabelsResponse) String() string + type UpdateTagRequest struct + Tag *Tag + func (*UpdateTagRequest) Descriptor() ([]byte, []int) + func (*UpdateTagRequest) ProtoMessage() + func (x *UpdateTagRequest) GetTag() *Tag + func (x *UpdateTagRequest) ProtoReflect() protoreflect.Message + func (x *UpdateTagRequest) Reset() + func (x *UpdateTagRequest) String() string + type UpdateTagResponse struct + func (*UpdateTagResponse) Descriptor() ([]byte, []int) + func (*UpdateTagResponse) ProtoMessage() + func (x *UpdateTagResponse) ProtoReflect() protoreflect.Message + func (x *UpdateTagResponse) Reset() + func (x *UpdateTagResponse) String() string
Go to main page