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

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 (*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) 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