api

package

Go to main page

Versions in this module

v0

v0.15.0

Nov 22, 2022

Changes in this version

+ var CatalogObject_Type_name = map[int32]string

+ var CatalogObject_Type_value = map[string]int32

+ var DatabaseObjectType_name = map[int32]string

+ var DatabaseObjectType_value = map[string]int32

+ var MigrationError_Code_name = map[int32]string

+ var MigrationError_Code_value = map[string]int32

+ var Model_Dialect_name = map[int32]string

+ var Model_Dialect_value = map[string]int32

+ var TimeGrain_name = map[int32]string

+ var TimeGrain_value = map[string]int32

+ var TimeRangeName_name = map[int32]string

+ var TimeRangeName_value = map[string]int32

+ var Type_Code_name = map[int32]string

+ var Type_Code_value = map[string]int32

+ type BasicMeasureDefinition struct

+ Expression string

+ Id string

+ SqlName *string

+ func (*BasicMeasureDefinition) Descriptor() ([]byte, []int)

+ func (*BasicMeasureDefinition) ProtoMessage()

+ func (x *BasicMeasureDefinition) GetExpression() string

+ func (x *BasicMeasureDefinition) GetId() string

+ func (x *BasicMeasureDefinition) GetSqlName() string

+ func (x *BasicMeasureDefinition) ProtoReflect() protoreflect.Message

+ func (x *BasicMeasureDefinition) Reset()

+ func (x *BasicMeasureDefinition) String() string

+ type CardinalityOfColumnRequest struct

+ ColumnName string

+ InstanceId string

+ TableName string

+ func (*CardinalityOfColumnRequest) Descriptor() ([]byte, []int)

+ func (*CardinalityOfColumnRequest) ProtoMessage()

+ func (x *CardinalityOfColumnRequest) GetColumnName() string

+ func (x *CardinalityOfColumnRequest) GetInstanceId() string

+ func (x *CardinalityOfColumnRequest) GetTableName() string

+ func (x *CardinalityOfColumnRequest) ProtoReflect() protoreflect.Message

+ func (x *CardinalityOfColumnRequest) Reset()

+ func (x *CardinalityOfColumnRequest) String() string

+ type CardinalityRequest struct

+ InstanceId string

+ TableName string

+ func (*CardinalityRequest) Descriptor() ([]byte, []int)

+ func (*CardinalityRequest) ProtoMessage()

+ func (x *CardinalityRequest) GetInstanceId() string

+ func (x *CardinalityRequest) GetTableName() string

+ func (x *CardinalityRequest) ProtoReflect() protoreflect.Message

+ func (x *CardinalityRequest) Reset()

+ func (x *CardinalityRequest) String() string

+ type CardinalityResponse struct

+ Cardinality int64

+ func (*CardinalityResponse) Descriptor() ([]byte, []int)

+ func (*CardinalityResponse) ProtoMessage()

+ func (x *CardinalityResponse) GetCardinality() int64

+ func (x *CardinalityResponse) ProtoReflect() protoreflect.Message

+ func (x *CardinalityResponse) Reset()

+ func (x *CardinalityResponse) String() string

type CatalogObject

+ CreatedOn *timestamppb.Timestamp

+ MetricsView *MetricsView

+ Model *Model

+ Name string

+ Path string

+ Source *Source

+ Table *Table

+ UpdatedOn *timestamppb.Timestamp

+ func (x *CatalogObject) GetCreatedOn() *timestamppb.Timestamp

+ func (x *CatalogObject) GetModel() *Model

+ func (x *CatalogObject) GetName() string

+ func (x *CatalogObject) GetPath() string

+ func (x *CatalogObject) GetTable() *Table

+ func (x *CatalogObject) GetUpdatedOn() *timestamppb.Timestamp

+ type CatalogObject_Type int32

+ const CatalogObject_TYPE_METRICS_VIEW

+ const CatalogObject_TYPE_MODEL

+ const CatalogObject_TYPE_SOURCE

+ const CatalogObject_TYPE_TABLE

+ const CatalogObject_TYPE_UNSPECIFIED

+ func (CatalogObject_Type) Descriptor() protoreflect.EnumDescriptor

+ func (CatalogObject_Type) EnumDescriptor() ([]byte, []int)

+ func (CatalogObject_Type) Type() protoreflect.EnumType

+ func (x CatalogObject_Type) Enum() *CatalogObject_Type

+ func (x CatalogObject_Type) Number() protoreflect.EnumNumber

+ func (x CatalogObject_Type) String() string

+ type CategoricalSummary struct

+ Cardinality *int64

+ TopKResponse *TopKResponse

+ func (*CategoricalSummary) Descriptor() ([]byte, []int)

+ func (*CategoricalSummary) ProtoMessage()

+ func (x *CategoricalSummary) GetCardinality() int64

+ func (x *CategoricalSummary) GetTopKResponse() *TopKResponse

+ func (x *CategoricalSummary) ProtoReflect() protoreflect.Message

+ func (x *CategoricalSummary) Reset()

+ func (x *CategoricalSummary) String() string

type CreateInstanceRequest

+ InstanceId string

+ func (x *CreateInstanceRequest) GetInstanceId() string

type CreateRepoRequest

+ RepoId string

+ func (x *CreateRepoRequest) GetRepoId() string

+ type DatabaseObjectType int32

+ const DatabaseObjectType_FUNCTION

+ const DatabaseObjectType_TABLE

+ const DatabaseObjectType_VIEW

+ func (DatabaseObjectType) Descriptor() protoreflect.EnumDescriptor

+ func (DatabaseObjectType) EnumDescriptor() ([]byte, []int)

+ func (DatabaseObjectType) Type() protoreflect.EnumType

+ func (x DatabaseObjectType) Enum() *DatabaseObjectType

+ func (x DatabaseObjectType) Number() protoreflect.EnumNumber

+ func (x DatabaseObjectType) String() string

+ type DeleteFileAndMigrateRequest struct

+ Dry bool

+ InstanceId string

+ Path string

+ RepoId string

+ Strict bool

+ func (*DeleteFileAndMigrateRequest) Descriptor() ([]byte, []int)

+ func (*DeleteFileAndMigrateRequest) ProtoMessage()

+ func (x *DeleteFileAndMigrateRequest) GetDry() bool

+ func (x *DeleteFileAndMigrateRequest) GetInstanceId() string

+ func (x *DeleteFileAndMigrateRequest) GetPath() string

+ func (x *DeleteFileAndMigrateRequest) GetRepoId() string

+ func (x *DeleteFileAndMigrateRequest) GetStrict() bool

+ func (x *DeleteFileAndMigrateRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteFileAndMigrateRequest) Reset()

+ func (x *DeleteFileAndMigrateRequest) String() string

+ type DeleteFileAndMigrateResponse struct

+ AffectedPaths []string

+ Errors []*MigrationError

+ func (*DeleteFileAndMigrateResponse) Descriptor() ([]byte, []int)

+ func (*DeleteFileAndMigrateResponse) ProtoMessage()

+ func (x *DeleteFileAndMigrateResponse) GetAffectedPaths() []string

+ func (x *DeleteFileAndMigrateResponse) GetErrors() []*MigrationError

+ func (x *DeleteFileAndMigrateResponse) ProtoReflect() protoreflect.Message

+ func (x *DeleteFileAndMigrateResponse) Reset()

+ func (x *DeleteFileAndMigrateResponse) String() string

+ type DeleteFileRequest struct

+ Path string

+ RepoId string

+ func (*DeleteFileRequest) Descriptor() ([]byte, []int)

+ func (*DeleteFileRequest) ProtoMessage()

+ func (x *DeleteFileRequest) GetPath() string

+ func (x *DeleteFileRequest) GetRepoId() string

+ func (x *DeleteFileRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteFileRequest) Reset()

+ func (x *DeleteFileRequest) String() string

+ type DeleteFileResponse struct

+ func (*DeleteFileResponse) Descriptor() ([]byte, []int)

+ func (*DeleteFileResponse) ProtoMessage()

+ func (x *DeleteFileResponse) ProtoReflect() protoreflect.Message

+ func (x *DeleteFileResponse) Reset()

+ func (x *DeleteFileResponse) String() string

+ type DescriptiveStatisticsRequest struct

+ ColumnName string

+ InstanceId string

+ TableName string

+ func (*DescriptiveStatisticsRequest) Descriptor() ([]byte, []int)

+ func (*DescriptiveStatisticsRequest) ProtoMessage()

+ func (x *DescriptiveStatisticsRequest) GetColumnName() string

+ func (x *DescriptiveStatisticsRequest) GetInstanceId() string

+ func (x *DescriptiveStatisticsRequest) GetTableName() string

+ func (x *DescriptiveStatisticsRequest) ProtoReflect() protoreflect.Message

+ func (x *DescriptiveStatisticsRequest) Reset()

+ func (x *DescriptiveStatisticsRequest) String() string

+ type EstimateRollupIntervalRequest struct

+ ColumnName string

+ InstanceId string

+ TableName string

+ func (*EstimateRollupIntervalRequest) Descriptor() ([]byte, []int)

+ func (*EstimateRollupIntervalRequest) ProtoMessage()

+ func (x *EstimateRollupIntervalRequest) GetColumnName() string

+ func (x *EstimateRollupIntervalRequest) GetInstanceId() string

+ func (x *EstimateRollupIntervalRequest) GetTableName() string

+ func (x *EstimateRollupIntervalRequest) ProtoReflect() protoreflect.Message

+ func (x *EstimateRollupIntervalRequest) Reset()

+ func (x *EstimateRollupIntervalRequest) String() string

+ type EstimateRollupIntervalResponse struct

+ Interval int64

+ Max *Scalar

+ Min *Scalar

+ func (*EstimateRollupIntervalResponse) Descriptor() ([]byte, []int)

+ func (*EstimateRollupIntervalResponse) ProtoMessage()

+ func (x *EstimateRollupIntervalResponse) GetInterval() int64

+ func (x *EstimateRollupIntervalResponse) GetMax() *Scalar

+ func (x *EstimateRollupIntervalResponse) GetMin() *Scalar

+ func (x *EstimateRollupIntervalResponse) ProtoReflect() protoreflect.Message

+ func (x *EstimateRollupIntervalResponse) Reset()

+ func (x *EstimateRollupIntervalResponse) String() string

+ type EstimateSmallestTimeGrainRequest struct

+ ColumnName string

+ InstanceId string

+ TableName string

+ func (*EstimateSmallestTimeGrainRequest) Descriptor() ([]byte, []int)

+ func (*EstimateSmallestTimeGrainRequest) ProtoMessage()

+ func (x *EstimateSmallestTimeGrainRequest) GetColumnName() string

+ func (x *EstimateSmallestTimeGrainRequest) GetInstanceId() string

+ func (x *EstimateSmallestTimeGrainRequest) GetTableName() string

+ func (x *EstimateSmallestTimeGrainRequest) ProtoReflect() protoreflect.Message

+ func (x *EstimateSmallestTimeGrainRequest) Reset()

+ func (x *EstimateSmallestTimeGrainRequest) String() string

+ type EstimateSmallestTimeGrainResponse struct

+ TimeGrain TimeGrain

+ func (*EstimateSmallestTimeGrainResponse) Descriptor() ([]byte, []int)

+ func (*EstimateSmallestTimeGrainResponse) ProtoMessage()

+ func (x *EstimateSmallestTimeGrainResponse) GetTimeGrain() TimeGrain

+ func (x *EstimateSmallestTimeGrainResponse) ProtoReflect() protoreflect.Message

+ func (x *EstimateSmallestTimeGrainResponse) Reset()

+ func (x *EstimateSmallestTimeGrainResponse) String() string

+ type GenerateTimeSeriesRequest struct

+ Filters *MetricsViewRequestFilter

+ InstanceId string

+ Measures *GenerateTimeSeriesRequest_BasicMeasures

+ Pixels *int64

+ SampleSize *int32

+ TableName string

+ TimeRange *TimeSeriesTimeRange

+ TimestampColumnName string

+ func (*GenerateTimeSeriesRequest) Descriptor() ([]byte, []int)

+ func (*GenerateTimeSeriesRequest) ProtoMessage()

+ func (x *GenerateTimeSeriesRequest) GetFilters() *MetricsViewRequestFilter

+ func (x *GenerateTimeSeriesRequest) GetInstanceId() string

+ func (x *GenerateTimeSeriesRequest) GetMeasures() *GenerateTimeSeriesRequest_BasicMeasures

+ func (x *GenerateTimeSeriesRequest) GetPixels() int64

+ func (x *GenerateTimeSeriesRequest) GetSampleSize() int32

+ func (x *GenerateTimeSeriesRequest) GetTableName() string

+ func (x *GenerateTimeSeriesRequest) GetTimeRange() *TimeSeriesTimeRange

+ func (x *GenerateTimeSeriesRequest) GetTimestampColumnName() string

+ func (x *GenerateTimeSeriesRequest) ProtoReflect() protoreflect.Message

+ func (x *GenerateTimeSeriesRequest) Reset()

+ func (x *GenerateTimeSeriesRequest) String() string

+ type GenerateTimeSeriesRequest_BasicMeasures struct

+ BasicMeasures []*BasicMeasureDefinition

+ func (*GenerateTimeSeriesRequest_BasicMeasures) Descriptor() ([]byte, []int)

+ func (*GenerateTimeSeriesRequest_BasicMeasures) ProtoMessage()

+ func (x *GenerateTimeSeriesRequest_BasicMeasures) GetBasicMeasures() []*BasicMeasureDefinition

+ func (x *GenerateTimeSeriesRequest_BasicMeasures) ProtoReflect() protoreflect.Message

+ func (x *GenerateTimeSeriesRequest_BasicMeasures) Reset()

+ func (x *GenerateTimeSeriesRequest_BasicMeasures) String() string

+ type GetFileRequest struct

+ Path string

+ RepoId string

+ func (*GetFileRequest) Descriptor() ([]byte, []int)

+ func (*GetFileRequest) ProtoMessage()

+ func (x *GetFileRequest) GetPath() string

+ func (x *GetFileRequest) GetRepoId() string

+ func (x *GetFileRequest) ProtoReflect() protoreflect.Message

+ func (x *GetFileRequest) Reset()

+ func (x *GetFileRequest) String() string

+ type GetFileResponse struct

+ Blob string

+ UpdatedOn *timestamppb.Timestamp

+ func (*GetFileResponse) Descriptor() ([]byte, []int)

+ func (*GetFileResponse) ProtoMessage()

+ func (x *GetFileResponse) GetBlob() string

+ func (x *GetFileResponse) GetUpdatedOn() *timestamppb.Timestamp

+ func (x *GetFileResponse) ProtoReflect() protoreflect.Message

+ func (x *GetFileResponse) Reset()

+ func (x *GetFileResponse) String() string

type ListCatalogObjectsRequest

+ Type CatalogObject_Type

+ func (x *ListCatalogObjectsRequest) GetType() CatalogObject_Type

+ type ListFilesRequest struct

+ Glob string

+ RepoId string

+ func (*ListFilesRequest) Descriptor() ([]byte, []int)

+ func (*ListFilesRequest) ProtoMessage()

+ func (x *ListFilesRequest) GetGlob() string

+ func (x *ListFilesRequest) GetRepoId() string

+ func (x *ListFilesRequest) ProtoReflect() protoreflect.Message

+ func (x *ListFilesRequest) Reset()

+ func (x *ListFilesRequest) String() string

+ type ListFilesResponse struct

+ Paths []string

+ func (*ListFilesResponse) Descriptor() ([]byte, []int)

+ func (*ListFilesResponse) ProtoMessage()

+ func (x *ListFilesResponse) GetPaths() []string

+ func (x *ListFilesResponse) ProtoReflect() protoreflect.Message

+ func (x *ListFilesResponse) Reset()

+ func (x *ListFilesResponse) String() string

+ type MapType struct

+ KeyType *Type

+ ValueType *Type

+ func (*MapType) Descriptor() ([]byte, []int)

+ func (*MapType) ProtoMessage()

+ func (x *MapType) GetKeyType() *Type

+ func (x *MapType) GetValueType() *Type

+ func (x *MapType) ProtoReflect() protoreflect.Message

+ func (x *MapType) Reset()

+ func (x *MapType) String() string

type MetricsView

+ From string

+ TimeDimension string

+ TimeGrains []string

+ func (x *MetricsView) GetFrom() string

+ func (x *MetricsView) GetTimeDimension() string

+ func (x *MetricsView) GetTimeGrains() []string

+ type MetricsViewColumn struct

+ Name string

+ Nullable bool

+ Type string

+ func (*MetricsViewColumn) Descriptor() ([]byte, []int)

+ func (*MetricsViewColumn) ProtoMessage()

+ func (x *MetricsViewColumn) GetName() string

+ func (x *MetricsViewColumn) GetNullable() bool

+ func (x *MetricsViewColumn) GetType() string

+ func (x *MetricsViewColumn) ProtoReflect() protoreflect.Message

+ func (x *MetricsViewColumn) Reset()

+ func (x *MetricsViewColumn) String() string

+ type MetricsViewDimensionValue struct

+ In []*structpb.Value

+ Like *MetricsViewDimensionValue_Values

+ Name string

+ func (*MetricsViewDimensionValue) Descriptor() ([]byte, []int)

+ func (*MetricsViewDimensionValue) ProtoMessage()

+ func (x *MetricsViewDimensionValue) GetIn() []*structpb.Value

+ func (x *MetricsViewDimensionValue) GetLike() *MetricsViewDimensionValue_Values

+ func (x *MetricsViewDimensionValue) GetName() string

+ func (x *MetricsViewDimensionValue) ProtoReflect() protoreflect.Message

+ func (x *MetricsViewDimensionValue) Reset()

+ func (x *MetricsViewDimensionValue) String() string

+ type MetricsViewDimensionValue_Values struct

+ Values []*structpb.Value

+ func (*MetricsViewDimensionValue_Values) Descriptor() ([]byte, []int)

+ func (*MetricsViewDimensionValue_Values) ProtoMessage()

+ func (x *MetricsViewDimensionValue_Values) GetValues() []*structpb.Value

+ func (x *MetricsViewDimensionValue_Values) ProtoReflect() protoreflect.Message

+ func (x *MetricsViewDimensionValue_Values) Reset()

+ func (x *MetricsViewDimensionValue_Values) String() string

+ type MetricsViewRequestFilter struct

+ Exclude []*MetricsViewDimensionValue

+ Include []*MetricsViewDimensionValue

+ func (*MetricsViewRequestFilter) Descriptor() ([]byte, []int)

+ func (*MetricsViewRequestFilter) ProtoMessage()

+ func (x *MetricsViewRequestFilter) GetExclude() []*MetricsViewDimensionValue

+ func (x *MetricsViewRequestFilter) GetInclude() []*MetricsViewDimensionValue

+ func (x *MetricsViewRequestFilter) ProtoReflect() protoreflect.Message

+ func (x *MetricsViewRequestFilter) Reset()

+ func (x *MetricsViewRequestFilter) String() string

type MetricsView_Dimension

+ Enabled string

+ Label string

+ func (x *MetricsView_Dimension) GetEnabled() string

+ func (x *MetricsView_Dimension) GetLabel() string

type MetricsView_Measure

+ Enabled string

+ Expression string

+ Format string

+ Label string

+ func (x *MetricsView_Measure) GetEnabled() string

+ func (x *MetricsView_Measure) GetExpression() string

+ func (x *MetricsView_Measure) GetFormat() string

+ func (x *MetricsView_Measure) GetLabel() string

type MigrateRequest

+ ChangedPaths []string

+ Dry bool

+ RepoId string

+ Strict bool

+ func (x *MigrateRequest) GetChangedPaths() []string

+ func (x *MigrateRequest) GetDry() bool

+ func (x *MigrateRequest) GetRepoId() string

+ func (x *MigrateRequest) GetStrict() bool

type MigrateResponse

+ AffectedPaths []string

+ Errors []*MigrationError

+ func (x *MigrateResponse) GetAffectedPaths() []string

+ func (x *MigrateResponse) GetErrors() []*MigrationError

+ type MigrationError struct

+ Code MigrationError_Code

+ EndLocation *MigrationError_CharLocation

+ FilePath string

+ Message string

+ PropertyPath string

+ StartLocation *MigrationError_CharLocation

+ func (*MigrationError) Descriptor() ([]byte, []int)

+ func (*MigrationError) ProtoMessage()

+ func (x *MigrationError) GetCode() MigrationError_Code

+ func (x *MigrationError) GetEndLocation() *MigrationError_CharLocation

+ func (x *MigrationError) GetFilePath() string

+ func (x *MigrationError) GetMessage() string

+ func (x *MigrationError) GetPropertyPath() string

+ func (x *MigrationError) GetStartLocation() *MigrationError_CharLocation

+ func (x *MigrationError) ProtoReflect() protoreflect.Message

+ func (x *MigrationError) Reset()

+ func (x *MigrationError) String() string

+ type MigrationError_CharLocation struct

+ Column uint32

+ Line uint32

+ func (*MigrationError_CharLocation) Descriptor() ([]byte, []int)

+ func (*MigrationError_CharLocation) ProtoMessage()

+ func (x *MigrationError_CharLocation) GetColumn() uint32

+ func (x *MigrationError_CharLocation) GetLine() uint32

+ func (x *MigrationError_CharLocation) ProtoReflect() protoreflect.Message

+ func (x *MigrationError_CharLocation) Reset()

+ func (x *MigrationError_CharLocation) String() string

+ type MigrationError_Code int32

+ const MigrationError_CODE_DEPENDENCY

+ const MigrationError_CODE_OLAP

+ const MigrationError_CODE_SOURCE

+ const MigrationError_CODE_SYNTAX

+ const MigrationError_CODE_UNSPECIFIED

+ const MigrationError_CODE_VALIDATION

+ func (MigrationError_Code) Descriptor() protoreflect.EnumDescriptor

+ func (MigrationError_Code) EnumDescriptor() ([]byte, []int)

+ func (MigrationError_Code) Type() protoreflect.EnumType

+ func (x MigrationError_Code) Enum() *MigrationError_Code

+ func (x MigrationError_Code) Number() protoreflect.EnumNumber

+ func (x MigrationError_Code) String() string

+ type Model struct

+ Dialect Model_Dialect

+ Name string

+ Schema *StructType

+ Sql string

+ func (*Model) Descriptor() ([]byte, []int)

+ func (*Model) ProtoMessage()

+ func (x *Model) GetDialect() Model_Dialect

+ func (x *Model) GetName() string

+ func (x *Model) GetSchema() *StructType

+ func (x *Model) GetSql() string

+ func (x *Model) ProtoReflect() protoreflect.Message

+ func (x *Model) Reset()

+ func (x *Model) String() string

+ type Model_Dialect int32

+ const Model_DIALECT_DUCKDB

+ const Model_DIALECT_UNSPECIFIED

+ func (Model_Dialect) Descriptor() protoreflect.EnumDescriptor

+ func (Model_Dialect) EnumDescriptor() ([]byte, []int)

+ func (Model_Dialect) Type() protoreflect.EnumType

+ func (x Model_Dialect) Enum() *Model_Dialect

+ func (x Model_Dialect) Number() protoreflect.EnumNumber

+ func (x Model_Dialect) String() string

+ type NullCountRequest struct

+ ColumnName string

+ InstanceId string

+ TableName string

+ func (*NullCountRequest) Descriptor() ([]byte, []int)

+ func (*NullCountRequest) ProtoMessage()

+ func (x *NullCountRequest) GetColumnName() string

+ func (x *NullCountRequest) GetInstanceId() string

+ func (x *NullCountRequest) GetTableName() string

+ func (x *NullCountRequest) ProtoReflect() protoreflect.Message

+ func (x *NullCountRequest) Reset()

+ func (x *NullCountRequest) String() string

+ type NullCountResponse struct

+ Count int64

+ func (*NullCountResponse) Descriptor() ([]byte, []int)

+ func (*NullCountResponse) ProtoMessage()

+ func (x *NullCountResponse) GetCount() int64

+ func (x *NullCountResponse) ProtoReflect() protoreflect.Message

+ func (x *NullCountResponse) Reset()

+ func (x *NullCountResponse) String() string

+ type NumericHistogramBins struct

+ Bins []*NumericHistogramBins_Bin

+ func (*NumericHistogramBins) Descriptor() ([]byte, []int)

+ func (*NumericHistogramBins) ProtoMessage()

+ func (x *NumericHistogramBins) GetBins() []*NumericHistogramBins_Bin

+ func (x *NumericHistogramBins) ProtoReflect() protoreflect.Message

+ func (x *NumericHistogramBins) Reset()

+ func (x *NumericHistogramBins) String() string

+ type NumericHistogramBins_Bin struct

+ Bucket int64

+ Count int64

+ High float64

+ Low float64

+ func (*NumericHistogramBins_Bin) Descriptor() ([]byte, []int)

+ func (*NumericHistogramBins_Bin) ProtoMessage()

+ func (x *NumericHistogramBins_Bin) GetBucket() int64

+ func (x *NumericHistogramBins_Bin) GetCount() int64

+ func (x *NumericHistogramBins_Bin) GetHigh() float64

+ func (x *NumericHistogramBins_Bin) GetLow() float64

+ func (x *NumericHistogramBins_Bin) ProtoReflect() protoreflect.Message

+ func (x *NumericHistogramBins_Bin) Reset()

+ func (x *NumericHistogramBins_Bin) String() string

+ type NumericHistogramRequest struct

+ ColumnName string

+ InstanceId string

+ TableName string

+ func (*NumericHistogramRequest) Descriptor() ([]byte, []int)

+ func (*NumericHistogramRequest) ProtoMessage()

+ func (x *NumericHistogramRequest) GetColumnName() string

+ func (x *NumericHistogramRequest) GetInstanceId() string

+ func (x *NumericHistogramRequest) GetTableName() string

+ func (x *NumericHistogramRequest) ProtoReflect() protoreflect.Message

+ func (x *NumericHistogramRequest) Reset()

+ func (x *NumericHistogramRequest) String() string

+ type NumericOutliers struct

+ Outliers []*NumericOutliers_Outlier

+ func (*NumericOutliers) Descriptor() ([]byte, []int)

+ func (*NumericOutliers) ProtoMessage()

+ func (x *NumericOutliers) GetOutliers() []*NumericOutliers_Outlier

+ func (x *NumericOutliers) ProtoReflect() protoreflect.Message

+ func (x *NumericOutliers) Reset()

+ func (x *NumericOutliers) String() string

+ type NumericOutliers_Outlier struct

+ Bucket int64

+ High float64

+ Low float64

+ Present bool

+ func (*NumericOutliers_Outlier) Descriptor() ([]byte, []int)

+ func (*NumericOutliers_Outlier) ProtoMessage()

+ func (x *NumericOutliers_Outlier) GetBucket() int64

+ func (x *NumericOutliers_Outlier) GetHigh() float64

+ func (x *NumericOutliers_Outlier) GetLow() float64

+ func (x *NumericOutliers_Outlier) GetPresent() bool

+ func (x *NumericOutliers_Outlier) ProtoReflect() protoreflect.Message

+ func (x *NumericOutliers_Outlier) Reset()

+ func (x *NumericOutliers_Outlier) String() string

+ type NumericStatistics struct

+ Max float64

+ Mean float64

+ Min float64

+ Q25 float64

+ Q50 float64

+ Q75 float64

+ Sd float64

+ func (*NumericStatistics) Descriptor() ([]byte, []int)

+ func (*NumericStatistics) ProtoMessage()

+ func (x *NumericStatistics) GetMax() float64

+ func (x *NumericStatistics) GetMean() float64

+ func (x *NumericStatistics) GetMin() float64

+ func (x *NumericStatistics) GetQ25() float64

+ func (x *NumericStatistics) GetQ50() float64

+ func (x *NumericStatistics) GetQ75() float64

+ func (x *NumericStatistics) GetSd() float64

+ func (x *NumericStatistics) ProtoReflect() protoreflect.Message

+ func (x *NumericStatistics) Reset()

+ func (x *NumericStatistics) String() string

+ type NumericSummary struct

+ NumericHistogramBins *NumericHistogramBins

+ NumericOutliers *NumericOutliers

+ NumericStatistics *NumericStatistics

+ func (*NumericSummary) Descriptor() ([]byte, []int)

+ func (*NumericSummary) ProtoMessage()

+ func (x *NumericSummary) GetNumericHistogramBins() *NumericHistogramBins

+ func (x *NumericSummary) GetNumericOutliers() *NumericOutliers

+ func (x *NumericSummary) GetNumericStatistics() *NumericStatistics

+ func (x *NumericSummary) ProtoReflect() protoreflect.Message

+ func (x *NumericSummary) Reset()

+ func (x *NumericSummary) String() string

+ type ProfileColumn struct

+ LargestStringLength int32

+ Name string

+ Type string

+ func (*ProfileColumn) Descriptor() ([]byte, []int)

+ func (*ProfileColumn) ProtoMessage()

+ func (x *ProfileColumn) GetLargestStringLength() int32

+ func (x *ProfileColumn) GetName() string

+ func (x *ProfileColumn) GetType() string

+ func (x *ProfileColumn) ProtoReflect() protoreflect.Message

+ func (x *ProfileColumn) Reset()

+ func (x *ProfileColumn) String() string

+ type ProfileColumnSummary struct

+ Case isProfileColumnSummary_Case

+ func (*ProfileColumnSummary) Descriptor() ([]byte, []int)

+ func (*ProfileColumnSummary) ProtoMessage()

+ func (m *ProfileColumnSummary) GetCase() isProfileColumnSummary_Case

+ func (x *ProfileColumnSummary) GetCategoricalSummary() *CategoricalSummary

+ func (x *ProfileColumnSummary) GetNumericSummary() *NumericSummary

+ func (x *ProfileColumnSummary) GetTimeRangeSummary() *TimeRangeSummary

+ func (x *ProfileColumnSummary) ProtoReflect() protoreflect.Message

+ func (x *ProfileColumnSummary) Reset()

+ func (x *ProfileColumnSummary) String() string

+ type ProfileColumnSummary_CategoricalSummary struct

+ CategoricalSummary *CategoricalSummary

+ type ProfileColumnSummary_NumericSummary struct

+ NumericSummary *NumericSummary

+ type ProfileColumnSummary_TimeRangeSummary struct

+ TimeRangeSummary *TimeRangeSummary

+ type ProfileColumnsRequest struct

+ InstanceId string

+ TableName string

+ func (*ProfileColumnsRequest) Descriptor() ([]byte, []int)

+ func (*ProfileColumnsRequest) ProtoMessage()

+ func (x *ProfileColumnsRequest) GetInstanceId() string

+ func (x *ProfileColumnsRequest) GetTableName() string

+ func (x *ProfileColumnsRequest) ProtoReflect() protoreflect.Message

+ func (x *ProfileColumnsRequest) Reset()

+ func (x *ProfileColumnsRequest) String() string

+ type ProfileColumnsResponse struct

+ ProfileColumns []*ProfileColumn

+ func (*ProfileColumnsResponse) Descriptor() ([]byte, []int)

+ func (*ProfileColumnsResponse) ProtoMessage()

+ func (x *ProfileColumnsResponse) GetProfileColumns() []*ProfileColumn

+ func (x *ProfileColumnsResponse) ProtoReflect() protoreflect.Message

+ func (x *ProfileColumnsResponse) Reset()

+ func (x *ProfileColumnsResponse) String() string

+ type PutFileAndMigrateRequest struct

+ Blob string

+ Create bool

+ CreateOnly bool

+ Dry bool

+ InstanceId string

+ Path string

+ RepoId string

+ Strict bool

+ func (*PutFileAndMigrateRequest) Descriptor() ([]byte, []int)

+ func (*PutFileAndMigrateRequest) ProtoMessage()

+ func (x *PutFileAndMigrateRequest) GetBlob() string

+ func (x *PutFileAndMigrateRequest) GetCreate() bool

+ func (x *PutFileAndMigrateRequest) GetCreateOnly() bool

+ func (x *PutFileAndMigrateRequest) GetDry() bool

+ func (x *PutFileAndMigrateRequest) GetInstanceId() string

+ func (x *PutFileAndMigrateRequest) GetPath() string

+ func (x *PutFileAndMigrateRequest) GetRepoId() string

+ func (x *PutFileAndMigrateRequest) GetStrict() bool

+ func (x *PutFileAndMigrateRequest) ProtoReflect() protoreflect.Message

+ func (x *PutFileAndMigrateRequest) Reset()

+ func (x *PutFileAndMigrateRequest) String() string

+ type PutFileAndMigrateResponse struct

+ AffectedPaths []string

+ Errors []*MigrationError

+ func (*PutFileAndMigrateResponse) Descriptor() ([]byte, []int)

+ func (*PutFileAndMigrateResponse) ProtoMessage()

+ func (x *PutFileAndMigrateResponse) GetAffectedPaths() []string

+ func (x *PutFileAndMigrateResponse) GetErrors() []*MigrationError

+ func (x *PutFileAndMigrateResponse) ProtoReflect() protoreflect.Message

+ func (x *PutFileAndMigrateResponse) Reset()

+ func (x *PutFileAndMigrateResponse) String() string

+ type PutFileRequest struct

+ Blob string

+ Create bool

+ CreateOnly bool

+ Path string

+ RepoId string

+ func (*PutFileRequest) Descriptor() ([]byte, []int)

+ func (*PutFileRequest) ProtoMessage()

+ func (x *PutFileRequest) GetBlob() string

+ func (x *PutFileRequest) GetCreate() bool

+ func (x *PutFileRequest) GetCreateOnly() bool

+ func (x *PutFileRequest) GetPath() string

+ func (x *PutFileRequest) GetRepoId() string

+ func (x *PutFileRequest) ProtoReflect() protoreflect.Message

+ func (x *PutFileRequest) Reset()

+ func (x *PutFileRequest) String() string

+ type PutFileResponse struct

+ FilePath string

+ func (*PutFileResponse) Descriptor() ([]byte, []int)

+ func (*PutFileResponse) ProtoMessage()

+ func (x *PutFileResponse) GetFilePath() string

+ func (x *PutFileResponse) ProtoReflect() protoreflect.Message

+ func (x *PutFileResponse) Reset()

+ func (x *PutFileResponse) String() string

+ type RenameDatabaseObjectRequest struct

+ InstanceId string

+ Name string

+ Newname string

+ Type *DatabaseObjectType

+ func (*RenameDatabaseObjectRequest) Descriptor() ([]byte, []int)

+ func (*RenameDatabaseObjectRequest) ProtoMessage()

+ func (x *RenameDatabaseObjectRequest) GetInstanceId() string

+ func (x *RenameDatabaseObjectRequest) GetName() string

+ func (x *RenameDatabaseObjectRequest) GetNewname() string

+ func (x *RenameDatabaseObjectRequest) GetType() DatabaseObjectType

+ func (x *RenameDatabaseObjectRequest) ProtoReflect() protoreflect.Message

+ func (x *RenameDatabaseObjectRequest) Reset()

+ func (x *RenameDatabaseObjectRequest) String() string

+ type RenameDatabaseObjectResponse struct

+ func (*RenameDatabaseObjectResponse) Descriptor() ([]byte, []int)

+ func (*RenameDatabaseObjectResponse) ProtoMessage()

+ func (x *RenameDatabaseObjectResponse) ProtoReflect() protoreflect.Message

+ func (x *RenameDatabaseObjectResponse) Reset()

+ func (x *RenameDatabaseObjectResponse) String() string

+ type RenameFileAndMigrateRequest struct

+ Dry bool

+ FromPath string

+ InstanceId string

+ RepoId string

+ Strict bool

+ ToPath string

+ func (*RenameFileAndMigrateRequest) Descriptor() ([]byte, []int)

+ func (*RenameFileAndMigrateRequest) ProtoMessage()

+ func (x *RenameFileAndMigrateRequest) GetDry() bool

+ func (x *RenameFileAndMigrateRequest) GetFromPath() string

+ func (x *RenameFileAndMigrateRequest) GetInstanceId() string

+ func (x *RenameFileAndMigrateRequest) GetRepoId() string

+ func (x *RenameFileAndMigrateRequest) GetStrict() bool

+ func (x *RenameFileAndMigrateRequest) GetToPath() string

+ func (x *RenameFileAndMigrateRequest) ProtoReflect() protoreflect.Message

+ func (x *RenameFileAndMigrateRequest) Reset()

+ func (x *RenameFileAndMigrateRequest) String() string

+ type RenameFileAndMigrateResponse struct

+ AffectedPaths []string

+ Errors []*MigrationError

+ func (*RenameFileAndMigrateResponse) Descriptor() ([]byte, []int)

+ func (*RenameFileAndMigrateResponse) ProtoMessage()

+ func (x *RenameFileAndMigrateResponse) GetAffectedPaths() []string

+ func (x *RenameFileAndMigrateResponse) GetErrors() []*MigrationError

+ func (x *RenameFileAndMigrateResponse) ProtoReflect() protoreflect.Message

+ func (x *RenameFileAndMigrateResponse) Reset()

+ func (x *RenameFileAndMigrateResponse) String() string

+ type RenameFileRequest struct

+ FromPath string

+ RepoId string

+ ToPath string

+ func (*RenameFileRequest) Descriptor() ([]byte, []int)

+ func (*RenameFileRequest) ProtoMessage()

+ func (x *RenameFileRequest) GetFromPath() string

+ func (x *RenameFileRequest) GetRepoId() string

+ func (x *RenameFileRequest) GetToPath() string

+ func (x *RenameFileRequest) ProtoReflect() protoreflect.Message

+ func (x *RenameFileRequest) Reset()

+ func (x *RenameFileRequest) String() string

+ type RenameFileResponse struct

+ func (*RenameFileResponse) Descriptor() ([]byte, []int)

+ func (*RenameFileResponse) ProtoMessage()

+ func (x *RenameFileResponse) ProtoReflect() protoreflect.Message

+ func (x *RenameFileResponse) Reset()

+ func (x *RenameFileResponse) String() string

+ type RowsRequest struct

+ InstanceId string

+ Limit int32

+ TableName string

+ func (*RowsRequest) Descriptor() ([]byte, []int)

+ func (*RowsRequest) ProtoMessage()

+ func (x *RowsRequest) GetInstanceId() string

+ func (x *RowsRequest) GetLimit() int32

+ func (x *RowsRequest) GetTableName() string

+ func (x *RowsRequest) ProtoReflect() protoreflect.Message

+ func (x *RowsRequest) Reset()

+ func (x *RowsRequest) String() string

+ type RowsResponse struct

+ Data []*structpb.Struct

+ func (*RowsResponse) Descriptor() ([]byte, []int)

+ func (*RowsResponse) ProtoMessage()

+ func (x *RowsResponse) GetData() []*structpb.Struct

+ func (x *RowsResponse) ProtoReflect() protoreflect.Message

+ func (x *RowsResponse) Reset()

+ func (x *RowsResponse) String() string

+ type RugHistogramRequest struct

+ ColumnName string

+ InstanceId string

+ TableName string

+ func (*RugHistogramRequest) Descriptor() ([]byte, []int)

+ func (*RugHistogramRequest) ProtoMessage()

+ func (x *RugHistogramRequest) GetColumnName() string

+ func (x *RugHistogramRequest) GetInstanceId() string

+ func (x *RugHistogramRequest) GetTableName() string

+ func (x *RugHistogramRequest) ProtoReflect() protoreflect.Message

+ func (x *RugHistogramRequest) Reset()

+ func (x *RugHistogramRequest) String() string

type RuntimeServiceClient

+ DeleteFile func(ctx context.Context, in *DeleteFileRequest, opts ...grpc.CallOption) (*DeleteFileResponse, error)

+ DeleteFileAndMigrate func(ctx context.Context, in *DeleteFileAndMigrateRequest, opts ...grpc.CallOption) (*DeleteFileAndMigrateResponse, error)

+ EstimateRollupInterval func(ctx context.Context, in *EstimateRollupIntervalRequest, ...) (*EstimateRollupIntervalResponse, error)

+ EstimateSmallestTimeGrain func(ctx context.Context, in *EstimateSmallestTimeGrainRequest, ...) (*EstimateSmallestTimeGrainResponse, error)

+ GenerateTimeSeries func(ctx context.Context, in *GenerateTimeSeriesRequest, opts ...grpc.CallOption) (*TimeSeriesRollup, error)

+ GetCardinalityOfColumn func(ctx context.Context, in *CardinalityOfColumnRequest, opts ...grpc.CallOption) (*CategoricalSummary, error)

+ GetDescriptiveStatistics func(ctx context.Context, in *DescriptiveStatisticsRequest, opts ...grpc.CallOption) (*NumericSummary, error)

+ GetFile func(ctx context.Context, in *GetFileRequest, opts ...grpc.CallOption) (*GetFileResponse, error)

+ GetNullCount func(ctx context.Context, in *NullCountRequest, opts ...grpc.CallOption) (*NullCountResponse, error)

+ GetNumericHistogram func(ctx context.Context, in *NumericHistogramRequest, opts ...grpc.CallOption) (*NumericSummary, error)

+ GetRugHistogram func(ctx context.Context, in *RugHistogramRequest, opts ...grpc.CallOption) (*NumericSummary, error)

+ GetTimeRangeSummary func(ctx context.Context, in *TimeRangeSummaryRequest, opts ...grpc.CallOption) (*TimeRangeSummary, error)

+ ListFiles func(ctx context.Context, in *ListFilesRequest, opts ...grpc.CallOption) (*ListFilesResponse, error)

+ ProfileColumns func(ctx context.Context, in *ProfileColumnsRequest, opts ...grpc.CallOption) (*ProfileColumnsResponse, error)

+ PutFile func(ctx context.Context, in *PutFileRequest, opts ...grpc.CallOption) (*PutFileResponse, error)

+ PutFileAndMigrate func(ctx context.Context, in *PutFileAndMigrateRequest, opts ...grpc.CallOption) (*PutFileAndMigrateResponse, error)

+ RenameDatabaseObject func(ctx context.Context, in *RenameDatabaseObjectRequest, opts ...grpc.CallOption) (*RenameDatabaseObjectResponse, error)

+ RenameFile func(ctx context.Context, in *RenameFileRequest, opts ...grpc.CallOption) (*RenameFileResponse, error)

+ RenameFileAndMigrate func(ctx context.Context, in *RenameFileAndMigrateRequest, opts ...grpc.CallOption) (*RenameFileAndMigrateResponse, error)

+ TableCardinality func(ctx context.Context, in *CardinalityRequest, opts ...grpc.CallOption) (*CardinalityResponse, error)

+ TableRows func(ctx context.Context, in *RowsRequest, opts ...grpc.CallOption) (*RowsResponse, error)

+ TriggerSync func(ctx context.Context, in *TriggerSyncRequest, opts ...grpc.CallOption) (*TriggerSyncResponse, error)

type RuntimeServiceServer

+ DeleteFile func(context.Context, *DeleteFileRequest) (*DeleteFileResponse, error)

+ DeleteFileAndMigrate func(context.Context, *DeleteFileAndMigrateRequest) (*DeleteFileAndMigrateResponse, error)

+ EstimateRollupInterval func(context.Context, *EstimateRollupIntervalRequest) (*EstimateRollupIntervalResponse, error)

+ EstimateSmallestTimeGrain func(context.Context, *EstimateSmallestTimeGrainRequest) (*EstimateSmallestTimeGrainResponse, error)

+ GenerateTimeSeries func(context.Context, *GenerateTimeSeriesRequest) (*TimeSeriesRollup, error)

+ GetCardinalityOfColumn func(context.Context, *CardinalityOfColumnRequest) (*CategoricalSummary, error)

+ GetDescriptiveStatistics func(context.Context, *DescriptiveStatisticsRequest) (*NumericSummary, error)

+ GetFile func(context.Context, *GetFileRequest) (*GetFileResponse, error)

+ GetNullCount func(context.Context, *NullCountRequest) (*NullCountResponse, error)

+ GetNumericHistogram func(context.Context, *NumericHistogramRequest) (*NumericSummary, error)

+ GetRugHistogram func(context.Context, *RugHistogramRequest) (*NumericSummary, error)

+ GetTimeRangeSummary func(context.Context, *TimeRangeSummaryRequest) (*TimeRangeSummary, error)

+ ListFiles func(context.Context, *ListFilesRequest) (*ListFilesResponse, error)

+ ProfileColumns func(context.Context, *ProfileColumnsRequest) (*ProfileColumnsResponse, error)

+ PutFile func(context.Context, *PutFileRequest) (*PutFileResponse, error)

+ PutFileAndMigrate func(context.Context, *PutFileAndMigrateRequest) (*PutFileAndMigrateResponse, error)

+ RenameDatabaseObject func(context.Context, *RenameDatabaseObjectRequest) (*RenameDatabaseObjectResponse, error)

+ RenameFile func(context.Context, *RenameFileRequest) (*RenameFileResponse, error)

+ RenameFileAndMigrate func(context.Context, *RenameFileAndMigrateRequest) (*RenameFileAndMigrateResponse, error)

+ TableCardinality func(context.Context, *CardinalityRequest) (*CardinalityResponse, error)

+ TableRows func(context.Context, *RowsRequest) (*RowsResponse, error)

+ TriggerSync func(context.Context, *TriggerSyncRequest) (*TriggerSyncResponse, error)

+ type Scalar struct

+ Value isScalar_Value

+ func (*Scalar) Descriptor() ([]byte, []int)

+ func (*Scalar) ProtoMessage()

+ func (m *Scalar) GetValue() isScalar_Value

+ func (x *Scalar) GetDouble() float64

+ func (x *Scalar) GetInt64() int64

+ func (x *Scalar) GetTimestamp() *timestamppb.Timestamp

+ func (x *Scalar) ProtoReflect() protoreflect.Message

+ func (x *Scalar) Reset()

+ func (x *Scalar) String() string

+ type Scalar_Double struct

+ Double float64

+ type Scalar_Int64 struct

+ Int64 int64

+ type Scalar_Timestamp struct

+ Timestamp *timestamppb.Timestamp

type Source

+ Schema *StructType

+ func (x *Source) GetSchema() *StructType

+ type StructType struct

+ Fields []*StructType_Field

+ func (*StructType) Descriptor() ([]byte, []int)

+ func (*StructType) ProtoMessage()

+ func (x *StructType) GetFields() []*StructType_Field

+ func (x *StructType) ProtoReflect() protoreflect.Message

+ func (x *StructType) Reset()

+ func (x *StructType) String() string

+ type StructType_Field struct

+ Name string

+ Type *Type

+ func (*StructType_Field) Descriptor() ([]byte, []int)

+ func (*StructType_Field) ProtoMessage()

+ func (x *StructType_Field) GetName() string

+ func (x *StructType_Field) GetType() *Type

+ func (x *StructType_Field) ProtoReflect() protoreflect.Message

+ func (x *StructType_Field) Reset()

+ func (x *StructType_Field) String() string

+ type Table struct

+ Managed bool

+ Name string

+ Schema *StructType

+ func (*Table) Descriptor() ([]byte, []int)

+ func (*Table) ProtoMessage()

+ func (x *Table) GetManaged() bool

+ func (x *Table) GetName() string

+ func (x *Table) GetSchema() *StructType

+ func (x *Table) ProtoReflect() protoreflect.Message

+ func (x *Table) Reset()

+ func (x *Table) String() string

+ type TimeGrain int32

+ const TimeGrain_DAY

+ const TimeGrain_HOUR

+ const TimeGrain_MILLISECOND

+ const TimeGrain_MINUTE

+ const TimeGrain_MONTH

+ const TimeGrain_SECOND

+ const TimeGrain_UNSPECIFIED

+ const TimeGrain_WEEK

+ const TimeGrain_YEAR

+ func (TimeGrain) Descriptor() protoreflect.EnumDescriptor

+ func (TimeGrain) EnumDescriptor() ([]byte, []int)

+ func (TimeGrain) Type() protoreflect.EnumType

+ func (x TimeGrain) Enum() *TimeGrain

+ func (x TimeGrain) Number() protoreflect.EnumNumber

+ func (x TimeGrain) String() string

+ type TimeRangeName int32

+ const TimeRangeName_AllTime

+ const TimeRangeName_Last2Days

+ const TimeRangeName_Last2Weeks

+ const TimeRangeName_Last30Days

+ const TimeRangeName_Last5Days

+ const TimeRangeName_Last60Days

+ const TimeRangeName_Last6Hours

+ const TimeRangeName_LastDay

+ const TimeRangeName_LastHour

+ const TimeRangeName_LastWeek

+ func (TimeRangeName) Descriptor() protoreflect.EnumDescriptor

+ func (TimeRangeName) EnumDescriptor() ([]byte, []int)

+ func (TimeRangeName) Type() protoreflect.EnumType

+ func (x TimeRangeName) Enum() *TimeRangeName

+ func (x TimeRangeName) Number() protoreflect.EnumNumber

+ func (x TimeRangeName) String() string

+ type TimeRangeSummary struct

+ Interval *TimeRangeSummary_Interval

+ Max string

+ Min string

+ func (*TimeRangeSummary) Descriptor() ([]byte, []int)

+ func (*TimeRangeSummary) ProtoMessage()

+ func (x *TimeRangeSummary) GetInterval() *TimeRangeSummary_Interval

+ func (x *TimeRangeSummary) GetMax() string

+ func (x *TimeRangeSummary) GetMin() string

+ func (x *TimeRangeSummary) ProtoReflect() protoreflect.Message

+ func (x *TimeRangeSummary) Reset()

+ func (x *TimeRangeSummary) String() string

+ type TimeRangeSummaryRequest struct

+ ColumnName string

+ InstanceId string

+ TableName string

+ func (*TimeRangeSummaryRequest) Descriptor() ([]byte, []int)

+ func (*TimeRangeSummaryRequest) ProtoMessage()

+ func (x *TimeRangeSummaryRequest) GetColumnName() string

+ func (x *TimeRangeSummaryRequest) GetInstanceId() string

+ func (x *TimeRangeSummaryRequest) GetTableName() string

+ func (x *TimeRangeSummaryRequest) ProtoReflect() protoreflect.Message

+ func (x *TimeRangeSummaryRequest) Reset()

+ func (x *TimeRangeSummaryRequest) String() string

+ type TimeRangeSummary_Interval struct

+ Days int32

+ Micros int64

+ Months int32

+ func (*TimeRangeSummary_Interval) Descriptor() ([]byte, []int)

+ func (*TimeRangeSummary_Interval) ProtoMessage()

+ func (x *TimeRangeSummary_Interval) GetDays() int32

+ func (x *TimeRangeSummary_Interval) GetMicros() int64

+ func (x *TimeRangeSummary_Interval) GetMonths() int32

+ func (x *TimeRangeSummary_Interval) ProtoReflect() protoreflect.Message

+ func (x *TimeRangeSummary_Interval) Reset()

+ func (x *TimeRangeSummary_Interval) String() string

+ type TimeSeriesResponse struct

+ Error *string

+ Id *string

+ Results []*TimeSeriesValue

+ SampleSize int32

+ Spark *TimeSeriesResponse_TimeSeriesValues

+ TimeRange *TimeSeriesTimeRange

+ func (*TimeSeriesResponse) Descriptor() ([]byte, []int)

+ func (*TimeSeriesResponse) ProtoMessage()

+ func (x *TimeSeriesResponse) GetError() string

+ func (x *TimeSeriesResponse) GetId() string

+ func (x *TimeSeriesResponse) GetResults() []*TimeSeriesValue

+ func (x *TimeSeriesResponse) GetSampleSize() int32

+ func (x *TimeSeriesResponse) GetSpark() *TimeSeriesResponse_TimeSeriesValues

+ func (x *TimeSeriesResponse) GetTimeRange() *TimeSeriesTimeRange

+ func (x *TimeSeriesResponse) ProtoReflect() protoreflect.Message

+ func (x *TimeSeriesResponse) Reset()

+ func (x *TimeSeriesResponse) String() string

+ type TimeSeriesResponse_TimeSeriesValues struct

+ Values []*TimeSeriesValue

+ func (*TimeSeriesResponse_TimeSeriesValues) Descriptor() ([]byte, []int)

+ func (*TimeSeriesResponse_TimeSeriesValues) ProtoMessage()

+ func (x *TimeSeriesResponse_TimeSeriesValues) GetValues() []*TimeSeriesValue

+ func (x *TimeSeriesResponse_TimeSeriesValues) ProtoReflect() protoreflect.Message

+ func (x *TimeSeriesResponse_TimeSeriesValues) Reset()

+ func (x *TimeSeriesResponse_TimeSeriesValues) String() string

+ type TimeSeriesRollup struct

+ Rollup *TimeSeriesResponse

+ func (*TimeSeriesRollup) Descriptor() ([]byte, []int)

+ func (*TimeSeriesRollup) ProtoMessage()

+ func (x *TimeSeriesRollup) GetRollup() *TimeSeriesResponse

+ func (x *TimeSeriesRollup) ProtoReflect() protoreflect.Message

+ func (x *TimeSeriesRollup) Reset()

+ func (x *TimeSeriesRollup) String() string

+ type TimeSeriesTimeRange struct

+ End string

+ Interval TimeGrain

+ Name TimeRangeName

+ Start string

+ func (*TimeSeriesTimeRange) Descriptor() ([]byte, []int)

+ func (*TimeSeriesTimeRange) ProtoMessage()

+ func (x *TimeSeriesTimeRange) GetEnd() string

+ func (x *TimeSeriesTimeRange) GetInterval() TimeGrain

+ func (x *TimeSeriesTimeRange) GetName() TimeRangeName

+ func (x *TimeSeriesTimeRange) GetStart() string

+ func (x *TimeSeriesTimeRange) ProtoReflect() protoreflect.Message

+ func (x *TimeSeriesTimeRange) Reset()

+ func (x *TimeSeriesTimeRange) String() string

+ type TimeSeriesValue struct

+ Bin *float64

+ Records map[string]float64

+ Ts string

+ func (*TimeSeriesValue) Descriptor() ([]byte, []int)

+ func (*TimeSeriesValue) ProtoMessage()

+ func (x *TimeSeriesValue) GetBin() float64

+ func (x *TimeSeriesValue) GetRecords() map[string]float64

+ func (x *TimeSeriesValue) GetTs() string

+ func (x *TimeSeriesValue) ProtoReflect() protoreflect.Message

+ func (x *TimeSeriesValue) Reset()

+ func (x *TimeSeriesValue) String() string

type TopKResponse

+ Entries []*TopKResponse_TopKEntry

+ func (x *TopKResponse) GetEntries() []*TopKResponse_TopKEntry

+ type TopKResponse_TopKEntry struct

+ Count float64

+ Value *string

+ func (*TopKResponse_TopKEntry) Descriptor() ([]byte, []int)

+ func (*TopKResponse_TopKEntry) ProtoMessage()

+ func (x *TopKResponse_TopKEntry) GetCount() float64

+ func (x *TopKResponse_TopKEntry) GetValue() string

+ func (x *TopKResponse_TopKEntry) ProtoReflect() protoreflect.Message

+ func (x *TopKResponse_TopKEntry) Reset()

+ func (x *TopKResponse_TopKEntry) String() string

+ type TriggerSyncRequest struct

+ InstanceId string

+ func (*TriggerSyncRequest) Descriptor() ([]byte, []int)

+ func (*TriggerSyncRequest) ProtoMessage()

+ func (x *TriggerSyncRequest) GetInstanceId() string

+ func (x *TriggerSyncRequest) ProtoReflect() protoreflect.Message

+ func (x *TriggerSyncRequest) Reset()

+ func (x *TriggerSyncRequest) String() string

+ type TriggerSyncResponse struct

+ ObjectsAddedCount uint32

+ ObjectsCount uint32

+ ObjectsRemovedCount uint32

+ ObjectsUpdatedCount uint32

+ func (*TriggerSyncResponse) Descriptor() ([]byte, []int)

+ func (*TriggerSyncResponse) ProtoMessage()

+ func (x *TriggerSyncResponse) GetObjectsAddedCount() uint32

+ func (x *TriggerSyncResponse) GetObjectsCount() uint32

+ func (x *TriggerSyncResponse) GetObjectsRemovedCount() uint32

+ func (x *TriggerSyncResponse) GetObjectsUpdatedCount() uint32

+ func (x *TriggerSyncResponse) ProtoReflect() protoreflect.Message

+ func (x *TriggerSyncResponse) Reset()

+ func (x *TriggerSyncResponse) String() string

+ type Type struct

+ ArrayElementType *Type

+ Code Type_Code

+ MapType *MapType

+ Nullable bool

+ StructType *StructType

+ func (*Type) Descriptor() ([]byte, []int)

+ func (*Type) ProtoMessage()

+ func (x *Type) GetArrayElementType() *Type

+ func (x *Type) GetCode() Type_Code

+ func (x *Type) GetMapType() *MapType

+ func (x *Type) GetNullable() bool

+ func (x *Type) GetStructType() *StructType

+ func (x *Type) ProtoReflect() protoreflect.Message

+ func (x *Type) Reset()

+ func (x *Type) String() string

+ type Type_Code int32

+ const Type_CODE_ARRAY

+ const Type_CODE_BOOL

+ const Type_CODE_BYTES

+ const Type_CODE_DATE

+ const Type_CODE_DECIMAL

+ const Type_CODE_FLOAT32

+ const Type_CODE_FLOAT64

+ const Type_CODE_INT128

+ const Type_CODE_INT16

+ const Type_CODE_INT32

+ const Type_CODE_INT64

+ const Type_CODE_INT8

+ const Type_CODE_JSON

+ const Type_CODE_MAP

+ const Type_CODE_STRING

+ const Type_CODE_STRUCT

+ const Type_CODE_TIME

+ const Type_CODE_TIMESTAMP

+ const Type_CODE_UINT128

+ const Type_CODE_UINT16

+ const Type_CODE_UINT32

+ const Type_CODE_UINT64

+ const Type_CODE_UINT8

+ const Type_CODE_UNSPECIFIED

+ const Type_CODE_UUID

+ func (Type_Code) Descriptor() protoreflect.EnumDescriptor

+ func (Type_Code) EnumDescriptor() ([]byte, []int)

+ func (Type_Code) Type() protoreflect.EnumType

+ func (x Type_Code) Enum() *Type_Code

+ func (x Type_Code) Number() protoreflect.EnumNumber

+ func (x Type_Code) String() string

type UnimplementedRuntimeServiceServer

+ func (UnimplementedRuntimeServiceServer) DeleteFile(context.Context, *DeleteFileRequest) (*DeleteFileResponse, error)

+ func (UnimplementedRuntimeServiceServer) DeleteFileAndMigrate(context.Context, *DeleteFileAndMigrateRequest) (*DeleteFileAndMigrateResponse, error)

+ func (UnimplementedRuntimeServiceServer) EstimateRollupInterval(context.Context, *EstimateRollupIntervalRequest) (*EstimateRollupIntervalResponse, error)

+ func (UnimplementedRuntimeServiceServer) EstimateSmallestTimeGrain(context.Context, *EstimateSmallestTimeGrainRequest) (*EstimateSmallestTimeGrainResponse, error)

+ func (UnimplementedRuntimeServiceServer) GenerateTimeSeries(context.Context, *GenerateTimeSeriesRequest) (*TimeSeriesRollup, error)

+ func (UnimplementedRuntimeServiceServer) GetCardinalityOfColumn(context.Context, *CardinalityOfColumnRequest) (*CategoricalSummary, error)

+ func (UnimplementedRuntimeServiceServer) GetDescriptiveStatistics(context.Context, *DescriptiveStatisticsRequest) (*NumericSummary, error)

+ func (UnimplementedRuntimeServiceServer) GetFile(context.Context, *GetFileRequest) (*GetFileResponse, error)

+ func (UnimplementedRuntimeServiceServer) GetNullCount(context.Context, *NullCountRequest) (*NullCountResponse, error)

+ func (UnimplementedRuntimeServiceServer) GetNumericHistogram(context.Context, *NumericHistogramRequest) (*NumericSummary, error)

+ func (UnimplementedRuntimeServiceServer) GetRugHistogram(context.Context, *RugHistogramRequest) (*NumericSummary, error)

+ func (UnimplementedRuntimeServiceServer) GetTimeRangeSummary(context.Context, *TimeRangeSummaryRequest) (*TimeRangeSummary, error)

+ func (UnimplementedRuntimeServiceServer) ListFiles(context.Context, *ListFilesRequest) (*ListFilesResponse, error)

+ func (UnimplementedRuntimeServiceServer) ProfileColumns(context.Context, *ProfileColumnsRequest) (*ProfileColumnsResponse, error)

+ func (UnimplementedRuntimeServiceServer) PutFile(context.Context, *PutFileRequest) (*PutFileResponse, error)

+ func (UnimplementedRuntimeServiceServer) PutFileAndMigrate(context.Context, *PutFileAndMigrateRequest) (*PutFileAndMigrateResponse, error)

+ func (UnimplementedRuntimeServiceServer) RenameDatabaseObject(context.Context, *RenameDatabaseObjectRequest) (*RenameDatabaseObjectResponse, error)

+ func (UnimplementedRuntimeServiceServer) RenameFile(context.Context, *RenameFileRequest) (*RenameFileResponse, error)

+ func (UnimplementedRuntimeServiceServer) RenameFileAndMigrate(context.Context, *RenameFileAndMigrateRequest) (*RenameFileAndMigrateResponse, error)

+ func (UnimplementedRuntimeServiceServer) TableCardinality(context.Context, *CardinalityRequest) (*CardinalityResponse, error)

+ func (UnimplementedRuntimeServiceServer) TableRows(context.Context, *RowsRequest) (*RowsResponse, error)

+ func (UnimplementedRuntimeServiceServer) TriggerSync(context.Context, *TriggerSyncRequest) (*TriggerSyncResponse, error)

v0.14.1

Nov 9, 2022

v0.14.0

Nov 8, 2022

Changes in this version

type RuntimeServiceClient

+ GetTopK func(ctx context.Context, in *TopKRequest, opts ...grpc.CallOption) (*TopKResponse, error)

type RuntimeServiceServer

+ GetTopK func(context.Context, *TopKRequest) (*TopKResponse, error)

+ type TopKRequest struct

+ Agg *string

+ ColumnName string

+ InstanceId string

+ K *int32

+ TableName string

+ func (*TopKRequest) Descriptor() ([]byte, []int)

+ func (*TopKRequest) ProtoMessage()

+ func (x *TopKRequest) GetAgg() string

+ func (x *TopKRequest) GetColumnName() string

+ func (x *TopKRequest) GetInstanceId() string

+ func (x *TopKRequest) GetK() int32

+ func (x *TopKRequest) GetTableName() string

+ func (x *TopKRequest) ProtoReflect() protoreflect.Message

+ func (x *TopKRequest) Reset()

+ func (x *TopKRequest) String() string

+ type TopKResponse struct

+ Data []*structpb.Struct

+ Meta []*SchemaColumn

+ func (*TopKResponse) Descriptor() ([]byte, []int)

+ func (*TopKResponse) ProtoMessage()

+ func (x *TopKResponse) GetData() []*structpb.Struct

+ func (x *TopKResponse) GetMeta() []*SchemaColumn

+ func (x *TopKResponse) ProtoReflect() protoreflect.Message

+ func (x *TopKResponse) Reset()

+ func (x *TopKResponse) String() string

type UnimplementedRuntimeServiceServer

+ func (UnimplementedRuntimeServiceServer) GetTopK(context.Context, *TopKRequest) (*TopKResponse, error)

v0.13.0

Oct 28, 2022

Changes in this version

type CatalogObject

+ RefreshedOn *timestamppb.Timestamp

+ func (x *CatalogObject) GetRefreshedOn() *timestamppb.Timestamp

type Connector_Property

+ Hint string

+ Href string

+ func (x *Connector_Property) GetHint() string

+ func (x *Connector_Property) GetHref() string

type Connector_Property_Type

+ const Connector_Property_TYPE_INFORMATIONAL

type MigrateSingleRequest

+ RenameFrom string

+ func (x *MigrateSingleRequest) GetRenameFrom() string

type PutRepoObjectResponse

+ FilePath string

+ func (x *PutRepoObjectResponse) GetFilePath() string

v0.12.1

Oct 14, 2022

v0.12.0

Oct 14, 2022

Changes in this version

+ var Connector_Property_Type_name = map[int32]string

+ var Connector_Property_Type_value = map[string]int32

+ var File_runtime_proto protoreflect.FileDescriptor

+ var RuntimeService_ServiceDesc = grpc.ServiceDesc

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

+ func RegisterRuntimeServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client RuntimeServiceClient) error

+ func RegisterRuntimeServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

+ func RegisterRuntimeServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server RuntimeServiceServer) error

+ func RegisterRuntimeServiceServer(s grpc.ServiceRegistrar, srv RuntimeServiceServer)

+ type CatalogObject struct

+ Type isCatalogObject_Type

+ func (*CatalogObject) Descriptor() ([]byte, []int)

+ func (*CatalogObject) ProtoMessage()

+ func (m *CatalogObject) GetType() isCatalogObject_Type

+ func (x *CatalogObject) GetMetricsView() *MetricsView

+ func (x *CatalogObject) GetSource() *Source

+ func (x *CatalogObject) GetUnmanagedTable() *UnmanagedTable

+ func (x *CatalogObject) ProtoReflect() protoreflect.Message

+ func (x *CatalogObject) Reset()

+ func (x *CatalogObject) String() string

+ type CatalogObject_MetricsView struct

+ MetricsView *MetricsView

+ type CatalogObject_Source struct

+ Source *Source

+ type CatalogObject_UnmanagedTable struct

+ UnmanagedTable *UnmanagedTable

+ type Connector struct

+ Description string

+ DisplayName string

+ Name string

+ Properties []*Connector_Property

+ func (*Connector) Descriptor() ([]byte, []int)

+ func (*Connector) ProtoMessage()

+ func (x *Connector) GetDescription() string

+ func (x *Connector) GetDisplayName() string

+ func (x *Connector) GetName() string

+ func (x *Connector) GetProperties() []*Connector_Property

+ func (x *Connector) ProtoReflect() protoreflect.Message

+ func (x *Connector) Reset()

+ func (x *Connector) String() string

+ type Connector_Property struct

+ Description string

+ DisplayName string

+ Key string

+ Nullable bool

+ Placeholder string

+ Type Connector_Property_Type

+ func (*Connector_Property) Descriptor() ([]byte, []int)

+ func (*Connector_Property) ProtoMessage()

+ func (x *Connector_Property) GetDescription() string

+ func (x *Connector_Property) GetDisplayName() string

+ func (x *Connector_Property) GetKey() string

+ func (x *Connector_Property) GetNullable() bool

+ func (x *Connector_Property) GetPlaceholder() string

+ func (x *Connector_Property) GetType() Connector_Property_Type

+ func (x *Connector_Property) ProtoReflect() protoreflect.Message

+ func (x *Connector_Property) Reset()

+ func (x *Connector_Property) String() string

+ type Connector_Property_Type int32

+ const Connector_Property_TYPE_BOOLEAN

+ const Connector_Property_TYPE_NUMBER

+ const Connector_Property_TYPE_STRING

+ const Connector_Property_TYPE_UNSPECIFIED

+ func (Connector_Property_Type) Descriptor() protoreflect.EnumDescriptor

+ func (Connector_Property_Type) EnumDescriptor() ([]byte, []int)

+ func (Connector_Property_Type) Type() protoreflect.EnumType

+ func (x Connector_Property_Type) Enum() *Connector_Property_Type

+ func (x Connector_Property_Type) Number() protoreflect.EnumNumber

+ func (x Connector_Property_Type) String() string

+ type CreateInstanceRequest struct

+ Driver string

+ Dsn string

+ EmbedCatalog bool

+ Exposed bool

+ ObjectPrefix string

+ func (*CreateInstanceRequest) Descriptor() ([]byte, []int)

+ func (*CreateInstanceRequest) ProtoMessage()

+ func (x *CreateInstanceRequest) GetDriver() string

+ func (x *CreateInstanceRequest) GetDsn() string

+ func (x *CreateInstanceRequest) GetEmbedCatalog() bool

+ func (x *CreateInstanceRequest) GetExposed() bool

+ func (x *CreateInstanceRequest) GetObjectPrefix() string

+ func (x *CreateInstanceRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateInstanceRequest) Reset()

+ func (x *CreateInstanceRequest) String() string

+ type CreateInstanceResponse struct

+ Instance *Instance

+ InstanceId string

+ func (*CreateInstanceResponse) Descriptor() ([]byte, []int)

+ func (*CreateInstanceResponse) ProtoMessage()

+ func (x *CreateInstanceResponse) GetInstance() *Instance

+ func (x *CreateInstanceResponse) GetInstanceId() string

+ func (x *CreateInstanceResponse) ProtoReflect() protoreflect.Message

+ func (x *CreateInstanceResponse) Reset()

+ func (x *CreateInstanceResponse) String() string

+ type CreateRepoRequest struct

+ Driver string

+ Dsn string

+ func (*CreateRepoRequest) Descriptor() ([]byte, []int)

+ func (*CreateRepoRequest) ProtoMessage()

+ func (x *CreateRepoRequest) GetDriver() string

+ func (x *CreateRepoRequest) GetDsn() string

+ func (x *CreateRepoRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateRepoRequest) Reset()

+ func (x *CreateRepoRequest) String() string

+ type CreateRepoResponse struct

+ Repo *Repo

+ func (*CreateRepoResponse) Descriptor() ([]byte, []int)

+ func (*CreateRepoResponse) ProtoMessage()

+ func (x *CreateRepoResponse) GetRepo() *Repo

+ func (x *CreateRepoResponse) ProtoReflect() protoreflect.Message

+ func (x *CreateRepoResponse) Reset()

+ func (x *CreateRepoResponse) String() string

+ type DeleteInstanceRequest struct

+ InstanceId string

+ func (*DeleteInstanceRequest) Descriptor() ([]byte, []int)

+ func (*DeleteInstanceRequest) ProtoMessage()

+ func (x *DeleteInstanceRequest) GetInstanceId() string

+ func (x *DeleteInstanceRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteInstanceRequest) Reset()

+ func (x *DeleteInstanceRequest) String() string

+ type DeleteInstanceResponse struct

+ func (*DeleteInstanceResponse) Descriptor() ([]byte, []int)

+ func (*DeleteInstanceResponse) ProtoMessage()

+ func (x *DeleteInstanceResponse) ProtoReflect() protoreflect.Message

+ func (x *DeleteInstanceResponse) Reset()

+ func (x *DeleteInstanceResponse) String() string

+ type DeleteRepoRequest struct

+ RepoId string

+ func (*DeleteRepoRequest) Descriptor() ([]byte, []int)

+ func (*DeleteRepoRequest) ProtoMessage()

+ func (x *DeleteRepoRequest) GetRepoId() string

+ func (x *DeleteRepoRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteRepoRequest) Reset()

+ func (x *DeleteRepoRequest) String() string

+ type DeleteRepoResponse struct

+ func (*DeleteRepoResponse) Descriptor() ([]byte, []int)

+ func (*DeleteRepoResponse) ProtoMessage()

+ func (x *DeleteRepoResponse) ProtoReflect() protoreflect.Message

+ func (x *DeleteRepoResponse) Reset()

+ func (x *DeleteRepoResponse) String() string

+ type GetCatalogObjectRequest struct

+ InstanceId string

+ Name string

+ func (*GetCatalogObjectRequest) Descriptor() ([]byte, []int)

+ func (*GetCatalogObjectRequest) ProtoMessage()

+ func (x *GetCatalogObjectRequest) GetInstanceId() string

+ func (x *GetCatalogObjectRequest) GetName() string

+ func (x *GetCatalogObjectRequest) ProtoReflect() protoreflect.Message

+ func (x *GetCatalogObjectRequest) Reset()

+ func (x *GetCatalogObjectRequest) String() string

+ type GetCatalogObjectResponse struct

+ Object *CatalogObject

+ func (*GetCatalogObjectResponse) Descriptor() ([]byte, []int)

+ func (*GetCatalogObjectResponse) ProtoMessage()

+ func (x *GetCatalogObjectResponse) GetObject() *CatalogObject

+ func (x *GetCatalogObjectResponse) ProtoReflect() protoreflect.Message

+ func (x *GetCatalogObjectResponse) Reset()

+ func (x *GetCatalogObjectResponse) String() string

+ type GetInstanceRequest struct

+ InstanceId string

+ func (*GetInstanceRequest) Descriptor() ([]byte, []int)

+ func (*GetInstanceRequest) ProtoMessage()

+ func (x *GetInstanceRequest) GetInstanceId() string

+ func (x *GetInstanceRequest) ProtoReflect() protoreflect.Message

+ func (x *GetInstanceRequest) Reset()

+ func (x *GetInstanceRequest) String() string

+ type GetInstanceResponse struct

+ Instance *Instance

+ func (*GetInstanceResponse) Descriptor() ([]byte, []int)

+ func (*GetInstanceResponse) ProtoMessage()

+ func (x *GetInstanceResponse) GetInstance() *Instance

+ func (x *GetInstanceResponse) ProtoReflect() protoreflect.Message

+ func (x *GetInstanceResponse) Reset()

+ func (x *GetInstanceResponse) String() string

+ type GetRepoObjectRequest struct

+ Path string

+ RepoId string

+ func (*GetRepoObjectRequest) Descriptor() ([]byte, []int)

+ func (*GetRepoObjectRequest) ProtoMessage()

+ func (x *GetRepoObjectRequest) GetPath() string

+ func (x *GetRepoObjectRequest) GetRepoId() string

+ func (x *GetRepoObjectRequest) ProtoReflect() protoreflect.Message

+ func (x *GetRepoObjectRequest) Reset()

+ func (x *GetRepoObjectRequest) String() string

+ type GetRepoObjectResponse struct

+ Blob string

+ func (*GetRepoObjectResponse) Descriptor() ([]byte, []int)

+ func (*GetRepoObjectResponse) ProtoMessage()

+ func (x *GetRepoObjectResponse) GetBlob() string

+ func (x *GetRepoObjectResponse) ProtoReflect() protoreflect.Message

+ func (x *GetRepoObjectResponse) Reset()

+ func (x *GetRepoObjectResponse) String() string

+ type GetRepoRequest struct

+ RepoId string

+ func (*GetRepoRequest) Descriptor() ([]byte, []int)

+ func (*GetRepoRequest) ProtoMessage()

+ func (x *GetRepoRequest) GetRepoId() string

+ func (x *GetRepoRequest) ProtoReflect() protoreflect.Message

+ func (x *GetRepoRequest) Reset()

+ func (x *GetRepoRequest) String() string

+ type GetRepoResponse struct

+ Repo *Repo

+ func (*GetRepoResponse) Descriptor() ([]byte, []int)

+ func (*GetRepoResponse) ProtoMessage()

+ func (x *GetRepoResponse) GetRepo() *Repo

+ func (x *GetRepoResponse) ProtoReflect() protoreflect.Message

+ func (x *GetRepoResponse) Reset()

+ func (x *GetRepoResponse) String() string

+ type Instance struct

+ Driver string

+ Dsn string

+ EmbedCatalog bool

+ Exposed bool

+ InstanceId string

+ ObjectPrefix string

+ func (*Instance) Descriptor() ([]byte, []int)

+ func (*Instance) ProtoMessage()

+ func (x *Instance) GetDriver() string

+ func (x *Instance) GetDsn() string

+ func (x *Instance) GetEmbedCatalog() bool

+ func (x *Instance) GetExposed() bool

+ func (x *Instance) GetInstanceId() string

+ func (x *Instance) GetObjectPrefix() string

+ func (x *Instance) ProtoReflect() protoreflect.Message

+ func (x *Instance) Reset()

+ func (x *Instance) String() string

+ type ListCatalogObjectsRequest struct

+ InstanceId string

+ func (*ListCatalogObjectsRequest) Descriptor() ([]byte, []int)

+ func (*ListCatalogObjectsRequest) ProtoMessage()

+ func (x *ListCatalogObjectsRequest) GetInstanceId() string

+ func (x *ListCatalogObjectsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListCatalogObjectsRequest) Reset()

+ func (x *ListCatalogObjectsRequest) String() string

+ type ListCatalogObjectsResponse struct

+ Objects []*CatalogObject

+ func (*ListCatalogObjectsResponse) Descriptor() ([]byte, []int)

+ func (*ListCatalogObjectsResponse) ProtoMessage()

+ func (x *ListCatalogObjectsResponse) GetObjects() []*CatalogObject

+ func (x *ListCatalogObjectsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListCatalogObjectsResponse) Reset()

+ func (x *ListCatalogObjectsResponse) String() string

+ type ListConnectorsRequest struct

+ func (*ListConnectorsRequest) Descriptor() ([]byte, []int)

+ func (*ListConnectorsRequest) ProtoMessage()

+ func (x *ListConnectorsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListConnectorsRequest) Reset()

+ func (x *ListConnectorsRequest) String() string

+ type ListConnectorsResponse struct

+ Connectors []*Connector

+ func (*ListConnectorsResponse) Descriptor() ([]byte, []int)

+ func (*ListConnectorsResponse) ProtoMessage()

+ func (x *ListConnectorsResponse) GetConnectors() []*Connector

+ func (x *ListConnectorsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListConnectorsResponse) Reset()

+ func (x *ListConnectorsResponse) String() string

+ type ListInstancesRequest struct

+ PageSize int32

+ PageToken string

+ func (*ListInstancesRequest) Descriptor() ([]byte, []int)

+ func (*ListInstancesRequest) ProtoMessage()

+ func (x *ListInstancesRequest) GetPageSize() int32

+ func (x *ListInstancesRequest) GetPageToken() string

+ func (x *ListInstancesRequest) ProtoReflect() protoreflect.Message

+ func (x *ListInstancesRequest) Reset()

+ func (x *ListInstancesRequest) String() string

+ type ListInstancesResponse struct

+ Instances []*Instance

+ NextPageToken string

+ func (*ListInstancesResponse) Descriptor() ([]byte, []int)

+ func (*ListInstancesResponse) ProtoMessage()

+ func (x *ListInstancesResponse) GetInstances() []*Instance

+ func (x *ListInstancesResponse) GetNextPageToken() string

+ func (x *ListInstancesResponse) ProtoReflect() protoreflect.Message

+ func (x *ListInstancesResponse) Reset()

+ func (x *ListInstancesResponse) String() string

+ type ListRepoObjectsRequest struct

+ RepoId string

+ func (*ListRepoObjectsRequest) Descriptor() ([]byte, []int)

+ func (*ListRepoObjectsRequest) ProtoMessage()

+ func (x *ListRepoObjectsRequest) GetRepoId() string

+ func (x *ListRepoObjectsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListRepoObjectsRequest) Reset()

+ func (x *ListRepoObjectsRequest) String() string

+ type ListRepoObjectsResponse struct

+ Paths []string

+ func (*ListRepoObjectsResponse) Descriptor() ([]byte, []int)

+ func (*ListRepoObjectsResponse) ProtoMessage()

+ func (x *ListRepoObjectsResponse) GetPaths() []string

+ func (x *ListRepoObjectsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListRepoObjectsResponse) Reset()

+ func (x *ListRepoObjectsResponse) String() string

+ type ListReposRequest struct

+ PageSize int32

+ PageToken string

+ func (*ListReposRequest) Descriptor() ([]byte, []int)

+ func (*ListReposRequest) ProtoMessage()

+ func (x *ListReposRequest) GetPageSize() int32

+ func (x *ListReposRequest) GetPageToken() string

+ func (x *ListReposRequest) ProtoReflect() protoreflect.Message

+ func (x *ListReposRequest) Reset()

+ func (x *ListReposRequest) String() string

+ type ListReposResponse struct

+ NextPageToken string

+ Repos []*Repo

+ func (*ListReposResponse) Descriptor() ([]byte, []int)

+ func (*ListReposResponse) ProtoMessage()

+ func (x *ListReposResponse) GetNextPageToken() string

+ func (x *ListReposResponse) GetRepos() []*Repo

+ func (x *ListReposResponse) ProtoReflect() protoreflect.Message

+ func (x *ListReposResponse) Reset()

+ func (x *ListReposResponse) String() string

+ type MetricsView struct

+ Dimensions []*MetricsView_Dimension

+ FromObject string

+ Measures []*MetricsView_Measure

+ Name string

+ Sql string

+ func (*MetricsView) Descriptor() ([]byte, []int)

+ func (*MetricsView) ProtoMessage()

+ func (x *MetricsView) GetDimensions() []*MetricsView_Dimension

+ func (x *MetricsView) GetFromObject() string

+ func (x *MetricsView) GetMeasures() []*MetricsView_Measure

+ func (x *MetricsView) GetName() string

+ func (x *MetricsView) GetSql() string

+ func (x *MetricsView) ProtoReflect() protoreflect.Message

+ func (x *MetricsView) Reset()

+ func (x *MetricsView) String() string

+ type MetricsViewFilter struct

+ Exclude []*MetricsViewFilter_Cond

+ Include []*MetricsViewFilter_Cond

+ Match []string

+ func (*MetricsViewFilter) Descriptor() ([]byte, []int)

+ func (*MetricsViewFilter) ProtoMessage()

+ func (x *MetricsViewFilter) GetExclude() []*MetricsViewFilter_Cond

+ func (x *MetricsViewFilter) GetInclude() []*MetricsViewFilter_Cond

+ func (x *MetricsViewFilter) GetMatch() []string

+ func (x *MetricsViewFilter) ProtoReflect() protoreflect.Message

+ func (x *MetricsViewFilter) Reset()

+ func (x *MetricsViewFilter) String() string

+ type MetricsViewFilter_Cond struct

+ In []*structpb.Value

+ Like []*structpb.Value

+ Name string

+ func (*MetricsViewFilter_Cond) Descriptor() ([]byte, []int)

+ func (*MetricsViewFilter_Cond) ProtoMessage()

+ func (x *MetricsViewFilter_Cond) GetIn() []*structpb.Value

+ func (x *MetricsViewFilter_Cond) GetLike() []*structpb.Value

+ func (x *MetricsViewFilter_Cond) GetName() string

+ func (x *MetricsViewFilter_Cond) ProtoReflect() protoreflect.Message

+ func (x *MetricsViewFilter_Cond) Reset()

+ func (x *MetricsViewFilter_Cond) String() string

+ type MetricsViewMetaRequest struct

+ InstanceId string

+ MetricsViewName string

+ func (*MetricsViewMetaRequest) Descriptor() ([]byte, []int)

+ func (*MetricsViewMetaRequest) ProtoMessage()

+ func (x *MetricsViewMetaRequest) GetInstanceId() string

+ func (x *MetricsViewMetaRequest) GetMetricsViewName() string

+ func (x *MetricsViewMetaRequest) ProtoReflect() protoreflect.Message

+ func (x *MetricsViewMetaRequest) Reset()

+ func (x *MetricsViewMetaRequest) String() string

+ type MetricsViewMetaResponse struct

+ Dimensions []*MetricsView_Dimension

+ FromObject string

+ Measures []*MetricsView_Measure

+ MetricsViewName string

+ func (*MetricsViewMetaResponse) Descriptor() ([]byte, []int)

+ func (*MetricsViewMetaResponse) ProtoMessage()

+ func (x *MetricsViewMetaResponse) GetDimensions() []*MetricsView_Dimension

+ func (x *MetricsViewMetaResponse) GetFromObject() string

+ func (x *MetricsViewMetaResponse) GetMeasures() []*MetricsView_Measure

+ func (x *MetricsViewMetaResponse) GetMetricsViewName() string

+ func (x *MetricsViewMetaResponse) ProtoReflect() protoreflect.Message

+ func (x *MetricsViewMetaResponse) Reset()

+ func (x *MetricsViewMetaResponse) String() string

+ type MetricsViewSort struct

+ Ascending bool

+ Name string

+ func (*MetricsViewSort) Descriptor() ([]byte, []int)

+ func (*MetricsViewSort) ProtoMessage()

+ func (x *MetricsViewSort) GetAscending() bool

+ func (x *MetricsViewSort) GetName() string

+ func (x *MetricsViewSort) ProtoReflect() protoreflect.Message

+ func (x *MetricsViewSort) Reset()

+ func (x *MetricsViewSort) String() string

+ type MetricsViewTimeSeriesRequest struct

+ Filter *MetricsViewFilter

+ InstanceId string

+ MeasureNames []string

+ MetricsViewName string

+ TimeEnd int64

+ TimeGranularity string

+ TimeStart int64

+ func (*MetricsViewTimeSeriesRequest) Descriptor() ([]byte, []int)

+ func (*MetricsViewTimeSeriesRequest) ProtoMessage()

+ func (x *MetricsViewTimeSeriesRequest) GetFilter() *MetricsViewFilter

+ func (x *MetricsViewTimeSeriesRequest) GetInstanceId() string

+ func (x *MetricsViewTimeSeriesRequest) GetMeasureNames() []string

+ func (x *MetricsViewTimeSeriesRequest) GetMetricsViewName() string

+ func (x *MetricsViewTimeSeriesRequest) GetTimeEnd() int64

+ func (x *MetricsViewTimeSeriesRequest) GetTimeGranularity() string

+ func (x *MetricsViewTimeSeriesRequest) GetTimeStart() int64

+ func (x *MetricsViewTimeSeriesRequest) ProtoReflect() protoreflect.Message

+ func (x *MetricsViewTimeSeriesRequest) Reset()

+ func (x *MetricsViewTimeSeriesRequest) String() string

+ type MetricsViewTimeSeriesResponse struct

+ Data []*structpb.Struct

+ Meta []*SchemaColumn

+ func (*MetricsViewTimeSeriesResponse) Descriptor() ([]byte, []int)

+ func (*MetricsViewTimeSeriesResponse) ProtoMessage()

+ func (x *MetricsViewTimeSeriesResponse) GetData() []*structpb.Struct

+ func (x *MetricsViewTimeSeriesResponse) GetMeta() []*SchemaColumn

+ func (x *MetricsViewTimeSeriesResponse) ProtoReflect() protoreflect.Message

+ func (x *MetricsViewTimeSeriesResponse) Reset()

+ func (x *MetricsViewTimeSeriesResponse) String() string

+ type MetricsViewToplistRequest struct

+ DimensionName string

+ Filter *MetricsViewFilter

+ InstanceId string

+ Limit int64

+ MeasureNames []string

+ MetricsViewName string

+ Offset int64

+ Sort []*MetricsViewSort

+ TimeEnd int64

+ TimeStart int64

+ func (*MetricsViewToplistRequest) Descriptor() ([]byte, []int)

+ func (*MetricsViewToplistRequest) ProtoMessage()

+ func (x *MetricsViewToplistRequest) GetDimensionName() string

+ func (x *MetricsViewToplistRequest) GetFilter() *MetricsViewFilter

+ func (x *MetricsViewToplistRequest) GetInstanceId() string

+ func (x *MetricsViewToplistRequest) GetLimit() int64

+ func (x *MetricsViewToplistRequest) GetMeasureNames() []string

+ func (x *MetricsViewToplistRequest) GetMetricsViewName() string

+ func (x *MetricsViewToplistRequest) GetOffset() int64

+ func (x *MetricsViewToplistRequest) GetSort() []*MetricsViewSort

+ func (x *MetricsViewToplistRequest) GetTimeEnd() int64

+ func (x *MetricsViewToplistRequest) GetTimeStart() int64

+ func (x *MetricsViewToplistRequest) ProtoReflect() protoreflect.Message

+ func (x *MetricsViewToplistRequest) Reset()

+ func (x *MetricsViewToplistRequest) String() string

+ type MetricsViewToplistResponse struct

+ Data []*structpb.Struct

+ Meta []*SchemaColumn

+ func (*MetricsViewToplistResponse) Descriptor() ([]byte, []int)

+ func (*MetricsViewToplistResponse) ProtoMessage()

+ func (x *MetricsViewToplistResponse) GetData() []*structpb.Struct

+ func (x *MetricsViewToplistResponse) GetMeta() []*SchemaColumn

+ func (x *MetricsViewToplistResponse) ProtoReflect() protoreflect.Message

+ func (x *MetricsViewToplistResponse) Reset()

+ func (x *MetricsViewToplistResponse) String() string

+ type MetricsViewTotalsRequest struct

+ Filter *MetricsViewFilter

+ InstanceId string

+ MeasureNames []string

+ MetricsViewName string

+ TimeEnd int64

+ TimeStart int64

+ func (*MetricsViewTotalsRequest) Descriptor() ([]byte, []int)

+ func (*MetricsViewTotalsRequest) ProtoMessage()

+ func (x *MetricsViewTotalsRequest) GetFilter() *MetricsViewFilter

+ func (x *MetricsViewTotalsRequest) GetInstanceId() string

+ func (x *MetricsViewTotalsRequest) GetMeasureNames() []string

+ func (x *MetricsViewTotalsRequest) GetMetricsViewName() string

+ func (x *MetricsViewTotalsRequest) GetTimeEnd() int64

+ func (x *MetricsViewTotalsRequest) GetTimeStart() int64

+ func (x *MetricsViewTotalsRequest) ProtoReflect() protoreflect.Message

+ func (x *MetricsViewTotalsRequest) Reset()

+ func (x *MetricsViewTotalsRequest) String() string

+ type MetricsViewTotalsResponse struct

+ Data *structpb.Struct

+ Meta []*SchemaColumn

+ func (*MetricsViewTotalsResponse) Descriptor() ([]byte, []int)

+ func (*MetricsViewTotalsResponse) ProtoMessage()

+ func (x *MetricsViewTotalsResponse) GetData() *structpb.Struct

+ func (x *MetricsViewTotalsResponse) GetMeta() []*SchemaColumn

+ func (x *MetricsViewTotalsResponse) ProtoReflect() protoreflect.Message

+ func (x *MetricsViewTotalsResponse) Reset()

+ func (x *MetricsViewTotalsResponse) String() string

+ type MetricsView_Dimension struct

+ Description string

+ Name string

+ PrimaryTime bool

+ Type string

+ func (*MetricsView_Dimension) Descriptor() ([]byte, []int)

+ func (*MetricsView_Dimension) ProtoMessage()

+ func (x *MetricsView_Dimension) GetDescription() string

+ func (x *MetricsView_Dimension) GetName() string

+ func (x *MetricsView_Dimension) GetPrimaryTime() bool

+ func (x *MetricsView_Dimension) GetType() string

+ func (x *MetricsView_Dimension) ProtoReflect() protoreflect.Message

+ func (x *MetricsView_Dimension) Reset()

+ func (x *MetricsView_Dimension) String() string

+ type MetricsView_Measure struct

+ Description string

+ Name string

+ Type string

+ func (*MetricsView_Measure) Descriptor() ([]byte, []int)

+ func (*MetricsView_Measure) ProtoMessage()

+ func (x *MetricsView_Measure) GetDescription() string

+ func (x *MetricsView_Measure) GetName() string

+ func (x *MetricsView_Measure) GetType() string

+ func (x *MetricsView_Measure) ProtoReflect() protoreflect.Message

+ func (x *MetricsView_Measure) Reset()

+ func (x *MetricsView_Measure) String() string

+ type MigrateDeleteRequest struct

+ InstanceId string

+ Name string

+ func (*MigrateDeleteRequest) Descriptor() ([]byte, []int)

+ func (*MigrateDeleteRequest) ProtoMessage()

+ func (x *MigrateDeleteRequest) GetInstanceId() string

+ func (x *MigrateDeleteRequest) GetName() string

+ func (x *MigrateDeleteRequest) ProtoReflect() protoreflect.Message

+ func (x *MigrateDeleteRequest) Reset()

+ func (x *MigrateDeleteRequest) String() string

+ type MigrateDeleteResponse struct

+ func (*MigrateDeleteResponse) Descriptor() ([]byte, []int)

+ func (*MigrateDeleteResponse) ProtoMessage()

+ func (x *MigrateDeleteResponse) ProtoReflect() protoreflect.Message

+ func (x *MigrateDeleteResponse) Reset()

+ func (x *MigrateDeleteResponse) String() string

+ type MigrateRequest struct

+ Blobs []string

+ DropDeleted bool

+ DryRun bool

+ InstanceId string

+ func (*MigrateRequest) Descriptor() ([]byte, []int)

+ func (*MigrateRequest) ProtoMessage()

+ func (x *MigrateRequest) GetBlobs() []string

+ func (x *MigrateRequest) GetDropDeleted() bool

+ func (x *MigrateRequest) GetDryRun() bool

+ func (x *MigrateRequest) GetInstanceId() string

+ func (x *MigrateRequest) ProtoReflect() protoreflect.Message

+ func (x *MigrateRequest) Reset()

+ func (x *MigrateRequest) String() string

+ type MigrateResponse struct

+ func (*MigrateResponse) Descriptor() ([]byte, []int)

+ func (*MigrateResponse) ProtoMessage()

+ func (x *MigrateResponse) ProtoReflect() protoreflect.Message

+ func (x *MigrateResponse) Reset()

+ func (x *MigrateResponse) String() string

+ type MigrateSingleRequest struct

+ CreateOrReplace bool

+ DryRun bool

+ InstanceId string

+ Sql string

+ func (*MigrateSingleRequest) Descriptor() ([]byte, []int)

+ func (*MigrateSingleRequest) ProtoMessage()

+ func (x *MigrateSingleRequest) GetCreateOrReplace() bool

+ func (x *MigrateSingleRequest) GetDryRun() bool

+ func (x *MigrateSingleRequest) GetInstanceId() string

+ func (x *MigrateSingleRequest) GetSql() string

+ func (x *MigrateSingleRequest) ProtoReflect() protoreflect.Message

+ func (x *MigrateSingleRequest) Reset()

+ func (x *MigrateSingleRequest) String() string

+ type MigrateSingleResponse struct

+ func (*MigrateSingleResponse) Descriptor() ([]byte, []int)

+ func (*MigrateSingleResponse) ProtoMessage()

+ func (x *MigrateSingleResponse) ProtoReflect() protoreflect.Message

+ func (x *MigrateSingleResponse) Reset()

+ func (x *MigrateSingleResponse) String() string

+ type PingRequest struct

+ func (*PingRequest) Descriptor() ([]byte, []int)

+ func (*PingRequest) ProtoMessage()

+ func (x *PingRequest) ProtoReflect() protoreflect.Message

+ func (x *PingRequest) Reset()

+ func (x *PingRequest) String() string

+ type PingResponse struct

+ Time *timestamppb.Timestamp

+ Version string

+ func (*PingResponse) Descriptor() ([]byte, []int)

+ func (*PingResponse) ProtoMessage()

+ func (x *PingResponse) GetTime() *timestamppb.Timestamp

+ func (x *PingResponse) GetVersion() string

+ func (x *PingResponse) ProtoReflect() protoreflect.Message

+ func (x *PingResponse) Reset()

+ func (x *PingResponse) String() string

+ type PutRepoObjectRequest struct

+ Blob string

+ Delete bool

+ Path string

+ RepoId string

+ func (*PutRepoObjectRequest) Descriptor() ([]byte, []int)

+ func (*PutRepoObjectRequest) ProtoMessage()

+ func (x *PutRepoObjectRequest) GetBlob() string

+ func (x *PutRepoObjectRequest) GetDelete() bool

+ func (x *PutRepoObjectRequest) GetPath() string

+ func (x *PutRepoObjectRequest) GetRepoId() string

+ func (x *PutRepoObjectRequest) ProtoReflect() protoreflect.Message

+ func (x *PutRepoObjectRequest) Reset()

+ func (x *PutRepoObjectRequest) String() string

+ type PutRepoObjectResponse struct

+ func (*PutRepoObjectResponse) Descriptor() ([]byte, []int)

+ func (*PutRepoObjectResponse) ProtoMessage()

+ func (x *PutRepoObjectResponse) ProtoReflect() protoreflect.Message

+ func (x *PutRepoObjectResponse) Reset()

+ func (x *PutRepoObjectResponse) String() string

+ type QueryDirectRequest struct

+ Args []*structpb.Value

+ DryRun bool

+ InstanceId string

+ Priority int64

+ Sql string

+ func (*QueryDirectRequest) Descriptor() ([]byte, []int)

+ func (*QueryDirectRequest) ProtoMessage()

+ func (x *QueryDirectRequest) GetArgs() []*structpb.Value

+ func (x *QueryDirectRequest) GetDryRun() bool

+ func (x *QueryDirectRequest) GetInstanceId() string

+ func (x *QueryDirectRequest) GetPriority() int64

+ func (x *QueryDirectRequest) GetSql() string

+ func (x *QueryDirectRequest) ProtoReflect() protoreflect.Message

+ func (x *QueryDirectRequest) Reset()

+ func (x *QueryDirectRequest) String() string

+ type QueryDirectResponse struct

+ Data []*structpb.Struct

+ Meta []*SchemaColumn

+ func (*QueryDirectResponse) Descriptor() ([]byte, []int)

+ func (*QueryDirectResponse) ProtoMessage()

+ func (x *QueryDirectResponse) GetData() []*structpb.Struct

+ func (x *QueryDirectResponse) GetMeta() []*SchemaColumn

+ func (x *QueryDirectResponse) ProtoReflect() protoreflect.Message

+ func (x *QueryDirectResponse) Reset()

+ func (x *QueryDirectResponse) String() string

+ type QueryRequest struct

+ Args []*structpb.Value

+ DryRun bool

+ InstanceId string

+ Priority int64

+ Sql string

+ func (*QueryRequest) Descriptor() ([]byte, []int)

+ func (*QueryRequest) ProtoMessage()

+ func (x *QueryRequest) GetArgs() []*structpb.Value

+ func (x *QueryRequest) GetDryRun() bool

+ func (x *QueryRequest) GetInstanceId() string

+ func (x *QueryRequest) GetPriority() int64

+ func (x *QueryRequest) GetSql() string

+ func (x *QueryRequest) ProtoReflect() protoreflect.Message

+ func (x *QueryRequest) Reset()

+ func (x *QueryRequest) String() string

+ type QueryResponse struct

+ Data []*structpb.Struct

+ Meta []*SchemaColumn

+ func (*QueryResponse) Descriptor() ([]byte, []int)

+ func (*QueryResponse) ProtoMessage()

+ func (x *QueryResponse) GetData() []*structpb.Struct

+ func (x *QueryResponse) GetMeta() []*SchemaColumn

+ func (x *QueryResponse) ProtoReflect() protoreflect.Message

+ func (x *QueryResponse) Reset()

+ func (x *QueryResponse) String() string

+ type Repo struct

+ Driver string

+ Dsn string

+ RepoId string

+ func (*Repo) Descriptor() ([]byte, []int)

+ func (*Repo) ProtoMessage()

+ func (x *Repo) GetDriver() string

+ func (x *Repo) GetDsn() string

+ func (x *Repo) GetRepoId() string

+ func (x *Repo) ProtoReflect() protoreflect.Message

+ func (x *Repo) Reset()

+ func (x *Repo) String() string

+ type RuntimeServiceClient interface

+ CreateInstance func(ctx context.Context, in *CreateInstanceRequest, opts ...grpc.CallOption) (*CreateInstanceResponse, error)

+ CreateRepo func(ctx context.Context, in *CreateRepoRequest, opts ...grpc.CallOption) (*CreateRepoResponse, error)

+ DeleteInstance func(ctx context.Context, in *DeleteInstanceRequest, opts ...grpc.CallOption) (*DeleteInstanceResponse, error)

+ DeleteRepo func(ctx context.Context, in *DeleteRepoRequest, opts ...grpc.CallOption) (*DeleteRepoResponse, error)

+ GetCatalogObject func(ctx context.Context, in *GetCatalogObjectRequest, opts ...grpc.CallOption) (*GetCatalogObjectResponse, error)

+ GetInstance func(ctx context.Context, in *GetInstanceRequest, opts ...grpc.CallOption) (*GetInstanceResponse, error)

+ GetRepo func(ctx context.Context, in *GetRepoRequest, opts ...grpc.CallOption) (*GetRepoResponse, error)

+ GetRepoObject func(ctx context.Context, in *GetRepoObjectRequest, opts ...grpc.CallOption) (*GetRepoObjectResponse, error)

+ ListCatalogObjects func(ctx context.Context, in *ListCatalogObjectsRequest, opts ...grpc.CallOption) (*ListCatalogObjectsResponse, error)

+ ListConnectors func(ctx context.Context, in *ListConnectorsRequest, opts ...grpc.CallOption) (*ListConnectorsResponse, error)

+ ListInstances func(ctx context.Context, in *ListInstancesRequest, opts ...grpc.CallOption) (*ListInstancesResponse, error)

+ ListRepoObjects func(ctx context.Context, in *ListRepoObjectsRequest, opts ...grpc.CallOption) (*ListRepoObjectsResponse, error)

+ ListRepos func(ctx context.Context, in *ListReposRequest, opts ...grpc.CallOption) (*ListReposResponse, error)

+ MetricsViewMeta func(ctx context.Context, in *MetricsViewMetaRequest, opts ...grpc.CallOption) (*MetricsViewMetaResponse, error)

+ MetricsViewTimeSeries func(ctx context.Context, in *MetricsViewTimeSeriesRequest, opts ...grpc.CallOption) (*MetricsViewTimeSeriesResponse, error)

+ MetricsViewToplist func(ctx context.Context, in *MetricsViewToplistRequest, opts ...grpc.CallOption) (*MetricsViewToplistResponse, error)

+ MetricsViewTotals func(ctx context.Context, in *MetricsViewTotalsRequest, opts ...grpc.CallOption) (*MetricsViewTotalsResponse, error)

+ Migrate func(ctx context.Context, in *MigrateRequest, opts ...grpc.CallOption) (*MigrateResponse, error)

+ MigrateDelete func(ctx context.Context, in *MigrateDeleteRequest, opts ...grpc.CallOption) (*MigrateDeleteResponse, error)

+ MigrateSingle func(ctx context.Context, in *MigrateSingleRequest, opts ...grpc.CallOption) (*MigrateSingleResponse, error)

+ Ping func(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)

+ PutRepoObject func(ctx context.Context, in *PutRepoObjectRequest, opts ...grpc.CallOption) (*PutRepoObjectResponse, error)

+ Query func(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error)

+ QueryDirect func(ctx context.Context, in *QueryDirectRequest, opts ...grpc.CallOption) (*QueryDirectResponse, error)

+ TriggerRefresh func(ctx context.Context, in *TriggerRefreshRequest, opts ...grpc.CallOption) (*TriggerRefreshResponse, error)

+ func NewRuntimeServiceClient(cc grpc.ClientConnInterface) RuntimeServiceClient

+ type RuntimeServiceServer interface

+ CreateInstance func(context.Context, *CreateInstanceRequest) (*CreateInstanceResponse, error)

+ CreateRepo func(context.Context, *CreateRepoRequest) (*CreateRepoResponse, error)

+ DeleteInstance func(context.Context, *DeleteInstanceRequest) (*DeleteInstanceResponse, error)

+ DeleteRepo func(context.Context, *DeleteRepoRequest) (*DeleteRepoResponse, error)

+ GetCatalogObject func(context.Context, *GetCatalogObjectRequest) (*GetCatalogObjectResponse, error)

+ GetInstance func(context.Context, *GetInstanceRequest) (*GetInstanceResponse, error)

+ GetRepo func(context.Context, *GetRepoRequest) (*GetRepoResponse, error)

+ GetRepoObject func(context.Context, *GetRepoObjectRequest) (*GetRepoObjectResponse, error)

+ ListCatalogObjects func(context.Context, *ListCatalogObjectsRequest) (*ListCatalogObjectsResponse, error)

+ ListConnectors func(context.Context, *ListConnectorsRequest) (*ListConnectorsResponse, error)

+ ListInstances func(context.Context, *ListInstancesRequest) (*ListInstancesResponse, error)

+ ListRepoObjects func(context.Context, *ListRepoObjectsRequest) (*ListRepoObjectsResponse, error)

+ ListRepos func(context.Context, *ListReposRequest) (*ListReposResponse, error)

+ MetricsViewMeta func(context.Context, *MetricsViewMetaRequest) (*MetricsViewMetaResponse, error)

+ MetricsViewTimeSeries func(context.Context, *MetricsViewTimeSeriesRequest) (*MetricsViewTimeSeriesResponse, error)

+ MetricsViewToplist func(context.Context, *MetricsViewToplistRequest) (*MetricsViewToplistResponse, error)

+ MetricsViewTotals func(context.Context, *MetricsViewTotalsRequest) (*MetricsViewTotalsResponse, error)

+ Migrate func(context.Context, *MigrateRequest) (*MigrateResponse, error)

+ MigrateDelete func(context.Context, *MigrateDeleteRequest) (*MigrateDeleteResponse, error)

+ MigrateSingle func(context.Context, *MigrateSingleRequest) (*MigrateSingleResponse, error)

+ Ping func(context.Context, *PingRequest) (*PingResponse, error)

+ PutRepoObject func(context.Context, *PutRepoObjectRequest) (*PutRepoObjectResponse, error)

+ Query func(context.Context, *QueryRequest) (*QueryResponse, error)

+ QueryDirect func(context.Context, *QueryDirectRequest) (*QueryDirectResponse, error)

+ TriggerRefresh func(context.Context, *TriggerRefreshRequest) (*TriggerRefreshResponse, error)

+ type SchemaColumn struct

+ Name string

+ Nullable bool

+ Type string

+ func (*SchemaColumn) Descriptor() ([]byte, []int)

+ func (*SchemaColumn) ProtoMessage()

+ func (x *SchemaColumn) GetName() string

+ func (x *SchemaColumn) GetNullable() bool

+ func (x *SchemaColumn) GetType() string

+ func (x *SchemaColumn) ProtoReflect() protoreflect.Message

+ func (x *SchemaColumn) Reset()

+ func (x *SchemaColumn) String() string

+ type Source struct

+ Connector string

+ Name string

+ Properties *structpb.Struct

+ Sql string

+ func (*Source) Descriptor() ([]byte, []int)

+ func (*Source) ProtoMessage()

+ func (x *Source) GetConnector() string

+ func (x *Source) GetName() string

+ func (x *Source) GetProperties() *structpb.Struct

+ func (x *Source) GetSql() string

+ func (x *Source) ProtoReflect() protoreflect.Message

+ func (x *Source) Reset()

+ func (x *Source) String() string

+ type TriggerRefreshRequest struct

+ InstanceId string

+ Name string

+ func (*TriggerRefreshRequest) Descriptor() ([]byte, []int)

+ func (*TriggerRefreshRequest) ProtoMessage()

+ func (x *TriggerRefreshRequest) GetInstanceId() string

+ func (x *TriggerRefreshRequest) GetName() string

+ func (x *TriggerRefreshRequest) ProtoReflect() protoreflect.Message

+ func (x *TriggerRefreshRequest) Reset()

+ func (x *TriggerRefreshRequest) String() string

+ type TriggerRefreshResponse struct

+ func (*TriggerRefreshResponse) Descriptor() ([]byte, []int)

+ func (*TriggerRefreshResponse) ProtoMessage()

+ func (x *TriggerRefreshResponse) ProtoReflect() protoreflect.Message

+ func (x *TriggerRefreshResponse) Reset()

+ func (x *TriggerRefreshResponse) String() string

+ type UnimplementedRuntimeServiceServer struct

+ func (UnimplementedRuntimeServiceServer) CreateInstance(context.Context, *CreateInstanceRequest) (*CreateInstanceResponse, error)

+ func (UnimplementedRuntimeServiceServer) CreateRepo(context.Context, *CreateRepoRequest) (*CreateRepoResponse, error)

+ func (UnimplementedRuntimeServiceServer) DeleteInstance(context.Context, *DeleteInstanceRequest) (*DeleteInstanceResponse, error)

+ func (UnimplementedRuntimeServiceServer) DeleteRepo(context.Context, *DeleteRepoRequest) (*DeleteRepoResponse, error)

+ func (UnimplementedRuntimeServiceServer) GetCatalogObject(context.Context, *GetCatalogObjectRequest) (*GetCatalogObjectResponse, error)

+ func (UnimplementedRuntimeServiceServer) GetInstance(context.Context, *GetInstanceRequest) (*GetInstanceResponse, error)

+ func (UnimplementedRuntimeServiceServer) GetRepo(context.Context, *GetRepoRequest) (*GetRepoResponse, error)

+ func (UnimplementedRuntimeServiceServer) GetRepoObject(context.Context, *GetRepoObjectRequest) (*GetRepoObjectResponse, error)

+ func (UnimplementedRuntimeServiceServer) ListCatalogObjects(context.Context, *ListCatalogObjectsRequest) (*ListCatalogObjectsResponse, error)

+ func (UnimplementedRuntimeServiceServer) ListConnectors(context.Context, *ListConnectorsRequest) (*ListConnectorsResponse, error)

+ func (UnimplementedRuntimeServiceServer) ListInstances(context.Context, *ListInstancesRequest) (*ListInstancesResponse, error)

+ func (UnimplementedRuntimeServiceServer) ListRepoObjects(context.Context, *ListRepoObjectsRequest) (*ListRepoObjectsResponse, error)

+ func (UnimplementedRuntimeServiceServer) ListRepos(context.Context, *ListReposRequest) (*ListReposResponse, error)

+ func (UnimplementedRuntimeServiceServer) MetricsViewMeta(context.Context, *MetricsViewMetaRequest) (*MetricsViewMetaResponse, error)

+ func (UnimplementedRuntimeServiceServer) MetricsViewTimeSeries(context.Context, *MetricsViewTimeSeriesRequest) (*MetricsViewTimeSeriesResponse, error)

+ func (UnimplementedRuntimeServiceServer) MetricsViewToplist(context.Context, *MetricsViewToplistRequest) (*MetricsViewToplistResponse, error)

+ func (UnimplementedRuntimeServiceServer) MetricsViewTotals(context.Context, *MetricsViewTotalsRequest) (*MetricsViewTotalsResponse, error)

+ func (UnimplementedRuntimeServiceServer) Migrate(context.Context, *MigrateRequest) (*MigrateResponse, error)

+ func (UnimplementedRuntimeServiceServer) MigrateDelete(context.Context, *MigrateDeleteRequest) (*MigrateDeleteResponse, error)

+ func (UnimplementedRuntimeServiceServer) MigrateSingle(context.Context, *MigrateSingleRequest) (*MigrateSingleResponse, error)

+ func (UnimplementedRuntimeServiceServer) Ping(context.Context, *PingRequest) (*PingResponse, error)

+ func (UnimplementedRuntimeServiceServer) PutRepoObject(context.Context, *PutRepoObjectRequest) (*PutRepoObjectResponse, error)

+ func (UnimplementedRuntimeServiceServer) Query(context.Context, *QueryRequest) (*QueryResponse, error)

+ func (UnimplementedRuntimeServiceServer) QueryDirect(context.Context, *QueryDirectRequest) (*QueryDirectResponse, error)

+ func (UnimplementedRuntimeServiceServer) TriggerRefresh(context.Context, *TriggerRefreshRequest) (*TriggerRefreshResponse, error)

+ type UnmanagedTable struct

+ Name string

+ Schema []*SchemaColumn

+ View bool

+ func (*UnmanagedTable) Descriptor() ([]byte, []int)

+ func (*UnmanagedTable) ProtoMessage()

+ func (x *UnmanagedTable) GetName() string

+ func (x *UnmanagedTable) GetSchema() []*SchemaColumn

+ func (x *UnmanagedTable) GetView() bool

+ func (x *UnmanagedTable) ProtoReflect() protoreflect.Message

+ func (x *UnmanagedTable) Reset()

+ func (x *UnmanagedTable) String() string

+ type UnsafeRuntimeServiceServer interface

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