omega_catalogv1

package
v0.0.0-...-8392814 Latest Latest
Warning

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

 Go to latest Published: Jun 17, 2024 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Overview

Package omega_catalogv1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	OmegaCatalogService_CreateCatalog_FullMethodName  = "/omega_catalog.v1.OmegaCatalogService/CreateCatalog"
	OmegaCatalogService_ListCatalogs_FullMethodName   = "/omega_catalog.v1.OmegaCatalogService/ListCatalogs"
	OmegaCatalogService_GetCatalog_FullMethodName     = "/omega_catalog.v1.OmegaCatalogService/GetCatalog"
	OmegaCatalogService_UpdateCatalog_FullMethodName  = "/omega_catalog.v1.OmegaCatalogService/UpdateCatalog"
	OmegaCatalogService_DeleteCatalog_FullMethodName  = "/omega_catalog.v1.OmegaCatalogService/DeleteCatalog"
	OmegaCatalogService_CreateSchema_FullMethodName   = "/omega_catalog.v1.OmegaCatalogService/CreateSchema"
	OmegaCatalogService_ListSchemas_FullMethodName    = "/omega_catalog.v1.OmegaCatalogService/ListSchemas"
	OmegaCatalogService_GetSchema_FullMethodName      = "/omega_catalog.v1.OmegaCatalogService/GetSchema"
	OmegaCatalogService_UpdateSchema_FullMethodName   = "/omega_catalog.v1.OmegaCatalogService/UpdateSchema"
	OmegaCatalogService_DeleteSchema_FullMethodName   = "/omega_catalog.v1.OmegaCatalogService/DeleteSchema"
	OmegaCatalogService_CreateTable_FullMethodName    = "/omega_catalog.v1.OmegaCatalogService/CreateTable"
	OmegaCatalogService_ListTables_FullMethodName     = "/omega_catalog.v1.OmegaCatalogService/ListTables"
	OmegaCatalogService_GetTable_FullMethodName       = "/omega_catalog.v1.OmegaCatalogService/GetTable"
	OmegaCatalogService_DeleteTable_FullMethodName    = "/omega_catalog.v1.OmegaCatalogService/DeleteTable"
	OmegaCatalogService_CreateVolume_FullMethodName   = "/omega_catalog.v1.OmegaCatalogService/CreateVolume"
	OmegaCatalogService_ListVolumes_FullMethodName    = "/omega_catalog.v1.OmegaCatalogService/ListVolumes"
	OmegaCatalogService_GetVolume_FullMethodName      = "/omega_catalog.v1.OmegaCatalogService/GetVolume"
	OmegaCatalogService_UpdateVolume_FullMethodName   = "/omega_catalog.v1.OmegaCatalogService/UpdateVolume"
	OmegaCatalogService_DeleteVolume_FullMethodName   = "/omega_catalog.v1.OmegaCatalogService/DeleteVolume"
	OmegaCatalogService_CreateFunction_FullMethodName = "/omega_catalog.v1.OmegaCatalogService/CreateFunction"
	OmegaCatalogService_ListFunctions_FullMethodName  = "/omega_catalog.v1.OmegaCatalogService/ListFunctions"
	OmegaCatalogService_GetFunction_FullMethodName    = "/omega_catalog.v1.OmegaCatalogService/GetFunction"
	OmegaCatalogService_DeleteFunction_FullMethodName = "/omega_catalog.v1.OmegaCatalogService/DeleteFunction"
)

Variables

View Source 
var (
	TableType_name = map[int32]string{
		0: "TABLE_TYPE_UNSPECIFIED",
		1: "TABLE_TYPE_MANAGED",
		2: "TABLE_TYPE_EXTERNAL",
	}
	TableType_value = map[string]int32{
		"TABLE_TYPE_UNSPECIFIED": 0,
		"TABLE_TYPE_MANAGED":     1,
		"TABLE_TYPE_EXTERNAL":    2,
	}
)

Enum value maps for TableType.

View Source 
var (
	DataSourceFormat_name = map[int32]string{
		0: "DATA_SOURCE_FORMAT_UNSPECIFIED",
		1: "DATA_SOURCE_FORMAT_CSV",
		2: "DATA_SOURCE_FORMAT_JSON",
		3: "DATA_SOURCE_FORMAT_PARQUET",
		4: "DATA_SOURCE_FORMAT_DELTA",
		5: "DATA_SOURCE_FORMAT_ORC",
		6: "DATA_SOURCE_FORMAT_TEXT",
		7: "DATA_SOURCE_FORMAT_AVRO",
	}
	DataSourceFormat_value = map[string]int32{
		"DATA_SOURCE_FORMAT_UNSPECIFIED": 0,
		"DATA_SOURCE_FORMAT_CSV":         1,
		"DATA_SOURCE_FORMAT_JSON":        2,
		"DATA_SOURCE_FORMAT_PARQUET":     3,
		"DATA_SOURCE_FORMAT_DELTA":       4,
		"DATA_SOURCE_FORMAT_ORC":         5,
		"DATA_SOURCE_FORMAT_TEXT":        6,
		"DATA_SOURCE_FORMAT_AVRO":        7,
	}
)

Enum value maps for DataSourceFormat.

View Source 
var (
	VolumeType_name = map[int32]string{
		0: "VOLUME_TYPE_UNSPECIFIED",
		1: "VOLUME_TYPE_MANAGED",
		2: "VOLUME_TYPE_EXTERNAL",
	}
	VolumeType_value = map[string]int32{
		"VOLUME_TYPE_UNSPECIFIED": 0,
		"VOLUME_TYPE_MANAGED":     1,
		"VOLUME_TYPE_EXTERNAL":    2,
	}
)

Enum value maps for VolumeType.

View Source 
var (
	FunctionSecurityType_name = map[int32]string{
		0: "FUNCTION_SECURITY_TYPE_UNSPECIFIED",
		1: "FUNCTION_SECURITY_TYPE_DEFINER",
	}
	FunctionSecurityType_value = map[string]int32{
		"FUNCTION_SECURITY_TYPE_UNSPECIFIED": 0,
		"FUNCTION_SECURITY_TYPE_DEFINER":     1,
	}
)

Enum value maps for FunctionSecurityType.

View Source 
var (
	SQLDataAccess_name = map[int32]string{
		0: "SQL_DATA_ACCESS_UNSPECIFIED",
		1: "SQL_DATA_ACCESS_CONTAINS_SQL",
		2: "SQL_DATA_ACCESS_NO_SQL",
		3: "SQL_DATA_ACCESS_READS_SQL_DATA",
	}
	SQLDataAccess_value = map[string]int32{
		"SQL_DATA_ACCESS_UNSPECIFIED":    0,
		"SQL_DATA_ACCESS_CONTAINS_SQL":   1,
		"SQL_DATA_ACCESS_NO_SQL":         2,
		"SQL_DATA_ACCESS_READS_SQL_DATA": 3,
	}
)

Enum value maps for SQLDataAccess.

View Source 
var (
	ParameterStyle_name = map[int32]string{
		0: "PARAMETER_STYLE_UNSPECIFIED",
		1: "PARAMETER_STYLE_SQL",
	}
	ParameterStyle_value = map[string]int32{
		"PARAMETER_STYLE_UNSPECIFIED": 0,
		"PARAMETER_STYLE_SQL":         1,
	}
)

Enum value maps for ParameterStyle.

View Source 
var (
	FunctionLanguage_name = map[int32]string{
		0: "FUNCTION_LANGUAGE_UNSPECIFIED",
		1: "FUNCTION_LANGUAGE_SQL",
		2: "FUNCTION_LANGUAGE_EXTERNAL",
	}
	FunctionLanguage_value = map[string]int32{
		"FUNCTION_LANGUAGE_UNSPECIFIED": 0,
		"FUNCTION_LANGUAGE_SQL":         1,
		"FUNCTION_LANGUAGE_EXTERNAL":    2,
	}
)

Enum value maps for FunctionLanguage.

View Source 
var (
	FunctionParameterMode_name = map[int32]string{
		0: "FUNCTION_PARAMETER_MODE_UNSPECIFIED",
		1: "FUNCTION_PARAMETER_MODE_IN",
	}
	FunctionParameterMode_value = map[string]int32{
		"FUNCTION_PARAMETER_MODE_UNSPECIFIED": 0,
		"FUNCTION_PARAMETER_MODE_IN":          1,
	}
)

Enum value maps for FunctionParameterMode.

View Source 
var (
	FunctionParameterType_name = map[int32]string{
		0: "FUNCTION_PARAMETER_TYPE_UNSPECIFIED",
		1: "FUNCTION_PARAMETER_TYPE_PARAM",
		2: "FUNCTION_PARAMETER_TYPE_COLUMN",
	}
	FunctionParameterType_value = map[string]int32{
		"FUNCTION_PARAMETER_TYPE_UNSPECIFIED": 0,
		"FUNCTION_PARAMETER_TYPE_PARAM":       1,
		"FUNCTION_PARAMETER_TYPE_COLUMN":      2,
	}
)

Enum value maps for FunctionParameterType.

View Source 
var (
	ColumnTypeName_name = map[int32]string{
		0:  "COLUMN_TYPE_NAME_UNSPECIFIED",
		1:  "COLUMN_TYPE_NAME_ARRAY",
		2:  "COLUMN_TYPE_NAME_BINARY",
		3:  "COLUMN_TYPE_NAME_BOOLEAN",
		4:  "COLUMN_TYPE_NAME_CHAR",
		5:  "COLUMN_TYPE_NAME_DATE",
		6:  "COLUMN_TYPE_NAME_DECIMAL",
		7:  "COLUMN_TYPE_NAME_DOUBLE",
		8:  "COLUMN_TYPE_NAME_FLOAT",
		9:  "COLUMN_TYPE_NAME_INT",
		10: "COLUMN_TYPE_NAME_INTERVAL",
		11: "COLUMN_TYPE_NAME_LONG",
		12: "COLUMN_TYPE_NAME_MAP",
		13: "COLUMN_TYPE_NAME_SHORT",
		14: "COLUMN_TYPE_NAME_STRING",
		15: "COLUMN_TYPE_NAME_STRUCT",
		16: "COLUMN_TYPE_NAME_TIMESTAMP_NTZ",
		17: "COLUMN_TYPE_NAME_TIMESTAMP",
		18: "COLUMN_TYPE_NAME_USER_DEFINED_TYPE",
		19: "COLUMN_TYPE_NAME_TABLE_TYPE",
		20: "COLUMN_TYPE_NAME_NULL",
		21: "COLUMN_TYPE_NAME_BYTE",
	}
	ColumnTypeName_value = map[string]int32{
		"COLUMN_TYPE_NAME_UNSPECIFIED":       0,
		"COLUMN_TYPE_NAME_ARRAY":             1,
		"COLUMN_TYPE_NAME_BINARY":            2,
		"COLUMN_TYPE_NAME_BOOLEAN":           3,
		"COLUMN_TYPE_NAME_CHAR":              4,
		"COLUMN_TYPE_NAME_DATE":              5,
		"COLUMN_TYPE_NAME_DECIMAL":           6,
		"COLUMN_TYPE_NAME_DOUBLE":            7,
		"COLUMN_TYPE_NAME_FLOAT":             8,
		"COLUMN_TYPE_NAME_INT":               9,
		"COLUMN_TYPE_NAME_INTERVAL":          10,
		"COLUMN_TYPE_NAME_LONG":              11,
		"COLUMN_TYPE_NAME_MAP":               12,
		"COLUMN_TYPE_NAME_SHORT":             13,
		"COLUMN_TYPE_NAME_STRING":            14,
		"COLUMN_TYPE_NAME_STRUCT":            15,
		"COLUMN_TYPE_NAME_TIMESTAMP_NTZ":     16,
		"COLUMN_TYPE_NAME_TIMESTAMP":         17,
		"COLUMN_TYPE_NAME_USER_DEFINED_TYPE": 18,
		"COLUMN_TYPE_NAME_TABLE_TYPE":        19,
		"COLUMN_TYPE_NAME_NULL":              20,
		"COLUMN_TYPE_NAME_BYTE":              21,
	}
)

Enum value maps for ColumnTypeName.

View Source 
var File_omega_catalog_v1_omega_catalog_proto protoreflect.FileDescriptor
View Source 
var OmegaCatalogService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "omega_catalog.v1.OmegaCatalogService",
	HandlerType: (*OmegaCatalogServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateCatalog",
			Handler:    _OmegaCatalogService_CreateCatalog_Handler,
		},
		{
			MethodName: "ListCatalogs",
			Handler:    _OmegaCatalogService_ListCatalogs_Handler,
		},
		{
			MethodName: "GetCatalog",
			Handler:    _OmegaCatalogService_GetCatalog_Handler,
		},
		{
			MethodName: "UpdateCatalog",
			Handler:    _OmegaCatalogService_UpdateCatalog_Handler,
		},
		{
			MethodName: "DeleteCatalog",
			Handler:    _OmegaCatalogService_DeleteCatalog_Handler,
		},
		{
			MethodName: "CreateSchema",
			Handler:    _OmegaCatalogService_CreateSchema_Handler,
		},
		{
			MethodName: "ListSchemas",
			Handler:    _OmegaCatalogService_ListSchemas_Handler,
		},
		{
			MethodName: "GetSchema",
			Handler:    _OmegaCatalogService_GetSchema_Handler,
		},
		{
			MethodName: "UpdateSchema",
			Handler:    _OmegaCatalogService_UpdateSchema_Handler,
		},
		{
			MethodName: "DeleteSchema",
			Handler:    _OmegaCatalogService_DeleteSchema_Handler,
		},
		{
			MethodName: "CreateTable",
			Handler:    _OmegaCatalogService_CreateTable_Handler,
		},
		{
			MethodName: "ListTables",
			Handler:    _OmegaCatalogService_ListTables_Handler,
		},
		{
			MethodName: "GetTable",
			Handler:    _OmegaCatalogService_GetTable_Handler,
		},
		{
			MethodName: "DeleteTable",
			Handler:    _OmegaCatalogService_DeleteTable_Handler,
		},
		{
			MethodName: "CreateVolume",
			Handler:    _OmegaCatalogService_CreateVolume_Handler,
		},
		{
			MethodName: "ListVolumes",
			Handler:    _OmegaCatalogService_ListVolumes_Handler,
		},
		{
			MethodName: "GetVolume",
			Handler:    _OmegaCatalogService_GetVolume_Handler,
		},
		{
			MethodName: "UpdateVolume",
			Handler:    _OmegaCatalogService_UpdateVolume_Handler,
		},
		{
			MethodName: "DeleteVolume",
			Handler:    _OmegaCatalogService_DeleteVolume_Handler,
		},
		{
			MethodName: "CreateFunction",
			Handler:    _OmegaCatalogService_CreateFunction_Handler,
		},
		{
			MethodName: "ListFunctions",
			Handler:    _OmegaCatalogService_ListFunctions_Handler,
		},
		{
			MethodName: "GetFunction",
			Handler:    _OmegaCatalogService_GetFunction_Handler,
		},
		{
			MethodName: "DeleteFunction",
			Handler:    _OmegaCatalogService_DeleteFunction_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "omega_catalog/v1/omega_catalog.proto",
}

OmegaCatalogService_ServiceDesc is the grpc.ServiceDesc for OmegaCatalogService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterOmegaCatalogServiceHandler 

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

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

func RegisterOmegaCatalogServiceHandlerClient 

func RegisterOmegaCatalogServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client OmegaCatalogServiceClient) error

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

func RegisterOmegaCatalogServiceHandlerFromEndpoint 

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

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

func RegisterOmegaCatalogServiceHandlerServer 

func RegisterOmegaCatalogServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server OmegaCatalogServiceServer) error

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

func RegisterOmegaCatalogServiceServer 

func RegisterOmegaCatalogServiceServer(s grpc.ServiceRegistrar, srv OmegaCatalogServiceServer)

Types

type Catalog 

type Catalog struct {
	Id         string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name       string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Comment    string                 `protobuf:"bytes,3,opt,name=comment,proto3" json:"comment,omitempty"`
	CreatedAt  *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt  *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	Properties map[string]string      `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

Catalog is a the top-most level of data organization, and contains databases/schemas, which contain tables.

func (*Catalog) Descriptor deprecated 

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

Deprecated: Use Catalog.ProtoReflect.Descriptor instead.

func (*Catalog) GetComment 

func (x *Catalog) GetComment() string

func (*Catalog) GetCreatedAt 

func (x *Catalog) GetCreatedAt() *timestamppb.Timestamp

func (*Catalog) GetId 

func (x *Catalog) GetId() string

func (*Catalog) GetName 

func (x *Catalog) GetName() string

func (*Catalog) GetProperties 

func (x *Catalog) GetProperties() map[string]string

func (*Catalog) GetUpdatedAt 

func (x *Catalog) GetUpdatedAt() *timestamppb.Timestamp

func (*Catalog) ProtoMessage 

func (*Catalog) ProtoMessage()

func (*Catalog) ProtoReflect 

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

func (*Catalog) Reset 

func (x *Catalog) Reset()

func (*Catalog) String 

func (x *Catalog) String() string

type ColumnInfo 

type ColumnInfo struct {
	Name             string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	TypeText         string `protobuf:"bytes,2,opt,name=type_text,json=typeText,proto3" json:"type_text,omitempty"`
	TypeJson         string `protobuf:"bytes,3,opt,name=type_json,json=typeJson,proto3" json:"type_json,omitempty"`
	TypeName         string `protobuf:"bytes,4,opt,name=type_name,json=typeName,proto3" json:"type_name,omitempty"`
	TypePrecision    int64  `protobuf:"varint,5,opt,name=type_precision,json=typePrecision,proto3" json:"type_precision,omitempty"`
	TypeScale        int64  `protobuf:"varint,6,opt,name=type_scale,json=typeScale,proto3" json:"type_scale,omitempty"`
	TypeIntervalType string `protobuf:"bytes,7,opt,name=type_interval_type,json=typeIntervalType,proto3" json:"type_interval_type,omitempty"`
	Position         int32  `protobuf:"varint,8,opt,name=position,proto3" json:"position,omitempty"`
	Comment          string `protobuf:"bytes,9,opt,name=comment,proto3" json:"comment,omitempty"`
	Nullable         bool   `protobuf:"varint,10,opt,name=nullable,proto3" json:"nullable,omitempty"`
	PartitionIndex   int32  `protobuf:"varint,11,opt,name=partition_index,json=partitionIndex,proto3" json:"partition_index,omitempty"`
	// contains filtered or unexported fields
}

func (*ColumnInfo) Descriptor deprecated 

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

Deprecated: Use ColumnInfo.ProtoReflect.Descriptor instead.

func (*ColumnInfo) GetComment 

func (x *ColumnInfo) GetComment() string

func (*ColumnInfo) GetName 

func (x *ColumnInfo) GetName() string

func (*ColumnInfo) GetNullable 

func (x *ColumnInfo) GetNullable() bool

func (*ColumnInfo) GetPartitionIndex 

func (x *ColumnInfo) GetPartitionIndex() int32

func (*ColumnInfo) GetPosition 

func (x *ColumnInfo) GetPosition() int32

func (*ColumnInfo) GetTypeIntervalType 

func (x *ColumnInfo) GetTypeIntervalType() string

func (*ColumnInfo) GetTypeJson 

func (x *ColumnInfo) GetTypeJson() string

func (*ColumnInfo) GetTypeName 

func (x *ColumnInfo) GetTypeName() string

func (*ColumnInfo) GetTypePrecision 

func (x *ColumnInfo) GetTypePrecision() int64

func (*ColumnInfo) GetTypeScale 

func (x *ColumnInfo) GetTypeScale() int64

func (*ColumnInfo) GetTypeText 

func (x *ColumnInfo) GetTypeText() string

func (*ColumnInfo) ProtoMessage 

func (*ColumnInfo) ProtoMessage()

func (*ColumnInfo) ProtoReflect 

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

func (*ColumnInfo) Reset 

func (x *ColumnInfo) Reset()

func (*ColumnInfo) String 

func (x *ColumnInfo) String() string

type ColumnTypeName 

type ColumnTypeName int32
const (
	ColumnTypeName_COLUMN_TYPE_NAME_UNSPECIFIED       ColumnTypeName = 0
	ColumnTypeName_COLUMN_TYPE_NAME_ARRAY             ColumnTypeName = 1
	ColumnTypeName_COLUMN_TYPE_NAME_BINARY            ColumnTypeName = 2
	ColumnTypeName_COLUMN_TYPE_NAME_BOOLEAN           ColumnTypeName = 3
	ColumnTypeName_COLUMN_TYPE_NAME_CHAR              ColumnTypeName = 4
	ColumnTypeName_COLUMN_TYPE_NAME_DATE              ColumnTypeName = 5
	ColumnTypeName_COLUMN_TYPE_NAME_DECIMAL           ColumnTypeName = 6
	ColumnTypeName_COLUMN_TYPE_NAME_DOUBLE            ColumnTypeName = 7
	ColumnTypeName_COLUMN_TYPE_NAME_FLOAT             ColumnTypeName = 8
	ColumnTypeName_COLUMN_TYPE_NAME_INT               ColumnTypeName = 9
	ColumnTypeName_COLUMN_TYPE_NAME_INTERVAL          ColumnTypeName = 10
	ColumnTypeName_COLUMN_TYPE_NAME_LONG              ColumnTypeName = 11
	ColumnTypeName_COLUMN_TYPE_NAME_MAP               ColumnTypeName = 12
	ColumnTypeName_COLUMN_TYPE_NAME_SHORT             ColumnTypeName = 13
	ColumnTypeName_COLUMN_TYPE_NAME_STRING            ColumnTypeName = 14
	ColumnTypeName_COLUMN_TYPE_NAME_STRUCT            ColumnTypeName = 15
	ColumnTypeName_COLUMN_TYPE_NAME_TIMESTAMP_NTZ     ColumnTypeName = 16
	ColumnTypeName_COLUMN_TYPE_NAME_TIMESTAMP         ColumnTypeName = 17
	ColumnTypeName_COLUMN_TYPE_NAME_USER_DEFINED_TYPE ColumnTypeName = 18
	ColumnTypeName_COLUMN_TYPE_NAME_TABLE_TYPE        ColumnTypeName = 19
	ColumnTypeName_COLUMN_TYPE_NAME_NULL              ColumnTypeName = 20
	ColumnTypeName_COLUMN_TYPE_NAME_BYTE              ColumnTypeName = 21
)

func (ColumnTypeName) Descriptor 

func (ColumnTypeName) Descriptor() protoreflect.EnumDescriptor

func (ColumnTypeName) Enum 

func (x ColumnTypeName) Enum() *ColumnTypeName

func (ColumnTypeName) EnumDescriptor deprecated 

func (ColumnTypeName) EnumDescriptor() ([]byte, []int)

Deprecated: Use ColumnTypeName.Descriptor instead.

func (ColumnTypeName) Number 

func (x ColumnTypeName) Number() protoreflect.EnumNumber

func (ColumnTypeName) String 

func (x ColumnTypeName) String() string

func (ColumnTypeName) Type 

func (ColumnTypeName) Type() protoreflect.EnumType

type CreateCatalogRequest 

type CreateCatalogRequest struct {
	Name       string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Comment    string            `protobuf:"bytes,2,opt,name=comment,proto3" json:"comment,omitempty"`
	Properties map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

CreateCatalogRequest is the request message for the CreateCatalog API.

func (*CreateCatalogRequest) Descriptor deprecated 

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

Deprecated: Use CreateCatalogRequest.ProtoReflect.Descriptor instead.

func (*CreateCatalogRequest) GetComment 

func (x *CreateCatalogRequest) GetComment() string

func (*CreateCatalogRequest) GetName 

func (x *CreateCatalogRequest) GetName() string

func (*CreateCatalogRequest) GetProperties 

func (x *CreateCatalogRequest) GetProperties() map[string]string

func (*CreateCatalogRequest) ProtoMessage 

func (*CreateCatalogRequest) ProtoMessage()

func (*CreateCatalogRequest) ProtoReflect 

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

func (*CreateCatalogRequest) Reset 

func (x *CreateCatalogRequest) Reset()

func (*CreateCatalogRequest) String 

func (x *CreateCatalogRequest) String() string

type CreateCatalogResponse 

type CreateCatalogResponse struct {
	Catalog *Catalog `protobuf:"bytes,1,opt,name=catalog,proto3" json:"catalog,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateCatalogResponse) Descriptor deprecated 

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

Deprecated: Use CreateCatalogResponse.ProtoReflect.Descriptor instead.

func (*CreateCatalogResponse) GetCatalog 

func (x *CreateCatalogResponse) GetCatalog() *Catalog

func (*CreateCatalogResponse) ProtoMessage 

func (*CreateCatalogResponse) ProtoMessage()

func (*CreateCatalogResponse) ProtoReflect 

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

func (*CreateCatalogResponse) Reset 

func (x *CreateCatalogResponse) Reset()

func (*CreateCatalogResponse) String 

func (x *CreateCatalogResponse) String() string

type CreateFunctionRequest 

type CreateFunctionRequest struct {

	// The name of the catalog where the schema and the function are
	CatalogName string `protobuf:"bytes,1,opt,name=catalog_name,json=catalogName,proto3" json:"catalog_name,omitempty"`
	// The name of the schema where the function is
	SchemaName string `protobuf:"bytes,2,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"`
	// The name of the function, relative to parent schema.
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// Specific name of the function; reserved for future use
	SpecificName string `protobuf:"bytes,4,opt,name=specific_name,json=specificName,proto3" json:"specific_name,omitempty"`
	// The comment attached to the function
	Comment string `protobuf:"bytes,5,opt,name=comment,proto3" json:"comment,omitempty"`
	// Input params
	InputParams *FunctionParameterInfos `protobuf:"bytes,6,opt,name=input_params,json=inputParams,proto3" json:"input_params,omitempty"`
	// Name of the type (INT, STRUCT, MAP, etc.)
	DataType ColumnTypeName `protobuf:"varint,7,opt,name=data_type,json=dataType,proto3,enum=omega_catalog.v1.ColumnTypeName" json:"data_type,omitempty"`
	// Pretty printed function data type
	FullDataType string `protobuf:"bytes,8,opt,name=full_data_type,json=fullDataType,proto3" json:"full_data_type,omitempty"`
	// Return params
	ReturnParams *FunctionParameterInfos `protobuf:"bytes,9,opt,name=return_params,json=returnParams,proto3" json:"return_params,omitempty"`
	// Function language. When EXTERNAL is used, the language
	// of the routine function should be specified in the
	// external_language field, and the return_params of the function
	// cannot be used (as TABLE return type is not supported),
	// and the sql_data_access field must be NO_SQL.
	RoutineBody FunctionLanguage `` /* 135-byte string literal not displayed */
	// Function body
	RoutineDefinition string `protobuf:"bytes,11,opt,name=routine_definition,json=routineDefinition,proto3" json:"routine_definition,omitempty"`
	// A list of dependencies
	RoutineDependencies *DependencyList `protobuf:"bytes,12,opt,name=routine_dependencies,json=routineDependencies,proto3" json:"routine_dependencies,omitempty"`
	// Function parameter style. S is the value for SQL.
	ParameterStyle ParameterStyle `` /* 142-byte string literal not displayed */
	// Whether the function is deterministic.
	IsDeterministic bool `protobuf:"varint,14,opt,name=is_deterministic,json=isDeterministic,proto3" json:"is_deterministic,omitempty"`
	// Function SQL data access.
	SqlDataAccess SQLDataAccess `` /* 140-byte string literal not displayed */
	// Function null call.
	IsNullCall bool `protobuf:"varint,16,opt,name=is_null_call,json=isNullCall,proto3" json:"is_null_call,omitempty"`
	// Function security type.
	SecurityType FunctionSecurityType `` /* 142-byte string literal not displayed */
	// Properties of the function.
	Properties map[string]string `` /* 162-byte string literal not displayed */
	// External language of the function.
	ExternalLanguage string `protobuf:"bytes,19,opt,name=external_language,json=externalLanguage,proto3" json:"external_language,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateFunctionRequest) Descriptor deprecated 

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

Deprecated: Use CreateFunctionRequest.ProtoReflect.Descriptor instead.

func (*CreateFunctionRequest) GetCatalogName 

func (x *CreateFunctionRequest) GetCatalogName() string

func (*CreateFunctionRequest) GetComment 

func (x *CreateFunctionRequest) GetComment() string

func (*CreateFunctionRequest) GetDataType 

func (x *CreateFunctionRequest) GetDataType() ColumnTypeName

func (*CreateFunctionRequest) GetExternalLanguage 

func (x *CreateFunctionRequest) GetExternalLanguage() string

func (*CreateFunctionRequest) GetFullDataType 

func (x *CreateFunctionRequest) GetFullDataType() string

func (*CreateFunctionRequest) GetInputParams 

func (x *CreateFunctionRequest) GetInputParams() *FunctionParameterInfos

func (*CreateFunctionRequest) GetIsDeterministic 

func (x *CreateFunctionRequest) GetIsDeterministic() bool

func (*CreateFunctionRequest) GetIsNullCall 

func (x *CreateFunctionRequest) GetIsNullCall() bool

func (*CreateFunctionRequest) GetName 

func (x *CreateFunctionRequest) GetName() string

func (*CreateFunctionRequest) GetParameterStyle 

func (x *CreateFunctionRequest) GetParameterStyle() ParameterStyle

func (*CreateFunctionRequest) GetProperties 

func (x *CreateFunctionRequest) GetProperties() map[string]string

func (*CreateFunctionRequest) GetReturnParams 

func (x *CreateFunctionRequest) GetReturnParams() *FunctionParameterInfos

func (*CreateFunctionRequest) GetRoutineBody 

func (x *CreateFunctionRequest) GetRoutineBody() FunctionLanguage

func (*CreateFunctionRequest) GetRoutineDefinition 

func (x *CreateFunctionRequest) GetRoutineDefinition() string

func (*CreateFunctionRequest) GetRoutineDependencies 

func (x *CreateFunctionRequest) GetRoutineDependencies() *DependencyList

func (*CreateFunctionRequest) GetSchemaName 

func (x *CreateFunctionRequest) GetSchemaName() string

func (*CreateFunctionRequest) GetSecurityType 

func (x *CreateFunctionRequest) GetSecurityType() FunctionSecurityType

func (*CreateFunctionRequest) GetSpecificName 

func (x *CreateFunctionRequest) GetSpecificName() string

func (*CreateFunctionRequest) GetSqlDataAccess 

func (x *CreateFunctionRequest) GetSqlDataAccess() SQLDataAccess

func (*CreateFunctionRequest) ProtoMessage 

func (*CreateFunctionRequest) ProtoMessage()

func (*CreateFunctionRequest) ProtoReflect 

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

func (*CreateFunctionRequest) Reset 

func (x *CreateFunctionRequest) Reset()

func (*CreateFunctionRequest) String 

func (x *CreateFunctionRequest) String() string

type CreateFunctionResponse 

type CreateFunctionResponse struct {
	Function *FunctionInfo `protobuf:"bytes,1,opt,name=function,proto3" json:"function,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateFunctionResponse) Descriptor deprecated 

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

Deprecated: Use CreateFunctionResponse.ProtoReflect.Descriptor instead.

func (*CreateFunctionResponse) GetFunction 

func (x *CreateFunctionResponse) GetFunction() *FunctionInfo

func (*CreateFunctionResponse) ProtoMessage 

func (*CreateFunctionResponse) ProtoMessage()

func (*CreateFunctionResponse) ProtoReflect 

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

func (*CreateFunctionResponse) Reset 

func (x *CreateFunctionResponse) Reset()

func (*CreateFunctionResponse) String 

func (x *CreateFunctionResponse) String() string

type CreateSchemaRequest 

type CreateSchemaRequest struct {

	// Name of the schema, relative to parent catalog.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Name of parent catalog.
	CatalogName string `protobuf:"bytes,2,opt,name=catalog_name,json=catalogName,proto3" json:"catalog_name,omitempty"`
	// User-provided free-form text description.
	Comment string `protobuf:"bytes,3,opt,name=comment,proto3" json:"comment,omitempty"`
	// A map of key-value properties attached to the securable object.
	Properties map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateSchemaRequest) Descriptor deprecated 

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

Deprecated: Use CreateSchemaRequest.ProtoReflect.Descriptor instead.

func (*CreateSchemaRequest) GetCatalogName 

func (x *CreateSchemaRequest) GetCatalogName() string

func (*CreateSchemaRequest) GetComment 

func (x *CreateSchemaRequest) GetComment() string

func (*CreateSchemaRequest) GetName 

func (x *CreateSchemaRequest) GetName() string

func (*CreateSchemaRequest) GetProperties 

func (x *CreateSchemaRequest) GetProperties() map[string]string

func (*CreateSchemaRequest) ProtoMessage 

func (*CreateSchemaRequest) ProtoMessage()

func (*CreateSchemaRequest) ProtoReflect 

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

func (*CreateSchemaRequest) Reset 

func (x *CreateSchemaRequest) Reset()

func (*CreateSchemaRequest) String 

func (x *CreateSchemaRequest) String() string

type CreateSchemaResponse 

type CreateSchemaResponse struct {
	Schema *Schema `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateSchemaResponse) Descriptor deprecated 

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

Deprecated: Use CreateSchemaResponse.ProtoReflect.Descriptor instead.

func (*CreateSchemaResponse) GetSchema 

func (x *CreateSchemaResponse) GetSchema() *Schema

func (*CreateSchemaResponse) ProtoMessage 

func (*CreateSchemaResponse) ProtoMessage()

func (*CreateSchemaResponse) ProtoReflect 

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

func (*CreateSchemaResponse) Reset 

func (x *CreateSchemaResponse) Reset()

func (*CreateSchemaResponse) String 

func (x *CreateSchemaResponse) String() string

type CreateTableRequest 

type CreateTableRequest struct {

	// Name of the table relative to parent schema.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Name of parent catalog.
	CatalogName string `protobuf:"bytes,2,opt,name=catalog_name,json=catalogName,proto3" json:"catalog_name,omitempty"`
	// Name of parent schema relative to its parent catalog.
	SchemaName string `protobuf:"bytes,3,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"`
	// The type of the table.
	TableType TableType `protobuf:"varint,4,opt,name=table_type,json=tableType,proto3,enum=omega_catalog.v1.TableType" json:"table_type,omitempty"`
	// The format of the data source.
	DataSourceFormat DataSourceFormat `` /* 151-byte string literal not displayed */
	// Array of the ColumnInfo definitions of the table's columns
	Columns []*ColumnInfo `protobuf:"bytes,6,rep,name=columns,proto3" json:"columns,omitempty"`
	// Storage root URL for table (for MANAGED, EXTERNAL tables)
	StorageLocation string `protobuf:"bytes,7,opt,name=storage_location,json=storageLocation,proto3" json:"storage_location,omitempty"`
	// User-provided free-form text description.
	Comment string `protobuf:"bytes,8,opt,name=comment,proto3" json:"comment,omitempty"`
	// A map of key-value properties attached to the securable object.
	Properties map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

CreateTableRequest is the request message for the CreateTable API.

func (*CreateTableRequest) Descriptor deprecated 

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

Deprecated: Use CreateTableRequest.ProtoReflect.Descriptor instead.

func (*CreateTableRequest) GetCatalogName 

func (x *CreateTableRequest) GetCatalogName() string

func (*CreateTableRequest) GetColumns 

func (x *CreateTableRequest) GetColumns() []*ColumnInfo

func (*CreateTableRequest) GetComment 

func (x *CreateTableRequest) GetComment() string

func (*CreateTableRequest) GetDataSourceFormat 

func (x *CreateTableRequest) GetDataSourceFormat() DataSourceFormat

func (*CreateTableRequest) GetName 

func (x *CreateTableRequest) GetName() string

func (*CreateTableRequest) GetProperties 

func (x *CreateTableRequest) GetProperties() map[string]string

func (*CreateTableRequest) GetSchemaName 

func (x *CreateTableRequest) GetSchemaName() string

func (*CreateTableRequest) GetStorageLocation 

func (x *CreateTableRequest) GetStorageLocation() string

func (*CreateTableRequest) GetTableType 

func (x *CreateTableRequest) GetTableType() TableType

func (*CreateTableRequest) ProtoMessage 

func (*CreateTableRequest) ProtoMessage()

func (*CreateTableRequest) ProtoReflect 

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

func (*CreateTableRequest) Reset 

func (x *CreateTableRequest) Reset()

func (*CreateTableRequest) String 

func (x *CreateTableRequest) String() string

type CreateTableResponse 

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

func (*CreateTableResponse) Descriptor deprecated 

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

Deprecated: Use CreateTableResponse.ProtoReflect.Descriptor instead.

func (*CreateTableResponse) GetTable 

func (x *CreateTableResponse) GetTable() *Table

func (*CreateTableResponse) ProtoMessage 

func (*CreateTableResponse) ProtoMessage()

func (*CreateTableResponse) ProtoReflect 

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

func (*CreateTableResponse) Reset 

func (x *CreateTableResponse) Reset()

func (*CreateTableResponse) String 

func (x *CreateTableResponse) String() string

type CreateVolumeRequest 

type CreateVolumeRequest struct {

	// The name of the catalog where the schema and the volume are
	CatalogName string `protobuf:"bytes,1,opt,name=catalog_name,json=catalogName,proto3" json:"catalog_name,omitempty"`
	// The name of the schema where the volume is
	SchemaName string `protobuf:"bytes,2,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"`
	// The name of the volume
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// The type of the volume
	VolumeType VolumeType `protobuf:"varint,4,opt,name=volume_type,json=volumeType,proto3,enum=omega_catalog.v1.VolumeType" json:"volume_type,omitempty"`
	// The comment attached to the volume
	Comment string `protobuf:"bytes,5,opt,name=comment,proto3" json:"comment,omitempty"`
	// The storage location of the volume
	StorageLocation string `protobuf:"bytes,6,opt,name=storage_location,json=storageLocation,proto3" json:"storage_location,omitempty"`
	// contains filtered or unexported fields
}

CreateVolumeRequest is the request message for the CreateVolume API.

func (*CreateVolumeRequest) Descriptor deprecated 

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

Deprecated: Use CreateVolumeRequest.ProtoReflect.Descriptor instead.

func (*CreateVolumeRequest) GetCatalogName 

func (x *CreateVolumeRequest) GetCatalogName() string

func (*CreateVolumeRequest) GetComment 

func (x *CreateVolumeRequest) GetComment() string

func (*CreateVolumeRequest) GetName 

func (x *CreateVolumeRequest) GetName() string

func (*CreateVolumeRequest) GetSchemaName 

func (x *CreateVolumeRequest) GetSchemaName() string

func (*CreateVolumeRequest) GetStorageLocation 

func (x *CreateVolumeRequest) GetStorageLocation() string

func (*CreateVolumeRequest) GetVolumeType 

func (x *CreateVolumeRequest) GetVolumeType() VolumeType

func (*CreateVolumeRequest) ProtoMessage 

func (*CreateVolumeRequest) ProtoMessage()

func (*CreateVolumeRequest) ProtoReflect 

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

func (*CreateVolumeRequest) Reset 

func (x *CreateVolumeRequest) Reset()

func (*CreateVolumeRequest) String 

func (x *CreateVolumeRequest) String() string

type CreateVolumeResponse 

type CreateVolumeResponse struct {
	Volume *Volume `protobuf:"bytes,1,opt,name=volume,proto3" json:"volume,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateVolumeResponse) Descriptor deprecated 

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

Deprecated: Use CreateVolumeResponse.ProtoReflect.Descriptor instead.

func (*CreateVolumeResponse) GetVolume 

func (x *CreateVolumeResponse) GetVolume() *Volume

func (*CreateVolumeResponse) ProtoMessage 

func (*CreateVolumeResponse) ProtoMessage()

func (*CreateVolumeResponse) ProtoReflect 

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

func (*CreateVolumeResponse) Reset 

func (x *CreateVolumeResponse) Reset()

func (*CreateVolumeResponse) String 

func (x *CreateVolumeResponse) String() string

type DataSourceFormat 

type DataSourceFormat int32
const (
	DataSourceFormat_DATA_SOURCE_FORMAT_UNSPECIFIED DataSourceFormat = 0
	DataSourceFormat_DATA_SOURCE_FORMAT_CSV         DataSourceFormat = 1
	DataSourceFormat_DATA_SOURCE_FORMAT_JSON        DataSourceFormat = 2
	DataSourceFormat_DATA_SOURCE_FORMAT_PARQUET     DataSourceFormat = 3
	DataSourceFormat_DATA_SOURCE_FORMAT_DELTA       DataSourceFormat = 4
	DataSourceFormat_DATA_SOURCE_FORMAT_ORC         DataSourceFormat = 5
	DataSourceFormat_DATA_SOURCE_FORMAT_TEXT        DataSourceFormat = 6
	DataSourceFormat_DATA_SOURCE_FORMAT_AVRO        DataSourceFormat = 7
)

func (DataSourceFormat) Descriptor 

func (DataSourceFormat) Descriptor() protoreflect.EnumDescriptor

func (DataSourceFormat) Enum 

func (x DataSourceFormat) Enum() *DataSourceFormat

func (DataSourceFormat) EnumDescriptor deprecated 

func (DataSourceFormat) EnumDescriptor() ([]byte, []int)

Deprecated: Use DataSourceFormat.Descriptor instead.

func (DataSourceFormat) Number 

func (x DataSourceFormat) Number() protoreflect.EnumNumber

func (DataSourceFormat) String 

func (x DataSourceFormat) String() string

func (DataSourceFormat) Type 

func (DataSourceFormat) Type() protoreflect.EnumType

type DeleteCatalogRequest 

type DeleteCatalogRequest struct {

	// The name of the catalog to delete.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// If set to true, the catalog will be deleted even if it is not empty.
	Force bool `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteCatalogRequest) Descriptor deprecated 

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

Deprecated: Use DeleteCatalogRequest.ProtoReflect.Descriptor instead.

func (*DeleteCatalogRequest) GetForce 

func (x *DeleteCatalogRequest) GetForce() bool

func (*DeleteCatalogRequest) GetName 

func (x *DeleteCatalogRequest) GetName() string

func (*DeleteCatalogRequest) ProtoMessage 

func (*DeleteCatalogRequest) ProtoMessage()

func (*DeleteCatalogRequest) ProtoReflect 

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

func (*DeleteCatalogRequest) Reset 

func (x *DeleteCatalogRequest) Reset()

func (*DeleteCatalogRequest) String 

func (x *DeleteCatalogRequest) String() string

type DeleteCatalogResponse 

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

func (*DeleteCatalogResponse) Descriptor deprecated 

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

Deprecated: Use DeleteCatalogResponse.ProtoReflect.Descriptor instead.

func (*DeleteCatalogResponse) ProtoMessage 

func (*DeleteCatalogResponse) ProtoMessage()

func (*DeleteCatalogResponse) ProtoReflect 

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

func (*DeleteCatalogResponse) Reset 

func (x *DeleteCatalogResponse) Reset()

func (*DeleteCatalogResponse) String 

func (x *DeleteCatalogResponse) String() string

type DeleteFunctionRequest 

type DeleteFunctionRequest struct {

	// The three-level (fully qualified) name of the function.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteFunctionRequest) Descriptor deprecated 

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

Deprecated: Use DeleteFunctionRequest.ProtoReflect.Descriptor instead.

func (*DeleteFunctionRequest) GetName 

func (x *DeleteFunctionRequest) GetName() string

func (*DeleteFunctionRequest) ProtoMessage 

func (*DeleteFunctionRequest) ProtoMessage()

func (*DeleteFunctionRequest) ProtoReflect 

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

func (*DeleteFunctionRequest) Reset 

func (x *DeleteFunctionRequest) Reset()

func (*DeleteFunctionRequest) String 

func (x *DeleteFunctionRequest) String() string

type DeleteFunctionResponse 

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

func (*DeleteFunctionResponse) Descriptor deprecated 

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

Deprecated: Use DeleteFunctionResponse.ProtoReflect.Descriptor instead.

func (*DeleteFunctionResponse) ProtoMessage 

func (*DeleteFunctionResponse) ProtoMessage()

func (*DeleteFunctionResponse) ProtoReflect 

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

func (*DeleteFunctionResponse) Reset 

func (x *DeleteFunctionResponse) Reset()

func (*DeleteFunctionResponse) String 

func (x *DeleteFunctionResponse) String() string

type DeleteSchemaRequest 

type DeleteSchemaRequest struct {

	// Full name of the schema.
	FullName string `protobuf:"bytes,1,opt,name=full_name,json=fullName,proto3" json:"full_name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteSchemaRequest) Descriptor deprecated 

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

Deprecated: Use DeleteSchemaRequest.ProtoReflect.Descriptor instead.

func (*DeleteSchemaRequest) GetFullName 

func (x *DeleteSchemaRequest) GetFullName() string

func (*DeleteSchemaRequest) ProtoMessage 

func (*DeleteSchemaRequest) ProtoMessage()

func (*DeleteSchemaRequest) ProtoReflect 

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

func (*DeleteSchemaRequest) Reset 

func (x *DeleteSchemaRequest) Reset()

func (*DeleteSchemaRequest) String 

func (x *DeleteSchemaRequest) String() string

type DeleteSchemaResponse 

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

func (*DeleteSchemaResponse) Descriptor deprecated 

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

Deprecated: Use DeleteSchemaResponse.ProtoReflect.Descriptor instead.

func (*DeleteSchemaResponse) ProtoMessage 

func (*DeleteSchemaResponse) ProtoMessage()

func (*DeleteSchemaResponse) ProtoReflect 

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

func (*DeleteSchemaResponse) Reset 

func (x *DeleteSchemaResponse) Reset()

func (*DeleteSchemaResponse) String 

func (x *DeleteSchemaResponse) String() string

type DeleteTableRequest 

type DeleteTableRequest struct {

	// Full name of the table.
	FullName string `protobuf:"bytes,1,opt,name=full_name,json=fullName,proto3" json:"full_name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteTableRequest) Descriptor deprecated 

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

Deprecated: Use DeleteTableRequest.ProtoReflect.Descriptor instead.

func (*DeleteTableRequest) GetFullName 

func (x *DeleteTableRequest) GetFullName() string

func (*DeleteTableRequest) ProtoMessage 

func (*DeleteTableRequest) ProtoMessage()

func (*DeleteTableRequest) ProtoReflect 

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

func (*DeleteTableRequest) Reset 

func (x *DeleteTableRequest) Reset()

func (*DeleteTableRequest) String 

func (x *DeleteTableRequest) String() string

type DeleteTableResponse 

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

func (*DeleteTableResponse) Descriptor deprecated 

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

Deprecated: Use DeleteTableResponse.ProtoReflect.Descriptor instead.

func (*DeleteTableResponse) ProtoMessage 

func (*DeleteTableResponse) ProtoMessage()

func (*DeleteTableResponse) ProtoReflect 

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

func (*DeleteTableResponse) Reset 

func (x *DeleteTableResponse) Reset()

func (*DeleteTableResponse) String 

func (x *DeleteTableResponse) String() string

type DeleteVolumeRequest 

type DeleteVolumeRequest struct {

	// The three-level (fully qualified) name of the volume.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteVolumeRequest) Descriptor deprecated 

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

Deprecated: Use DeleteVolumeRequest.ProtoReflect.Descriptor instead.

func (*DeleteVolumeRequest) GetName 

func (x *DeleteVolumeRequest) GetName() string

func (*DeleteVolumeRequest) ProtoMessage 

func (*DeleteVolumeRequest) ProtoMessage()

func (*DeleteVolumeRequest) ProtoReflect 

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

func (*DeleteVolumeRequest) Reset 

func (x *DeleteVolumeRequest) Reset()

func (*DeleteVolumeRequest) String 

func (x *DeleteVolumeRequest) String() string

type DeleteVolumeResponse 

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

func (*DeleteVolumeResponse) Descriptor deprecated 

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

Deprecated: Use DeleteVolumeResponse.ProtoReflect.Descriptor instead.

func (*DeleteVolumeResponse) ProtoMessage 

func (*DeleteVolumeResponse) ProtoMessage()

func (*DeleteVolumeResponse) ProtoReflect 

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

func (*DeleteVolumeResponse) Reset 

func (x *DeleteVolumeResponse) Reset()

func (*DeleteVolumeResponse) String 

func (x *DeleteVolumeResponse) String() string

type Dependency 

type Dependency struct {
	Table    *TableDependency    `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	Function *FunctionDependency `protobuf:"bytes,2,opt,name=function,proto3" json:"function,omitempty"`
	// contains filtered or unexported fields
}

A dependency of a SQL object. Either the `table` field or the `function` field must be defined.

func (*Dependency) Descriptor deprecated 

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

Deprecated: Use Dependency.ProtoReflect.Descriptor instead.

func (*Dependency) GetFunction 

func (x *Dependency) GetFunction() *FunctionDependency

func (*Dependency) GetTable 

func (x *Dependency) GetTable() *TableDependency

func (*Dependency) ProtoMessage 

func (*Dependency) ProtoMessage()

func (*Dependency) ProtoReflect 

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

func (*Dependency) Reset 

func (x *Dependency) Reset()

func (*Dependency) String 

func (x *Dependency) String() string

type DependencyList 

type DependencyList struct {

	// A list of dependencies
	Dependencies []*Dependency `protobuf:"bytes,1,rep,name=dependencies,proto3" json:"dependencies,omitempty"`
	// contains filtered or unexported fields
}

func (*DependencyList) Descriptor deprecated 

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

Deprecated: Use DependencyList.ProtoReflect.Descriptor instead.

func (*DependencyList) GetDependencies 

func (x *DependencyList) GetDependencies() []*Dependency

func (*DependencyList) ProtoMessage 

func (*DependencyList) ProtoMessage()

func (*DependencyList) ProtoReflect 

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

func (*DependencyList) Reset 

func (x *DependencyList) Reset()

func (*DependencyList) String 

func (x *DependencyList) String() string

type FunctionDependency 

type FunctionDependency struct {

	// Full name of the dependent function, in the form of catalog_name.schema_name.function_name
	FunctionFullName string `protobuf:"bytes,1,opt,name=function_full_name,json=functionFullName,proto3" json:"function_full_name,omitempty"`
	// contains filtered or unexported fields
}

func (*FunctionDependency) Descriptor deprecated 

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

Deprecated: Use FunctionDependency.ProtoReflect.Descriptor instead.

func (*FunctionDependency) GetFunctionFullName 

func (x *FunctionDependency) GetFunctionFullName() string

func (*FunctionDependency) ProtoMessage 

func (*FunctionDependency) ProtoMessage()

func (*FunctionDependency) ProtoReflect 

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

func (*FunctionDependency) Reset 

func (x *FunctionDependency) Reset()

func (*FunctionDependency) String 

func (x *FunctionDependency) String() string

type FunctionInfo 

type FunctionInfo struct {

	// Unique identifier for the function.
	FunctionId string `protobuf:"bytes,1,opt,name=function_id,json=functionId,proto3" json:"function_id,omitempty"`
	// The name of the catalog where the schema and the function are
	CatalogName string `protobuf:"bytes,2,opt,name=catalog_name,json=catalogName,proto3" json:"catalog_name,omitempty"`
	// The name of the schema where the function is
	SchemaName string `protobuf:"bytes,3,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"`
	// The name of the function, relative to parent schema.
	Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	// Specific name of the function; reserved for future use
	SpecificName string `protobuf:"bytes,5,opt,name=specific_name,json=specificName,proto3" json:"specific_name,omitempty"`
	// The comment attached to the function
	Comment string `protobuf:"bytes,6,opt,name=comment,proto3" json:"comment,omitempty"`
	// The time at which the function was created.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// The time at which the function was last updated.
	UpdatedAt   *timestamppb.Timestamp  `protobuf:"bytes,8,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	InputParams *FunctionParameterInfos `protobuf:"bytes,9,opt,name=input_params,json=inputParams,proto3" json:"input_params,omitempty"`
	// Name of the type (INT, STRUCT, MAP, etc.)
	DataType ColumnTypeName `protobuf:"varint,10,opt,name=data_type,json=dataType,proto3,enum=omega_catalog.v1.ColumnTypeName" json:"data_type,omitempty"`
	// Pretty printed function data type
	FullDataType string                  `protobuf:"bytes,11,opt,name=full_data_type,json=fullDataType,proto3" json:"full_data_type,omitempty"`
	ReturnParams *FunctionParameterInfos `protobuf:"bytes,12,opt,name=return_params,json=returnParams,proto3" json:"return_params,omitempty"`
	// Function language. When EXTERNAL is used, the language
	// of the routine function should be specified in the
	// external_language field, and the return_params of the function
	// cannot be used (as TABLE return type is not supported),
	// and the sql_data_access field must be NO_SQL.
	RoutineBody FunctionLanguage `` /* 135-byte string literal not displayed */
	// Function body
	RoutineDefinition string `protobuf:"bytes,14,opt,name=routine_definition,json=routineDefinition,proto3" json:"routine_definition,omitempty"`
	// A list of dependencies
	RoutineDependencies *DependencyList `protobuf:"bytes,15,opt,name=routine_dependencies,json=routineDependencies,proto3" json:"routine_dependencies,omitempty"`
	// Function parameter style. S is the value for SQL.
	ParameterStyle ParameterStyle `` /* 142-byte string literal not displayed */
	// Whether the function is deterministic.
	IsDeterministic bool `protobuf:"varint,17,opt,name=is_deterministic,json=isDeterministic,proto3" json:"is_deterministic,omitempty"`
	// Function SQL data access.
	SqlDataAccess SQLDataAccess `` /* 140-byte string literal not displayed */
	// Function null call.
	IsNullCall bool `protobuf:"varint,19,opt,name=is_null_call,json=isNullCall,proto3" json:"is_null_call,omitempty"`
	// Function security type.
	SecurityType FunctionSecurityType `` /* 142-byte string literal not displayed */
	// Properties of the function.
	Properties map[string]string `` /* 162-byte string literal not displayed */
	// Full name of the function, in form of catalog.schema.function
	FullName string `protobuf:"bytes,22,opt,name=full_name,json=fullName,proto3" json:"full_name,omitempty"`
	// External language of the function.
	ExternalLanguage string `protobuf:"bytes,23,opt,name=external_language,json=externalLanguage,proto3" json:"external_language,omitempty"`
	// contains filtered or unexported fields
}

func (*FunctionInfo) Descriptor deprecated 

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

Deprecated: Use FunctionInfo.ProtoReflect.Descriptor instead.

func (*FunctionInfo) GetCatalogName 

func (x *FunctionInfo) GetCatalogName() string

func (*FunctionInfo) GetComment 

func (x *FunctionInfo) GetComment() string

func (*FunctionInfo) GetCreatedAt 

func (x *FunctionInfo) GetCreatedAt() *timestamppb.Timestamp

func (*FunctionInfo) GetDataType 

func (x *FunctionInfo) GetDataType() ColumnTypeName

func (*FunctionInfo) GetExternalLanguage 

func (x *FunctionInfo) GetExternalLanguage() string

func (*FunctionInfo) GetFullDataType 

func (x *FunctionInfo) GetFullDataType() string

func (*FunctionInfo) GetFullName 

func (x *FunctionInfo) GetFullName() string

func (*FunctionInfo) GetFunctionId 

func (x *FunctionInfo) GetFunctionId() string

func (*FunctionInfo) GetInputParams 

func (x *FunctionInfo) GetInputParams() *FunctionParameterInfos

func (*FunctionInfo) GetIsDeterministic 

func (x *FunctionInfo) GetIsDeterministic() bool

func (*FunctionInfo) GetIsNullCall 

func (x *FunctionInfo) GetIsNullCall() bool

func (*FunctionInfo) GetName 

func (x *FunctionInfo) GetName() string

func (*FunctionInfo) GetParameterStyle 

func (x *FunctionInfo) GetParameterStyle() ParameterStyle

func (*FunctionInfo) GetProperties 

func (x *FunctionInfo) GetProperties() map[string]string

func (*FunctionInfo) GetReturnParams 

func (x *FunctionInfo) GetReturnParams() *FunctionParameterInfos

func (*FunctionInfo) GetRoutineBody 

func (x *FunctionInfo) GetRoutineBody() FunctionLanguage

func (*FunctionInfo) GetRoutineDefinition 

func (x *FunctionInfo) GetRoutineDefinition() string

func (*FunctionInfo) GetRoutineDependencies 

func (x *FunctionInfo) GetRoutineDependencies() *DependencyList

func (*FunctionInfo) GetSchemaName 

func (x *FunctionInfo) GetSchemaName() string

func (*FunctionInfo) GetSecurityType 

func (x *FunctionInfo) GetSecurityType() FunctionSecurityType

func (*FunctionInfo) GetSpecificName 

func (x *FunctionInfo) GetSpecificName() string

func (*FunctionInfo) GetSqlDataAccess 

func (x *FunctionInfo) GetSqlDataAccess() SQLDataAccess

func (*FunctionInfo) GetUpdatedAt 

func (x *FunctionInfo) GetUpdatedAt() *timestamppb.Timestamp

func (*FunctionInfo) ProtoMessage 

func (*FunctionInfo) ProtoMessage()

func (*FunctionInfo) ProtoReflect 

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

func (*FunctionInfo) Reset 

func (x *FunctionInfo) Reset()

func (*FunctionInfo) String 

func (x *FunctionInfo) String() string

type FunctionLanguage 

type FunctionLanguage int32
const (
	FunctionLanguage_FUNCTION_LANGUAGE_UNSPECIFIED FunctionLanguage = 0
	FunctionLanguage_FUNCTION_LANGUAGE_SQL         FunctionLanguage = 1
	FunctionLanguage_FUNCTION_LANGUAGE_EXTERNAL    FunctionLanguage = 2
)

func (FunctionLanguage) Descriptor 

func (FunctionLanguage) Descriptor() protoreflect.EnumDescriptor

func (FunctionLanguage) Enum 

func (x FunctionLanguage) Enum() *FunctionLanguage

func (FunctionLanguage) EnumDescriptor deprecated 

func (FunctionLanguage) EnumDescriptor() ([]byte, []int)

Deprecated: Use FunctionLanguage.Descriptor instead.

func (FunctionLanguage) Number 

func (x FunctionLanguage) Number() protoreflect.EnumNumber

func (FunctionLanguage) String 

func (x FunctionLanguage) String() string

func (FunctionLanguage) Type 

func (FunctionLanguage) Type() protoreflect.EnumType

type FunctionParameterInfo 

type FunctionParameterInfo struct {

	// Name of the parameter
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Full data type spec, SQL/catalogString text.
	TypeText string `protobuf:"bytes,2,opt,name=type_text,json=typeText,proto3" json:"type_text,omitempty"`
	// Full data type sepc, JSON-serialized
	TypeJson string `protobuf:"bytes,3,opt,name=type_json,json=typeJson,proto3" json:"type_json,omitempty"`
	// Name of the type (INT, STRUCT, MAP, etc.)
	TypeName ColumnTypeName `protobuf:"varint,4,opt,name=type_name,json=typeName,proto3,enum=omega_catalog.v1.ColumnTypeName" json:"type_name,omitempty"`
	// Digits of precision; required on Create for DecimalTypes
	TypePrecision int32 `protobuf:"varint,5,opt,name=type_precision,json=typePrecision,proto3" json:"type_precision,omitempty"`
	// Digits to the right of decimal; required on Create for DecimalTypes
	TypeScale int32 `protobuf:"varint,6,opt,name=type_scale,json=typeScale,proto3" json:"type_scale,omitempty"`
	// Format of IntervalType
	TypeIntervalType string `protobuf:"bytes,7,opt,name=type_interval_type,json=typeIntervalType,proto3" json:"type_interval_type,omitempty"`
	// Ordinal position of column (starting at position 0)
	Position int32 `protobuf:"varint,8,opt,name=position,proto3" json:"position,omitempty"`
	// The mode of the function parameter.
	ParameterMode FunctionParameterMode `` /* 145-byte string literal not displayed */
	// The type of function parameter.
	ParameterType FunctionParameterType `` /* 146-byte string literal not displayed */
	// The default value of the parameter.
	ParameterDefault string `protobuf:"bytes,11,opt,name=parameter_default,json=parameterDefault,proto3" json:"parameter_default,omitempty"`
	// User-provided free-form text description.
	Comment string `protobuf:"bytes,12,opt,name=comment,proto3" json:"comment,omitempty"`
	// contains filtered or unexported fields
}

func (*FunctionParameterInfo) Descriptor deprecated 

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

Deprecated: Use FunctionParameterInfo.ProtoReflect.Descriptor instead.

func (*FunctionParameterInfo) GetComment 

func (x *FunctionParameterInfo) GetComment() string

func (*FunctionParameterInfo) GetName 

func (x *FunctionParameterInfo) GetName() string

func (*FunctionParameterInfo) GetParameterDefault 

func (x *FunctionParameterInfo) GetParameterDefault() string

func (*FunctionParameterInfo) GetParameterMode 

func (x *FunctionParameterInfo) GetParameterMode() FunctionParameterMode

func (*FunctionParameterInfo) GetParameterType 

func (x *FunctionParameterInfo) GetParameterType() FunctionParameterType

func (*FunctionParameterInfo) GetPosition 

func (x *FunctionParameterInfo) GetPosition() int32

func (*FunctionParameterInfo) GetTypeIntervalType 

func (x *FunctionParameterInfo) GetTypeIntervalType() string

func (*FunctionParameterInfo) GetTypeJson 

func (x *FunctionParameterInfo) GetTypeJson() string

func (*FunctionParameterInfo) GetTypeName 

func (x *FunctionParameterInfo) GetTypeName() ColumnTypeName

func (*FunctionParameterInfo) GetTypePrecision 

func (x *FunctionParameterInfo) GetTypePrecision() int32

func (*FunctionParameterInfo) GetTypeScale 

func (x *FunctionParameterInfo) GetTypeScale() int32

func (*FunctionParameterInfo) GetTypeText 

func (x *FunctionParameterInfo) GetTypeText() string

func (*FunctionParameterInfo) ProtoMessage 

func (*FunctionParameterInfo) ProtoMessage()

func (*FunctionParameterInfo) ProtoReflect 

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

func (*FunctionParameterInfo) Reset 

func (x *FunctionParameterInfo) Reset()

func (*FunctionParameterInfo) String 

func (x *FunctionParameterInfo) String() string

type FunctionParameterInfos 

type FunctionParameterInfos struct {

	// The array of FunctionParameterInfo definitions of the function's parameters
	Parameters []*FunctionParameterInfo `protobuf:"bytes,1,rep,name=parameters,proto3" json:"parameters,omitempty"`
	// contains filtered or unexported fields
}

func (*FunctionParameterInfos) Descriptor deprecated 

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

Deprecated: Use FunctionParameterInfos.ProtoReflect.Descriptor instead.

func (*FunctionParameterInfos) GetParameters 

func (x *FunctionParameterInfos) GetParameters() []*FunctionParameterInfo

func (*FunctionParameterInfos) ProtoMessage 

func (*FunctionParameterInfos) ProtoMessage()

func (*FunctionParameterInfos) ProtoReflect 

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

func (*FunctionParameterInfos) Reset 

func (x *FunctionParameterInfos) Reset()

func (*FunctionParameterInfos) String 

func (x *FunctionParameterInfos) String() string

type FunctionParameterMode 

type FunctionParameterMode int32
const (
	FunctionParameterMode_FUNCTION_PARAMETER_MODE_UNSPECIFIED FunctionParameterMode = 0
	FunctionParameterMode_FUNCTION_PARAMETER_MODE_IN          FunctionParameterMode = 1
)

func (FunctionParameterMode) Descriptor 

func (FunctionParameterMode) Descriptor() protoreflect.EnumDescriptor

func (FunctionParameterMode) Enum 

func (x FunctionParameterMode) Enum() *FunctionParameterMode

func (FunctionParameterMode) EnumDescriptor deprecated 

func (FunctionParameterMode) EnumDescriptor() ([]byte, []int)

Deprecated: Use FunctionParameterMode.Descriptor instead.

func (FunctionParameterMode) Number 

func (x FunctionParameterMode) Number() protoreflect.EnumNumber

func (FunctionParameterMode) String 

func (x FunctionParameterMode) String() string

func (FunctionParameterMode) Type 

func (FunctionParameterMode) Type() protoreflect.EnumType

type FunctionParameterType 

type FunctionParameterType int32
const (
	FunctionParameterType_FUNCTION_PARAMETER_TYPE_UNSPECIFIED FunctionParameterType = 0
	FunctionParameterType_FUNCTION_PARAMETER_TYPE_PARAM       FunctionParameterType = 1
	FunctionParameterType_FUNCTION_PARAMETER_TYPE_COLUMN      FunctionParameterType = 2
)

func (FunctionParameterType) Descriptor 

func (FunctionParameterType) Descriptor() protoreflect.EnumDescriptor

func (FunctionParameterType) Enum 

func (x FunctionParameterType) Enum() *FunctionParameterType

func (FunctionParameterType) EnumDescriptor deprecated 

func (FunctionParameterType) EnumDescriptor() ([]byte, []int)

Deprecated: Use FunctionParameterType.Descriptor instead.

func (FunctionParameterType) Number 

func (x FunctionParameterType) Number() protoreflect.EnumNumber

func (FunctionParameterType) String 

func (x FunctionParameterType) String() string

func (FunctionParameterType) Type 

func (FunctionParameterType) Type() protoreflect.EnumType

type FunctionSecurityType 

type FunctionSecurityType int32
const (
	FunctionSecurityType_FUNCTION_SECURITY_TYPE_UNSPECIFIED FunctionSecurityType = 0
	FunctionSecurityType_FUNCTION_SECURITY_TYPE_DEFINER     FunctionSecurityType = 1
)

func (FunctionSecurityType) Descriptor 

func (FunctionSecurityType) Descriptor() protoreflect.EnumDescriptor

func (FunctionSecurityType) Enum 

func (x FunctionSecurityType) Enum() *FunctionSecurityType

func (FunctionSecurityType) EnumDescriptor deprecated 

func (FunctionSecurityType) EnumDescriptor() ([]byte, []int)

Deprecated: Use FunctionSecurityType.Descriptor instead.

func (FunctionSecurityType) Number 

func (x FunctionSecurityType) Number() protoreflect.EnumNumber

func (FunctionSecurityType) String 

func (x FunctionSecurityType) String() string

func (FunctionSecurityType) Type 

func (FunctionSecurityType) Type() protoreflect.EnumType

type GetCatalogRequest 

type GetCatalogRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCatalogRequest) Descriptor deprecated 

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

Deprecated: Use GetCatalogRequest.ProtoReflect.Descriptor instead.

func (*GetCatalogRequest) GetName 

func (x *GetCatalogRequest) GetName() string

func (*GetCatalogRequest) ProtoMessage 

func (*GetCatalogRequest) ProtoMessage()

func (*GetCatalogRequest) ProtoReflect 

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

func (*GetCatalogRequest) Reset 

func (x *GetCatalogRequest) Reset()

func (*GetCatalogRequest) String 

func (x *GetCatalogRequest) String() string

type GetCatalogResponse 

type GetCatalogResponse struct {
	Catalog *Catalog `protobuf:"bytes,1,opt,name=catalog,proto3" json:"catalog,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCatalogResponse) Descriptor deprecated 

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

Deprecated: Use GetCatalogResponse.ProtoReflect.Descriptor instead.

func (*GetCatalogResponse) GetCatalog 

func (x *GetCatalogResponse) GetCatalog() *Catalog

func (*GetCatalogResponse) ProtoMessage 

func (*GetCatalogResponse) ProtoMessage()

func (*GetCatalogResponse) ProtoReflect 

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

func (*GetCatalogResponse) Reset 

func (x *GetCatalogResponse) Reset()

func (*GetCatalogResponse) String 

func (x *GetCatalogResponse) String() string

type GetFunctionRequest 

type GetFunctionRequest struct {

	// The three-level (fully qualified) name of the function.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFunctionRequest) Descriptor deprecated 

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

Deprecated: Use GetFunctionRequest.ProtoReflect.Descriptor instead.

func (*GetFunctionRequest) GetName 

func (x *GetFunctionRequest) GetName() string

func (*GetFunctionRequest) ProtoMessage 

func (*GetFunctionRequest) ProtoMessage()

func (*GetFunctionRequest) ProtoReflect 

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

func (*GetFunctionRequest) Reset 

func (x *GetFunctionRequest) Reset()

func (*GetFunctionRequest) String 

func (x *GetFunctionRequest) String() string

type GetFunctionResponse 

type GetFunctionResponse struct {
	Function *FunctionInfo `protobuf:"bytes,1,opt,name=function,proto3" json:"function,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFunctionResponse) Descriptor deprecated 

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

Deprecated: Use GetFunctionResponse.ProtoReflect.Descriptor instead.

func (*GetFunctionResponse) GetFunction 

func (x *GetFunctionResponse) GetFunction() *FunctionInfo

func (*GetFunctionResponse) ProtoMessage 

func (*GetFunctionResponse) ProtoMessage()

func (*GetFunctionResponse) ProtoReflect 

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

func (*GetFunctionResponse) Reset 

func (x *GetFunctionResponse) Reset()

func (*GetFunctionResponse) String 

func (x *GetFunctionResponse) String() string

type GetSchemaRequest 

type GetSchemaRequest struct {

	// Full name of the schema.
	FullName string `protobuf:"bytes,1,opt,name=full_name,json=fullName,proto3" json:"full_name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSchemaRequest) Descriptor deprecated 

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

Deprecated: Use GetSchemaRequest.ProtoReflect.Descriptor instead.

func (*GetSchemaRequest) GetFullName 

func (x *GetSchemaRequest) GetFullName() string

func (*GetSchemaRequest) ProtoMessage 

func (*GetSchemaRequest) ProtoMessage()

func (*GetSchemaRequest) ProtoReflect 

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

func (*GetSchemaRequest) Reset 

func (x *GetSchemaRequest) Reset()

func (*GetSchemaRequest) String 

func (x *GetSchemaRequest) String() string

type GetSchemaResponse 

type GetSchemaResponse struct {
	Schema *Schema `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSchemaResponse) Descriptor deprecated 

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

Deprecated: Use GetSchemaResponse.ProtoReflect.Descriptor instead.

func (*GetSchemaResponse) GetSchema 

func (x *GetSchemaResponse) GetSchema() *Schema

func (*GetSchemaResponse) ProtoMessage 

func (*GetSchemaResponse) ProtoMessage()

func (*GetSchemaResponse) ProtoReflect 

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

func (*GetSchemaResponse) Reset 

func (x *GetSchemaResponse) Reset()

func (*GetSchemaResponse) String 

func (x *GetSchemaResponse) String() string

type GetTableRequest 

type GetTableRequest struct {

	// Full name of the table.
	FullName string `protobuf:"bytes,1,opt,name=full_name,json=fullName,proto3" json:"full_name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTableRequest) Descriptor deprecated 

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

Deprecated: Use GetTableRequest.ProtoReflect.Descriptor instead.

func (*GetTableRequest) GetFullName 

func (x *GetTableRequest) GetFullName() string

func (*GetTableRequest) ProtoMessage 

func (*GetTableRequest) ProtoMessage()

func (*GetTableRequest) ProtoReflect 

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

func (*GetTableRequest) Reset 

func (x *GetTableRequest) Reset()

func (*GetTableRequest) String 

func (x *GetTableRequest) String() string

type GetTableResponse 

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

func (*GetTableResponse) Descriptor deprecated 

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

Deprecated: Use GetTableResponse.ProtoReflect.Descriptor instead.

func (*GetTableResponse) GetTable 

func (x *GetTableResponse) GetTable() *Table

func (*GetTableResponse) ProtoMessage 

func (*GetTableResponse) ProtoMessage()

func (*GetTableResponse) ProtoReflect 

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

func (*GetTableResponse) Reset 

func (x *GetTableResponse) Reset()

func (*GetTableResponse) String 

func (x *GetTableResponse) String() string

type GetVolumeRequest 

type GetVolumeRequest struct {

	// The three-level (fully qualified) name of the volume.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetVolumeRequest) Descriptor deprecated 

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

Deprecated: Use GetVolumeRequest.ProtoReflect.Descriptor instead.

func (*GetVolumeRequest) GetName 

func (x *GetVolumeRequest) GetName() string

func (*GetVolumeRequest) ProtoMessage 

func (*GetVolumeRequest) ProtoMessage()

func (*GetVolumeRequest) ProtoReflect 

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

func (*GetVolumeRequest) Reset 

func (x *GetVolumeRequest) Reset()

func (*GetVolumeRequest) String 

func (x *GetVolumeRequest) String() string

type GetVolumeResponse 

type GetVolumeResponse struct {
	Volume *Volume `protobuf:"bytes,1,opt,name=volume,proto3" json:"volume,omitempty"`
	// contains filtered or unexported fields
}

func (*GetVolumeResponse) Descriptor deprecated 

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

Deprecated: Use GetVolumeResponse.ProtoReflect.Descriptor instead.

func (*GetVolumeResponse) GetVolume 

func (x *GetVolumeResponse) GetVolume() *Volume

func (*GetVolumeResponse) ProtoMessage 

func (*GetVolumeResponse) ProtoMessage()

func (*GetVolumeResponse) ProtoReflect 

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

func (*GetVolumeResponse) Reset 

func (x *GetVolumeResponse) Reset()

func (*GetVolumeResponse) String 

func (x *GetVolumeResponse) String() string

type ListCatalogsRequest 

type ListCatalogsRequest struct {

	// Opaque pagination token to go to the next page on previous query
	PageToken string `protobuf:"bytes,1,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Maximum number of catalogs to return.
	// - when set to a value greater than 0, the page length is the maximum;
	// - when set to 0, the page length is set to a server configured value;
	// - when set to a value less than 0, an invalid parameter error is returned;
	MaxResults int32 `protobuf:"varint,2,opt,name=max_results,json=maxResults,proto3" json:"max_results,omitempty"`
	// contains filtered or unexported fields
}

func (*ListCatalogsRequest) Descriptor deprecated 

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

Deprecated: Use ListCatalogsRequest.ProtoReflect.Descriptor instead.

func (*ListCatalogsRequest) GetMaxResults 

func (x *ListCatalogsRequest) GetMaxResults() int32

func (*ListCatalogsRequest) GetPageToken 

func (x *ListCatalogsRequest) GetPageToken() string

func (*ListCatalogsRequest) ProtoMessage 

func (*ListCatalogsRequest) ProtoMessage()

func (*ListCatalogsRequest) ProtoReflect 

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

func (*ListCatalogsRequest) Reset 

func (x *ListCatalogsRequest) Reset()

func (*ListCatalogsRequest) String 

func (x *ListCatalogsRequest) String() string

type ListCatalogsResponse 

type ListCatalogsResponse struct {
	Catalogs      []*Catalog `protobuf:"bytes,1,rep,name=catalogs,proto3" json:"catalogs,omitempty"`
	NextPageToken string     `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListCatalogsResponse) Descriptor deprecated 

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

Deprecated: Use ListCatalogsResponse.ProtoReflect.Descriptor instead.

func (*ListCatalogsResponse) GetCatalogs 

func (x *ListCatalogsResponse) GetCatalogs() []*Catalog

func (*ListCatalogsResponse) GetNextPageToken 

func (x *ListCatalogsResponse) GetNextPageToken() string

func (*ListCatalogsResponse) ProtoMessage 

func (*ListCatalogsResponse) ProtoMessage()

func (*ListCatalogsResponse) ProtoReflect 

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

func (*ListCatalogsResponse) Reset 

func (x *ListCatalogsResponse) Reset()

func (*ListCatalogsResponse) String 

func (x *ListCatalogsResponse) String() string

type ListFunctionsRequest 

type ListFunctionsRequest struct {

	// Opaque pagination token to go to the next page on previous query
	PageToken string `protobuf:"bytes,1,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Maximum number of functions to return.
	// - when set to a value greater than 0, the page length is the maximum;
	// - when set to 0, the page length is set to a server configured value;
	// - when set to a value less than 0, an invalid parameter error is returned;
	MaxResults int32 `protobuf:"varint,2,opt,name=max_results,json=maxResults,proto3" json:"max_results,omitempty"`
	// The identifier of the catalog.
	CatalogName string `protobuf:"bytes,3,opt,name=catalog_name,json=catalogName,proto3" json:"catalog_name,omitempty"`
	// The identifier of the schema.
	SchemaName string `protobuf:"bytes,4,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"`
	// contains filtered or unexported fields
}

func (*ListFunctionsRequest) Descriptor deprecated 

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

Deprecated: Use ListFunctionsRequest.ProtoReflect.Descriptor instead.

func (*ListFunctionsRequest) GetCatalogName 

func (x *ListFunctionsRequest) GetCatalogName() string

func (*ListFunctionsRequest) GetMaxResults 

func (x *ListFunctionsRequest) GetMaxResults() int32

func (*ListFunctionsRequest) GetPageToken 

func (x *ListFunctionsRequest) GetPageToken() string

func (*ListFunctionsRequest) GetSchemaName 

func (x *ListFunctionsRequest) GetSchemaName() string

func (*ListFunctionsRequest) ProtoMessage 

func (*ListFunctionsRequest) ProtoMessage()

func (*ListFunctionsRequest) ProtoReflect 

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

func (*ListFunctionsRequest) Reset 

func (x *ListFunctionsRequest) Reset()

func (*ListFunctionsRequest) String 

func (x *ListFunctionsRequest) String() string

type ListFunctionsResponse 

type ListFunctionsResponse struct {
	Functions     []*FunctionInfo `protobuf:"bytes,1,rep,name=functions,proto3" json:"functions,omitempty"`
	NextPageToken string          `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListFunctionsResponse) Descriptor deprecated 

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

Deprecated: Use ListFunctionsResponse.ProtoReflect.Descriptor instead.

func (*ListFunctionsResponse) GetFunctions 

func (x *ListFunctionsResponse) GetFunctions() []*FunctionInfo

func (*ListFunctionsResponse) GetNextPageToken 

func (x *ListFunctionsResponse) GetNextPageToken() string

func (*ListFunctionsResponse) ProtoMessage 

func (*ListFunctionsResponse) ProtoMessage()

func (*ListFunctionsResponse) ProtoReflect 

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

func (*ListFunctionsResponse) Reset 

func (x *ListFunctionsResponse) Reset()

func (*ListFunctionsResponse) String 

func (x *ListFunctionsResponse) String() string

type ListSchemasRequest 

type ListSchemasRequest struct {

	// Opaque pagination token to go to the next page on previous query
	PageToken string `protobuf:"bytes,1,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Maximum number of schemas to return.
	// - when set to a value greater than 0, the page length is the maximum;
	// - when set to 0, the page length is set to a server configured value;
	// - when set to a value less than 0, an invalid parameter error is returned;
	MaxResults int32 `protobuf:"varint,2,opt,name=max_results,json=maxResults,proto3" json:"max_results,omitempty"`
	// Name of parent catalog for schemas of interest.
	CatalogName string `protobuf:"bytes,3,opt,name=catalog_name,json=catalogName,proto3" json:"catalog_name,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSchemasRequest) Descriptor deprecated 

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

Deprecated: Use ListSchemasRequest.ProtoReflect.Descriptor instead.

func (*ListSchemasRequest) GetCatalogName 

func (x *ListSchemasRequest) GetCatalogName() string

func (*ListSchemasRequest) GetMaxResults 

func (x *ListSchemasRequest) GetMaxResults() int32

func (*ListSchemasRequest) GetPageToken 

func (x *ListSchemasRequest) GetPageToken() string

func (*ListSchemasRequest) ProtoMessage 

func (*ListSchemasRequest) ProtoMessage()

func (*ListSchemasRequest) ProtoReflect 

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

func (*ListSchemasRequest) Reset 

func (x *ListSchemasRequest) Reset()

func (*ListSchemasRequest) String 

func (x *ListSchemasRequest) String() string

type ListSchemasResponse 

type ListSchemasResponse struct {
	Schemas       []*Schema `protobuf:"bytes,1,rep,name=schemas,proto3" json:"schemas,omitempty"`
	NextPageToken string    `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSchemasResponse) Descriptor deprecated 

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

Deprecated: Use ListSchemasResponse.ProtoReflect.Descriptor instead.

func (*ListSchemasResponse) GetNextPageToken 

func (x *ListSchemasResponse) GetNextPageToken() string

func (*ListSchemasResponse) GetSchemas 

func (x *ListSchemasResponse) GetSchemas() []*Schema

func (*ListSchemasResponse) ProtoMessage 

func (*ListSchemasResponse) ProtoMessage()

func (*ListSchemasResponse) ProtoReflect 

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

func (*ListSchemasResponse) Reset 

func (x *ListSchemasResponse) Reset()

func (*ListSchemasResponse) String 

func (x *ListSchemasResponse) String() string

type ListTablesRequest 

type ListTablesRequest struct {

	// Opaque pagination token to go to the next page on previous query
	PageToken string `protobuf:"bytes,1,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Maximum number of tables to return.
	// - when set to a value greater than 0, the page length is the maximum;
	// - when set to 0, the page length is set to a server configured value;
	// - when set to a value less than 0, an invalid parameter error is returned;
	MaxResults int32 `protobuf:"varint,2,opt,name=max_results,json=maxResults,proto3" json:"max_results,omitempty"`
	// Name of parent catalog for tables of interest.
	CatalogName string `protobuf:"bytes,3,opt,name=catalog_name,json=catalogName,proto3" json:"catalog_name,omitempty"`
	// Parent schema of tables.
	SchemaName string `protobuf:"bytes,4,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTablesRequest) Descriptor deprecated 

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

Deprecated: Use ListTablesRequest.ProtoReflect.Descriptor instead.

func (*ListTablesRequest) GetCatalogName 

func (x *ListTablesRequest) GetCatalogName() string

func (*ListTablesRequest) GetMaxResults 

func (x *ListTablesRequest) GetMaxResults() int32

func (*ListTablesRequest) GetPageToken 

func (x *ListTablesRequest) GetPageToken() string

func (*ListTablesRequest) GetSchemaName 

func (x *ListTablesRequest) GetSchemaName() string

func (*ListTablesRequest) ProtoMessage 

func (*ListTablesRequest) ProtoMessage()

func (*ListTablesRequest) ProtoReflect 

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

func (*ListTablesRequest) Reset 

func (x *ListTablesRequest) Reset()

func (*ListTablesRequest) String 

func (x *ListTablesRequest) String() string

type ListTablesResponse 

type ListTablesResponse struct {
	Tables        []*Table `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"`
	NextPageToken string   `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTablesResponse) Descriptor deprecated 

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

Deprecated: Use ListTablesResponse.ProtoReflect.Descriptor instead.

func (*ListTablesResponse) GetNextPageToken 

func (x *ListTablesResponse) GetNextPageToken() string

func (*ListTablesResponse) GetTables 

func (x *ListTablesResponse) GetTables() []*Table

func (*ListTablesResponse) ProtoMessage 

func (*ListTablesResponse) ProtoMessage()

func (*ListTablesResponse) ProtoReflect 

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

func (*ListTablesResponse) Reset 

func (x *ListTablesResponse) Reset()

func (*ListTablesResponse) String 

func (x *ListTablesResponse) String() string

type ListVolumesRequest 

type ListVolumesRequest struct {

	// Opaque pagination token to go to the next page on previous query
	PageToken string `protobuf:"bytes,1,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Maximum number of volumes to return.
	// - when set to a value greater than 0, the page length is the maximum;
	// - when set to 0, the page length is set to a server configured value;
	// - when set to a value less than 0, an invalid parameter error is returned;
	MaxResults int32 `protobuf:"varint,2,opt,name=max_results,json=maxResults,proto3" json:"max_results,omitempty"`
	// The identifier of the catalog.
	CatalogName string `protobuf:"bytes,3,opt,name=catalog_name,json=catalogName,proto3" json:"catalog_name,omitempty"`
	// The identifier of the schema.
	SchemaName string `protobuf:"bytes,4,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"`
	// contains filtered or unexported fields
}

func (*ListVolumesRequest) Descriptor deprecated 

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

Deprecated: Use ListVolumesRequest.ProtoReflect.Descriptor instead.

func (*ListVolumesRequest) GetCatalogName 

func (x *ListVolumesRequest) GetCatalogName() string

func (*ListVolumesRequest) GetMaxResults 

func (x *ListVolumesRequest) GetMaxResults() int32

func (*ListVolumesRequest) GetPageToken 

func (x *ListVolumesRequest) GetPageToken() string

func (*ListVolumesRequest) GetSchemaName 

func (x *ListVolumesRequest) GetSchemaName() string

func (*ListVolumesRequest) ProtoMessage 

func (*ListVolumesRequest) ProtoMessage()

func (*ListVolumesRequest) ProtoReflect 

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

func (*ListVolumesRequest) Reset 

func (x *ListVolumesRequest) Reset()

func (*ListVolumesRequest) String 

func (x *ListVolumesRequest) String() string

type ListVolumesResponse 

type ListVolumesResponse struct {
	Volumes       []*Volume `protobuf:"bytes,1,rep,name=volumes,proto3" json:"volumes,omitempty"`
	NextPageToken string    `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListVolumesResponse) Descriptor deprecated 

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

Deprecated: Use ListVolumesResponse.ProtoReflect.Descriptor instead.

func (*ListVolumesResponse) GetNextPageToken 

func (x *ListVolumesResponse) GetNextPageToken() string

func (*ListVolumesResponse) GetVolumes 

func (x *ListVolumesResponse) GetVolumes() []*Volume

func (*ListVolumesResponse) ProtoMessage 

func (*ListVolumesResponse) ProtoMessage()

func (*ListVolumesResponse) ProtoReflect 

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

func (*ListVolumesResponse) Reset 

func (x *ListVolumesResponse) Reset()

func (*ListVolumesResponse) String 

func (x *ListVolumesResponse) String() string

type OmegaCatalogServiceClient 

type OmegaCatalogServiceClient interface {
	CreateCatalog(ctx context.Context, in *CreateCatalogRequest, opts ...grpc.CallOption) (*CreateCatalogResponse, error)
	ListCatalogs(ctx context.Context, in *ListCatalogsRequest, opts ...grpc.CallOption) (*ListCatalogsResponse, error)
	GetCatalog(ctx context.Context, in *GetCatalogRequest, opts ...grpc.CallOption) (*GetCatalogResponse, error)
	UpdateCatalog(ctx context.Context, in *UpdateCatalogRequest, opts ...grpc.CallOption) (*UpdateCatalogResponse, error)
	DeleteCatalog(ctx context.Context, in *DeleteCatalogRequest, opts ...grpc.CallOption) (*DeleteCatalogResponse, error)
	CreateSchema(ctx context.Context, in *CreateSchemaRequest, opts ...grpc.CallOption) (*CreateSchemaResponse, error)
	ListSchemas(ctx context.Context, in *ListSchemasRequest, opts ...grpc.CallOption) (*ListSchemasResponse, error)
	GetSchema(ctx context.Context, in *GetSchemaRequest, opts ...grpc.CallOption) (*GetSchemaResponse, error)
	UpdateSchema(ctx context.Context, in *UpdateSchemaRequest, opts ...grpc.CallOption) (*UpdateSchemaResponse, error)
	DeleteSchema(ctx context.Context, in *DeleteSchemaRequest, opts ...grpc.CallOption) (*DeleteSchemaResponse, error)
	CreateTable(ctx context.Context, in *CreateTableRequest, opts ...grpc.CallOption) (*CreateTableResponse, error)
	ListTables(ctx context.Context, in *ListTablesRequest, opts ...grpc.CallOption) (*ListTablesResponse, error)
	GetTable(ctx context.Context, in *GetTableRequest, opts ...grpc.CallOption) (*GetTableResponse, error)
	DeleteTable(ctx context.Context, in *DeleteTableRequest, opts ...grpc.CallOption) (*DeleteTableResponse, error)
	CreateVolume(ctx context.Context, in *CreateVolumeRequest, opts ...grpc.CallOption) (*CreateVolumeResponse, error)
	ListVolumes(ctx context.Context, in *ListVolumesRequest, opts ...grpc.CallOption) (*ListVolumesResponse, error)
	// Gets a volume for a specific catalog and schema.
	GetVolume(ctx context.Context, in *GetVolumeRequest, opts ...grpc.CallOption) (*GetVolumeResponse, error)
	UpdateVolume(ctx context.Context, in *UpdateVolumeRequest, opts ...grpc.CallOption) (*UpdateVolumeResponse, error)
	DeleteVolume(ctx context.Context, in *DeleteVolumeRequest, opts ...grpc.CallOption) (*DeleteVolumeResponse, error)
	CreateFunction(ctx context.Context, in *CreateFunctionRequest, opts ...grpc.CallOption) (*CreateFunctionResponse, error)
	ListFunctions(ctx context.Context, in *ListFunctionsRequest, opts ...grpc.CallOption) (*ListFunctionsResponse, error)
	GetFunction(ctx context.Context, in *GetFunctionRequest, opts ...grpc.CallOption) (*GetFunctionResponse, error)
	DeleteFunction(ctx context.Context, in *DeleteFunctionRequest, opts ...grpc.CallOption) (*DeleteFunctionResponse, error)
}

OmegaCatalogServiceClient is the client API for OmegaCatalogService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

OmegaCatalog is the core service that provides the catalog management API.

func NewOmegaCatalogServiceClient 

func NewOmegaCatalogServiceClient(cc grpc.ClientConnInterface) OmegaCatalogServiceClient

type OmegaCatalogServiceServer 

type OmegaCatalogServiceServer interface {
	CreateCatalog(context.Context, *CreateCatalogRequest) (*CreateCatalogResponse, error)
	ListCatalogs(context.Context, *ListCatalogsRequest) (*ListCatalogsResponse, error)
	GetCatalog(context.Context, *GetCatalogRequest) (*GetCatalogResponse, error)
	UpdateCatalog(context.Context, *UpdateCatalogRequest) (*UpdateCatalogResponse, error)
	DeleteCatalog(context.Context, *DeleteCatalogRequest) (*DeleteCatalogResponse, error)
	CreateSchema(context.Context, *CreateSchemaRequest) (*CreateSchemaResponse, error)
	ListSchemas(context.Context, *ListSchemasRequest) (*ListSchemasResponse, error)
	GetSchema(context.Context, *GetSchemaRequest) (*GetSchemaResponse, error)
	UpdateSchema(context.Context, *UpdateSchemaRequest) (*UpdateSchemaResponse, error)
	DeleteSchema(context.Context, *DeleteSchemaRequest) (*DeleteSchemaResponse, error)
	CreateTable(context.Context, *CreateTableRequest) (*CreateTableResponse, error)
	ListTables(context.Context, *ListTablesRequest) (*ListTablesResponse, error)
	GetTable(context.Context, *GetTableRequest) (*GetTableResponse, error)
	DeleteTable(context.Context, *DeleteTableRequest) (*DeleteTableResponse, error)
	CreateVolume(context.Context, *CreateVolumeRequest) (*CreateVolumeResponse, error)
	ListVolumes(context.Context, *ListVolumesRequest) (*ListVolumesResponse, error)
	// Gets a volume for a specific catalog and schema.
	GetVolume(context.Context, *GetVolumeRequest) (*GetVolumeResponse, error)
	UpdateVolume(context.Context, *UpdateVolumeRequest) (*UpdateVolumeResponse, error)
	DeleteVolume(context.Context, *DeleteVolumeRequest) (*DeleteVolumeResponse, error)
	CreateFunction(context.Context, *CreateFunctionRequest) (*CreateFunctionResponse, error)
	ListFunctions(context.Context, *ListFunctionsRequest) (*ListFunctionsResponse, error)
	GetFunction(context.Context, *GetFunctionRequest) (*GetFunctionResponse, error)
	DeleteFunction(context.Context, *DeleteFunctionRequest) (*DeleteFunctionResponse, error)
	// contains filtered or unexported methods
}

OmegaCatalogServiceServer is the server API for OmegaCatalogService service. All implementations must embed UnimplementedOmegaCatalogServiceServer for forward compatibility

OmegaCatalog is the core service that provides the catalog management API.

type ParameterStyle 

type ParameterStyle int32
const (
	ParameterStyle_PARAMETER_STYLE_UNSPECIFIED ParameterStyle = 0
	ParameterStyle_PARAMETER_STYLE_SQL         ParameterStyle = 1
)

func (ParameterStyle) Descriptor 

func (ParameterStyle) Descriptor() protoreflect.EnumDescriptor

func (ParameterStyle) Enum 

func (x ParameterStyle) Enum() *ParameterStyle

func (ParameterStyle) EnumDescriptor deprecated 

func (ParameterStyle) EnumDescriptor() ([]byte, []int)

Deprecated: Use ParameterStyle.Descriptor instead.

func (ParameterStyle) Number 

func (x ParameterStyle) Number() protoreflect.EnumNumber

func (ParameterStyle) String 

func (x ParameterStyle) String() string

func (ParameterStyle) Type 

func (ParameterStyle) Type() protoreflect.EnumType

type SQLDataAccess 

type SQLDataAccess int32
const (
	SQLDataAccess_SQL_DATA_ACCESS_UNSPECIFIED    SQLDataAccess = 0
	SQLDataAccess_SQL_DATA_ACCESS_CONTAINS_SQL   SQLDataAccess = 1
	SQLDataAccess_SQL_DATA_ACCESS_NO_SQL         SQLDataAccess = 2
	SQLDataAccess_SQL_DATA_ACCESS_READS_SQL_DATA SQLDataAccess = 3
)

func (SQLDataAccess) Descriptor 

func (SQLDataAccess) Descriptor() protoreflect.EnumDescriptor

func (SQLDataAccess) Enum 

func (x SQLDataAccess) Enum() *SQLDataAccess

func (SQLDataAccess) EnumDescriptor deprecated 

func (SQLDataAccess) EnumDescriptor() ([]byte, []int)

Deprecated: Use SQLDataAccess.Descriptor instead.

func (SQLDataAccess) Number 

func (x SQLDataAccess) Number() protoreflect.EnumNumber

func (SQLDataAccess) String 

func (x SQLDataAccess) String() string

func (SQLDataAccess) Type 

func (SQLDataAccess) Type() protoreflect.EnumType

type Schema 

type Schema struct {

	// Unique identifier for the schema.
	SchemaId string `protobuf:"bytes,1,opt,name=schema_id,json=schemaId,proto3" json:"schema_id,omitempty"`
	// Name of the schema, relative to parent catalog.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Name of parent catalog.
	CatalogName string `protobuf:"bytes,3,opt,name=catalog_name,json=catalogName,proto3" json:"catalog_name,omitempty"`
	// User-provided free-form text description.
	Comment string `protobuf:"bytes,4,opt,name=comment,proto3" json:"comment,omitempty"`
	// The time at which the schema was created.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// The time at which the schema was last updated.
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// A map of key-value properties attached to the securable object.
	Properties map[string]string `` /* 161-byte string literal not displayed */
	// Full name of the schema, in form of catalog.schema
	FullName string `protobuf:"bytes,8,opt,name=full_name,json=fullName,proto3" json:"full_name,omitempty"`
	// contains filtered or unexported fields
}

Schema is a collection of securable objects such as tables and volumes.

func (*Schema) Descriptor deprecated 

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

Deprecated: Use Schema.ProtoReflect.Descriptor instead.

func (*Schema) GetCatalogName 

func (x *Schema) GetCatalogName() string

func (*Schema) GetComment 

func (x *Schema) GetComment() string

func (*Schema) GetCreatedAt 

func (x *Schema) GetCreatedAt() *timestamppb.Timestamp

func (*Schema) GetFullName 

func (x *Schema) GetFullName() string

func (*Schema) GetName 

func (x *Schema) GetName() string

func (*Schema) GetProperties 

func (x *Schema) GetProperties() map[string]string

func (*Schema) GetSchemaId 

func (x *Schema) GetSchemaId() string

func (*Schema) GetUpdatedAt 

func (x *Schema) GetUpdatedAt() *timestamppb.Timestamp

func (*Schema) ProtoMessage 

func (*Schema) ProtoMessage()

func (*Schema) ProtoReflect 

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

func (*Schema) Reset 

func (x *Schema) Reset()

func (*Schema) String 

func (x *Schema) String() string

type Table 

type Table struct {

	// Unique identifier for the table.
	TableId string `protobuf:"bytes,1,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
	// Name of the table, relative to parent schema.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Name of parent catalog.
	CatalogName string `protobuf:"bytes,3,opt,name=catalog_name,json=catalogName,proto3" json:"catalog_name,omitempty"`
	// Name of parent schema relative to its parent catalog.
	SchemaName string `protobuf:"bytes,4,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"`
	// The type of the table.
	TableType TableType `protobuf:"varint,5,opt,name=table_type,json=tableType,proto3,enum=omega_catalog.v1.TableType" json:"table_type,omitempty"`
	// The format of the data source.
	DataSourceFormat DataSourceFormat `` /* 151-byte string literal not displayed */
	// Array of the ColumnInfo definitions of the table's columns
	Columns []*ColumnInfo `protobuf:"bytes,7,rep,name=columns,proto3" json:"columns,omitempty"`
	// Storage root URL for table (for MANAGED, EXTERNAL tables)
	StorageLocation string `protobuf:"bytes,8,opt,name=storage_location,json=storageLocation,proto3" json:"storage_location,omitempty"`
	// User-provided free-form text description.
	Comment string `protobuf:"bytes,9,opt,name=comment,proto3" json:"comment,omitempty"`
	// The time at which the table was created.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// The time at which the table was last updated.
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// A map of key-value properties attached to the securable object.
	Properties map[string]string `` /* 162-byte string literal not displayed */
	// contains filtered or unexported fields
}

Table is a collection of data organized into rows and columns.

func (*Table) Descriptor deprecated 

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

Deprecated: Use Table.ProtoReflect.Descriptor instead.

func (*Table) GetCatalogName 

func (x *Table) GetCatalogName() string

func (*Table) GetColumns 

func (x *Table) GetColumns() []*ColumnInfo

func (*Table) GetComment 

func (x *Table) GetComment() string

func (*Table) GetCreatedAt 

func (x *Table) GetCreatedAt() *timestamppb.Timestamp

func (*Table) GetDataSourceFormat 

func (x *Table) GetDataSourceFormat() DataSourceFormat

func (*Table) GetName 

func (x *Table) GetName() string

func (*Table) GetProperties 

func (x *Table) GetProperties() map[string]string

func (*Table) GetSchemaName 

func (x *Table) GetSchemaName() string

func (*Table) GetStorageLocation 

func (x *Table) GetStorageLocation() string

func (*Table) GetTableId 

func (x *Table) GetTableId() string

func (*Table) GetTableType 

func (x *Table) GetTableType() TableType

func (*Table) GetUpdatedAt 

func (x *Table) GetUpdatedAt() *timestamppb.Timestamp

func (*Table) ProtoMessage 

func (*Table) ProtoMessage()

func (*Table) ProtoReflect 

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

func (*Table) Reset 

func (x *Table) Reset()

func (*Table) String 

func (x *Table) String() string

type TableDependency 

type TableDependency struct {

	// Full name of the dependent table, in the form of catalog_name.schema_name.table_name
	TableFullName string `protobuf:"bytes,1,opt,name=table_full_name,json=tableFullName,proto3" json:"table_full_name,omitempty"`
	// contains filtered or unexported fields
}

func (*TableDependency) Descriptor deprecated 

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

Deprecated: Use TableDependency.ProtoReflect.Descriptor instead.

func (*TableDependency) GetTableFullName 

func (x *TableDependency) GetTableFullName() string

func (*TableDependency) ProtoMessage 

func (*TableDependency) ProtoMessage()

func (*TableDependency) ProtoReflect 

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

func (*TableDependency) Reset 

func (x *TableDependency) Reset()

func (*TableDependency) String 

func (x *TableDependency) String() string

type TableType 

type TableType int32
const (
	TableType_TABLE_TYPE_UNSPECIFIED TableType = 0
	TableType_TABLE_TYPE_MANAGED     TableType = 1
	TableType_TABLE_TYPE_EXTERNAL    TableType = 2
)

func (TableType) Descriptor 

func (TableType) Descriptor() protoreflect.EnumDescriptor

func (TableType) Enum 

func (x TableType) Enum() *TableType

func (TableType) EnumDescriptor deprecated 

func (TableType) EnumDescriptor() ([]byte, []int)

Deprecated: Use TableType.Descriptor instead.

func (TableType) Number 

func (x TableType) Number() protoreflect.EnumNumber

func (TableType) String 

func (x TableType) String() string

func (TableType) Type 

func (TableType) Type() protoreflect.EnumType

type UnimplementedOmegaCatalogServiceServer 

type UnimplementedOmegaCatalogServiceServer struct {
}

UnimplementedOmegaCatalogServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedOmegaCatalogServiceServer) CreateCatalog 

func (UnimplementedOmegaCatalogServiceServer) CreateCatalog(context.Context, *CreateCatalogRequest) (*CreateCatalogResponse, error)

func (UnimplementedOmegaCatalogServiceServer) CreateFunction 

func (UnimplementedOmegaCatalogServiceServer) CreateFunction(context.Context, *CreateFunctionRequest) (*CreateFunctionResponse, error)

func (UnimplementedOmegaCatalogServiceServer) CreateSchema 

func (UnimplementedOmegaCatalogServiceServer) CreateSchema(context.Context, *CreateSchemaRequest) (*CreateSchemaResponse, error)

func (UnimplementedOmegaCatalogServiceServer) CreateTable 

func (UnimplementedOmegaCatalogServiceServer) CreateTable(context.Context, *CreateTableRequest) (*CreateTableResponse, error)

func (UnimplementedOmegaCatalogServiceServer) CreateVolume 

func (UnimplementedOmegaCatalogServiceServer) CreateVolume(context.Context, *CreateVolumeRequest) (*CreateVolumeResponse, error)

func (UnimplementedOmegaCatalogServiceServer) DeleteCatalog 

func (UnimplementedOmegaCatalogServiceServer) DeleteCatalog(context.Context, *DeleteCatalogRequest) (*DeleteCatalogResponse, error)

func (UnimplementedOmegaCatalogServiceServer) DeleteFunction 

func (UnimplementedOmegaCatalogServiceServer) DeleteFunction(context.Context, *DeleteFunctionRequest) (*DeleteFunctionResponse, error)

func (UnimplementedOmegaCatalogServiceServer) DeleteSchema 

func (UnimplementedOmegaCatalogServiceServer) DeleteSchema(context.Context, *DeleteSchemaRequest) (*DeleteSchemaResponse, error)

func (UnimplementedOmegaCatalogServiceServer) DeleteTable 

func (UnimplementedOmegaCatalogServiceServer) DeleteTable(context.Context, *DeleteTableRequest) (*DeleteTableResponse, error)

func (UnimplementedOmegaCatalogServiceServer) DeleteVolume 

func (UnimplementedOmegaCatalogServiceServer) DeleteVolume(context.Context, *DeleteVolumeRequest) (*DeleteVolumeResponse, error)

func (UnimplementedOmegaCatalogServiceServer) GetCatalog 

func (UnimplementedOmegaCatalogServiceServer) GetCatalog(context.Context, *GetCatalogRequest) (*GetCatalogResponse, error)

func (UnimplementedOmegaCatalogServiceServer) GetFunction 

func (UnimplementedOmegaCatalogServiceServer) GetFunction(context.Context, *GetFunctionRequest) (*GetFunctionResponse, error)

func (UnimplementedOmegaCatalogServiceServer) GetSchema 

func (UnimplementedOmegaCatalogServiceServer) GetSchema(context.Context, *GetSchemaRequest) (*GetSchemaResponse, error)

func (UnimplementedOmegaCatalogServiceServer) GetTable 

func (UnimplementedOmegaCatalogServiceServer) GetTable(context.Context, *GetTableRequest) (*GetTableResponse, error)

func (UnimplementedOmegaCatalogServiceServer) GetVolume 

func (UnimplementedOmegaCatalogServiceServer) GetVolume(context.Context, *GetVolumeRequest) (*GetVolumeResponse, error)

func (UnimplementedOmegaCatalogServiceServer) ListCatalogs 

func (UnimplementedOmegaCatalogServiceServer) ListCatalogs(context.Context, *ListCatalogsRequest) (*ListCatalogsResponse, error)

func (UnimplementedOmegaCatalogServiceServer) ListFunctions 

func (UnimplementedOmegaCatalogServiceServer) ListFunctions(context.Context, *ListFunctionsRequest) (*ListFunctionsResponse, error)

func (UnimplementedOmegaCatalogServiceServer) ListSchemas 

func (UnimplementedOmegaCatalogServiceServer) ListSchemas(context.Context, *ListSchemasRequest) (*ListSchemasResponse, error)

func (UnimplementedOmegaCatalogServiceServer) ListTables 

func (UnimplementedOmegaCatalogServiceServer) ListTables(context.Context, *ListTablesRequest) (*ListTablesResponse, error)

func (UnimplementedOmegaCatalogServiceServer) ListVolumes 

func (UnimplementedOmegaCatalogServiceServer) ListVolumes(context.Context, *ListVolumesRequest) (*ListVolumesResponse, error)

func (UnimplementedOmegaCatalogServiceServer) UpdateCatalog 

func (UnimplementedOmegaCatalogServiceServer) UpdateCatalog(context.Context, *UpdateCatalogRequest) (*UpdateCatalogResponse, error)

func (UnimplementedOmegaCatalogServiceServer) UpdateSchema 

func (UnimplementedOmegaCatalogServiceServer) UpdateSchema(context.Context, *UpdateSchemaRequest) (*UpdateSchemaResponse, error)

func (UnimplementedOmegaCatalogServiceServer) UpdateVolume 

func (UnimplementedOmegaCatalogServiceServer) UpdateVolume(context.Context, *UpdateVolumeRequest) (*UpdateVolumeResponse, error)

type UnsafeOmegaCatalogServiceServer 

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

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

type UpdateCatalogRequest 

type UpdateCatalogRequest struct {

	// The name of the catalog to update.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The new comment for the catalog.
	Comment string `protobuf:"bytes,2,opt,name=comment,proto3" json:"comment,omitempty"`
	// The new name for the catalog, if renaming it.
	NewName string `protobuf:"bytes,3,opt,name=new_name,json=newName,proto3" json:"new_name,omitempty"`
	// The new properties for the catalog.
	Properties map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UpdateCatalogRequest) Descriptor deprecated 

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

Deprecated: Use UpdateCatalogRequest.ProtoReflect.Descriptor instead.

func (*UpdateCatalogRequest) GetComment 

func (x *UpdateCatalogRequest) GetComment() string

func (*UpdateCatalogRequest) GetName 

func (x *UpdateCatalogRequest) GetName() string

func (*UpdateCatalogRequest) GetNewName 

func (x *UpdateCatalogRequest) GetNewName() string

func (*UpdateCatalogRequest) GetProperties 

func (x *UpdateCatalogRequest) GetProperties() map[string]string

func (*UpdateCatalogRequest) ProtoMessage 

func (*UpdateCatalogRequest) ProtoMessage()

func (*UpdateCatalogRequest) ProtoReflect 

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

func (*UpdateCatalogRequest) Reset 

func (x *UpdateCatalogRequest) Reset()

func (*UpdateCatalogRequest) String 

func (x *UpdateCatalogRequest) String() string

type UpdateCatalogResponse 

type UpdateCatalogResponse struct {
	Catalog *Catalog `protobuf:"bytes,1,opt,name=catalog,proto3" json:"catalog,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateCatalogResponse) Descriptor deprecated 

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

Deprecated: Use UpdateCatalogResponse.ProtoReflect.Descriptor instead.

func (*UpdateCatalogResponse) GetCatalog 

func (x *UpdateCatalogResponse) GetCatalog() *Catalog

func (*UpdateCatalogResponse) ProtoMessage 

func (*UpdateCatalogResponse) ProtoMessage()

func (*UpdateCatalogResponse) ProtoReflect 

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

func (*UpdateCatalogResponse) Reset 

func (x *UpdateCatalogResponse) Reset()

func (*UpdateCatalogResponse) String 

func (x *UpdateCatalogResponse) String() string

type UpdateSchemaRequest 

type UpdateSchemaRequest struct {

	// Full name of the schema.
	FullName string `protobuf:"bytes,1,opt,name=full_name,json=fullName,proto3" json:"full_name,omitempty"`
	// The new comment for the schema.
	Comment string `protobuf:"bytes,2,opt,name=comment,proto3" json:"comment,omitempty"`
	// The new name for the schema, if renaming it.
	NewName string `protobuf:"bytes,3,opt,name=new_name,json=newName,proto3" json:"new_name,omitempty"`
	// The new properties for the schema.
	Properties map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UpdateSchemaRequest) Descriptor deprecated 

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

Deprecated: Use UpdateSchemaRequest.ProtoReflect.Descriptor instead.

func (*UpdateSchemaRequest) GetComment 

func (x *UpdateSchemaRequest) GetComment() string

func (*UpdateSchemaRequest) GetFullName 

func (x *UpdateSchemaRequest) GetFullName() string

func (*UpdateSchemaRequest) GetNewName 

func (x *UpdateSchemaRequest) GetNewName() string

func (*UpdateSchemaRequest) GetProperties 

func (x *UpdateSchemaRequest) GetProperties() map[string]string

func (*UpdateSchemaRequest) ProtoMessage 

func (*UpdateSchemaRequest) ProtoMessage()

func (*UpdateSchemaRequest) ProtoReflect 

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

func (*UpdateSchemaRequest) Reset 

func (x *UpdateSchemaRequest) Reset()

func (*UpdateSchemaRequest) String 

func (x *UpdateSchemaRequest) String() string

type UpdateSchemaResponse 

type UpdateSchemaResponse struct {
	Schema *Schema `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSchemaResponse) Descriptor deprecated 

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

Deprecated: Use UpdateSchemaResponse.ProtoReflect.Descriptor instead.

func (*UpdateSchemaResponse) GetSchema 

func (x *UpdateSchemaResponse) GetSchema() *Schema

func (*UpdateSchemaResponse) ProtoMessage 

func (*UpdateSchemaResponse) ProtoMessage()

func (*UpdateSchemaResponse) ProtoReflect 

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

func (*UpdateSchemaResponse) Reset 

func (x *UpdateSchemaResponse) Reset()

func (*UpdateSchemaResponse) String 

func (x *UpdateSchemaResponse) String() string

type UpdateVolumeRequest 

type UpdateVolumeRequest struct {

	// The three-level (fully qualified) name of the volume.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The new comment for the volume.
	Comment string `protobuf:"bytes,2,opt,name=comment,proto3" json:"comment,omitempty"`
	// The new name for the volume, if renaming it.
	NewName string `protobuf:"bytes,3,opt,name=new_name,json=newName,proto3" json:"new_name,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateVolumeRequest) Descriptor deprecated 

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

Deprecated: Use UpdateVolumeRequest.ProtoReflect.Descriptor instead.

func (*UpdateVolumeRequest) GetComment 

func (x *UpdateVolumeRequest) GetComment() string

func (*UpdateVolumeRequest) GetName 

func (x *UpdateVolumeRequest) GetName() string

func (*UpdateVolumeRequest) GetNewName 

func (x *UpdateVolumeRequest) GetNewName() string

func (*UpdateVolumeRequest) ProtoMessage 

func (*UpdateVolumeRequest) ProtoMessage()

func (*UpdateVolumeRequest) ProtoReflect 

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

func (*UpdateVolumeRequest) Reset 

func (x *UpdateVolumeRequest) Reset()

func (*UpdateVolumeRequest) String 

func (x *UpdateVolumeRequest) String() string

type UpdateVolumeResponse 

type UpdateVolumeResponse struct {
	Volume *Volume `protobuf:"bytes,1,opt,name=volume,proto3" json:"volume,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateVolumeResponse) Descriptor deprecated 

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

Deprecated: Use UpdateVolumeResponse.ProtoReflect.Descriptor instead.

func (*UpdateVolumeResponse) GetVolume 

func (x *UpdateVolumeResponse) GetVolume() *Volume

func (*UpdateVolumeResponse) ProtoMessage 

func (*UpdateVolumeResponse) ProtoMessage()

func (*UpdateVolumeResponse) ProtoReflect 

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

func (*UpdateVolumeResponse) Reset 

func (x *UpdateVolumeResponse) Reset()

func (*UpdateVolumeResponse) String 

func (x *UpdateVolumeResponse) String() string

type Volume 

type Volume struct {

	// Unique identifier for the volume.
	VolumeId string `protobuf:"bytes,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	// The name of the catalog where the schema and the volume are
	CatalogName string `protobuf:"bytes,2,opt,name=catalog_name,json=catalogName,proto3" json:"catalog_name,omitempty"`
	// The name of the schema where the volume is
	SchemaName string `protobuf:"bytes,3,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"`
	// The name of the volume
	Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	// Full name of the volume, in form of catalog.schema.volume
	FullName string `protobuf:"bytes,5,opt,name=full_name,json=fullName,proto3" json:"full_name,omitempty"`
	// The type of the volume
	VolumeType VolumeType `protobuf:"varint,6,opt,name=volume_type,json=volumeType,proto3,enum=omega_catalog.v1.VolumeType" json:"volume_type,omitempty"`
	// The comment attached to the volume
	Comment string `protobuf:"bytes,7,opt,name=comment,proto3" json:"comment,omitempty"`
	// The storage location of the volume
	StorageLocation string `protobuf:"bytes,8,opt,name=storage_location,json=storageLocation,proto3" json:"storage_location,omitempty"`
	// The time at which the volume was created.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// The time at which the volume was last updated.
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Volume) Descriptor deprecated 

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

Deprecated: Use Volume.ProtoReflect.Descriptor instead.

func (*Volume) GetCatalogName 

func (x *Volume) GetCatalogName() string

func (*Volume) GetComment 

func (x *Volume) GetComment() string

func (*Volume) GetCreatedAt 

func (x *Volume) GetCreatedAt() *timestamppb.Timestamp

func (*Volume) GetFullName 

func (x *Volume) GetFullName() string

func (*Volume) GetName 

func (x *Volume) GetName() string

func (*Volume) GetSchemaName 

func (x *Volume) GetSchemaName() string

func (*Volume) GetStorageLocation 

func (x *Volume) GetStorageLocation() string

func (*Volume) GetUpdatedAt 

func (x *Volume) GetUpdatedAt() *timestamppb.Timestamp

func (*Volume) GetVolumeId 

func (x *Volume) GetVolumeId() string

func (*Volume) GetVolumeType 

func (x *Volume) GetVolumeType() VolumeType

func (*Volume) ProtoMessage 

func (*Volume) ProtoMessage()

func (*Volume) ProtoReflect 

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

func (*Volume) Reset 

func (x *Volume) Reset()

func (*Volume) String 

func (x *Volume) String() string

type VolumeType 

type VolumeType int32
const (
	VolumeType_VOLUME_TYPE_UNSPECIFIED VolumeType = 0
	VolumeType_VOLUME_TYPE_MANAGED     VolumeType = 1
	VolumeType_VOLUME_TYPE_EXTERNAL    VolumeType = 2
)

func (VolumeType) Descriptor 

func (VolumeType) Descriptor() protoreflect.EnumDescriptor

func (VolumeType) Enum 

func (x VolumeType) Enum() *VolumeType

func (VolumeType) EnumDescriptor deprecated 

func (VolumeType) EnumDescriptor() ([]byte, []int)

Deprecated: Use VolumeType.Descriptor instead.

func (VolumeType) Number 

func (x VolumeType) Number() protoreflect.EnumNumber

func (VolumeType) String 

func (x VolumeType) String() string

func (VolumeType) Type 

func (VolumeType) Type() protoreflect.EnumType

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.