v1

package
v0.5.68 Latest Latest
Warning

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

 Go to latest Published: Aug 5, 2022 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Overview

Package v1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var File_github_com_metaprov_modelaapi_services_modelpipeline_v1_modelpipeline_proto protoreflect.FileDescriptor
View Source 
var ModelPipelineService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "github.com.metaprov.modelaapi.services.modelpipeline.v1.ModelPipelineService",
	HandlerType: (*ModelPipelineServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListModelPipelines",
			Handler:    _ModelPipelineService_ListModelPipelines_Handler,
		},
		{
			MethodName: "CreateModelPipeline",
			Handler:    _ModelPipelineService_CreateModelPipeline_Handler,
		},
		{
			MethodName: "GetModelPipeline",
			Handler:    _ModelPipelineService_GetModelPipeline_Handler,
		},
		{
			MethodName: "UpdateModelPipeline",
			Handler:    _ModelPipelineService_UpdateModelPipeline_Handler,
		},
		{
			MethodName: "DeleteModelPipeline",
			Handler:    _ModelPipelineService_DeleteModelPipeline_Handler,
		},
		{
			MethodName: "RunModelPipeline",
			Handler:    _ModelPipelineService_RunModelPipeline_Handler,
		},
		{
			MethodName: "PauseModelPipeline",
			Handler:    _ModelPipelineService_PauseModelPipeline_Handler,
		},
		{
			MethodName: "ResumeModelPipeline",
			Handler:    _ModelPipelineService_ResumeModelPipeline_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "github.com/metaprov/modelaapi/services/modelpipeline/v1/modelpipeline.proto",
}

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

Functions

func RegisterModelPipelineServiceHandler added in v0.4.687 

func RegisterModelPipelineServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterModelPipelineServiceHandler registers the http handlers for service ModelPipelineService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterModelPipelineServiceHandlerClient added in v0.4.687 

func RegisterModelPipelineServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ModelPipelineServiceClient) error

RegisterModelPipelineServiceHandlerClient registers the http handlers for service ModelPipelineService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ModelPipelineServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ModelPipelineServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ModelPipelineServiceClient" to call the correct interceptors.

func RegisterModelPipelineServiceHandlerFromEndpoint added in v0.4.687 

func RegisterModelPipelineServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterModelPipelineServiceHandlerFromEndpoint is same as RegisterModelPipelineServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterModelPipelineServiceHandlerServer added in v0.4.687 

func RegisterModelPipelineServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ModelPipelineServiceServer) error

RegisterModelPipelineServiceHandlerServer registers the http handlers for service ModelPipelineService to "mux". UnaryRPC :call ModelPipelineServiceServer 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 RegisterModelPipelineServiceHandlerFromEndpoint instead.

func RegisterModelPipelineServiceServer 

func RegisterModelPipelineServiceServer(s grpc.ServiceRegistrar, srv ModelPipelineServiceServer)

Types

type CreateModelPipelineRequest 

type CreateModelPipelineRequest struct {
	Modelpipeline *v1alpha1.ModelPipeline `protobuf:"bytes,1,opt,name=modelpipeline,proto3" json:"modelpipeline,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateModelPipelineRequest) Descriptor deprecated 

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

Deprecated: Use CreateModelPipelineRequest.ProtoReflect.Descriptor instead.

func (*CreateModelPipelineRequest) GetModelpipeline added in v0.4.481 

func (x *CreateModelPipelineRequest) GetModelpipeline() *v1alpha1.ModelPipeline

func (*CreateModelPipelineRequest) ProtoMessage 

func (*CreateModelPipelineRequest) ProtoMessage()

func (*CreateModelPipelineRequest) ProtoReflect 

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

func (*CreateModelPipelineRequest) Reset 

func (x *CreateModelPipelineRequest) Reset()

func (*CreateModelPipelineRequest) String 

func (x *CreateModelPipelineRequest) String() string

type CreateModelPipelineResponse 

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

func (*CreateModelPipelineResponse) Descriptor deprecated 

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

Deprecated: Use CreateModelPipelineResponse.ProtoReflect.Descriptor instead.

func (*CreateModelPipelineResponse) ProtoMessage 

func (*CreateModelPipelineResponse) ProtoMessage()

func (*CreateModelPipelineResponse) ProtoReflect 

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

func (*CreateModelPipelineResponse) Reset 

func (x *CreateModelPipelineResponse) Reset()

func (*CreateModelPipelineResponse) String 

func (x *CreateModelPipelineResponse) String() string

type DeleteModelPipelineRequest 

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

func (*DeleteModelPipelineRequest) Descriptor deprecated 

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

Deprecated: Use DeleteModelPipelineRequest.ProtoReflect.Descriptor instead.

func (*DeleteModelPipelineRequest) GetName 

func (x *DeleteModelPipelineRequest) GetName() string

func (*DeleteModelPipelineRequest) GetNamespace 

func (x *DeleteModelPipelineRequest) GetNamespace() string

func (*DeleteModelPipelineRequest) ProtoMessage 

func (*DeleteModelPipelineRequest) ProtoMessage()

func (*DeleteModelPipelineRequest) ProtoReflect 

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

func (*DeleteModelPipelineRequest) Reset 

func (x *DeleteModelPipelineRequest) Reset()

func (*DeleteModelPipelineRequest) String 

func (x *DeleteModelPipelineRequest) String() string

type DeleteModelPipelineResponse 

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

func (*DeleteModelPipelineResponse) Descriptor deprecated 

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

Deprecated: Use DeleteModelPipelineResponse.ProtoReflect.Descriptor instead.

func (*DeleteModelPipelineResponse) ProtoMessage 

func (*DeleteModelPipelineResponse) ProtoMessage()

func (*DeleteModelPipelineResponse) ProtoReflect 

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

func (*DeleteModelPipelineResponse) Reset 

func (x *DeleteModelPipelineResponse) Reset()

func (*DeleteModelPipelineResponse) String 

func (x *DeleteModelPipelineResponse) String() string

type GetModelPipelineRequest 

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

func (*GetModelPipelineRequest) Descriptor deprecated 

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

Deprecated: Use GetModelPipelineRequest.ProtoReflect.Descriptor instead.

func (*GetModelPipelineRequest) GetName 

func (x *GetModelPipelineRequest) GetName() string

func (*GetModelPipelineRequest) GetNamespace 

func (x *GetModelPipelineRequest) GetNamespace() string

func (*GetModelPipelineRequest) ProtoMessage 

func (*GetModelPipelineRequest) ProtoMessage()

func (*GetModelPipelineRequest) ProtoReflect 

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

func (*GetModelPipelineRequest) Reset 

func (x *GetModelPipelineRequest) Reset()

func (*GetModelPipelineRequest) String 

func (x *GetModelPipelineRequest) String() string

type GetModelPipelineResponse 

type GetModelPipelineResponse struct {
	Modelpipeline *v1alpha1.ModelPipeline `protobuf:"bytes,1,opt,name=modelpipeline,proto3" json:"modelpipeline,omitempty"`
	Yaml          string                  `protobuf:"bytes,2,opt,name=yaml,proto3" json:"yaml,omitempty"`
	// contains filtered or unexported fields
}

func (*GetModelPipelineResponse) Descriptor deprecated 

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

Deprecated: Use GetModelPipelineResponse.ProtoReflect.Descriptor instead.

func (*GetModelPipelineResponse) GetModelpipeline added in v0.4.480 

func (x *GetModelPipelineResponse) GetModelpipeline() *v1alpha1.ModelPipeline

func (*GetModelPipelineResponse) GetYaml 

func (x *GetModelPipelineResponse) GetYaml() string

func (*GetModelPipelineResponse) ProtoMessage 

func (*GetModelPipelineResponse) ProtoMessage()

func (*GetModelPipelineResponse) ProtoReflect 

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

func (*GetModelPipelineResponse) Reset 

func (x *GetModelPipelineResponse) Reset()

func (*GetModelPipelineResponse) String 

func (x *GetModelPipelineResponse) String() string

type ListModelPipelinesRequest 

type ListModelPipelinesRequest struct {
	Namespace string            `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Labels    map[string]string `` /* 153-byte string literal not displayed */
	PageSize  int32             `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	PageToken string            `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	OrderBy   string            `protobuf:"bytes,5,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
	// contains filtered or unexported fields
}

func (*ListModelPipelinesRequest) Descriptor deprecated 

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

Deprecated: Use ListModelPipelinesRequest.ProtoReflect.Descriptor instead.

func (*ListModelPipelinesRequest) GetLabels 

func (x *ListModelPipelinesRequest) GetLabels() map[string]string

func (*ListModelPipelinesRequest) GetNamespace 

func (x *ListModelPipelinesRequest) GetNamespace() string

func (*ListModelPipelinesRequest) GetOrderBy added in v0.4.414 

func (x *ListModelPipelinesRequest) GetOrderBy() string

func (*ListModelPipelinesRequest) GetPageSize added in v0.4.414 

func (x *ListModelPipelinesRequest) GetPageSize() int32

func (*ListModelPipelinesRequest) GetPageToken added in v0.4.414 

func (x *ListModelPipelinesRequest) GetPageToken() string

func (*ListModelPipelinesRequest) ProtoMessage 

func (*ListModelPipelinesRequest) ProtoMessage()

func (*ListModelPipelinesRequest) ProtoReflect 

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

func (*ListModelPipelinesRequest) Reset 

func (x *ListModelPipelinesRequest) Reset()

func (*ListModelPipelinesRequest) String 

func (x *ListModelPipelinesRequest) String() string

type ListModelPipelinesResponse 

type ListModelPipelinesResponse struct {
	Modelpipelines *v1alpha1.ModelPipelineList `protobuf:"bytes,1,opt,name=modelpipelines,proto3" json:"modelpipelines,omitempty"`
	NextPageToken  string                      `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListModelPipelinesResponse) Descriptor deprecated 

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

Deprecated: Use ListModelPipelinesResponse.ProtoReflect.Descriptor instead.

func (*ListModelPipelinesResponse) GetModelpipelines added in v0.4.481 

func (x *ListModelPipelinesResponse) GetModelpipelines() *v1alpha1.ModelPipelineList

func (*ListModelPipelinesResponse) GetNextPageToken added in v0.4.472 

func (x *ListModelPipelinesResponse) GetNextPageToken() string

func (*ListModelPipelinesResponse) ProtoMessage 

func (*ListModelPipelinesResponse) ProtoMessage()

func (*ListModelPipelinesResponse) ProtoReflect 

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

func (*ListModelPipelinesResponse) Reset 

func (x *ListModelPipelinesResponse) Reset()

func (*ListModelPipelinesResponse) String 

func (x *ListModelPipelinesResponse) String() string

type ModelPipelineResponse 

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

func (*ModelPipelineResponse) Descriptor deprecated 

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

Deprecated: Use ModelPipelineResponse.ProtoReflect.Descriptor instead.

func (*ModelPipelineResponse) ProtoMessage 

func (*ModelPipelineResponse) ProtoMessage()

func (*ModelPipelineResponse) ProtoReflect 

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

func (*ModelPipelineResponse) Reset 

func (x *ModelPipelineResponse) Reset()

func (*ModelPipelineResponse) String 

func (x *ModelPipelineResponse) String() string

type ModelPipelineServiceClient 

type ModelPipelineServiceClient interface {
	ListModelPipelines(ctx context.Context, in *ListModelPipelinesRequest, opts ...grpc.CallOption) (*ListModelPipelinesResponse, error)
	CreateModelPipeline(ctx context.Context, in *CreateModelPipelineRequest, opts ...grpc.CallOption) (*CreateModelPipelineResponse, error)
	GetModelPipeline(ctx context.Context, in *GetModelPipelineRequest, opts ...grpc.CallOption) (*GetModelPipelineResponse, error)
	UpdateModelPipeline(ctx context.Context, in *UpdateModelPipelineRequest, opts ...grpc.CallOption) (*UpdateModelPipelineResponse, error)
	DeleteModelPipeline(ctx context.Context, in *DeleteModelPipelineRequest, opts ...grpc.CallOption) (*DeleteModelPipelineResponse, error)
	RunModelPipeline(ctx context.Context, in *RunModelPipelineRequest, opts ...grpc.CallOption) (*RunModelPipelineResponse, error)
	PauseModelPipeline(ctx context.Context, in *PauseModelPipelineRequest, opts ...grpc.CallOption) (*PauseModelPipelineResponse, error)
	ResumeModelPipeline(ctx context.Context, in *ResumeModelPipelineRequest, opts ...grpc.CallOption) (*ResumeModelPipelineResponse, error)
}

ModelPipelineServiceClient is the client API for ModelPipelineService 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 NewModelPipelineServiceClient 

func NewModelPipelineServiceClient(cc grpc.ClientConnInterface) ModelPipelineServiceClient

type ModelPipelineServiceServer 

type ModelPipelineServiceServer interface {
	ListModelPipelines(context.Context, *ListModelPipelinesRequest) (*ListModelPipelinesResponse, error)
	CreateModelPipeline(context.Context, *CreateModelPipelineRequest) (*CreateModelPipelineResponse, error)
	GetModelPipeline(context.Context, *GetModelPipelineRequest) (*GetModelPipelineResponse, error)
	UpdateModelPipeline(context.Context, *UpdateModelPipelineRequest) (*UpdateModelPipelineResponse, error)
	DeleteModelPipeline(context.Context, *DeleteModelPipelineRequest) (*DeleteModelPipelineResponse, error)
	RunModelPipeline(context.Context, *RunModelPipelineRequest) (*RunModelPipelineResponse, error)
	PauseModelPipeline(context.Context, *PauseModelPipelineRequest) (*PauseModelPipelineResponse, error)
	ResumeModelPipeline(context.Context, *ResumeModelPipelineRequest) (*ResumeModelPipelineResponse, error)
	// contains filtered or unexported methods
}

ModelPipelineServiceServer is the server API for ModelPipelineService service. All implementations must embed UnimplementedModelPipelineServiceServer for forward compatibility

type PauseModelPipelineRequest 

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

func (*PauseModelPipelineRequest) Descriptor deprecated 

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

Deprecated: Use PauseModelPipelineRequest.ProtoReflect.Descriptor instead.

func (*PauseModelPipelineRequest) GetName 

func (x *PauseModelPipelineRequest) GetName() string

func (*PauseModelPipelineRequest) GetNamespace 

func (x *PauseModelPipelineRequest) GetNamespace() string

func (*PauseModelPipelineRequest) ProtoMessage 

func (*PauseModelPipelineRequest) ProtoMessage()

func (*PauseModelPipelineRequest) ProtoReflect 

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

func (*PauseModelPipelineRequest) Reset 

func (x *PauseModelPipelineRequest) Reset()

func (*PauseModelPipelineRequest) String 

func (x *PauseModelPipelineRequest) String() string

type PauseModelPipelineResponse 

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

func (*PauseModelPipelineResponse) Descriptor deprecated 

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

Deprecated: Use PauseModelPipelineResponse.ProtoReflect.Descriptor instead.

func (*PauseModelPipelineResponse) ProtoMessage 

func (*PauseModelPipelineResponse) ProtoMessage()

func (*PauseModelPipelineResponse) ProtoReflect 

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

func (*PauseModelPipelineResponse) Reset 

func (x *PauseModelPipelineResponse) Reset()

func (*PauseModelPipelineResponse) String 

func (x *PauseModelPipelineResponse) String() string

type ResumeModelPipelineRequest 

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

func (*ResumeModelPipelineRequest) Descriptor deprecated 

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

Deprecated: Use ResumeModelPipelineRequest.ProtoReflect.Descriptor instead.

func (*ResumeModelPipelineRequest) GetName 

func (x *ResumeModelPipelineRequest) GetName() string

func (*ResumeModelPipelineRequest) GetNamespace 

func (x *ResumeModelPipelineRequest) GetNamespace() string

func (*ResumeModelPipelineRequest) ProtoMessage 

func (*ResumeModelPipelineRequest) ProtoMessage()

func (*ResumeModelPipelineRequest) ProtoReflect 

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

func (*ResumeModelPipelineRequest) Reset 

func (x *ResumeModelPipelineRequest) Reset()

func (*ResumeModelPipelineRequest) String 

func (x *ResumeModelPipelineRequest) String() string

type ResumeModelPipelineResponse 

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

func (*ResumeModelPipelineResponse) Descriptor deprecated 

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

Deprecated: Use ResumeModelPipelineResponse.ProtoReflect.Descriptor instead.

func (*ResumeModelPipelineResponse) ProtoMessage 

func (*ResumeModelPipelineResponse) ProtoMessage()

func (*ResumeModelPipelineResponse) ProtoReflect 

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

func (*ResumeModelPipelineResponse) Reset 

func (x *ResumeModelPipelineResponse) Reset()

func (*ResumeModelPipelineResponse) String 

func (x *ResumeModelPipelineResponse) String() string

type RunModelPipelineRequest 

type RunModelPipelineRequest struct {
	Modelpipeline *v1alpha1.ModelPipeline `protobuf:"bytes,1,opt,name=modelpipeline,proto3" json:"modelpipeline,omitempty"`
	// contains filtered or unexported fields
}

func (*RunModelPipelineRequest) Descriptor deprecated 

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

Deprecated: Use RunModelPipelineRequest.ProtoReflect.Descriptor instead.

func (*RunModelPipelineRequest) GetModelpipeline added in v0.4.480 

func (x *RunModelPipelineRequest) GetModelpipeline() *v1alpha1.ModelPipeline

func (*RunModelPipelineRequest) ProtoMessage 

func (*RunModelPipelineRequest) ProtoMessage()

func (*RunModelPipelineRequest) ProtoReflect 

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

func (*RunModelPipelineRequest) Reset 

func (x *RunModelPipelineRequest) Reset()

func (*RunModelPipelineRequest) String 

func (x *RunModelPipelineRequest) String() string

type RunModelPipelineResponse 

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

func (*RunModelPipelineResponse) Descriptor deprecated 

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

Deprecated: Use RunModelPipelineResponse.ProtoReflect.Descriptor instead.

func (*RunModelPipelineResponse) ProtoMessage 

func (*RunModelPipelineResponse) ProtoMessage()

func (*RunModelPipelineResponse) ProtoReflect 

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

func (*RunModelPipelineResponse) Reset 

func (x *RunModelPipelineResponse) Reset()

func (*RunModelPipelineResponse) String 

func (x *RunModelPipelineResponse) String() string

type UnimplementedModelPipelineServiceServer 

type UnimplementedModelPipelineServiceServer struct {
}

UnimplementedModelPipelineServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedModelPipelineServiceServer) CreateModelPipeline 

func (UnimplementedModelPipelineServiceServer) CreateModelPipeline(context.Context, *CreateModelPipelineRequest) (*CreateModelPipelineResponse, error)

func (UnimplementedModelPipelineServiceServer) DeleteModelPipeline 

func (UnimplementedModelPipelineServiceServer) DeleteModelPipeline(context.Context, *DeleteModelPipelineRequest) (*DeleteModelPipelineResponse, error)

func (UnimplementedModelPipelineServiceServer) GetModelPipeline 

func (UnimplementedModelPipelineServiceServer) GetModelPipeline(context.Context, *GetModelPipelineRequest) (*GetModelPipelineResponse, error)

func (UnimplementedModelPipelineServiceServer) ListModelPipelines 

func (UnimplementedModelPipelineServiceServer) ListModelPipelines(context.Context, *ListModelPipelinesRequest) (*ListModelPipelinesResponse, error)

func (UnimplementedModelPipelineServiceServer) PauseModelPipeline 

func (UnimplementedModelPipelineServiceServer) PauseModelPipeline(context.Context, *PauseModelPipelineRequest) (*PauseModelPipelineResponse, error)

func (UnimplementedModelPipelineServiceServer) ResumeModelPipeline 

func (UnimplementedModelPipelineServiceServer) ResumeModelPipeline(context.Context, *ResumeModelPipelineRequest) (*ResumeModelPipelineResponse, error)

func (UnimplementedModelPipelineServiceServer) RunModelPipeline 

func (UnimplementedModelPipelineServiceServer) RunModelPipeline(context.Context, *RunModelPipelineRequest) (*RunModelPipelineResponse, error)

func (UnimplementedModelPipelineServiceServer) UpdateModelPipeline 

func (UnimplementedModelPipelineServiceServer) UpdateModelPipeline(context.Context, *UpdateModelPipelineRequest) (*UpdateModelPipelineResponse, error)

type UnsafeModelPipelineServiceServer added in v0.4.687 

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

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

type UpdateModelPipelineRequest 

type UpdateModelPipelineRequest struct {
	Modelpipeline *v1alpha1.ModelPipeline `protobuf:"bytes,1,opt,name=modelpipeline,proto3" json:"modelpipeline,omitempty"`
	FieldMask     *field_mask.FieldMask   `protobuf:"bytes,2,opt,name=field_mask,json=fieldMask,proto3" json:"field_mask,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateModelPipelineRequest) Descriptor deprecated 

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

Deprecated: Use UpdateModelPipelineRequest.ProtoReflect.Descriptor instead.

func (*UpdateModelPipelineRequest) GetFieldMask added in v0.4.422 

func (x *UpdateModelPipelineRequest) GetFieldMask() *field_mask.FieldMask

func (*UpdateModelPipelineRequest) GetModelpipeline added in v0.4.481 

func (x *UpdateModelPipelineRequest) GetModelpipeline() *v1alpha1.ModelPipeline

func (*UpdateModelPipelineRequest) ProtoMessage 

func (*UpdateModelPipelineRequest) ProtoMessage()

func (*UpdateModelPipelineRequest) ProtoReflect 

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

func (*UpdateModelPipelineRequest) Reset 

func (x *UpdateModelPipelineRequest) Reset()

func (*UpdateModelPipelineRequest) String 

func (x *UpdateModelPipelineRequest) String() string

type UpdateModelPipelineResponse 

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

func (*UpdateModelPipelineResponse) Descriptor deprecated 

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

Deprecated: Use UpdateModelPipelineResponse.ProtoReflect.Descriptor instead.

func (*UpdateModelPipelineResponse) ProtoMessage 

func (*UpdateModelPipelineResponse) ProtoMessage()

func (*UpdateModelPipelineResponse) ProtoReflect 

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

func (*UpdateModelPipelineResponse) Reset 

func (x *UpdateModelPipelineResponse) Reset()

func (*UpdateModelPipelineResponse) String 

func (x *UpdateModelPipelineResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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