v1

package
v0.7.1 Latest Latest
Warning

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

 Go to latest Published: Aug 16, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

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 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"`
	Format   *v1alpha1.FlatFileFormatSpec `protobuf:"bytes,2,opt,name=format,proto3" json:"format,omitempty"`
	Location *v1alpha11.DataLocation      `protobuf:"bytes,3,opt,name=location,proto3" json:"location,omitempty"`
	// 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 (x *GetTableViewRequest) GetFormat() *v1alpha1.FlatFileFormatSpec

func (*GetTableViewRequest) GetLocation 

func (x *GetTableViewRequest) GetLocation() *v1alpha11.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 {
	Tenant     string                  `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	Datasource *v1alpha1.DataSource    `protobuf:"bytes,2,opt,name=datasource,proto3" json:"datasource,omitempty"`
	Location   *v1alpha11.DataLocation `protobuf:"bytes,3,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() *v1alpha11.DataLocation

func (*InferSchemaRequest) GetTenant added in v0.6.252 

func (x *InferSchemaRequest) GetTenant() 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 {
	Features []*v1alpha1.FeatureStatistics `protobuf:"bytes,1,rep,name=features,proto3" json:"features,omitempty"`
	// contains filtered or unexported fields
}

func (*InferSchemaResponse) Descriptor deprecated 

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

Deprecated: Use InferSchemaResponse.ProtoReflect.Descriptor instead.

func (*InferSchemaResponse) GetFeatures added in v0.6.252 

func (x *InferSchemaResponse) GetFeatures() []*v1alpha1.FeatureStatistics

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

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.