v1

package
v0.5.461 Latest Latest
Warning

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

Go to latest
Published: Nov 28, 2022 License: Apache-2.0 Imports: 20 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 DataSourceService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "github.com.metaprov.modelaapi.services.datasource.v1.DataSourceService",
	HandlerType: (*DataSourceServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListDataSources",
			Handler:    _DataSourceService_ListDataSources_Handler,
		},
		{
			MethodName: "CreateDataSource",
			Handler:    _DataSourceService_CreateDataSource_Handler,
		},
		{
			MethodName: "GetDataSource",
			Handler:    _DataSourceService_GetDataSource_Handler,
		},
		{
			MethodName: "UpdateDataSource",
			Handler:    _DataSourceService_UpdateDataSource_Handler,
		},
		{
			MethodName: "DeleteDataSource",
			Handler:    _DataSourceService_DeleteDataSource_Handler,
		},
		{
			MethodName: "InferSchema",
			Handler:    _DataSourceService_InferSchema_Handler,
		},
		{
			MethodName: "GetTableView",
			Handler:    _DataSourceService_GetTableView_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "github.com/metaprov/modelaapi/services/datasource/v1/datasource.proto",
}

DataSourceService_ServiceDesc is the grpc.ServiceDesc for DataSourceService 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_datasource_v1_datasource_proto protoreflect.FileDescriptor

Functions

func RegisterDataSourceServiceHandler added in v0.4.687

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

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

func RegisterDataSourceServiceHandlerClient added in v0.4.687

func RegisterDataSourceServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client DataSourceServiceClient) error

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

func RegisterDataSourceServiceHandlerFromEndpoint added in v0.4.687

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

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

func RegisterDataSourceServiceHandlerServer added in v0.4.687

func RegisterDataSourceServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server DataSourceServiceServer) error

RegisterDataSourceServiceHandlerServer registers the http handlers for service DataSourceService to "mux". UnaryRPC :call DataSourceServiceServer 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 RegisterDataSourceServiceHandlerFromEndpoint instead.

func RegisterDataSourceServiceServer

func RegisterDataSourceServiceServer(s grpc.ServiceRegistrar, srv DataSourceServiceServer)

Types

type CreateDataSourceRequest

type CreateDataSourceRequest struct {
	Datasource *v1alpha1.DataSource `protobuf:"bytes,1,opt,name=datasource,proto3" json:"datasource,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateDataSourceRequest) Descriptor deprecated

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

Deprecated: Use CreateDataSourceRequest.ProtoReflect.Descriptor instead.

func (*CreateDataSourceRequest) GetDatasource added in v0.4.475

func (x *CreateDataSourceRequest) GetDatasource() *v1alpha1.DataSource

func (*CreateDataSourceRequest) ProtoMessage

func (*CreateDataSourceRequest) ProtoMessage()

func (*CreateDataSourceRequest) ProtoReflect

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

func (*CreateDataSourceRequest) Reset

func (x *CreateDataSourceRequest) Reset()

func (*CreateDataSourceRequest) String

func (x *CreateDataSourceRequest) String() string

type CreateDataSourceResponse

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

func (*CreateDataSourceResponse) Descriptor deprecated

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

Deprecated: Use CreateDataSourceResponse.ProtoReflect.Descriptor instead.

func (*CreateDataSourceResponse) ProtoMessage

func (*CreateDataSourceResponse) ProtoMessage()

func (*CreateDataSourceResponse) ProtoReflect

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

func (*CreateDataSourceResponse) Reset

func (x *CreateDataSourceResponse) Reset()

func (*CreateDataSourceResponse) String

func (x *CreateDataSourceResponse) String() string

type DataSourceServiceClient

type DataSourceServiceClient interface {
	ListDataSources(ctx context.Context, in *ListDataSourceRequest, opts ...grpc.CallOption) (*ListDataSourceResponse, error)
	CreateDataSource(ctx context.Context, in *CreateDataSourceRequest, opts ...grpc.CallOption) (*CreateDataSourceResponse, error)
	GetDataSource(ctx context.Context, in *GetDataSourceRequest, opts ...grpc.CallOption) (*GetDataSourceResponse, error)
	UpdateDataSource(ctx context.Context, in *UpdateDataSourceRequest, opts ...grpc.CallOption) (*UpdateDataSourceResponse, error)
	DeleteDataSource(ctx context.Context, in *DeleteDataSourceRequest, opts ...grpc.CallOption) (*DeleteDataSourceResponse, error)
	InferSchema(ctx context.Context, in *InferSchemaRequest, opts ...grpc.CallOption) (*InferSchemaResponse, error)
	// get the table view from the data source. used to present table view.
	GetTableView(ctx context.Context, in *GetTableViewRequest, opts ...grpc.CallOption) (*GetTableViewResponse, error)
}

DataSourceServiceClient is the client API for DataSourceService 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.

type DataSourceServiceServer

type DataSourceServiceServer interface {
	ListDataSources(context.Context, *ListDataSourceRequest) (*ListDataSourceResponse, error)
	CreateDataSource(context.Context, *CreateDataSourceRequest) (*CreateDataSourceResponse, error)
	GetDataSource(context.Context, *GetDataSourceRequest) (*GetDataSourceResponse, error)
	UpdateDataSource(context.Context, *UpdateDataSourceRequest) (*UpdateDataSourceResponse, error)
	DeleteDataSource(context.Context, *DeleteDataSourceRequest) (*DeleteDataSourceResponse, error)
	InferSchema(context.Context, *InferSchemaRequest) (*InferSchemaResponse, error)
	// get the table view from the data source. used to present table view.
	GetTableView(context.Context, *GetTableViewRequest) (*GetTableViewResponse, error)
	// contains filtered or unexported methods
}

DataSourceServiceServer is the server API for DataSourceService service. All implementations must embed UnimplementedDataSourceServiceServer for forward compatibility

type DeleteDataSourceRequest

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

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

Deprecated: Use DeleteDataSourceRequest.ProtoReflect.Descriptor instead.

func (*DeleteDataSourceRequest) GetName

func (x *DeleteDataSourceRequest) GetName() string

func (*DeleteDataSourceRequest) GetNamespace

func (x *DeleteDataSourceRequest) GetNamespace() string

func (*DeleteDataSourceRequest) ProtoMessage

func (*DeleteDataSourceRequest) ProtoMessage()

func (*DeleteDataSourceRequest) ProtoReflect

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

func (*DeleteDataSourceRequest) Reset

func (x *DeleteDataSourceRequest) Reset()

func (*DeleteDataSourceRequest) String

func (x *DeleteDataSourceRequest) String() string

type DeleteDataSourceResponse

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

func (*DeleteDataSourceResponse) Descriptor deprecated

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

Deprecated: Use DeleteDataSourceResponse.ProtoReflect.Descriptor instead.

func (*DeleteDataSourceResponse) ProtoMessage

func (*DeleteDataSourceResponse) ProtoMessage()

func (*DeleteDataSourceResponse) ProtoReflect

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

func (*DeleteDataSourceResponse) Reset

func (x *DeleteDataSourceResponse) Reset()

func (*DeleteDataSourceResponse) String

func (x *DeleteDataSourceResponse) String() string

type GetDataSourceRequest

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

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

Deprecated: Use GetDataSourceRequest.ProtoReflect.Descriptor instead.

func (*GetDataSourceRequest) GetName

func (x *GetDataSourceRequest) GetName() string

func (*GetDataSourceRequest) GetNamespace

func (x *GetDataSourceRequest) GetNamespace() string

func (*GetDataSourceRequest) ProtoMessage

func (*GetDataSourceRequest) ProtoMessage()

func (*GetDataSourceRequest) ProtoReflect

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

func (*GetDataSourceRequest) Reset

func (x *GetDataSourceRequest) Reset()

func (*GetDataSourceRequest) String

func (x *GetDataSourceRequest) String() string

type GetDataSourceResponse

type GetDataSourceResponse struct {
	Datasource *v1alpha1.DataSource `protobuf:"bytes,1,opt,name=datasource,proto3" json:"datasource,omitempty"`
	Yaml       string               `protobuf:"bytes,2,opt,name=yaml,proto3" json:"yaml,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDataSourceResponse) Descriptor deprecated

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

Deprecated: Use GetDataSourceResponse.ProtoReflect.Descriptor instead.

func (*GetDataSourceResponse) GetDatasource added in v0.4.475

func (x *GetDataSourceResponse) GetDatasource() *v1alpha1.DataSource

func (*GetDataSourceResponse) GetYaml

func (x *GetDataSourceResponse) GetYaml() string

func (*GetDataSourceResponse) ProtoMessage

func (*GetDataSourceResponse) ProtoMessage()

func (*GetDataSourceResponse) ProtoReflect

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

func (*GetDataSourceResponse) Reset

func (x *GetDataSourceResponse) Reset()

func (*GetDataSourceResponse) String

func (x *GetDataSourceResponse) String() string

type GetTableViewRequest

type GetTableViewRequest struct {
	Tenant   string                       `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	Format   *v1alpha1.FlatFileFormatSpec `protobuf:"bytes,2,opt,name=format,proto3" json:"format,omitempty"`     // contain the csv or table definition
	Location *v1alpha1.DataLocation       `protobuf:"bytes,3,opt,name=location,proto3" json:"location,omitempty"` // contain the csv or table definition
	// contains filtered or unexported fields
}

func (*GetTableViewRequest) Descriptor deprecated

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

Deprecated: Use GetTableViewRequest.ProtoReflect.Descriptor instead.

func (*GetTableViewRequest) GetFormat added in v0.4.864

func (*GetTableViewRequest) GetLocation

func (x *GetTableViewRequest) GetLocation() *v1alpha1.DataLocation

func (*GetTableViewRequest) GetTenant

func (x *GetTableViewRequest) GetTenant() string

func (*GetTableViewRequest) ProtoMessage

func (*GetTableViewRequest) ProtoMessage()

func (*GetTableViewRequest) ProtoReflect

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

func (*GetTableViewRequest) Reset

func (x *GetTableViewRequest) Reset()

func (*GetTableViewRequest) String

func (x *GetTableViewRequest) String() string

type GetTableViewResponse

type GetTableViewResponse struct {
	Table *v1.TableView `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTableViewResponse) Descriptor deprecated

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

Deprecated: Use GetTableViewResponse.ProtoReflect.Descriptor instead.

func (*GetTableViewResponse) GetTable

func (x *GetTableViewResponse) GetTable() *v1.TableView

func (*GetTableViewResponse) ProtoMessage

func (*GetTableViewResponse) ProtoMessage()

func (*GetTableViewResponse) ProtoReflect

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

func (*GetTableViewResponse) Reset

func (x *GetTableViewResponse) Reset()

func (*GetTableViewResponse) String

func (x *GetTableViewResponse) String() string

type InferSchemaRequest

type InferSchemaRequest 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"`
	Datasource *v1alpha1.DataSource   `protobuf:"bytes,3,opt,name=datasource,proto3" json:"datasource,omitempty"`
	Location   *v1alpha1.DataLocation `protobuf:"bytes,4,opt,name=location,proto3" json:"location,omitempty"`
	// contains filtered or unexported fields
}

func (*InferSchemaRequest) Descriptor deprecated

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

Deprecated: Use InferSchemaRequest.ProtoReflect.Descriptor instead.

func (*InferSchemaRequest) GetDatasource

func (x *InferSchemaRequest) GetDatasource() *v1alpha1.DataSource

func (*InferSchemaRequest) GetLocation

func (x *InferSchemaRequest) GetLocation() *v1alpha1.DataLocation

func (*InferSchemaRequest) GetName

func (x *InferSchemaRequest) GetName() string

func (*InferSchemaRequest) GetNamespace

func (x *InferSchemaRequest) GetNamespace() string

func (*InferSchemaRequest) ProtoMessage

func (*InferSchemaRequest) ProtoMessage()

func (*InferSchemaRequest) ProtoReflect

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

func (*InferSchemaRequest) Reset

func (x *InferSchemaRequest) Reset()

func (*InferSchemaRequest) String

func (x *InferSchemaRequest) String() string

type InferSchemaResponse

type InferSchemaResponse struct {
	Columns []*v1.ColumnProfile `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
	// contains filtered or unexported fields
}

func (*InferSchemaResponse) Descriptor deprecated

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

Deprecated: Use InferSchemaResponse.ProtoReflect.Descriptor instead.

func (*InferSchemaResponse) GetColumns

func (x *InferSchemaResponse) GetColumns() []*v1.ColumnProfile

func (*InferSchemaResponse) ProtoMessage

func (*InferSchemaResponse) ProtoMessage()

func (*InferSchemaResponse) ProtoReflect

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

func (*InferSchemaResponse) Reset

func (x *InferSchemaResponse) Reset()

func (*InferSchemaResponse) String

func (x *InferSchemaResponse) String() string

type ListDataSourceRequest

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

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

Deprecated: Use ListDataSourceRequest.ProtoReflect.Descriptor instead.

func (*ListDataSourceRequest) GetLabels

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

func (*ListDataSourceRequest) GetNamespace

func (x *ListDataSourceRequest) GetNamespace() string

func (*ListDataSourceRequest) GetOrderBy added in v0.4.414

func (x *ListDataSourceRequest) GetOrderBy() string

func (*ListDataSourceRequest) GetPageSize added in v0.4.414

func (x *ListDataSourceRequest) GetPageSize() int32

func (*ListDataSourceRequest) GetPageToken added in v0.4.414

func (x *ListDataSourceRequest) GetPageToken() string

func (*ListDataSourceRequest) ProtoMessage

func (*ListDataSourceRequest) ProtoMessage()

func (*ListDataSourceRequest) ProtoReflect

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

func (*ListDataSourceRequest) Reset

func (x *ListDataSourceRequest) Reset()

func (*ListDataSourceRequest) String

func (x *ListDataSourceRequest) String() string

type ListDataSourceResponse

type ListDataSourceResponse struct {
	Datasources   *v1alpha1.DataSourceList `protobuf:"bytes,1,opt,name=datasources,proto3" json:"datasources,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 (*ListDataSourceResponse) Descriptor deprecated

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

Deprecated: Use ListDataSourceResponse.ProtoReflect.Descriptor instead.

func (*ListDataSourceResponse) GetDatasources added in v0.4.472

func (x *ListDataSourceResponse) GetDatasources() *v1alpha1.DataSourceList

func (*ListDataSourceResponse) GetNextPageToken added in v0.4.472

func (x *ListDataSourceResponse) GetNextPageToken() string

func (*ListDataSourceResponse) ProtoMessage

func (*ListDataSourceResponse) ProtoMessage()

func (*ListDataSourceResponse) ProtoReflect

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

func (*ListDataSourceResponse) Reset

func (x *ListDataSourceResponse) Reset()

func (*ListDataSourceResponse) String

func (x *ListDataSourceResponse) String() string

type UnimplementedDataSourceServiceServer

type UnimplementedDataSourceServiceServer struct {
}

UnimplementedDataSourceServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDataSourceServiceServer) CreateDataSource

func (UnimplementedDataSourceServiceServer) DeleteDataSource

func (UnimplementedDataSourceServiceServer) GetDataSource

func (UnimplementedDataSourceServiceServer) GetTableView

func (UnimplementedDataSourceServiceServer) InferSchema

func (UnimplementedDataSourceServiceServer) ListDataSources

func (UnimplementedDataSourceServiceServer) UpdateDataSource

type UnsafeDataSourceServiceServer added in v0.4.687

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

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

type UpdateDataSourceRequest

type UpdateDataSourceRequest struct {
	Datasource *v1alpha1.DataSource  `protobuf:"bytes,1,opt,name=datasource,proto3" json:"datasource,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 (*UpdateDataSourceRequest) Descriptor deprecated

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

Deprecated: Use UpdateDataSourceRequest.ProtoReflect.Descriptor instead.

func (*UpdateDataSourceRequest) GetDatasource added in v0.4.475

func (x *UpdateDataSourceRequest) GetDatasource() *v1alpha1.DataSource

func (*UpdateDataSourceRequest) GetFieldMask added in v0.4.422

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

func (*UpdateDataSourceRequest) ProtoMessage

func (*UpdateDataSourceRequest) ProtoMessage()

func (*UpdateDataSourceRequest) ProtoReflect

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

func (*UpdateDataSourceRequest) Reset

func (x *UpdateDataSourceRequest) Reset()

func (*UpdateDataSourceRequest) String

func (x *UpdateDataSourceRequest) String() string

type UpdateDataSourceResponse

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

func (*UpdateDataSourceResponse) Descriptor deprecated

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

Deprecated: Use UpdateDataSourceResponse.ProtoReflect.Descriptor instead.

func (*UpdateDataSourceResponse) ProtoMessage

func (*UpdateDataSourceResponse) ProtoMessage()

func (*UpdateDataSourceResponse) ProtoReflect

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

func (*UpdateDataSourceResponse) Reset

func (x *UpdateDataSourceResponse) Reset()

func (*UpdateDataSourceResponse) String

func (x *UpdateDataSourceResponse) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL