explorer

Aug 20, 2024

Changes in this version

type SchemaType

+ const SchemaType_SCHEMA_TYPE_MAP

Aug 9, 2024

Changes in this version

+ var ExportFormat_name = map[int32]string

+ var ExportFormat_value = map[string]int32

+ type ExportFormat int32

+ const ExportFormat_REPORT_FORMAT_CSV

+ const ExportFormat_REPORT_FORMAT_PARQUET

+ const ExportFormat_REPORT_FORMAT_UNSPECIFIED

+ func (ExportFormat) Descriptor() protoreflect.EnumDescriptor

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

+ func (ExportFormat) Type() protoreflect.EnumType

+ func (x ExportFormat) Enum() *ExportFormat

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

+ func (x ExportFormat) String() string

type ListDatasourceSchemasRequest

+ DatasourceNames []string

+ DatasourceType DatasourceType

+ func (x *ListDatasourceSchemasRequest) GetDatasourceNames() []string

+ func (x *ListDatasourceSchemasRequest) GetDatasourceType() DatasourceType

type QueryRequest

+ Format ExportFormat

+ func (x *QueryRequest) GetFormat() ExportFormat

type Schema

+ TableDescription string

+ func (x *Schema) GetTableDescription() string

type SchemaField

+ ColumnDescription string

+ func (x *SchemaField) GetColumnDescription() string

Jul 23, 2024

Changes in this version

+ const ExplorerService_ListDatasourceSchemas_FullMethodName

+ const ExplorerService_Query_FullMethodName

+ var DatasourceType_name = map[int32]string

+ var DatasourceType_value = map[string]int32

+ var ExplorerService_ServiceDesc = grpc.ServiceDesc

+ var File_api_v1alpha1_explorer_entities_proto protoreflect.FileDescriptor

+ var File_api_v1alpha1_explorer_service_proto protoreflect.FileDescriptor

+ var SchemaType_name = map[int32]string

+ var SchemaType_value = map[string]int32

+ func RegisterExplorerServiceServer(s grpc.ServiceRegistrar, srv ExplorerServiceServer)

+ type DatasourceType int32

+ const DatasourceType_DATASOURCE_TYPE_CLICKHOUSE

+ const DatasourceType_DATASOURCE_TYPE_UNSPECIFIED

+ const DatasourceType_DATASOURCE_TYPE_VFS

+ func (DatasourceType) Descriptor() protoreflect.EnumDescriptor

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

+ func (DatasourceType) Type() protoreflect.EnumType

+ func (x DatasourceType) Enum() *DatasourceType

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

+ func (x DatasourceType) String() string

+ type ExplorerServiceClient interface

+ ListDatasourceSchemas func(ctx context.Context, in *ListDatasourceSchemasRequest, opts ...grpc.CallOption) (*ListDatasourceSchemasResponse, error)

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

+ func NewExplorerServiceClient(cc grpc.ClientConnInterface) ExplorerServiceClient

+ type ExplorerServiceServer interface

+ ListDatasourceSchemas func(context.Context, *ListDatasourceSchemasRequest) (*ListDatasourceSchemasResponse, error)

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

+ type ListDatasourceSchemasRequest struct

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

+ func (*ListDatasourceSchemasRequest) ProtoMessage()

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

+ func (x *ListDatasourceSchemasRequest) Reset()

+ func (x *ListDatasourceSchemasRequest) String() string

+ type ListDatasourceSchemasResponse struct

+ Schemas []*Schema

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

+ func (*ListDatasourceSchemasResponse) ProtoMessage()

+ func (x *ListDatasourceSchemasResponse) GetSchemas() []*Schema

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

+ func (x *ListDatasourceSchemasResponse) Reset()

+ func (x *ListDatasourceSchemasResponse) String() string

+ type Parameters struct

+ Parameters map[string]*Parameters_Parameter

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

+ func (*Parameters) ProtoMessage()

+ func (x *Parameters) GetParameters() map[string]*Parameters_Parameter

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

+ func (x *Parameters) Reset()

+ func (x *Parameters) String() string

+ type Parameters_Parameter struct

+ DataType string

+ Value string

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

+ func (*Parameters_Parameter) ProtoMessage()

+ func (x *Parameters_Parameter) GetDataType() string

+ func (x *Parameters_Parameter) GetValue() string

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

+ func (x *Parameters_Parameter) Reset()

+ func (x *Parameters_Parameter) String() string

+ type QueryRequest struct

+ Comment string

+ DatasourceName string

+ DatasourceType DatasourceType

+ EndTime *timestamppb.Timestamp

+ OrgIds []string

+ PipelineParameters *Parameters

+ Query isQueryRequest_Query

+ StartTime *timestamppb.Timestamp

+ Timezone string

+ UiTraceId string

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

+ func (*QueryRequest) ProtoMessage()

+ func (m *QueryRequest) GetQuery() isQueryRequest_Query

+ func (x *QueryRequest) GetComment() string

+ func (x *QueryRequest) GetDatasourceName() string

+ func (x *QueryRequest) GetDatasourceType() DatasourceType

+ func (x *QueryRequest) GetEndTime() *timestamppb.Timestamp

+ func (x *QueryRequest) GetOrgIds() []string

+ func (x *QueryRequest) GetPipeline() string

+ func (x *QueryRequest) GetPipelineParameters() *Parameters

+ func (x *QueryRequest) GetPrql() string

+ func (x *QueryRequest) GetStartTime() *timestamppb.Timestamp

+ func (x *QueryRequest) GetTimezone() string

+ func (x *QueryRequest) GetUiTraceId() string

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

+ func (x *QueryRequest) Reset()

+ func (x *QueryRequest) String() string

+ type QueryRequest_Pipeline struct

+ Pipeline string

+ type QueryRequest_Prql struct

+ Prql string

+ type QueryResponse struct

+ ResultSizeBytes int64

+ ResultUrl string

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

+ func (*QueryResponse) ProtoMessage()

+ func (x *QueryResponse) GetResultSizeBytes() int64

+ func (x *QueryResponse) GetResultUrl() string

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

+ func (x *QueryResponse) Reset()

+ func (x *QueryResponse) String() string

+ type Schema struct

+ DatasourceType DatasourceType

+ Fields []*SchemaField

+ Name string

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

+ func (*Schema) ProtoMessage()

+ func (x *Schema) GetDatasourceType() DatasourceType

+ func (x *Schema) GetFields() []*SchemaField

+ func (x *Schema) GetName() string

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

+ func (x *Schema) Reset()

+ func (x *Schema) String() string

+ type SchemaField struct

+ ColumnType SchemaType

+ IsLowCardinality bool

+ IsPrimaryKey bool

+ Name string

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

+ func (*SchemaField) ProtoMessage()

+ func (x *SchemaField) GetColumnType() SchemaType

+ func (x *SchemaField) GetIsLowCardinality() bool

+ func (x *SchemaField) GetIsPrimaryKey() bool

+ func (x *SchemaField) GetName() string

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

+ func (x *SchemaField) Reset()

+ func (x *SchemaField) String() string

+ type SchemaType int32

+ const SchemaType_SCHEMA_TYPE_BOOL

+ const SchemaType_SCHEMA_TYPE_BOOL_ARRAY

+ const SchemaType_SCHEMA_TYPE_FLOAT

+ const SchemaType_SCHEMA_TYPE_FLOAT_ARRAY

+ const SchemaType_SCHEMA_TYPE_INT

+ const SchemaType_SCHEMA_TYPE_INT_ARRAY

+ const SchemaType_SCHEMA_TYPE_STRING

+ const SchemaType_SCHEMA_TYPE_STRING_ARRAY

+ const SchemaType_SCHEMA_TYPE_TIMESTAMP

+ const SchemaType_SCHEMA_TYPE_UNSPECIFIED

+ func (SchemaType) Descriptor() protoreflect.EnumDescriptor

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

+ func (SchemaType) Type() protoreflect.EnumType

+ func (x SchemaType) Enum() *SchemaType

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

+ func (x SchemaType) String() string

+ type UnimplementedExplorerServiceServer struct

+ func (UnimplementedExplorerServiceServer) ListDatasourceSchemas(context.Context, *ListDatasourceSchemasRequest) (*ListDatasourceSchemasResponse, error)

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

+ type UnsafeExplorerServiceServer interface