v1

package
v0.6.310 Latest Latest
Warning

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

 Go to latest Published: Jan 18, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

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