flight

package
v15.0.2 Latest Latest
Warning

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

 Go to latest Published: Mar 13, 2024 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause, + 7 more Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	CancelStatus_name = map[int32]string{
		0: "CANCEL_STATUS_UNSPECIFIED",
		1: "CANCEL_STATUS_CANCELLED",
		2: "CANCEL_STATUS_CANCELLING",
		3: "CANCEL_STATUS_NOT_CANCELLABLE",
	}
	CancelStatus_value = map[string]int32{
		"CANCEL_STATUS_UNSPECIFIED":     0,
		"CANCEL_STATUS_CANCELLED":       1,
		"CANCEL_STATUS_CANCELLING":      2,
		"CANCEL_STATUS_NOT_CANCELLABLE": 3,
	}
)

Enum value maps for CancelStatus.

View Source 
var (
	FlightDescriptor_DescriptorType_name = map[int32]string{
		0: "UNKNOWN",
		1: "PATH",
		2: "CMD",
	}
	FlightDescriptor_DescriptorType_value = map[string]int32{
		"UNKNOWN": 0,
		"PATH":    1,
		"CMD":     2,
	}
)

Enum value maps for FlightDescriptor_DescriptorType.

View Source 
var (
	SqlInfo_name = map[int32]string{
		0:   "FLIGHT_SQL_SERVER_NAME",
		1:   "FLIGHT_SQL_SERVER_VERSION",
		2:   "FLIGHT_SQL_SERVER_ARROW_VERSION",
		3:   "FLIGHT_SQL_SERVER_READ_ONLY",
		4:   "FLIGHT_SQL_SERVER_SQL",
		5:   "FLIGHT_SQL_SERVER_SUBSTRAIT",
		6:   "FLIGHT_SQL_SERVER_SUBSTRAIT_MIN_VERSION",
		7:   "FLIGHT_SQL_SERVER_SUBSTRAIT_MAX_VERSION",
		8:   "FLIGHT_SQL_SERVER_TRANSACTION",
		9:   "FLIGHT_SQL_SERVER_CANCEL",
		100: "FLIGHT_SQL_SERVER_STATEMENT_TIMEOUT",
		101: "FLIGHT_SQL_SERVER_TRANSACTION_TIMEOUT",
		500: "SQL_DDL_CATALOG",
		501: "SQL_DDL_SCHEMA",
		502: "SQL_DDL_TABLE",
		503: "SQL_IDENTIFIER_CASE",
		504: "SQL_IDENTIFIER_QUOTE_CHAR",
		505: "SQL_QUOTED_IDENTIFIER_CASE",
		506: "SQL_ALL_TABLES_ARE_SELECTABLE",
		507: "SQL_NULL_ORDERING",
		508: "SQL_KEYWORDS",
		509: "SQL_NUMERIC_FUNCTIONS",
		510: "SQL_STRING_FUNCTIONS",
		511: "SQL_SYSTEM_FUNCTIONS",
		512: "SQL_DATETIME_FUNCTIONS",
		513: "SQL_SEARCH_STRING_ESCAPE",
		514: "SQL_EXTRA_NAME_CHARACTERS",
		515: "SQL_SUPPORTS_COLUMN_ALIASING",
		516: "SQL_NULL_PLUS_NULL_IS_NULL",
		517: "SQL_SUPPORTS_CONVERT",
		518: "SQL_SUPPORTS_TABLE_CORRELATION_NAMES",
		519: "SQL_SUPPORTS_DIFFERENT_TABLE_CORRELATION_NAMES",
		520: "SQL_SUPPORTS_EXPRESSIONS_IN_ORDER_BY",
		521: "SQL_SUPPORTS_ORDER_BY_UNRELATED",
		522: "SQL_SUPPORTED_GROUP_BY",
		523: "SQL_SUPPORTS_LIKE_ESCAPE_CLAUSE",
		524: "SQL_SUPPORTS_NON_NULLABLE_COLUMNS",
		525: "SQL_SUPPORTED_GRAMMAR",
		526: "SQL_ANSI92_SUPPORTED_LEVEL",
		527: "SQL_SUPPORTS_INTEGRITY_ENHANCEMENT_FACILITY",
		528: "SQL_OUTER_JOINS_SUPPORT_LEVEL",
		529: "SQL_SCHEMA_TERM",
		530: "SQL_PROCEDURE_TERM",
		531: "SQL_CATALOG_TERM",
		532: "SQL_CATALOG_AT_START",
		533: "SQL_SCHEMAS_SUPPORTED_ACTIONS",
		534: "SQL_CATALOGS_SUPPORTED_ACTIONS",
		535: "SQL_SUPPORTED_POSITIONED_COMMANDS",
		536: "SQL_SELECT_FOR_UPDATE_SUPPORTED",
		537: "SQL_STORED_PROCEDURES_SUPPORTED",
		538: "SQL_SUPPORTED_SUBQUERIES",
		539: "SQL_CORRELATED_SUBQUERIES_SUPPORTED",
		540: "SQL_SUPPORTED_UNIONS",
		541: "SQL_MAX_BINARY_LITERAL_LENGTH",
		542: "SQL_MAX_CHAR_LITERAL_LENGTH",
		543: "SQL_MAX_COLUMN_NAME_LENGTH",
		544: "SQL_MAX_COLUMNS_IN_GROUP_BY",
		545: "SQL_MAX_COLUMNS_IN_INDEX",
		546: "SQL_MAX_COLUMNS_IN_ORDER_BY",
		547: "SQL_MAX_COLUMNS_IN_SELECT",
		548: "SQL_MAX_COLUMNS_IN_TABLE",
		549: "SQL_MAX_CONNECTIONS",
		550: "SQL_MAX_CURSOR_NAME_LENGTH",
		551: "SQL_MAX_INDEX_LENGTH",
		552: "SQL_DB_SCHEMA_NAME_LENGTH",
		553: "SQL_MAX_PROCEDURE_NAME_LENGTH",
		554: "SQL_MAX_CATALOG_NAME_LENGTH",
		555: "SQL_MAX_ROW_SIZE",
		556: "SQL_MAX_ROW_SIZE_INCLUDES_BLOBS",
		557: "SQL_MAX_STATEMENT_LENGTH",
		558: "SQL_MAX_STATEMENTS",
		559: "SQL_MAX_TABLE_NAME_LENGTH",
		560: "SQL_MAX_TABLES_IN_SELECT",
		561: "SQL_MAX_USERNAME_LENGTH",
		562: "SQL_DEFAULT_TRANSACTION_ISOLATION",
		563: "SQL_TRANSACTIONS_SUPPORTED",
		564: "SQL_SUPPORTED_TRANSACTIONS_ISOLATION_LEVELS",
		565: "SQL_DATA_DEFINITION_CAUSES_TRANSACTION_COMMIT",
		566: "SQL_DATA_DEFINITIONS_IN_TRANSACTIONS_IGNORED",
		567: "SQL_SUPPORTED_RESULT_SET_TYPES",
		568: "SQL_SUPPORTED_CONCURRENCIES_FOR_RESULT_SET_UNSPECIFIED",
		569: "SQL_SUPPORTED_CONCURRENCIES_FOR_RESULT_SET_FORWARD_ONLY",
		570: "SQL_SUPPORTED_CONCURRENCIES_FOR_RESULT_SET_SCROLL_SENSITIVE",
		571: "SQL_SUPPORTED_CONCURRENCIES_FOR_RESULT_SET_SCROLL_INSENSITIVE",
		572: "SQL_BATCH_UPDATES_SUPPORTED",
		573: "SQL_SAVEPOINTS_SUPPORTED",
		574: "SQL_NAMED_PARAMETERS_SUPPORTED",
		575: "SQL_LOCATORS_UPDATE_COPY",
		576: "SQL_STORED_FUNCTIONS_USING_CALL_SYNTAX_SUPPORTED",
	}
	SqlInfo_value = map[string]int32{
		"FLIGHT_SQL_SERVER_NAME":                                        0,
		"FLIGHT_SQL_SERVER_VERSION":                                     1,
		"FLIGHT_SQL_SERVER_ARROW_VERSION":                               2,
		"FLIGHT_SQL_SERVER_READ_ONLY":                                   3,
		"FLIGHT_SQL_SERVER_SQL":                                         4,
		"FLIGHT_SQL_SERVER_SUBSTRAIT":                                   5,
		"FLIGHT_SQL_SERVER_SUBSTRAIT_MIN_VERSION":                       6,
		"FLIGHT_SQL_SERVER_SUBSTRAIT_MAX_VERSION":                       7,
		"FLIGHT_SQL_SERVER_TRANSACTION":                                 8,
		"FLIGHT_SQL_SERVER_CANCEL":                                      9,
		"FLIGHT_SQL_SERVER_STATEMENT_TIMEOUT":                           100,
		"FLIGHT_SQL_SERVER_TRANSACTION_TIMEOUT":                         101,
		"SQL_DDL_CATALOG":                                               500,
		"SQL_DDL_SCHEMA":                                                501,
		"SQL_DDL_TABLE":                                                 502,
		"SQL_IDENTIFIER_CASE":                                           503,
		"SQL_IDENTIFIER_QUOTE_CHAR":                                     504,
		"SQL_QUOTED_IDENTIFIER_CASE":                                    505,
		"SQL_ALL_TABLES_ARE_SELECTABLE":                                 506,
		"SQL_NULL_ORDERING":                                             507,
		"SQL_KEYWORDS":                                                  508,
		"SQL_NUMERIC_FUNCTIONS":                                         509,
		"SQL_STRING_FUNCTIONS":                                          510,
		"SQL_SYSTEM_FUNCTIONS":                                          511,
		"SQL_DATETIME_FUNCTIONS":                                        512,
		"SQL_SEARCH_STRING_ESCAPE":                                      513,
		"SQL_EXTRA_NAME_CHARACTERS":                                     514,
		"SQL_SUPPORTS_COLUMN_ALIASING":                                  515,
		"SQL_NULL_PLUS_NULL_IS_NULL":                                    516,
		"SQL_SUPPORTS_CONVERT":                                          517,
		"SQL_SUPPORTS_TABLE_CORRELATION_NAMES":                          518,
		"SQL_SUPPORTS_DIFFERENT_TABLE_CORRELATION_NAMES":                519,
		"SQL_SUPPORTS_EXPRESSIONS_IN_ORDER_BY":                          520,
		"SQL_SUPPORTS_ORDER_BY_UNRELATED":                               521,
		"SQL_SUPPORTED_GROUP_BY":                                        522,
		"SQL_SUPPORTS_LIKE_ESCAPE_CLAUSE":                               523,
		"SQL_SUPPORTS_NON_NULLABLE_COLUMNS":                             524,
		"SQL_SUPPORTED_GRAMMAR":                                         525,
		"SQL_ANSI92_SUPPORTED_LEVEL":                                    526,
		"SQL_SUPPORTS_INTEGRITY_ENHANCEMENT_FACILITY":                   527,
		"SQL_OUTER_JOINS_SUPPORT_LEVEL":                                 528,
		"SQL_SCHEMA_TERM":                                               529,
		"SQL_PROCEDURE_TERM":                                            530,
		"SQL_CATALOG_TERM":                                              531,
		"SQL_CATALOG_AT_START":                                          532,
		"SQL_SCHEMAS_SUPPORTED_ACTIONS":                                 533,
		"SQL_CATALOGS_SUPPORTED_ACTIONS":                                534,
		"SQL_SUPPORTED_POSITIONED_COMMANDS":                             535,
		"SQL_SELECT_FOR_UPDATE_SUPPORTED":                               536,
		"SQL_STORED_PROCEDURES_SUPPORTED":                               537,
		"SQL_SUPPORTED_SUBQUERIES":                                      538,
		"SQL_CORRELATED_SUBQUERIES_SUPPORTED":                           539,
		"SQL_SUPPORTED_UNIONS":                                          540,
		"SQL_MAX_BINARY_LITERAL_LENGTH":                                 541,
		"SQL_MAX_CHAR_LITERAL_LENGTH":                                   542,
		"SQL_MAX_COLUMN_NAME_LENGTH":                                    543,
		"SQL_MAX_COLUMNS_IN_GROUP_BY":                                   544,
		"SQL_MAX_COLUMNS_IN_INDEX":                                      545,
		"SQL_MAX_COLUMNS_IN_ORDER_BY":                                   546,
		"SQL_MAX_COLUMNS_IN_SELECT":                                     547,
		"SQL_MAX_COLUMNS_IN_TABLE":                                      548,
		"SQL_MAX_CONNECTIONS":                                           549,
		"SQL_MAX_CURSOR_NAME_LENGTH":                                    550,
		"SQL_MAX_INDEX_LENGTH":                                          551,
		"SQL_DB_SCHEMA_NAME_LENGTH":                                     552,
		"SQL_MAX_PROCEDURE_NAME_LENGTH":                                 553,
		"SQL_MAX_CATALOG_NAME_LENGTH":                                   554,
		"SQL_MAX_ROW_SIZE":                                              555,
		"SQL_MAX_ROW_SIZE_INCLUDES_BLOBS":                               556,
		"SQL_MAX_STATEMENT_LENGTH":                                      557,
		"SQL_MAX_STATEMENTS":                                            558,
		"SQL_MAX_TABLE_NAME_LENGTH":                                     559,
		"SQL_MAX_TABLES_IN_SELECT":                                      560,
		"SQL_MAX_USERNAME_LENGTH":                                       561,
		"SQL_DEFAULT_TRANSACTION_ISOLATION":                             562,
		"SQL_TRANSACTIONS_SUPPORTED":                                    563,
		"SQL_SUPPORTED_TRANSACTIONS_ISOLATION_LEVELS":                   564,
		"SQL_DATA_DEFINITION_CAUSES_TRANSACTION_COMMIT":                 565,
		"SQL_DATA_DEFINITIONS_IN_TRANSACTIONS_IGNORED":                  566,
		"SQL_SUPPORTED_RESULT_SET_TYPES":                                567,
		"SQL_SUPPORTED_CONCURRENCIES_FOR_RESULT_SET_UNSPECIFIED":        568,
		"SQL_SUPPORTED_CONCURRENCIES_FOR_RESULT_SET_FORWARD_ONLY":       569,
		"SQL_SUPPORTED_CONCURRENCIES_FOR_RESULT_SET_SCROLL_SENSITIVE":   570,
		"SQL_SUPPORTED_CONCURRENCIES_FOR_RESULT_SET_SCROLL_INSENSITIVE": 571,
		"SQL_BATCH_UPDATES_SUPPORTED":                                   572,
		"SQL_SAVEPOINTS_SUPPORTED":                                      573,
		"SQL_NAMED_PARAMETERS_SUPPORTED":                                574,
		"SQL_LOCATORS_UPDATE_COPY":                                      575,
		"SQL_STORED_FUNCTIONS_USING_CALL_SYNTAX_SUPPORTED":              576,
	}
)

Enum value maps for SqlInfo.

View Source 
var (
	SqlSupportedTransaction_name = map[int32]string{
		0: "SQL_SUPPORTED_TRANSACTION_NONE",
		1: "SQL_SUPPORTED_TRANSACTION_TRANSACTION",
		2: "SQL_SUPPORTED_TRANSACTION_SAVEPOINT",
	}
	SqlSupportedTransaction_value = map[string]int32{
		"SQL_SUPPORTED_TRANSACTION_NONE":        0,
		"SQL_SUPPORTED_TRANSACTION_TRANSACTION": 1,
		"SQL_SUPPORTED_TRANSACTION_SAVEPOINT":   2,
	}
)

Enum value maps for SqlSupportedTransaction.

View Source 
var (
	SqlSupportedCaseSensitivity_name = map[int32]string{
		0: "SQL_CASE_SENSITIVITY_UNKNOWN",
		1: "SQL_CASE_SENSITIVITY_CASE_INSENSITIVE",
		2: "SQL_CASE_SENSITIVITY_UPPERCASE",
		3: "SQL_CASE_SENSITIVITY_LOWERCASE",
	}
	SqlSupportedCaseSensitivity_value = map[string]int32{
		"SQL_CASE_SENSITIVITY_UNKNOWN":          0,
		"SQL_CASE_SENSITIVITY_CASE_INSENSITIVE": 1,
		"SQL_CASE_SENSITIVITY_UPPERCASE":        2,
		"SQL_CASE_SENSITIVITY_LOWERCASE":        3,
	}
)

Enum value maps for SqlSupportedCaseSensitivity.

View Source 
var (
	SqlNullOrdering_name = map[int32]string{
		0: "SQL_NULLS_SORTED_HIGH",
		1: "SQL_NULLS_SORTED_LOW",
		2: "SQL_NULLS_SORTED_AT_START",
		3: "SQL_NULLS_SORTED_AT_END",
	}
	SqlNullOrdering_value = map[string]int32{
		"SQL_NULLS_SORTED_HIGH":     0,
		"SQL_NULLS_SORTED_LOW":      1,
		"SQL_NULLS_SORTED_AT_START": 2,
		"SQL_NULLS_SORTED_AT_END":   3,
	}
)

Enum value maps for SqlNullOrdering.

View Source 
var (
	SupportedSqlGrammar_name = map[int32]string{
		0: "SQL_MINIMUM_GRAMMAR",
		1: "SQL_CORE_GRAMMAR",
		2: "SQL_EXTENDED_GRAMMAR",
	}
	SupportedSqlGrammar_value = map[string]int32{
		"SQL_MINIMUM_GRAMMAR":  0,
		"SQL_CORE_GRAMMAR":     1,
		"SQL_EXTENDED_GRAMMAR": 2,
	}
)

Enum value maps for SupportedSqlGrammar.

View Source 
var (
	SupportedAnsi92SqlGrammarLevel_name = map[int32]string{
		0: "ANSI92_ENTRY_SQL",
		1: "ANSI92_INTERMEDIATE_SQL",
		2: "ANSI92_FULL_SQL",
	}
	SupportedAnsi92SqlGrammarLevel_value = map[string]int32{
		"ANSI92_ENTRY_SQL":        0,
		"ANSI92_INTERMEDIATE_SQL": 1,
		"ANSI92_FULL_SQL":         2,
	}
)

Enum value maps for SupportedAnsi92SqlGrammarLevel.

View Source 
var (
	SqlOuterJoinsSupportLevel_name = map[int32]string{
		0: "SQL_JOINS_UNSUPPORTED",
		1: "SQL_LIMITED_OUTER_JOINS",
		2: "SQL_FULL_OUTER_JOINS",
	}
	SqlOuterJoinsSupportLevel_value = map[string]int32{
		"SQL_JOINS_UNSUPPORTED":   0,
		"SQL_LIMITED_OUTER_JOINS": 1,
		"SQL_FULL_OUTER_JOINS":    2,
	}
)

Enum value maps for SqlOuterJoinsSupportLevel.

View Source 
var (
	SqlSupportedGroupBy_name = map[int32]string{
		0: "SQL_GROUP_BY_UNRELATED",
		1: "SQL_GROUP_BY_BEYOND_SELECT",
	}
	SqlSupportedGroupBy_value = map[string]int32{
		"SQL_GROUP_BY_UNRELATED":     0,
		"SQL_GROUP_BY_BEYOND_SELECT": 1,
	}
)

Enum value maps for SqlSupportedGroupBy.

View Source 
var (
	SqlSupportedElementActions_name = map[int32]string{
		0: "SQL_ELEMENT_IN_PROCEDURE_CALLS",
		1: "SQL_ELEMENT_IN_INDEX_DEFINITIONS",
		2: "SQL_ELEMENT_IN_PRIVILEGE_DEFINITIONS",
	}
	SqlSupportedElementActions_value = map[string]int32{
		"SQL_ELEMENT_IN_PROCEDURE_CALLS":       0,
		"SQL_ELEMENT_IN_INDEX_DEFINITIONS":     1,
		"SQL_ELEMENT_IN_PRIVILEGE_DEFINITIONS": 2,
	}
)

Enum value maps for SqlSupportedElementActions.

View Source 
var (
	SqlSupportedPositionedCommands_name = map[int32]string{
		0: "SQL_POSITIONED_DELETE",
		1: "SQL_POSITIONED_UPDATE",
	}
	SqlSupportedPositionedCommands_value = map[string]int32{
		"SQL_POSITIONED_DELETE": 0,
		"SQL_POSITIONED_UPDATE": 1,
	}
)

Enum value maps for SqlSupportedPositionedCommands.

View Source 
var (
	SqlSupportedSubqueries_name = map[int32]string{
		0: "SQL_SUBQUERIES_IN_COMPARISONS",
		1: "SQL_SUBQUERIES_IN_EXISTS",
		2: "SQL_SUBQUERIES_IN_INS",
		3: "SQL_SUBQUERIES_IN_QUANTIFIEDS",
	}
	SqlSupportedSubqueries_value = map[string]int32{
		"SQL_SUBQUERIES_IN_COMPARISONS": 0,
		"SQL_SUBQUERIES_IN_EXISTS":      1,
		"SQL_SUBQUERIES_IN_INS":         2,
		"SQL_SUBQUERIES_IN_QUANTIFIEDS": 3,
	}
)

Enum value maps for SqlSupportedSubqueries.

View Source 
var (
	SqlSupportedUnions_name = map[int32]string{
		0: "SQL_UNION",
		1: "SQL_UNION_ALL",
	}
	SqlSupportedUnions_value = map[string]int32{
		"SQL_UNION":     0,
		"SQL_UNION_ALL": 1,
	}
)

Enum value maps for SqlSupportedUnions.

View Source 
var (
	SqlTransactionIsolationLevel_name = map[int32]string{
		0: "SQL_TRANSACTION_NONE",
		1: "SQL_TRANSACTION_READ_UNCOMMITTED",
		2: "SQL_TRANSACTION_READ_COMMITTED",
		3: "SQL_TRANSACTION_REPEATABLE_READ",
		4: "SQL_TRANSACTION_SERIALIZABLE",
	}
	SqlTransactionIsolationLevel_value = map[string]int32{
		"SQL_TRANSACTION_NONE":             0,
		"SQL_TRANSACTION_READ_UNCOMMITTED": 1,
		"SQL_TRANSACTION_READ_COMMITTED":   2,
		"SQL_TRANSACTION_REPEATABLE_READ":  3,
		"SQL_TRANSACTION_SERIALIZABLE":     4,
	}
)

Enum value maps for SqlTransactionIsolationLevel.

View Source 
var (
	SqlSupportedTransactions_name = map[int32]string{
		0: "SQL_TRANSACTION_UNSPECIFIED",
		1: "SQL_DATA_DEFINITION_TRANSACTIONS",
		2: "SQL_DATA_MANIPULATION_TRANSACTIONS",
	}
	SqlSupportedTransactions_value = map[string]int32{
		"SQL_TRANSACTION_UNSPECIFIED":        0,
		"SQL_DATA_DEFINITION_TRANSACTIONS":   1,
		"SQL_DATA_MANIPULATION_TRANSACTIONS": 2,
	}
)

Enum value maps for SqlSupportedTransactions.

View Source 
var (
	SqlSupportedResultSetType_name = map[int32]string{
		0: "SQL_RESULT_SET_TYPE_UNSPECIFIED",
		1: "SQL_RESULT_SET_TYPE_FORWARD_ONLY",
		2: "SQL_RESULT_SET_TYPE_SCROLL_INSENSITIVE",
		3: "SQL_RESULT_SET_TYPE_SCROLL_SENSITIVE",
	}
	SqlSupportedResultSetType_value = map[string]int32{
		"SQL_RESULT_SET_TYPE_UNSPECIFIED":        0,
		"SQL_RESULT_SET_TYPE_FORWARD_ONLY":       1,
		"SQL_RESULT_SET_TYPE_SCROLL_INSENSITIVE": 2,
		"SQL_RESULT_SET_TYPE_SCROLL_SENSITIVE":   3,
	}
)

Enum value maps for SqlSupportedResultSetType.

View Source 
var (
	SqlSupportedResultSetConcurrency_name = map[int32]string{
		0: "SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED",
		1: "SQL_RESULT_SET_CONCURRENCY_READ_ONLY",
		2: "SQL_RESULT_SET_CONCURRENCY_UPDATABLE",
	}
	SqlSupportedResultSetConcurrency_value = map[string]int32{
		"SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED": 0,
		"SQL_RESULT_SET_CONCURRENCY_READ_ONLY":   1,
		"SQL_RESULT_SET_CONCURRENCY_UPDATABLE":   2,
	}
)

Enum value maps for SqlSupportedResultSetConcurrency.

View Source 
var (
	SqlSupportsConvert_name = map[int32]string{
		0:  "SQL_CONVERT_BIGINT",
		1:  "SQL_CONVERT_BINARY",
		2:  "SQL_CONVERT_BIT",
		3:  "SQL_CONVERT_CHAR",
		4:  "SQL_CONVERT_DATE",
		5:  "SQL_CONVERT_DECIMAL",
		6:  "SQL_CONVERT_FLOAT",
		7:  "SQL_CONVERT_INTEGER",
		8:  "SQL_CONVERT_INTERVAL_DAY_TIME",
		9:  "SQL_CONVERT_INTERVAL_YEAR_MONTH",
		10: "SQL_CONVERT_LONGVARBINARY",
		11: "SQL_CONVERT_LONGVARCHAR",
		12: "SQL_CONVERT_NUMERIC",
		13: "SQL_CONVERT_REAL",
		14: "SQL_CONVERT_SMALLINT",
		15: "SQL_CONVERT_TIME",
		16: "SQL_CONVERT_TIMESTAMP",
		17: "SQL_CONVERT_TINYINT",
		18: "SQL_CONVERT_VARBINARY",
		19: "SQL_CONVERT_VARCHAR",
	}
	SqlSupportsConvert_value = map[string]int32{
		"SQL_CONVERT_BIGINT":              0,
		"SQL_CONVERT_BINARY":              1,
		"SQL_CONVERT_BIT":                 2,
		"SQL_CONVERT_CHAR":                3,
		"SQL_CONVERT_DATE":                4,
		"SQL_CONVERT_DECIMAL":             5,
		"SQL_CONVERT_FLOAT":               6,
		"SQL_CONVERT_INTEGER":             7,
		"SQL_CONVERT_INTERVAL_DAY_TIME":   8,
		"SQL_CONVERT_INTERVAL_YEAR_MONTH": 9,
		"SQL_CONVERT_LONGVARBINARY":       10,
		"SQL_CONVERT_LONGVARCHAR":         11,
		"SQL_CONVERT_NUMERIC":             12,
		"SQL_CONVERT_REAL":                13,
		"SQL_CONVERT_SMALLINT":            14,
		"SQL_CONVERT_TIME":                15,
		"SQL_CONVERT_TIMESTAMP":           16,
		"SQL_CONVERT_TINYINT":             17,
		"SQL_CONVERT_VARBINARY":           18,
		"SQL_CONVERT_VARCHAR":             19,
	}
)

Enum value maps for SqlSupportsConvert.

View Source 
var (
	XdbcDataType_name = map[int32]string{
		0:  "XDBC_UNKNOWN_TYPE",
		1:  "XDBC_CHAR",
		2:  "XDBC_NUMERIC",
		3:  "XDBC_DECIMAL",
		4:  "XDBC_INTEGER",
		5:  "XDBC_SMALLINT",
		6:  "XDBC_FLOAT",
		7:  "XDBC_REAL",
		8:  "XDBC_DOUBLE",
		9:  "XDBC_DATETIME",
		10: "XDBC_INTERVAL",
		12: "XDBC_VARCHAR",
		91: "XDBC_DATE",
		92: "XDBC_TIME",
		93: "XDBC_TIMESTAMP",
		-1: "XDBC_LONGVARCHAR",
		-2: "XDBC_BINARY",
		-3: "XDBC_VARBINARY",
		-4: "XDBC_LONGVARBINARY",
		-5: "XDBC_BIGINT",
		-6: "XDBC_TINYINT",
		-7: "XDBC_BIT",
		-8: "XDBC_WCHAR",
		-9: "XDBC_WVARCHAR",
	}
	XdbcDataType_value = map[string]int32{
		"XDBC_UNKNOWN_TYPE":  0,
		"XDBC_CHAR":          1,
		"XDBC_NUMERIC":       2,
		"XDBC_DECIMAL":       3,
		"XDBC_INTEGER":       4,
		"XDBC_SMALLINT":      5,
		"XDBC_FLOAT":         6,
		"XDBC_REAL":          7,
		"XDBC_DOUBLE":        8,
		"XDBC_DATETIME":      9,
		"XDBC_INTERVAL":      10,
		"XDBC_VARCHAR":       12,
		"XDBC_DATE":          91,
		"XDBC_TIME":          92,
		"XDBC_TIMESTAMP":     93,
		"XDBC_LONGVARCHAR":   -1,
		"XDBC_BINARY":        -2,
		"XDBC_VARBINARY":     -3,
		"XDBC_LONGVARBINARY": -4,
		"XDBC_BIGINT":        -5,
		"XDBC_TINYINT":       -6,
		"XDBC_BIT":           -7,
		"XDBC_WCHAR":         -8,
		"XDBC_WVARCHAR":      -9,
	}
)

Enum value maps for XdbcDataType.

View Source 
var (
	XdbcDatetimeSubcode_name = map[int32]string{
		0: "XDBC_SUBCODE_UNKNOWN",
		1: "XDBC_SUBCODE_YEAR",

		2: "XDBC_SUBCODE_TIME",

		3: "XDBC_SUBCODE_TIMESTAMP",

		4: "XDBC_SUBCODE_TIME_WITH_TIMEZONE",

		5: "XDBC_SUBCODE_TIMESTAMP_WITH_TIMEZONE",

		6:   "XDBC_SUBCODE_SECOND",
		7:   "XDBC_SUBCODE_YEAR_TO_MONTH",
		8:   "XDBC_SUBCODE_DAY_TO_HOUR",
		9:   "XDBC_SUBCODE_DAY_TO_MINUTE",
		10:  "XDBC_SUBCODE_DAY_TO_SECOND",
		11:  "XDBC_SUBCODE_HOUR_TO_MINUTE",
		12:  "XDBC_SUBCODE_HOUR_TO_SECOND",
		13:  "XDBC_SUBCODE_MINUTE_TO_SECOND",
		101: "XDBC_SUBCODE_INTERVAL_YEAR",
		102: "XDBC_SUBCODE_INTERVAL_MONTH",
		103: "XDBC_SUBCODE_INTERVAL_DAY",
		104: "XDBC_SUBCODE_INTERVAL_HOUR",
		105: "XDBC_SUBCODE_INTERVAL_MINUTE",
		106: "XDBC_SUBCODE_INTERVAL_SECOND",
		107: "XDBC_SUBCODE_INTERVAL_YEAR_TO_MONTH",
		108: "XDBC_SUBCODE_INTERVAL_DAY_TO_HOUR",
		109: "XDBC_SUBCODE_INTERVAL_DAY_TO_MINUTE",
		110: "XDBC_SUBCODE_INTERVAL_DAY_TO_SECOND",
		111: "XDBC_SUBCODE_INTERVAL_HOUR_TO_MINUTE",
		112: "XDBC_SUBCODE_INTERVAL_HOUR_TO_SECOND",
		113: "XDBC_SUBCODE_INTERVAL_MINUTE_TO_SECOND",
	}
	XdbcDatetimeSubcode_value = map[string]int32{
		"XDBC_SUBCODE_UNKNOWN":                   0,
		"XDBC_SUBCODE_YEAR":                      1,
		"XDBC_SUBCODE_DATE":                      1,
		"XDBC_SUBCODE_TIME":                      2,
		"XDBC_SUBCODE_MONTH":                     2,
		"XDBC_SUBCODE_TIMESTAMP":                 3,
		"XDBC_SUBCODE_DAY":                       3,
		"XDBC_SUBCODE_TIME_WITH_TIMEZONE":        4,
		"XDBC_SUBCODE_HOUR":                      4,
		"XDBC_SUBCODE_TIMESTAMP_WITH_TIMEZONE":   5,
		"XDBC_SUBCODE_MINUTE":                    5,
		"XDBC_SUBCODE_SECOND":                    6,
		"XDBC_SUBCODE_YEAR_TO_MONTH":             7,
		"XDBC_SUBCODE_DAY_TO_HOUR":               8,
		"XDBC_SUBCODE_DAY_TO_MINUTE":             9,
		"XDBC_SUBCODE_DAY_TO_SECOND":             10,
		"XDBC_SUBCODE_HOUR_TO_MINUTE":            11,
		"XDBC_SUBCODE_HOUR_TO_SECOND":            12,
		"XDBC_SUBCODE_MINUTE_TO_SECOND":          13,
		"XDBC_SUBCODE_INTERVAL_YEAR":             101,
		"XDBC_SUBCODE_INTERVAL_MONTH":            102,
		"XDBC_SUBCODE_INTERVAL_DAY":              103,
		"XDBC_SUBCODE_INTERVAL_HOUR":             104,
		"XDBC_SUBCODE_INTERVAL_MINUTE":           105,
		"XDBC_SUBCODE_INTERVAL_SECOND":           106,
		"XDBC_SUBCODE_INTERVAL_YEAR_TO_MONTH":    107,
		"XDBC_SUBCODE_INTERVAL_DAY_TO_HOUR":      108,
		"XDBC_SUBCODE_INTERVAL_DAY_TO_MINUTE":    109,
		"XDBC_SUBCODE_INTERVAL_DAY_TO_SECOND":    110,
		"XDBC_SUBCODE_INTERVAL_HOUR_TO_MINUTE":   111,
		"XDBC_SUBCODE_INTERVAL_HOUR_TO_SECOND":   112,
		"XDBC_SUBCODE_INTERVAL_MINUTE_TO_SECOND": 113,
	}
)

Enum value maps for XdbcDatetimeSubcode.

View Source 
var (
	Nullable_name = map[int32]string{
		0: "NULLABILITY_NO_NULLS",
		1: "NULLABILITY_NULLABLE",
		2: "NULLABILITY_UNKNOWN",
	}
	Nullable_value = map[string]int32{
		"NULLABILITY_NO_NULLS": 0,
		"NULLABILITY_NULLABLE": 1,
		"NULLABILITY_UNKNOWN":  2,
	}
)

Enum value maps for Nullable.

View Source 
var (
	Searchable_name = map[int32]string{
		0: "SEARCHABLE_NONE",
		1: "SEARCHABLE_CHAR",
		2: "SEARCHABLE_BASIC",
		3: "SEARCHABLE_FULL",
	}
	Searchable_value = map[string]int32{
		"SEARCHABLE_NONE":  0,
		"SEARCHABLE_CHAR":  1,
		"SEARCHABLE_BASIC": 2,
		"SEARCHABLE_FULL":  3,
	}
)

Enum value maps for Searchable.

View Source 
var (
	UpdateDeleteRules_name = map[int32]string{
		0: "CASCADE",
		1: "RESTRICT",
		2: "SET_NULL",
		3: "NO_ACTION",
		4: "SET_DEFAULT",
	}
	UpdateDeleteRules_value = map[string]int32{
		"CASCADE":     0,
		"RESTRICT":    1,
		"SET_NULL":    2,
		"NO_ACTION":   3,
		"SET_DEFAULT": 4,
	}
)

Enum value maps for UpdateDeleteRules.

View Source 
var (
	ActionEndTransactionRequest_EndTransaction_name = map[int32]string{
		0: "END_TRANSACTION_UNSPECIFIED",
		1: "END_TRANSACTION_COMMIT",
		2: "END_TRANSACTION_ROLLBACK",
	}
	ActionEndTransactionRequest_EndTransaction_value = map[string]int32{
		"END_TRANSACTION_UNSPECIFIED": 0,
		"END_TRANSACTION_COMMIT":      1,
		"END_TRANSACTION_ROLLBACK":    2,
	}
)

Enum value maps for ActionEndTransactionRequest_EndTransaction.

View Source 
var (
	ActionEndSavepointRequest_EndSavepoint_name = map[int32]string{
		0: "END_SAVEPOINT_UNSPECIFIED",
		1: "END_SAVEPOINT_RELEASE",
		2: "END_SAVEPOINT_ROLLBACK",
	}
	ActionEndSavepointRequest_EndSavepoint_value = map[string]int32{
		"END_SAVEPOINT_UNSPECIFIED": 0,
		"END_SAVEPOINT_RELEASE":     1,
		"END_SAVEPOINT_ROLLBACK":    2,
	}
)

Enum value maps for ActionEndSavepointRequest_EndSavepoint.

View Source 
var (
	ActionCancelQueryResult_CancelResult_name = map[int32]string{
		0: "CANCEL_RESULT_UNSPECIFIED",
		1: "CANCEL_RESULT_CANCELLED",
		2: "CANCEL_RESULT_CANCELLING",
		3: "CANCEL_RESULT_NOT_CANCELLABLE",
	}
	ActionCancelQueryResult_CancelResult_value = map[string]int32{
		"CANCEL_RESULT_UNSPECIFIED":     0,
		"CANCEL_RESULT_CANCELLED":       1,
		"CANCEL_RESULT_CANCELLING":      2,
		"CANCEL_RESULT_NOT_CANCELLABLE": 3,
	}
)

Enum value maps for ActionCancelQueryResult_CancelResult.

View Source 
var (
	// optional bool experimental = 1000;
	E_Experimental = &file_FlightSql_proto_extTypes[0]
)

Extension fields to descriptorpb.MessageOptions.

View Source 
var File_FlightSql_proto protoreflect.FileDescriptor
View Source 
var File_Flight_proto protoreflect.FileDescriptor
View Source 
var FlightService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "arrow.flight.protocol.FlightService",
	HandlerType: (*FlightServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetFlightInfo",
			Handler:    _FlightService_GetFlightInfo_Handler,
		},
		{
			MethodName: "PollFlightInfo",
			Handler:    _FlightService_PollFlightInfo_Handler,
		},
		{
			MethodName: "GetSchema",
			Handler:    _FlightService_GetSchema_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Handshake",
			Handler:       _FlightService_Handshake_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "ListFlights",
			Handler:       _FlightService_ListFlights_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DoGet",
			Handler:       _FlightService_DoGet_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DoPut",
			Handler:       _FlightService_DoPut_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "DoExchange",
			Handler:       _FlightService_DoExchange_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "DoAction",
			Handler:       _FlightService_DoAction_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ListActions",
			Handler:       _FlightService_ListActions_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "Flight.proto",
}

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

Functions

func RegisterFlightServiceServer 

func RegisterFlightServiceServer(s grpc.ServiceRegistrar, srv FlightServiceServer)

Types

type Action 

type Action struct {
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Body []byte `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

An opaque action specific for the service.

func (*Action) Descriptor deprecated 

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

Deprecated: Use Action.ProtoReflect.Descriptor instead.

func (*Action) GetBody 

func (x *Action) GetBody() []byte

func (*Action) GetType 

func (x *Action) GetType() string

func (*Action) ProtoMessage 

func (*Action) ProtoMessage()

func (*Action) ProtoReflect 

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

func (*Action) Reset 

func (x *Action) Reset()

func (*Action) String 

func (x *Action) String() string

type ActionBeginSavepointRequest 

type ActionBeginSavepointRequest struct {

	// The transaction to which a savepoint belongs.
	TransactionId []byte `protobuf:"bytes,1,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	// Name for the savepoint.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request message for the "BeginSavepoint" action. Creates a savepoint within a transaction.

Only supported if FLIGHT_SQL_TRANSACTION is FLIGHT_SQL_TRANSACTION_SUPPORT_SAVEPOINT.

func (*ActionBeginSavepointRequest) Descriptor deprecated 

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

Deprecated: Use ActionBeginSavepointRequest.ProtoReflect.Descriptor instead.

func (*ActionBeginSavepointRequest) GetName 

func (x *ActionBeginSavepointRequest) GetName() string

func (*ActionBeginSavepointRequest) GetTransactionId 

func (x *ActionBeginSavepointRequest) GetTransactionId() []byte

func (*ActionBeginSavepointRequest) ProtoMessage 

func (*ActionBeginSavepointRequest) ProtoMessage()

func (*ActionBeginSavepointRequest) ProtoReflect 

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

func (*ActionBeginSavepointRequest) Reset 

func (x *ActionBeginSavepointRequest) Reset()

func (*ActionBeginSavepointRequest) String 

func (x *ActionBeginSavepointRequest) String() string

type ActionBeginSavepointResult 

type ActionBeginSavepointResult struct {

	// Opaque handle for the savepoint on the server.
	SavepointId []byte `protobuf:"bytes,1,opt,name=savepoint_id,json=savepointId,proto3" json:"savepoint_id,omitempty"`
	// contains filtered or unexported fields
}

The result of a "BeginSavepoint" action.

The transaction can be manipulated with the "EndSavepoint" action. If the associated transaction is committed, rolled back, or times out, then the savepoint is also invalidated.

The result should be wrapped in a google.protobuf.Any message.

func (*ActionBeginSavepointResult) Descriptor deprecated 

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

Deprecated: Use ActionBeginSavepointResult.ProtoReflect.Descriptor instead.

func (*ActionBeginSavepointResult) GetSavepointId 

func (x *ActionBeginSavepointResult) GetSavepointId() []byte

func (*ActionBeginSavepointResult) ProtoMessage 

func (*ActionBeginSavepointResult) ProtoMessage()

func (*ActionBeginSavepointResult) ProtoReflect 

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

func (*ActionBeginSavepointResult) Reset 

func (x *ActionBeginSavepointResult) Reset()

func (*ActionBeginSavepointResult) String 

func (x *ActionBeginSavepointResult) String() string

type ActionBeginTransactionRequest 

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

Request message for the "BeginTransaction" action. Begins a transaction.

func (*ActionBeginTransactionRequest) Descriptor deprecated 

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

Deprecated: Use ActionBeginTransactionRequest.ProtoReflect.Descriptor instead.

func (*ActionBeginTransactionRequest) ProtoMessage 

func (*ActionBeginTransactionRequest) ProtoMessage()

func (*ActionBeginTransactionRequest) ProtoReflect 

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

func (*ActionBeginTransactionRequest) Reset 

func (x *ActionBeginTransactionRequest) Reset()

func (*ActionBeginTransactionRequest) String 

func (x *ActionBeginTransactionRequest) String() string

type ActionBeginTransactionResult 

type ActionBeginTransactionResult struct {

	// Opaque handle for the transaction on the server.
	TransactionId []byte `protobuf:"bytes,1,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	// contains filtered or unexported fields
}

The result of a "BeginTransaction" action.

The transaction can be manipulated with the "EndTransaction" action, or automatically via server timeout. If the transaction times out, then it is automatically rolled back.

The result should be wrapped in a google.protobuf.Any message.

func (*ActionBeginTransactionResult) Descriptor deprecated 

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

Deprecated: Use ActionBeginTransactionResult.ProtoReflect.Descriptor instead.

func (*ActionBeginTransactionResult) GetTransactionId 

func (x *ActionBeginTransactionResult) GetTransactionId() []byte

func (*ActionBeginTransactionResult) ProtoMessage 

func (*ActionBeginTransactionResult) ProtoMessage()

func (*ActionBeginTransactionResult) ProtoReflect 

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

func (*ActionBeginTransactionResult) Reset 

func (x *ActionBeginTransactionResult) Reset()

func (*ActionBeginTransactionResult) String 

func (x *ActionBeginTransactionResult) String() string

type ActionCancelQueryRequest deprecated 

type ActionCancelQueryRequest struct {

	// The result of the GetFlightInfo RPC that initiated the query.
	// XXX(ARROW-16902): this must be a serialized FlightInfo, but is
	// rendered as bytes because Protobuf does not really support one
	// DLL using Protobuf definitions from another DLL.
	Info []byte `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

Request message for the "CancelQuery" action.

Explicitly cancel a running query.

This lets a single client explicitly cancel work, no matter how many clients are involved/whether the query is distributed or not, given server support. The transaction/statement is not rolled back; it is the application's job to commit or rollback as appropriate. This only indicates the client no longer wishes to read the remainder of the query results or continue submitting data.

This command is idempotent.

This command is deprecated since 13.0.0. Use the "CancelFlightInfo" action with DoAction instead.

Deprecated: Do not use.

func (*ActionCancelQueryRequest) Descriptor deprecated 

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

Deprecated: Use ActionCancelQueryRequest.ProtoReflect.Descriptor instead.

func (*ActionCancelQueryRequest) GetInfo 

func (x *ActionCancelQueryRequest) GetInfo() []byte

func (*ActionCancelQueryRequest) ProtoMessage 

func (*ActionCancelQueryRequest) ProtoMessage()

func (*ActionCancelQueryRequest) ProtoReflect 

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

func (*ActionCancelQueryRequest) Reset 

func (x *ActionCancelQueryRequest) Reset()

func (*ActionCancelQueryRequest) String 

func (x *ActionCancelQueryRequest) String() string

type ActionCancelQueryResult deprecated 

type ActionCancelQueryResult struct {
	Result ActionCancelQueryResult_CancelResult `` /* 134-byte string literal not displayed */
	// contains filtered or unexported fields
}

The result of cancelling a query.

The result should be wrapped in a google.protobuf.Any message.

This command is deprecated since 13.0.0. Use the "CancelFlightInfo" action with DoAction instead.

Deprecated: Do not use.

func (*ActionCancelQueryResult) Descriptor deprecated 

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

Deprecated: Use ActionCancelQueryResult.ProtoReflect.Descriptor instead.

func (*ActionCancelQueryResult) GetResult 

func (x *ActionCancelQueryResult) GetResult() ActionCancelQueryResult_CancelResult

func (*ActionCancelQueryResult) ProtoMessage 

func (*ActionCancelQueryResult) ProtoMessage()

func (*ActionCancelQueryResult) ProtoReflect 

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

func (*ActionCancelQueryResult) Reset 

func (x *ActionCancelQueryResult) Reset()

func (*ActionCancelQueryResult) String 

func (x *ActionCancelQueryResult) String() string

type ActionCancelQueryResult_CancelResult 

type ActionCancelQueryResult_CancelResult int32
const (
	// The cancellation status is unknown. Servers should avoid using
	// this value (send a NOT_FOUND error if the requested query is
	// not known). Clients can retry the request.
	ActionCancelQueryResult_CANCEL_RESULT_UNSPECIFIED ActionCancelQueryResult_CancelResult = 0
	// The cancellation request is complete. Subsequent requests with
	// the same payload may return CANCELLED or a NOT_FOUND error.
	ActionCancelQueryResult_CANCEL_RESULT_CANCELLED ActionCancelQueryResult_CancelResult = 1
	// The cancellation request is in progress. The client may retry
	// the cancellation request.
	ActionCancelQueryResult_CANCEL_RESULT_CANCELLING ActionCancelQueryResult_CancelResult = 2
	// The query is not cancellable. The client should not retry the
	// cancellation request.
	ActionCancelQueryResult_CANCEL_RESULT_NOT_CANCELLABLE ActionCancelQueryResult_CancelResult = 3
)

func (ActionCancelQueryResult_CancelResult) Descriptor 

func (ActionCancelQueryResult_CancelResult) Descriptor() protoreflect.EnumDescriptor

func (ActionCancelQueryResult_CancelResult) Enum 

func (x ActionCancelQueryResult_CancelResult) Enum() *ActionCancelQueryResult_CancelResult

func (ActionCancelQueryResult_CancelResult) EnumDescriptor deprecated 

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

Deprecated: Use ActionCancelQueryResult_CancelResult.Descriptor instead.

func (ActionCancelQueryResult_CancelResult) Number 

func (x ActionCancelQueryResult_CancelResult) Number() protoreflect.EnumNumber

func (ActionCancelQueryResult_CancelResult) String 

func (x ActionCancelQueryResult_CancelResult) String() string

func (ActionCancelQueryResult_CancelResult) Type 

func (ActionCancelQueryResult_CancelResult) Type() protoreflect.EnumType

type ActionClosePreparedStatementRequest 

type ActionClosePreparedStatementRequest struct {

	// Opaque handle for the prepared statement on the server.
	PreparedStatementHandle []byte `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

Request message for the "ClosePreparedStatement" action on a Flight SQL enabled backend. Closes server resources associated with the prepared statement handle.

func (*ActionClosePreparedStatementRequest) Descriptor deprecated 

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

Deprecated: Use ActionClosePreparedStatementRequest.ProtoReflect.Descriptor instead.

func (*ActionClosePreparedStatementRequest) GetPreparedStatementHandle 

func (x *ActionClosePreparedStatementRequest) GetPreparedStatementHandle() []byte

func (*ActionClosePreparedStatementRequest) ProtoMessage 

func (*ActionClosePreparedStatementRequest) ProtoMessage()

func (*ActionClosePreparedStatementRequest) ProtoReflect 

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

func (*ActionClosePreparedStatementRequest) Reset 

func (x *ActionClosePreparedStatementRequest) Reset()

func (*ActionClosePreparedStatementRequest) String 

func (x *ActionClosePreparedStatementRequest) String() string

type ActionCreatePreparedStatementRequest 

type ActionCreatePreparedStatementRequest struct {

	// The valid SQL string to create a prepared statement for.
	Query string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	// Create/execute the prepared statement as part of this transaction (if
	// unset, executions of the prepared statement will be auto-committed).
	TransactionId []byte `protobuf:"bytes,2,opt,name=transaction_id,json=transactionId,proto3,oneof" json:"transaction_id,omitempty"`
	// contains filtered or unexported fields
}

Request message for the "CreatePreparedStatement" action on a Flight SQL enabled backend.

func (*ActionCreatePreparedStatementRequest) Descriptor deprecated 

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

Deprecated: Use ActionCreatePreparedStatementRequest.ProtoReflect.Descriptor instead.

func (*ActionCreatePreparedStatementRequest) GetQuery 

func (x *ActionCreatePreparedStatementRequest) GetQuery() string

func (*ActionCreatePreparedStatementRequest) GetTransactionId 

func (x *ActionCreatePreparedStatementRequest) GetTransactionId() []byte

func (*ActionCreatePreparedStatementRequest) ProtoMessage 

func (*ActionCreatePreparedStatementRequest) ProtoMessage()

func (*ActionCreatePreparedStatementRequest) ProtoReflect 

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

func (*ActionCreatePreparedStatementRequest) Reset 

func (x *ActionCreatePreparedStatementRequest) Reset()

func (*ActionCreatePreparedStatementRequest) String 

func (x *ActionCreatePreparedStatementRequest) String() string

type ActionCreatePreparedStatementResult 

type ActionCreatePreparedStatementResult struct {

	// Opaque handle for the prepared statement on the server.
	PreparedStatementHandle []byte `` /* 132-byte string literal not displayed */
	// If a result set generating query was provided, dataset_schema contains the
	// schema of the dataset as described in Schema.fbs::Schema, it is serialized as an IPC message.
	DatasetSchema []byte `protobuf:"bytes,2,opt,name=dataset_schema,json=datasetSchema,proto3" json:"dataset_schema,omitempty"`
	// If the query provided contained parameters, parameter_schema contains the
	// schema of the expected parameters as described in Schema.fbs::Schema, it is serialized as an IPC message.
	ParameterSchema []byte `protobuf:"bytes,3,opt,name=parameter_schema,json=parameterSchema,proto3" json:"parameter_schema,omitempty"`
	// contains filtered or unexported fields
}

Wrap the result of a "CreatePreparedStatement" or "CreatePreparedSubstraitPlan" action.

The resultant PreparedStatement can be closed either: - Manually, through the "ClosePreparedStatement" action; - Automatically, by a server timeout.

The result should be wrapped in a google.protobuf.Any message.

func (*ActionCreatePreparedStatementResult) Descriptor deprecated 

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

Deprecated: Use ActionCreatePreparedStatementResult.ProtoReflect.Descriptor instead.

func (*ActionCreatePreparedStatementResult) GetDatasetSchema 

func (x *ActionCreatePreparedStatementResult) GetDatasetSchema() []byte

func (*ActionCreatePreparedStatementResult) GetParameterSchema 

func (x *ActionCreatePreparedStatementResult) GetParameterSchema() []byte

func (*ActionCreatePreparedStatementResult) GetPreparedStatementHandle 

func (x *ActionCreatePreparedStatementResult) GetPreparedStatementHandle() []byte

func (*ActionCreatePreparedStatementResult) ProtoMessage 

func (*ActionCreatePreparedStatementResult) ProtoMessage()

func (*ActionCreatePreparedStatementResult) ProtoReflect 

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

func (*ActionCreatePreparedStatementResult) Reset 

func (x *ActionCreatePreparedStatementResult) Reset()

func (*ActionCreatePreparedStatementResult) String 

func (x *ActionCreatePreparedStatementResult) String() string

type ActionCreatePreparedSubstraitPlanRequest 

type ActionCreatePreparedSubstraitPlanRequest struct {

	// The serialized substrait.Plan to create a prepared statement for.
	Plan *SubstraitPlan `protobuf:"bytes,1,opt,name=plan,proto3" json:"plan,omitempty"`
	// Create/execute the prepared statement as part of this transaction (if
	// unset, executions of the prepared statement will be auto-committed).
	TransactionId []byte `protobuf:"bytes,2,opt,name=transaction_id,json=transactionId,proto3,oneof" json:"transaction_id,omitempty"`
	// contains filtered or unexported fields
}

Request message for the "CreatePreparedSubstraitPlan" action on a Flight SQL enabled backend.

func (*ActionCreatePreparedSubstraitPlanRequest) Descriptor deprecated 

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

Deprecated: Use ActionCreatePreparedSubstraitPlanRequest.ProtoReflect.Descriptor instead.

func (*ActionCreatePreparedSubstraitPlanRequest) GetPlan 

func (x *ActionCreatePreparedSubstraitPlanRequest) GetPlan() *SubstraitPlan

func (*ActionCreatePreparedSubstraitPlanRequest) GetTransactionId 

func (x *ActionCreatePreparedSubstraitPlanRequest) GetTransactionId() []byte

func (*ActionCreatePreparedSubstraitPlanRequest) ProtoMessage 

func (*ActionCreatePreparedSubstraitPlanRequest) ProtoMessage()

func (*ActionCreatePreparedSubstraitPlanRequest) ProtoReflect 

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

func (*ActionCreatePreparedSubstraitPlanRequest) Reset 

func (x *ActionCreatePreparedSubstraitPlanRequest) Reset()

func (*ActionCreatePreparedSubstraitPlanRequest) String 

func (x *ActionCreatePreparedSubstraitPlanRequest) String() string

type ActionEndSavepointRequest 

type ActionEndSavepointRequest struct {

	// Opaque handle for the savepoint on the server.
	SavepointId []byte `protobuf:"bytes,1,opt,name=savepoint_id,json=savepointId,proto3" json:"savepoint_id,omitempty"`
	// Whether to rollback/release the given savepoint.
	Action ActionEndSavepointRequest_EndSavepoint `` /* 136-byte string literal not displayed */
	// contains filtered or unexported fields
}

Request message for the "EndSavepoint" action.

Release (RELEASE) the savepoint or rollback (ROLLBACK) to the savepoint.

Releasing a savepoint invalidates that savepoint. Rolling back to a savepoint does not invalidate the savepoint, but invalidates all savepoints created after the current savepoint.

func (*ActionEndSavepointRequest) Descriptor deprecated 

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

Deprecated: Use ActionEndSavepointRequest.ProtoReflect.Descriptor instead.

func (*ActionEndSavepointRequest) GetAction 

func (x *ActionEndSavepointRequest) GetAction() ActionEndSavepointRequest_EndSavepoint

func (*ActionEndSavepointRequest) GetSavepointId 

func (x *ActionEndSavepointRequest) GetSavepointId() []byte

func (*ActionEndSavepointRequest) ProtoMessage 

func (*ActionEndSavepointRequest) ProtoMessage()

func (*ActionEndSavepointRequest) ProtoReflect 

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

func (*ActionEndSavepointRequest) Reset 

func (x *ActionEndSavepointRequest) Reset()

func (*ActionEndSavepointRequest) String 

func (x *ActionEndSavepointRequest) String() string

type ActionEndSavepointRequest_EndSavepoint 

type ActionEndSavepointRequest_EndSavepoint int32
const (
	ActionEndSavepointRequest_END_SAVEPOINT_UNSPECIFIED ActionEndSavepointRequest_EndSavepoint = 0
	// Release the savepoint.
	ActionEndSavepointRequest_END_SAVEPOINT_RELEASE ActionEndSavepointRequest_EndSavepoint = 1
	// Roll back to a savepoint.
	ActionEndSavepointRequest_END_SAVEPOINT_ROLLBACK ActionEndSavepointRequest_EndSavepoint = 2
)

func (ActionEndSavepointRequest_EndSavepoint) Descriptor 

func (ActionEndSavepointRequest_EndSavepoint) Descriptor() protoreflect.EnumDescriptor

func (ActionEndSavepointRequest_EndSavepoint) Enum 

func (x ActionEndSavepointRequest_EndSavepoint) Enum() *ActionEndSavepointRequest_EndSavepoint

func (ActionEndSavepointRequest_EndSavepoint) EnumDescriptor deprecated 

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

Deprecated: Use ActionEndSavepointRequest_EndSavepoint.Descriptor instead.

func (ActionEndSavepointRequest_EndSavepoint) Number 

func (x ActionEndSavepointRequest_EndSavepoint) Number() protoreflect.EnumNumber

func (ActionEndSavepointRequest_EndSavepoint) String 

func (x ActionEndSavepointRequest_EndSavepoint) String() string

func (ActionEndSavepointRequest_EndSavepoint) Type 

func (ActionEndSavepointRequest_EndSavepoint) Type() protoreflect.EnumType

type ActionEndTransactionRequest 

type ActionEndTransactionRequest struct {

	// Opaque handle for the transaction on the server.
	TransactionId []byte `protobuf:"bytes,1,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	// Whether to commit/rollback the given transaction.
	Action ActionEndTransactionRequest_EndTransaction `` /* 140-byte string literal not displayed */
	// contains filtered or unexported fields
}

Request message for the "EndTransaction" action.

Commit (COMMIT) or rollback (ROLLBACK) the transaction.

If the action completes successfully, the transaction handle is invalidated, as are all associated savepoints.

func (*ActionEndTransactionRequest) Descriptor deprecated 

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

Deprecated: Use ActionEndTransactionRequest.ProtoReflect.Descriptor instead.

func (*ActionEndTransactionRequest) GetAction 

func (x *ActionEndTransactionRequest) GetAction() ActionEndTransactionRequest_EndTransaction

func (*ActionEndTransactionRequest) GetTransactionId 

func (x *ActionEndTransactionRequest) GetTransactionId() []byte

func (*ActionEndTransactionRequest) ProtoMessage 

func (*ActionEndTransactionRequest) ProtoMessage()

func (*ActionEndTransactionRequest) ProtoReflect 

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

func (*ActionEndTransactionRequest) Reset 

func (x *ActionEndTransactionRequest) Reset()

func (*ActionEndTransactionRequest) String 

func (x *ActionEndTransactionRequest) String() string

type ActionEndTransactionRequest_EndTransaction 

type ActionEndTransactionRequest_EndTransaction int32
const (
	ActionEndTransactionRequest_END_TRANSACTION_UNSPECIFIED ActionEndTransactionRequest_EndTransaction = 0
	// Commit the transaction.
	ActionEndTransactionRequest_END_TRANSACTION_COMMIT ActionEndTransactionRequest_EndTransaction = 1
	// Roll back the transaction.
	ActionEndTransactionRequest_END_TRANSACTION_ROLLBACK ActionEndTransactionRequest_EndTransaction = 2
)

func (ActionEndTransactionRequest_EndTransaction) Descriptor 

func (ActionEndTransactionRequest_EndTransaction) Descriptor() protoreflect.EnumDescriptor

func (ActionEndTransactionRequest_EndTransaction) Enum 

func (x ActionEndTransactionRequest_EndTransaction) Enum() *ActionEndTransactionRequest_EndTransaction

func (ActionEndTransactionRequest_EndTransaction) EnumDescriptor deprecated 

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

Deprecated: Use ActionEndTransactionRequest_EndTransaction.Descriptor instead.

func (ActionEndTransactionRequest_EndTransaction) Number 

func (x ActionEndTransactionRequest_EndTransaction) Number() protoreflect.EnumNumber

func (ActionEndTransactionRequest_EndTransaction) String 

func (x ActionEndTransactionRequest_EndTransaction) String() string

func (ActionEndTransactionRequest_EndTransaction) Type 

func (ActionEndTransactionRequest_EndTransaction) Type() protoreflect.EnumType

type ActionType 

type ActionType struct {
	Type        string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

Describes an available action, including both the name used for execution along with a short description of the purpose of the action.

func (*ActionType) Descriptor deprecated 

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

Deprecated: Use ActionType.ProtoReflect.Descriptor instead.

func (*ActionType) GetDescription 

func (x *ActionType) GetDescription() string

func (*ActionType) GetType 

func (x *ActionType) GetType() string

func (*ActionType) ProtoMessage 

func (*ActionType) ProtoMessage()

func (*ActionType) ProtoReflect 

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

func (*ActionType) Reset 

func (x *ActionType) Reset()

func (*ActionType) String 

func (x *ActionType) String() string

type BasicAuth 

type BasicAuth struct {
	Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	Password string `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

A message for doing simple auth.

func (*BasicAuth) Descriptor deprecated 

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

Deprecated: Use BasicAuth.ProtoReflect.Descriptor instead.

func (*BasicAuth) GetPassword 

func (x *BasicAuth) GetPassword() string

func (*BasicAuth) GetUsername 

func (x *BasicAuth) GetUsername() string

func (*BasicAuth) ProtoMessage 

func (*BasicAuth) ProtoMessage()

func (*BasicAuth) ProtoReflect 

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

func (*BasicAuth) Reset 

func (x *BasicAuth) Reset()

func (*BasicAuth) String 

func (x *BasicAuth) String() string

type CancelFlightInfoRequest 

type CancelFlightInfoRequest struct {
	Info *FlightInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

The request of the CancelFlightInfo action.

The request should be stored in Action.body.

func (*CancelFlightInfoRequest) Descriptor deprecated 

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

Deprecated: Use CancelFlightInfoRequest.ProtoReflect.Descriptor instead.

func (*CancelFlightInfoRequest) GetInfo 

func (x *CancelFlightInfoRequest) GetInfo() *FlightInfo

func (*CancelFlightInfoRequest) ProtoMessage 

func (*CancelFlightInfoRequest) ProtoMessage()

func (*CancelFlightInfoRequest) ProtoReflect 

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

func (*CancelFlightInfoRequest) Reset 

func (x *CancelFlightInfoRequest) Reset()

func (*CancelFlightInfoRequest) String 

func (x *CancelFlightInfoRequest) String() string

type CancelFlightInfoResult 

type CancelFlightInfoResult struct {
	Status CancelStatus `protobuf:"varint,1,opt,name=status,proto3,enum=arrow.flight.protocol.CancelStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

The result of the CancelFlightInfo action.

The result should be stored in Result.body.

func (*CancelFlightInfoResult) Descriptor deprecated 

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

Deprecated: Use CancelFlightInfoResult.ProtoReflect.Descriptor instead.

func (*CancelFlightInfoResult) GetStatus 

func (x *CancelFlightInfoResult) GetStatus() CancelStatus

func (*CancelFlightInfoResult) ProtoMessage 

func (*CancelFlightInfoResult) ProtoMessage()

func (*CancelFlightInfoResult) ProtoReflect 

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

func (*CancelFlightInfoResult) Reset 

func (x *CancelFlightInfoResult) Reset()

func (*CancelFlightInfoResult) String 

func (x *CancelFlightInfoResult) String() string

type CancelStatus 

type CancelStatus int32

The result of a cancel operation.

This is used by CancelFlightInfoResult.status. 

const (
	// The cancellation status is unknown. Servers should avoid using
	// this value (send a NOT_FOUND error if the requested query is
	// not known). Clients can retry the request.
	CancelStatus_CANCEL_STATUS_UNSPECIFIED CancelStatus = 0
	// The cancellation request is complete. Subsequent requests with
	// the same payload may return CANCELLED or a NOT_FOUND error.
	CancelStatus_CANCEL_STATUS_CANCELLED CancelStatus = 1
	// The cancellation request is in progress. The client may retry
	// the cancellation request.
	CancelStatus_CANCEL_STATUS_CANCELLING CancelStatus = 2
	// The query is not cancellable. The client should not retry the
	// cancellation request.
	CancelStatus_CANCEL_STATUS_NOT_CANCELLABLE CancelStatus = 3
)

func (CancelStatus) Descriptor 

func (CancelStatus) Descriptor() protoreflect.EnumDescriptor

func (CancelStatus) Enum 

func (x CancelStatus) Enum() *CancelStatus

func (CancelStatus) EnumDescriptor deprecated 

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

Deprecated: Use CancelStatus.Descriptor instead.

func (CancelStatus) Number 

func (x CancelStatus) Number() protoreflect.EnumNumber

func (CancelStatus) String 

func (x CancelStatus) String() string

func (CancelStatus) Type 

func (CancelStatus) Type() protoreflect.EnumType

type CommandGetCatalogs 

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

Represents a request to retrieve the list of catalogs on a Flight SQL enabled backend. The definition of a catalog depends on vendor/implementation. It is usually the database itself Used in the command member of FlightDescriptor for the following RPC calls:

  • GetSchema: return the Arrow schema of the query.
  • GetFlightInfo: execute the catalog metadata request.

The returned Arrow schema will be: < 

catalog_name: utf8 not null

> The returned data should be ordered by catalog_name.

func (*CommandGetCatalogs) Descriptor deprecated 

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

Deprecated: Use CommandGetCatalogs.ProtoReflect.Descriptor instead.

func (*CommandGetCatalogs) ProtoMessage 

func (*CommandGetCatalogs) ProtoMessage()

func (*CommandGetCatalogs) ProtoReflect 

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

func (*CommandGetCatalogs) Reset 

func (x *CommandGetCatalogs) Reset()

func (*CommandGetCatalogs) String 

func (x *CommandGetCatalogs) String() string

type CommandGetCrossReference 

type CommandGetCrossReference struct {

	//*
	// The catalog name where the parent table is.
	// An empty string retrieves those without a catalog.
	// If omitted the catalog name should not be used to narrow the search.
	PkCatalog *string `protobuf:"bytes,1,opt,name=pk_catalog,json=pkCatalog,proto3,oneof" json:"pk_catalog,omitempty"`
	//*
	// The Schema name where the parent table is.
	// An empty string retrieves those without a schema.
	// If omitted the schema name should not be used to narrow the search.
	PkDbSchema *string `protobuf:"bytes,2,opt,name=pk_db_schema,json=pkDbSchema,proto3,oneof" json:"pk_db_schema,omitempty"`
	//*
	// The parent table name. It cannot be null.
	PkTable string `protobuf:"bytes,3,opt,name=pk_table,json=pkTable,proto3" json:"pk_table,omitempty"`
	//*
	// The catalog name where the foreign table is.
	// An empty string retrieves those without a catalog.
	// If omitted the catalog name should not be used to narrow the search.
	FkCatalog *string `protobuf:"bytes,4,opt,name=fk_catalog,json=fkCatalog,proto3,oneof" json:"fk_catalog,omitempty"`
	//*
	// The schema name where the foreign table is.
	// An empty string retrieves those without a schema.
	// If omitted the schema name should not be used to narrow the search.
	FkDbSchema *string `protobuf:"bytes,5,opt,name=fk_db_schema,json=fkDbSchema,proto3,oneof" json:"fk_db_schema,omitempty"`
	//*
	// The foreign table name. It cannot be null.
	FkTable string `protobuf:"bytes,6,opt,name=fk_table,json=fkTable,proto3" json:"fk_table,omitempty"`
	// contains filtered or unexported fields
}

Represents a request to retrieve a description of the foreign key columns in the given foreign key table that reference the primary key or the columns representing a unique constraint of the parent table (could be the same or a different table) on a Flight SQL enabled backend. Used in the command member of FlightDescriptor for the following RPC calls:

  • GetSchema: return the Arrow schema of the query.
  • GetFlightInfo: execute the catalog metadata request.

The returned Arrow schema will be: < 

pk_catalog_name: utf8,
pk_db_schema_name: utf8,
pk_table_name: utf8 not null,
pk_column_name: utf8 not null,
fk_catalog_name: utf8,
fk_db_schema_name: utf8,
fk_table_name: utf8 not null,
fk_column_name: utf8 not null,
key_sequence: int32 not null,
fk_key_name: utf8,
pk_key_name: utf8,
update_rule: uint8 not null,
delete_rule: uint8 not null

> The returned data should be ordered by pk_catalog_name, pk_db_schema_name, pk_table_name, pk_key_name, then key_sequence. update_rule and delete_rule returns a byte that is equivalent to actions:

  • 0 = CASCADE
  • 1 = RESTRICT
  • 2 = SET NULL
  • 3 = NO ACTION
  • 4 = SET DEFAULT

func (*CommandGetCrossReference) Descriptor deprecated 

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

Deprecated: Use CommandGetCrossReference.ProtoReflect.Descriptor instead.

func (*CommandGetCrossReference) GetFkCatalog 

func (x *CommandGetCrossReference) GetFkCatalog() string

func (*CommandGetCrossReference) GetFkDbSchema 

func (x *CommandGetCrossReference) GetFkDbSchema() string

func (*CommandGetCrossReference) GetFkTable 

func (x *CommandGetCrossReference) GetFkTable() string

func (*CommandGetCrossReference) GetPkCatalog 

func (x *CommandGetCrossReference) GetPkCatalog() string

func (*CommandGetCrossReference) GetPkDbSchema 

func (x *CommandGetCrossReference) GetPkDbSchema() string

func (*CommandGetCrossReference) GetPkTable 

func (x *CommandGetCrossReference) GetPkTable() string

func (*CommandGetCrossReference) ProtoMessage 

func (*CommandGetCrossReference) ProtoMessage()

func (*CommandGetCrossReference) ProtoReflect 

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

func (*CommandGetCrossReference) Reset 

func (x *CommandGetCrossReference) Reset()

func (*CommandGetCrossReference) String 

func (x *CommandGetCrossReference) String() string

type CommandGetDbSchemas 

type CommandGetDbSchemas struct {

	//
	// Specifies the Catalog to search for the tables.
	// An empty string retrieves those without a catalog.
	// If omitted the catalog name should not be used to narrow the search.
	Catalog *string `protobuf:"bytes,1,opt,name=catalog,proto3,oneof" json:"catalog,omitempty"`
	//
	// Specifies a filter pattern for schemas to search for.
	// When no db_schema_filter_pattern is provided, the pattern will not be used to narrow the search.
	// In the pattern string, two special characters can be used to denote matching rules:
	//    - "%" means to match any substring with 0 or more characters.
	//    - "_" means to match any one character.
	DbSchemaFilterPattern *string `` /* 134-byte string literal not displayed */
	// contains filtered or unexported fields
}

Represents a request to retrieve the list of database schemas on a Flight SQL enabled backend. The definition of a database schema depends on vendor/implementation. It is usually a collection of tables. Used in the command member of FlightDescriptor for the following RPC calls:

  • GetSchema: return the Arrow schema of the query.
  • GetFlightInfo: execute the catalog metadata request.

The returned Arrow schema will be: < 

catalog_name: utf8,
db_schema_name: utf8 not null

> The returned data should be ordered by catalog_name, then db_schema_name.

func (*CommandGetDbSchemas) Descriptor deprecated 

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

Deprecated: Use CommandGetDbSchemas.ProtoReflect.Descriptor instead.

func (*CommandGetDbSchemas) GetCatalog 

func (x *CommandGetDbSchemas) GetCatalog() string

func (*CommandGetDbSchemas) GetDbSchemaFilterPattern 

func (x *CommandGetDbSchemas) GetDbSchemaFilterPattern() string

func (*CommandGetDbSchemas) ProtoMessage 

func (*CommandGetDbSchemas) ProtoMessage()

func (*CommandGetDbSchemas) ProtoReflect 

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

func (*CommandGetDbSchemas) Reset 

func (x *CommandGetDbSchemas) Reset()

func (*CommandGetDbSchemas) String 

func (x *CommandGetDbSchemas) String() string

type CommandGetExportedKeys 

type CommandGetExportedKeys struct {

	//
	// Specifies the catalog to search for the foreign key table.
	// An empty string retrieves those without a catalog.
	// If omitted the catalog name should not be used to narrow the search.
	Catalog *string `protobuf:"bytes,1,opt,name=catalog,proto3,oneof" json:"catalog,omitempty"`
	//
	// Specifies the schema to search for the foreign key table.
	// An empty string retrieves those without a schema.
	// If omitted the schema name should not be used to narrow the search.
	DbSchema *string `protobuf:"bytes,2,opt,name=db_schema,json=dbSchema,proto3,oneof" json:"db_schema,omitempty"`
	// Specifies the foreign key table to get the foreign keys for.
	Table string `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"`
	// contains filtered or unexported fields
}

Represents a request to retrieve a description of the foreign key columns that reference the given table's primary key columns (the foreign keys exported by a table) of a table on a Flight SQL enabled backend. Used in the command member of FlightDescriptor for the following RPC calls:

  • GetSchema: return the Arrow schema of the query.
  • GetFlightInfo: execute the catalog metadata request.

The returned Arrow schema will be: < 

pk_catalog_name: utf8,
pk_db_schema_name: utf8,
pk_table_name: utf8 not null,
pk_column_name: utf8 not null,
fk_catalog_name: utf8,
fk_db_schema_name: utf8,
fk_table_name: utf8 not null,
fk_column_name: utf8 not null,
key_sequence: int32 not null,
fk_key_name: utf8,
pk_key_name: utf8,
update_rule: uint8 not null,
delete_rule: uint8 not null

> The returned data should be ordered by fk_catalog_name, fk_db_schema_name, fk_table_name, fk_key_name, then key_sequence. update_rule and delete_rule returns a byte that is equivalent to actions declared on UpdateDeleteRules enum.

func (*CommandGetExportedKeys) Descriptor deprecated 

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

Deprecated: Use CommandGetExportedKeys.ProtoReflect.Descriptor instead.

func (*CommandGetExportedKeys) GetCatalog 

func (x *CommandGetExportedKeys) GetCatalog() string

func (*CommandGetExportedKeys) GetDbSchema 

func (x *CommandGetExportedKeys) GetDbSchema() string

func (*CommandGetExportedKeys) GetTable 

func (x *CommandGetExportedKeys) GetTable() string

func (*CommandGetExportedKeys) ProtoMessage 

func (*CommandGetExportedKeys) ProtoMessage()

func (*CommandGetExportedKeys) ProtoReflect 

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

func (*CommandGetExportedKeys) Reset 

func (x *CommandGetExportedKeys) Reset()

func (*CommandGetExportedKeys) String 

func (x *CommandGetExportedKeys) String() string

type CommandGetImportedKeys 

type CommandGetImportedKeys struct {

	//
	// Specifies the catalog to search for the primary key table.
	// An empty string retrieves those without a catalog.
	// If omitted the catalog name should not be used to narrow the search.
	Catalog *string `protobuf:"bytes,1,opt,name=catalog,proto3,oneof" json:"catalog,omitempty"`
	//
	// Specifies the schema to search for the primary key table.
	// An empty string retrieves those without a schema.
	// If omitted the schema name should not be used to narrow the search.
	DbSchema *string `protobuf:"bytes,2,opt,name=db_schema,json=dbSchema,proto3,oneof" json:"db_schema,omitempty"`
	// Specifies the primary key table to get the foreign keys for.
	Table string `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"`
	// contains filtered or unexported fields
}

Represents a request to retrieve the foreign keys of a table on a Flight SQL enabled backend. Used in the command member of FlightDescriptor for the following RPC calls:

  • GetSchema: return the Arrow schema of the query.
  • GetFlightInfo: execute the catalog metadata request.

The returned Arrow schema will be: < 

pk_catalog_name: utf8,
pk_db_schema_name: utf8,
pk_table_name: utf8 not null,
pk_column_name: utf8 not null,
fk_catalog_name: utf8,
fk_db_schema_name: utf8,
fk_table_name: utf8 not null,
fk_column_name: utf8 not null,
key_sequence: int32 not null,
fk_key_name: utf8,
pk_key_name: utf8,
update_rule: uint8 not null,
delete_rule: uint8 not null

> The returned data should be ordered by pk_catalog_name, pk_db_schema_name, pk_table_name, pk_key_name, then key_sequence. update_rule and delete_rule returns a byte that is equivalent to actions:

  • 0 = CASCADE
  • 1 = RESTRICT
  • 2 = SET NULL
  • 3 = NO ACTION
  • 4 = SET DEFAULT

func (*CommandGetImportedKeys) Descriptor deprecated 

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

Deprecated: Use CommandGetImportedKeys.ProtoReflect.Descriptor instead.

func (*CommandGetImportedKeys) GetCatalog 

func (x *CommandGetImportedKeys) GetCatalog() string

func (*CommandGetImportedKeys) GetDbSchema 

func (x *CommandGetImportedKeys) GetDbSchema() string

func (*CommandGetImportedKeys) GetTable 

func (x *CommandGetImportedKeys) GetTable() string

func (*CommandGetImportedKeys) ProtoMessage 

func (*CommandGetImportedKeys) ProtoMessage()

func (*CommandGetImportedKeys) ProtoReflect 

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

func (*CommandGetImportedKeys) Reset 

func (x *CommandGetImportedKeys) Reset()

func (*CommandGetImportedKeys) String 

func (x *CommandGetImportedKeys) String() string

type CommandGetPrimaryKeys 

type CommandGetPrimaryKeys struct {

	//
	// Specifies the catalog to search for the table.
	// An empty string retrieves those without a catalog.
	// If omitted the catalog name should not be used to narrow the search.
	Catalog *string `protobuf:"bytes,1,opt,name=catalog,proto3,oneof" json:"catalog,omitempty"`
	//
	// Specifies the schema to search for the table.
	// An empty string retrieves those without a schema.
	// If omitted the schema name should not be used to narrow the search.
	DbSchema *string `protobuf:"bytes,2,opt,name=db_schema,json=dbSchema,proto3,oneof" json:"db_schema,omitempty"`
	// Specifies the table to get the primary keys for.
	Table string `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"`
	// contains filtered or unexported fields
}

Represents a request to retrieve the primary keys of a table on a Flight SQL enabled backend. Used in the command member of FlightDescriptor for the following RPC calls:

  • GetSchema: return the Arrow schema of the query.
  • GetFlightInfo: execute the catalog metadata request.

The returned Arrow schema will be: < 

catalog_name: utf8,
db_schema_name: utf8,
table_name: utf8 not null,
column_name: utf8 not null,
key_name: utf8,
key_sequence: int32 not null

> The returned data should be ordered by catalog_name, db_schema_name, table_name, key_name, then key_sequence.

func (*CommandGetPrimaryKeys) Descriptor deprecated 

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

Deprecated: Use CommandGetPrimaryKeys.ProtoReflect.Descriptor instead.

func (*CommandGetPrimaryKeys) GetCatalog 

func (x *CommandGetPrimaryKeys) GetCatalog() string

func (*CommandGetPrimaryKeys) GetDbSchema 

func (x *CommandGetPrimaryKeys) GetDbSchema() string

func (*CommandGetPrimaryKeys) GetTable 

func (x *CommandGetPrimaryKeys) GetTable() string

func (*CommandGetPrimaryKeys) ProtoMessage 

func (*CommandGetPrimaryKeys) ProtoMessage()

func (*CommandGetPrimaryKeys) ProtoReflect 

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

func (*CommandGetPrimaryKeys) Reset 

func (x *CommandGetPrimaryKeys) Reset()

func (*CommandGetPrimaryKeys) String 

func (x *CommandGetPrimaryKeys) String() string

type CommandGetSqlInfo 

type CommandGetSqlInfo struct {

	//
	// Values are modelled after ODBC's SQLGetInfo() function. This information is intended to provide
	// Flight SQL clients with basic, SQL syntax and SQL functions related information.
	// More information types can be added in future releases.
	// E.g. more SQL syntax support types, scalar functions support, type conversion support etc.
	//
	// Note that the set of metadata may expand.
	//
	// Initially, Flight SQL will support the following information types:
	// - Server Information - Range [0-500)
	// - Syntax Information - Range [500-1000)
	// Range [0-10,000) is reserved for defaults (see SqlInfo enum for default options).
	// Custom options should start at 10,000.
	//
	// If omitted, then all metadata will be retrieved.
	// Flight SQL Servers may choose to include additional metadata above and beyond the specified set, however they must
	// at least return the specified set. IDs ranging from 0 to 10,000 (exclusive) are reserved for future use.
	// If additional metadata is included, the metadata IDs should start from 10,000.
	Info []uint32 `protobuf:"varint,1,rep,packed,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

Represents a metadata request. Used in the command member of FlightDescriptor for the following RPC calls:

  • GetSchema: return the Arrow schema of the query.
  • GetFlightInfo: execute the metadata request.

The returned Arrow schema will be: < 

info_name: uint32 not null,
value: dense_union<
            string_value: utf8,
            bool_value: bool,
            bigint_value: int64,
            int32_bitmask: int32,
            string_list: list<string_data: utf8>
            int32_to_int32_list_map: map<key: int32, value: list<$data$: int32>>

> where there is one row per requested piece of metadata information.

func (*CommandGetSqlInfo) Descriptor deprecated 

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

Deprecated: Use CommandGetSqlInfo.ProtoReflect.Descriptor instead.

func (*CommandGetSqlInfo) GetInfo 

func (x *CommandGetSqlInfo) GetInfo() []uint32

func (*CommandGetSqlInfo) ProtoMessage 

func (*CommandGetSqlInfo) ProtoMessage()

func (*CommandGetSqlInfo) ProtoReflect 

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

func (*CommandGetSqlInfo) Reset 

func (x *CommandGetSqlInfo) Reset()

func (*CommandGetSqlInfo) String 

func (x *CommandGetSqlInfo) String() string

type CommandGetTableTypes 

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

Represents a request to retrieve the list of table types on a Flight SQL enabled backend. The table types depend on vendor/implementation. It is usually used to separate tables from views or system tables. TABLE, VIEW, and SYSTEM TABLE are commonly supported. Used in the command member of FlightDescriptor for the following RPC calls:

  • GetSchema: return the Arrow schema of the query.
  • GetFlightInfo: execute the catalog metadata request.

The returned Arrow schema will be: < 

table_type: utf8 not null

> The returned data should be ordered by table_type.

func (*CommandGetTableTypes) Descriptor deprecated 

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

Deprecated: Use CommandGetTableTypes.ProtoReflect.Descriptor instead.

func (*CommandGetTableTypes) ProtoMessage 

func (*CommandGetTableTypes) ProtoMessage()

func (*CommandGetTableTypes) ProtoReflect 

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

func (*CommandGetTableTypes) Reset 

func (x *CommandGetTableTypes) Reset()

func (*CommandGetTableTypes) String 

func (x *CommandGetTableTypes) String() string

type CommandGetTables 

type CommandGetTables struct {

	//
	// Specifies the Catalog to search for the tables.
	// An empty string retrieves those without a catalog.
	// If omitted the catalog name should not be used to narrow the search.
	Catalog *string `protobuf:"bytes,1,opt,name=catalog,proto3,oneof" json:"catalog,omitempty"`
	//
	// Specifies a filter pattern for schemas to search for.
	// When no db_schema_filter_pattern is provided, all schemas matching other filters are searched.
	// In the pattern string, two special characters can be used to denote matching rules:
	//    - "%" means to match any substring with 0 or more characters.
	//    - "_" means to match any one character.
	DbSchemaFilterPattern *string `` /* 134-byte string literal not displayed */
	//
	// Specifies a filter pattern for tables to search for.
	// When no table_name_filter_pattern is provided, all tables matching other filters are searched.
	// In the pattern string, two special characters can be used to denote matching rules:
	//    - "%" means to match any substring with 0 or more characters.
	//    - "_" means to match any one character.
	TableNameFilterPattern *string `` /* 137-byte string literal not displayed */
	//
	// Specifies a filter of table types which must match.
	// The table types depend on vendor/implementation. It is usually used to separate tables from views or system tables.
	// TABLE, VIEW, and SYSTEM TABLE are commonly supported.
	TableTypes []string `protobuf:"bytes,4,rep,name=table_types,json=tableTypes,proto3" json:"table_types,omitempty"`
	// Specifies if the Arrow schema should be returned for found tables.
	IncludeSchema bool `protobuf:"varint,5,opt,name=include_schema,json=includeSchema,proto3" json:"include_schema,omitempty"`
	// contains filtered or unexported fields
}

Represents a request to retrieve the list of tables, and optionally their schemas, on a Flight SQL enabled backend. Used in the command member of FlightDescriptor for the following RPC calls:

  • GetSchema: return the Arrow schema of the query.
  • GetFlightInfo: execute the catalog metadata request.

The returned Arrow schema will be: < 

catalog_name: utf8,
db_schema_name: utf8,
table_name: utf8 not null,
table_type: utf8 not null,
[optional] table_schema: bytes not null (schema of the table as described in Schema.fbs::Schema,
                                         it is serialized as an IPC message.)

> Fields on table_schema may contain the following metadata:

  • ARROW:FLIGHT:SQL:CATALOG_NAME - Table's catalog name
  • ARROW:FLIGHT:SQL:DB_SCHEMA_NAME - Database schema name
  • ARROW:FLIGHT:SQL:TABLE_NAME - Table name
  • ARROW:FLIGHT:SQL:TYPE_NAME - The data source-specific name for the data type of the column.
  • ARROW:FLIGHT:SQL:PRECISION - Column precision/size
  • ARROW:FLIGHT:SQL:SCALE - Column scale/decimal digits if applicable
  • ARROW:FLIGHT:SQL:IS_AUTO_INCREMENT - "1" indicates if the column is auto incremented, "0" otherwise.
  • ARROW:FLIGHT:SQL:IS_CASE_SENSITIVE - "1" indicates if the column is case-sensitive, "0" otherwise.
  • ARROW:FLIGHT:SQL:IS_READ_ONLY - "1" indicates if the column is read only, "0" otherwise.
  • ARROW:FLIGHT:SQL:IS_SEARCHABLE - "1" indicates if the column is searchable via WHERE clause, "0" otherwise.

The returned data should be ordered by catalog_name, db_schema_name, table_name, then table_type, followed by table_schema if requested.

func (*CommandGetTables) Descriptor deprecated 

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

Deprecated: Use CommandGetTables.ProtoReflect.Descriptor instead.

func (*CommandGetTables) GetCatalog 

func (x *CommandGetTables) GetCatalog() string

func (*CommandGetTables) GetDbSchemaFilterPattern 

func (x *CommandGetTables) GetDbSchemaFilterPattern() string

func (*CommandGetTables) GetIncludeSchema 

func (x *CommandGetTables) GetIncludeSchema() bool

func (*CommandGetTables) GetTableNameFilterPattern 

func (x *CommandGetTables) GetTableNameFilterPattern() string

func (*CommandGetTables) GetTableTypes 

func (x *CommandGetTables) GetTableTypes() []string

func (*CommandGetTables) ProtoMessage 

func (*CommandGetTables) ProtoMessage()

func (*CommandGetTables) ProtoReflect 

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

func (*CommandGetTables) Reset 

func (x *CommandGetTables) Reset()

func (*CommandGetTables) String 

func (x *CommandGetTables) String() string

type CommandGetXdbcTypeInfo 

type CommandGetXdbcTypeInfo struct {

	//
	// Specifies the data type to search for the info.
	DataType *int32 `protobuf:"varint,1,opt,name=data_type,json=dataType,proto3,oneof" json:"data_type,omitempty"`
	// contains filtered or unexported fields
}

Represents a request to retrieve information about data type supported on a Flight SQL enabled backend. Used in the command member of FlightDescriptor for the following RPC calls:

  • GetSchema: return the schema of the query.
  • GetFlightInfo: execute the catalog metadata request.

The returned schema will be: < 

type_name: utf8 not null (The name of the data type, for example: VARCHAR, INTEGER, etc),
data_type: int32 not null (The SQL data type),
column_size: int32 (The maximum size supported by that column.
                    In case of exact numeric types, this represents the maximum precision.
                    In case of string types, this represents the character length.
                    In case of datetime data types, this represents the length in characters of the string representation.
                    NULL is returned for data types where column size is not applicable.),
literal_prefix: utf8 (Character or characters used to prefix a literal, NULL is returned for
                      data types where a literal prefix is not applicable.),
literal_suffix: utf8 (Character or characters used to terminate a literal,
                      NULL is returned for data types where a literal suffix is not applicable.),
create_params: list<utf8 not null>
                     (A list of keywords corresponding to which parameters can be used when creating
                      a column for that specific type.
                      NULL is returned if there are no parameters for the data type definition.),
nullable: int32 not null (Shows if the data type accepts a NULL value. The possible values can be seen in the
                          Nullable enum.),
case_sensitive: bool not null (Shows if a character data type is case-sensitive in collations and comparisons),
searchable: int32 not null (Shows how the data type is used in a WHERE clause. The possible values can be seen in the
                            Searchable enum.),
unsigned_attribute: bool (Shows if the data type is unsigned. NULL is returned if the attribute is
                          not applicable to the data type or the data type is not numeric.),
fixed_prec_scale: bool not null (Shows if the data type has predefined fixed precision and scale.),
auto_increment: bool (Shows if the data type is auto incremental. NULL is returned if the attribute
                      is not applicable to the data type or the data type is not numeric.),
local_type_name: utf8 (Localized version of the data source-dependent name of the data type. NULL
                       is returned if a localized name is not supported by the data source),
minimum_scale: int32 (The minimum scale of the data type on the data source.
                      If a data type has a fixed scale, the MINIMUM_SCALE and MAXIMUM_SCALE
                      columns both contain this value. NULL is returned if scale is not applicable.),
maximum_scale: int32 (The maximum scale of the data type on the data source.
                      NULL is returned if scale is not applicable.),
sql_data_type: int32 not null (The value of the SQL DATA TYPE which has the same values
                               as data_type value. Except for interval and datetime, which
                               uses generic values. More info about those types can be
                               obtained through datetime_subcode. The possible values can be seen
                               in the XdbcDataType enum.),
datetime_subcode: int32 (Only used when the SQL DATA TYPE is interval or datetime. It contains
                         its sub types. For type different from interval and datetime, this value
                         is NULL. The possible values can be seen in the XdbcDatetimeSubcode enum.),
num_prec_radix: int32 (If the data type is an approximate numeric type, this column contains
                       the value 2 to indicate that COLUMN_SIZE specifies a number of bits. For
                       exact numeric types, this column contains the value 10 to indicate that
                       column size specifies a number of decimal digits. Otherwise, this column is NULL.),
interval_precision: int32 (If the data type is an interval data type, then this column contains the value
                           of the interval leading precision. Otherwise, this column is NULL. This fields
                           is only relevant to be used by ODBC).

> The returned data should be ordered by data_type and then by type_name.

func (*CommandGetXdbcTypeInfo) Descriptor deprecated 

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

Deprecated: Use CommandGetXdbcTypeInfo.ProtoReflect.Descriptor instead.

func (*CommandGetXdbcTypeInfo) GetDataType 

func (x *CommandGetXdbcTypeInfo) GetDataType() int32

func (*CommandGetXdbcTypeInfo) ProtoMessage 

func (*CommandGetXdbcTypeInfo) ProtoMessage()

func (*CommandGetXdbcTypeInfo) ProtoReflect 

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

func (*CommandGetXdbcTypeInfo) Reset 

func (x *CommandGetXdbcTypeInfo) Reset()

func (*CommandGetXdbcTypeInfo) String 

func (x *CommandGetXdbcTypeInfo) String() string

type CommandPreparedStatementQuery 

type CommandPreparedStatementQuery struct {

	// Opaque handle for the prepared statement on the server.
	PreparedStatementHandle []byte `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

Represents an instance of executing a prepared statement. Used in the command member of FlightDescriptor for the following RPC calls:

  • GetSchema: return the Arrow schema of the query. Fields on this schema may contain the following metadata:
  • ARROW:FLIGHT:SQL:CATALOG_NAME - Table's catalog name
  • ARROW:FLIGHT:SQL:DB_SCHEMA_NAME - Database schema name
  • ARROW:FLIGHT:SQL:TABLE_NAME - Table name
  • ARROW:FLIGHT:SQL:TYPE_NAME - The data source-specific name for the data type of the column.
  • ARROW:FLIGHT:SQL:PRECISION - Column precision/size
  • ARROW:FLIGHT:SQL:SCALE - Column scale/decimal digits if applicable
  • ARROW:FLIGHT:SQL:IS_AUTO_INCREMENT - "1" indicates if the column is auto incremented, "0" otherwise.
  • ARROW:FLIGHT:SQL:IS_CASE_SENSITIVE - "1" indicates if the column is case-sensitive, "0" otherwise.
  • ARROW:FLIGHT:SQL:IS_READ_ONLY - "1" indicates if the column is read only, "0" otherwise.
  • ARROW:FLIGHT:SQL:IS_SEARCHABLE - "1" indicates if the column is searchable via WHERE clause, "0" otherwise.
  • DoPut: bind parameter values. All of the bound parameter sets will be executed as a single atomic execution.
  • GetFlightInfo: execute the prepared statement instance.

func (*CommandPreparedStatementQuery) Descriptor deprecated 

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

Deprecated: Use CommandPreparedStatementQuery.ProtoReflect.Descriptor instead.

func (*CommandPreparedStatementQuery) GetPreparedStatementHandle 

func (x *CommandPreparedStatementQuery) GetPreparedStatementHandle() []byte

func (*CommandPreparedStatementQuery) ProtoMessage 

func (*CommandPreparedStatementQuery) ProtoMessage()

func (*CommandPreparedStatementQuery) ProtoReflect 

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

func (*CommandPreparedStatementQuery) Reset 

func (x *CommandPreparedStatementQuery) Reset()

func (*CommandPreparedStatementQuery) String 

func (x *CommandPreparedStatementQuery) String() string

type CommandPreparedStatementUpdate 

type CommandPreparedStatementUpdate struct {

	// Opaque handle for the prepared statement on the server.
	PreparedStatementHandle []byte `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

Represents a SQL update query. Used in the command member of FlightDescriptor for the RPC call DoPut to cause the server to execute the included prepared statement handle as an update.

func (*CommandPreparedStatementUpdate) Descriptor deprecated 

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

Deprecated: Use CommandPreparedStatementUpdate.ProtoReflect.Descriptor instead.

func (*CommandPreparedStatementUpdate) GetPreparedStatementHandle 

func (x *CommandPreparedStatementUpdate) GetPreparedStatementHandle() []byte

func (*CommandPreparedStatementUpdate) ProtoMessage 

func (*CommandPreparedStatementUpdate) ProtoMessage()

func (*CommandPreparedStatementUpdate) ProtoReflect 

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

func (*CommandPreparedStatementUpdate) Reset 

func (x *CommandPreparedStatementUpdate) Reset()

func (*CommandPreparedStatementUpdate) String 

func (x *CommandPreparedStatementUpdate) String() string

type CommandStatementQuery 

type CommandStatementQuery struct {

	// The SQL syntax.
	Query string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	// Include the query as part of this transaction (if unset, the query is auto-committed).
	TransactionId []byte `protobuf:"bytes,2,opt,name=transaction_id,json=transactionId,proto3,oneof" json:"transaction_id,omitempty"`
	// contains filtered or unexported fields
}

Represents a SQL query. Used in the command member of FlightDescriptor for the following RPC calls:

  • GetSchema: return the Arrow schema of the query. Fields on this schema may contain the following metadata:
  • ARROW:FLIGHT:SQL:CATALOG_NAME - Table's catalog name
  • ARROW:FLIGHT:SQL:DB_SCHEMA_NAME - Database schema name
  • ARROW:FLIGHT:SQL:TABLE_NAME - Table name
  • ARROW:FLIGHT:SQL:TYPE_NAME - The data source-specific name for the data type of the column.
  • ARROW:FLIGHT:SQL:PRECISION - Column precision/size
  • ARROW:FLIGHT:SQL:SCALE - Column scale/decimal digits if applicable
  • ARROW:FLIGHT:SQL:IS_AUTO_INCREMENT - "1" indicates if the column is auto incremented, "0" otherwise.
  • ARROW:FLIGHT:SQL:IS_CASE_SENSITIVE - "1" indicates if the column is case-sensitive, "0" otherwise.
  • ARROW:FLIGHT:SQL:IS_READ_ONLY - "1" indicates if the column is read only, "0" otherwise.
  • ARROW:FLIGHT:SQL:IS_SEARCHABLE - "1" indicates if the column is searchable via WHERE clause, "0" otherwise.
  • GetFlightInfo: execute the query.

func (*CommandStatementQuery) Descriptor deprecated 

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

Deprecated: Use CommandStatementQuery.ProtoReflect.Descriptor instead.

func (*CommandStatementQuery) GetQuery 

func (x *CommandStatementQuery) GetQuery() string

func (*CommandStatementQuery) GetTransactionId 

func (x *CommandStatementQuery) GetTransactionId() []byte

func (*CommandStatementQuery) ProtoMessage 

func (*CommandStatementQuery) ProtoMessage()

func (*CommandStatementQuery) ProtoReflect 

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

func (*CommandStatementQuery) Reset 

func (x *CommandStatementQuery) Reset()

func (*CommandStatementQuery) String 

func (x *CommandStatementQuery) String() string

type CommandStatementSubstraitPlan 

type CommandStatementSubstraitPlan struct {

	// A serialized substrait.Plan
	Plan *SubstraitPlan `protobuf:"bytes,1,opt,name=plan,proto3" json:"plan,omitempty"`
	// Include the query as part of this transaction (if unset, the query is auto-committed).
	TransactionId []byte `protobuf:"bytes,2,opt,name=transaction_id,json=transactionId,proto3,oneof" json:"transaction_id,omitempty"`
	// contains filtered or unexported fields
}

Represents a Substrait plan. Used in the command member of FlightDescriptor for the following RPC calls:

  • GetSchema: return the Arrow schema of the query. Fields on this schema may contain the following metadata:
  • ARROW:FLIGHT:SQL:CATALOG_NAME - Table's catalog name
  • ARROW:FLIGHT:SQL:DB_SCHEMA_NAME - Database schema name
  • ARROW:FLIGHT:SQL:TABLE_NAME - Table name
  • ARROW:FLIGHT:SQL:TYPE_NAME - The data source-specific name for the data type of the column.
  • ARROW:FLIGHT:SQL:PRECISION - Column precision/size
  • ARROW:FLIGHT:SQL:SCALE - Column scale/decimal digits if applicable
  • ARROW:FLIGHT:SQL:IS_AUTO_INCREMENT - "1" indicates if the column is auto incremented, "0" otherwise.
  • ARROW:FLIGHT:SQL:IS_CASE_SENSITIVE - "1" indicates if the column is case-sensitive, "0" otherwise.
  • ARROW:FLIGHT:SQL:IS_READ_ONLY - "1" indicates if the column is read only, "0" otherwise.
  • ARROW:FLIGHT:SQL:IS_SEARCHABLE - "1" indicates if the column is searchable via WHERE clause, "0" otherwise.
  • GetFlightInfo: execute the query.
  • DoPut: execute the query.

func (*CommandStatementSubstraitPlan) Descriptor deprecated 

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

Deprecated: Use CommandStatementSubstraitPlan.ProtoReflect.Descriptor instead.

func (*CommandStatementSubstraitPlan) GetPlan 

func (x *CommandStatementSubstraitPlan) GetPlan() *SubstraitPlan

func (*CommandStatementSubstraitPlan) GetTransactionId 

func (x *CommandStatementSubstraitPlan) GetTransactionId() []byte

func (*CommandStatementSubstraitPlan) ProtoMessage 

func (*CommandStatementSubstraitPlan) ProtoMessage()

func (*CommandStatementSubstraitPlan) ProtoReflect 

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

func (*CommandStatementSubstraitPlan) Reset 

func (x *CommandStatementSubstraitPlan) Reset()

func (*CommandStatementSubstraitPlan) String 

func (x *CommandStatementSubstraitPlan) String() string

type CommandStatementUpdate 

type CommandStatementUpdate struct {

	// The SQL syntax.
	Query string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	// Include the query as part of this transaction (if unset, the query is auto-committed).
	TransactionId []byte `protobuf:"bytes,2,opt,name=transaction_id,json=transactionId,proto3,oneof" json:"transaction_id,omitempty"`
	// contains filtered or unexported fields
}

Represents a SQL update query. Used in the command member of FlightDescriptor for the RPC call DoPut to cause the server to execute the included SQL update.

func (*CommandStatementUpdate) Descriptor deprecated 

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

Deprecated: Use CommandStatementUpdate.ProtoReflect.Descriptor instead.

func (*CommandStatementUpdate) GetQuery 

func (x *CommandStatementUpdate) GetQuery() string

func (*CommandStatementUpdate) GetTransactionId 

func (x *CommandStatementUpdate) GetTransactionId() []byte

func (*CommandStatementUpdate) ProtoMessage 

func (*CommandStatementUpdate) ProtoMessage()

func (*CommandStatementUpdate) ProtoReflect 

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

func (*CommandStatementUpdate) Reset 

func (x *CommandStatementUpdate) Reset()

func (*CommandStatementUpdate) String 

func (x *CommandStatementUpdate) String() string

type Criteria 

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

A service specific expression that can be used to return a limited set of available Arrow Flight streams.

func (*Criteria) Descriptor deprecated 

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

Deprecated: Use Criteria.ProtoReflect.Descriptor instead.

func (*Criteria) GetExpression 

func (x *Criteria) GetExpression() []byte

func (*Criteria) ProtoMessage 

func (*Criteria) ProtoMessage()

func (*Criteria) ProtoReflect 

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

func (*Criteria) Reset 

func (x *Criteria) Reset()

func (*Criteria) String 

func (x *Criteria) String() string

type DoPutUpdateResult 

type DoPutUpdateResult struct {

	// The number of records updated. A return value of -1 represents
	// an unknown updated record count.
	RecordCount int64 `protobuf:"varint,1,opt,name=record_count,json=recordCount,proto3" json:"record_count,omitempty"`
	// contains filtered or unexported fields
}

Returned from the RPC call DoPut when a CommandStatementUpdate CommandPreparedStatementUpdate was in the request, containing results from the update.

func (*DoPutUpdateResult) Descriptor deprecated 

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

Deprecated: Use DoPutUpdateResult.ProtoReflect.Descriptor instead.

func (*DoPutUpdateResult) GetRecordCount 

func (x *DoPutUpdateResult) GetRecordCount() int64

func (*DoPutUpdateResult) ProtoMessage 

func (*DoPutUpdateResult) ProtoMessage()

func (*DoPutUpdateResult) ProtoReflect 

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

func (*DoPutUpdateResult) Reset 

func (x *DoPutUpdateResult) Reset()

func (*DoPutUpdateResult) String 

func (x *DoPutUpdateResult) String() string

type Empty 

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

func (*Empty) Descriptor deprecated 

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

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

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type FlightData 

type FlightData struct {

	//
	// The descriptor of the data. This is only relevant when a client is
	// starting a new DoPut stream.
	FlightDescriptor *FlightDescriptor `protobuf:"bytes,1,opt,name=flight_descriptor,json=flightDescriptor,proto3" json:"flight_descriptor,omitempty"`
	//
	// Header for message data as described in Message.fbs::Message.
	DataHeader []byte `protobuf:"bytes,2,opt,name=data_header,json=dataHeader,proto3" json:"data_header,omitempty"`
	//
	// Application-defined metadata.
	AppMetadata []byte `protobuf:"bytes,3,opt,name=app_metadata,json=appMetadata,proto3" json:"app_metadata,omitempty"`
	//
	// The actual batch of Arrow data. Preferably handled with minimal-copies
	// coming last in the definition to help with sidecar patterns (it is
	// expected that some implementations will fetch this field off the wire
	// with specialized code to avoid extra memory copies).
	DataBody []byte `protobuf:"bytes,1000,opt,name=data_body,json=dataBody,proto3" json:"data_body,omitempty"`
	// contains filtered or unexported fields
}

A batch of Arrow data as part of a stream of batches.

func (*FlightData) Descriptor deprecated 

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

Deprecated: Use FlightData.ProtoReflect.Descriptor instead.

func (*FlightData) GetAppMetadata 

func (x *FlightData) GetAppMetadata() []byte

func (*FlightData) GetDataBody 

func (x *FlightData) GetDataBody() []byte

func (*FlightData) GetDataHeader 

func (x *FlightData) GetDataHeader() []byte

func (*FlightData) GetFlightDescriptor 

func (x *FlightData) GetFlightDescriptor() *FlightDescriptor

func (*FlightData) ProtoMessage 

func (*FlightData) ProtoMessage()

func (*FlightData) ProtoReflect 

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

func (*FlightData) Reset 

func (x *FlightData) Reset()

func (*FlightData) String 

func (x *FlightData) String() string

type FlightDescriptor 

type FlightDescriptor struct {
	Type FlightDescriptor_DescriptorType `protobuf:"varint,1,opt,name=type,proto3,enum=arrow.flight.protocol.FlightDescriptor_DescriptorType" json:"type,omitempty"`
	//
	// Opaque value used to express a command. Should only be defined when
	// type = CMD.
	Cmd []byte `protobuf:"bytes,2,opt,name=cmd,proto3" json:"cmd,omitempty"`
	//
	// List of strings identifying a particular dataset. Should only be defined
	// when type = PATH.
	Path []string `protobuf:"bytes,3,rep,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

The name or tag for a Flight. May be used as a way to retrieve or generate a flight or be used to expose a set of previously defined flights.

func (*FlightDescriptor) Descriptor deprecated 

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

Deprecated: Use FlightDescriptor.ProtoReflect.Descriptor instead.

func (*FlightDescriptor) GetCmd 

func (x *FlightDescriptor) GetCmd() []byte

func (*FlightDescriptor) GetPath 

func (x *FlightDescriptor) GetPath() []string

func (*FlightDescriptor) GetType 

func (x *FlightDescriptor) GetType() FlightDescriptor_DescriptorType

func (*FlightDescriptor) ProtoMessage 

func (*FlightDescriptor) ProtoMessage()

func (*FlightDescriptor) ProtoReflect 

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

func (*FlightDescriptor) Reset 

func (x *FlightDescriptor) Reset()

func (*FlightDescriptor) String 

func (x *FlightDescriptor) String() string

type FlightDescriptor_DescriptorType 

type FlightDescriptor_DescriptorType int32

Describes what type of descriptor is defined. 

const (
	// Protobuf pattern, not used.
	FlightDescriptor_UNKNOWN FlightDescriptor_DescriptorType = 0
	//
	// A named path that identifies a dataset. A path is composed of a string
	// or list of strings describing a particular dataset. This is conceptually
	//  similar to a path inside a filesystem.
	FlightDescriptor_PATH FlightDescriptor_DescriptorType = 1
	//
	// An opaque command to generate a dataset.
	FlightDescriptor_CMD FlightDescriptor_DescriptorType = 2
)

func (FlightDescriptor_DescriptorType) Descriptor 

func (FlightDescriptor_DescriptorType) Descriptor() protoreflect.EnumDescriptor

func (FlightDescriptor_DescriptorType) Enum 

func (x FlightDescriptor_DescriptorType) Enum() *FlightDescriptor_DescriptorType

func (FlightDescriptor_DescriptorType) EnumDescriptor deprecated 

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

Deprecated: Use FlightDescriptor_DescriptorType.Descriptor instead.

func (FlightDescriptor_DescriptorType) Number 

func (x FlightDescriptor_DescriptorType) Number() protoreflect.EnumNumber

func (FlightDescriptor_DescriptorType) String 

func (x FlightDescriptor_DescriptorType) String() string

func (FlightDescriptor_DescriptorType) Type 

func (FlightDescriptor_DescriptorType) Type() protoreflect.EnumType

type FlightEndpoint 

type FlightEndpoint struct {

	//
	// Token used to retrieve this stream.
	Ticket *Ticket `protobuf:"bytes,1,opt,name=ticket,proto3" json:"ticket,omitempty"`
	//
	// A list of URIs where this ticket can be redeemed via DoGet().
	//
	// If the list is empty, the expectation is that the ticket can only
	// be redeemed on the current service where the ticket was
	// generated.
	//
	// If the list is not empty, the expectation is that the ticket can
	// be redeemed at any of the locations, and that the data returned
	// will be equivalent. In this case, the ticket may only be redeemed
	// at one of the given locations, and not (necessarily) on the
	// current service.
	//
	// In other words, an application can use multiple locations to
	// represent redundant and/or load balanced services.
	Location []*Location `protobuf:"bytes,2,rep,name=location,proto3" json:"location,omitempty"`
	//
	// Expiration time of this stream. If present, clients may assume
	// they can retry DoGet requests. Otherwise, it is
	// application-defined whether DoGet requests may be retried.
	ExpirationTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=expiration_time,json=expirationTime,proto3" json:"expiration_time,omitempty"`
	//
	// Application-defined metadata.
	AppMetadata []byte `protobuf:"bytes,4,opt,name=app_metadata,json=appMetadata,proto3" json:"app_metadata,omitempty"`
	// contains filtered or unexported fields
}

A particular stream or split associated with a flight.

func (*FlightEndpoint) Descriptor deprecated 

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

Deprecated: Use FlightEndpoint.ProtoReflect.Descriptor instead.

func (*FlightEndpoint) GetAppMetadata 

func (x *FlightEndpoint) GetAppMetadata() []byte

func (*FlightEndpoint) GetExpirationTime 

func (x *FlightEndpoint) GetExpirationTime() *timestamppb.Timestamp

func (*FlightEndpoint) GetLocation 

func (x *FlightEndpoint) GetLocation() []*Location

func (*FlightEndpoint) GetTicket 

func (x *FlightEndpoint) GetTicket() *Ticket

func (*FlightEndpoint) ProtoMessage 

func (*FlightEndpoint) ProtoMessage()

func (*FlightEndpoint) ProtoReflect 

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

func (*FlightEndpoint) Reset 

func (x *FlightEndpoint) Reset()

func (*FlightEndpoint) String 

func (x *FlightEndpoint) String() string

type FlightInfo 

type FlightInfo struct {

	// The schema of the dataset in its IPC form:
	//   4 bytes - an optional IPC_CONTINUATION_TOKEN prefix
	//   4 bytes - the byte length of the payload
	//   a flatbuffer Message whose header is the Schema
	Schema []byte `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	//
	// The descriptor associated with this info.
	FlightDescriptor *FlightDescriptor `protobuf:"bytes,2,opt,name=flight_descriptor,json=flightDescriptor,proto3" json:"flight_descriptor,omitempty"`
	//
	// A list of endpoints associated with the flight. To consume the
	// whole flight, all endpoints (and hence all Tickets) must be
	// consumed. Endpoints can be consumed in any order.
	//
	// In other words, an application can use multiple endpoints to
	// represent partitioned data.
	//
	// If the returned data has an ordering, an application can use
	// "FlightInfo.ordered = true" or should return the all data in a
	// single endpoint. Otherwise, there is no ordering defined on
	// endpoints or the data within.
	//
	// A client can read ordered data by reading data from returned
	// endpoints, in order, from front to back.
	//
	// Note that a client may ignore "FlightInfo.ordered = true". If an
	// ordering is important for an application, an application must
	// choose one of them:
	//
	// * An application requires that all clients must read data in
	//   returned endpoints order.
	// * An application must return the all data in a single endpoint.
	Endpoint []*FlightEndpoint `protobuf:"bytes,3,rep,name=endpoint,proto3" json:"endpoint,omitempty"`
	// Set these to -1 if unknown.
	TotalRecords int64 `protobuf:"varint,4,opt,name=total_records,json=totalRecords,proto3" json:"total_records,omitempty"`
	TotalBytes   int64 `protobuf:"varint,5,opt,name=total_bytes,json=totalBytes,proto3" json:"total_bytes,omitempty"`
	//
	// FlightEndpoints are in the same order as the data.
	Ordered bool `protobuf:"varint,6,opt,name=ordered,proto3" json:"ordered,omitempty"`
	//
	// Application-defined metadata.
	AppMetadata []byte `protobuf:"bytes,7,opt,name=app_metadata,json=appMetadata,proto3" json:"app_metadata,omitempty"`
	// contains filtered or unexported fields
}

The access coordinates for retrieval of a dataset. With a FlightInfo, a consumer is able to determine how to retrieve a dataset.

func (*FlightInfo) Descriptor deprecated 

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

Deprecated: Use FlightInfo.ProtoReflect.Descriptor instead.

func (*FlightInfo) GetAppMetadata 

func (x *FlightInfo) GetAppMetadata() []byte

func (*FlightInfo) GetEndpoint 

func (x *FlightInfo) GetEndpoint() []*FlightEndpoint

func (*FlightInfo) GetFlightDescriptor 

func (x *FlightInfo) GetFlightDescriptor() *FlightDescriptor

func (*FlightInfo) GetOrdered 

func (x *FlightInfo) GetOrdered() bool

func (*FlightInfo) GetSchema 

func (x *FlightInfo) GetSchema() []byte

func (*FlightInfo) GetTotalBytes 

func (x *FlightInfo) GetTotalBytes() int64

func (*FlightInfo) GetTotalRecords 

func (x *FlightInfo) GetTotalRecords() int64

func (*FlightInfo) ProtoMessage 

func (*FlightInfo) ProtoMessage()

func (*FlightInfo) ProtoReflect 

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

func (*FlightInfo) Reset 

func (x *FlightInfo) Reset()

func (*FlightInfo) String 

func (x *FlightInfo) String() string

type FlightServiceClient 

type FlightServiceClient interface {
	//
	// Handshake between client and server. Depending on the server, the
	// handshake may be required to determine the token that should be used for
	// future operations. Both request and response are streams to allow multiple
	// round-trips depending on auth mechanism.
	Handshake(ctx context.Context, opts ...grpc.CallOption) (FlightService_HandshakeClient, error)
	//
	// Get a list of available streams given a particular criteria. Most flight
	// services will expose one or more streams that are readily available for
	// retrieval. This api allows listing the streams available for
	// consumption. A user can also provide a criteria. The criteria can limit
	// the subset of streams that can be listed via this interface. Each flight
	// service allows its own definition of how to consume criteria.
	ListFlights(ctx context.Context, in *Criteria, opts ...grpc.CallOption) (FlightService_ListFlightsClient, error)
	//
	// For a given FlightDescriptor, get information about how the flight can be
	// consumed. This is a useful interface if the consumer of the interface
	// already can identify the specific flight to consume. This interface can
	// also allow a consumer to generate a flight stream through a specified
	// descriptor. For example, a flight descriptor might be something that
	// includes a SQL statement or a Pickled Python operation that will be
	// executed. In those cases, the descriptor will not be previously available
	// within the list of available streams provided by ListFlights but will be
	// available for consumption for the duration defined by the specific flight
	// service.
	GetFlightInfo(ctx context.Context, in *FlightDescriptor, opts ...grpc.CallOption) (*FlightInfo, error)
	//
	// For a given FlightDescriptor, start a query and get information
	// to poll its execution status. This is a useful interface if the
	// query may be a long-running query. The first PollFlightInfo call
	// should return as quickly as possible. (GetFlightInfo doesn't
	// return until the query is complete.)
	//
	// A client can consume any available results before
	// the query is completed. See PollInfo.info for details.
	//
	// A client can poll the updated query status by calling
	// PollFlightInfo() with PollInfo.flight_descriptor. A server
	// should not respond until the result would be different from last
	// time. That way, the client can "long poll" for updates
	// without constantly making requests. Clients can set a short timeout
	// to avoid blocking calls if desired.
	//
	// A client can't use PollInfo.flight_descriptor after
	// PollInfo.expiration_time passes. A server might not accept the
	// retry descriptor anymore and the query may be cancelled.
	//
	// A client may use the CancelFlightInfo action with
	// PollInfo.info to cancel the running query.
	PollFlightInfo(ctx context.Context, in *FlightDescriptor, opts ...grpc.CallOption) (*PollInfo, error)
	//
	// For a given FlightDescriptor, get the Schema as described in Schema.fbs::Schema
	// This is used when a consumer needs the Schema of flight stream. Similar to
	// GetFlightInfo this interface may generate a new flight that was not previously
	// available in ListFlights.
	GetSchema(ctx context.Context, in *FlightDescriptor, opts ...grpc.CallOption) (*SchemaResult, error)
	//
	// Retrieve a single stream associated with a particular descriptor
	// associated with the referenced ticket. A Flight can be composed of one or
	// more streams where each stream can be retrieved using a separate opaque
	// ticket that the flight service uses for managing a collection of streams.
	DoGet(ctx context.Context, in *Ticket, opts ...grpc.CallOption) (FlightService_DoGetClient, error)
	//
	// Push a stream to the flight service associated with a particular
	// flight stream. This allows a client of a flight service to upload a stream
	// of data. Depending on the particular flight service, a client consumer
	// could be allowed to upload a single stream per descriptor or an unlimited
	// number. In the latter, the service might implement a 'seal' action that
	// can be applied to a descriptor once all streams are uploaded.
	DoPut(ctx context.Context, opts ...grpc.CallOption) (FlightService_DoPutClient, error)
	//
	// Open a bidirectional data channel for a given descriptor. This
	// allows clients to send and receive arbitrary Arrow data and
	// application-specific metadata in a single logical stream. In
	// contrast to DoGet/DoPut, this is more suited for clients
	// offloading computation (rather than storage) to a Flight service.
	DoExchange(ctx context.Context, opts ...grpc.CallOption) (FlightService_DoExchangeClient, error)
	//
	// Flight services can support an arbitrary number of simple actions in
	// addition to the possible ListFlights, GetFlightInfo, DoGet, DoPut
	// operations that are potentially available. DoAction allows a flight client
	// to do a specific action against a flight service. An action includes
	// opaque request and response objects that are specific to the type action
	// being undertaken.
	DoAction(ctx context.Context, in *Action, opts ...grpc.CallOption) (FlightService_DoActionClient, error)
	//
	// A flight service exposes all of the available action types that it has
	// along with descriptions. This allows different flight consumers to
	// understand the capabilities of the flight service.
	ListActions(ctx context.Context, in *Empty, opts ...grpc.CallOption) (FlightService_ListActionsClient, error)
}

FlightServiceClient is the client API for FlightService service.

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

func NewFlightServiceClient 

func NewFlightServiceClient(cc grpc.ClientConnInterface) FlightServiceClient

type FlightServiceServer 

type FlightServiceServer interface {
	//
	// Handshake between client and server. Depending on the server, the
	// handshake may be required to determine the token that should be used for
	// future operations. Both request and response are streams to allow multiple
	// round-trips depending on auth mechanism.
	Handshake(FlightService_HandshakeServer) error
	//
	// Get a list of available streams given a particular criteria. Most flight
	// services will expose one or more streams that are readily available for
	// retrieval. This api allows listing the streams available for
	// consumption. A user can also provide a criteria. The criteria can limit
	// the subset of streams that can be listed via this interface. Each flight
	// service allows its own definition of how to consume criteria.
	ListFlights(*Criteria, FlightService_ListFlightsServer) error
	//
	// For a given FlightDescriptor, get information about how the flight can be
	// consumed. This is a useful interface if the consumer of the interface
	// already can identify the specific flight to consume. This interface can
	// also allow a consumer to generate a flight stream through a specified
	// descriptor. For example, a flight descriptor might be something that
	// includes a SQL statement or a Pickled Python operation that will be
	// executed. In those cases, the descriptor will not be previously available
	// within the list of available streams provided by ListFlights but will be
	// available for consumption for the duration defined by the specific flight
	// service.
	GetFlightInfo(context.Context, *FlightDescriptor) (*FlightInfo, error)
	//
	// For a given FlightDescriptor, start a query and get information
	// to poll its execution status. This is a useful interface if the
	// query may be a long-running query. The first PollFlightInfo call
	// should return as quickly as possible. (GetFlightInfo doesn't
	// return until the query is complete.)
	//
	// A client can consume any available results before
	// the query is completed. See PollInfo.info for details.
	//
	// A client can poll the updated query status by calling
	// PollFlightInfo() with PollInfo.flight_descriptor. A server
	// should not respond until the result would be different from last
	// time. That way, the client can "long poll" for updates
	// without constantly making requests. Clients can set a short timeout
	// to avoid blocking calls if desired.
	//
	// A client can't use PollInfo.flight_descriptor after
	// PollInfo.expiration_time passes. A server might not accept the
	// retry descriptor anymore and the query may be cancelled.
	//
	// A client may use the CancelFlightInfo action with
	// PollInfo.info to cancel the running query.
	PollFlightInfo(context.Context, *FlightDescriptor) (*PollInfo, error)
	//
	// For a given FlightDescriptor, get the Schema as described in Schema.fbs::Schema
	// This is used when a consumer needs the Schema of flight stream. Similar to
	// GetFlightInfo this interface may generate a new flight that was not previously
	// available in ListFlights.
	GetSchema(context.Context, *FlightDescriptor) (*SchemaResult, error)
	//
	// Retrieve a single stream associated with a particular descriptor
	// associated with the referenced ticket. A Flight can be composed of one or
	// more streams where each stream can be retrieved using a separate opaque
	// ticket that the flight service uses for managing a collection of streams.
	DoGet(*Ticket, FlightService_DoGetServer) error
	//
	// Push a stream to the flight service associated with a particular
	// flight stream. This allows a client of a flight service to upload a stream
	// of data. Depending on the particular flight service, a client consumer
	// could be allowed to upload a single stream per descriptor or an unlimited
	// number. In the latter, the service might implement a 'seal' action that
	// can be applied to a descriptor once all streams are uploaded.
	DoPut(FlightService_DoPutServer) error
	//
	// Open a bidirectional data channel for a given descriptor. This
	// allows clients to send and receive arbitrary Arrow data and
	// application-specific metadata in a single logical stream. In
	// contrast to DoGet/DoPut, this is more suited for clients
	// offloading computation (rather than storage) to a Flight service.
	DoExchange(FlightService_DoExchangeServer) error
	//
	// Flight services can support an arbitrary number of simple actions in
	// addition to the possible ListFlights, GetFlightInfo, DoGet, DoPut
	// operations that are potentially available. DoAction allows a flight client
	// to do a specific action against a flight service. An action includes
	// opaque request and response objects that are specific to the type action
	// being undertaken.
	DoAction(*Action, FlightService_DoActionServer) error
	//
	// A flight service exposes all of the available action types that it has
	// along with descriptions. This allows different flight consumers to
	// understand the capabilities of the flight service.
	ListActions(*Empty, FlightService_ListActionsServer) error
	// contains filtered or unexported methods
}

FlightServiceServer is the server API for FlightService service. All implementations must embed UnimplementedFlightServiceServer for forward compatibility

type FlightService_DoActionClient 

type FlightService_DoActionClient interface {
	Recv() (*Result, error)
	grpc.ClientStream
}

type FlightService_DoActionServer 

type FlightService_DoActionServer interface {
	Send(*Result) error
	grpc.ServerStream
}

type FlightService_DoExchangeClient 

type FlightService_DoExchangeClient interface {
	Send(*FlightData) error
	Recv() (*FlightData, error)
	grpc.ClientStream
}

type FlightService_DoExchangeServer 

type FlightService_DoExchangeServer interface {
	Send(*FlightData) error
	Recv() (*FlightData, error)
	grpc.ServerStream
}

type FlightService_DoGetClient 

type FlightService_DoGetClient interface {
	Recv() (*FlightData, error)
	grpc.ClientStream
}

type FlightService_DoGetServer 

type FlightService_DoGetServer interface {
	Send(*FlightData) error
	grpc.ServerStream
}

type FlightService_DoPutClient 

type FlightService_DoPutClient interface {
	Send(*FlightData) error
	Recv() (*PutResult, error)
	grpc.ClientStream
}

type FlightService_DoPutServer 

type FlightService_DoPutServer interface {
	Send(*PutResult) error
	Recv() (*FlightData, error)
	grpc.ServerStream
}

type FlightService_HandshakeClient 

type FlightService_HandshakeClient interface {
	Send(*HandshakeRequest) error
	Recv() (*HandshakeResponse, error)
	grpc.ClientStream
}

type FlightService_HandshakeServer 

type FlightService_HandshakeServer interface {
	Send(*HandshakeResponse) error
	Recv() (*HandshakeRequest, error)
	grpc.ServerStream
}

type FlightService_ListActionsClient 

type FlightService_ListActionsClient interface {
	Recv() (*ActionType, error)
	grpc.ClientStream
}

type FlightService_ListActionsServer 

type FlightService_ListActionsServer interface {
	Send(*ActionType) error
	grpc.ServerStream
}

type FlightService_ListFlightsClient 

type FlightService_ListFlightsClient interface {
	Recv() (*FlightInfo, error)
	grpc.ClientStream
}

type FlightService_ListFlightsServer 

type FlightService_ListFlightsServer interface {
	Send(*FlightInfo) error
	grpc.ServerStream
}

type HandshakeRequest 

type HandshakeRequest struct {

	//
	// A defined protocol version
	ProtocolVersion uint64 `protobuf:"varint,1,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
	//
	// Arbitrary auth/handshake info.
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

The request that a client provides to a server on handshake.

func (*HandshakeRequest) Descriptor deprecated 

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

Deprecated: Use HandshakeRequest.ProtoReflect.Descriptor instead.

func (*HandshakeRequest) GetPayload 

func (x *HandshakeRequest) GetPayload() []byte

func (*HandshakeRequest) GetProtocolVersion 

func (x *HandshakeRequest) GetProtocolVersion() uint64

func (*HandshakeRequest) ProtoMessage 

func (*HandshakeRequest) ProtoMessage()

func (*HandshakeRequest) ProtoReflect 

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

func (*HandshakeRequest) Reset 

func (x *HandshakeRequest) Reset()

func (*HandshakeRequest) String 

func (x *HandshakeRequest) String() string

type HandshakeResponse 

type HandshakeResponse struct {

	//
	// A defined protocol version
	ProtocolVersion uint64 `protobuf:"varint,1,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
	//
	// Arbitrary auth/handshake info.
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*HandshakeResponse) Descriptor deprecated 

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

Deprecated: Use HandshakeResponse.ProtoReflect.Descriptor instead.

func (*HandshakeResponse) GetPayload 

func (x *HandshakeResponse) GetPayload() []byte

func (*HandshakeResponse) GetProtocolVersion 

func (x *HandshakeResponse) GetProtocolVersion() uint64

func (*HandshakeResponse) ProtoMessage 

func (*HandshakeResponse) ProtoMessage()

func (*HandshakeResponse) ProtoReflect 

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

func (*HandshakeResponse) Reset 

func (x *HandshakeResponse) Reset()

func (*HandshakeResponse) String 

func (x *HandshakeResponse) String() string

type Location 

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

A location where a Flight service will accept retrieval of a particular stream given a ticket.

func (*Location) Descriptor deprecated 

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

Deprecated: Use Location.ProtoReflect.Descriptor instead.

func (*Location) GetUri 

func (x *Location) GetUri() string

func (*Location) ProtoMessage 

func (*Location) ProtoMessage()

func (*Location) ProtoReflect 

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

func (*Location) Reset 

func (x *Location) Reset()

func (*Location) String 

func (x *Location) String() string

type Nullable 

type Nullable int32
const (
	//*
	// Indicates that the fields does not allow the use of null values.
	Nullable_NULLABILITY_NO_NULLS Nullable = 0
	//*
	// Indicates that the fields allow the use of null values.
	Nullable_NULLABILITY_NULLABLE Nullable = 1
	//*
	// Indicates that nullability of the fields cannot be determined.
	Nullable_NULLABILITY_UNKNOWN Nullable = 2
)

func (Nullable) Descriptor 

func (Nullable) Descriptor() protoreflect.EnumDescriptor

func (Nullable) Enum 

func (x Nullable) Enum() *Nullable

func (Nullable) EnumDescriptor deprecated 

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

Deprecated: Use Nullable.Descriptor instead.

func (Nullable) Number 

func (x Nullable) Number() protoreflect.EnumNumber

func (Nullable) String 

func (x Nullable) String() string

func (Nullable) Type 

func (Nullable) Type() protoreflect.EnumType

type PollInfo 

type PollInfo struct {

	//
	// The currently available results.
	//
	// If "flight_descriptor" is not specified, the query is complete
	// and "info" specifies all results. Otherwise, "info" contains
	// partial query results.
	//
	// Note that each PollInfo response contains a complete
	// FlightInfo (not just the delta between the previous and current
	// FlightInfo).
	//
	// Subsequent PollInfo responses may only append new endpoints to
	// info.
	//
	// Clients can begin fetching results via DoGet(Ticket) with the
	// ticket in the info before the query is
	// completed. FlightInfo.ordered is also valid.
	Info *FlightInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	//
	// The descriptor the client should use on the next try.
	// If unset, the query is complete.
	FlightDescriptor *FlightDescriptor `protobuf:"bytes,2,opt,name=flight_descriptor,json=flightDescriptor,proto3" json:"flight_descriptor,omitempty"`
	//
	// Query progress. If known, must be in [0.0, 1.0] but need not be
	// monotonic or nondecreasing. If unknown, do not set.
	Progress *float64 `protobuf:"fixed64,3,opt,name=progress,proto3,oneof" json:"progress,omitempty"`
	//
	// Expiration time for this request. After this passes, the server
	// might not accept the retry descriptor anymore (and the query may
	// be cancelled). This may be updated on a call to PollFlightInfo.
	ExpirationTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=expiration_time,json=expirationTime,proto3" json:"expiration_time,omitempty"`
	// contains filtered or unexported fields
}

The information to process a long-running query.

func (*PollInfo) Descriptor deprecated 

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

Deprecated: Use PollInfo.ProtoReflect.Descriptor instead.

func (*PollInfo) GetExpirationTime 

func (x *PollInfo) GetExpirationTime() *timestamppb.Timestamp

func (*PollInfo) GetFlightDescriptor 

func (x *PollInfo) GetFlightDescriptor() *FlightDescriptor

func (*PollInfo) GetInfo 

func (x *PollInfo) GetInfo() *FlightInfo

func (*PollInfo) GetProgress 

func (x *PollInfo) GetProgress() float64

func (*PollInfo) ProtoMessage 

func (*PollInfo) ProtoMessage()

func (*PollInfo) ProtoReflect 

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

func (*PollInfo) Reset 

func (x *PollInfo) Reset()

func (*PollInfo) String 

func (x *PollInfo) String() string

type PutResult 

type PutResult struct {
	AppMetadata []byte `protobuf:"bytes,1,opt,name=app_metadata,json=appMetadata,proto3" json:"app_metadata,omitempty"`
	// contains filtered or unexported fields
}

* The response message associated with the submission of a DoPut.

func (*PutResult) Descriptor deprecated 

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

Deprecated: Use PutResult.ProtoReflect.Descriptor instead.

func (*PutResult) GetAppMetadata 

func (x *PutResult) GetAppMetadata() []byte

func (*PutResult) ProtoMessage 

func (*PutResult) ProtoMessage()

func (*PutResult) ProtoReflect 

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

func (*PutResult) Reset 

func (x *PutResult) Reset()

func (*PutResult) String 

func (x *PutResult) String() string

type RenewFlightEndpointRequest 

type RenewFlightEndpointRequest struct {
	Endpoint *FlightEndpoint `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// contains filtered or unexported fields
}

The request of the RenewFlightEndpoint action.

The request should be stored in Action.body.

func (*RenewFlightEndpointRequest) Descriptor deprecated 

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

Deprecated: Use RenewFlightEndpointRequest.ProtoReflect.Descriptor instead.

func (*RenewFlightEndpointRequest) GetEndpoint 

func (x *RenewFlightEndpointRequest) GetEndpoint() *FlightEndpoint

func (*RenewFlightEndpointRequest) ProtoMessage 

func (*RenewFlightEndpointRequest) ProtoMessage()

func (*RenewFlightEndpointRequest) ProtoReflect 

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

func (*RenewFlightEndpointRequest) Reset 

func (x *RenewFlightEndpointRequest) Reset()

func (*RenewFlightEndpointRequest) String 

func (x *RenewFlightEndpointRequest) String() string

type Result 

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

An opaque result returned after executing an action.

func (*Result) Descriptor deprecated 

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

Deprecated: Use Result.ProtoReflect.Descriptor instead.

func (*Result) GetBody 

func (x *Result) GetBody() []byte

func (*Result) ProtoMessage 

func (*Result) ProtoMessage()

func (*Result) ProtoReflect 

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

func (*Result) Reset 

func (x *Result) Reset()

func (*Result) String 

func (x *Result) String() string

type SchemaResult 

type SchemaResult struct {

	// The schema of the dataset in its IPC form:
	//   4 bytes - an optional IPC_CONTINUATION_TOKEN prefix
	//   4 bytes - the byte length of the payload
	//   a flatbuffer Message whose header is the Schema
	Schema []byte `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

Wrap the result of a getSchema call

func (*SchemaResult) Descriptor deprecated 

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

Deprecated: Use SchemaResult.ProtoReflect.Descriptor instead.

func (*SchemaResult) GetSchema 

func (x *SchemaResult) GetSchema() []byte

func (*SchemaResult) ProtoMessage 

func (*SchemaResult) ProtoMessage()

func (*SchemaResult) ProtoReflect 

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

func (*SchemaResult) Reset 

func (x *SchemaResult) Reset()

func (*SchemaResult) String 

func (x *SchemaResult) String() string

type Searchable 

type Searchable int32
const (
	//*
	// Indicates that column cannot be used in a WHERE clause.
	Searchable_SEARCHABLE_NONE Searchable = 0
	//*
	// Indicates that the column can be used in a WHERE clause if it is using a
	// LIKE operator.
	Searchable_SEARCHABLE_CHAR Searchable = 1
	//*
	// Indicates that the column can be used In a WHERE clause with any
	// operator other than LIKE.
	//
	// - Allowed operators: comparison, quantified comparison, BETWEEN,
	//                      DISTINCT, IN, MATCH, and UNIQUE.
	Searchable_SEARCHABLE_BASIC Searchable = 2
	//*
	// Indicates that the column can be used in a WHERE clause using any operator.
	Searchable_SEARCHABLE_FULL Searchable = 3
)

func (Searchable) Descriptor 

func (Searchable) Descriptor() protoreflect.EnumDescriptor

func (Searchable) Enum 

func (x Searchable) Enum() *Searchable

func (Searchable) EnumDescriptor deprecated 

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

Deprecated: Use Searchable.Descriptor instead.

func (Searchable) Number 

func (x Searchable) Number() protoreflect.EnumNumber

func (Searchable) String 

func (x Searchable) String() string

func (Searchable) Type 

func (Searchable) Type() protoreflect.EnumType

type SqlInfo 

type SqlInfo int32

Options for CommandGetSqlInfo. 

const (
	// Retrieves a UTF-8 string with the name of the Flight SQL Server.
	SqlInfo_FLIGHT_SQL_SERVER_NAME SqlInfo = 0
	// Retrieves a UTF-8 string with the native version of the Flight SQL Server.
	SqlInfo_FLIGHT_SQL_SERVER_VERSION SqlInfo = 1
	// Retrieves a UTF-8 string with the Arrow format version of the Flight SQL Server.
	SqlInfo_FLIGHT_SQL_SERVER_ARROW_VERSION SqlInfo = 2
	//
	// Retrieves a boolean value indicating whether the Flight SQL Server is read only.
	//
	// Returns:
	// - false: if read-write
	// - true: if read only
	SqlInfo_FLIGHT_SQL_SERVER_READ_ONLY SqlInfo = 3
	//
	// Retrieves a boolean value indicating whether the Flight SQL Server supports executing
	// SQL queries.
	//
	// Note that the absence of this info (as opposed to a false value) does not necessarily
	// mean that SQL is not supported, as this property was not originally defined.
	SqlInfo_FLIGHT_SQL_SERVER_SQL SqlInfo = 4
	//
	// Retrieves a boolean value indicating whether the Flight SQL Server supports executing
	// Substrait plans.
	SqlInfo_FLIGHT_SQL_SERVER_SUBSTRAIT SqlInfo = 5
	//
	// Retrieves a string value indicating the minimum supported Substrait version, or null
	// if Substrait is not supported.
	SqlInfo_FLIGHT_SQL_SERVER_SUBSTRAIT_MIN_VERSION SqlInfo = 6
	//
	// Retrieves a string value indicating the maximum supported Substrait version, or null
	// if Substrait is not supported.
	SqlInfo_FLIGHT_SQL_SERVER_SUBSTRAIT_MAX_VERSION SqlInfo = 7
	//
	// Retrieves an int32 indicating whether the Flight SQL Server supports the
	// BeginTransaction/EndTransaction/BeginSavepoint/EndSavepoint actions.
	//
	// Even if this is not supported, the database may still support explicit "BEGIN
	// TRANSACTION"/"COMMIT" SQL statements (see SQL_TRANSACTIONS_SUPPORTED); this property
	// is only about whether the server implements the Flight SQL API endpoints.
	//
	// The possible values are listed in `SqlSupportedTransaction`.
	SqlInfo_FLIGHT_SQL_SERVER_TRANSACTION SqlInfo = 8
	//
	// Retrieves a boolean value indicating whether the Flight SQL Server supports explicit
	// query cancellation (the CancelQuery action).
	SqlInfo_FLIGHT_SQL_SERVER_CANCEL SqlInfo = 9
	//
	// Retrieves an int32 indicating the timeout (in milliseconds) for prepared statement handles.
	//
	// If 0, there is no timeout.  Servers should reset the timeout when the handle is used in a command.
	SqlInfo_FLIGHT_SQL_SERVER_STATEMENT_TIMEOUT SqlInfo = 100
	//
	// Retrieves an int32 indicating the timeout (in milliseconds) for transactions, since transactions are not tied to a connection.
	//
	// If 0, there is no timeout.  Servers should reset the timeout when the handle is used in a command.
	SqlInfo_FLIGHT_SQL_SERVER_TRANSACTION_TIMEOUT SqlInfo = 101
	//
	// Retrieves a boolean value indicating whether the Flight SQL Server supports CREATE and DROP of catalogs.
	//
	// Returns:
	// - false: if it doesn't support CREATE and DROP of catalogs.
	// - true: if it supports CREATE and DROP of catalogs.
	SqlInfo_SQL_DDL_CATALOG SqlInfo = 500
	//
	// Retrieves a boolean value indicating whether the Flight SQL Server supports CREATE and DROP of schemas.
	//
	// Returns:
	// - false: if it doesn't support CREATE and DROP of schemas.
	// - true: if it supports CREATE and DROP of schemas.
	SqlInfo_SQL_DDL_SCHEMA SqlInfo = 501
	//
	// Indicates whether the Flight SQL Server supports CREATE and DROP of tables.
	//
	// Returns:
	// - false: if it doesn't support CREATE and DROP of tables.
	// - true: if it supports CREATE and DROP of tables.
	SqlInfo_SQL_DDL_TABLE SqlInfo = 502
	//
	// Retrieves a int32 ordinal representing the case sensitivity of catalog, table, schema and table names.
	//
	// The possible values are listed in `arrow.flight.protocol.sql.SqlSupportedCaseSensitivity`.
	SqlInfo_SQL_IDENTIFIER_CASE SqlInfo = 503
	// Retrieves a UTF-8 string with the supported character(s) used to surround a delimited identifier.
	SqlInfo_SQL_IDENTIFIER_QUOTE_CHAR SqlInfo = 504
	//
	// Retrieves a int32 describing the case sensitivity of quoted identifiers.
	//
	// The possible values are listed in `arrow.flight.protocol.sql.SqlSupportedCaseSensitivity`.
	SqlInfo_SQL_QUOTED_IDENTIFIER_CASE SqlInfo = 505
	//
	// Retrieves a boolean value indicating whether all tables are selectable.
	//
	// Returns:
	// - false: if not all tables are selectable or if none are;
	// - true: if all tables are selectable.
	SqlInfo_SQL_ALL_TABLES_ARE_SELECTABLE SqlInfo = 506
	//
	// Retrieves the null ordering.
	//
	// Returns a int32 ordinal for the null ordering being used, as described in
	// `arrow.flight.protocol.sql.SqlNullOrdering`.
	SqlInfo_SQL_NULL_ORDERING SqlInfo = 507
	// Retrieves a UTF-8 string list with values of the supported keywords.
	SqlInfo_SQL_KEYWORDS SqlInfo = 508
	// Retrieves a UTF-8 string list with values of the supported numeric functions.
	SqlInfo_SQL_NUMERIC_FUNCTIONS SqlInfo = 509
	// Retrieves a UTF-8 string list with values of the supported string functions.
	SqlInfo_SQL_STRING_FUNCTIONS SqlInfo = 510
	// Retrieves a UTF-8 string list with values of the supported system functions.
	SqlInfo_SQL_SYSTEM_FUNCTIONS SqlInfo = 511
	// Retrieves a UTF-8 string list with values of the supported datetime functions.
	SqlInfo_SQL_DATETIME_FUNCTIONS SqlInfo = 512
	//
	// Retrieves the UTF-8 string that can be used to escape wildcard characters.
	// This is the string that can be used to escape '_' or '%' in the catalog search parameters that are a pattern
	// (and therefore use one of the wildcard characters).
	// The '_' character represents any single character; the '%' character represents any sequence of zero or more
	// characters.
	SqlInfo_SQL_SEARCH_STRING_ESCAPE SqlInfo = 513
	//
	// Retrieves a UTF-8 string with all the "extra" characters that can be used in unquoted identifier names
	// (those beyond a-z, A-Z, 0-9 and _).
	SqlInfo_SQL_EXTRA_NAME_CHARACTERS SqlInfo = 514
	//
	// Retrieves a boolean value indicating whether column aliasing is supported.
	// If so, the SQL AS clause can be used to provide names for computed columns or to provide alias names for columns
	// as required.
	//
	// Returns:
	// - false: if column aliasing is unsupported;
	// - true: if column aliasing is supported.
	SqlInfo_SQL_SUPPORTS_COLUMN_ALIASING SqlInfo = 515
	//
	// Retrieves a boolean value indicating whether concatenations between null and non-null values being
	// null are supported.
	//
	// - Returns:
	// - false: if concatenations between null and non-null values being null are unsupported;
	// - true: if concatenations between null and non-null values being null are supported.
	SqlInfo_SQL_NULL_PLUS_NULL_IS_NULL SqlInfo = 516
	//
	// Retrieves a map where the key is the type to convert from and the value is a list with the types to convert to,
	// indicating the supported conversions. Each key and each item on the list value is a value to a predefined type on
	// SqlSupportsConvert enum.
	// The returned map will be:  map<int32, list<int32>>
	SqlInfo_SQL_SUPPORTS_CONVERT SqlInfo = 517
	//
	// Retrieves a boolean value indicating whether, when table correlation names are supported,
	// they are restricted to being different from the names of the tables.
	//
	// Returns:
	// - false: if table correlation names are unsupported;
	// - true: if table correlation names are supported.
	SqlInfo_SQL_SUPPORTS_TABLE_CORRELATION_NAMES SqlInfo = 518
	//
	// Retrieves a boolean value indicating whether, when table correlation names are supported,
	// they are restricted to being different from the names of the tables.
	//
	// Returns:
	// - false: if different table correlation names are unsupported;
	// - true: if different table correlation names are supported
	SqlInfo_SQL_SUPPORTS_DIFFERENT_TABLE_CORRELATION_NAMES SqlInfo = 519
	//
	// Retrieves a boolean value indicating whether expressions in ORDER BY lists are supported.
	//
	// Returns:
	// - false: if expressions in ORDER BY are unsupported;
	// - true: if expressions in ORDER BY are supported;
	SqlInfo_SQL_SUPPORTS_EXPRESSIONS_IN_ORDER_BY SqlInfo = 520
	//
	// Retrieves a boolean value indicating whether using a column that is not in the SELECT statement in a GROUP BY
	// clause is supported.
	//
	// Returns:
	// - false: if using a column that is not in the SELECT statement in a GROUP BY clause is unsupported;
	// - true: if using a column that is not in the SELECT statement in a GROUP BY clause is supported.
	SqlInfo_SQL_SUPPORTS_ORDER_BY_UNRELATED SqlInfo = 521
	//
	// Retrieves the supported GROUP BY commands;
	//
	// Returns an int32 bitmask value representing the supported commands.
	// The returned bitmask should be parsed in order to retrieve the supported commands.
	//
	// For instance:
	// - return 0 (\b0)   => [] (GROUP BY is unsupported);
	// - return 1 (\b1)   => [SQL_GROUP_BY_UNRELATED];
	// - return 2 (\b10)  => [SQL_GROUP_BY_BEYOND_SELECT];
	// - return 3 (\b11)  => [SQL_GROUP_BY_UNRELATED, SQL_GROUP_BY_BEYOND_SELECT].
	// Valid GROUP BY types are described under `arrow.flight.protocol.sql.SqlSupportedGroupBy`.
	SqlInfo_SQL_SUPPORTED_GROUP_BY SqlInfo = 522
	//
	// Retrieves a boolean value indicating whether specifying a LIKE escape clause is supported.
	//
	// Returns:
	// - false: if specifying a LIKE escape clause is unsupported;
	// - true: if specifying a LIKE escape clause is supported.
	SqlInfo_SQL_SUPPORTS_LIKE_ESCAPE_CLAUSE SqlInfo = 523
	//
	// Retrieves a boolean value indicating whether columns may be defined as non-nullable.
	//
	// Returns:
	// - false: if columns cannot be defined as non-nullable;
	// - true: if columns may be defined as non-nullable.
	SqlInfo_SQL_SUPPORTS_NON_NULLABLE_COLUMNS SqlInfo = 524
	//
	// Retrieves the supported SQL grammar level as per the ODBC specification.
	//
	// Returns an int32 bitmask value representing the supported SQL grammar level.
	// The returned bitmask should be parsed in order to retrieve the supported grammar levels.
	//
	// For instance:
	// - return 0 (\b0)   => [] (SQL grammar is unsupported);
	// - return 1 (\b1)   => [SQL_MINIMUM_GRAMMAR];
	// - return 2 (\b10)  => [SQL_CORE_GRAMMAR];
	// - return 3 (\b11)  => [SQL_MINIMUM_GRAMMAR, SQL_CORE_GRAMMAR];
	// - return 4 (\b100) => [SQL_EXTENDED_GRAMMAR];
	// - return 5 (\b101) => [SQL_MINIMUM_GRAMMAR, SQL_EXTENDED_GRAMMAR];
	// - return 6 (\b110) => [SQL_CORE_GRAMMAR, SQL_EXTENDED_GRAMMAR];
	// - return 7 (\b111) => [SQL_MINIMUM_GRAMMAR, SQL_CORE_GRAMMAR, SQL_EXTENDED_GRAMMAR].
	// Valid SQL grammar levels are described under `arrow.flight.protocol.sql.SupportedSqlGrammar`.
	SqlInfo_SQL_SUPPORTED_GRAMMAR SqlInfo = 525
	//
	// Retrieves the supported ANSI92 SQL grammar level.
	//
	// Returns an int32 bitmask value representing the supported ANSI92 SQL grammar level.
	// The returned bitmask should be parsed in order to retrieve the supported commands.
	//
	// For instance:
	// - return 0 (\b0)   => [] (ANSI92 SQL grammar is unsupported);
	// - return 1 (\b1)   => [ANSI92_ENTRY_SQL];
	// - return 2 (\b10)  => [ANSI92_INTERMEDIATE_SQL];
	// - return 3 (\b11)  => [ANSI92_ENTRY_SQL, ANSI92_INTERMEDIATE_SQL];
	// - return 4 (\b100) => [ANSI92_FULL_SQL];
	// - return 5 (\b101) => [ANSI92_ENTRY_SQL, ANSI92_FULL_SQL];
	// - return 6 (\b110) => [ANSI92_INTERMEDIATE_SQL, ANSI92_FULL_SQL];
	// - return 7 (\b111) => [ANSI92_ENTRY_SQL, ANSI92_INTERMEDIATE_SQL, ANSI92_FULL_SQL].
	// Valid ANSI92 SQL grammar levels are described under `arrow.flight.protocol.sql.SupportedAnsi92SqlGrammarLevel`.
	SqlInfo_SQL_ANSI92_SUPPORTED_LEVEL SqlInfo = 526
	//
	// Retrieves a boolean value indicating whether the SQL Integrity Enhancement Facility is supported.
	//
	// Returns:
	// - false: if the SQL Integrity Enhancement Facility is supported;
	// - true: if the SQL Integrity Enhancement Facility is supported.
	SqlInfo_SQL_SUPPORTS_INTEGRITY_ENHANCEMENT_FACILITY SqlInfo = 527
	//
	// Retrieves the support level for SQL OUTER JOINs.
	//
	// Returns a int32 ordinal for the SQL ordering being used, as described in
	// `arrow.flight.protocol.sql.SqlOuterJoinsSupportLevel`.
	SqlInfo_SQL_OUTER_JOINS_SUPPORT_LEVEL SqlInfo = 528
	// Retrieves a UTF-8 string with the preferred term for "schema".
	SqlInfo_SQL_SCHEMA_TERM SqlInfo = 529
	// Retrieves a UTF-8 string with the preferred term for "procedure".
	SqlInfo_SQL_PROCEDURE_TERM SqlInfo = 530
	//
	// Retrieves a UTF-8 string with the preferred term for "catalog".
	// If a empty string is returned its assumed that the server does NOT supports catalogs.
	SqlInfo_SQL_CATALOG_TERM SqlInfo = 531
	//
	// Retrieves a boolean value indicating whether a catalog appears at the start of a fully qualified table name.
	//
	// - false: if a catalog does not appear at the start of a fully qualified table name;
	// - true: if a catalog appears at the start of a fully qualified table name.
	SqlInfo_SQL_CATALOG_AT_START SqlInfo = 532
	//
	// Retrieves the supported actions for a SQL schema.
	//
	// Returns an int32 bitmask value representing the supported actions for a SQL schema.
	// The returned bitmask should be parsed in order to retrieve the supported actions for a SQL schema.
	//
	// For instance:
	// - return 0 (\b0)   => [] (no supported actions for SQL schema);
	// - return 1 (\b1)   => [SQL_ELEMENT_IN_PROCEDURE_CALLS];
	// - return 2 (\b10)  => [SQL_ELEMENT_IN_INDEX_DEFINITIONS];
	// - return 3 (\b11)  => [SQL_ELEMENT_IN_PROCEDURE_CALLS, SQL_ELEMENT_IN_INDEX_DEFINITIONS];
	// - return 4 (\b100) => [SQL_ELEMENT_IN_PRIVILEGE_DEFINITIONS];
	// - return 5 (\b101) => [SQL_ELEMENT_IN_PROCEDURE_CALLS, SQL_ELEMENT_IN_PRIVILEGE_DEFINITIONS];
	// - return 6 (\b110) => [SQL_ELEMENT_IN_INDEX_DEFINITIONS, SQL_ELEMENT_IN_PRIVILEGE_DEFINITIONS];
	// - return 7 (\b111) => [SQL_ELEMENT_IN_PROCEDURE_CALLS, SQL_ELEMENT_IN_INDEX_DEFINITIONS, SQL_ELEMENT_IN_PRIVILEGE_DEFINITIONS].
	// Valid actions for a SQL schema described under `arrow.flight.protocol.sql.SqlSupportedElementActions`.
	SqlInfo_SQL_SCHEMAS_SUPPORTED_ACTIONS SqlInfo = 533
	//
	// Retrieves the supported actions for a SQL schema.
	//
	// Returns an int32 bitmask value representing the supported actions for a SQL catalog.
	// The returned bitmask should be parsed in order to retrieve the supported actions for a SQL catalog.
	//
	// For instance:
	// - return 0 (\b0)   => [] (no supported actions for SQL catalog);
	// - return 1 (\b1)   => [SQL_ELEMENT_IN_PROCEDURE_CALLS];
	// - return 2 (\b10)  => [SQL_ELEMENT_IN_INDEX_DEFINITIONS];
	// - return 3 (\b11)  => [SQL_ELEMENT_IN_PROCEDURE_CALLS, SQL_ELEMENT_IN_INDEX_DEFINITIONS];
	// - return 4 (\b100) => [SQL_ELEMENT_IN_PRIVILEGE_DEFINITIONS];
	// - return 5 (\b101) => [SQL_ELEMENT_IN_PROCEDURE_CALLS, SQL_ELEMENT_IN_PRIVILEGE_DEFINITIONS];
	// - return 6 (\b110) => [SQL_ELEMENT_IN_INDEX_DEFINITIONS, SQL_ELEMENT_IN_PRIVILEGE_DEFINITIONS];
	// - return 7 (\b111) => [SQL_ELEMENT_IN_PROCEDURE_CALLS, SQL_ELEMENT_IN_INDEX_DEFINITIONS, SQL_ELEMENT_IN_PRIVILEGE_DEFINITIONS].
	// Valid actions for a SQL catalog are described under `arrow.flight.protocol.sql.SqlSupportedElementActions`.
	SqlInfo_SQL_CATALOGS_SUPPORTED_ACTIONS SqlInfo = 534
	//
	// Retrieves the supported SQL positioned commands.
	//
	// Returns an int32 bitmask value representing the supported SQL positioned commands.
	// The returned bitmask should be parsed in order to retrieve the supported SQL positioned commands.
	//
	// For instance:
	// - return 0 (\b0)   => [] (no supported SQL positioned commands);
	// - return 1 (\b1)   => [SQL_POSITIONED_DELETE];
	// - return 2 (\b10)  => [SQL_POSITIONED_UPDATE];
	// - return 3 (\b11)  => [SQL_POSITIONED_DELETE, SQL_POSITIONED_UPDATE].
	// Valid SQL positioned commands are described under `arrow.flight.protocol.sql.SqlSupportedPositionedCommands`.
	SqlInfo_SQL_SUPPORTED_POSITIONED_COMMANDS SqlInfo = 535
	//
	// Retrieves a boolean value indicating whether SELECT FOR UPDATE statements are supported.
	//
	// Returns:
	// - false: if SELECT FOR UPDATE statements are unsupported;
	// - true: if SELECT FOR UPDATE statements are supported.
	SqlInfo_SQL_SELECT_FOR_UPDATE_SUPPORTED SqlInfo = 536
	//
	// Retrieves a boolean value indicating whether stored procedure calls that use the stored procedure escape syntax
	// are supported.
	//
	// Returns:
	// - false: if stored procedure calls that use the stored procedure escape syntax are unsupported;
	// - true: if stored procedure calls that use the stored procedure escape syntax are supported.
	SqlInfo_SQL_STORED_PROCEDURES_SUPPORTED SqlInfo = 537
	//
	// Retrieves the supported SQL subqueries.
	//
	// Returns an int32 bitmask value representing the supported SQL subqueries.
	// The returned bitmask should be parsed in order to retrieve the supported SQL subqueries.
	//
	// For instance:
	// - return 0   (\b0)     => [] (no supported SQL subqueries);
	// - return 1   (\b1)     => [SQL_SUBQUERIES_IN_COMPARISONS];
	// - return 2   (\b10)    => [SQL_SUBQUERIES_IN_EXISTS];
	// - return 3   (\b11)    => [SQL_SUBQUERIES_IN_COMPARISONS, SQL_SUBQUERIES_IN_EXISTS];
	// - return 4   (\b100)   => [SQL_SUBQUERIES_IN_INS];
	// - return 5   (\b101)   => [SQL_SUBQUERIES_IN_COMPARISONS, SQL_SUBQUERIES_IN_INS];
	// - return 6   (\b110)   => [SQL_SUBQUERIES_IN_INS, SQL_SUBQUERIES_IN_EXISTS];
	// - return 7   (\b111)   => [SQL_SUBQUERIES_IN_COMPARISONS, SQL_SUBQUERIES_IN_EXISTS, SQL_SUBQUERIES_IN_INS];
	// - return 8   (\b1000)  => [SQL_SUBQUERIES_IN_QUANTIFIEDS];
	// - return 9   (\b1001)  => [SQL_SUBQUERIES_IN_COMPARISONS, SQL_SUBQUERIES_IN_QUANTIFIEDS];
	// - return 10  (\b1010)  => [SQL_SUBQUERIES_IN_EXISTS, SQL_SUBQUERIES_IN_QUANTIFIEDS];
	// - return 11  (\b1011)  => [SQL_SUBQUERIES_IN_COMPARISONS, SQL_SUBQUERIES_IN_EXISTS, SQL_SUBQUERIES_IN_QUANTIFIEDS];
	// - return 12  (\b1100)  => [SQL_SUBQUERIES_IN_INS, SQL_SUBQUERIES_IN_QUANTIFIEDS];
	// - return 13  (\b1101)  => [SQL_SUBQUERIES_IN_COMPARISONS, SQL_SUBQUERIES_IN_INS, SQL_SUBQUERIES_IN_QUANTIFIEDS];
	// - return 14  (\b1110)  => [SQL_SUBQUERIES_IN_EXISTS, SQL_SUBQUERIES_IN_INS, SQL_SUBQUERIES_IN_QUANTIFIEDS];
	// - return 15  (\b1111)  => [SQL_SUBQUERIES_IN_COMPARISONS, SQL_SUBQUERIES_IN_EXISTS, SQL_SUBQUERIES_IN_INS, SQL_SUBQUERIES_IN_QUANTIFIEDS];
	// - ...
	// Valid SQL subqueries are described under `arrow.flight.protocol.sql.SqlSupportedSubqueries`.
	SqlInfo_SQL_SUPPORTED_SUBQUERIES SqlInfo = 538
	//
	// Retrieves a boolean value indicating whether correlated subqueries are supported.
	//
	// Returns:
	// - false: if correlated subqueries are unsupported;
	// - true: if correlated subqueries are supported.
	SqlInfo_SQL_CORRELATED_SUBQUERIES_SUPPORTED SqlInfo = 539
	//
	// Retrieves the supported SQL UNIONs.
	//
	// Returns an int32 bitmask value representing the supported SQL UNIONs.
	// The returned bitmask should be parsed in order to retrieve the supported SQL UNIONs.
	//
	// For instance:
	// - return 0 (\b0)   => [] (no supported SQL positioned commands);
	// - return 1 (\b1)   => [SQL_UNION];
	// - return 2 (\b10)  => [SQL_UNION_ALL];
	// - return 3 (\b11)  => [SQL_UNION, SQL_UNION_ALL].
	// Valid SQL positioned commands are described under `arrow.flight.protocol.sql.SqlSupportedUnions`.
	SqlInfo_SQL_SUPPORTED_UNIONS SqlInfo = 540
	// Retrieves a int64 value representing the maximum number of hex characters allowed in an inline binary literal.
	SqlInfo_SQL_MAX_BINARY_LITERAL_LENGTH SqlInfo = 541
	// Retrieves a int64 value representing the maximum number of characters allowed for a character literal.
	SqlInfo_SQL_MAX_CHAR_LITERAL_LENGTH SqlInfo = 542
	// Retrieves a int64 value representing the maximum number of characters allowed for a column name.
	SqlInfo_SQL_MAX_COLUMN_NAME_LENGTH SqlInfo = 543
	// Retrieves a int64 value representing the maximum number of columns allowed in a GROUP BY clause.
	SqlInfo_SQL_MAX_COLUMNS_IN_GROUP_BY SqlInfo = 544
	// Retrieves a int64 value representing the maximum number of columns allowed in an index.
	SqlInfo_SQL_MAX_COLUMNS_IN_INDEX SqlInfo = 545
	// Retrieves a int64 value representing the maximum number of columns allowed in an ORDER BY clause.
	SqlInfo_SQL_MAX_COLUMNS_IN_ORDER_BY SqlInfo = 546
	// Retrieves a int64 value representing the maximum number of columns allowed in a SELECT list.
	SqlInfo_SQL_MAX_COLUMNS_IN_SELECT SqlInfo = 547
	// Retrieves a int64 value representing the maximum number of columns allowed in a table.
	SqlInfo_SQL_MAX_COLUMNS_IN_TABLE SqlInfo = 548
	// Retrieves a int64 value representing the maximum number of concurrent connections possible.
	SqlInfo_SQL_MAX_CONNECTIONS SqlInfo = 549
	// Retrieves a int64 value the maximum number of characters allowed in a cursor name.
	SqlInfo_SQL_MAX_CURSOR_NAME_LENGTH SqlInfo = 550
	//
	// Retrieves a int64 value representing the maximum number of bytes allowed for an index,
	// including all of the parts of the index.
	SqlInfo_SQL_MAX_INDEX_LENGTH SqlInfo = 551
	// Retrieves a int64 value representing the maximum number of characters allowed in a schema name.
	SqlInfo_SQL_DB_SCHEMA_NAME_LENGTH SqlInfo = 552
	// Retrieves a int64 value representing the maximum number of characters allowed in a procedure name.
	SqlInfo_SQL_MAX_PROCEDURE_NAME_LENGTH SqlInfo = 553
	// Retrieves a int64 value representing the maximum number of characters allowed in a catalog name.
	SqlInfo_SQL_MAX_CATALOG_NAME_LENGTH SqlInfo = 554
	// Retrieves a int64 value representing the maximum number of bytes allowed in a single row.
	SqlInfo_SQL_MAX_ROW_SIZE SqlInfo = 555
	//
	// Retrieves a boolean indicating whether the return value for the JDBC method getMaxRowSize includes the SQL
	// data types LONGVARCHAR and LONGVARBINARY.
	//
	// Returns:
	// - false: if return value for the JDBC method getMaxRowSize does
	//          not include the SQL data types LONGVARCHAR and LONGVARBINARY;
	// - true: if return value for the JDBC method getMaxRowSize includes
	//         the SQL data types LONGVARCHAR and LONGVARBINARY.
	SqlInfo_SQL_MAX_ROW_SIZE_INCLUDES_BLOBS SqlInfo = 556
	//
	// Retrieves a int64 value representing the maximum number of characters allowed for an SQL statement;
	// a result of 0 (zero) means that there is no limit or the limit is not known.
	SqlInfo_SQL_MAX_STATEMENT_LENGTH SqlInfo = 557
	// Retrieves a int64 value representing the maximum number of active statements that can be open at the same time.
	SqlInfo_SQL_MAX_STATEMENTS SqlInfo = 558
	// Retrieves a int64 value representing the maximum number of characters allowed in a table name.
	SqlInfo_SQL_MAX_TABLE_NAME_LENGTH SqlInfo = 559
	// Retrieves a int64 value representing the maximum number of tables allowed in a SELECT statement.
	SqlInfo_SQL_MAX_TABLES_IN_SELECT SqlInfo = 560
	// Retrieves a int64 value representing the maximum number of characters allowed in a user name.
	SqlInfo_SQL_MAX_USERNAME_LENGTH SqlInfo = 561
	//
	// Retrieves this database's default transaction isolation level as described in
	// `arrow.flight.protocol.sql.SqlTransactionIsolationLevel`.
	//
	// Returns a int32 ordinal for the SQL transaction isolation level.
	SqlInfo_SQL_DEFAULT_TRANSACTION_ISOLATION SqlInfo = 562
	//
	// Retrieves a boolean value indicating whether transactions are supported. If not, invoking the method commit is a
	// noop, and the isolation level is `arrow.flight.protocol.sql.SqlTransactionIsolationLevel.TRANSACTION_NONE`.
	//
	// Returns:
	// - false: if transactions are unsupported;
	// - true: if transactions are supported.
	SqlInfo_SQL_TRANSACTIONS_SUPPORTED SqlInfo = 563
	//
	// Retrieves the supported transactions isolation levels.
	//
	// Returns an int32 bitmask value representing the supported transactions isolation levels.
	// The returned bitmask should be parsed in order to retrieve the supported transactions isolation levels.
	//
	// For instance:
	// - return 0   (\b0)     => [] (no supported SQL transactions isolation levels);
	// - return 1   (\b1)     => [SQL_TRANSACTION_NONE];
	// - return 2   (\b10)    => [SQL_TRANSACTION_READ_UNCOMMITTED];
	// - return 3   (\b11)    => [SQL_TRANSACTION_NONE, SQL_TRANSACTION_READ_UNCOMMITTED];
	// - return 4   (\b100)   => [SQL_TRANSACTION_REPEATABLE_READ];
	// - return 5   (\b101)   => [SQL_TRANSACTION_NONE, SQL_TRANSACTION_REPEATABLE_READ];
	// - return 6   (\b110)   => [SQL_TRANSACTION_READ_UNCOMMITTED, SQL_TRANSACTION_REPEATABLE_READ];
	// - return 7   (\b111)   => [SQL_TRANSACTION_NONE, SQL_TRANSACTION_READ_UNCOMMITTED, SQL_TRANSACTION_REPEATABLE_READ];
	// - return 8   (\b1000)  => [SQL_TRANSACTION_REPEATABLE_READ];
	// - return 9   (\b1001)  => [SQL_TRANSACTION_NONE, SQL_TRANSACTION_REPEATABLE_READ];
	// - return 10  (\b1010)  => [SQL_TRANSACTION_READ_UNCOMMITTED, SQL_TRANSACTION_REPEATABLE_READ];
	// - return 11  (\b1011)  => [SQL_TRANSACTION_NONE, SQL_TRANSACTION_READ_UNCOMMITTED, SQL_TRANSACTION_REPEATABLE_READ];
	// - return 12  (\b1100)  => [SQL_TRANSACTION_REPEATABLE_READ, SQL_TRANSACTION_REPEATABLE_READ];
	// - return 13  (\b1101)  => [SQL_TRANSACTION_NONE, SQL_TRANSACTION_REPEATABLE_READ, SQL_TRANSACTION_REPEATABLE_READ];
	// - return 14  (\b1110)  => [SQL_TRANSACTION_READ_UNCOMMITTED, SQL_TRANSACTION_REPEATABLE_READ, SQL_TRANSACTION_REPEATABLE_READ];
	// - return 15  (\b1111)  => [SQL_TRANSACTION_NONE, SQL_TRANSACTION_READ_UNCOMMITTED, SQL_TRANSACTION_REPEATABLE_READ, SQL_TRANSACTION_REPEATABLE_READ];
	// - return 16  (\b10000) => [SQL_TRANSACTION_SERIALIZABLE];
	// - ...
	// Valid SQL positioned commands are described under `arrow.flight.protocol.sql.SqlTransactionIsolationLevel`.
	SqlInfo_SQL_SUPPORTED_TRANSACTIONS_ISOLATION_LEVELS SqlInfo = 564
	//
	// Retrieves a boolean value indicating whether a data definition statement within a transaction forces
	// the transaction to commit.
	//
	// Returns:
	// - false: if a data definition statement within a transaction does not force the transaction to commit;
	// - true: if a data definition statement within a transaction forces the transaction to commit.
	SqlInfo_SQL_DATA_DEFINITION_CAUSES_TRANSACTION_COMMIT SqlInfo = 565
	//
	// Retrieves a boolean value indicating whether a data definition statement within a transaction is ignored.
	//
	// Returns:
	// - false: if a data definition statement within a transaction is taken into account;
	// - true: a data definition statement within a transaction is ignored.
	SqlInfo_SQL_DATA_DEFINITIONS_IN_TRANSACTIONS_IGNORED SqlInfo = 566
	//
	// Retrieves an int32 bitmask value representing the supported result set types.
	// The returned bitmask should be parsed in order to retrieve the supported result set types.
	//
	// For instance:
	// - return 0   (\b0)     => [] (no supported result set types);
	// - return 1   (\b1)     => [SQL_RESULT_SET_TYPE_UNSPECIFIED];
	// - return 2   (\b10)    => [SQL_RESULT_SET_TYPE_FORWARD_ONLY];
	// - return 3   (\b11)    => [SQL_RESULT_SET_TYPE_UNSPECIFIED, SQL_RESULT_SET_TYPE_FORWARD_ONLY];
	// - return 4   (\b100)   => [SQL_RESULT_SET_TYPE_SCROLL_INSENSITIVE];
	// - return 5   (\b101)   => [SQL_RESULT_SET_TYPE_UNSPECIFIED, SQL_RESULT_SET_TYPE_SCROLL_INSENSITIVE];
	// - return 6   (\b110)   => [SQL_RESULT_SET_TYPE_FORWARD_ONLY, SQL_RESULT_SET_TYPE_SCROLL_INSENSITIVE];
	// - return 7   (\b111)   => [SQL_RESULT_SET_TYPE_UNSPECIFIED, SQL_RESULT_SET_TYPE_FORWARD_ONLY, SQL_RESULT_SET_TYPE_SCROLL_INSENSITIVE];
	// - return 8   (\b1000)  => [SQL_RESULT_SET_TYPE_SCROLL_SENSITIVE];
	// - ...
	// Valid result set types are described under `arrow.flight.protocol.sql.SqlSupportedResultSetType`.
	SqlInfo_SQL_SUPPORTED_RESULT_SET_TYPES SqlInfo = 567
	//
	// Returns an int32 bitmask value concurrency types supported for
	// `arrow.flight.protocol.sql.SqlSupportedResultSetType.SQL_RESULT_SET_TYPE_UNSPECIFIED`.
	//
	// For instance:
	// - return 0 (\b0)   => [] (no supported concurrency types for this result set type)
	// - return 1 (\b1)   => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED]
	// - return 2 (\b10)  => [SQL_RESULT_SET_CONCURRENCY_READ_ONLY]
	// - return 3 (\b11)  => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED, SQL_RESULT_SET_CONCURRENCY_READ_ONLY]
	// - return 4 (\b100) => [SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
	// - return 5 (\b101) => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED, SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
	// - return 6 (\b110)  => [SQL_RESULT_SET_CONCURRENCY_READ_ONLY, SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
	// - return 7 (\b111)  => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED, SQL_RESULT_SET_CONCURRENCY_READ_ONLY, SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
	// Valid result set types are described under `arrow.flight.protocol.sql.SqlSupportedResultSetConcurrency`.
	SqlInfo_SQL_SUPPORTED_CONCURRENCIES_FOR_RESULT_SET_UNSPECIFIED SqlInfo = 568
	//
	// Returns an int32 bitmask value concurrency types supported for
	// `arrow.flight.protocol.sql.SqlSupportedResultSetType.SQL_RESULT_SET_TYPE_FORWARD_ONLY`.
	//
	// For instance:
	// - return 0 (\b0)   => [] (no supported concurrency types for this result set type)
	// - return 1 (\b1)   => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED]
	// - return 2 (\b10)  => [SQL_RESULT_SET_CONCURRENCY_READ_ONLY]
	// - return 3 (\b11)  => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED, SQL_RESULT_SET_CONCURRENCY_READ_ONLY]
	// - return 4 (\b100) => [SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
	// - return 5 (\b101) => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED, SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
	// - return 6 (\b110)  => [SQL_RESULT_SET_CONCURRENCY_READ_ONLY, SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
	// - return 7 (\b111)  => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED, SQL_RESULT_SET_CONCURRENCY_READ_ONLY, SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
	// Valid result set types are described under `arrow.flight.protocol.sql.SqlSupportedResultSetConcurrency`.
	SqlInfo_SQL_SUPPORTED_CONCURRENCIES_FOR_RESULT_SET_FORWARD_ONLY SqlInfo = 569
	//
	// Returns an int32 bitmask value concurrency types supported for
	// `arrow.flight.protocol.sql.SqlSupportedResultSetType.SQL_RESULT_SET_TYPE_SCROLL_SENSITIVE`.
	//
	// For instance:
	// - return 0 (\b0)   => [] (no supported concurrency types for this result set type)
	// - return 1 (\b1)   => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED]
	// - return 2 (\b10)  => [SQL_RESULT_SET_CONCURRENCY_READ_ONLY]
	// - return 3 (\b11)  => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED, SQL_RESULT_SET_CONCURRENCY_READ_ONLY]
	// - return 4 (\b100) => [SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
	// - return 5 (\b101) => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED, SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
	// - return 6 (\b110)  => [SQL_RESULT_SET_CONCURRENCY_READ_ONLY, SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
	// - return 7 (\b111)  => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED, SQL_RESULT_SET_CONCURRENCY_READ_ONLY, SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
	// Valid result set types are described under `arrow.flight.protocol.sql.SqlSupportedResultSetConcurrency`.
	SqlInfo_SQL_SUPPORTED_CONCURRENCIES_FOR_RESULT_SET_SCROLL_SENSITIVE SqlInfo = 570
	//
	// Returns an int32 bitmask value concurrency types supported for
	// `arrow.flight.protocol.sql.SqlSupportedResultSetType.SQL_RESULT_SET_TYPE_SCROLL_INSENSITIVE`.
	//
	// For instance:
	// - return 0 (\b0)   => [] (no supported concurrency types for this result set type)
	// - return 1 (\b1)   => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED]
	// - return 2 (\b10)  => [SQL_RESULT_SET_CONCURRENCY_READ_ONLY]
	// - return 3 (\b11)  => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED, SQL_RESULT_SET_CONCURRENCY_READ_ONLY]
	// - return 4 (\b100) => [SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
	// - return 5 (\b101) => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED, SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
	// - return 6 (\b110)  => [SQL_RESULT_SET_CONCURRENCY_READ_ONLY, SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
	// - return 7 (\b111)  => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED, SQL_RESULT_SET_CONCURRENCY_READ_ONLY, SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
	// Valid result set types are described under `arrow.flight.protocol.sql.SqlSupportedResultSetConcurrency`.
	SqlInfo_SQL_SUPPORTED_CONCURRENCIES_FOR_RESULT_SET_SCROLL_INSENSITIVE SqlInfo = 571
	//
	// Retrieves a boolean value indicating whether this database supports batch updates.
	//
	// - false: if this database does not support batch updates;
	// - true: if this database supports batch updates.
	SqlInfo_SQL_BATCH_UPDATES_SUPPORTED SqlInfo = 572
	//
	// Retrieves a boolean value indicating whether this database supports savepoints.
	//
	// Returns:
	// - false: if this database does not support savepoints;
	// - true: if this database supports savepoints.
	SqlInfo_SQL_SAVEPOINTS_SUPPORTED SqlInfo = 573
	//
	// Retrieves a boolean value indicating whether named parameters are supported in callable statements.
	//
	// Returns:
	// - false: if named parameters in callable statements are unsupported;
	// - true: if named parameters in callable statements are supported.
	SqlInfo_SQL_NAMED_PARAMETERS_SUPPORTED SqlInfo = 574
	//
	// Retrieves a boolean value indicating whether updates made to a LOB are made on a copy or directly to the LOB.
	//
	// Returns:
	// - false: if updates made to a LOB are made directly to the LOB;
	// - true: if updates made to a LOB are made on a copy.
	SqlInfo_SQL_LOCATORS_UPDATE_COPY SqlInfo = 575
	//
	// Retrieves a boolean value indicating whether invoking user-defined or vendor functions
	// using the stored procedure escape syntax is supported.
	//
	// Returns:
	// - false: if invoking user-defined or vendor functions using the stored procedure escape syntax is unsupported;
	// - true: if invoking user-defined or vendor functions using the stored procedure escape syntax is supported.
	SqlInfo_SQL_STORED_FUNCTIONS_USING_CALL_SYNTAX_SUPPORTED SqlInfo = 576
)

func (SqlInfo) Descriptor 

func (SqlInfo) Descriptor() protoreflect.EnumDescriptor

func (SqlInfo) Enum 

func (x SqlInfo) Enum() *SqlInfo

func (SqlInfo) EnumDescriptor deprecated 

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

Deprecated: Use SqlInfo.Descriptor instead.

func (SqlInfo) Number 

func (x SqlInfo) Number() protoreflect.EnumNumber

func (SqlInfo) String 

func (x SqlInfo) String() string

func (SqlInfo) Type 

func (SqlInfo) Type() protoreflect.EnumType

type SqlNullOrdering 

type SqlNullOrdering int32
const (
	SqlNullOrdering_SQL_NULLS_SORTED_HIGH     SqlNullOrdering = 0
	SqlNullOrdering_SQL_NULLS_SORTED_LOW      SqlNullOrdering = 1
	SqlNullOrdering_SQL_NULLS_SORTED_AT_START SqlNullOrdering = 2
	SqlNullOrdering_SQL_NULLS_SORTED_AT_END   SqlNullOrdering = 3
)

func (SqlNullOrdering) Descriptor 

func (SqlNullOrdering) Descriptor() protoreflect.EnumDescriptor

func (SqlNullOrdering) Enum 

func (x SqlNullOrdering) Enum() *SqlNullOrdering

func (SqlNullOrdering) EnumDescriptor deprecated 

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

Deprecated: Use SqlNullOrdering.Descriptor instead.

func (SqlNullOrdering) Number 

func (x SqlNullOrdering) Number() protoreflect.EnumNumber

func (SqlNullOrdering) String 

func (x SqlNullOrdering) String() string

func (SqlNullOrdering) Type 

func (SqlNullOrdering) Type() protoreflect.EnumType

type SqlOuterJoinsSupportLevel 

type SqlOuterJoinsSupportLevel int32
const (
	SqlOuterJoinsSupportLevel_SQL_JOINS_UNSUPPORTED   SqlOuterJoinsSupportLevel = 0
	SqlOuterJoinsSupportLevel_SQL_LIMITED_OUTER_JOINS SqlOuterJoinsSupportLevel = 1
	SqlOuterJoinsSupportLevel_SQL_FULL_OUTER_JOINS    SqlOuterJoinsSupportLevel = 2
)

func (SqlOuterJoinsSupportLevel) Descriptor 

func (SqlOuterJoinsSupportLevel) Descriptor() protoreflect.EnumDescriptor

func (SqlOuterJoinsSupportLevel) Enum 

func (x SqlOuterJoinsSupportLevel) Enum() *SqlOuterJoinsSupportLevel

func (SqlOuterJoinsSupportLevel) EnumDescriptor deprecated 

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

Deprecated: Use SqlOuterJoinsSupportLevel.Descriptor instead.

func (SqlOuterJoinsSupportLevel) Number 

func (x SqlOuterJoinsSupportLevel) Number() protoreflect.EnumNumber

func (SqlOuterJoinsSupportLevel) String 

func (x SqlOuterJoinsSupportLevel) String() string

func (SqlOuterJoinsSupportLevel) Type 

func (SqlOuterJoinsSupportLevel) Type() protoreflect.EnumType

type SqlSupportedCaseSensitivity 

type SqlSupportedCaseSensitivity int32
const (
	SqlSupportedCaseSensitivity_SQL_CASE_SENSITIVITY_UNKNOWN          SqlSupportedCaseSensitivity = 0
	SqlSupportedCaseSensitivity_SQL_CASE_SENSITIVITY_CASE_INSENSITIVE SqlSupportedCaseSensitivity = 1
	SqlSupportedCaseSensitivity_SQL_CASE_SENSITIVITY_UPPERCASE        SqlSupportedCaseSensitivity = 2
	SqlSupportedCaseSensitivity_SQL_CASE_SENSITIVITY_LOWERCASE        SqlSupportedCaseSensitivity = 3
)

func (SqlSupportedCaseSensitivity) Descriptor 

func (SqlSupportedCaseSensitivity) Descriptor() protoreflect.EnumDescriptor

func (SqlSupportedCaseSensitivity) Enum 

func (x SqlSupportedCaseSensitivity) Enum() *SqlSupportedCaseSensitivity

func (SqlSupportedCaseSensitivity) EnumDescriptor deprecated 

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

Deprecated: Use SqlSupportedCaseSensitivity.Descriptor instead.

func (SqlSupportedCaseSensitivity) Number 

func (x SqlSupportedCaseSensitivity) Number() protoreflect.EnumNumber

func (SqlSupportedCaseSensitivity) String 

func (x SqlSupportedCaseSensitivity) String() string

func (SqlSupportedCaseSensitivity) Type 

func (SqlSupportedCaseSensitivity) Type() protoreflect.EnumType

type SqlSupportedElementActions 

type SqlSupportedElementActions int32
const (
	SqlSupportedElementActions_SQL_ELEMENT_IN_PROCEDURE_CALLS       SqlSupportedElementActions = 0
	SqlSupportedElementActions_SQL_ELEMENT_IN_INDEX_DEFINITIONS     SqlSupportedElementActions = 1
	SqlSupportedElementActions_SQL_ELEMENT_IN_PRIVILEGE_DEFINITIONS SqlSupportedElementActions = 2
)

func (SqlSupportedElementActions) Descriptor 

func (SqlSupportedElementActions) Descriptor() protoreflect.EnumDescriptor

func (SqlSupportedElementActions) Enum 

func (x SqlSupportedElementActions) Enum() *SqlSupportedElementActions

func (SqlSupportedElementActions) EnumDescriptor deprecated 

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

Deprecated: Use SqlSupportedElementActions.Descriptor instead.

func (SqlSupportedElementActions) Number 

func (x SqlSupportedElementActions) Number() protoreflect.EnumNumber

func (SqlSupportedElementActions) String 

func (x SqlSupportedElementActions) String() string

func (SqlSupportedElementActions) Type 

func (SqlSupportedElementActions) Type() protoreflect.EnumType

type SqlSupportedGroupBy 

type SqlSupportedGroupBy int32
const (
	SqlSupportedGroupBy_SQL_GROUP_BY_UNRELATED     SqlSupportedGroupBy = 0
	SqlSupportedGroupBy_SQL_GROUP_BY_BEYOND_SELECT SqlSupportedGroupBy = 1
)

func (SqlSupportedGroupBy) Descriptor 

func (SqlSupportedGroupBy) Descriptor() protoreflect.EnumDescriptor

func (SqlSupportedGroupBy) Enum 

func (x SqlSupportedGroupBy) Enum() *SqlSupportedGroupBy

func (SqlSupportedGroupBy) EnumDescriptor deprecated 

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

Deprecated: Use SqlSupportedGroupBy.Descriptor instead.

func (SqlSupportedGroupBy) Number 

func (x SqlSupportedGroupBy) Number() protoreflect.EnumNumber

func (SqlSupportedGroupBy) String 

func (x SqlSupportedGroupBy) String() string

func (SqlSupportedGroupBy) Type 

func (SqlSupportedGroupBy) Type() protoreflect.EnumType

type SqlSupportedPositionedCommands 

type SqlSupportedPositionedCommands int32
const (
	SqlSupportedPositionedCommands_SQL_POSITIONED_DELETE SqlSupportedPositionedCommands = 0
	SqlSupportedPositionedCommands_SQL_POSITIONED_UPDATE SqlSupportedPositionedCommands = 1
)

func (SqlSupportedPositionedCommands) Descriptor 

func (SqlSupportedPositionedCommands) Descriptor() protoreflect.EnumDescriptor

func (SqlSupportedPositionedCommands) Enum 

func (x SqlSupportedPositionedCommands) Enum() *SqlSupportedPositionedCommands

func (SqlSupportedPositionedCommands) EnumDescriptor deprecated 

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

Deprecated: Use SqlSupportedPositionedCommands.Descriptor instead.

func (SqlSupportedPositionedCommands) Number 

func (x SqlSupportedPositionedCommands) Number() protoreflect.EnumNumber

func (SqlSupportedPositionedCommands) String 

func (x SqlSupportedPositionedCommands) String() string

func (SqlSupportedPositionedCommands) Type 

func (SqlSupportedPositionedCommands) Type() protoreflect.EnumType

type SqlSupportedResultSetConcurrency 

type SqlSupportedResultSetConcurrency int32
const (
	SqlSupportedResultSetConcurrency_SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED SqlSupportedResultSetConcurrency = 0
	SqlSupportedResultSetConcurrency_SQL_RESULT_SET_CONCURRENCY_READ_ONLY   SqlSupportedResultSetConcurrency = 1
	SqlSupportedResultSetConcurrency_SQL_RESULT_SET_CONCURRENCY_UPDATABLE   SqlSupportedResultSetConcurrency = 2
)

func (SqlSupportedResultSetConcurrency) Descriptor 

func (SqlSupportedResultSetConcurrency) Descriptor() protoreflect.EnumDescriptor

func (SqlSupportedResultSetConcurrency) Enum 

func (x SqlSupportedResultSetConcurrency) Enum() *SqlSupportedResultSetConcurrency

func (SqlSupportedResultSetConcurrency) EnumDescriptor deprecated 

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

Deprecated: Use SqlSupportedResultSetConcurrency.Descriptor instead.

func (SqlSupportedResultSetConcurrency) Number 

func (x SqlSupportedResultSetConcurrency) Number() protoreflect.EnumNumber

func (SqlSupportedResultSetConcurrency) String 

func (x SqlSupportedResultSetConcurrency) String() string

func (SqlSupportedResultSetConcurrency) Type 

func (SqlSupportedResultSetConcurrency) Type() protoreflect.EnumType

type SqlSupportedResultSetType 

type SqlSupportedResultSetType int32
const (
	SqlSupportedResultSetType_SQL_RESULT_SET_TYPE_UNSPECIFIED        SqlSupportedResultSetType = 0
	SqlSupportedResultSetType_SQL_RESULT_SET_TYPE_FORWARD_ONLY       SqlSupportedResultSetType = 1
	SqlSupportedResultSetType_SQL_RESULT_SET_TYPE_SCROLL_INSENSITIVE SqlSupportedResultSetType = 2
	SqlSupportedResultSetType_SQL_RESULT_SET_TYPE_SCROLL_SENSITIVE   SqlSupportedResultSetType = 3
)

func (SqlSupportedResultSetType) Descriptor 

func (SqlSupportedResultSetType) Descriptor() protoreflect.EnumDescriptor

func (SqlSupportedResultSetType) Enum 

func (x SqlSupportedResultSetType) Enum() *SqlSupportedResultSetType

func (SqlSupportedResultSetType) EnumDescriptor deprecated 

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

Deprecated: Use SqlSupportedResultSetType.Descriptor instead.

func (SqlSupportedResultSetType) Number 

func (x SqlSupportedResultSetType) Number() protoreflect.EnumNumber

func (SqlSupportedResultSetType) String 

func (x SqlSupportedResultSetType) String() string

func (SqlSupportedResultSetType) Type 

func (SqlSupportedResultSetType) Type() protoreflect.EnumType

type SqlSupportedSubqueries 

type SqlSupportedSubqueries int32
const (
	SqlSupportedSubqueries_SQL_SUBQUERIES_IN_COMPARISONS SqlSupportedSubqueries = 0
	SqlSupportedSubqueries_SQL_SUBQUERIES_IN_EXISTS      SqlSupportedSubqueries = 1
	SqlSupportedSubqueries_SQL_SUBQUERIES_IN_INS         SqlSupportedSubqueries = 2
	SqlSupportedSubqueries_SQL_SUBQUERIES_IN_QUANTIFIEDS SqlSupportedSubqueries = 3
)

func (SqlSupportedSubqueries) Descriptor 

func (SqlSupportedSubqueries) Descriptor() protoreflect.EnumDescriptor

func (SqlSupportedSubqueries) Enum 

func (x SqlSupportedSubqueries) Enum() *SqlSupportedSubqueries

func (SqlSupportedSubqueries) EnumDescriptor deprecated 

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

Deprecated: Use SqlSupportedSubqueries.Descriptor instead.

func (SqlSupportedSubqueries) Number 

func (x SqlSupportedSubqueries) Number() protoreflect.EnumNumber

func (SqlSupportedSubqueries) String 

func (x SqlSupportedSubqueries) String() string

func (SqlSupportedSubqueries) Type 

func (SqlSupportedSubqueries) Type() protoreflect.EnumType

type SqlSupportedTransaction 

type SqlSupportedTransaction int32

The level of support for Flight SQL transaction RPCs. 

const (
	// Unknown/not indicated/no support
	SqlSupportedTransaction_SQL_SUPPORTED_TRANSACTION_NONE SqlSupportedTransaction = 0
	// Transactions, but not savepoints.
	// A savepoint is a mark within a transaction that can be individually
	// rolled back to. Not all databases support savepoints.
	SqlSupportedTransaction_SQL_SUPPORTED_TRANSACTION_TRANSACTION SqlSupportedTransaction = 1
	// Transactions and savepoints
	SqlSupportedTransaction_SQL_SUPPORTED_TRANSACTION_SAVEPOINT SqlSupportedTransaction = 2
)

func (SqlSupportedTransaction) Descriptor 

func (SqlSupportedTransaction) Descriptor() protoreflect.EnumDescriptor

func (SqlSupportedTransaction) Enum 

func (x SqlSupportedTransaction) Enum() *SqlSupportedTransaction

func (SqlSupportedTransaction) EnumDescriptor deprecated 

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

Deprecated: Use SqlSupportedTransaction.Descriptor instead.

func (SqlSupportedTransaction) Number 

func (x SqlSupportedTransaction) Number() protoreflect.EnumNumber

func (SqlSupportedTransaction) String 

func (x SqlSupportedTransaction) String() string

func (SqlSupportedTransaction) Type 

func (SqlSupportedTransaction) Type() protoreflect.EnumType

type SqlSupportedTransactions 

type SqlSupportedTransactions int32
const (
	SqlSupportedTransactions_SQL_TRANSACTION_UNSPECIFIED        SqlSupportedTransactions = 0
	SqlSupportedTransactions_SQL_DATA_DEFINITION_TRANSACTIONS   SqlSupportedTransactions = 1
	SqlSupportedTransactions_SQL_DATA_MANIPULATION_TRANSACTIONS SqlSupportedTransactions = 2
)

func (SqlSupportedTransactions) Descriptor 

func (SqlSupportedTransactions) Descriptor() protoreflect.EnumDescriptor

func (SqlSupportedTransactions) Enum 

func (x SqlSupportedTransactions) Enum() *SqlSupportedTransactions

func (SqlSupportedTransactions) EnumDescriptor deprecated 

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

Deprecated: Use SqlSupportedTransactions.Descriptor instead.

func (SqlSupportedTransactions) Number 

func (x SqlSupportedTransactions) Number() protoreflect.EnumNumber

func (SqlSupportedTransactions) String 

func (x SqlSupportedTransactions) String() string

func (SqlSupportedTransactions) Type 

func (SqlSupportedTransactions) Type() protoreflect.EnumType

type SqlSupportedUnions 

type SqlSupportedUnions int32
const (
	SqlSupportedUnions_SQL_UNION     SqlSupportedUnions = 0
	SqlSupportedUnions_SQL_UNION_ALL SqlSupportedUnions = 1
)

func (SqlSupportedUnions) Descriptor 

func (SqlSupportedUnions) Descriptor() protoreflect.EnumDescriptor

func (SqlSupportedUnions) Enum 

func (x SqlSupportedUnions) Enum() *SqlSupportedUnions

func (SqlSupportedUnions) EnumDescriptor deprecated 

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

Deprecated: Use SqlSupportedUnions.Descriptor instead.

func (SqlSupportedUnions) Number 

func (x SqlSupportedUnions) Number() protoreflect.EnumNumber

func (SqlSupportedUnions) String 

func (x SqlSupportedUnions) String() string

func (SqlSupportedUnions) Type 

func (SqlSupportedUnions) Type() protoreflect.EnumType

type SqlSupportsConvert 

type SqlSupportsConvert int32
const (
	SqlSupportsConvert_SQL_CONVERT_BIGINT              SqlSupportsConvert = 0
	SqlSupportsConvert_SQL_CONVERT_BINARY              SqlSupportsConvert = 1
	SqlSupportsConvert_SQL_CONVERT_BIT                 SqlSupportsConvert = 2
	SqlSupportsConvert_SQL_CONVERT_CHAR                SqlSupportsConvert = 3
	SqlSupportsConvert_SQL_CONVERT_DATE                SqlSupportsConvert = 4
	SqlSupportsConvert_SQL_CONVERT_DECIMAL             SqlSupportsConvert = 5
	SqlSupportsConvert_SQL_CONVERT_FLOAT               SqlSupportsConvert = 6
	SqlSupportsConvert_SQL_CONVERT_INTEGER             SqlSupportsConvert = 7
	SqlSupportsConvert_SQL_CONVERT_INTERVAL_DAY_TIME   SqlSupportsConvert = 8
	SqlSupportsConvert_SQL_CONVERT_INTERVAL_YEAR_MONTH SqlSupportsConvert = 9
	SqlSupportsConvert_SQL_CONVERT_LONGVARBINARY       SqlSupportsConvert = 10
	SqlSupportsConvert_SQL_CONVERT_LONGVARCHAR         SqlSupportsConvert = 11
	SqlSupportsConvert_SQL_CONVERT_NUMERIC             SqlSupportsConvert = 12
	SqlSupportsConvert_SQL_CONVERT_REAL                SqlSupportsConvert = 13
	SqlSupportsConvert_SQL_CONVERT_SMALLINT            SqlSupportsConvert = 14
	SqlSupportsConvert_SQL_CONVERT_TIME                SqlSupportsConvert = 15
	SqlSupportsConvert_SQL_CONVERT_TIMESTAMP           SqlSupportsConvert = 16
	SqlSupportsConvert_SQL_CONVERT_TINYINT             SqlSupportsConvert = 17
	SqlSupportsConvert_SQL_CONVERT_VARBINARY           SqlSupportsConvert = 18
	SqlSupportsConvert_SQL_CONVERT_VARCHAR             SqlSupportsConvert = 19
)

func (SqlSupportsConvert) Descriptor 

func (SqlSupportsConvert) Descriptor() protoreflect.EnumDescriptor

func (SqlSupportsConvert) Enum 

func (x SqlSupportsConvert) Enum() *SqlSupportsConvert

func (SqlSupportsConvert) EnumDescriptor deprecated 

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

Deprecated: Use SqlSupportsConvert.Descriptor instead.

func (SqlSupportsConvert) Number 

func (x SqlSupportsConvert) Number() protoreflect.EnumNumber

func (SqlSupportsConvert) String 

func (x SqlSupportsConvert) String() string

func (SqlSupportsConvert) Type 

func (SqlSupportsConvert) Type() protoreflect.EnumType

type SqlTransactionIsolationLevel 

type SqlTransactionIsolationLevel int32
const (
	SqlTransactionIsolationLevel_SQL_TRANSACTION_NONE             SqlTransactionIsolationLevel = 0
	SqlTransactionIsolationLevel_SQL_TRANSACTION_READ_UNCOMMITTED SqlTransactionIsolationLevel = 1
	SqlTransactionIsolationLevel_SQL_TRANSACTION_READ_COMMITTED   SqlTransactionIsolationLevel = 2
	SqlTransactionIsolationLevel_SQL_TRANSACTION_REPEATABLE_READ  SqlTransactionIsolationLevel = 3
	SqlTransactionIsolationLevel_SQL_TRANSACTION_SERIALIZABLE     SqlTransactionIsolationLevel = 4
)

func (SqlTransactionIsolationLevel) Descriptor 

func (SqlTransactionIsolationLevel) Descriptor() protoreflect.EnumDescriptor

func (SqlTransactionIsolationLevel) Enum 

func (x SqlTransactionIsolationLevel) Enum() *SqlTransactionIsolationLevel

func (SqlTransactionIsolationLevel) EnumDescriptor deprecated 

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

Deprecated: Use SqlTransactionIsolationLevel.Descriptor instead.

func (SqlTransactionIsolationLevel) Number 

func (x SqlTransactionIsolationLevel) Number() protoreflect.EnumNumber

func (SqlTransactionIsolationLevel) String 

func (x SqlTransactionIsolationLevel) String() string

func (SqlTransactionIsolationLevel) Type 

func (SqlTransactionIsolationLevel) Type() protoreflect.EnumType

type SubstraitPlan 

type SubstraitPlan struct {

	// The serialized substrait.Plan to create a prepared statement for.
	// XXX(ARROW-16902): this is bytes instead of an embedded message
	// because Protobuf does not really support one DLL using Protobuf
	// definitions from another DLL.
	Plan []byte `protobuf:"bytes,1,opt,name=plan,proto3" json:"plan,omitempty"`
	// The Substrait release, e.g. "0.12.0". This information is not
	// tracked in the plan itself, so this is the only way for consumers
	// to potentially know if they can handle the plan.
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

An embedded message describing a Substrait plan to execute.

func (*SubstraitPlan) Descriptor deprecated 

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

Deprecated: Use SubstraitPlan.ProtoReflect.Descriptor instead.

func (*SubstraitPlan) GetPlan 

func (x *SubstraitPlan) GetPlan() []byte

func (*SubstraitPlan) GetVersion 

func (x *SubstraitPlan) GetVersion() string

func (*SubstraitPlan) ProtoMessage 

func (*SubstraitPlan) ProtoMessage()

func (*SubstraitPlan) ProtoReflect 

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

func (*SubstraitPlan) Reset 

func (x *SubstraitPlan) Reset()

func (*SubstraitPlan) String 

func (x *SubstraitPlan) String() string

type SupportedAnsi92SqlGrammarLevel 

type SupportedAnsi92SqlGrammarLevel int32
const (
	SupportedAnsi92SqlGrammarLevel_ANSI92_ENTRY_SQL        SupportedAnsi92SqlGrammarLevel = 0
	SupportedAnsi92SqlGrammarLevel_ANSI92_INTERMEDIATE_SQL SupportedAnsi92SqlGrammarLevel = 1
	SupportedAnsi92SqlGrammarLevel_ANSI92_FULL_SQL         SupportedAnsi92SqlGrammarLevel = 2
)

func (SupportedAnsi92SqlGrammarLevel) Descriptor 

func (SupportedAnsi92SqlGrammarLevel) Descriptor() protoreflect.EnumDescriptor

func (SupportedAnsi92SqlGrammarLevel) Enum 

func (x SupportedAnsi92SqlGrammarLevel) Enum() *SupportedAnsi92SqlGrammarLevel

func (SupportedAnsi92SqlGrammarLevel) EnumDescriptor deprecated 

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

Deprecated: Use SupportedAnsi92SqlGrammarLevel.Descriptor instead.

func (SupportedAnsi92SqlGrammarLevel) Number 

func (x SupportedAnsi92SqlGrammarLevel) Number() protoreflect.EnumNumber

func (SupportedAnsi92SqlGrammarLevel) String 

func (x SupportedAnsi92SqlGrammarLevel) String() string

func (SupportedAnsi92SqlGrammarLevel) Type 

func (SupportedAnsi92SqlGrammarLevel) Type() protoreflect.EnumType

type SupportedSqlGrammar 

type SupportedSqlGrammar int32
const (
	SupportedSqlGrammar_SQL_MINIMUM_GRAMMAR  SupportedSqlGrammar = 0
	SupportedSqlGrammar_SQL_CORE_GRAMMAR     SupportedSqlGrammar = 1
	SupportedSqlGrammar_SQL_EXTENDED_GRAMMAR SupportedSqlGrammar = 2
)

func (SupportedSqlGrammar) Descriptor 

func (SupportedSqlGrammar) Descriptor() protoreflect.EnumDescriptor

func (SupportedSqlGrammar) Enum 

func (x SupportedSqlGrammar) Enum() *SupportedSqlGrammar

func (SupportedSqlGrammar) EnumDescriptor deprecated 

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

Deprecated: Use SupportedSqlGrammar.Descriptor instead.

func (SupportedSqlGrammar) Number 

func (x SupportedSqlGrammar) Number() protoreflect.EnumNumber

func (SupportedSqlGrammar) String 

func (x SupportedSqlGrammar) String() string

func (SupportedSqlGrammar) Type 

func (SupportedSqlGrammar) Type() protoreflect.EnumType

type Ticket 

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

An opaque identifier that the service can use to retrieve a particular portion of a stream.

Tickets are meant to be single use. It is an error/application-defined behavior to reuse a ticket.

func (*Ticket) Descriptor deprecated 

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

Deprecated: Use Ticket.ProtoReflect.Descriptor instead.

func (*Ticket) GetTicket 

func (x *Ticket) GetTicket() []byte

func (*Ticket) ProtoMessage 

func (*Ticket) ProtoMessage()

func (*Ticket) ProtoReflect 

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

func (*Ticket) Reset 

func (x *Ticket) Reset()

func (*Ticket) String 

func (x *Ticket) String() string

type TicketStatementQuery 

type TicketStatementQuery struct {

	// Unique identifier for the instance of the statement to execute.
	StatementHandle []byte `protobuf:"bytes,1,opt,name=statement_handle,json=statementHandle,proto3" json:"statement_handle,omitempty"`
	// contains filtered or unexported fields
}

* Represents a ticket resulting from GetFlightInfo with a CommandStatementQuery. This should be used only once and treated as an opaque value, that is, clients should not attempt to parse this.

func (*TicketStatementQuery) Descriptor deprecated 

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

Deprecated: Use TicketStatementQuery.ProtoReflect.Descriptor instead.

func (*TicketStatementQuery) GetStatementHandle 

func (x *TicketStatementQuery) GetStatementHandle() []byte

func (*TicketStatementQuery) ProtoMessage 

func (*TicketStatementQuery) ProtoMessage()

func (*TicketStatementQuery) ProtoReflect 

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

func (*TicketStatementQuery) Reset 

func (x *TicketStatementQuery) Reset()

func (*TicketStatementQuery) String 

func (x *TicketStatementQuery) String() string

type UnimplementedFlightServiceServer 

type UnimplementedFlightServiceServer struct {
}

UnimplementedFlightServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedFlightServiceServer) DoAction 

func (UnimplementedFlightServiceServer) DoAction(*Action, FlightService_DoActionServer) error

func (UnimplementedFlightServiceServer) DoExchange 

func (UnimplementedFlightServiceServer) DoExchange(FlightService_DoExchangeServer) error

func (UnimplementedFlightServiceServer) DoGet 

func (UnimplementedFlightServiceServer) DoGet(*Ticket, FlightService_DoGetServer) error

func (UnimplementedFlightServiceServer) DoPut 

func (UnimplementedFlightServiceServer) DoPut(FlightService_DoPutServer) error

func (UnimplementedFlightServiceServer) GetFlightInfo 

func (UnimplementedFlightServiceServer) GetFlightInfo(context.Context, *FlightDescriptor) (*FlightInfo, error)

func (UnimplementedFlightServiceServer) GetSchema 

func (UnimplementedFlightServiceServer) GetSchema(context.Context, *FlightDescriptor) (*SchemaResult, error)

func (UnimplementedFlightServiceServer) Handshake 

func (UnimplementedFlightServiceServer) Handshake(FlightService_HandshakeServer) error

func (UnimplementedFlightServiceServer) ListActions 

func (UnimplementedFlightServiceServer) ListActions(*Empty, FlightService_ListActionsServer) error

func (UnimplementedFlightServiceServer) ListFlights 

func (UnimplementedFlightServiceServer) ListFlights(*Criteria, FlightService_ListFlightsServer) error

func (UnimplementedFlightServiceServer) PollFlightInfo 

func (UnimplementedFlightServiceServer) PollFlightInfo(context.Context, *FlightDescriptor) (*PollInfo, error)

type UnsafeFlightServiceServer 

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

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

type UpdateDeleteRules 

type UpdateDeleteRules int32
const (
	UpdateDeleteRules_CASCADE     UpdateDeleteRules = 0
	UpdateDeleteRules_RESTRICT    UpdateDeleteRules = 1
	UpdateDeleteRules_SET_NULL    UpdateDeleteRules = 2
	UpdateDeleteRules_NO_ACTION   UpdateDeleteRules = 3
	UpdateDeleteRules_SET_DEFAULT UpdateDeleteRules = 4
)

func (UpdateDeleteRules) Descriptor 

func (UpdateDeleteRules) Descriptor() protoreflect.EnumDescriptor

func (UpdateDeleteRules) Enum 

func (x UpdateDeleteRules) Enum() *UpdateDeleteRules

func (UpdateDeleteRules) EnumDescriptor deprecated 

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

Deprecated: Use UpdateDeleteRules.Descriptor instead.

func (UpdateDeleteRules) Number 

func (x UpdateDeleteRules) Number() protoreflect.EnumNumber

func (UpdateDeleteRules) String 

func (x UpdateDeleteRules) String() string

func (UpdateDeleteRules) Type 

func (UpdateDeleteRules) Type() protoreflect.EnumType

type XdbcDataType 

type XdbcDataType int32

* The JDBC/ODBC-defined type of any object. All the values here are the same as in the JDBC and ODBC specs. 

const (
	XdbcDataType_XDBC_UNKNOWN_TYPE  XdbcDataType = 0
	XdbcDataType_XDBC_CHAR          XdbcDataType = 1
	XdbcDataType_XDBC_NUMERIC       XdbcDataType = 2
	XdbcDataType_XDBC_DECIMAL       XdbcDataType = 3
	XdbcDataType_XDBC_INTEGER       XdbcDataType = 4
	XdbcDataType_XDBC_SMALLINT      XdbcDataType = 5
	XdbcDataType_XDBC_FLOAT         XdbcDataType = 6
	XdbcDataType_XDBC_REAL          XdbcDataType = 7
	XdbcDataType_XDBC_DOUBLE        XdbcDataType = 8
	XdbcDataType_XDBC_DATETIME      XdbcDataType = 9
	XdbcDataType_XDBC_INTERVAL      XdbcDataType = 10
	XdbcDataType_XDBC_VARCHAR       XdbcDataType = 12
	XdbcDataType_XDBC_DATE          XdbcDataType = 91
	XdbcDataType_XDBC_TIME          XdbcDataType = 92
	XdbcDataType_XDBC_TIMESTAMP     XdbcDataType = 93
	XdbcDataType_XDBC_LONGVARCHAR   XdbcDataType = -1
	XdbcDataType_XDBC_BINARY        XdbcDataType = -2
	XdbcDataType_XDBC_VARBINARY     XdbcDataType = -3
	XdbcDataType_XDBC_LONGVARBINARY XdbcDataType = -4
	XdbcDataType_XDBC_BIGINT        XdbcDataType = -5
	XdbcDataType_XDBC_TINYINT       XdbcDataType = -6
	XdbcDataType_XDBC_BIT           XdbcDataType = -7
	XdbcDataType_XDBC_WCHAR         XdbcDataType = -8
	XdbcDataType_XDBC_WVARCHAR      XdbcDataType = -9
)

func (XdbcDataType) Descriptor 

func (XdbcDataType) Descriptor() protoreflect.EnumDescriptor

func (XdbcDataType) Enum 

func (x XdbcDataType) Enum() *XdbcDataType

func (XdbcDataType) EnumDescriptor deprecated 

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

Deprecated: Use XdbcDataType.Descriptor instead.

func (XdbcDataType) Number 

func (x XdbcDataType) Number() protoreflect.EnumNumber

func (XdbcDataType) String 

func (x XdbcDataType) String() string

func (XdbcDataType) Type 

func (XdbcDataType) Type() protoreflect.EnumType

type XdbcDatetimeSubcode 

type XdbcDatetimeSubcode int32

* Detailed subtype information for XDBC_TYPE_DATETIME and XDBC_TYPE_INTERVAL. 

const (
	XdbcDatetimeSubcode_XDBC_SUBCODE_UNKNOWN                   XdbcDatetimeSubcode = 0
	XdbcDatetimeSubcode_XDBC_SUBCODE_YEAR                      XdbcDatetimeSubcode = 1
	XdbcDatetimeSubcode_XDBC_SUBCODE_DATE                      XdbcDatetimeSubcode = 1
	XdbcDatetimeSubcode_XDBC_SUBCODE_TIME                      XdbcDatetimeSubcode = 2
	XdbcDatetimeSubcode_XDBC_SUBCODE_MONTH                     XdbcDatetimeSubcode = 2
	XdbcDatetimeSubcode_XDBC_SUBCODE_TIMESTAMP                 XdbcDatetimeSubcode = 3
	XdbcDatetimeSubcode_XDBC_SUBCODE_DAY                       XdbcDatetimeSubcode = 3
	XdbcDatetimeSubcode_XDBC_SUBCODE_TIME_WITH_TIMEZONE        XdbcDatetimeSubcode = 4
	XdbcDatetimeSubcode_XDBC_SUBCODE_HOUR                      XdbcDatetimeSubcode = 4
	XdbcDatetimeSubcode_XDBC_SUBCODE_TIMESTAMP_WITH_TIMEZONE   XdbcDatetimeSubcode = 5
	XdbcDatetimeSubcode_XDBC_SUBCODE_MINUTE                    XdbcDatetimeSubcode = 5
	XdbcDatetimeSubcode_XDBC_SUBCODE_SECOND                    XdbcDatetimeSubcode = 6
	XdbcDatetimeSubcode_XDBC_SUBCODE_YEAR_TO_MONTH             XdbcDatetimeSubcode = 7
	XdbcDatetimeSubcode_XDBC_SUBCODE_DAY_TO_HOUR               XdbcDatetimeSubcode = 8
	XdbcDatetimeSubcode_XDBC_SUBCODE_DAY_TO_MINUTE             XdbcDatetimeSubcode = 9
	XdbcDatetimeSubcode_XDBC_SUBCODE_DAY_TO_SECOND             XdbcDatetimeSubcode = 10
	XdbcDatetimeSubcode_XDBC_SUBCODE_HOUR_TO_MINUTE            XdbcDatetimeSubcode = 11
	XdbcDatetimeSubcode_XDBC_SUBCODE_HOUR_TO_SECOND            XdbcDatetimeSubcode = 12
	XdbcDatetimeSubcode_XDBC_SUBCODE_MINUTE_TO_SECOND          XdbcDatetimeSubcode = 13
	XdbcDatetimeSubcode_XDBC_SUBCODE_INTERVAL_YEAR             XdbcDatetimeSubcode = 101
	XdbcDatetimeSubcode_XDBC_SUBCODE_INTERVAL_MONTH            XdbcDatetimeSubcode = 102
	XdbcDatetimeSubcode_XDBC_SUBCODE_INTERVAL_DAY              XdbcDatetimeSubcode = 103
	XdbcDatetimeSubcode_XDBC_SUBCODE_INTERVAL_HOUR             XdbcDatetimeSubcode = 104
	XdbcDatetimeSubcode_XDBC_SUBCODE_INTERVAL_MINUTE           XdbcDatetimeSubcode = 105
	XdbcDatetimeSubcode_XDBC_SUBCODE_INTERVAL_SECOND           XdbcDatetimeSubcode = 106
	XdbcDatetimeSubcode_XDBC_SUBCODE_INTERVAL_YEAR_TO_MONTH    XdbcDatetimeSubcode = 107
	XdbcDatetimeSubcode_XDBC_SUBCODE_INTERVAL_DAY_TO_HOUR      XdbcDatetimeSubcode = 108
	XdbcDatetimeSubcode_XDBC_SUBCODE_INTERVAL_DAY_TO_MINUTE    XdbcDatetimeSubcode = 109
	XdbcDatetimeSubcode_XDBC_SUBCODE_INTERVAL_DAY_TO_SECOND    XdbcDatetimeSubcode = 110
	XdbcDatetimeSubcode_XDBC_SUBCODE_INTERVAL_HOUR_TO_MINUTE   XdbcDatetimeSubcode = 111
	XdbcDatetimeSubcode_XDBC_SUBCODE_INTERVAL_HOUR_TO_SECOND   XdbcDatetimeSubcode = 112
	XdbcDatetimeSubcode_XDBC_SUBCODE_INTERVAL_MINUTE_TO_SECOND XdbcDatetimeSubcode = 113
)

func (XdbcDatetimeSubcode) Descriptor 

func (XdbcDatetimeSubcode) Descriptor() protoreflect.EnumDescriptor

func (XdbcDatetimeSubcode) Enum 

func (x XdbcDatetimeSubcode) Enum() *XdbcDatetimeSubcode

func (XdbcDatetimeSubcode) EnumDescriptor deprecated 

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

Deprecated: Use XdbcDatetimeSubcode.Descriptor instead.

func (XdbcDatetimeSubcode) Number 

func (x XdbcDatetimeSubcode) Number() protoreflect.EnumNumber

func (XdbcDatetimeSubcode) String 

func (x XdbcDatetimeSubcode) String() string

func (XdbcDatetimeSubcode) Type 

func (XdbcDatetimeSubcode) 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.