v1

package
v0.5.337 Latest Latest
Warning

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

 Go to latest Published: Oct 31, 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 DataPipelineService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "github.com.metaprov.modelaapi.services.datapipeline.v1.DataPipelineService",
	HandlerType: (*DataPipelineServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListDataPipelines",
			Handler:    _DataPipelineService_ListDataPipelines_Handler,
		},
		{
			MethodName: "CreateDataPipeline",
			Handler:    _DataPipelineService_CreateDataPipeline_Handler,
		},
		{
			MethodName: "GetDataPipeline",
			Handler:    _DataPipelineService_GetDataPipeline_Handler,
		},
		{
			MethodName: "UpdateDataPipeline",
			Handler:    _DataPipelineService_UpdateDataPipeline_Handler,
		},
		{
			MethodName: "DeleteDataPipeline",
			Handler:    _DataPipelineService_DeleteDataPipeline_Handler,
		},
		{
			MethodName: "RunDataPipeline",
			Handler:    _DataPipelineService_RunDataPipeline_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "github.com/metaprov/modelaapi/services/datapipeline/v1/datapipeline.proto",
}

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

View Source 
var File_github_com_metaprov_modelaapi_services_datapipeline_v1_datapipeline_proto protoreflect.FileDescriptor

Functions

func RegisterDataPipelineServiceHandler added in v0.4.687 

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

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

func RegisterDataPipelineServiceHandlerClient added in v0.4.687 

func RegisterDataPipelineServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client DataPipelineServiceClient) error

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

func RegisterDataPipelineServiceHandlerFromEndpoint added in v0.4.687 

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

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

func RegisterDataPipelineServiceHandlerServer added in v0.4.687 

func RegisterDataPipelineServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server DataPipelineServiceServer) error

RegisterDataPipelineServiceHandlerServer registers the http handlers for service DataPipelineService to "mux". UnaryRPC :call DataPipelineServiceServer 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 RegisterDataPipelineServiceHandlerFromEndpoint instead.

func RegisterDataPipelineServiceServer 

func RegisterDataPipelineServiceServer(s grpc.ServiceRegistrar, srv DataPipelineServiceServer)

Types

type CreateDataPipelineRequest 

type CreateDataPipelineRequest struct {
	Datapipeline *v1alpha1.DataPipeline `protobuf:"bytes,1,opt,name=datapipeline,proto3" json:"datapipeline,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateDataPipelineRequest) Descriptor deprecated 

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

Deprecated: Use CreateDataPipelineRequest.ProtoReflect.Descriptor instead.

func (*CreateDataPipelineRequest) GetDatapipeline added in v0.4.480 

func (x *CreateDataPipelineRequest) GetDatapipeline() *v1alpha1.DataPipeline

func (*CreateDataPipelineRequest) ProtoMessage 

func (*CreateDataPipelineRequest) ProtoMessage()

func (*CreateDataPipelineRequest) ProtoReflect 

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

func (*CreateDataPipelineRequest) Reset 

func (x *CreateDataPipelineRequest) Reset()

func (*CreateDataPipelineRequest) String 

func (x *CreateDataPipelineRequest) String() string

type CreateDataPipelineResponse 

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

func (*CreateDataPipelineResponse) Descriptor deprecated 

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

Deprecated: Use CreateDataPipelineResponse.ProtoReflect.Descriptor instead.

func (*CreateDataPipelineResponse) ProtoMessage 

func (*CreateDataPipelineResponse) ProtoMessage()

func (*CreateDataPipelineResponse) ProtoReflect 

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

func (*CreateDataPipelineResponse) Reset 

func (x *CreateDataPipelineResponse) Reset()

func (*CreateDataPipelineResponse) String 

func (x *CreateDataPipelineResponse) String() string

type DataPipelineServiceClient 

type DataPipelineServiceClient interface {
	ListDataPipelines(ctx context.Context, in *ListDataPipelinesRequest, opts ...grpc.CallOption) (*ListDataPipelinesResponse, error)
	CreateDataPipeline(ctx context.Context, in *CreateDataPipelineRequest, opts ...grpc.CallOption) (*CreateDataPipelineResponse, error)
	GetDataPipeline(ctx context.Context, in *GetDataPipelineRequest, opts ...grpc.CallOption) (*GetDataPipelineResponse, error)
	UpdateDataPipeline(ctx context.Context, in *UpdateDataPipelineRequest, opts ...grpc.CallOption) (*UpdateDataPipelineResponse, error)
	DeleteDataPipeline(ctx context.Context, in *DeleteDataPipelineRequest, opts ...grpc.CallOption) (*DeleteDataPipelineResponse, error)
	RunDataPipeline(ctx context.Context, in *RunDataPipelineRequest, opts ...grpc.CallOption) (*RunDataPipelineResponse, error)
}

DataPipelineServiceClient is the client API for DataPipelineService 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 NewDataPipelineServiceClient 

func NewDataPipelineServiceClient(cc grpc.ClientConnInterface) DataPipelineServiceClient

type DataPipelineServiceServer 

type DataPipelineServiceServer interface {
	ListDataPipelines(context.Context, *ListDataPipelinesRequest) (*ListDataPipelinesResponse, error)
	CreateDataPipeline(context.Context, *CreateDataPipelineRequest) (*CreateDataPipelineResponse, error)
	GetDataPipeline(context.Context, *GetDataPipelineRequest) (*GetDataPipelineResponse, error)
	UpdateDataPipeline(context.Context, *UpdateDataPipelineRequest) (*UpdateDataPipelineResponse, error)
	DeleteDataPipeline(context.Context, *DeleteDataPipelineRequest) (*DeleteDataPipelineResponse, error)
	RunDataPipeline(context.Context, *RunDataPipelineRequest) (*RunDataPipelineResponse, error)
	// contains filtered or unexported methods
}

DataPipelineServiceServer is the server API for DataPipelineService service. All implementations must embed UnimplementedDataPipelineServiceServer for forward compatibility

type DeleteDataPipelineRequest 

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

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

Deprecated: Use DeleteDataPipelineRequest.ProtoReflect.Descriptor instead.

func (*DeleteDataPipelineRequest) GetName 

func (x *DeleteDataPipelineRequest) GetName() string

func (*DeleteDataPipelineRequest) GetNamespace 

func (x *DeleteDataPipelineRequest) GetNamespace() string

func (*DeleteDataPipelineRequest) ProtoMessage 

func (*DeleteDataPipelineRequest) ProtoMessage()

func (*DeleteDataPipelineRequest) ProtoReflect 

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

func (*DeleteDataPipelineRequest) Reset 

func (x *DeleteDataPipelineRequest) Reset()

func (*DeleteDataPipelineRequest) String 

func (x *DeleteDataPipelineRequest) String() string

type DeleteDataPipelineResponse 

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

func (*DeleteDataPipelineResponse) Descriptor deprecated 

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

Deprecated: Use DeleteDataPipelineResponse.ProtoReflect.Descriptor instead.

func (*DeleteDataPipelineResponse) ProtoMessage 

func (*DeleteDataPipelineResponse) ProtoMessage()

func (*DeleteDataPipelineResponse) ProtoReflect 

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

func (*DeleteDataPipelineResponse) Reset 

func (x *DeleteDataPipelineResponse) Reset()

func (*DeleteDataPipelineResponse) String 

func (x *DeleteDataPipelineResponse) String() string

type GetDataPipelineRequest 

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

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

Deprecated: Use GetDataPipelineRequest.ProtoReflect.Descriptor instead.

func (*GetDataPipelineRequest) GetName 

func (x *GetDataPipelineRequest) GetName() string

func (*GetDataPipelineRequest) GetNamespace 

func (x *GetDataPipelineRequest) GetNamespace() string

func (*GetDataPipelineRequest) ProtoMessage 

func (*GetDataPipelineRequest) ProtoMessage()

func (*GetDataPipelineRequest) ProtoReflect 

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

func (*GetDataPipelineRequest) Reset 

func (x *GetDataPipelineRequest) Reset()

func (*GetDataPipelineRequest) String 

func (x *GetDataPipelineRequest) String() string

type GetDataPipelineResponse 

type GetDataPipelineResponse struct {
	Datapipeline *v1alpha1.DataPipeline `protobuf:"bytes,1,opt,name=datapipeline,proto3" json:"datapipeline,omitempty"`
	Yaml         string                 `protobuf:"bytes,2,opt,name=yaml,proto3" json:"yaml,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDataPipelineResponse) Descriptor deprecated 

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

Deprecated: Use GetDataPipelineResponse.ProtoReflect.Descriptor instead.

func (*GetDataPipelineResponse) GetDatapipeline added in v0.4.480 

func (x *GetDataPipelineResponse) GetDatapipeline() *v1alpha1.DataPipeline

func (*GetDataPipelineResponse) GetYaml 

func (x *GetDataPipelineResponse) GetYaml() string

func (*GetDataPipelineResponse) ProtoMessage 

func (*GetDataPipelineResponse) ProtoMessage()

func (*GetDataPipelineResponse) ProtoReflect 

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

func (*GetDataPipelineResponse) Reset 

func (x *GetDataPipelineResponse) Reset()

func (*GetDataPipelineResponse) String 

func (x *GetDataPipelineResponse) String() string

type ListDataPipelinesRequest 

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

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

Deprecated: Use ListDataPipelinesRequest.ProtoReflect.Descriptor instead.

func (*ListDataPipelinesRequest) GetLabels 

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

func (*ListDataPipelinesRequest) GetNamespace 

func (x *ListDataPipelinesRequest) GetNamespace() string

func (*ListDataPipelinesRequest) GetOrderBy added in v0.4.414 

func (x *ListDataPipelinesRequest) GetOrderBy() string

func (*ListDataPipelinesRequest) GetPageSize 

func (x *ListDataPipelinesRequest) GetPageSize() int32

func (*ListDataPipelinesRequest) GetPageToken 

func (x *ListDataPipelinesRequest) GetPageToken() string

func (*ListDataPipelinesRequest) ProtoMessage 

func (*ListDataPipelinesRequest) ProtoMessage()

func (*ListDataPipelinesRequest) ProtoReflect 

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

func (*ListDataPipelinesRequest) Reset 

func (x *ListDataPipelinesRequest) Reset()

func (*ListDataPipelinesRequest) String 

func (x *ListDataPipelinesRequest) String() string

type ListDataPipelinesResponse 

type ListDataPipelinesResponse struct {
	Datapipelines *v1alpha1.DataPipelineList `protobuf:"bytes,1,opt,name=datapipelines,proto3" json:"datapipelines,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 (*ListDataPipelinesResponse) Descriptor deprecated 

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

Deprecated: Use ListDataPipelinesResponse.ProtoReflect.Descriptor instead.

func (*ListDataPipelinesResponse) GetDatapipelines added in v0.4.480 

func (x *ListDataPipelinesResponse) GetDatapipelines() *v1alpha1.DataPipelineList

func (*ListDataPipelinesResponse) GetNextPageToken added in v0.4.472 

func (x *ListDataPipelinesResponse) GetNextPageToken() string

func (*ListDataPipelinesResponse) ProtoMessage 

func (*ListDataPipelinesResponse) ProtoMessage()

func (*ListDataPipelinesResponse) ProtoReflect 

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

func (*ListDataPipelinesResponse) Reset 

func (x *ListDataPipelinesResponse) Reset()

func (*ListDataPipelinesResponse) String 

func (x *ListDataPipelinesResponse) String() string

type RunDataPipelineRequest 

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

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

Deprecated: Use RunDataPipelineRequest.ProtoReflect.Descriptor instead.

func (*RunDataPipelineRequest) GetName 

func (x *RunDataPipelineRequest) GetName() string

func (*RunDataPipelineRequest) GetNamespace 

func (x *RunDataPipelineRequest) GetNamespace() string

func (*RunDataPipelineRequest) ProtoMessage 

func (*RunDataPipelineRequest) ProtoMessage()

func (*RunDataPipelineRequest) ProtoReflect 

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

func (*RunDataPipelineRequest) Reset 

func (x *RunDataPipelineRequest) Reset()

func (*RunDataPipelineRequest) String 

func (x *RunDataPipelineRequest) String() string

type RunDataPipelineResponse 

type RunDataPipelineResponse struct {
	Pipeline *v1alpha1.DataPipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	Yaml     string                 `protobuf:"bytes,2,opt,name=yaml,proto3" json:"yaml,omitempty"`
	// contains filtered or unexported fields
}

func (*RunDataPipelineResponse) Descriptor deprecated 

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

Deprecated: Use RunDataPipelineResponse.ProtoReflect.Descriptor instead.

func (*RunDataPipelineResponse) GetPipeline 

func (x *RunDataPipelineResponse) GetPipeline() *v1alpha1.DataPipeline

func (*RunDataPipelineResponse) GetYaml 

func (x *RunDataPipelineResponse) GetYaml() string

func (*RunDataPipelineResponse) ProtoMessage 

func (*RunDataPipelineResponse) ProtoMessage()

func (*RunDataPipelineResponse) ProtoReflect 

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

func (*RunDataPipelineResponse) Reset 

func (x *RunDataPipelineResponse) Reset()

func (*RunDataPipelineResponse) String 

func (x *RunDataPipelineResponse) String() string

type UnimplementedDataPipelineServiceServer 

type UnimplementedDataPipelineServiceServer struct {
}

UnimplementedDataPipelineServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDataPipelineServiceServer) CreateDataPipeline 

func (UnimplementedDataPipelineServiceServer) CreateDataPipeline(context.Context, *CreateDataPipelineRequest) (*CreateDataPipelineResponse, error)

func (UnimplementedDataPipelineServiceServer) DeleteDataPipeline 

func (UnimplementedDataPipelineServiceServer) DeleteDataPipeline(context.Context, *DeleteDataPipelineRequest) (*DeleteDataPipelineResponse, error)

func (UnimplementedDataPipelineServiceServer) GetDataPipeline 

func (UnimplementedDataPipelineServiceServer) GetDataPipeline(context.Context, *GetDataPipelineRequest) (*GetDataPipelineResponse, error)

func (UnimplementedDataPipelineServiceServer) ListDataPipelines 

func (UnimplementedDataPipelineServiceServer) ListDataPipelines(context.Context, *ListDataPipelinesRequest) (*ListDataPipelinesResponse, error)

func (UnimplementedDataPipelineServiceServer) RunDataPipeline 

func (UnimplementedDataPipelineServiceServer) RunDataPipeline(context.Context, *RunDataPipelineRequest) (*RunDataPipelineResponse, error)

func (UnimplementedDataPipelineServiceServer) UpdateDataPipeline 

func (UnimplementedDataPipelineServiceServer) UpdateDataPipeline(context.Context, *UpdateDataPipelineRequest) (*UpdateDataPipelineResponse, error)

type UnsafeDataPipelineServiceServer added in v0.4.687 

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

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

type UpdateDataPipelineRequest 

type UpdateDataPipelineRequest struct {
	Datapipeline *v1alpha1.DataPipeline `protobuf:"bytes,1,opt,name=datapipeline,proto3" json:"datapipeline,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 (*UpdateDataPipelineRequest) Descriptor deprecated 

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

Deprecated: Use UpdateDataPipelineRequest.ProtoReflect.Descriptor instead.

func (*UpdateDataPipelineRequest) GetDatapipeline added in v0.4.480 

func (x *UpdateDataPipelineRequest) GetDatapipeline() *v1alpha1.DataPipeline

func (*UpdateDataPipelineRequest) GetFieldMask added in v0.4.422 

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

func (*UpdateDataPipelineRequest) ProtoMessage 

func (*UpdateDataPipelineRequest) ProtoMessage()

func (*UpdateDataPipelineRequest) ProtoReflect 

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

func (*UpdateDataPipelineRequest) Reset 

func (x *UpdateDataPipelineRequest) Reset()

func (*UpdateDataPipelineRequest) String 

func (x *UpdateDataPipelineRequest) String() string

type UpdateDataPipelineResponse 

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

func (*UpdateDataPipelineResponse) Descriptor deprecated 

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

Deprecated: Use UpdateDataPipelineResponse.ProtoReflect.Descriptor instead.

func (*UpdateDataPipelineResponse) ProtoMessage 

func (*UpdateDataPipelineResponse) ProtoMessage()

func (*UpdateDataPipelineResponse) ProtoReflect 

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

func (*UpdateDataPipelineResponse) Reset 

func (x *UpdateDataPipelineResponse) Reset()

func (*UpdateDataPipelineResponse) String 

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