Documentation ¶
Overview ¶
Package pipelinev1alpha is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Variables
- func RegisterPipelineServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterPipelineServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client PipelineServiceClient) error
- func RegisterPipelineServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterPipelineServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server PipelineServiceServer) error
- func RegisterPipelineServiceServer(s grpc.ServiceRegistrar, srv PipelineServiceServer)
- type ActivatePipelineRequest
- func (*ActivatePipelineRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ActivatePipelineRequest) GetName() string
- func (*ActivatePipelineRequest) ProtoMessage()
- func (x *ActivatePipelineRequest) ProtoReflect() protoreflect.Message
- func (x *ActivatePipelineRequest) Reset()
- func (x *ActivatePipelineRequest) String() string
- type ActivatePipelineResponse
- func (*ActivatePipelineResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ActivatePipelineResponse) GetPipeline() *Pipeline
- func (*ActivatePipelineResponse) ProtoMessage()
- func (x *ActivatePipelineResponse) ProtoReflect() protoreflect.Message
- func (x *ActivatePipelineResponse) Reset()
- func (x *ActivatePipelineResponse) String() string
- type CreatePipelineRequest
- func (*CreatePipelineRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreatePipelineRequest) GetPipeline() *Pipeline
- func (*CreatePipelineRequest) ProtoMessage()
- func (x *CreatePipelineRequest) ProtoReflect() protoreflect.Message
- func (x *CreatePipelineRequest) Reset()
- func (x *CreatePipelineRequest) String() string
- type CreatePipelineResponse
- func (*CreatePipelineResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreatePipelineResponse) GetPipeline() *Pipeline
- func (*CreatePipelineResponse) ProtoMessage()
- func (x *CreatePipelineResponse) ProtoReflect() protoreflect.Message
- func (x *CreatePipelineResponse) Reset()
- func (x *CreatePipelineResponse) String() string
- type DeactivatePipelineRequest
- func (*DeactivatePipelineRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeactivatePipelineRequest) GetName() string
- func (*DeactivatePipelineRequest) ProtoMessage()
- func (x *DeactivatePipelineRequest) ProtoReflect() protoreflect.Message
- func (x *DeactivatePipelineRequest) Reset()
- func (x *DeactivatePipelineRequest) String() string
- type DeactivatePipelineResponse
- func (*DeactivatePipelineResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeactivatePipelineResponse) GetPipeline() *Pipeline
- func (*DeactivatePipelineResponse) ProtoMessage()
- func (x *DeactivatePipelineResponse) ProtoReflect() protoreflect.Message
- func (x *DeactivatePipelineResponse) Reset()
- func (x *DeactivatePipelineResponse) String() string
- type DeletePipelineRequest
- func (*DeletePipelineRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeletePipelineRequest) GetName() string
- func (*DeletePipelineRequest) ProtoMessage()
- func (x *DeletePipelineRequest) ProtoReflect() protoreflect.Message
- func (x *DeletePipelineRequest) Reset()
- func (x *DeletePipelineRequest) String() string
- type DeletePipelineResponse
- type GetPipelineRequest
- func (*GetPipelineRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetPipelineRequest) GetName() string
- func (x *GetPipelineRequest) GetView() View
- func (*GetPipelineRequest) ProtoMessage()
- func (x *GetPipelineRequest) ProtoReflect() protoreflect.Message
- func (x *GetPipelineRequest) Reset()
- func (x *GetPipelineRequest) String() string
- type GetPipelineResponse
- func (*GetPipelineResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetPipelineResponse) GetPipeline() *Pipeline
- func (*GetPipelineResponse) ProtoMessage()
- func (x *GetPipelineResponse) ProtoReflect() protoreflect.Message
- func (x *GetPipelineResponse) Reset()
- func (x *GetPipelineResponse) String() string
- type Input
- func (*Input) Descriptor() ([]byte, []int)deprecated
- func (x *Input) GetImageBase64() string
- func (x *Input) GetImageUrl() string
- func (m *Input) GetType() isInput_Type
- func (*Input) ProtoMessage()
- func (x *Input) ProtoReflect() protoreflect.Message
- func (x *Input) Reset()
- func (x *Input) String() string
- type Input_ImageBase64
- type Input_ImageUrl
- type ListPipelineRequest
- func (*ListPipelineRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListPipelineRequest) GetFilter() string
- func (x *ListPipelineRequest) GetPageSize() int64
- func (x *ListPipelineRequest) GetPageToken() string
- func (x *ListPipelineRequest) GetView() View
- func (*ListPipelineRequest) ProtoMessage()
- func (x *ListPipelineRequest) ProtoReflect() protoreflect.Message
- func (x *ListPipelineRequest) Reset()
- func (x *ListPipelineRequest) String() string
- type ListPipelineResponse
- func (*ListPipelineResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListPipelineResponse) GetNextPageToken() string
- func (x *ListPipelineResponse) GetPipelines() []*Pipeline
- func (x *ListPipelineResponse) GetTotalSize() int64
- func (*ListPipelineResponse) ProtoMessage()
- func (x *ListPipelineResponse) ProtoReflect() protoreflect.Message
- func (x *ListPipelineResponse) Reset()
- func (x *ListPipelineResponse) String() string
- type LivenessRequest
- func (*LivenessRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LivenessRequest) GetHealthCheckRequest() *v1alpha.HealthCheckRequest
- func (*LivenessRequest) ProtoMessage()
- func (x *LivenessRequest) ProtoReflect() protoreflect.Message
- func (x *LivenessRequest) Reset()
- func (x *LivenessRequest) String() string
- type LivenessResponse
- func (*LivenessResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LivenessResponse) GetHealthCheckResponse() *v1alpha.HealthCheckResponse
- func (*LivenessResponse) ProtoMessage()
- func (x *LivenessResponse) ProtoReflect() protoreflect.Message
- func (x *LivenessResponse) Reset()
- func (x *LivenessResponse) String() string
- type LookUpPipelineRequest
- func (*LookUpPipelineRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LookUpPipelineRequest) GetPermalink() string
- func (x *LookUpPipelineRequest) GetView() View
- func (*LookUpPipelineRequest) ProtoMessage()
- func (x *LookUpPipelineRequest) ProtoReflect() protoreflect.Message
- func (x *LookUpPipelineRequest) Reset()
- func (x *LookUpPipelineRequest) String() string
- type LookUpPipelineResponse
- func (*LookUpPipelineResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LookUpPipelineResponse) GetPipeline() *Pipeline
- func (*LookUpPipelineResponse) ProtoMessage()
- func (x *LookUpPipelineResponse) ProtoReflect() protoreflect.Message
- func (x *LookUpPipelineResponse) Reset()
- func (x *LookUpPipelineResponse) String() string
- type ModelInstanceOutput
- func (*ModelInstanceOutput) Descriptor() ([]byte, []int)deprecated
- func (x *ModelInstanceOutput) GetModelInstance() string
- func (x *ModelInstanceOutput) GetTask() v1alpha.ModelInstance_Task
- func (x *ModelInstanceOutput) GetTaskOutputs() []*TaskOutput
- func (*ModelInstanceOutput) ProtoMessage()
- func (x *ModelInstanceOutput) ProtoReflect() protoreflect.Message
- func (x *ModelInstanceOutput) Reset()
- func (x *ModelInstanceOutput) String() string
- type Pipeline
- func (*Pipeline) Descriptor() ([]byte, []int)deprecated
- func (x *Pipeline) GetCreateTime() *timestamppb.Timestamp
- func (x *Pipeline) GetDescription() string
- func (x *Pipeline) GetId() string
- func (x *Pipeline) GetMode() Pipeline_Mode
- func (x *Pipeline) GetName() string
- func (x *Pipeline) GetOrg() string
- func (m *Pipeline) GetOwner() isPipeline_Owner
- func (x *Pipeline) GetRecipe() *Recipe
- func (x *Pipeline) GetState() Pipeline_State
- func (x *Pipeline) GetUid() string
- func (x *Pipeline) GetUpdateTime() *timestamppb.Timestamp
- func (x *Pipeline) GetUser() string
- func (*Pipeline) ProtoMessage()
- func (x *Pipeline) ProtoReflect() protoreflect.Message
- func (x *Pipeline) Reset()
- func (x *Pipeline) String() string
- type PipelineServiceClient
- type PipelineServiceServer
- type PipelineService_TriggerPipelineBinaryFileUploadClient
- type PipelineService_TriggerPipelineBinaryFileUploadServer
- type Pipeline_Mode
- func (Pipeline_Mode) Descriptor() protoreflect.EnumDescriptor
- func (x Pipeline_Mode) Enum() *Pipeline_Mode
- func (Pipeline_Mode) EnumDescriptor() ([]byte, []int)deprecated
- func (x Pipeline_Mode) Number() protoreflect.EnumNumber
- func (x Pipeline_Mode) String() string
- func (Pipeline_Mode) Type() protoreflect.EnumType
- type Pipeline_Org
- type Pipeline_State
- func (Pipeline_State) Descriptor() protoreflect.EnumDescriptor
- func (x Pipeline_State) Enum() *Pipeline_State
- func (Pipeline_State) EnumDescriptor() ([]byte, []int)deprecated
- func (x Pipeline_State) Number() protoreflect.EnumNumber
- func (x Pipeline_State) String() string
- func (Pipeline_State) Type() protoreflect.EnumType
- type Pipeline_User
- type ReadinessRequest
- func (*ReadinessRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReadinessRequest) GetHealthCheckRequest() *v1alpha.HealthCheckRequest
- func (*ReadinessRequest) ProtoMessage()
- func (x *ReadinessRequest) ProtoReflect() protoreflect.Message
- func (x *ReadinessRequest) Reset()
- func (x *ReadinessRequest) String() string
- type ReadinessResponse
- func (*ReadinessResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ReadinessResponse) GetHealthCheckResponse() *v1alpha.HealthCheckResponse
- func (*ReadinessResponse) ProtoMessage()
- func (x *ReadinessResponse) ProtoReflect() protoreflect.Message
- func (x *ReadinessResponse) Reset()
- func (x *ReadinessResponse) String() string
- type Recipe
- func (*Recipe) Descriptor() ([]byte, []int)deprecated
- func (x *Recipe) GetDestination() string
- func (x *Recipe) GetModelInstances() []string
- func (x *Recipe) GetSource() string
- func (*Recipe) ProtoMessage()
- func (x *Recipe) ProtoReflect() protoreflect.Message
- func (x *Recipe) Reset()
- func (x *Recipe) String() string
- type RenamePipelineRequest
- func (*RenamePipelineRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RenamePipelineRequest) GetName() string
- func (x *RenamePipelineRequest) GetNewPipelineId() string
- func (*RenamePipelineRequest) ProtoMessage()
- func (x *RenamePipelineRequest) ProtoReflect() protoreflect.Message
- func (x *RenamePipelineRequest) Reset()
- func (x *RenamePipelineRequest) String() string
- type RenamePipelineResponse
- func (*RenamePipelineResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RenamePipelineResponse) GetPipeline() *Pipeline
- func (*RenamePipelineResponse) ProtoMessage()
- func (x *RenamePipelineResponse) ProtoReflect() protoreflect.Message
- func (x *RenamePipelineResponse) Reset()
- func (x *RenamePipelineResponse) String() string
- type TaskOutput
- func (*TaskOutput) Descriptor() ([]byte, []int)deprecated
- func (x *TaskOutput) GetClassification() *v1alpha.ClassificationOutput
- func (x *TaskOutput) GetDetection() *v1alpha.DetectionOutput
- func (x *TaskOutput) GetIndex() string
- func (x *TaskOutput) GetKeypoint() *v1alpha.KeypointOutput
- func (x *TaskOutput) GetOcr() *v1alpha.OcrOutput
- func (m *TaskOutput) GetOutput() isTaskOutput_Output
- func (x *TaskOutput) GetUnspecified() *v1alpha.UnspecifiedOutput
- func (*TaskOutput) ProtoMessage()
- func (x *TaskOutput) ProtoReflect() protoreflect.Message
- func (x *TaskOutput) Reset()
- func (x *TaskOutput) String() string
- type TaskOutput_Classification
- type TaskOutput_Detection
- type TaskOutput_Keypoint
- type TaskOutput_Ocr
- type TaskOutput_Unspecified
- type TriggerPipelineBinaryFileUploadRequest
- func (*TriggerPipelineBinaryFileUploadRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TriggerPipelineBinaryFileUploadRequest) GetContent() []byte
- func (x *TriggerPipelineBinaryFileUploadRequest) GetFileLengths() []uint64
- func (x *TriggerPipelineBinaryFileUploadRequest) GetFileNames() []string
- func (x *TriggerPipelineBinaryFileUploadRequest) GetName() string
- func (*TriggerPipelineBinaryFileUploadRequest) ProtoMessage()
- func (x *TriggerPipelineBinaryFileUploadRequest) ProtoReflect() protoreflect.Message
- func (x *TriggerPipelineBinaryFileUploadRequest) Reset()
- func (x *TriggerPipelineBinaryFileUploadRequest) String() string
- type TriggerPipelineBinaryFileUploadResponse
- func (*TriggerPipelineBinaryFileUploadResponse) Descriptor() ([]byte, []int)deprecated
- func (x *TriggerPipelineBinaryFileUploadResponse) GetDataMappingIndices() []string
- func (x *TriggerPipelineBinaryFileUploadResponse) GetModelInstanceOutputs() []*ModelInstanceOutput
- func (*TriggerPipelineBinaryFileUploadResponse) ProtoMessage()
- func (x *TriggerPipelineBinaryFileUploadResponse) ProtoReflect() protoreflect.Message
- func (x *TriggerPipelineBinaryFileUploadResponse) Reset()
- func (x *TriggerPipelineBinaryFileUploadResponse) String() string
- type TriggerPipelineRequest
- func (*TriggerPipelineRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TriggerPipelineRequest) GetInputs() []*Input
- func (x *TriggerPipelineRequest) GetName() string
- func (*TriggerPipelineRequest) ProtoMessage()
- func (x *TriggerPipelineRequest) ProtoReflect() protoreflect.Message
- func (x *TriggerPipelineRequest) Reset()
- func (x *TriggerPipelineRequest) String() string
- type TriggerPipelineResponse
- func (*TriggerPipelineResponse) Descriptor() ([]byte, []int)deprecated
- func (x *TriggerPipelineResponse) GetDataMappingIndices() []string
- func (x *TriggerPipelineResponse) GetModelInstanceOutputs() []*ModelInstanceOutput
- func (*TriggerPipelineResponse) ProtoMessage()
- func (x *TriggerPipelineResponse) ProtoReflect() protoreflect.Message
- func (x *TriggerPipelineResponse) Reset()
- func (x *TriggerPipelineResponse) String() string
- type UnimplementedPipelineServiceServer
- func (UnimplementedPipelineServiceServer) ActivatePipeline(context.Context, *ActivatePipelineRequest) (*ActivatePipelineResponse, error)
- func (UnimplementedPipelineServiceServer) CreatePipeline(context.Context, *CreatePipelineRequest) (*CreatePipelineResponse, error)
- func (UnimplementedPipelineServiceServer) DeactivatePipeline(context.Context, *DeactivatePipelineRequest) (*DeactivatePipelineResponse, error)
- func (UnimplementedPipelineServiceServer) DeletePipeline(context.Context, *DeletePipelineRequest) (*DeletePipelineResponse, error)
- func (UnimplementedPipelineServiceServer) GetPipeline(context.Context, *GetPipelineRequest) (*GetPipelineResponse, error)
- func (UnimplementedPipelineServiceServer) ListPipeline(context.Context, *ListPipelineRequest) (*ListPipelineResponse, error)
- func (UnimplementedPipelineServiceServer) Liveness(context.Context, *LivenessRequest) (*LivenessResponse, error)
- func (UnimplementedPipelineServiceServer) LookUpPipeline(context.Context, *LookUpPipelineRequest) (*LookUpPipelineResponse, error)
- func (UnimplementedPipelineServiceServer) Readiness(context.Context, *ReadinessRequest) (*ReadinessResponse, error)
- func (UnimplementedPipelineServiceServer) RenamePipeline(context.Context, *RenamePipelineRequest) (*RenamePipelineResponse, error)
- func (UnimplementedPipelineServiceServer) TriggerPipeline(context.Context, *TriggerPipelineRequest) (*TriggerPipelineResponse, error)
- func (UnimplementedPipelineServiceServer) TriggerPipelineBinaryFileUpload(PipelineService_TriggerPipelineBinaryFileUploadServer) error
- func (UnimplementedPipelineServiceServer) UpdatePipeline(context.Context, *UpdatePipelineRequest) (*UpdatePipelineResponse, error)
- type UnsafePipelineServiceServer
- type UpdatePipelineRequest
- func (*UpdatePipelineRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdatePipelineRequest) GetPipeline() *Pipeline
- func (x *UpdatePipelineRequest) GetUpdateMask() *fieldmaskpb.FieldMask
- func (*UpdatePipelineRequest) ProtoMessage()
- func (x *UpdatePipelineRequest) ProtoReflect() protoreflect.Message
- func (x *UpdatePipelineRequest) Reset()
- func (x *UpdatePipelineRequest) String() string
- type UpdatePipelineResponse
- func (*UpdatePipelineResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdatePipelineResponse) GetPipeline() *Pipeline
- func (*UpdatePipelineResponse) ProtoMessage()
- func (x *UpdatePipelineResponse) ProtoReflect() protoreflect.Message
- func (x *UpdatePipelineResponse) Reset()
- func (x *UpdatePipelineResponse) String() string
- type View
Constants ¶
This section is empty.
Variables ¶
var ( View_name = map[int32]string{ 0: "VIEW_UNSPECIFIED", 1: "VIEW_BASIC", 2: "VIEW_FULL", } View_value = map[string]int32{ "VIEW_UNSPECIFIED": 0, "VIEW_BASIC": 1, "VIEW_FULL": 2, } )
Enum value maps for View.
var ( Pipeline_Mode_name = map[int32]string{ 0: "MODE_UNSPECIFIED", 1: "MODE_SYNC", 2: "MODE_ASYNC", } Pipeline_Mode_value = map[string]int32{ "MODE_UNSPECIFIED": 0, "MODE_SYNC": 1, "MODE_ASYNC": 2, } )
Enum value maps for Pipeline_Mode.
var ( Pipeline_State_name = map[int32]string{ 0: "STATE_UNSPECIFIED", 1: "STATE_INACTIVE", 2: "STATE_ACTIVE", 3: "STATE_ERROR", } Pipeline_State_value = map[string]int32{ "STATE_UNSPECIFIED": 0, "STATE_INACTIVE": 1, "STATE_ACTIVE": 2, "STATE_ERROR": 3, } )
Enum value maps for Pipeline_State.
var File_vdp_pipeline_v1alpha_healthcheck_proto protoreflect.FileDescriptor
var File_vdp_pipeline_v1alpha_pipeline_proto protoreflect.FileDescriptor
var File_vdp_pipeline_v1alpha_pipeline_service_proto protoreflect.FileDescriptor
var PipelineService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "vdp.pipeline.v1alpha.PipelineService", HandlerType: (*PipelineServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Liveness", Handler: _PipelineService_Liveness_Handler, }, { MethodName: "Readiness", Handler: _PipelineService_Readiness_Handler, }, { MethodName: "CreatePipeline", Handler: _PipelineService_CreatePipeline_Handler, }, { MethodName: "ListPipeline", Handler: _PipelineService_ListPipeline_Handler, }, { MethodName: "GetPipeline", Handler: _PipelineService_GetPipeline_Handler, }, { MethodName: "UpdatePipeline", Handler: _PipelineService_UpdatePipeline_Handler, }, { MethodName: "DeletePipeline", Handler: _PipelineService_DeletePipeline_Handler, }, { MethodName: "LookUpPipeline", Handler: _PipelineService_LookUpPipeline_Handler, }, { MethodName: "ActivatePipeline", Handler: _PipelineService_ActivatePipeline_Handler, }, { MethodName: "DeactivatePipeline", Handler: _PipelineService_DeactivatePipeline_Handler, }, { MethodName: "RenamePipeline", Handler: _PipelineService_RenamePipeline_Handler, }, { MethodName: "TriggerPipeline", Handler: _PipelineService_TriggerPipeline_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "TriggerPipelineBinaryFileUpload", Handler: _PipelineService_TriggerPipelineBinaryFileUpload_Handler, ClientStreams: true, }, }, Metadata: "vdp/pipeline/v1alpha/pipeline_service.proto", }
PipelineService_ServiceDesc is the grpc.ServiceDesc for PipelineService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterPipelineServiceHandler ¶
func RegisterPipelineServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterPipelineServiceHandler registers the http handlers for service PipelineService to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterPipelineServiceHandlerClient ¶
func RegisterPipelineServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client PipelineServiceClient) error
RegisterPipelineServiceHandlerClient registers the http handlers for service PipelineService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "PipelineServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "PipelineServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "PipelineServiceClient" to call the correct interceptors.
func RegisterPipelineServiceHandlerFromEndpoint ¶
func RegisterPipelineServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterPipelineServiceHandlerFromEndpoint is same as RegisterPipelineServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterPipelineServiceHandlerServer ¶
func RegisterPipelineServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server PipelineServiceServer) error
RegisterPipelineServiceHandlerServer registers the http handlers for service PipelineService to "mux". UnaryRPC :call PipelineServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterPipelineServiceHandlerFromEndpoint instead.
func RegisterPipelineServiceServer ¶
func RegisterPipelineServiceServer(s grpc.ServiceRegistrar, srv PipelineServiceServer)
Types ¶
type ActivatePipelineRequest ¶
type ActivatePipelineRequest struct { // Pipeline resource name. It must have the format of "pipelines/*" Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
ActivatePipelineRequest represents a request to activate a pipeline
func (*ActivatePipelineRequest) Descriptor
deprecated
func (*ActivatePipelineRequest) Descriptor() ([]byte, []int)
Deprecated: Use ActivatePipelineRequest.ProtoReflect.Descriptor instead.
func (*ActivatePipelineRequest) GetName ¶
func (x *ActivatePipelineRequest) GetName() string
func (*ActivatePipelineRequest) ProtoMessage ¶
func (*ActivatePipelineRequest) ProtoMessage()
func (*ActivatePipelineRequest) ProtoReflect ¶
func (x *ActivatePipelineRequest) ProtoReflect() protoreflect.Message
func (*ActivatePipelineRequest) Reset ¶
func (x *ActivatePipelineRequest) Reset()
func (*ActivatePipelineRequest) String ¶
func (x *ActivatePipelineRequest) String() string
type ActivatePipelineResponse ¶
type ActivatePipelineResponse struct { // A pipeline resource Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"` // contains filtered or unexported fields }
ActivatePipelineResponse represents an activated pipeline
func (*ActivatePipelineResponse) Descriptor
deprecated
func (*ActivatePipelineResponse) Descriptor() ([]byte, []int)
Deprecated: Use ActivatePipelineResponse.ProtoReflect.Descriptor instead.
func (*ActivatePipelineResponse) GetPipeline ¶
func (x *ActivatePipelineResponse) GetPipeline() *Pipeline
func (*ActivatePipelineResponse) ProtoMessage ¶
func (*ActivatePipelineResponse) ProtoMessage()
func (*ActivatePipelineResponse) ProtoReflect ¶
func (x *ActivatePipelineResponse) ProtoReflect() protoreflect.Message
func (*ActivatePipelineResponse) Reset ¶
func (x *ActivatePipelineResponse) Reset()
func (*ActivatePipelineResponse) String ¶
func (x *ActivatePipelineResponse) String() string
type CreatePipelineRequest ¶
type CreatePipelineRequest struct { // A pipeline resource to create Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"` // contains filtered or unexported fields }
CreatePipelineRequest represents a request to create a pipeline
func (*CreatePipelineRequest) Descriptor
deprecated
func (*CreatePipelineRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreatePipelineRequest.ProtoReflect.Descriptor instead.
func (*CreatePipelineRequest) GetPipeline ¶
func (x *CreatePipelineRequest) GetPipeline() *Pipeline
func (*CreatePipelineRequest) ProtoMessage ¶
func (*CreatePipelineRequest) ProtoMessage()
func (*CreatePipelineRequest) ProtoReflect ¶
func (x *CreatePipelineRequest) ProtoReflect() protoreflect.Message
func (*CreatePipelineRequest) Reset ¶
func (x *CreatePipelineRequest) Reset()
func (*CreatePipelineRequest) String ¶
func (x *CreatePipelineRequest) String() string
type CreatePipelineResponse ¶
type CreatePipelineResponse struct { // The created pipeline resource Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"` // contains filtered or unexported fields }
CreatePipelineResponse represents a response for a pipeline resource
func (*CreatePipelineResponse) Descriptor
deprecated
func (*CreatePipelineResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreatePipelineResponse.ProtoReflect.Descriptor instead.
func (*CreatePipelineResponse) GetPipeline ¶
func (x *CreatePipelineResponse) GetPipeline() *Pipeline
func (*CreatePipelineResponse) ProtoMessage ¶
func (*CreatePipelineResponse) ProtoMessage()
func (*CreatePipelineResponse) ProtoReflect ¶
func (x *CreatePipelineResponse) ProtoReflect() protoreflect.Message
func (*CreatePipelineResponse) Reset ¶
func (x *CreatePipelineResponse) Reset()
func (*CreatePipelineResponse) String ¶
func (x *CreatePipelineResponse) String() string
type DeactivatePipelineRequest ¶
type DeactivatePipelineRequest struct { // Pipeline resource name. It must have the format of "pipelines/*" Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
DeactivatePipelineRequest represents a request to deactivate a pipeline
func (*DeactivatePipelineRequest) Descriptor
deprecated
func (*DeactivatePipelineRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeactivatePipelineRequest.ProtoReflect.Descriptor instead.
func (*DeactivatePipelineRequest) GetName ¶
func (x *DeactivatePipelineRequest) GetName() string
func (*DeactivatePipelineRequest) ProtoMessage ¶
func (*DeactivatePipelineRequest) ProtoMessage()
func (*DeactivatePipelineRequest) ProtoReflect ¶
func (x *DeactivatePipelineRequest) ProtoReflect() protoreflect.Message
func (*DeactivatePipelineRequest) Reset ¶
func (x *DeactivatePipelineRequest) Reset()
func (*DeactivatePipelineRequest) String ¶
func (x *DeactivatePipelineRequest) String() string
type DeactivatePipelineResponse ¶
type DeactivatePipelineResponse struct { // A pipeline resource Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"` // contains filtered or unexported fields }
DeactivatePipelineResponse represents an inactivated pipeline
func (*DeactivatePipelineResponse) Descriptor
deprecated
func (*DeactivatePipelineResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeactivatePipelineResponse.ProtoReflect.Descriptor instead.
func (*DeactivatePipelineResponse) GetPipeline ¶
func (x *DeactivatePipelineResponse) GetPipeline() *Pipeline
func (*DeactivatePipelineResponse) ProtoMessage ¶
func (*DeactivatePipelineResponse) ProtoMessage()
func (*DeactivatePipelineResponse) ProtoReflect ¶
func (x *DeactivatePipelineResponse) ProtoReflect() protoreflect.Message
func (*DeactivatePipelineResponse) Reset ¶
func (x *DeactivatePipelineResponse) Reset()
func (*DeactivatePipelineResponse) String ¶
func (x *DeactivatePipelineResponse) String() string
type DeletePipelineRequest ¶
type DeletePipelineRequest struct { // Pipeline resource name. It must have the format of "pipelines/*" Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
DeletePipelineRequest represents a request to delete a pipeline resource
func (*DeletePipelineRequest) Descriptor
deprecated
func (*DeletePipelineRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeletePipelineRequest.ProtoReflect.Descriptor instead.
func (*DeletePipelineRequest) GetName ¶
func (x *DeletePipelineRequest) GetName() string
func (*DeletePipelineRequest) ProtoMessage ¶
func (*DeletePipelineRequest) ProtoMessage()
func (*DeletePipelineRequest) ProtoReflect ¶
func (x *DeletePipelineRequest) ProtoReflect() protoreflect.Message
func (*DeletePipelineRequest) Reset ¶
func (x *DeletePipelineRequest) Reset()
func (*DeletePipelineRequest) String ¶
func (x *DeletePipelineRequest) String() string
type DeletePipelineResponse ¶
type DeletePipelineResponse struct {
// contains filtered or unexported fields
}
DeletePipelineResponse represents an empty response
func (*DeletePipelineResponse) Descriptor
deprecated
func (*DeletePipelineResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeletePipelineResponse.ProtoReflect.Descriptor instead.
func (*DeletePipelineResponse) ProtoMessage ¶
func (*DeletePipelineResponse) ProtoMessage()
func (*DeletePipelineResponse) ProtoReflect ¶
func (x *DeletePipelineResponse) ProtoReflect() protoreflect.Message
func (*DeletePipelineResponse) Reset ¶
func (x *DeletePipelineResponse) Reset()
func (*DeletePipelineResponse) String ¶
func (x *DeletePipelineResponse) String() string
type GetPipelineRequest ¶
type GetPipelineRequest struct { // Pipeline resource name. It must have the format of "pipelines/*" Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Pipeline resource view (default is VIEW_BASIC) View *View `protobuf:"varint,2,opt,name=view,proto3,enum=vdp.pipeline.v1alpha.View,oneof" json:"view,omitempty"` // contains filtered or unexported fields }
GetPipelineRequest represents a request to query a pipeline
func (*GetPipelineRequest) Descriptor
deprecated
func (*GetPipelineRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetPipelineRequest.ProtoReflect.Descriptor instead.
func (*GetPipelineRequest) GetName ¶
func (x *GetPipelineRequest) GetName() string
func (*GetPipelineRequest) GetView ¶
func (x *GetPipelineRequest) GetView() View
func (*GetPipelineRequest) ProtoMessage ¶
func (*GetPipelineRequest) ProtoMessage()
func (*GetPipelineRequest) ProtoReflect ¶
func (x *GetPipelineRequest) ProtoReflect() protoreflect.Message
func (*GetPipelineRequest) Reset ¶
func (x *GetPipelineRequest) Reset()
func (*GetPipelineRequest) String ¶
func (x *GetPipelineRequest) String() string
type GetPipelineResponse ¶
type GetPipelineResponse struct { // A pipeline resource Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"` // contains filtered or unexported fields }
GetPipelineResponse represents a response for a pipeline resource
func (*GetPipelineResponse) Descriptor
deprecated
func (*GetPipelineResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetPipelineResponse.ProtoReflect.Descriptor instead.
func (*GetPipelineResponse) GetPipeline ¶
func (x *GetPipelineResponse) GetPipeline() *Pipeline
func (*GetPipelineResponse) ProtoMessage ¶
func (*GetPipelineResponse) ProtoMessage()
func (*GetPipelineResponse) ProtoReflect ¶
func (x *GetPipelineResponse) ProtoReflect() protoreflect.Message
func (*GetPipelineResponse) Reset ¶
func (x *GetPipelineResponse) Reset()
func (*GetPipelineResponse) String ¶
func (x *GetPipelineResponse) String() string
type Input ¶
type Input struct { // Input type // // Types that are assignable to Type: // *Input_ImageUrl // *Input_ImageBase64 Type isInput_Type `protobuf_oneof:"type"` // contains filtered or unexported fields }
Input represents the input to a pipeline
func (*Input) Descriptor
deprecated
func (*Input) GetImageBase64 ¶
func (*Input) GetImageUrl ¶
func (*Input) ProtoMessage ¶
func (*Input) ProtoMessage()
func (*Input) ProtoReflect ¶
func (x *Input) ProtoReflect() protoreflect.Message
type Input_ImageBase64 ¶
type Input_ImageBase64 struct { // Image type base64 ImageBase64 string `protobuf:"bytes,2,opt,name=image_base64,json=imageBase64,proto3,oneof"` }
type Input_ImageUrl ¶
type Input_ImageUrl struct { // Image type URL ImageUrl string `protobuf:"bytes,1,opt,name=image_url,json=imageUrl,proto3,oneof"` }
type ListPipelineRequest ¶
type ListPipelineRequest struct { // The maximum number of pipelines to return. The service may return fewer // than this value. If unspecified, at most 10 pipelines will be returned. The // maximum value is 100; values above 100 will be coerced to 100. PageSize *int64 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3,oneof" json:"page_size,omitempty"` // Page token PageToken *string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3,oneof" json:"page_token,omitempty"` // View view (default is VIEW_BASIC) View *View `protobuf:"varint,3,opt,name=view,proto3,enum=vdp.pipeline.v1alpha.View,oneof" json:"view,omitempty"` // Filter expression to list pipelines Filter *string `protobuf:"bytes,4,opt,name=filter,proto3,oneof" json:"filter,omitempty"` // contains filtered or unexported fields }
ListPipelineRequest represents a request to list pipelines
func (*ListPipelineRequest) Descriptor
deprecated
func (*ListPipelineRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListPipelineRequest.ProtoReflect.Descriptor instead.
func (*ListPipelineRequest) GetFilter ¶
func (x *ListPipelineRequest) GetFilter() string
func (*ListPipelineRequest) GetPageSize ¶
func (x *ListPipelineRequest) GetPageSize() int64
func (*ListPipelineRequest) GetPageToken ¶
func (x *ListPipelineRequest) GetPageToken() string
func (*ListPipelineRequest) GetView ¶
func (x *ListPipelineRequest) GetView() View
func (*ListPipelineRequest) ProtoMessage ¶
func (*ListPipelineRequest) ProtoMessage()
func (*ListPipelineRequest) ProtoReflect ¶
func (x *ListPipelineRequest) ProtoReflect() protoreflect.Message
func (*ListPipelineRequest) Reset ¶
func (x *ListPipelineRequest) Reset()
func (*ListPipelineRequest) String ¶
func (x *ListPipelineRequest) String() string
type ListPipelineResponse ¶
type ListPipelineResponse struct { // A list of pipeline resources Pipelines []*Pipeline `protobuf:"bytes,1,rep,name=pipelines,proto3" json:"pipelines,omitempty"` // Next page token NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // Total count of pipeline resources TotalSize int64 `protobuf:"varint,3,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"` // contains filtered or unexported fields }
ListPipelineResponse represents a response for a list of pipelines
func (*ListPipelineResponse) Descriptor
deprecated
func (*ListPipelineResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListPipelineResponse.ProtoReflect.Descriptor instead.
func (*ListPipelineResponse) GetNextPageToken ¶
func (x *ListPipelineResponse) GetNextPageToken() string
func (*ListPipelineResponse) GetPipelines ¶
func (x *ListPipelineResponse) GetPipelines() []*Pipeline
func (*ListPipelineResponse) GetTotalSize ¶
func (x *ListPipelineResponse) GetTotalSize() int64
func (*ListPipelineResponse) ProtoMessage ¶
func (*ListPipelineResponse) ProtoMessage()
func (*ListPipelineResponse) ProtoReflect ¶
func (x *ListPipelineResponse) ProtoReflect() protoreflect.Message
func (*ListPipelineResponse) Reset ¶
func (x *ListPipelineResponse) Reset()
func (*ListPipelineResponse) String ¶
func (x *ListPipelineResponse) String() string
type LivenessRequest ¶
type LivenessRequest struct { // HealthCheckRequest message HealthCheckRequest *v1alpha.HealthCheckRequest `protobuf:"bytes,1,opt,name=health_check_request,json=healthCheckRequest,proto3,oneof" json:"health_check_request,omitempty"` // contains filtered or unexported fields }
LivenessRequest represents a request to check a service liveness status
func (*LivenessRequest) Descriptor
deprecated
func (*LivenessRequest) Descriptor() ([]byte, []int)
Deprecated: Use LivenessRequest.ProtoReflect.Descriptor instead.
func (*LivenessRequest) GetHealthCheckRequest ¶
func (x *LivenessRequest) GetHealthCheckRequest() *v1alpha.HealthCheckRequest
func (*LivenessRequest) ProtoMessage ¶
func (*LivenessRequest) ProtoMessage()
func (*LivenessRequest) ProtoReflect ¶
func (x *LivenessRequest) ProtoReflect() protoreflect.Message
func (*LivenessRequest) Reset ¶
func (x *LivenessRequest) Reset()
func (*LivenessRequest) String ¶
func (x *LivenessRequest) String() string
type LivenessResponse ¶
type LivenessResponse struct { // HealthCheckResponse message HealthCheckResponse *v1alpha.HealthCheckResponse `protobuf:"bytes,1,opt,name=health_check_response,json=healthCheckResponse,proto3" json:"health_check_response,omitempty"` // contains filtered or unexported fields }
LivenessResponse represents a response for a service liveness status
func (*LivenessResponse) Descriptor
deprecated
func (*LivenessResponse) Descriptor() ([]byte, []int)
Deprecated: Use LivenessResponse.ProtoReflect.Descriptor instead.
func (*LivenessResponse) GetHealthCheckResponse ¶
func (x *LivenessResponse) GetHealthCheckResponse() *v1alpha.HealthCheckResponse
func (*LivenessResponse) ProtoMessage ¶
func (*LivenessResponse) ProtoMessage()
func (*LivenessResponse) ProtoReflect ¶
func (x *LivenessResponse) ProtoReflect() protoreflect.Message
func (*LivenessResponse) Reset ¶
func (x *LivenessResponse) Reset()
func (*LivenessResponse) String ¶
func (x *LivenessResponse) String() string
type LookUpPipelineRequest ¶
type LookUpPipelineRequest struct { // Permalink of a pipeline. For example: // "pipelines/{uid}" Permalink string `protobuf:"bytes,1,opt,name=permalink,proto3" json:"permalink,omitempty"` // View view (default is VIEW_BASIC) View *View `protobuf:"varint,2,opt,name=view,proto3,enum=vdp.pipeline.v1alpha.View,oneof" json:"view,omitempty"` // contains filtered or unexported fields }
LookUpPipelineRequest represents a request to query a pipeline by permalink
func (*LookUpPipelineRequest) Descriptor
deprecated
func (*LookUpPipelineRequest) Descriptor() ([]byte, []int)
Deprecated: Use LookUpPipelineRequest.ProtoReflect.Descriptor instead.
func (*LookUpPipelineRequest) GetPermalink ¶
func (x *LookUpPipelineRequest) GetPermalink() string
func (*LookUpPipelineRequest) GetView ¶
func (x *LookUpPipelineRequest) GetView() View
func (*LookUpPipelineRequest) ProtoMessage ¶
func (*LookUpPipelineRequest) ProtoMessage()
func (*LookUpPipelineRequest) ProtoReflect ¶
func (x *LookUpPipelineRequest) ProtoReflect() protoreflect.Message
func (*LookUpPipelineRequest) Reset ¶
func (x *LookUpPipelineRequest) Reset()
func (*LookUpPipelineRequest) String ¶
func (x *LookUpPipelineRequest) String() string
type LookUpPipelineResponse ¶
type LookUpPipelineResponse struct { // A pipeline resource Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"` // contains filtered or unexported fields }
LookUpPipelineResponse represents a response for a pipeline resource
func (*LookUpPipelineResponse) Descriptor
deprecated
func (*LookUpPipelineResponse) Descriptor() ([]byte, []int)
Deprecated: Use LookUpPipelineResponse.ProtoReflect.Descriptor instead.
func (*LookUpPipelineResponse) GetPipeline ¶
func (x *LookUpPipelineResponse) GetPipeline() *Pipeline
func (*LookUpPipelineResponse) ProtoMessage ¶
func (*LookUpPipelineResponse) ProtoMessage()
func (*LookUpPipelineResponse) ProtoReflect ¶
func (x *LookUpPipelineResponse) ProtoReflect() protoreflect.Message
func (*LookUpPipelineResponse) Reset ¶
func (x *LookUpPipelineResponse) Reset()
func (*LookUpPipelineResponse) String ¶
func (x *LookUpPipelineResponse) String() string
type ModelInstanceOutput ¶
type ModelInstanceOutput struct { // The model instance ModelInstance string `protobuf:"bytes,1,opt,name=model_instance,json=modelInstance,proto3" json:"model_instance,omitempty"` // The task type Task v1alpha.ModelInstance_Task `protobuf:"varint,2,opt,name=task,proto3,enum=vdp.model.v1alpha.ModelInstance_Task" json:"task,omitempty"` // The extended task outputs based on the model instance inference (i.e., // from a trigger endpoint of model-backend) TaskOutputs []*TaskOutput `protobuf:"bytes,3,rep,name=task_outputs,json=taskOutputs,proto3" json:"task_outputs,omitempty"` // contains filtered or unexported fields }
ModelInstanceOutput represents one model instance inference result
func (*ModelInstanceOutput) Descriptor
deprecated
func (*ModelInstanceOutput) Descriptor() ([]byte, []int)
Deprecated: Use ModelInstanceOutput.ProtoReflect.Descriptor instead.
func (*ModelInstanceOutput) GetModelInstance ¶
func (x *ModelInstanceOutput) GetModelInstance() string
func (*ModelInstanceOutput) GetTask ¶
func (x *ModelInstanceOutput) GetTask() v1alpha.ModelInstance_Task
func (*ModelInstanceOutput) GetTaskOutputs ¶
func (x *ModelInstanceOutput) GetTaskOutputs() []*TaskOutput
func (*ModelInstanceOutput) ProtoMessage ¶
func (*ModelInstanceOutput) ProtoMessage()
func (*ModelInstanceOutput) ProtoReflect ¶
func (x *ModelInstanceOutput) ProtoReflect() protoreflect.Message
func (*ModelInstanceOutput) Reset ¶
func (x *ModelInstanceOutput) Reset()
func (*ModelInstanceOutput) String ¶
func (x *ModelInstanceOutput) String() string
type Pipeline ¶
type Pipeline struct { // Pipeline resource name. It must have the format of "pipelines/*" Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Pipeline UUID Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"` // Pipeline resource ID (the last segment of the resource name) used to // construct the resource name. This conforms to RFC-1034, which restricts to // letters, numbers, and hyphen, with the first character a letter, the last a // letter or a number, and a 63 character maximum. Id string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"` // Pipeline description Description *string `protobuf:"bytes,4,opt,name=description,proto3,oneof" json:"description,omitempty"` // Pipeline recipe Recipe *Recipe `protobuf:"bytes,5,opt,name=recipe,proto3" json:"recipe,omitempty"` // Pipeline mode Mode Pipeline_Mode `protobuf:"varint,6,opt,name=mode,proto3,enum=vdp.pipeline.v1alpha.Pipeline_Mode" json:"mode,omitempty"` // Pipeline state State Pipeline_State `protobuf:"varint,7,opt,name=state,proto3,enum=vdp.pipeline.v1alpha.Pipeline_State" json:"state,omitempty"` // Pipeline owner // // Types that are assignable to Owner: // *Pipeline_User // *Pipeline_Org Owner isPipeline_Owner `protobuf_oneof:"owner"` // Pipeline creation time CreateTime *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` // Pipeline update time UpdateTime *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"` // contains filtered or unexported fields }
Pipeline represents the content of a pipeline
func (*Pipeline) Descriptor
deprecated
func (*Pipeline) GetCreateTime ¶
func (x *Pipeline) GetCreateTime() *timestamppb.Timestamp
func (*Pipeline) GetDescription ¶
func (*Pipeline) GetMode ¶
func (x *Pipeline) GetMode() Pipeline_Mode
func (*Pipeline) GetState ¶
func (x *Pipeline) GetState() Pipeline_State
func (*Pipeline) GetUpdateTime ¶
func (x *Pipeline) GetUpdateTime() *timestamppb.Timestamp
func (*Pipeline) ProtoMessage ¶
func (*Pipeline) ProtoMessage()
func (*Pipeline) ProtoReflect ¶
func (x *Pipeline) ProtoReflect() protoreflect.Message
type PipelineServiceClient ¶
type PipelineServiceClient interface { // Liveness method receives a LivenessRequest message and returns a // LivenessResponse message. // See https://github.com/grpc/grpc/blob/master/doc/health-checking.md Liveness(ctx context.Context, in *LivenessRequest, opts ...grpc.CallOption) (*LivenessResponse, error) // Readiness method receives a ReadinessRequest message and returns a // ReadinessResponse message. // See https://github.com/grpc/grpc/blob/master/doc/health-checking.md Readiness(ctx context.Context, in *ReadinessRequest, opts ...grpc.CallOption) (*ReadinessResponse, error) // CreatePipeline method receives a CreatePipelineRequest message and returns // a CreatePipelineResponse message. CreatePipeline(ctx context.Context, in *CreatePipelineRequest, opts ...grpc.CallOption) (*CreatePipelineResponse, error) // ListPipeline method receives a ListPipelineRequest message and returns a // ListPipelineResponse message. ListPipeline(ctx context.Context, in *ListPipelineRequest, opts ...grpc.CallOption) (*ListPipelineResponse, error) // GetPipeline method receives a GetPipelineRequest message and returns a // GetPipelineResponse message. GetPipeline(ctx context.Context, in *GetPipelineRequest, opts ...grpc.CallOption) (*GetPipelineResponse, error) // UpdatePipeline method receives a UpdatePipelineRequest message and returns // a UpdatePipelineResponse message. UpdatePipeline(ctx context.Context, in *UpdatePipelineRequest, opts ...grpc.CallOption) (*UpdatePipelineResponse, error) // DeletePipeline method receives a DeletePipelineRequest message and returns // a DeletePipelineResponse message. DeletePipeline(ctx context.Context, in *DeletePipelineRequest, opts ...grpc.CallOption) (*DeletePipelineResponse, error) // LookUpPipeline method receives a LookUpPipelineRequest message and returns // a LookUpPipelineResponse LookUpPipeline(ctx context.Context, in *LookUpPipelineRequest, opts ...grpc.CallOption) (*LookUpPipelineResponse, error) // Activate a pipeline. // The "state" of the pipeline after activating is "ACTIVE". // ActivatePipeline can be called on Pipelines in the state "INACTIVE"; // Pipelines in a different state (including "ACTIVE") returns an error. ActivatePipeline(ctx context.Context, in *ActivatePipelineRequest, opts ...grpc.CallOption) (*ActivatePipelineResponse, error) // Deactivate a pipeline. // The "state" of the pipeline after inactivating is "INACTIVE". // DeactivatePipeline can be called on Pipelines in the state "ACTIVE"; // Pipelines in a different state (including "INACTIVE") returns an error. DeactivatePipeline(ctx context.Context, in *DeactivatePipelineRequest, opts ...grpc.CallOption) (*DeactivatePipelineResponse, error) // RenamePipeline method receives a RenamePipelineRequest message and returns // a RenamePipelineResponse message. RenamePipeline(ctx context.Context, in *RenamePipelineRequest, opts ...grpc.CallOption) (*RenamePipelineResponse, error) // TriggerPipeline method receives a TriggerPipelineRequest message and // returns a TriggerPipelineResponse. TriggerPipeline(ctx context.Context, in *TriggerPipelineRequest, opts ...grpc.CallOption) (*TriggerPipelineResponse, error) // TriggerPipelineBinaryFileUpload method receives a // TriggerPipelineBinaryFileUploadRequest message and returns a // TriggerPipelineBinaryFileUploadResponse message. // // Endpoint: "POST /v1alpha/{name=pipelines/*}:trigger-multipart" TriggerPipelineBinaryFileUpload(ctx context.Context, opts ...grpc.CallOption) (PipelineService_TriggerPipelineBinaryFileUploadClient, error) }
PipelineServiceClient is the client API for PipelineService 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 NewPipelineServiceClient ¶
func NewPipelineServiceClient(cc grpc.ClientConnInterface) PipelineServiceClient
type PipelineServiceServer ¶
type PipelineServiceServer interface { // Liveness method receives a LivenessRequest message and returns a // LivenessResponse message. // See https://github.com/grpc/grpc/blob/master/doc/health-checking.md Liveness(context.Context, *LivenessRequest) (*LivenessResponse, error) // Readiness method receives a ReadinessRequest message and returns a // ReadinessResponse message. // See https://github.com/grpc/grpc/blob/master/doc/health-checking.md Readiness(context.Context, *ReadinessRequest) (*ReadinessResponse, error) // CreatePipeline method receives a CreatePipelineRequest message and returns // a CreatePipelineResponse message. CreatePipeline(context.Context, *CreatePipelineRequest) (*CreatePipelineResponse, error) // ListPipeline method receives a ListPipelineRequest message and returns a // ListPipelineResponse message. ListPipeline(context.Context, *ListPipelineRequest) (*ListPipelineResponse, error) // GetPipeline method receives a GetPipelineRequest message and returns a // GetPipelineResponse message. GetPipeline(context.Context, *GetPipelineRequest) (*GetPipelineResponse, error) // UpdatePipeline method receives a UpdatePipelineRequest message and returns // a UpdatePipelineResponse message. UpdatePipeline(context.Context, *UpdatePipelineRequest) (*UpdatePipelineResponse, error) // DeletePipeline method receives a DeletePipelineRequest message and returns // a DeletePipelineResponse message. DeletePipeline(context.Context, *DeletePipelineRequest) (*DeletePipelineResponse, error) // LookUpPipeline method receives a LookUpPipelineRequest message and returns // a LookUpPipelineResponse LookUpPipeline(context.Context, *LookUpPipelineRequest) (*LookUpPipelineResponse, error) // Activate a pipeline. // The "state" of the pipeline after activating is "ACTIVE". // ActivatePipeline can be called on Pipelines in the state "INACTIVE"; // Pipelines in a different state (including "ACTIVE") returns an error. ActivatePipeline(context.Context, *ActivatePipelineRequest) (*ActivatePipelineResponse, error) // Deactivate a pipeline. // The "state" of the pipeline after inactivating is "INACTIVE". // DeactivatePipeline can be called on Pipelines in the state "ACTIVE"; // Pipelines in a different state (including "INACTIVE") returns an error. DeactivatePipeline(context.Context, *DeactivatePipelineRequest) (*DeactivatePipelineResponse, error) // RenamePipeline method receives a RenamePipelineRequest message and returns // a RenamePipelineResponse message. RenamePipeline(context.Context, *RenamePipelineRequest) (*RenamePipelineResponse, error) // TriggerPipeline method receives a TriggerPipelineRequest message and // returns a TriggerPipelineResponse. TriggerPipeline(context.Context, *TriggerPipelineRequest) (*TriggerPipelineResponse, error) // TriggerPipelineBinaryFileUpload method receives a // TriggerPipelineBinaryFileUploadRequest message and returns a // TriggerPipelineBinaryFileUploadResponse message. // // Endpoint: "POST /v1alpha/{name=pipelines/*}:trigger-multipart" TriggerPipelineBinaryFileUpload(PipelineService_TriggerPipelineBinaryFileUploadServer) error }
PipelineServiceServer is the server API for PipelineService service. All implementations should embed UnimplementedPipelineServiceServer for forward compatibility
type PipelineService_TriggerPipelineBinaryFileUploadClient ¶
type PipelineService_TriggerPipelineBinaryFileUploadClient interface { Send(*TriggerPipelineBinaryFileUploadRequest) error CloseAndRecv() (*TriggerPipelineBinaryFileUploadResponse, error) grpc.ClientStream }
type PipelineService_TriggerPipelineBinaryFileUploadServer ¶
type PipelineService_TriggerPipelineBinaryFileUploadServer interface { SendAndClose(*TriggerPipelineBinaryFileUploadResponse) error Recv() (*TriggerPipelineBinaryFileUploadRequest, error) grpc.ServerStream }
type Pipeline_Mode ¶
type Pipeline_Mode int32
Mode enumerates the pipeline modes
const ( // Mode: UNSPECIFIED Pipeline_MODE_UNSPECIFIED Pipeline_Mode = 0 // Mode: SYNC Pipeline_MODE_SYNC Pipeline_Mode = 1 // Mode: ASYNC Pipeline_MODE_ASYNC Pipeline_Mode = 2 )
func (Pipeline_Mode) Descriptor ¶
func (Pipeline_Mode) Descriptor() protoreflect.EnumDescriptor
func (Pipeline_Mode) Enum ¶
func (x Pipeline_Mode) Enum() *Pipeline_Mode
func (Pipeline_Mode) EnumDescriptor
deprecated
func (Pipeline_Mode) EnumDescriptor() ([]byte, []int)
Deprecated: Use Pipeline_Mode.Descriptor instead.
func (Pipeline_Mode) Number ¶
func (x Pipeline_Mode) Number() protoreflect.EnumNumber
func (Pipeline_Mode) String ¶
func (x Pipeline_Mode) String() string
func (Pipeline_Mode) Type ¶
func (Pipeline_Mode) Type() protoreflect.EnumType
type Pipeline_Org ¶
type Pipeline_Org struct { // The resource name of an organization Org string `protobuf:"bytes,9,opt,name=org,proto3,oneof"` }
type Pipeline_State ¶
type Pipeline_State int32
State enumerates the state of a pipeline
const ( // State: UNSPECIFIED Pipeline_STATE_UNSPECIFIED Pipeline_State = 0 // State INACTIVE indicates the pipeline is inactive Pipeline_STATE_INACTIVE Pipeline_State = 1 // State ACTIVE indicates the pipeline is active Pipeline_STATE_ACTIVE Pipeline_State = 2 // State ERROR indicates the pipeline has error Pipeline_STATE_ERROR Pipeline_State = 3 )
func (Pipeline_State) Descriptor ¶
func (Pipeline_State) Descriptor() protoreflect.EnumDescriptor
func (Pipeline_State) Enum ¶
func (x Pipeline_State) Enum() *Pipeline_State
func (Pipeline_State) EnumDescriptor
deprecated
func (Pipeline_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use Pipeline_State.Descriptor instead.
func (Pipeline_State) Number ¶
func (x Pipeline_State) Number() protoreflect.EnumNumber
func (Pipeline_State) String ¶
func (x Pipeline_State) String() string
func (Pipeline_State) Type ¶
func (Pipeline_State) Type() protoreflect.EnumType
type Pipeline_User ¶
type Pipeline_User struct { // The resource name of a user, e.g., "users/local-user". User string `protobuf:"bytes,8,opt,name=user,proto3,oneof"` }
type ReadinessRequest ¶
type ReadinessRequest struct { // HealthCheckRequest message HealthCheckRequest *v1alpha.HealthCheckRequest `protobuf:"bytes,1,opt,name=health_check_request,json=healthCheckRequest,proto3,oneof" json:"health_check_request,omitempty"` // contains filtered or unexported fields }
ReadinessRequest represents a request to check a service readiness status
func (*ReadinessRequest) Descriptor
deprecated
func (*ReadinessRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReadinessRequest.ProtoReflect.Descriptor instead.
func (*ReadinessRequest) GetHealthCheckRequest ¶
func (x *ReadinessRequest) GetHealthCheckRequest() *v1alpha.HealthCheckRequest
func (*ReadinessRequest) ProtoMessage ¶
func (*ReadinessRequest) ProtoMessage()
func (*ReadinessRequest) ProtoReflect ¶
func (x *ReadinessRequest) ProtoReflect() protoreflect.Message
func (*ReadinessRequest) Reset ¶
func (x *ReadinessRequest) Reset()
func (*ReadinessRequest) String ¶
func (x *ReadinessRequest) String() string
type ReadinessResponse ¶
type ReadinessResponse struct { // HealthCheckResponse message HealthCheckResponse *v1alpha.HealthCheckResponse `protobuf:"bytes,1,opt,name=health_check_response,json=healthCheckResponse,proto3" json:"health_check_response,omitempty"` // contains filtered or unexported fields }
ReadinessResponse represents a response for a service readiness status
func (*ReadinessResponse) Descriptor
deprecated
func (*ReadinessResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReadinessResponse.ProtoReflect.Descriptor instead.
func (*ReadinessResponse) GetHealthCheckResponse ¶
func (x *ReadinessResponse) GetHealthCheckResponse() *v1alpha.HealthCheckResponse
func (*ReadinessResponse) ProtoMessage ¶
func (*ReadinessResponse) ProtoMessage()
func (*ReadinessResponse) ProtoReflect ¶
func (x *ReadinessResponse) ProtoReflect() protoreflect.Message
func (*ReadinessResponse) Reset ¶
func (x *ReadinessResponse) Reset()
func (*ReadinessResponse) String ¶
func (x *ReadinessResponse) String() string
type Recipe ¶
type Recipe struct { // A source connector resource Source string `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"` // A destination connector resource Destination string `protobuf:"bytes,2,opt,name=destination,proto3" json:"destination,omitempty"` // A list of model instance resources ModelInstances []string `protobuf:"bytes,3,rep,name=model_instances,json=modelInstances,proto3" json:"model_instances,omitempty"` // contains filtered or unexported fields }
Pipeline represents a pipeline recipe
func (*Recipe) Descriptor
deprecated
func (*Recipe) GetDestination ¶
func (*Recipe) GetModelInstances ¶
func (*Recipe) ProtoMessage ¶
func (*Recipe) ProtoMessage()
func (*Recipe) ProtoReflect ¶
func (x *Recipe) ProtoReflect() protoreflect.Message
type RenamePipelineRequest ¶
type RenamePipelineRequest struct { // Pipeline resource name. It must have the format of "pipelines/*" Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Pipeline new resource id to replace with the pipeline resource name to be // "pipelines/{new_pipeline_id}" NewPipelineId string `protobuf:"bytes,2,opt,name=new_pipeline_id,json=newPipelineId,proto3" json:"new_pipeline_id,omitempty"` // contains filtered or unexported fields }
RenamePipelineRequest represents a request to rename the pipeline resource name
func (*RenamePipelineRequest) Descriptor
deprecated
func (*RenamePipelineRequest) Descriptor() ([]byte, []int)
Deprecated: Use RenamePipelineRequest.ProtoReflect.Descriptor instead.
func (*RenamePipelineRequest) GetName ¶
func (x *RenamePipelineRequest) GetName() string
func (*RenamePipelineRequest) GetNewPipelineId ¶
func (x *RenamePipelineRequest) GetNewPipelineId() string
func (*RenamePipelineRequest) ProtoMessage ¶
func (*RenamePipelineRequest) ProtoMessage()
func (*RenamePipelineRequest) ProtoReflect ¶
func (x *RenamePipelineRequest) ProtoReflect() protoreflect.Message
func (*RenamePipelineRequest) Reset ¶
func (x *RenamePipelineRequest) Reset()
func (*RenamePipelineRequest) String ¶
func (x *RenamePipelineRequest) String() string
type RenamePipelineResponse ¶
type RenamePipelineResponse struct { // A pipeline resource Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"` // contains filtered or unexported fields }
RenamePipelineResponse represents a renamed pipeline resource
func (*RenamePipelineResponse) Descriptor
deprecated
func (*RenamePipelineResponse) Descriptor() ([]byte, []int)
Deprecated: Use RenamePipelineResponse.ProtoReflect.Descriptor instead.
func (*RenamePipelineResponse) GetPipeline ¶
func (x *RenamePipelineResponse) GetPipeline() *Pipeline
func (*RenamePipelineResponse) ProtoMessage ¶
func (*RenamePipelineResponse) ProtoMessage()
func (*RenamePipelineResponse) ProtoReflect ¶
func (x *RenamePipelineResponse) ProtoReflect() protoreflect.Message
func (*RenamePipelineResponse) Reset ¶
func (x *RenamePipelineResponse) Reset()
func (*RenamePipelineResponse) String ¶
func (x *RenamePipelineResponse) String() string
type TaskOutput ¶
type TaskOutput struct { // The index of input data in a batch Index string `protobuf:"bytes,1,opt,name=index,proto3" json:"index,omitempty"` // The inference task output // // Types that are assignable to Output: // *TaskOutput_Classification // *TaskOutput_Detection // *TaskOutput_Keypoint // *TaskOutput_Ocr // *TaskOutput_Unspecified Output isTaskOutput_Output `protobuf_oneof:"output"` // contains filtered or unexported fields }
TaskOutput represents the output of a CV Task result from a model instance, extended from model.v1alpha.TaskOutput. Here we don't use a model.v1alpha.TaskOutput type field but explicitly use the replicated oneof field because we want the CV Task output to be at the same message layer like the trigger output of model instance.
func (*TaskOutput) Descriptor
deprecated
func (*TaskOutput) Descriptor() ([]byte, []int)
Deprecated: Use TaskOutput.ProtoReflect.Descriptor instead.
func (*TaskOutput) GetClassification ¶
func (x *TaskOutput) GetClassification() *v1alpha.ClassificationOutput
func (*TaskOutput) GetDetection ¶
func (x *TaskOutput) GetDetection() *v1alpha.DetectionOutput
func (*TaskOutput) GetIndex ¶
func (x *TaskOutput) GetIndex() string
func (*TaskOutput) GetKeypoint ¶
func (x *TaskOutput) GetKeypoint() *v1alpha.KeypointOutput
func (*TaskOutput) GetOcr ¶
func (x *TaskOutput) GetOcr() *v1alpha.OcrOutput
func (*TaskOutput) GetOutput ¶
func (m *TaskOutput) GetOutput() isTaskOutput_Output
func (*TaskOutput) GetUnspecified ¶
func (x *TaskOutput) GetUnspecified() *v1alpha.UnspecifiedOutput
func (*TaskOutput) ProtoMessage ¶
func (*TaskOutput) ProtoMessage()
func (*TaskOutput) ProtoReflect ¶
func (x *TaskOutput) ProtoReflect() protoreflect.Message
func (*TaskOutput) Reset ¶
func (x *TaskOutput) Reset()
func (*TaskOutput) String ¶
func (x *TaskOutput) String() string
type TaskOutput_Classification ¶
type TaskOutput_Classification struct { // The classification output Classification *v1alpha.ClassificationOutput `protobuf:"bytes,2,opt,name=classification,proto3,oneof"` }
type TaskOutput_Detection ¶
type TaskOutput_Detection struct { // The detection output Detection *v1alpha.DetectionOutput `protobuf:"bytes,3,opt,name=detection,proto3,oneof"` }
type TaskOutput_Keypoint ¶
type TaskOutput_Keypoint struct { // The keypoint output Keypoint *v1alpha.KeypointOutput `protobuf:"bytes,4,opt,name=keypoint,proto3,oneof"` }
type TaskOutput_Ocr ¶
type TaskOutput_Unspecified ¶
type TaskOutput_Unspecified struct { // The unspecified task output Unspecified *v1alpha.UnspecifiedOutput `protobuf:"bytes,6,opt,name=unspecified,proto3,oneof"` }
type TriggerPipelineBinaryFileUploadRequest ¶
type TriggerPipelineBinaryFileUploadRequest struct { // Pipeline resource name. It must have the format of "pipelines/*" Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // The list of file name for each uploaded binary file FileNames []string `protobuf:"bytes,2,rep,name=file_names,json=fileNames,proto3" json:"file_names,omitempty"` // The list of file length for each uploaded binary file FileLengths []uint64 `protobuf:"varint,3,rep,packed,name=file_lengths,json=fileLengths,proto3" json:"file_lengths,omitempty"` // Content (i.e., images) used to trigger the pipeline in bytes Content []byte `protobuf:"bytes,4,opt,name=content,proto3" json:"content,omitempty"` // contains filtered or unexported fields }
TriggerPipelineBinaryFileUploadRequest represents a request to trigger a pipeline
func (*TriggerPipelineBinaryFileUploadRequest) Descriptor
deprecated
func (*TriggerPipelineBinaryFileUploadRequest) Descriptor() ([]byte, []int)
Deprecated: Use TriggerPipelineBinaryFileUploadRequest.ProtoReflect.Descriptor instead.
func (*TriggerPipelineBinaryFileUploadRequest) GetContent ¶
func (x *TriggerPipelineBinaryFileUploadRequest) GetContent() []byte
func (*TriggerPipelineBinaryFileUploadRequest) GetFileLengths ¶
func (x *TriggerPipelineBinaryFileUploadRequest) GetFileLengths() []uint64
func (*TriggerPipelineBinaryFileUploadRequest) GetFileNames ¶
func (x *TriggerPipelineBinaryFileUploadRequest) GetFileNames() []string
func (*TriggerPipelineBinaryFileUploadRequest) GetName ¶
func (x *TriggerPipelineBinaryFileUploadRequest) GetName() string
func (*TriggerPipelineBinaryFileUploadRequest) ProtoMessage ¶
func (*TriggerPipelineBinaryFileUploadRequest) ProtoMessage()
func (*TriggerPipelineBinaryFileUploadRequest) ProtoReflect ¶
func (x *TriggerPipelineBinaryFileUploadRequest) ProtoReflect() protoreflect.Message
func (*TriggerPipelineBinaryFileUploadRequest) Reset ¶
func (x *TriggerPipelineBinaryFileUploadRequest) Reset()
func (*TriggerPipelineBinaryFileUploadRequest) String ¶
func (x *TriggerPipelineBinaryFileUploadRequest) String() string
type TriggerPipelineBinaryFileUploadResponse ¶
type TriggerPipelineBinaryFileUploadResponse struct { // The data mapping indices stores UUID for each input DataMappingIndices []string `protobuf:"bytes,1,rep,name=data_mapping_indices,json=dataMappingIndices,proto3" json:"data_mapping_indices,omitempty"` // The multiple model instance inference outputs ModelInstanceOutputs []*ModelInstanceOutput `protobuf:"bytes,2,rep,name=model_instance_outputs,json=modelInstanceOutputs,proto3" json:"model_instance_outputs,omitempty"` // contains filtered or unexported fields }
TriggerPipelineBinaryFileUploadResponse represents a response for the output of a pipeline, i.e., the multiple model instance inference outputs
func (*TriggerPipelineBinaryFileUploadResponse) Descriptor
deprecated
func (*TriggerPipelineBinaryFileUploadResponse) Descriptor() ([]byte, []int)
Deprecated: Use TriggerPipelineBinaryFileUploadResponse.ProtoReflect.Descriptor instead.
func (*TriggerPipelineBinaryFileUploadResponse) GetDataMappingIndices ¶
func (x *TriggerPipelineBinaryFileUploadResponse) GetDataMappingIndices() []string
func (*TriggerPipelineBinaryFileUploadResponse) GetModelInstanceOutputs ¶
func (x *TriggerPipelineBinaryFileUploadResponse) GetModelInstanceOutputs() []*ModelInstanceOutput
func (*TriggerPipelineBinaryFileUploadResponse) ProtoMessage ¶
func (*TriggerPipelineBinaryFileUploadResponse) ProtoMessage()
func (*TriggerPipelineBinaryFileUploadResponse) ProtoReflect ¶
func (x *TriggerPipelineBinaryFileUploadResponse) ProtoReflect() protoreflect.Message
func (*TriggerPipelineBinaryFileUploadResponse) Reset ¶
func (x *TriggerPipelineBinaryFileUploadResponse) Reset()
func (*TriggerPipelineBinaryFileUploadResponse) String ¶
func (x *TriggerPipelineBinaryFileUploadResponse) String() string
type TriggerPipelineRequest ¶
type TriggerPipelineRequest struct { // Pipeline resource name. It must have the format of "pipelines/*" Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Input to the pipeline Inputs []*Input `protobuf:"bytes,2,rep,name=inputs,proto3" json:"inputs,omitempty"` // contains filtered or unexported fields }
TriggerPipelineRequest represents a request to trigger a pipeline
func (*TriggerPipelineRequest) Descriptor
deprecated
func (*TriggerPipelineRequest) Descriptor() ([]byte, []int)
Deprecated: Use TriggerPipelineRequest.ProtoReflect.Descriptor instead.
func (*TriggerPipelineRequest) GetInputs ¶
func (x *TriggerPipelineRequest) GetInputs() []*Input
func (*TriggerPipelineRequest) GetName ¶
func (x *TriggerPipelineRequest) GetName() string
func (*TriggerPipelineRequest) ProtoMessage ¶
func (*TriggerPipelineRequest) ProtoMessage()
func (*TriggerPipelineRequest) ProtoReflect ¶
func (x *TriggerPipelineRequest) ProtoReflect() protoreflect.Message
func (*TriggerPipelineRequest) Reset ¶
func (x *TriggerPipelineRequest) Reset()
func (*TriggerPipelineRequest) String ¶
func (x *TriggerPipelineRequest) String() string
type TriggerPipelineResponse ¶
type TriggerPipelineResponse struct { // The data mapping indices stores UUID for each input DataMappingIndices []string `protobuf:"bytes,1,rep,name=data_mapping_indices,json=dataMappingIndices,proto3" json:"data_mapping_indices,omitempty"` // The multiple model instance inference outputs ModelInstanceOutputs []*ModelInstanceOutput `protobuf:"bytes,2,rep,name=model_instance_outputs,json=modelInstanceOutputs,proto3" json:"model_instance_outputs,omitempty"` // contains filtered or unexported fields }
TriggerPipelineResponse represents a response for the output of a pipeline, i.e., the multiple model instance inference outputs
func (*TriggerPipelineResponse) Descriptor
deprecated
func (*TriggerPipelineResponse) Descriptor() ([]byte, []int)
Deprecated: Use TriggerPipelineResponse.ProtoReflect.Descriptor instead.
func (*TriggerPipelineResponse) GetDataMappingIndices ¶
func (x *TriggerPipelineResponse) GetDataMappingIndices() []string
func (*TriggerPipelineResponse) GetModelInstanceOutputs ¶
func (x *TriggerPipelineResponse) GetModelInstanceOutputs() []*ModelInstanceOutput
func (*TriggerPipelineResponse) ProtoMessage ¶
func (*TriggerPipelineResponse) ProtoMessage()
func (*TriggerPipelineResponse) ProtoReflect ¶
func (x *TriggerPipelineResponse) ProtoReflect() protoreflect.Message
func (*TriggerPipelineResponse) Reset ¶
func (x *TriggerPipelineResponse) Reset()
func (*TriggerPipelineResponse) String ¶
func (x *TriggerPipelineResponse) String() string
type UnimplementedPipelineServiceServer ¶
type UnimplementedPipelineServiceServer struct { }
UnimplementedPipelineServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedPipelineServiceServer) ActivatePipeline ¶
func (UnimplementedPipelineServiceServer) ActivatePipeline(context.Context, *ActivatePipelineRequest) (*ActivatePipelineResponse, error)
func (UnimplementedPipelineServiceServer) CreatePipeline ¶
func (UnimplementedPipelineServiceServer) CreatePipeline(context.Context, *CreatePipelineRequest) (*CreatePipelineResponse, error)
func (UnimplementedPipelineServiceServer) DeactivatePipeline ¶
func (UnimplementedPipelineServiceServer) DeactivatePipeline(context.Context, *DeactivatePipelineRequest) (*DeactivatePipelineResponse, error)
func (UnimplementedPipelineServiceServer) DeletePipeline ¶
func (UnimplementedPipelineServiceServer) DeletePipeline(context.Context, *DeletePipelineRequest) (*DeletePipelineResponse, error)
func (UnimplementedPipelineServiceServer) GetPipeline ¶
func (UnimplementedPipelineServiceServer) GetPipeline(context.Context, *GetPipelineRequest) (*GetPipelineResponse, error)
func (UnimplementedPipelineServiceServer) ListPipeline ¶
func (UnimplementedPipelineServiceServer) ListPipeline(context.Context, *ListPipelineRequest) (*ListPipelineResponse, error)
func (UnimplementedPipelineServiceServer) Liveness ¶
func (UnimplementedPipelineServiceServer) Liveness(context.Context, *LivenessRequest) (*LivenessResponse, error)
func (UnimplementedPipelineServiceServer) LookUpPipeline ¶
func (UnimplementedPipelineServiceServer) LookUpPipeline(context.Context, *LookUpPipelineRequest) (*LookUpPipelineResponse, error)
func (UnimplementedPipelineServiceServer) Readiness ¶
func (UnimplementedPipelineServiceServer) Readiness(context.Context, *ReadinessRequest) (*ReadinessResponse, error)
func (UnimplementedPipelineServiceServer) RenamePipeline ¶
func (UnimplementedPipelineServiceServer) RenamePipeline(context.Context, *RenamePipelineRequest) (*RenamePipelineResponse, error)
func (UnimplementedPipelineServiceServer) TriggerPipeline ¶
func (UnimplementedPipelineServiceServer) TriggerPipeline(context.Context, *TriggerPipelineRequest) (*TriggerPipelineResponse, error)
func (UnimplementedPipelineServiceServer) TriggerPipelineBinaryFileUpload ¶
func (UnimplementedPipelineServiceServer) TriggerPipelineBinaryFileUpload(PipelineService_TriggerPipelineBinaryFileUploadServer) error
func (UnimplementedPipelineServiceServer) UpdatePipeline ¶
func (UnimplementedPipelineServiceServer) UpdatePipeline(context.Context, *UpdatePipelineRequest) (*UpdatePipelineResponse, error)
type UnsafePipelineServiceServer ¶
type UnsafePipelineServiceServer interface {
// contains filtered or unexported methods
}
UnsafePipelineServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PipelineServiceServer will result in compilation errors.
type UpdatePipelineRequest ¶
type UpdatePipelineRequest struct { // A pipeline resource to update Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"` // Update mask for a pipeline resource UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"` // contains filtered or unexported fields }
UpdatePipelineRequest represents a request to update a pipeline
func (*UpdatePipelineRequest) Descriptor
deprecated
func (*UpdatePipelineRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdatePipelineRequest.ProtoReflect.Descriptor instead.
func (*UpdatePipelineRequest) GetPipeline ¶
func (x *UpdatePipelineRequest) GetPipeline() *Pipeline
func (*UpdatePipelineRequest) GetUpdateMask ¶
func (x *UpdatePipelineRequest) GetUpdateMask() *fieldmaskpb.FieldMask
func (*UpdatePipelineRequest) ProtoMessage ¶
func (*UpdatePipelineRequest) ProtoMessage()
func (*UpdatePipelineRequest) ProtoReflect ¶
func (x *UpdatePipelineRequest) ProtoReflect() protoreflect.Message
func (*UpdatePipelineRequest) Reset ¶
func (x *UpdatePipelineRequest) Reset()
func (*UpdatePipelineRequest) String ¶
func (x *UpdatePipelineRequest) String() string
type UpdatePipelineResponse ¶
type UpdatePipelineResponse struct { // An updated pipeline resource Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"` // contains filtered or unexported fields }
UpdatePipelineResponse represents a response for a pipeline resource
func (*UpdatePipelineResponse) Descriptor
deprecated
func (*UpdatePipelineResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdatePipelineResponse.ProtoReflect.Descriptor instead.
func (*UpdatePipelineResponse) GetPipeline ¶
func (x *UpdatePipelineResponse) GetPipeline() *Pipeline
func (*UpdatePipelineResponse) ProtoMessage ¶
func (*UpdatePipelineResponse) ProtoMessage()
func (*UpdatePipelineResponse) ProtoReflect ¶
func (x *UpdatePipelineResponse) ProtoReflect() protoreflect.Message
func (*UpdatePipelineResponse) Reset ¶
func (x *UpdatePipelineResponse) Reset()
func (*UpdatePipelineResponse) String ¶
func (x *UpdatePipelineResponse) String() string
type View ¶
type View int32
View represents a view of any resource. The resource view is implemented by adding a parameter to the method request which allows the client to specify which view of the resource it wants to receive in the response.
func (View) Descriptor ¶
func (View) Descriptor() protoreflect.EnumDescriptor
func (View) EnumDescriptor
deprecated
func (View) Number ¶
func (x View) Number() protoreflect.EnumNumber
func (View) Type ¶
func (View) Type() protoreflect.EnumType