v1

package
v0.5.557 Latest Latest
Warning

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

 Go to latest Published: Jan 12, 2023 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Overview

Package v1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var DatasetService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "github.com.metaprov.modelaapi.services.dataset.v1.DatasetService",
	HandlerType: (*DatasetServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListDatasets",
			Handler:    _DatasetService_ListDatasets_Handler,
		},
		{
			MethodName: "GetDataset",
			Handler:    _DatasetService_GetDataset_Handler,
		},
		{
			MethodName: "CreateDataset",
			Handler:    _DatasetService_CreateDataset_Handler,
		},
		{
			MethodName: "UpdateDataset",
			Handler:    _DatasetService_UpdateDataset_Handler,
		},
		{
			MethodName: "DeleteDataset",
			Handler:    _DatasetService_DeleteDataset_Handler,
		},
		{
			MethodName: "CompareDatasets",
			Handler:    _DatasetService_CompareDatasets_Handler,
		},
		{
			MethodName: "GetDatasetProfile",
			Handler:    _DatasetService_GetDatasetProfile_Handler,
		},
		{
			MethodName: "CreateDatasetProfile",
			Handler:    _DatasetService_CreateDatasetProfile_Handler,
		},
		{
			MethodName: "CreateColumnProfile",
			Handler:    _DatasetService_CreateColumnProfile_Handler,
		},
		{
			MethodName: "GenerateDataset",
			Handler:    _DatasetService_GenerateDataset_Handler,
		},
		{
			MethodName: "ValidateDataset",
			Handler:    _DatasetService_ValidateDataset_Handler,
		},
		{
			MethodName: "DownloadDataset",
			Handler:    _DatasetService_DownloadDataset_Handler,
		},
		{
			MethodName: "GetDatabases",
			Handler:    _DatasetService_GetDatabases_Handler,
		},
		{
			MethodName: "GetTables",
			Handler:    _DatasetService_GetTables_Handler,
		},
		{
			MethodName: "ExecuteSql",
			Handler:    _DatasetService_ExecuteSql_Handler,
		},
		{
			MethodName: "GetAnomalies",
			Handler:    _DatasetService_GetAnomalies_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "github.com/metaprov/modelaapi/services/dataset/v1/dataset.proto",
}

DatasetService_ServiceDesc is the grpc.ServiceDesc for DatasetService 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_dataset_v1_dataset_proto protoreflect.FileDescriptor

Functions

func RegisterDatasetServiceHandler added in v0.4.687 

func RegisterDatasetServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterDatasetServiceHandler registers the http handlers for service DatasetService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterDatasetServiceHandlerClient added in v0.4.687 

func RegisterDatasetServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client DatasetServiceClient) error

RegisterDatasetServiceHandlerClient registers the http handlers for service DatasetService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "DatasetServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "DatasetServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "DatasetServiceClient" to call the correct interceptors.

func RegisterDatasetServiceHandlerFromEndpoint added in v0.4.687 

func RegisterDatasetServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterDatasetServiceHandlerFromEndpoint is same as RegisterDatasetServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterDatasetServiceHandlerServer added in v0.4.687 

func RegisterDatasetServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server DatasetServiceServer) error

RegisterDatasetServiceHandlerServer registers the http handlers for service DatasetService to "mux". UnaryRPC :call DatasetServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterDatasetServiceHandlerFromEndpoint instead.

func RegisterDatasetServiceServer 

func RegisterDatasetServiceServer(s grpc.ServiceRegistrar, 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 (x *CreateColumnProfileRequest) ProtoReflect() protoreflect.Message

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 (x *CreateColumnProfileResponse) ProtoReflect() protoreflect.Message

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 (x *CreateDatasetProfileRequest) ProtoReflect() protoreflect.Message

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 (x *CreateDatasetProfileResponse) GetProfile() *v1.DatasetProfile

func (*CreateDatasetProfileResponse) GetUri 

func (x *CreateDatasetProfileResponse) GetUri() string

func (*CreateDatasetProfileResponse) ProtoMessage 

func (*CreateDatasetProfileResponse) ProtoMessage()

func (*CreateDatasetProfileResponse) ProtoReflect 

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

func (*CreateDatasetProfileResponse) Reset 

func (x *CreateDatasetProfileResponse) Reset()

func (*CreateDatasetProfileResponse) String 

func (x *CreateDatasetProfileResponse) String() 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)
	GetAnomalies(ctx context.Context, in *GetAnomaliesRequest, opts ...grpc.CallOption) (*GetAnomaliesResponse, error)
}

DatasetServiceClient is the client API for DatasetService 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 NewDatasetServiceClient 

func NewDatasetServiceClient(cc grpc.ClientConnInterface) DatasetServiceClient

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)
	GetAnomalies(context.Context, *GetAnomaliesRequest) (*GetAnomaliesResponse, error)
	// contains filtered or unexported methods
}

DatasetServiceServer is the server API for DatasetService service. All implementations must embed UnimplementedDatasetServiceServer for forward compatibility

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"`
	Group     string `protobuf:"bytes,3,opt,name=group,proto3" json:"group,omitempty"` // if not null this is a group request
	// contains filtered or unexported fields
}

func (*DownloadDatasetRequest) Descriptor deprecated 

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

Deprecated: Use DownloadDatasetRequest.ProtoReflect.Descriptor instead.

func (*DownloadDatasetRequest) GetGroup added in v0.5.220 

func (x *DownloadDatasetRequest) GetGroup() string

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 GetAnomaliesRequest added in v0.4.856 

type GetAnomaliesRequest 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 (*GetAnomaliesRequest) Descriptor deprecated added in v0.4.856 

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

Deprecated: Use GetAnomaliesRequest.ProtoReflect.Descriptor instead.

func (*GetAnomaliesRequest) GetName added in v0.4.856 

func (x *GetAnomaliesRequest) GetName() string

func (*GetAnomaliesRequest) GetNamespace added in v0.4.856 

func (x *GetAnomaliesRequest) GetNamespace() string

func (*GetAnomaliesRequest) ProtoMessage added in v0.4.856 

func (*GetAnomaliesRequest) ProtoMessage()

func (*GetAnomaliesRequest) ProtoReflect added in v0.4.856 

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

func (*GetAnomaliesRequest) Reset added in v0.4.856 

func (x *GetAnomaliesRequest) Reset()

func (*GetAnomaliesRequest) String added in v0.4.856 

func (x *GetAnomaliesRequest) String() string

type GetAnomaliesResponse added in v0.4.856 

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

func (*GetAnomaliesResponse) Descriptor deprecated added in v0.4.856 

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

Deprecated: Use GetAnomaliesResponse.ProtoReflect.Descriptor instead.

func (*GetAnomaliesResponse) GetTable added in v0.4.856 

func (x *GetAnomaliesResponse) GetTable() *v1.TableView

func (*GetAnomaliesResponse) ProtoMessage added in v0.4.856 

func (*GetAnomaliesResponse) ProtoMessage()

func (*GetAnomaliesResponse) ProtoReflect added in v0.4.856 

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

func (*GetAnomaliesResponse) Reset added in v0.4.856 

func (x *GetAnomaliesResponse) Reset()

func (*GetAnomaliesResponse) String added in v0.4.856 

func (x *GetAnomaliesResponse) 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)
	Group     string `protobuf:"bytes,4,opt,name=group,proto3" json:"group,omitempty"` // if not null, this is a group profile.
	// contains filtered or unexported fields
}

func (*GetDatasetProfileRequest) Descriptor deprecated 

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

Deprecated: Use GetDatasetProfileRequest.ProtoReflect.Descriptor instead.

func (*GetDatasetProfileRequest) GetGroup added in v0.5.220 

func (x *GetDatasetProfileRequest) GetGroup() string

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 (x *GetDatasetProfileResponse) ProtoReflect() protoreflect.Message

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 must be embedded to have forward compatible implementations.

func (UnimplementedDatasetServiceServer) CompareDatasets 

func (UnimplementedDatasetServiceServer) CompareDatasets(context.Context, *CompareDatasetsRequest) (*CompareDatasetsResponse, error)

func (UnimplementedDatasetServiceServer) CreateColumnProfile 

func (UnimplementedDatasetServiceServer) CreateColumnProfile(context.Context, *CreateColumnProfileRequest) (*CreateColumnProfileResponse, error)

func (UnimplementedDatasetServiceServer) CreateDataset 

func (UnimplementedDatasetServiceServer) CreateDataset(context.Context, *CreateDatasetRequest) (*CreateDatasetResponse, error)

func (UnimplementedDatasetServiceServer) CreateDatasetProfile 

func (UnimplementedDatasetServiceServer) CreateDatasetProfile(context.Context, *CreateDatasetProfileRequest) (*CreateDatasetProfileResponse, error)

func (UnimplementedDatasetServiceServer) DeleteDataset 

func (UnimplementedDatasetServiceServer) DeleteDataset(context.Context, *DeleteDatasetRequest) (*DeleteDatasetResponse, error)

func (UnimplementedDatasetServiceServer) DownloadDataset 

func (UnimplementedDatasetServiceServer) DownloadDataset(context.Context, *DownloadDatasetRequest) (*DownloadDatasetResponse, error)

func (UnimplementedDatasetServiceServer) ExecuteSql 

func (UnimplementedDatasetServiceServer) ExecuteSql(context.Context, *ExecuteSqlRequest) (*ExecuteSqlResponse, error)

func (UnimplementedDatasetServiceServer) GenerateDataset 

func (UnimplementedDatasetServiceServer) GenerateDataset(context.Context, *GenerateDatasetRequest) (*GenerateDatasetResponse, error)

func (UnimplementedDatasetServiceServer) GetAnomalies added in v0.4.856 

func (UnimplementedDatasetServiceServer) GetAnomalies(context.Context, *GetAnomaliesRequest) (*GetAnomaliesResponse, error)

func (UnimplementedDatasetServiceServer) GetDatabases 

func (UnimplementedDatasetServiceServer) GetDatabases(context.Context, *GetDatabasesRequest) (*GetDatabasesResponse, error)

func (UnimplementedDatasetServiceServer) GetDataset 

func (UnimplementedDatasetServiceServer) GetDataset(context.Context, *GetDatasetRequest) (*GetDatasetResponse, error)

func (UnimplementedDatasetServiceServer) GetDatasetProfile 

func (UnimplementedDatasetServiceServer) GetDatasetProfile(context.Context, *GetDatasetProfileRequest) (*GetDatasetProfileResponse, error)

func (UnimplementedDatasetServiceServer) GetTables 

func (UnimplementedDatasetServiceServer) GetTables(context.Context, *GetTablesRequest) (*GetTablesResponse, error)

func (UnimplementedDatasetServiceServer) ListDatasets 

func (UnimplementedDatasetServiceServer) ListDatasets(context.Context, *ListDatasetsRequest) (*ListDatasetsResponse, error)

func (UnimplementedDatasetServiceServer) UpdateDataset 

func (UnimplementedDatasetServiceServer) UpdateDataset(context.Context, *UpdateDatasetRequest) (*UpdateDatasetResponse, error)

func (UnimplementedDatasetServiceServer) ValidateDataset 

func (UnimplementedDatasetServiceServer) ValidateDataset(context.Context, *ValidateDatasetRequest) (*ValidateDatasetResponse, error)

type UnsafeDatasetServiceServer added in v0.4.687 

type UnsafeDatasetServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeDatasetServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DatasetServiceServer will result in compilation errors.

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

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.