v1

package
v0.4.686 Latest Latest
Warning

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

Go to latest
Published: Apr 11, 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_dataset_v1_dataset_proto protoreflect.FileDescriptor

Functions

func RegisterDatasetServiceServer

func RegisterDatasetServiceServer(s *grpc.Server, srv DatasetServiceServer)

Types

type CompareDatasetsRequest

type CompareDatasetsRequest struct {
	Namespace string   `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Names     []string `protobuf:"bytes,2,rep,name=names,proto3" json:"names,omitempty"`
	// contains filtered or unexported fields
}

compare the profile of one or more datasets

func (*CompareDatasetsRequest) Descriptor deprecated

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

Deprecated: Use CompareDatasetsRequest.ProtoReflect.Descriptor instead.

func (*CompareDatasetsRequest) GetNames

func (x *CompareDatasetsRequest) GetNames() []string

func (*CompareDatasetsRequest) GetNamespace

func (x *CompareDatasetsRequest) GetNamespace() string

func (*CompareDatasetsRequest) ProtoMessage

func (*CompareDatasetsRequest) ProtoMessage()

func (*CompareDatasetsRequest) ProtoReflect

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

func (*CompareDatasetsRequest) Reset

func (x *CompareDatasetsRequest) Reset()

func (*CompareDatasetsRequest) String

func (x *CompareDatasetsRequest) String() string

type CompareDatasetsResponse

type CompareDatasetsResponse struct {
	Namespace string               `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Names     []string             `protobuf:"bytes,2,rep,name=names,proto3" json:"names,omitempty"`
	Profiles  []*v1.DatasetProfile `protobuf:"bytes,3,rep,name=profiles,proto3" json:"profiles,omitempty"`
	// contains filtered or unexported fields
}

return the profile of one or more datasets

func (*CompareDatasetsResponse) Descriptor deprecated

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

Deprecated: Use CompareDatasetsResponse.ProtoReflect.Descriptor instead.

func (*CompareDatasetsResponse) GetNames

func (x *CompareDatasetsResponse) GetNames() []string

func (*CompareDatasetsResponse) GetNamespace

func (x *CompareDatasetsResponse) GetNamespace() string

func (*CompareDatasetsResponse) GetProfiles

func (x *CompareDatasetsResponse) GetProfiles() []*v1.DatasetProfile

func (*CompareDatasetsResponse) ProtoMessage

func (*CompareDatasetsResponse) ProtoMessage()

func (*CompareDatasetsResponse) ProtoReflect

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

func (*CompareDatasetsResponse) Reset

func (x *CompareDatasetsResponse) Reset()

func (*CompareDatasetsResponse) String

func (x *CompareDatasetsResponse) String() string

type CreateColumnProfileRequest

type CreateColumnProfileRequest 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"`
	Col       string            `protobuf:"bytes,3,opt,name=col,proto3" json:"col,omitempty"`
	Dataset   *v1alpha1.Dataset `protobuf:"bytes,4,opt,name=dataset,proto3" json:"dataset,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateColumnProfileRequest) Descriptor deprecated

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

Deprecated: Use CreateColumnProfileRequest.ProtoReflect.Descriptor instead.

func (*CreateColumnProfileRequest) GetCol

func (x *CreateColumnProfileRequest) GetCol() string

func (*CreateColumnProfileRequest) GetDataset added in v0.4.479

func (x *CreateColumnProfileRequest) GetDataset() *v1alpha1.Dataset

func (*CreateColumnProfileRequest) GetName

func (x *CreateColumnProfileRequest) GetName() string

func (*CreateColumnProfileRequest) GetNamespace

func (x *CreateColumnProfileRequest) GetNamespace() string

func (*CreateColumnProfileRequest) ProtoMessage

func (*CreateColumnProfileRequest) ProtoMessage()

func (*CreateColumnProfileRequest) ProtoReflect

func (*CreateColumnProfileRequest) Reset

func (x *CreateColumnProfileRequest) Reset()

func (*CreateColumnProfileRequest) String

func (x *CreateColumnProfileRequest) String() string

type CreateColumnProfileResponse

type CreateColumnProfileResponse struct {
	Name string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Plot *v1.Plot `protobuf:"bytes,2,opt,name=plot,proto3" json:"plot,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateColumnProfileResponse) Descriptor deprecated

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

Deprecated: Use CreateColumnProfileResponse.ProtoReflect.Descriptor instead.

func (*CreateColumnProfileResponse) GetName

func (x *CreateColumnProfileResponse) GetName() string

func (*CreateColumnProfileResponse) GetPlot

func (x *CreateColumnProfileResponse) GetPlot() *v1.Plot

func (*CreateColumnProfileResponse) ProtoMessage

func (*CreateColumnProfileResponse) ProtoMessage()

func (*CreateColumnProfileResponse) ProtoReflect

func (*CreateColumnProfileResponse) Reset

func (x *CreateColumnProfileResponse) Reset()

func (*CreateColumnProfileResponse) String

func (x *CreateColumnProfileResponse) String() string

type CreateDatasetProfileRequest

type CreateDatasetProfileRequest 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"`
	Dataset   *v1alpha1.Dataset `protobuf:"bytes,3,opt,name=dataset,proto3" json:"dataset,omitempty"`
	// contains filtered or unexported fields
}

create profile

func (*CreateDatasetProfileRequest) Descriptor deprecated

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

Deprecated: Use CreateDatasetProfileRequest.ProtoReflect.Descriptor instead.

func (*CreateDatasetProfileRequest) GetDataset added in v0.4.479

func (x *CreateDatasetProfileRequest) GetDataset() *v1alpha1.Dataset

func (*CreateDatasetProfileRequest) GetName

func (x *CreateDatasetProfileRequest) GetName() string

func (*CreateDatasetProfileRequest) GetNamespace

func (x *CreateDatasetProfileRequest) GetNamespace() string

func (*CreateDatasetProfileRequest) ProtoMessage

func (*CreateDatasetProfileRequest) ProtoMessage()

func (*CreateDatasetProfileRequest) ProtoReflect

func (*CreateDatasetProfileRequest) Reset

func (x *CreateDatasetProfileRequest) Reset()

func (*CreateDatasetProfileRequest) String

func (x *CreateDatasetProfileRequest) String() string

type CreateDatasetProfileResponse

type CreateDatasetProfileResponse struct {
	Uri     string             `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"` // the profile uri
	Profile *v1.DatasetProfile `protobuf:"bytes,2,opt,name=profile,proto3" json:"profile,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateDatasetProfileResponse) Descriptor deprecated

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

Deprecated: Use CreateDatasetProfileResponse.ProtoReflect.Descriptor instead.

func (*CreateDatasetProfileResponse) GetProfile

func (*CreateDatasetProfileResponse) GetUri

func (*CreateDatasetProfileResponse) ProtoMessage

func (*CreateDatasetProfileResponse) ProtoMessage()

func (*CreateDatasetProfileResponse) ProtoReflect

func (*CreateDatasetProfileResponse) Reset

func (x *CreateDatasetProfileResponse) Reset()

func (*CreateDatasetProfileResponse) String

type CreateDatasetRequest

type CreateDatasetRequest struct {
	Dataset *v1alpha1.Dataset `protobuf:"bytes,1,opt,name=dataset,proto3" json:"dataset,omitempty"`
	// contains filtered or unexported fields
}

Create Dataset

func (*CreateDatasetRequest) Descriptor deprecated

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

Deprecated: Use CreateDatasetRequest.ProtoReflect.Descriptor instead.

func (*CreateDatasetRequest) GetDataset added in v0.4.479

func (x *CreateDatasetRequest) GetDataset() *v1alpha1.Dataset

func (*CreateDatasetRequest) ProtoMessage

func (*CreateDatasetRequest) ProtoMessage()

func (*CreateDatasetRequest) ProtoReflect

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

func (*CreateDatasetRequest) Reset

func (x *CreateDatasetRequest) Reset()

func (*CreateDatasetRequest) String

func (x *CreateDatasetRequest) String() string

type CreateDatasetResponse

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

func (*CreateDatasetResponse) Descriptor deprecated

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

Deprecated: Use CreateDatasetResponse.ProtoReflect.Descriptor instead.

func (*CreateDatasetResponse) ProtoMessage

func (*CreateDatasetResponse) ProtoMessage()

func (*CreateDatasetResponse) ProtoReflect

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

func (*CreateDatasetResponse) Reset

func (x *CreateDatasetResponse) Reset()

func (*CreateDatasetResponse) String

func (x *CreateDatasetResponse) String() string

type DatasetServiceClient

type DatasetServiceClient interface {
	// Datasets
	ListDatasets(ctx context.Context, in *ListDatasetsRequest, opts ...grpc.CallOption) (*ListDatasetsResponse, error)
	GetDataset(ctx context.Context, in *GetDatasetRequest, opts ...grpc.CallOption) (*GetDatasetResponse, error)
	CreateDataset(ctx context.Context, in *CreateDatasetRequest, opts ...grpc.CallOption) (*CreateDatasetResponse, error)
	UpdateDataset(ctx context.Context, in *UpdateDatasetRequest, opts ...grpc.CallOption) (*UpdateDatasetResponse, error)
	DeleteDataset(ctx context.Context, in *DeleteDatasetRequest, opts ...grpc.CallOption) (*DeleteDatasetResponse, error)
	// compare one or more datasets
	CompareDatasets(ctx context.Context, in *CompareDatasetsRequest, opts ...grpc.CallOption) (*CompareDatasetsResponse, error)
	GetDatasetProfile(ctx context.Context, in *GetDatasetProfileRequest, opts ...grpc.CallOption) (*GetDatasetProfileResponse, error)
	CreateDatasetProfile(ctx context.Context, in *CreateDatasetProfileRequest, opts ...grpc.CallOption) (*CreateDatasetProfileResponse, error)
	// Get a single column viz, we do that since we want to parallelize the computation of the viz
	CreateColumnProfile(ctx context.Context, in *CreateColumnProfileRequest, opts ...grpc.CallOption) (*CreateColumnProfileResponse, error)
	// generate a syntatic dataset
	GenerateDataset(ctx context.Context, in *GenerateDatasetRequest, opts ...grpc.CallOption) (*GenerateDatasetResponse, error)
	ValidateDataset(ctx context.Context, in *ValidateDatasetRequest, opts ...grpc.CallOption) (*ValidateDatasetResponse, error)
	DownloadDataset(ctx context.Context, in *DownloadDatasetRequest, opts ...grpc.CallOption) (*DownloadDatasetResponse, error)
	GetDatabases(ctx context.Context, in *GetDatabasesRequest, opts ...grpc.CallOption) (*GetDatabasesResponse, error)
	GetTables(ctx context.Context, in *GetTablesRequest, opts ...grpc.CallOption) (*GetTablesResponse, error)
	ExecuteSql(ctx context.Context, in *ExecuteSqlRequest, opts ...grpc.CallOption) (*ExecuteSqlResponse, error)
}

DatasetServiceClient is the client API for DatasetService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

type DatasetServiceServer

type DatasetServiceServer interface {
	// Datasets
	ListDatasets(context.Context, *ListDatasetsRequest) (*ListDatasetsResponse, error)
	GetDataset(context.Context, *GetDatasetRequest) (*GetDatasetResponse, error)
	CreateDataset(context.Context, *CreateDatasetRequest) (*CreateDatasetResponse, error)
	UpdateDataset(context.Context, *UpdateDatasetRequest) (*UpdateDatasetResponse, error)
	DeleteDataset(context.Context, *DeleteDatasetRequest) (*DeleteDatasetResponse, error)
	// compare one or more datasets
	CompareDatasets(context.Context, *CompareDatasetsRequest) (*CompareDatasetsResponse, error)
	GetDatasetProfile(context.Context, *GetDatasetProfileRequest) (*GetDatasetProfileResponse, error)
	CreateDatasetProfile(context.Context, *CreateDatasetProfileRequest) (*CreateDatasetProfileResponse, error)
	// Get a single column viz, we do that since we want to parallelize the computation of the viz
	CreateColumnProfile(context.Context, *CreateColumnProfileRequest) (*CreateColumnProfileResponse, error)
	// generate a syntatic dataset
	GenerateDataset(context.Context, *GenerateDatasetRequest) (*GenerateDatasetResponse, error)
	ValidateDataset(context.Context, *ValidateDatasetRequest) (*ValidateDatasetResponse, error)
	DownloadDataset(context.Context, *DownloadDatasetRequest) (*DownloadDatasetResponse, error)
	GetDatabases(context.Context, *GetDatabasesRequest) (*GetDatabasesResponse, error)
	GetTables(context.Context, *GetTablesRequest) (*GetTablesResponse, error)
	ExecuteSql(context.Context, *ExecuteSqlRequest) (*ExecuteSqlResponse, error)
}

DatasetServiceServer is the server API for DatasetService service.

type DeleteDatasetRequest

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

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

Deprecated: Use DeleteDatasetRequest.ProtoReflect.Descriptor instead.

func (*DeleteDatasetRequest) GetName

func (x *DeleteDatasetRequest) GetName() string

func (*DeleteDatasetRequest) GetNamespace

func (x *DeleteDatasetRequest) GetNamespace() string

func (*DeleteDatasetRequest) ProtoMessage

func (*DeleteDatasetRequest) ProtoMessage()

func (*DeleteDatasetRequest) ProtoReflect

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

func (*DeleteDatasetRequest) Reset

func (x *DeleteDatasetRequest) Reset()

func (*DeleteDatasetRequest) String

func (x *DeleteDatasetRequest) String() string

type DeleteDatasetResponse

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

func (*DeleteDatasetResponse) Descriptor deprecated

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

Deprecated: Use DeleteDatasetResponse.ProtoReflect.Descriptor instead.

func (*DeleteDatasetResponse) ProtoMessage

func (*DeleteDatasetResponse) ProtoMessage()

func (*DeleteDatasetResponse) ProtoReflect

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

func (*DeleteDatasetResponse) Reset

func (x *DeleteDatasetResponse) Reset()

func (*DeleteDatasetResponse) String

func (x *DeleteDatasetResponse) String() string

type DownloadDatasetRequest

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

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

Deprecated: Use DownloadDatasetRequest.ProtoReflect.Descriptor instead.

func (*DownloadDatasetRequest) GetName

func (x *DownloadDatasetRequest) GetName() string

func (*DownloadDatasetRequest) GetNamespace

func (x *DownloadDatasetRequest) GetNamespace() string

func (*DownloadDatasetRequest) ProtoMessage

func (*DownloadDatasetRequest) ProtoMessage()

func (*DownloadDatasetRequest) ProtoReflect

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

func (*DownloadDatasetRequest) Reset

func (x *DownloadDatasetRequest) Reset()

func (*DownloadDatasetRequest) String

func (x *DownloadDatasetRequest) String() string

type DownloadDatasetResponse

type DownloadDatasetResponse struct {
	Raw []byte `protobuf:"bytes,1,opt,name=raw,proto3" json:"raw,omitempty"`
	// contains filtered or unexported fields
}

Answer the report in base 64

func (*DownloadDatasetResponse) Descriptor deprecated

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

Deprecated: Use DownloadDatasetResponse.ProtoReflect.Descriptor instead.

func (*DownloadDatasetResponse) GetRaw

func (x *DownloadDatasetResponse) GetRaw() []byte

func (*DownloadDatasetResponse) ProtoMessage

func (*DownloadDatasetResponse) ProtoMessage()

func (*DownloadDatasetResponse) ProtoReflect

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

func (*DownloadDatasetResponse) Reset

func (x *DownloadDatasetResponse) Reset()

func (*DownloadDatasetResponse) String

func (x *DownloadDatasetResponse) String() string

type ExecuteSqlRequest

type ExecuteSqlRequest struct {
	ConnectionNamespace string `protobuf:"bytes,1,opt,name=connectionNamespace,proto3" json:"connectionNamespace,omitempty"`
	ConnectionName      string `protobuf:"bytes,2,opt,name=connectionName,proto3" json:"connectionName,omitempty"`
	DatabaseName        string `protobuf:"bytes,3,opt,name=databaseName,proto3" json:"databaseName,omitempty"`
	Sql                 string `protobuf:"bytes,4,opt,name=sql,proto3" json:"sql,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteSqlRequest) Descriptor deprecated

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

Deprecated: Use ExecuteSqlRequest.ProtoReflect.Descriptor instead.

func (*ExecuteSqlRequest) GetConnectionName

func (x *ExecuteSqlRequest) GetConnectionName() string

func (*ExecuteSqlRequest) GetConnectionNamespace

func (x *ExecuteSqlRequest) GetConnectionNamespace() string

func (*ExecuteSqlRequest) GetDatabaseName

func (x *ExecuteSqlRequest) GetDatabaseName() string

func (*ExecuteSqlRequest) GetSql

func (x *ExecuteSqlRequest) GetSql() string

func (*ExecuteSqlRequest) ProtoMessage

func (*ExecuteSqlRequest) ProtoMessage()

func (*ExecuteSqlRequest) ProtoReflect

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

func (*ExecuteSqlRequest) Reset

func (x *ExecuteSqlRequest) Reset()

func (*ExecuteSqlRequest) String

func (x *ExecuteSqlRequest) String() string

type ExecuteSqlResponse

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

func (*ExecuteSqlResponse) Descriptor deprecated

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

Deprecated: Use ExecuteSqlResponse.ProtoReflect.Descriptor instead.

func (*ExecuteSqlResponse) GetTableview

func (x *ExecuteSqlResponse) GetTableview() *v1.TableView

func (*ExecuteSqlResponse) ProtoMessage

func (*ExecuteSqlResponse) ProtoMessage()

func (*ExecuteSqlResponse) ProtoReflect

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

func (*ExecuteSqlResponse) Reset

func (x *ExecuteSqlResponse) Reset()

func (*ExecuteSqlResponse) String

func (x *ExecuteSqlResponse) String() string

type GenerateDatasetRequest

type GenerateDatasetRequest struct {
	Namespace string   `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Names     []string `protobuf:"bytes,2,rep,name=names,proto3" json:"names,omitempty"`
	// contains filtered or unexported fields
}

compare the profile of one or more datasets

func (*GenerateDatasetRequest) Descriptor deprecated

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

Deprecated: Use GenerateDatasetRequest.ProtoReflect.Descriptor instead.

func (*GenerateDatasetRequest) GetNames

func (x *GenerateDatasetRequest) GetNames() []string

func (*GenerateDatasetRequest) GetNamespace

func (x *GenerateDatasetRequest) GetNamespace() string

func (*GenerateDatasetRequest) ProtoMessage

func (*GenerateDatasetRequest) ProtoMessage()

func (*GenerateDatasetRequest) ProtoReflect

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

func (*GenerateDatasetRequest) Reset

func (x *GenerateDatasetRequest) Reset()

func (*GenerateDatasetRequest) String

func (x *GenerateDatasetRequest) String() string

type GenerateDatasetResponse

type GenerateDatasetResponse struct {
	Namespace string               `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Names     []string             `protobuf:"bytes,2,rep,name=names,proto3" json:"names,omitempty"`
	Profiles  []*v1.DatasetProfile `protobuf:"bytes,3,rep,name=profiles,proto3" json:"profiles,omitempty"`
	// contains filtered or unexported fields
}

return the profile of one or more datasets

func (*GenerateDatasetResponse) Descriptor deprecated

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

Deprecated: Use GenerateDatasetResponse.ProtoReflect.Descriptor instead.

func (*GenerateDatasetResponse) GetNames

func (x *GenerateDatasetResponse) GetNames() []string

func (*GenerateDatasetResponse) GetNamespace

func (x *GenerateDatasetResponse) GetNamespace() string

func (*GenerateDatasetResponse) GetProfiles

func (x *GenerateDatasetResponse) GetProfiles() []*v1.DatasetProfile

func (*GenerateDatasetResponse) ProtoMessage

func (*GenerateDatasetResponse) ProtoMessage()

func (*GenerateDatasetResponse) ProtoReflect

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

func (*GenerateDatasetResponse) Reset

func (x *GenerateDatasetResponse) Reset()

func (*GenerateDatasetResponse) String

func (x *GenerateDatasetResponse) String() string

type GetDatabasesRequest

type GetDatabasesRequest struct {
	ConnectionNamespace string `protobuf:"bytes,1,opt,name=connectionNamespace,proto3" json:"connectionNamespace,omitempty"`
	ConnectionName      string `protobuf:"bytes,2,opt,name=connectionName,proto3" json:"connectionName,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDatabasesRequest) Descriptor deprecated

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

Deprecated: Use GetDatabasesRequest.ProtoReflect.Descriptor instead.

func (*GetDatabasesRequest) GetConnectionName

func (x *GetDatabasesRequest) GetConnectionName() string

func (*GetDatabasesRequest) GetConnectionNamespace

func (x *GetDatabasesRequest) GetConnectionNamespace() string

func (*GetDatabasesRequest) ProtoMessage

func (*GetDatabasesRequest) ProtoMessage()

func (*GetDatabasesRequest) ProtoReflect

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

func (*GetDatabasesRequest) Reset

func (x *GetDatabasesRequest) Reset()

func (*GetDatabasesRequest) String

func (x *GetDatabasesRequest) String() string

type GetDatabasesResponse

type GetDatabasesResponse struct {
	Databases []string `protobuf:"bytes,1,rep,name=databases,proto3" json:"databases,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDatabasesResponse) Descriptor deprecated

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

Deprecated: Use GetDatabasesResponse.ProtoReflect.Descriptor instead.

func (*GetDatabasesResponse) GetDatabases

func (x *GetDatabasesResponse) GetDatabases() []string

func (*GetDatabasesResponse) ProtoMessage

func (*GetDatabasesResponse) ProtoMessage()

func (*GetDatabasesResponse) ProtoReflect

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

func (*GetDatabasesResponse) Reset

func (x *GetDatabasesResponse) Reset()

func (*GetDatabasesResponse) String

func (x *GetDatabasesResponse) String() string

type GetDatasetProfileRequest

type GetDatasetProfileRequest 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"`
	Uri       string `protobuf:"bytes,3,opt,name=uri,proto3" json:"uri,omitempty"` // this is optional. used when we do the analysis from the ui (vs in batch mode)
	// contains filtered or unexported fields
}

func (*GetDatasetProfileRequest) Descriptor deprecated

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

Deprecated: Use GetDatasetProfileRequest.ProtoReflect.Descriptor instead.

func (*GetDatasetProfileRequest) GetName

func (x *GetDatasetProfileRequest) GetName() string

func (*GetDatasetProfileRequest) GetNamespace

func (x *GetDatasetProfileRequest) GetNamespace() string

func (*GetDatasetProfileRequest) GetUri

func (x *GetDatasetProfileRequest) GetUri() string

func (*GetDatasetProfileRequest) ProtoMessage

func (*GetDatasetProfileRequest) ProtoMessage()

func (*GetDatasetProfileRequest) ProtoReflect

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

func (*GetDatasetProfileRequest) Reset

func (x *GetDatasetProfileRequest) Reset()

func (*GetDatasetProfileRequest) String

func (x *GetDatasetProfileRequest) String() string

type GetDatasetProfileResponse

type GetDatasetProfileResponse 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"`
	Profile   *v1.DatasetProfile `protobuf:"bytes,3,opt,name=profile,proto3" json:"profile,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDatasetProfileResponse) Descriptor deprecated

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

Deprecated: Use GetDatasetProfileResponse.ProtoReflect.Descriptor instead.

func (*GetDatasetProfileResponse) GetName

func (x *GetDatasetProfileResponse) GetName() string

func (*GetDatasetProfileResponse) GetNamespace

func (x *GetDatasetProfileResponse) GetNamespace() string

func (*GetDatasetProfileResponse) GetProfile

func (x *GetDatasetProfileResponse) GetProfile() *v1.DatasetProfile

func (*GetDatasetProfileResponse) ProtoMessage

func (*GetDatasetProfileResponse) ProtoMessage()

func (*GetDatasetProfileResponse) ProtoReflect

func (*GetDatasetProfileResponse) Reset

func (x *GetDatasetProfileResponse) Reset()

func (*GetDatasetProfileResponse) String

func (x *GetDatasetProfileResponse) String() string

type GetDatasetRequest

type GetDatasetRequest 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"`
	Labels    map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

Get Dataset

func (*GetDatasetRequest) Descriptor deprecated

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

Deprecated: Use GetDatasetRequest.ProtoReflect.Descriptor instead.

func (*GetDatasetRequest) GetLabels

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

func (*GetDatasetRequest) GetName

func (x *GetDatasetRequest) GetName() string

func (*GetDatasetRequest) GetNamespace

func (x *GetDatasetRequest) GetNamespace() string

func (*GetDatasetRequest) ProtoMessage

func (*GetDatasetRequest) ProtoMessage()

func (*GetDatasetRequest) ProtoReflect

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

func (*GetDatasetRequest) Reset

func (x *GetDatasetRequest) Reset()

func (*GetDatasetRequest) String

func (x *GetDatasetRequest) String() string

type GetDatasetResponse

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

func (*GetDatasetResponse) Descriptor deprecated

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

Deprecated: Use GetDatasetResponse.ProtoReflect.Descriptor instead.

func (*GetDatasetResponse) GetDataset added in v0.4.475

func (x *GetDatasetResponse) GetDataset() *v1alpha1.Dataset

func (*GetDatasetResponse) GetYaml

func (x *GetDatasetResponse) GetYaml() string

func (*GetDatasetResponse) ProtoMessage

func (*GetDatasetResponse) ProtoMessage()

func (*GetDatasetResponse) ProtoReflect

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

func (*GetDatasetResponse) Reset

func (x *GetDatasetResponse) Reset()

func (*GetDatasetResponse) String

func (x *GetDatasetResponse) String() string

type GetTablesRequest

type GetTablesRequest struct {
	ConnectionNamespace string `protobuf:"bytes,1,opt,name=connectionNamespace,proto3" json:"connectionNamespace,omitempty"`
	ConnectionName      string `protobuf:"bytes,2,opt,name=connectionName,proto3" json:"connectionName,omitempty"`
	DatabaseName        string `protobuf:"bytes,3,opt,name=databaseName,proto3" json:"databaseName,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTablesRequest) Descriptor deprecated

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

Deprecated: Use GetTablesRequest.ProtoReflect.Descriptor instead.

func (*GetTablesRequest) GetConnectionName

func (x *GetTablesRequest) GetConnectionName() string

func (*GetTablesRequest) GetConnectionNamespace

func (x *GetTablesRequest) GetConnectionNamespace() string

func (*GetTablesRequest) GetDatabaseName

func (x *GetTablesRequest) GetDatabaseName() string

func (*GetTablesRequest) ProtoMessage

func (*GetTablesRequest) ProtoMessage()

func (*GetTablesRequest) ProtoReflect

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

func (*GetTablesRequest) Reset

func (x *GetTablesRequest) Reset()

func (*GetTablesRequest) String

func (x *GetTablesRequest) String() string

type GetTablesResponse

type GetTablesResponse struct {
	Tables []string `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTablesResponse) Descriptor deprecated

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

Deprecated: Use GetTablesResponse.ProtoReflect.Descriptor instead.

func (*GetTablesResponse) GetTables

func (x *GetTablesResponse) GetTables() []string

func (*GetTablesResponse) ProtoMessage

func (*GetTablesResponse) ProtoMessage()

func (*GetTablesResponse) ProtoReflect

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

func (*GetTablesResponse) Reset

func (x *GetTablesResponse) Reset()

func (*GetTablesResponse) String

func (x *GetTablesResponse) String() string

type ListDatasetsRequest

type ListDatasetsRequest 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
}

list datasets req/response

func (*ListDatasetsRequest) Descriptor deprecated

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

Deprecated: Use ListDatasetsRequest.ProtoReflect.Descriptor instead.

func (*ListDatasetsRequest) GetLabels

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

func (*ListDatasetsRequest) GetNamespace

func (x *ListDatasetsRequest) GetNamespace() string

func (*ListDatasetsRequest) GetOrderBy added in v0.4.414

func (x *ListDatasetsRequest) GetOrderBy() string

func (*ListDatasetsRequest) GetPageSize added in v0.4.414

func (x *ListDatasetsRequest) GetPageSize() int32

func (*ListDatasetsRequest) GetPageToken added in v0.4.414

func (x *ListDatasetsRequest) GetPageToken() string

func (*ListDatasetsRequest) ProtoMessage

func (*ListDatasetsRequest) ProtoMessage()

func (*ListDatasetsRequest) ProtoReflect

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

func (*ListDatasetsRequest) Reset

func (x *ListDatasetsRequest) Reset()

func (*ListDatasetsRequest) String

func (x *ListDatasetsRequest) String() string

type ListDatasetsResponse

type ListDatasetsResponse struct {
	Datasets      *v1alpha1.DatasetList `protobuf:"bytes,1,opt,name=datasets,proto3" json:"datasets,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 (*ListDatasetsResponse) Descriptor deprecated

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

Deprecated: Use ListDatasetsResponse.ProtoReflect.Descriptor instead.

func (*ListDatasetsResponse) GetDatasets

func (x *ListDatasetsResponse) GetDatasets() *v1alpha1.DatasetList

func (*ListDatasetsResponse) GetNextPageToken added in v0.4.472

func (x *ListDatasetsResponse) GetNextPageToken() string

func (*ListDatasetsResponse) ProtoMessage

func (*ListDatasetsResponse) ProtoMessage()

func (*ListDatasetsResponse) ProtoReflect

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

func (*ListDatasetsResponse) Reset

func (x *ListDatasetsResponse) Reset()

func (*ListDatasetsResponse) String

func (x *ListDatasetsResponse) String() string

type SnapshotRequest

type SnapshotRequest struct {
	ConnectionNamespace string `protobuf:"bytes,1,opt,name=connectionNamespace,proto3" json:"connectionNamespace,omitempty"`
	ConnectionName      string `protobuf:"bytes,2,opt,name=connectionName,proto3" json:"connectionName,omitempty"`
	DatabaseName        string `protobuf:"bytes,3,opt,name=databaseName,proto3" json:"databaseName,omitempty"`
	Sql                 string `protobuf:"bytes,4,opt,name=sql,proto3" json:"sql,omitempty"`
	// contains filtered or unexported fields
}

func (*SnapshotRequest) Descriptor deprecated

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

Deprecated: Use SnapshotRequest.ProtoReflect.Descriptor instead.

func (*SnapshotRequest) GetConnectionName

func (x *SnapshotRequest) GetConnectionName() string

func (*SnapshotRequest) GetConnectionNamespace

func (x *SnapshotRequest) GetConnectionNamespace() string

func (*SnapshotRequest) GetDatabaseName

func (x *SnapshotRequest) GetDatabaseName() string

func (*SnapshotRequest) GetSql

func (x *SnapshotRequest) GetSql() string

func (*SnapshotRequest) ProtoMessage

func (*SnapshotRequest) ProtoMessage()

func (*SnapshotRequest) ProtoReflect

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

func (*SnapshotRequest) Reset

func (x *SnapshotRequest) Reset()

func (*SnapshotRequest) String

func (x *SnapshotRequest) String() string

type SnapshotResponse

type SnapshotResponse struct {
	Bucket string `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Path   string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*SnapshotResponse) Descriptor deprecated

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

Deprecated: Use SnapshotResponse.ProtoReflect.Descriptor instead.

func (*SnapshotResponse) GetBucket

func (x *SnapshotResponse) GetBucket() string

func (*SnapshotResponse) GetPath

func (x *SnapshotResponse) GetPath() string

func (*SnapshotResponse) ProtoMessage

func (*SnapshotResponse) ProtoMessage()

func (*SnapshotResponse) ProtoReflect

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

func (*SnapshotResponse) Reset

func (x *SnapshotResponse) Reset()

func (*SnapshotResponse) String

func (x *SnapshotResponse) String() string

type UnimplementedDatasetServiceServer

type UnimplementedDatasetServiceServer struct {
}

UnimplementedDatasetServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedDatasetServiceServer) CompareDatasets

func (*UnimplementedDatasetServiceServer) CreateColumnProfile

func (*UnimplementedDatasetServiceServer) CreateDataset

func (*UnimplementedDatasetServiceServer) CreateDatasetProfile

func (*UnimplementedDatasetServiceServer) DeleteDataset

func (*UnimplementedDatasetServiceServer) DownloadDataset

func (*UnimplementedDatasetServiceServer) ExecuteSql

func (*UnimplementedDatasetServiceServer) GenerateDataset

func (*UnimplementedDatasetServiceServer) GetDatabases

func (*UnimplementedDatasetServiceServer) GetDataset

func (*UnimplementedDatasetServiceServer) GetDatasetProfile

func (*UnimplementedDatasetServiceServer) GetTables

func (*UnimplementedDatasetServiceServer) ListDatasets

func (*UnimplementedDatasetServiceServer) UpdateDataset

func (*UnimplementedDatasetServiceServer) ValidateDataset

type UpdateDatasetRequest

type UpdateDatasetRequest struct {
	Dataset   *v1alpha1.Dataset     `protobuf:"bytes,1,opt,name=dataset,proto3" json:"dataset,omitempty"`
	FieldMask *field_mask.FieldMask `protobuf:"bytes,2,opt,name=field_mask,json=fieldMask,proto3" json:"field_mask,omitempty"`
	// contains filtered or unexported fields
}

update dataset

func (*UpdateDatasetRequest) Descriptor deprecated

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

Deprecated: Use UpdateDatasetRequest.ProtoReflect.Descriptor instead.

func (*UpdateDatasetRequest) GetDataset added in v0.4.475

func (x *UpdateDatasetRequest) GetDataset() *v1alpha1.Dataset

func (*UpdateDatasetRequest) GetFieldMask added in v0.4.422

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

func (*UpdateDatasetRequest) ProtoMessage

func (*UpdateDatasetRequest) ProtoMessage()

func (*UpdateDatasetRequest) ProtoReflect

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

func (*UpdateDatasetRequest) Reset

func (x *UpdateDatasetRequest) Reset()

func (*UpdateDatasetRequest) String

func (x *UpdateDatasetRequest) String() string

type UpdateDatasetResponse

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

func (*UpdateDatasetResponse) Descriptor deprecated

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

Deprecated: Use UpdateDatasetResponse.ProtoReflect.Descriptor instead.

func (*UpdateDatasetResponse) ProtoMessage

func (*UpdateDatasetResponse) ProtoMessage()

func (*UpdateDatasetResponse) ProtoReflect

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

func (*UpdateDatasetResponse) Reset

func (x *UpdateDatasetResponse) Reset()

func (*UpdateDatasetResponse) String

func (x *UpdateDatasetResponse) String() string

type UploadChunkRequest

type UploadChunkRequest struct {
	Fname   string `protobuf:"bytes,1,opt,name=fname,proto3" json:"fname,omitempty"`     // the file name
	Content []byte `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"` // the chunk content
	Index   int32  `protobuf:"varint,3,opt,name=index,proto3" json:"index,omitempty"`    // the chunk index
	Last    bool   `protobuf:"varint,4,opt,name=last,proto3" json:"last,omitempty"`      // this is the last chunk
	// contains filtered or unexported fields
}

Chunk is used to send

func (*UploadChunkRequest) Descriptor deprecated

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

Deprecated: Use UploadChunkRequest.ProtoReflect.Descriptor instead.

func (*UploadChunkRequest) GetContent

func (x *UploadChunkRequest) GetContent() []byte

func (*UploadChunkRequest) GetFname

func (x *UploadChunkRequest) GetFname() string

func (*UploadChunkRequest) GetIndex

func (x *UploadChunkRequest) GetIndex() int32

func (*UploadChunkRequest) GetLast

func (x *UploadChunkRequest) GetLast() bool

func (*UploadChunkRequest) ProtoMessage

func (*UploadChunkRequest) ProtoMessage()

func (*UploadChunkRequest) ProtoReflect

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

func (*UploadChunkRequest) Reset

func (x *UploadChunkRequest) Reset()

func (*UploadChunkRequest) String

func (x *UploadChunkRequest) String() string

type UploadChunkResponse

type UploadChunkResponse struct {
	Fname string `protobuf:"bytes,1,opt,name=fname,proto3" json:"fname,omitempty"`
	Ok    bool   `protobuf:"varint,2,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

return the result

func (*UploadChunkResponse) Descriptor deprecated

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

Deprecated: Use UploadChunkResponse.ProtoReflect.Descriptor instead.

func (*UploadChunkResponse) GetFname

func (x *UploadChunkResponse) GetFname() string

func (*UploadChunkResponse) GetOk

func (x *UploadChunkResponse) GetOk() bool

func (*UploadChunkResponse) ProtoMessage

func (*UploadChunkResponse) ProtoMessage()

func (*UploadChunkResponse) ProtoReflect

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

func (*UploadChunkResponse) Reset

func (x *UploadChunkResponse) Reset()

func (*UploadChunkResponse) String

func (x *UploadChunkResponse) String() string

type ValidateDatasetRequest

type ValidateDatasetRequest struct {
	Namespace string   `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Names     []string `protobuf:"bytes,2,rep,name=names,proto3" json:"names,omitempty"`
	// contains filtered or unexported fields
}

compare the profile of one or more datasets

func (*ValidateDatasetRequest) Descriptor deprecated

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

Deprecated: Use ValidateDatasetRequest.ProtoReflect.Descriptor instead.

func (*ValidateDatasetRequest) GetNames

func (x *ValidateDatasetRequest) GetNames() []string

func (*ValidateDatasetRequest) GetNamespace

func (x *ValidateDatasetRequest) GetNamespace() string

func (*ValidateDatasetRequest) ProtoMessage

func (*ValidateDatasetRequest) ProtoMessage()

func (*ValidateDatasetRequest) ProtoReflect

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

func (*ValidateDatasetRequest) Reset

func (x *ValidateDatasetRequest) Reset()

func (*ValidateDatasetRequest) String

func (x *ValidateDatasetRequest) String() string

type ValidateDatasetResponse

type ValidateDatasetResponse struct {
	Namespace string               `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Names     []string             `protobuf:"bytes,2,rep,name=names,proto3" json:"names,omitempty"`
	Profiles  []*v1.DatasetProfile `protobuf:"bytes,3,rep,name=profiles,proto3" json:"profiles,omitempty"`
	// contains filtered or unexported fields
}

return the profile of one or more datasets

func (*ValidateDatasetResponse) Descriptor deprecated

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

Deprecated: Use ValidateDatasetResponse.ProtoReflect.Descriptor instead.

func (*ValidateDatasetResponse) GetNames

func (x *ValidateDatasetResponse) GetNames() []string

func (*ValidateDatasetResponse) GetNamespace

func (x *ValidateDatasetResponse) GetNamespace() string

func (*ValidateDatasetResponse) GetProfiles

func (x *ValidateDatasetResponse) GetProfiles() []*v1.DatasetProfile

func (*ValidateDatasetResponse) ProtoMessage

func (*ValidateDatasetResponse) ProtoMessage()

func (*ValidateDatasetResponse) ProtoReflect

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

func (*ValidateDatasetResponse) Reset

func (x *ValidateDatasetResponse) Reset()

func (*ValidateDatasetResponse) String

func (x *ValidateDatasetResponse) String() string

Jump to

Keyboard shortcuts

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