Documentation
¶
Overview ¶
Package v1 is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Variables
- func RegisterDataSourceServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterDataSourceServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client DataSourceServiceClient) error
- func RegisterDataSourceServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterDataSourceServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server DataSourceServiceServer) error
- func RegisterDataSourceServiceServer(s grpc.ServiceRegistrar, srv DataSourceServiceServer)
- type CreateDataSourceRequest
- func (*CreateDataSourceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateDataSourceRequest) GetDatasource() *v1alpha1.DataSource
- func (*CreateDataSourceRequest) ProtoMessage()
- func (x *CreateDataSourceRequest) ProtoReflect() protoreflect.Message
- func (x *CreateDataSourceRequest) Reset()
- func (x *CreateDataSourceRequest) String() string
- type CreateDataSourceResponse
- type DataSourceServiceClient
- type DataSourceServiceServer
- type DeleteDataSourceRequest
- func (*DeleteDataSourceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteDataSourceRequest) GetName() string
- func (x *DeleteDataSourceRequest) GetNamespace() string
- func (*DeleteDataSourceRequest) ProtoMessage()
- func (x *DeleteDataSourceRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteDataSourceRequest) Reset()
- func (x *DeleteDataSourceRequest) String() string
- type DeleteDataSourceResponse
- type GetDataSourceRequest
- func (*GetDataSourceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetDataSourceRequest) GetName() string
- func (x *GetDataSourceRequest) GetNamespace() string
- func (*GetDataSourceRequest) ProtoMessage()
- func (x *GetDataSourceRequest) ProtoReflect() protoreflect.Message
- func (x *GetDataSourceRequest) Reset()
- func (x *GetDataSourceRequest) String() string
- type GetDataSourceResponse
- func (*GetDataSourceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetDataSourceResponse) GetDatasource() *v1alpha1.DataSource
- func (x *GetDataSourceResponse) GetYaml() string
- func (*GetDataSourceResponse) ProtoMessage()
- func (x *GetDataSourceResponse) ProtoReflect() protoreflect.Message
- func (x *GetDataSourceResponse) Reset()
- func (x *GetDataSourceResponse) String() string
- type GetTableViewRequest
- func (*GetTableViewRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetTableViewRequest) GetFlatfilespec() *v1alpha1.CsvFileSpec
- func (x *GetTableViewRequest) GetLocation() *v1alpha1.DataLocation
- func (x *GetTableViewRequest) GetTenant() string
- func (*GetTableViewRequest) ProtoMessage()
- func (x *GetTableViewRequest) ProtoReflect() protoreflect.Message
- func (x *GetTableViewRequest) Reset()
- func (x *GetTableViewRequest) String() string
- type GetTableViewResponse
- func (*GetTableViewResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetTableViewResponse) GetTable() *v1.TableView
- func (*GetTableViewResponse) ProtoMessage()
- func (x *GetTableViewResponse) ProtoReflect() protoreflect.Message
- func (x *GetTableViewResponse) Reset()
- func (x *GetTableViewResponse) String() string
- type InferSchemaRequest
- func (*InferSchemaRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InferSchemaRequest) GetDatasource() *v1alpha1.DataSource
- func (x *InferSchemaRequest) GetLocation() *v1alpha1.DataLocation
- func (x *InferSchemaRequest) GetName() string
- func (x *InferSchemaRequest) GetNamespace() string
- func (*InferSchemaRequest) ProtoMessage()
- func (x *InferSchemaRequest) ProtoReflect() protoreflect.Message
- func (x *InferSchemaRequest) Reset()
- func (x *InferSchemaRequest) String() string
- type InferSchemaResponse
- func (*InferSchemaResponse) Descriptor() ([]byte, []int)deprecated
- func (x *InferSchemaResponse) GetColumns() []*v1.ColumnProfile
- func (*InferSchemaResponse) ProtoMessage()
- func (x *InferSchemaResponse) ProtoReflect() protoreflect.Message
- func (x *InferSchemaResponse) Reset()
- func (x *InferSchemaResponse) String() string
- type ListDataSourceRequest
- func (*ListDataSourceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListDataSourceRequest) GetLabels() map[string]string
- func (x *ListDataSourceRequest) GetNamespace() string
- func (x *ListDataSourceRequest) GetOrderBy() string
- func (x *ListDataSourceRequest) GetPageSize() int32
- func (x *ListDataSourceRequest) GetPageToken() string
- func (*ListDataSourceRequest) ProtoMessage()
- func (x *ListDataSourceRequest) ProtoReflect() protoreflect.Message
- func (x *ListDataSourceRequest) Reset()
- func (x *ListDataSourceRequest) String() string
- type ListDataSourceResponse
- func (*ListDataSourceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListDataSourceResponse) GetDatasources() *v1alpha1.DataSourceList
- func (x *ListDataSourceResponse) GetNextPageToken() string
- func (*ListDataSourceResponse) ProtoMessage()
- func (x *ListDataSourceResponse) ProtoReflect() protoreflect.Message
- func (x *ListDataSourceResponse) Reset()
- func (x *ListDataSourceResponse) String() string
- type UnimplementedDataSourceServiceServer
- func (UnimplementedDataSourceServiceServer) CreateDataSource(context.Context, *CreateDataSourceRequest) (*CreateDataSourceResponse, error)
- func (UnimplementedDataSourceServiceServer) DeleteDataSource(context.Context, *DeleteDataSourceRequest) (*DeleteDataSourceResponse, error)
- func (UnimplementedDataSourceServiceServer) GetDataSource(context.Context, *GetDataSourceRequest) (*GetDataSourceResponse, error)
- func (UnimplementedDataSourceServiceServer) GetTableView(context.Context, *GetTableViewRequest) (*GetTableViewResponse, error)
- func (UnimplementedDataSourceServiceServer) InferSchema(context.Context, *InferSchemaRequest) (*InferSchemaResponse, error)
- func (UnimplementedDataSourceServiceServer) ListDataSources(context.Context, *ListDataSourceRequest) (*ListDataSourceResponse, error)
- func (UnimplementedDataSourceServiceServer) UpdateDataSource(context.Context, *UpdateDataSourceRequest) (*UpdateDataSourceResponse, error)
- type UnsafeDataSourceServiceServer
- type UpdateDataSourceRequest
- func (*UpdateDataSourceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateDataSourceRequest) GetDatasource() *v1alpha1.DataSource
- func (x *UpdateDataSourceRequest) GetFieldMask() *field_mask.FieldMask
- func (*UpdateDataSourceRequest) ProtoMessage()
- func (x *UpdateDataSourceRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateDataSourceRequest) Reset()
- func (x *UpdateDataSourceRequest) String() string
- type UpdateDataSourceResponse
Constants ¶
This section is empty.
Variables ¶
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)
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.
func NewDataSourceServiceClient ¶
func NewDataSourceServiceClient(cc grpc.ClientConnInterface) DataSourceServiceClient
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"` Flatfilespec *v1alpha1.CsvFileSpec `protobuf:"bytes,2,opt,name=flatfilespec,proto3" json:"flatfilespec,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) GetFlatfilespec ¶
func (x *GetTableViewRequest) GetFlatfilespec() *v1alpha1.CsvFileSpec
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) CreateDataSource(context.Context, *CreateDataSourceRequest) (*CreateDataSourceResponse, error)
func (UnimplementedDataSourceServiceServer) DeleteDataSource ¶
func (UnimplementedDataSourceServiceServer) DeleteDataSource(context.Context, *DeleteDataSourceRequest) (*DeleteDataSourceResponse, error)
func (UnimplementedDataSourceServiceServer) GetDataSource ¶
func (UnimplementedDataSourceServiceServer) GetDataSource(context.Context, *GetDataSourceRequest) (*GetDataSourceResponse, error)
func (UnimplementedDataSourceServiceServer) GetTableView ¶
func (UnimplementedDataSourceServiceServer) GetTableView(context.Context, *GetTableViewRequest) (*GetTableViewResponse, error)
func (UnimplementedDataSourceServiceServer) InferSchema ¶
func (UnimplementedDataSourceServiceServer) InferSchema(context.Context, *InferSchemaRequest) (*InferSchemaResponse, error)
func (UnimplementedDataSourceServiceServer) ListDataSources ¶
func (UnimplementedDataSourceServiceServer) ListDataSources(context.Context, *ListDataSourceRequest) (*ListDataSourceResponse, error)
func (UnimplementedDataSourceServiceServer) UpdateDataSource ¶
func (UnimplementedDataSourceServiceServer) UpdateDataSource(context.Context, *UpdateDataSourceRequest) (*UpdateDataSourceResponse, error)
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