pipelinev1alpha

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
}

type ActivatePipelineResponse struct {

	// A pipeline resource
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// contains filtered or unexported fields
}

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
}

type CreatePipelineResponse struct {

	// The created pipeline resource
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// contains filtered or unexported fields
}

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
}

type DeactivatePipelineResponse struct {

	// A pipeline resource
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// contains filtered or unexported fields
}

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
}

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

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
}

type GetPipelineResponse struct {

	// A pipeline resource
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// contains filtered or unexported fields
}

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
}

type Input_ImageBase64 struct {
	// Image type base64
	ImageBase64 string `protobuf:"bytes,2,opt,name=image_base64,json=imageBase64,proto3,oneof"`
}

type Input_ImageUrl struct {
	// Image type URL
	ImageUrl string `protobuf:"bytes,1,opt,name=image_url,json=imageUrl,proto3,oneof"`
}

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
}

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
}

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
}

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
}

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
}

type LookUpPipelineResponse struct {

	// A pipeline resource
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// contains filtered or unexported fields
}

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
}

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
}

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

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
}

type PipelineService_TriggerPipelineBinaryFileUploadClient interface {
	Send(*TriggerPipelineBinaryFileUploadRequest) error
	CloseAndRecv() (*TriggerPipelineBinaryFileUploadResponse, error)
	grpc.ClientStream
}

type PipelineService_TriggerPipelineBinaryFileUploadServer interface {
	SendAndClose(*TriggerPipelineBinaryFileUploadResponse) error
	Recv() (*TriggerPipelineBinaryFileUploadRequest, error)
	grpc.ServerStream
}

type Pipeline_Mode int32

type Pipeline_Org struct {
	// The resource name of an organization
	Org string `protobuf:"bytes,9,opt,name=org,proto3,oneof"`
}

type Pipeline_State int32

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

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
}

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
}

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
}

type RenamePipelineResponse struct {

	// A pipeline resource
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// contains filtered or unexported fields
}

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
}

type TaskOutput_Classification struct {
	// The classification output
	Classification *v1alpha.ClassificationOutput `protobuf:"bytes,2,opt,name=classification,proto3,oneof"`
}

type TaskOutput_Detection struct {
	// The detection output
	Detection *v1alpha.DetectionOutput `protobuf:"bytes,3,opt,name=detection,proto3,oneof"`
}

type TaskOutput_Keypoint struct {
	// The keypoint output
	Keypoint *v1alpha.KeypointOutput `protobuf:"bytes,4,opt,name=keypoint,proto3,oneof"`
}

type TaskOutput_Ocr struct {
	// The ocr output
	Ocr *v1alpha.OcrOutput `protobuf:"bytes,5,opt,name=ocr,proto3,oneof"`
}

type TaskOutput_Unspecified struct {
	// The unspecified task output
	Unspecified *v1alpha.UnspecifiedOutput `protobuf:"bytes,6,opt,name=unspecified,proto3,oneof"`
}

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
}

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
}

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
}

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
}

type UnimplementedPipelineServiceServer struct {
}

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

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
}

type UpdatePipelineResponse struct {

	// An updated pipeline resource
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// contains filtered or unexported fields
}

type View int32