v1

package
v0.4.850 Latest Latest
Warning

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

 Go to latest Published: Jun 11, 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_modelpipelinerun_v1_modelpipelinerun_proto protoreflect.FileDescriptor
View Source 
var ModelPipelineRunService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "github.com.metaprov.modelaapi.services.modelpipelinerun.v1.ModelPipelineRunService",
	HandlerType: (*ModelPipelineRunServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListModelPipelineRuns",
			Handler:    _ModelPipelineRunService_ListModelPipelineRuns_Handler,
		},
		{
			MethodName: "CreateModelPipelineRun",
			Handler:    _ModelPipelineRunService_CreateModelPipelineRun_Handler,
		},
		{
			MethodName: "GetModelPipelineRun",
			Handler:    _ModelPipelineRunService_GetModelPipelineRun_Handler,
		},
		{
			MethodName: "UpdateModelPipelineRun",
			Handler:    _ModelPipelineRunService_UpdateModelPipelineRun_Handler,
		},
		{
			MethodName: "DeleteModelPipelineRun",
			Handler:    _ModelPipelineRunService_DeleteModelPipelineRun_Handler,
		},
		{
			MethodName: "ApproveModelPipelineRun",
			Handler:    _ModelPipelineRunService_ApproveModelPipelineRun_Handler,
		},
		{
			MethodName: "DenyModelPipelineRun",
			Handler:    _ModelPipelineRunService_DenyModelPipelineRun_Handler,
		},
		{
			MethodName: "AbortModelPipelineRun",
			Handler:    _ModelPipelineRunService_AbortModelPipelineRun_Handler,
		},
		{
			MethodName: "PauseModelPipelineRun",
			Handler:    _ModelPipelineRunService_PauseModelPipelineRun_Handler,
		},
		{
			MethodName: "ResumeModelPipelineRun",
			Handler:    _ModelPipelineRunService_ResumeModelPipelineRun_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "github.com/metaprov/modelaapi/services/modelpipelinerun/v1/modelpipelinerun.proto",
}

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

Functions

func RegisterModelPipelineRunServiceHandler added in v0.4.687 

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

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

func RegisterModelPipelineRunServiceHandlerClient added in v0.4.687 

func RegisterModelPipelineRunServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ModelPipelineRunServiceClient) error

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

func RegisterModelPipelineRunServiceHandlerFromEndpoint added in v0.4.687 

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

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

func RegisterModelPipelineRunServiceHandlerServer added in v0.4.687 

func RegisterModelPipelineRunServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ModelPipelineRunServiceServer) error

RegisterModelPipelineRunServiceHandlerServer registers the http handlers for service ModelPipelineRunService to "mux". UnaryRPC :call ModelPipelineRunServiceServer 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 RegisterModelPipelineRunServiceHandlerFromEndpoint instead.

func RegisterModelPipelineRunServiceServer 

func RegisterModelPipelineRunServiceServer(s grpc.ServiceRegistrar, srv ModelPipelineRunServiceServer)

Types

type AbortModelPipelineRunRequest 

type AbortModelPipelineRunRequest 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 (*AbortModelPipelineRunRequest) Descriptor deprecated 

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

Deprecated: Use AbortModelPipelineRunRequest.ProtoReflect.Descriptor instead.

func (*AbortModelPipelineRunRequest) GetName 

func (x *AbortModelPipelineRunRequest) GetName() string

func (*AbortModelPipelineRunRequest) GetNamespace 

func (x *AbortModelPipelineRunRequest) GetNamespace() string

func (*AbortModelPipelineRunRequest) ProtoMessage 

func (*AbortModelPipelineRunRequest) ProtoMessage()

func (*AbortModelPipelineRunRequest) ProtoReflect 

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

func (*AbortModelPipelineRunRequest) Reset 

func (x *AbortModelPipelineRunRequest) Reset()

func (*AbortModelPipelineRunRequest) String 

func (x *AbortModelPipelineRunRequest) String() string

type AbortModelPipelineRunResponse 

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

func (*AbortModelPipelineRunResponse) Descriptor deprecated 

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

Deprecated: Use AbortModelPipelineRunResponse.ProtoReflect.Descriptor instead.

func (*AbortModelPipelineRunResponse) ProtoMessage 

func (*AbortModelPipelineRunResponse) ProtoMessage()

func (*AbortModelPipelineRunResponse) ProtoReflect 

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

func (*AbortModelPipelineRunResponse) Reset 

func (x *AbortModelPipelineRunResponse) Reset()

func (*AbortModelPipelineRunResponse) String 

func (x *AbortModelPipelineRunResponse) String() string

type ApproveModelPipelineRunRequest 

type ApproveModelPipelineRunRequest 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"`
	Stage     string `protobuf:"bytes,3,opt,name=stage,proto3" json:"stage,omitempty"`
	Account   string `protobuf:"bytes,4,opt,name=account,proto3" json:"account,omitempty"`
	// contains filtered or unexported fields
}

func (*ApproveModelPipelineRunRequest) Descriptor deprecated 

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

Deprecated: Use ApproveModelPipelineRunRequest.ProtoReflect.Descriptor instead.

func (*ApproveModelPipelineRunRequest) GetAccount 

func (x *ApproveModelPipelineRunRequest) GetAccount() string

func (*ApproveModelPipelineRunRequest) GetName 

func (x *ApproveModelPipelineRunRequest) GetName() string

func (*ApproveModelPipelineRunRequest) GetNamespace 

func (x *ApproveModelPipelineRunRequest) GetNamespace() string

func (*ApproveModelPipelineRunRequest) GetStage 

func (x *ApproveModelPipelineRunRequest) GetStage() string

func (*ApproveModelPipelineRunRequest) ProtoMessage 

func (*ApproveModelPipelineRunRequest) ProtoMessage()

func (*ApproveModelPipelineRunRequest) ProtoReflect 

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

func (*ApproveModelPipelineRunRequest) Reset 

func (x *ApproveModelPipelineRunRequest) Reset()

func (*ApproveModelPipelineRunRequest) String 

func (x *ApproveModelPipelineRunRequest) String() string

type ApproveModelPipelineRunResponse 

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

func (*ApproveModelPipelineRunResponse) Descriptor deprecated 

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

Deprecated: Use ApproveModelPipelineRunResponse.ProtoReflect.Descriptor instead.

func (*ApproveModelPipelineRunResponse) ProtoMessage 

func (*ApproveModelPipelineRunResponse) ProtoMessage()

func (*ApproveModelPipelineRunResponse) ProtoReflect 

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

func (*ApproveModelPipelineRunResponse) Reset 

func (x *ApproveModelPipelineRunResponse) Reset()

func (*ApproveModelPipelineRunResponse) String 

func (x *ApproveModelPipelineRunResponse) String() string

type CreateModelPipelineRunRequest 

type CreateModelPipelineRunRequest struct {
	Modelpipelinerun *v1alpha1.ModelPipelineRun `protobuf:"bytes,1,opt,name=modelpipelinerun,proto3" json:"modelpipelinerun,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateModelPipelineRunRequest) Descriptor deprecated 

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

Deprecated: Use CreateModelPipelineRunRequest.ProtoReflect.Descriptor instead.

func (*CreateModelPipelineRunRequest) GetModelpipelinerun added in v0.4.531 

func (x *CreateModelPipelineRunRequest) GetModelpipelinerun() *v1alpha1.ModelPipelineRun

func (*CreateModelPipelineRunRequest) ProtoMessage 

func (*CreateModelPipelineRunRequest) ProtoMessage()

func (*CreateModelPipelineRunRequest) ProtoReflect 

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

func (*CreateModelPipelineRunRequest) Reset 

func (x *CreateModelPipelineRunRequest) Reset()

func (*CreateModelPipelineRunRequest) String 

func (x *CreateModelPipelineRunRequest) String() string

type CreateModelPipelineRunResponse 

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

func (*CreateModelPipelineRunResponse) Descriptor deprecated 

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

Deprecated: Use CreateModelPipelineRunResponse.ProtoReflect.Descriptor instead.

func (*CreateModelPipelineRunResponse) ProtoMessage 

func (*CreateModelPipelineRunResponse) ProtoMessage()

func (*CreateModelPipelineRunResponse) ProtoReflect 

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

func (*CreateModelPipelineRunResponse) Reset 

func (x *CreateModelPipelineRunResponse) Reset()

func (*CreateModelPipelineRunResponse) String 

func (x *CreateModelPipelineRunResponse) String() string

type DeleteModelPipelineRunRequest 

type DeleteModelPipelineRunRequest 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 (*DeleteModelPipelineRunRequest) Descriptor deprecated 

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

Deprecated: Use DeleteModelPipelineRunRequest.ProtoReflect.Descriptor instead.

func (*DeleteModelPipelineRunRequest) GetName 

func (x *DeleteModelPipelineRunRequest) GetName() string

func (*DeleteModelPipelineRunRequest) GetNamespace 

func (x *DeleteModelPipelineRunRequest) GetNamespace() string

func (*DeleteModelPipelineRunRequest) ProtoMessage 

func (*DeleteModelPipelineRunRequest) ProtoMessage()

func (*DeleteModelPipelineRunRequest) ProtoReflect 

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

func (*DeleteModelPipelineRunRequest) Reset 

func (x *DeleteModelPipelineRunRequest) Reset()

func (*DeleteModelPipelineRunRequest) String 

func (x *DeleteModelPipelineRunRequest) String() string

type DeleteModelPipelineRunResponse 

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

func (*DeleteModelPipelineRunResponse) Descriptor deprecated 

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

Deprecated: Use DeleteModelPipelineRunResponse.ProtoReflect.Descriptor instead.

func (*DeleteModelPipelineRunResponse) ProtoMessage 

func (*DeleteModelPipelineRunResponse) ProtoMessage()

func (*DeleteModelPipelineRunResponse) ProtoReflect 

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

func (*DeleteModelPipelineRunResponse) Reset 

func (x *DeleteModelPipelineRunResponse) Reset()

func (*DeleteModelPipelineRunResponse) String 

func (x *DeleteModelPipelineRunResponse) String() string

type DenyModelPipelineRunRequest 

type DenyModelPipelineRunRequest 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"`
	Stage     string `protobuf:"bytes,3,opt,name=stage,proto3" json:"stage,omitempty"`
	Account   string `protobuf:"bytes,4,opt,name=account,proto3" json:"account,omitempty"`
	// contains filtered or unexported fields
}

func (*DenyModelPipelineRunRequest) Descriptor deprecated 

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

Deprecated: Use DenyModelPipelineRunRequest.ProtoReflect.Descriptor instead.

func (*DenyModelPipelineRunRequest) GetAccount 

func (x *DenyModelPipelineRunRequest) GetAccount() string

func (*DenyModelPipelineRunRequest) GetName 

func (x *DenyModelPipelineRunRequest) GetName() string

func (*DenyModelPipelineRunRequest) GetNamespace 

func (x *DenyModelPipelineRunRequest) GetNamespace() string

func (*DenyModelPipelineRunRequest) GetStage 

func (x *DenyModelPipelineRunRequest) GetStage() string

func (*DenyModelPipelineRunRequest) ProtoMessage 

func (*DenyModelPipelineRunRequest) ProtoMessage()

func (*DenyModelPipelineRunRequest) ProtoReflect 

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

func (*DenyModelPipelineRunRequest) Reset 

func (x *DenyModelPipelineRunRequest) Reset()

func (*DenyModelPipelineRunRequest) String 

func (x *DenyModelPipelineRunRequest) String() string

type DenyModelPipelineRunResponse 

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

func (*DenyModelPipelineRunResponse) Descriptor deprecated 

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

Deprecated: Use DenyModelPipelineRunResponse.ProtoReflect.Descriptor instead.

func (*DenyModelPipelineRunResponse) ProtoMessage 

func (*DenyModelPipelineRunResponse) ProtoMessage()

func (*DenyModelPipelineRunResponse) ProtoReflect 

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

func (*DenyModelPipelineRunResponse) Reset 

func (x *DenyModelPipelineRunResponse) Reset()

func (*DenyModelPipelineRunResponse) String 

func (x *DenyModelPipelineRunResponse) String() string

type GetModelPipelineRunRequest 

type GetModelPipelineRunRequest 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 (*GetModelPipelineRunRequest) Descriptor deprecated 

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

Deprecated: Use GetModelPipelineRunRequest.ProtoReflect.Descriptor instead.

func (*GetModelPipelineRunRequest) GetName 

func (x *GetModelPipelineRunRequest) GetName() string

func (*GetModelPipelineRunRequest) GetNamespace 

func (x *GetModelPipelineRunRequest) GetNamespace() string

func (*GetModelPipelineRunRequest) ProtoMessage 

func (*GetModelPipelineRunRequest) ProtoMessage()

func (*GetModelPipelineRunRequest) ProtoReflect 

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

func (*GetModelPipelineRunRequest) Reset 

func (x *GetModelPipelineRunRequest) Reset()

func (*GetModelPipelineRunRequest) String 

func (x *GetModelPipelineRunRequest) String() string

type GetModelPipelineRunResponse 

type GetModelPipelineRunResponse struct {
	Modelpipelinerun *v1alpha1.ModelPipelineRun `protobuf:"bytes,1,opt,name=modelpipelinerun,proto3" json:"modelpipelinerun,omitempty"`
	Yaml             string                     `protobuf:"bytes,2,opt,name=yaml,proto3" json:"yaml,omitempty"`
	// contains filtered or unexported fields
}

func (*GetModelPipelineRunResponse) Descriptor deprecated 

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

Deprecated: Use GetModelPipelineRunResponse.ProtoReflect.Descriptor instead.

func (*GetModelPipelineRunResponse) GetModelpipelinerun added in v0.4.531 

func (x *GetModelPipelineRunResponse) GetModelpipelinerun() *v1alpha1.ModelPipelineRun

func (*GetModelPipelineRunResponse) GetYaml 

func (x *GetModelPipelineRunResponse) GetYaml() string

func (*GetModelPipelineRunResponse) ProtoMessage 

func (*GetModelPipelineRunResponse) ProtoMessage()

func (*GetModelPipelineRunResponse) ProtoReflect 

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

func (*GetModelPipelineRunResponse) Reset 

func (x *GetModelPipelineRunResponse) Reset()

func (*GetModelPipelineRunResponse) String 

func (x *GetModelPipelineRunResponse) String() string

type ListModelPipelineRunsRequest 

type ListModelPipelineRunsRequest 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 (*ListModelPipelineRunsRequest) Descriptor deprecated 

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

Deprecated: Use ListModelPipelineRunsRequest.ProtoReflect.Descriptor instead.

func (*ListModelPipelineRunsRequest) GetLabels 

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

func (*ListModelPipelineRunsRequest) GetNamespace 

func (x *ListModelPipelineRunsRequest) GetNamespace() string

func (*ListModelPipelineRunsRequest) GetOrderBy added in v0.4.414 

func (x *ListModelPipelineRunsRequest) GetOrderBy() string

func (*ListModelPipelineRunsRequest) GetPageSize added in v0.4.414 

func (x *ListModelPipelineRunsRequest) GetPageSize() int32

func (*ListModelPipelineRunsRequest) GetPageToken added in v0.4.414 

func (x *ListModelPipelineRunsRequest) GetPageToken() string

func (*ListModelPipelineRunsRequest) ProtoMessage 

func (*ListModelPipelineRunsRequest) ProtoMessage()

func (*ListModelPipelineRunsRequest) ProtoReflect 

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

func (*ListModelPipelineRunsRequest) Reset 

func (x *ListModelPipelineRunsRequest) Reset()

func (*ListModelPipelineRunsRequest) String 

func (x *ListModelPipelineRunsRequest) String() string

type ListModelPipelineRunsResponse 

type ListModelPipelineRunsResponse struct {
	Modelpipelineruns *v1alpha1.ModelPipelineRunList `protobuf:"bytes,1,opt,name=modelpipelineruns,proto3" json:"modelpipelineruns,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 (*ListModelPipelineRunsResponse) Descriptor deprecated 

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

Deprecated: Use ListModelPipelineRunsResponse.ProtoReflect.Descriptor instead.

func (*ListModelPipelineRunsResponse) GetModelpipelineruns added in v0.4.531 

func (x *ListModelPipelineRunsResponse) GetModelpipelineruns() *v1alpha1.ModelPipelineRunList

func (*ListModelPipelineRunsResponse) GetNextPageToken added in v0.4.472 

func (x *ListModelPipelineRunsResponse) GetNextPageToken() string

func (*ListModelPipelineRunsResponse) ProtoMessage 

func (*ListModelPipelineRunsResponse) ProtoMessage()

func (*ListModelPipelineRunsResponse) ProtoReflect 

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

func (*ListModelPipelineRunsResponse) Reset 

func (x *ListModelPipelineRunsResponse) Reset()

func (*ListModelPipelineRunsResponse) String 

func (x *ListModelPipelineRunsResponse) String() string

type ModelPipelineRunResponse 

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

func (*ModelPipelineRunResponse) Descriptor deprecated 

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

Deprecated: Use ModelPipelineRunResponse.ProtoReflect.Descriptor instead.

func (*ModelPipelineRunResponse) ProtoMessage 

func (*ModelPipelineRunResponse) ProtoMessage()

func (*ModelPipelineRunResponse) ProtoReflect 

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

func (*ModelPipelineRunResponse) Reset 

func (x *ModelPipelineRunResponse) Reset()

func (*ModelPipelineRunResponse) String 

func (x *ModelPipelineRunResponse) String() string

type ModelPipelineRunServiceClient 

type ModelPipelineRunServiceClient interface {
	ListModelPipelineRuns(ctx context.Context, in *ListModelPipelineRunsRequest, opts ...grpc.CallOption) (*ListModelPipelineRunsResponse, error)
	CreateModelPipelineRun(ctx context.Context, in *CreateModelPipelineRunRequest, opts ...grpc.CallOption) (*CreateModelPipelineRunResponse, error)
	GetModelPipelineRun(ctx context.Context, in *GetModelPipelineRunRequest, opts ...grpc.CallOption) (*GetModelPipelineRunResponse, error)
	UpdateModelPipelineRun(ctx context.Context, in *UpdateModelPipelineRunRequest, opts ...grpc.CallOption) (*UpdateModelPipelineRunResponse, error)
	DeleteModelPipelineRun(ctx context.Context, in *DeleteModelPipelineRunRequest, opts ...grpc.CallOption) (*DeleteModelPipelineRunResponse, error)
	ApproveModelPipelineRun(ctx context.Context, in *ApproveModelPipelineRunRequest, opts ...grpc.CallOption) (*ApproveModelPipelineRunResponse, error)
	DenyModelPipelineRun(ctx context.Context, in *DenyModelPipelineRunRequest, opts ...grpc.CallOption) (*DenyModelPipelineRunResponse, error)
	AbortModelPipelineRun(ctx context.Context, in *AbortModelPipelineRunRequest, opts ...grpc.CallOption) (*AbortModelPipelineRunResponse, error)
	PauseModelPipelineRun(ctx context.Context, in *PauseModelPipelineRunRequest, opts ...grpc.CallOption) (*PauseModelPipelineRunResponse, error)
	ResumeModelPipelineRun(ctx context.Context, in *ResumeModelPipelineRunRequest, opts ...grpc.CallOption) (*ResumeModelPipelineRunResponse, error)
}

ModelPipelineRunServiceClient is the client API for ModelPipelineRunService 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 NewModelPipelineRunServiceClient 

func NewModelPipelineRunServiceClient(cc grpc.ClientConnInterface) ModelPipelineRunServiceClient

type ModelPipelineRunServiceServer 

type ModelPipelineRunServiceServer interface {
	ListModelPipelineRuns(context.Context, *ListModelPipelineRunsRequest) (*ListModelPipelineRunsResponse, error)
	CreateModelPipelineRun(context.Context, *CreateModelPipelineRunRequest) (*CreateModelPipelineRunResponse, error)
	GetModelPipelineRun(context.Context, *GetModelPipelineRunRequest) (*GetModelPipelineRunResponse, error)
	UpdateModelPipelineRun(context.Context, *UpdateModelPipelineRunRequest) (*UpdateModelPipelineRunResponse, error)
	DeleteModelPipelineRun(context.Context, *DeleteModelPipelineRunRequest) (*DeleteModelPipelineRunResponse, error)
	ApproveModelPipelineRun(context.Context, *ApproveModelPipelineRunRequest) (*ApproveModelPipelineRunResponse, error)
	DenyModelPipelineRun(context.Context, *DenyModelPipelineRunRequest) (*DenyModelPipelineRunResponse, error)
	AbortModelPipelineRun(context.Context, *AbortModelPipelineRunRequest) (*AbortModelPipelineRunResponse, error)
	PauseModelPipelineRun(context.Context, *PauseModelPipelineRunRequest) (*PauseModelPipelineRunResponse, error)
	ResumeModelPipelineRun(context.Context, *ResumeModelPipelineRunRequest) (*ResumeModelPipelineRunResponse, error)
	// contains filtered or unexported methods
}

ModelPipelineRunServiceServer is the server API for ModelPipelineRunService service. All implementations must embed UnimplementedModelPipelineRunServiceServer for forward compatibility

type PauseModelPipelineRunRequest 

type PauseModelPipelineRunRequest 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 (*PauseModelPipelineRunRequest) Descriptor deprecated 

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

Deprecated: Use PauseModelPipelineRunRequest.ProtoReflect.Descriptor instead.

func (*PauseModelPipelineRunRequest) GetName 

func (x *PauseModelPipelineRunRequest) GetName() string

func (*PauseModelPipelineRunRequest) GetNamespace 

func (x *PauseModelPipelineRunRequest) GetNamespace() string

func (*PauseModelPipelineRunRequest) ProtoMessage 

func (*PauseModelPipelineRunRequest) ProtoMessage()

func (*PauseModelPipelineRunRequest) ProtoReflect 

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

func (*PauseModelPipelineRunRequest) Reset 

func (x *PauseModelPipelineRunRequest) Reset()

func (*PauseModelPipelineRunRequest) String 

func (x *PauseModelPipelineRunRequest) String() string

type PauseModelPipelineRunResponse 

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

func (*PauseModelPipelineRunResponse) Descriptor deprecated 

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

Deprecated: Use PauseModelPipelineRunResponse.ProtoReflect.Descriptor instead.

func (*PauseModelPipelineRunResponse) ProtoMessage 

func (*PauseModelPipelineRunResponse) ProtoMessage()

func (*PauseModelPipelineRunResponse) ProtoReflect 

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

func (*PauseModelPipelineRunResponse) Reset 

func (x *PauseModelPipelineRunResponse) Reset()

func (*PauseModelPipelineRunResponse) String 

func (x *PauseModelPipelineRunResponse) String() string

type ResumeModelPipelineRunRequest 

type ResumeModelPipelineRunRequest 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 (*ResumeModelPipelineRunRequest) Descriptor deprecated 

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

Deprecated: Use ResumeModelPipelineRunRequest.ProtoReflect.Descriptor instead.

func (*ResumeModelPipelineRunRequest) GetName 

func (x *ResumeModelPipelineRunRequest) GetName() string

func (*ResumeModelPipelineRunRequest) GetNamespace 

func (x *ResumeModelPipelineRunRequest) GetNamespace() string

func (*ResumeModelPipelineRunRequest) ProtoMessage 

func (*ResumeModelPipelineRunRequest) ProtoMessage()

func (*ResumeModelPipelineRunRequest) ProtoReflect 

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

func (*ResumeModelPipelineRunRequest) Reset 

func (x *ResumeModelPipelineRunRequest) Reset()

func (*ResumeModelPipelineRunRequest) String 

func (x *ResumeModelPipelineRunRequest) String() string

type ResumeModelPipelineRunResponse 

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

func (*ResumeModelPipelineRunResponse) Descriptor deprecated 

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

Deprecated: Use ResumeModelPipelineRunResponse.ProtoReflect.Descriptor instead.

func (*ResumeModelPipelineRunResponse) ProtoMessage 

func (*ResumeModelPipelineRunResponse) ProtoMessage()

func (*ResumeModelPipelineRunResponse) ProtoReflect 

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

func (*ResumeModelPipelineRunResponse) Reset 

func (x *ResumeModelPipelineRunResponse) Reset()

func (*ResumeModelPipelineRunResponse) String 

func (x *ResumeModelPipelineRunResponse) String() string

type UnimplementedModelPipelineRunServiceServer 

type UnimplementedModelPipelineRunServiceServer struct {
}

UnimplementedModelPipelineRunServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedModelPipelineRunServiceServer) AbortModelPipelineRun 

func (UnimplementedModelPipelineRunServiceServer) AbortModelPipelineRun(context.Context, *AbortModelPipelineRunRequest) (*AbortModelPipelineRunResponse, error)

func (UnimplementedModelPipelineRunServiceServer) ApproveModelPipelineRun 

func (UnimplementedModelPipelineRunServiceServer) ApproveModelPipelineRun(context.Context, *ApproveModelPipelineRunRequest) (*ApproveModelPipelineRunResponse, error)

func (UnimplementedModelPipelineRunServiceServer) CreateModelPipelineRun 

func (UnimplementedModelPipelineRunServiceServer) CreateModelPipelineRun(context.Context, *CreateModelPipelineRunRequest) (*CreateModelPipelineRunResponse, error)

func (UnimplementedModelPipelineRunServiceServer) DeleteModelPipelineRun 

func (UnimplementedModelPipelineRunServiceServer) DeleteModelPipelineRun(context.Context, *DeleteModelPipelineRunRequest) (*DeleteModelPipelineRunResponse, error)

func (UnimplementedModelPipelineRunServiceServer) DenyModelPipelineRun 

func (UnimplementedModelPipelineRunServiceServer) DenyModelPipelineRun(context.Context, *DenyModelPipelineRunRequest) (*DenyModelPipelineRunResponse, error)

func (UnimplementedModelPipelineRunServiceServer) GetModelPipelineRun 

func (UnimplementedModelPipelineRunServiceServer) GetModelPipelineRun(context.Context, *GetModelPipelineRunRequest) (*GetModelPipelineRunResponse, error)

func (UnimplementedModelPipelineRunServiceServer) ListModelPipelineRuns 

func (UnimplementedModelPipelineRunServiceServer) ListModelPipelineRuns(context.Context, *ListModelPipelineRunsRequest) (*ListModelPipelineRunsResponse, error)

func (UnimplementedModelPipelineRunServiceServer) PauseModelPipelineRun 

func (UnimplementedModelPipelineRunServiceServer) PauseModelPipelineRun(context.Context, *PauseModelPipelineRunRequest) (*PauseModelPipelineRunResponse, error)

func (UnimplementedModelPipelineRunServiceServer) ResumeModelPipelineRun 

func (UnimplementedModelPipelineRunServiceServer) ResumeModelPipelineRun(context.Context, *ResumeModelPipelineRunRequest) (*ResumeModelPipelineRunResponse, error)

func (UnimplementedModelPipelineRunServiceServer) UpdateModelPipelineRun 

func (UnimplementedModelPipelineRunServiceServer) UpdateModelPipelineRun(context.Context, *UpdateModelPipelineRunRequest) (*UpdateModelPipelineRunResponse, error)

type UnsafeModelPipelineRunServiceServer added in v0.4.687 

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

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

type UpdateModelPipelineRunRequest 

type UpdateModelPipelineRunRequest struct {
	Modelpipelinerun *v1alpha1.ModelPipelineRun `protobuf:"bytes,1,opt,name=modelpipelinerun,proto3" json:"modelpipelinerun,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 (*UpdateModelPipelineRunRequest) Descriptor deprecated 

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

Deprecated: Use UpdateModelPipelineRunRequest.ProtoReflect.Descriptor instead.

func (*UpdateModelPipelineRunRequest) GetFieldMask added in v0.4.422 

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

func (*UpdateModelPipelineRunRequest) GetModelpipelinerun added in v0.4.531 

func (x *UpdateModelPipelineRunRequest) GetModelpipelinerun() *v1alpha1.ModelPipelineRun

func (*UpdateModelPipelineRunRequest) ProtoMessage 

func (*UpdateModelPipelineRunRequest) ProtoMessage()

func (*UpdateModelPipelineRunRequest) ProtoReflect 

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

func (*UpdateModelPipelineRunRequest) Reset 

func (x *UpdateModelPipelineRunRequest) Reset()

func (*UpdateModelPipelineRunRequest) String 

func (x *UpdateModelPipelineRunRequest) String() string

type UpdateModelPipelineRunResponse 

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

func (*UpdateModelPipelineRunResponse) Descriptor deprecated 

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

Deprecated: Use UpdateModelPipelineRunResponse.ProtoReflect.Descriptor instead.

func (*UpdateModelPipelineRunResponse) ProtoMessage 

func (*UpdateModelPipelineRunResponse) ProtoMessage()

func (*UpdateModelPipelineRunResponse) ProtoReflect 

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

func (*UpdateModelPipelineRunResponse) Reset 

func (x *UpdateModelPipelineRunResponse) Reset()

func (*UpdateModelPipelineRunResponse) String 

func (x *UpdateModelPipelineRunResponse) 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.