v1

package
v0.4.449 Latest Latest
Warning

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

 Go to latest Published: Feb 7, 2022 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_github_com_metaprov_modelaapi_services_datasource_v1_datasource_proto protoreflect.FileDescriptor

Functions

func RegisterDataSourceServiceServer 

func RegisterDataSourceServiceServer(s *grpc.Server, srv DataSourceServiceServer)

Types

type CreateDataSourceRequest 

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

func (*CreateDataSourceRequest) Descriptor deprecated 

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

Deprecated: Use CreateDataSourceRequest.ProtoReflect.Descriptor instead.

func (*CreateDataSourceRequest) GetItem 

func (x *CreateDataSourceRequest) GetItem() *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://godoc.org/google.golang.org/grpc#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)
}

DataSourceServiceServer is the server API for DataSourceService service.

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 {
	Item *v1alpha1.DataSource `protobuf:"bytes,1,opt,name=item,proto3" json:"item,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) GetItem 

func (x *GetDataSourceResponse) GetItem() *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 {
	List *v1alpha1.DataSourceList `protobuf:"bytes,1,opt,name=list,proto3" json:"list,omitempty"`
	// contains filtered or unexported fields
}

func (*ListDataSourceResponse) Descriptor deprecated 

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

Deprecated: Use ListDataSourceResponse.ProtoReflect.Descriptor instead.

func (*ListDataSourceResponse) GetList 

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

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 can 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 UpdateDataSourceRequest 

type UpdateDataSourceRequest struct {
	Item      *v1alpha1.DataSource  `protobuf:"bytes,1,opt,name=item,proto3" json:"item,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) GetFieldMask added in v0.4.422 

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

func (*UpdateDataSourceRequest) GetItem 

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

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.