Ydb_FederatedQuery

package
v0.0.0-...-8dd88c8 Latest Latest
Warning

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

Go to latest
Published: Mar 9, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ExecuteMode_name = map[int32]string{
		0: "EXECUTE_MODE_UNSPECIFIED",
		1: "SAVE",
		2: "PARSE",
		3: "COMPILE",
		4: "VALIDATE",
		5: "EXPLAIN",
		6: "RUN",
	}
	ExecuteMode_value = map[string]int32{
		"EXECUTE_MODE_UNSPECIFIED": 0,
		"SAVE":                     1,
		"PARSE":                    2,
		"COMPILE":                  3,
		"VALIDATE":                 4,
		"EXPLAIN":                  5,
		"RUN":                      6,
	}
)

Enum value maps for ExecuteMode.

View Source
var (
	QueryAction_name = map[int32]string{
		0: "QUERY_ACTION_UNSPECIFIED",
		1: "PAUSE",
		2: "PAUSE_GRACEFULLY",
		3: "ABORT",
		4: "ABORT_GRACEFULLY",
		5: "RESUME",
	}
	QueryAction_value = map[string]int32{
		"QUERY_ACTION_UNSPECIFIED": 0,
		"PAUSE":                    1,
		"PAUSE_GRACEFULLY":         2,
		"ABORT":                    3,
		"ABORT_GRACEFULLY":         4,
		"RESUME":                   5,
	}
)

Enum value maps for QueryAction.

View Source
var (
	StateLoadMode_name = map[int32]string{
		0: "STATE_LOAD_MODE_UNSPECIFIED",
		1: "EMPTY",
		2: "FROM_LAST_CHECKPOINT",
	}
	StateLoadMode_value = map[string]int32{
		"STATE_LOAD_MODE_UNSPECIFIED": 0,
		"EMPTY":                       1,
		"FROM_LAST_CHECKPOINT":        2,
	}
)

Enum value maps for StateLoadMode.

View Source
var (
	AutomaticType_name = map[int32]string{
		0: "AUTOMATIC_TYPE_UNSPECIFIED",
		1: "AUTOMATIC",
		2: "NOT_AUTOMATIC",
	}
	AutomaticType_value = map[string]int32{
		"AUTOMATIC_TYPE_UNSPECIFIED": 0,
		"AUTOMATIC":                  1,
		"NOT_AUTOMATIC":              2,
	}
)

Enum value maps for AutomaticType.

View Source
var (
	Acl_Visibility_name = map[int32]string{
		0: "VISIBILITY_UNSPECIFIED",
		1: "PRIVATE",
		2: "SCOPE",
	}
	Acl_Visibility_value = map[string]int32{
		"VISIBILITY_UNSPECIFIED": 0,
		"PRIVATE":                1,
		"SCOPE":                  2,
	}
)

Enum value maps for Acl_Visibility.

View Source
var (
	QueryContent_QueryType_name = map[int32]string{
		0: "QUERY_TYPE_UNSPECIFIED",
		1: "ANALYTICS",
		2: "STREAMING",
	}
	QueryContent_QueryType_value = map[string]int32{
		"QUERY_TYPE_UNSPECIFIED": 0,
		"ANALYTICS":              1,
		"STREAMING":              2,
	}
)

Enum value maps for QueryContent_QueryType.

View Source
var (
	QueryContent_QuerySyntax_name = map[int32]string{
		0: "QUERY_SYNTAX_UNSPECIFIED",
		1: "YQL_V1",
		2: "PG",
	}
	QueryContent_QuerySyntax_value = map[string]int32{
		"QUERY_SYNTAX_UNSPECIFIED": 0,
		"YQL_V1":                   1,
		"PG":                       2,
	}
)

Enum value maps for QueryContent_QuerySyntax.

View Source
var (
	QueryMeta_ComputeStatus_name = map[int32]string{
		0:  "COMPUTE_STATUS_UNSPECIFIED",
		1:  "STARTING",
		2:  "ABORTED_BY_USER",
		3:  "ABORTED_BY_SYSTEM",
		4:  "ABORTING_BY_USER",
		5:  "ABORTING_BY_SYSTEM",
		6:  "RESUMING",
		7:  "RUNNING",
		8:  "COMPLETED",
		12: "COMPLETING",
		9:  "FAILED",
		13: "FAILING",
		11: "PAUSED",
		10: "PAUSING",
	}
	QueryMeta_ComputeStatus_value = map[string]int32{
		"COMPUTE_STATUS_UNSPECIFIED": 0,
		"STARTING":                   1,
		"ABORTED_BY_USER":            2,
		"ABORTED_BY_SYSTEM":          3,
		"ABORTING_BY_USER":           4,
		"ABORTING_BY_SYSTEM":         5,
		"RESUMING":                   6,
		"RUNNING":                    7,
		"COMPLETED":                  8,
		"COMPLETING":                 12,
		"FAILED":                     9,
		"FAILING":                    13,
		"PAUSED":                     11,
		"PAUSING":                    10,
	}
)

Enum value maps for QueryMeta_ComputeStatus.

View Source
var (
	ConnectionSetting_ConnectionType_name = map[int32]string{
		0: "CONNECTION_TYPE_UNSPECIFIED",
		1: "YDB_DATABASE",
		2: "CLICKHOUSE_CLUSTER",
		3: "DATA_STREAMS",
		4: "OBJECT_STORAGE",
		5: "MONITORING",
		6: "POSTGRESQL_CLUSTER",
	}
	ConnectionSetting_ConnectionType_value = map[string]int32{
		"CONNECTION_TYPE_UNSPECIFIED": 0,
		"YDB_DATABASE":                1,
		"CLICKHOUSE_CLUSTER":          2,
		"DATA_STREAMS":                3,
		"OBJECT_STORAGE":              4,
		"MONITORING":                  5,
		"POSTGRESQL_CLUSTER":          6,
	}
)

Enum value maps for ConnectionSetting_ConnectionType.

View Source
var (
	BindingSetting_BindingType_name = map[int32]string{
		0: "BINDING_TYPE_UNSPECIFIED",
		1: "DATA_STREAMS",
		2: "OBJECT_STORAGE",
	}
	BindingSetting_BindingType_value = map[string]int32{
		"BINDING_TYPE_UNSPECIFIED": 0,
		"DATA_STREAMS":             1,
		"OBJECT_STORAGE":           2,
	}
)

Enum value maps for BindingSetting_BindingType.

View Source
var File_draft_protos_ydb_federated_query_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Acl

type Acl struct {
	Visibility Acl_Visibility `protobuf:"varint,1,opt,name=visibility,proto3,enum=FederatedQuery.Acl_Visibility" json:"visibility,omitempty"`
	// contains filtered or unexported fields
}

func (*Acl) Descriptor deprecated

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

Deprecated: Use Acl.ProtoReflect.Descriptor instead.

func (*Acl) GetVisibility

func (x *Acl) GetVisibility() Acl_Visibility

func (*Acl) ProtoMessage

func (*Acl) ProtoMessage()

func (*Acl) ProtoReflect

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

func (*Acl) Reset

func (x *Acl) Reset()

func (*Acl) String

func (x *Acl) String() string

type Acl_Visibility

type Acl_Visibility int32
const (
	Acl_VISIBILITY_UNSPECIFIED Acl_Visibility = 0
	Acl_PRIVATE                Acl_Visibility = 1 // Visibility only for the creator of the entity
	Acl_SCOPE                  Acl_Visibility = 2 // Visibility for subjects within scope
)

func (Acl_Visibility) Descriptor

func (Acl_Visibility) Enum

func (x Acl_Visibility) Enum() *Acl_Visibility

func (Acl_Visibility) EnumDescriptor deprecated

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

Deprecated: Use Acl_Visibility.Descriptor instead.

func (Acl_Visibility) Number

func (Acl_Visibility) String

func (x Acl_Visibility) String() string

func (Acl_Visibility) Type

type AutomaticType

type AutomaticType int32
const (
	AutomaticType_AUTOMATIC_TYPE_UNSPECIFIED AutomaticType = 0
	AutomaticType_AUTOMATIC                  AutomaticType = 1
	AutomaticType_NOT_AUTOMATIC              AutomaticType = 2
)

func (AutomaticType) Descriptor

func (AutomaticType) Enum

func (x AutomaticType) Enum() *AutomaticType

func (AutomaticType) EnumDescriptor deprecated

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

Deprecated: Use AutomaticType.Descriptor instead.

func (AutomaticType) Number

func (AutomaticType) String

func (x AutomaticType) String() string

func (AutomaticType) Type

type Binding

type Binding struct {
	Content *BindingContent `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
	Meta    *CommonMeta     `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

func (*Binding) Descriptor deprecated

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

Deprecated: Use Binding.ProtoReflect.Descriptor instead.

func (*Binding) GetContent

func (x *Binding) GetContent() *BindingContent

func (*Binding) GetMeta

func (x *Binding) GetMeta() *CommonMeta

func (*Binding) ProtoMessage

func (*Binding) ProtoMessage()

func (*Binding) ProtoReflect

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

func (*Binding) Reset

func (x *Binding) Reset()

func (*Binding) String

func (x *Binding) String() string

type BindingContent

type BindingContent struct {
	Name         string          `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ConnectionId string          `protobuf:"bytes,2,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	Setting      *BindingSetting `protobuf:"bytes,3,opt,name=setting,proto3" json:"setting,omitempty"`
	Acl          *Acl            `protobuf:"bytes,4,opt,name=acl,proto3" json:"acl,omitempty"`
	Description  string          `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*BindingContent) Descriptor deprecated

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

Deprecated: Use BindingContent.ProtoReflect.Descriptor instead.

func (*BindingContent) GetAcl

func (x *BindingContent) GetAcl() *Acl

func (*BindingContent) GetConnectionId

func (x *BindingContent) GetConnectionId() string

func (*BindingContent) GetDescription

func (x *BindingContent) GetDescription() string

func (*BindingContent) GetName

func (x *BindingContent) GetName() string

func (*BindingContent) GetSetting

func (x *BindingContent) GetSetting() *BindingSetting

func (*BindingContent) ProtoMessage

func (*BindingContent) ProtoMessage()

func (*BindingContent) ProtoReflect

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

func (*BindingContent) Reset

func (x *BindingContent) Reset()

func (*BindingContent) String

func (x *BindingContent) String() string

type BindingSetting

type BindingSetting struct {

	// Types that are assignable to Binding:
	//
	//	*BindingSetting_DataStreams
	//	*BindingSetting_ObjectStorage
	Binding isBindingSetting_Binding `protobuf_oneof:"binding"`
	// contains filtered or unexported fields
}

func (*BindingSetting) Descriptor deprecated

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

Deprecated: Use BindingSetting.ProtoReflect.Descriptor instead.

func (*BindingSetting) GetBinding

func (m *BindingSetting) GetBinding() isBindingSetting_Binding

func (*BindingSetting) GetDataStreams

func (x *BindingSetting) GetDataStreams() *DataStreamsBinding

func (*BindingSetting) GetObjectStorage

func (x *BindingSetting) GetObjectStorage() *ObjectStorageBinding

func (*BindingSetting) ProtoMessage

func (*BindingSetting) ProtoMessage()

func (*BindingSetting) ProtoReflect

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

func (*BindingSetting) Reset

func (x *BindingSetting) Reset()

func (*BindingSetting) String

func (x *BindingSetting) String() string

type BindingSetting_BindingType

type BindingSetting_BindingType int32
const (
	BindingSetting_BINDING_TYPE_UNSPECIFIED BindingSetting_BindingType = 0
	BindingSetting_DATA_STREAMS             BindingSetting_BindingType = 1
	BindingSetting_OBJECT_STORAGE           BindingSetting_BindingType = 2
)

func (BindingSetting_BindingType) Descriptor

func (BindingSetting_BindingType) Enum

func (BindingSetting_BindingType) EnumDescriptor deprecated

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

Deprecated: Use BindingSetting_BindingType.Descriptor instead.

func (BindingSetting_BindingType) Number

func (BindingSetting_BindingType) String

func (BindingSetting_BindingType) Type

type BindingSetting_DataStreams

type BindingSetting_DataStreams struct {
	DataStreams *DataStreamsBinding `protobuf:"bytes,1,opt,name=data_streams,json=dataStreams,proto3,oneof"`
}

type BindingSetting_ObjectStorage

type BindingSetting_ObjectStorage struct {
	ObjectStorage *ObjectStorageBinding `protobuf:"bytes,2,opt,name=object_storage,json=objectStorage,proto3,oneof"`
}

type BriefBinding

type BriefBinding struct {
	Name         string                     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ConnectionId string                     `protobuf:"bytes,2,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	Meta         *CommonMeta                `protobuf:"bytes,3,opt,name=meta,proto3" json:"meta,omitempty"`
	Type         BindingSetting_BindingType `protobuf:"varint,4,opt,name=type,proto3,enum=FederatedQuery.BindingSetting_BindingType" json:"type,omitempty"`
	Visibility   Acl_Visibility             `protobuf:"varint,5,opt,name=visibility,proto3,enum=FederatedQuery.Acl_Visibility" json:"visibility,omitempty"`
	// contains filtered or unexported fields
}

func (*BriefBinding) Descriptor deprecated

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

Deprecated: Use BriefBinding.ProtoReflect.Descriptor instead.

func (*BriefBinding) GetConnectionId

func (x *BriefBinding) GetConnectionId() string

func (*BriefBinding) GetMeta

func (x *BriefBinding) GetMeta() *CommonMeta

func (*BriefBinding) GetName

func (x *BriefBinding) GetName() string

func (*BriefBinding) GetType

func (*BriefBinding) GetVisibility

func (x *BriefBinding) GetVisibility() Acl_Visibility

func (*BriefBinding) ProtoMessage

func (*BriefBinding) ProtoMessage()

func (*BriefBinding) ProtoReflect

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

func (*BriefBinding) Reset

func (x *BriefBinding) Reset()

func (*BriefBinding) String

func (x *BriefBinding) String() string

type BriefJob

type BriefJob struct {
	Meta       *CommonMeta            `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	QueryMeta  *QueryMeta             `protobuf:"bytes,3,opt,name=query_meta,json=queryMeta,proto3" json:"query_meta,omitempty"`
	QueryName  string                 `protobuf:"bytes,9,opt,name=query_name,json=queryName,proto3" json:"query_name,omitempty"`
	Visibility Acl_Visibility         `protobuf:"varint,10,opt,name=visibility,proto3,enum=FederatedQuery.Acl_Visibility" json:"visibility,omitempty"`
	Automatic  bool                   `protobuf:"varint,11,opt,name=automatic,proto3" json:"automatic,omitempty"`
	ExpireAt   *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=expire_at,json=expireAt,proto3" json:"expire_at,omitempty"`
	// contains filtered or unexported fields
}

func (*BriefJob) Descriptor deprecated

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

Deprecated: Use BriefJob.ProtoReflect.Descriptor instead.

func (*BriefJob) GetAutomatic

func (x *BriefJob) GetAutomatic() bool

func (*BriefJob) GetExpireAt

func (x *BriefJob) GetExpireAt() *timestamppb.Timestamp

func (*BriefJob) GetMeta

func (x *BriefJob) GetMeta() *CommonMeta

func (*BriefJob) GetQueryMeta

func (x *BriefJob) GetQueryMeta() *QueryMeta

func (*BriefJob) GetQueryName

func (x *BriefJob) GetQueryName() string

func (*BriefJob) GetVisibility

func (x *BriefJob) GetVisibility() Acl_Visibility

func (*BriefJob) ProtoMessage

func (*BriefJob) ProtoMessage()

func (*BriefJob) ProtoReflect

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

func (*BriefJob) Reset

func (x *BriefJob) Reset()

func (*BriefJob) String

func (x *BriefJob) String() string

type BriefQuery

type BriefQuery struct {
	Type       QueryContent_QueryType `protobuf:"varint,1,opt,name=type,proto3,enum=FederatedQuery.QueryContent_QueryType" json:"type,omitempty"`
	Name       string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Meta       *QueryMeta             `protobuf:"bytes,3,opt,name=meta,proto3" json:"meta,omitempty"`
	Visibility Acl_Visibility         `protobuf:"varint,4,opt,name=visibility,proto3,enum=FederatedQuery.Acl_Visibility" json:"visibility,omitempty"`
	Automatic  bool                   `protobuf:"varint,5,opt,name=automatic,proto3" json:"automatic,omitempty"`
	// contains filtered or unexported fields
}

func (*BriefQuery) Descriptor deprecated

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

Deprecated: Use BriefQuery.ProtoReflect.Descriptor instead.

func (*BriefQuery) GetAutomatic

func (x *BriefQuery) GetAutomatic() bool

func (*BriefQuery) GetMeta

func (x *BriefQuery) GetMeta() *QueryMeta

func (*BriefQuery) GetName

func (x *BriefQuery) GetName() string

func (*BriefQuery) GetType

func (x *BriefQuery) GetType() QueryContent_QueryType

func (*BriefQuery) GetVisibility

func (x *BriefQuery) GetVisibility() Acl_Visibility

func (*BriefQuery) ProtoMessage

func (*BriefQuery) ProtoMessage()

func (*BriefQuery) ProtoReflect

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

func (*BriefQuery) Reset

func (x *BriefQuery) Reset()

func (*BriefQuery) String

func (x *BriefQuery) String() string

type ClickHouseCluster

type ClickHouseCluster struct {
	DatabaseId   string   `protobuf:"bytes,1,opt,name=database_id,json=databaseId,proto3" json:"database_id,omitempty"`
	DatabaseName string   `protobuf:"bytes,8,opt,name=database_name,json=databaseName,proto3" json:"database_name,omitempty"`
	Login        string   `protobuf:"bytes,2,opt,name=login,proto3" json:"login,omitempty"`
	Password     string   `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"`
	Auth         *IamAuth `protobuf:"bytes,4,opt,name=auth,proto3" json:"auth,omitempty"`
	// for internal usage
	Host   string `protobuf:"bytes,5,opt,name=host,proto3" json:"host,omitempty"`
	Port   int32  `protobuf:"varint,6,opt,name=port,proto3" json:"port,omitempty"`
	Secure bool   `protobuf:"varint,7,opt,name=secure,proto3" json:"secure,omitempty"`
	// contains filtered or unexported fields
}

func (*ClickHouseCluster) Descriptor deprecated

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

Deprecated: Use ClickHouseCluster.ProtoReflect.Descriptor instead.

func (*ClickHouseCluster) GetAuth

func (x *ClickHouseCluster) GetAuth() *IamAuth

func (*ClickHouseCluster) GetDatabaseId

func (x *ClickHouseCluster) GetDatabaseId() string

func (*ClickHouseCluster) GetDatabaseName

func (x *ClickHouseCluster) GetDatabaseName() string

func (*ClickHouseCluster) GetHost

func (x *ClickHouseCluster) GetHost() string

func (*ClickHouseCluster) GetLogin

func (x *ClickHouseCluster) GetLogin() string

func (*ClickHouseCluster) GetPassword

func (x *ClickHouseCluster) GetPassword() string

func (*ClickHouseCluster) GetPort

func (x *ClickHouseCluster) GetPort() int32

func (*ClickHouseCluster) GetSecure

func (x *ClickHouseCluster) GetSecure() bool

func (*ClickHouseCluster) ProtoMessage

func (*ClickHouseCluster) ProtoMessage()

func (*ClickHouseCluster) ProtoReflect

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

func (*ClickHouseCluster) Reset

func (x *ClickHouseCluster) Reset()

func (*ClickHouseCluster) String

func (x *ClickHouseCluster) String() string

type CommonMeta

type CommonMeta struct {
	Id         string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	CreatedBy  string                 `protobuf:"bytes,2,opt,name=created_by,json=createdBy,proto3" json:"created_by,omitempty"`
	ModifiedBy string                 `protobuf:"bytes,3,opt,name=modified_by,json=modifiedBy,proto3" json:"modified_by,omitempty"`
	CreatedAt  *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	ModifiedAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=modified_at,json=modifiedAt,proto3" json:"modified_at,omitempty"`
	Revision   int64                  `protobuf:"varint,6,opt,name=revision,proto3" json:"revision,omitempty"` // Entity version, increases with each change
	// contains filtered or unexported fields
}

func (*CommonMeta) Descriptor deprecated

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

Deprecated: Use CommonMeta.ProtoReflect.Descriptor instead.

func (*CommonMeta) GetCreatedAt

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

func (*CommonMeta) GetCreatedBy

func (x *CommonMeta) GetCreatedBy() string

func (*CommonMeta) GetId

func (x *CommonMeta) GetId() string

func (*CommonMeta) GetModifiedAt

func (x *CommonMeta) GetModifiedAt() *timestamppb.Timestamp

func (*CommonMeta) GetModifiedBy

func (x *CommonMeta) GetModifiedBy() string

func (*CommonMeta) GetRevision

func (x *CommonMeta) GetRevision() int64

func (*CommonMeta) ProtoMessage

func (*CommonMeta) ProtoMessage()

func (*CommonMeta) ProtoReflect

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

func (*CommonMeta) Reset

func (x *CommonMeta) Reset()

func (*CommonMeta) String

func (x *CommonMeta) String() string

type Connection

type Connection struct {
	Content *ConnectionContent `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
	Meta    *CommonMeta        `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

func (*Connection) Descriptor deprecated

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

Deprecated: Use Connection.ProtoReflect.Descriptor instead.

func (*Connection) GetContent

func (x *Connection) GetContent() *ConnectionContent

func (*Connection) GetMeta

func (x *Connection) GetMeta() *CommonMeta

func (*Connection) ProtoMessage

func (*Connection) ProtoMessage()

func (*Connection) ProtoReflect

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

func (*Connection) Reset

func (x *Connection) Reset()

func (*Connection) String

func (x *Connection) String() string

type ConnectionContent

type ConnectionContent struct {
	Name        string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Setting     *ConnectionSetting `protobuf:"bytes,2,opt,name=setting,proto3" json:"setting,omitempty"`
	Acl         *Acl               `protobuf:"bytes,3,opt,name=acl,proto3" json:"acl,omitempty"`
	Description string             `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectionContent) Descriptor deprecated

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

Deprecated: Use ConnectionContent.ProtoReflect.Descriptor instead.

func (*ConnectionContent) GetAcl

func (x *ConnectionContent) GetAcl() *Acl

func (*ConnectionContent) GetDescription

func (x *ConnectionContent) GetDescription() string

func (*ConnectionContent) GetName

func (x *ConnectionContent) GetName() string

func (*ConnectionContent) GetSetting

func (x *ConnectionContent) GetSetting() *ConnectionSetting

func (*ConnectionContent) ProtoMessage

func (*ConnectionContent) ProtoMessage()

func (*ConnectionContent) ProtoReflect

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

func (*ConnectionContent) Reset

func (x *ConnectionContent) Reset()

func (*ConnectionContent) String

func (x *ConnectionContent) String() string

type ConnectionSetting

type ConnectionSetting struct {

	// Types that are assignable to Connection:
	//
	//	*ConnectionSetting_YdbDatabase
	//	*ConnectionSetting_ClickhouseCluster
	//	*ConnectionSetting_DataStreams
	//	*ConnectionSetting_ObjectStorage
	//	*ConnectionSetting_Monitoring
	//	*ConnectionSetting_PostgresqlCluster
	Connection isConnectionSetting_Connection `protobuf_oneof:"connection"`
	// contains filtered or unexported fields
}

func (*ConnectionSetting) Descriptor deprecated

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

Deprecated: Use ConnectionSetting.ProtoReflect.Descriptor instead.

func (*ConnectionSetting) GetClickhouseCluster

func (x *ConnectionSetting) GetClickhouseCluster() *ClickHouseCluster

func (*ConnectionSetting) GetConnection

func (m *ConnectionSetting) GetConnection() isConnectionSetting_Connection

func (*ConnectionSetting) GetDataStreams

func (x *ConnectionSetting) GetDataStreams() *DataStreams

func (*ConnectionSetting) GetMonitoring

func (x *ConnectionSetting) GetMonitoring() *Monitoring

func (*ConnectionSetting) GetObjectStorage

func (x *ConnectionSetting) GetObjectStorage() *ObjectStorageConnection

func (*ConnectionSetting) GetPostgresqlCluster

func (x *ConnectionSetting) GetPostgresqlCluster() *PostgreSQLCluster

func (*ConnectionSetting) GetYdbDatabase

func (x *ConnectionSetting) GetYdbDatabase() *YdbDatabase

func (*ConnectionSetting) ProtoMessage

func (*ConnectionSetting) ProtoMessage()

func (*ConnectionSetting) ProtoReflect

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

func (*ConnectionSetting) Reset

func (x *ConnectionSetting) Reset()

func (*ConnectionSetting) String

func (x *ConnectionSetting) String() string

type ConnectionSetting_ClickhouseCluster

type ConnectionSetting_ClickhouseCluster struct {
	ClickhouseCluster *ClickHouseCluster `protobuf:"bytes,2,opt,name=clickhouse_cluster,json=clickhouseCluster,proto3,oneof"`
}

type ConnectionSetting_ConnectionType

type ConnectionSetting_ConnectionType int32
const (
	ConnectionSetting_CONNECTION_TYPE_UNSPECIFIED ConnectionSetting_ConnectionType = 0
	ConnectionSetting_YDB_DATABASE                ConnectionSetting_ConnectionType = 1
	ConnectionSetting_CLICKHOUSE_CLUSTER          ConnectionSetting_ConnectionType = 2
	ConnectionSetting_DATA_STREAMS                ConnectionSetting_ConnectionType = 3
	ConnectionSetting_OBJECT_STORAGE              ConnectionSetting_ConnectionType = 4
	ConnectionSetting_MONITORING                  ConnectionSetting_ConnectionType = 5
	ConnectionSetting_POSTGRESQL_CLUSTER          ConnectionSetting_ConnectionType = 6
)

func (ConnectionSetting_ConnectionType) Descriptor

func (ConnectionSetting_ConnectionType) Enum

func (ConnectionSetting_ConnectionType) EnumDescriptor deprecated

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

Deprecated: Use ConnectionSetting_ConnectionType.Descriptor instead.

func (ConnectionSetting_ConnectionType) Number

func (ConnectionSetting_ConnectionType) String

func (ConnectionSetting_ConnectionType) Type

type ConnectionSetting_DataStreams

type ConnectionSetting_DataStreams struct {
	DataStreams *DataStreams `protobuf:"bytes,3,opt,name=data_streams,json=dataStreams,proto3,oneof"`
}

type ConnectionSetting_Monitoring

type ConnectionSetting_Monitoring struct {
	Monitoring *Monitoring `protobuf:"bytes,5,opt,name=monitoring,proto3,oneof"`
}

type ConnectionSetting_ObjectStorage

type ConnectionSetting_ObjectStorage struct {
	ObjectStorage *ObjectStorageConnection `protobuf:"bytes,4,opt,name=object_storage,json=objectStorage,proto3,oneof"`
}

type ConnectionSetting_PostgresqlCluster

type ConnectionSetting_PostgresqlCluster struct {
	PostgresqlCluster *PostgreSQLCluster `protobuf:"bytes,6,opt,name=postgresql_cluster,json=postgresqlCluster,proto3,oneof"`
}

type ConnectionSetting_YdbDatabase

type ConnectionSetting_YdbDatabase struct {
	YdbDatabase *YdbDatabase `protobuf:"bytes,1,opt,name=ydb_database,json=ydbDatabase,proto3,oneof"`
}

type ControlQueryRequest

type ControlQueryRequest struct {
	OperationParams  *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	QueryId          string                          `protobuf:"bytes,2,opt,name=query_id,json=queryId,proto3" json:"query_id,omitempty"`
	Action           QueryAction                     `protobuf:"varint,3,opt,name=action,proto3,enum=FederatedQuery.QueryAction" json:"action,omitempty"`
	PreviousRevision int64                           `protobuf:"varint,4,opt,name=previous_revision,json=previousRevision,proto3" json:"previous_revision,omitempty"`
	IdempotencyKey   string                          `protobuf:"bytes,5,opt,name=idempotency_key,json=idempotencyKey,proto3" json:"idempotency_key,omitempty"`
	// contains filtered or unexported fields
}

Managing query status (pause, abort, resume, ...)

func (*ControlQueryRequest) Descriptor deprecated

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

Deprecated: Use ControlQueryRequest.ProtoReflect.Descriptor instead.

func (*ControlQueryRequest) GetAction

func (x *ControlQueryRequest) GetAction() QueryAction

func (*ControlQueryRequest) GetIdempotencyKey

func (x *ControlQueryRequest) GetIdempotencyKey() string

func (*ControlQueryRequest) GetOperationParams

func (x *ControlQueryRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*ControlQueryRequest) GetPreviousRevision

func (x *ControlQueryRequest) GetPreviousRevision() int64

func (*ControlQueryRequest) GetQueryId

func (x *ControlQueryRequest) GetQueryId() string

func (*ControlQueryRequest) ProtoMessage

func (*ControlQueryRequest) ProtoMessage()

func (*ControlQueryRequest) ProtoReflect

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

func (*ControlQueryRequest) Reset

func (x *ControlQueryRequest) Reset()

func (*ControlQueryRequest) String

func (x *ControlQueryRequest) String() string

type ControlQueryResponse

type ControlQueryResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // ControlQueryResult
	// contains filtered or unexported fields
}

func (*ControlQueryResponse) Descriptor deprecated

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

Deprecated: Use ControlQueryResponse.ProtoReflect.Descriptor instead.

func (*ControlQueryResponse) GetOperation

func (x *ControlQueryResponse) GetOperation() *Ydb_Operations.Operation

func (*ControlQueryResponse) ProtoMessage

func (*ControlQueryResponse) ProtoMessage()

func (*ControlQueryResponse) ProtoReflect

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

func (*ControlQueryResponse) Reset

func (x *ControlQueryResponse) Reset()

func (*ControlQueryResponse) String

func (x *ControlQueryResponse) String() string

type ControlQueryResult

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

func (*ControlQueryResult) Descriptor deprecated

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

Deprecated: Use ControlQueryResult.ProtoReflect.Descriptor instead.

func (*ControlQueryResult) ProtoMessage

func (*ControlQueryResult) ProtoMessage()

func (*ControlQueryResult) ProtoReflect

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

func (*ControlQueryResult) Reset

func (x *ControlQueryResult) Reset()

func (*ControlQueryResult) String

func (x *ControlQueryResult) String() string

type CreateBindingRequest

type CreateBindingRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	Content         *BindingContent                 `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	IdempotencyKey  string                          `protobuf:"bytes,3,opt,name=idempotency_key,json=idempotencyKey,proto3" json:"idempotency_key,omitempty"`
	// contains filtered or unexported fields
}

Create a new binding

func (*CreateBindingRequest) Descriptor deprecated

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

Deprecated: Use CreateBindingRequest.ProtoReflect.Descriptor instead.

func (*CreateBindingRequest) GetContent

func (x *CreateBindingRequest) GetContent() *BindingContent

func (*CreateBindingRequest) GetIdempotencyKey

func (x *CreateBindingRequest) GetIdempotencyKey() string

func (*CreateBindingRequest) GetOperationParams

func (x *CreateBindingRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*CreateBindingRequest) ProtoMessage

func (*CreateBindingRequest) ProtoMessage()

func (*CreateBindingRequest) ProtoReflect

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

func (*CreateBindingRequest) Reset

func (x *CreateBindingRequest) Reset()

func (*CreateBindingRequest) String

func (x *CreateBindingRequest) String() string

type CreateBindingResponse

type CreateBindingResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // CreateBindingResult
	// contains filtered or unexported fields
}

func (*CreateBindingResponse) Descriptor deprecated

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

Deprecated: Use CreateBindingResponse.ProtoReflect.Descriptor instead.

func (*CreateBindingResponse) GetOperation

func (x *CreateBindingResponse) GetOperation() *Ydb_Operations.Operation

func (*CreateBindingResponse) ProtoMessage

func (*CreateBindingResponse) ProtoMessage()

func (*CreateBindingResponse) ProtoReflect

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

func (*CreateBindingResponse) Reset

func (x *CreateBindingResponse) Reset()

func (*CreateBindingResponse) String

func (x *CreateBindingResponse) String() string

type CreateBindingResult

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

func (*CreateBindingResult) Descriptor deprecated

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

Deprecated: Use CreateBindingResult.ProtoReflect.Descriptor instead.

func (*CreateBindingResult) GetBindingId

func (x *CreateBindingResult) GetBindingId() string

func (*CreateBindingResult) ProtoMessage

func (*CreateBindingResult) ProtoMessage()

func (*CreateBindingResult) ProtoReflect

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

func (*CreateBindingResult) Reset

func (x *CreateBindingResult) Reset()

func (*CreateBindingResult) String

func (x *CreateBindingResult) String() string

type CreateConnectionRequest

type CreateConnectionRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	Content         *ConnectionContent              `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	IdempotencyKey  string                          `protobuf:"bytes,3,opt,name=idempotency_key,json=idempotencyKey,proto3" json:"idempotency_key,omitempty"`
	// contains filtered or unexported fields
}

Create a new connection

func (*CreateConnectionRequest) Descriptor deprecated

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

Deprecated: Use CreateConnectionRequest.ProtoReflect.Descriptor instead.

func (*CreateConnectionRequest) GetContent

func (x *CreateConnectionRequest) GetContent() *ConnectionContent

func (*CreateConnectionRequest) GetIdempotencyKey

func (x *CreateConnectionRequest) GetIdempotencyKey() string

func (*CreateConnectionRequest) GetOperationParams

func (x *CreateConnectionRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*CreateConnectionRequest) ProtoMessage

func (*CreateConnectionRequest) ProtoMessage()

func (*CreateConnectionRequest) ProtoReflect

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

func (*CreateConnectionRequest) Reset

func (x *CreateConnectionRequest) Reset()

func (*CreateConnectionRequest) String

func (x *CreateConnectionRequest) String() string

type CreateConnectionResponse

type CreateConnectionResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // CreateConnectionResult
	// contains filtered or unexported fields
}

func (*CreateConnectionResponse) Descriptor deprecated

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

Deprecated: Use CreateConnectionResponse.ProtoReflect.Descriptor instead.

func (*CreateConnectionResponse) GetOperation

func (*CreateConnectionResponse) ProtoMessage

func (*CreateConnectionResponse) ProtoMessage()

func (*CreateConnectionResponse) ProtoReflect

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

func (*CreateConnectionResponse) Reset

func (x *CreateConnectionResponse) Reset()

func (*CreateConnectionResponse) String

func (x *CreateConnectionResponse) String() string

type CreateConnectionResult

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

func (*CreateConnectionResult) Descriptor deprecated

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

Deprecated: Use CreateConnectionResult.ProtoReflect.Descriptor instead.

func (*CreateConnectionResult) GetConnectionId

func (x *CreateConnectionResult) GetConnectionId() string

func (*CreateConnectionResult) ProtoMessage

func (*CreateConnectionResult) ProtoMessage()

func (*CreateConnectionResult) ProtoReflect

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

func (*CreateConnectionResult) Reset

func (x *CreateConnectionResult) Reset()

func (*CreateConnectionResult) String

func (x *CreateConnectionResult) String() string

type CreateQueryRequest

type CreateQueryRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	Content         *QueryContent                   `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	ExecuteMode     ExecuteMode                     `` /* 127-byte string literal not displayed */
	Disposition     *StreamingDisposition           `protobuf:"bytes,4,opt,name=disposition,proto3" json:"disposition,omitempty"`
	IdempotencyKey  string                          `protobuf:"bytes,5,opt,name=idempotency_key,json=idempotencyKey,proto3" json:"idempotency_key,omitempty"`
	// contains filtered or unexported fields
}

Create a new query

func (*CreateQueryRequest) Descriptor deprecated

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

Deprecated: Use CreateQueryRequest.ProtoReflect.Descriptor instead.

func (*CreateQueryRequest) GetContent

func (x *CreateQueryRequest) GetContent() *QueryContent

func (*CreateQueryRequest) GetDisposition

func (x *CreateQueryRequest) GetDisposition() *StreamingDisposition

func (*CreateQueryRequest) GetExecuteMode

func (x *CreateQueryRequest) GetExecuteMode() ExecuteMode

func (*CreateQueryRequest) GetIdempotencyKey

func (x *CreateQueryRequest) GetIdempotencyKey() string

func (*CreateQueryRequest) GetOperationParams

func (x *CreateQueryRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*CreateQueryRequest) ProtoMessage

func (*CreateQueryRequest) ProtoMessage()

func (*CreateQueryRequest) ProtoReflect

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

func (*CreateQueryRequest) Reset

func (x *CreateQueryRequest) Reset()

func (*CreateQueryRequest) String

func (x *CreateQueryRequest) String() string

type CreateQueryResponse

type CreateQueryResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // CreateQueryResult
	// contains filtered or unexported fields
}

func (*CreateQueryResponse) Descriptor deprecated

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

Deprecated: Use CreateQueryResponse.ProtoReflect.Descriptor instead.

func (*CreateQueryResponse) GetOperation

func (x *CreateQueryResponse) GetOperation() *Ydb_Operations.Operation

func (*CreateQueryResponse) ProtoMessage

func (*CreateQueryResponse) ProtoMessage()

func (*CreateQueryResponse) ProtoReflect

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

func (*CreateQueryResponse) Reset

func (x *CreateQueryResponse) Reset()

func (*CreateQueryResponse) String

func (x *CreateQueryResponse) String() string

type CreateQueryResult

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

func (*CreateQueryResult) Descriptor deprecated

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

Deprecated: Use CreateQueryResult.ProtoReflect.Descriptor instead.

func (*CreateQueryResult) GetQueryId

func (x *CreateQueryResult) GetQueryId() string

func (*CreateQueryResult) ProtoMessage

func (*CreateQueryResult) ProtoMessage()

func (*CreateQueryResult) ProtoReflect

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

func (*CreateQueryResult) Reset

func (x *CreateQueryResult) Reset()

func (*CreateQueryResult) String

func (x *CreateQueryResult) String() string

type CurrentIAMTokenAuth

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

func (*CurrentIAMTokenAuth) Descriptor deprecated

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

Deprecated: Use CurrentIAMTokenAuth.ProtoReflect.Descriptor instead.

func (*CurrentIAMTokenAuth) ProtoMessage

func (*CurrentIAMTokenAuth) ProtoMessage()

func (*CurrentIAMTokenAuth) ProtoReflect

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

func (*CurrentIAMTokenAuth) Reset

func (x *CurrentIAMTokenAuth) Reset()

func (*CurrentIAMTokenAuth) String

func (x *CurrentIAMTokenAuth) String() string

type DataStreams

type DataStreams struct {
	DatabaseId string   `protobuf:"bytes,1,opt,name=database_id,json=databaseId,proto3" json:"database_id,omitempty"`
	Auth       *IamAuth `protobuf:"bytes,2,opt,name=auth,proto3" json:"auth,omitempty"`
	// for internal usage
	Endpoint string `protobuf:"bytes,3,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Database string `protobuf:"bytes,4,opt,name=database,proto3" json:"database,omitempty"`
	Secure   bool   `protobuf:"varint,5,opt,name=secure,proto3" json:"secure,omitempty"`
	// contains filtered or unexported fields
}

func (*DataStreams) Descriptor deprecated

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

Deprecated: Use DataStreams.ProtoReflect.Descriptor instead.

func (*DataStreams) GetAuth

func (x *DataStreams) GetAuth() *IamAuth

func (*DataStreams) GetDatabase

func (x *DataStreams) GetDatabase() string

func (*DataStreams) GetDatabaseId

func (x *DataStreams) GetDatabaseId() string

func (*DataStreams) GetEndpoint

func (x *DataStreams) GetEndpoint() string

func (*DataStreams) GetSecure

func (x *DataStreams) GetSecure() bool

func (*DataStreams) ProtoMessage

func (*DataStreams) ProtoMessage()

func (*DataStreams) ProtoReflect

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

func (*DataStreams) Reset

func (x *DataStreams) Reset()

func (*DataStreams) String

func (x *DataStreams) String() string

type DataStreamsBinding

type DataStreamsBinding struct {
	StreamName    string            `protobuf:"bytes,1,opt,name=stream_name,json=streamName,proto3" json:"stream_name,omitempty"`
	Format        string            `protobuf:"bytes,2,opt,name=format,proto3" json:"format,omitempty"`
	Compression   string            `protobuf:"bytes,3,opt,name=compression,proto3" json:"compression,omitempty"`
	Schema        *Schema           `protobuf:"bytes,4,opt,name=schema,proto3" json:"schema,omitempty"`
	FormatSetting map[string]string `` /* 188-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DataStreamsBinding) Descriptor deprecated

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

Deprecated: Use DataStreamsBinding.ProtoReflect.Descriptor instead.

func (*DataStreamsBinding) GetCompression

func (x *DataStreamsBinding) GetCompression() string

func (*DataStreamsBinding) GetFormat

func (x *DataStreamsBinding) GetFormat() string

func (*DataStreamsBinding) GetFormatSetting

func (x *DataStreamsBinding) GetFormatSetting() map[string]string

func (*DataStreamsBinding) GetSchema

func (x *DataStreamsBinding) GetSchema() *Schema

func (*DataStreamsBinding) GetStreamName

func (x *DataStreamsBinding) GetStreamName() string

func (*DataStreamsBinding) ProtoMessage

func (*DataStreamsBinding) ProtoMessage()

func (*DataStreamsBinding) ProtoReflect

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

func (*DataStreamsBinding) Reset

func (x *DataStreamsBinding) Reset()

func (*DataStreamsBinding) String

func (x *DataStreamsBinding) String() string

type DeleteBindingRequest

type DeleteBindingRequest struct {
	OperationParams  *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	BindingId        string                          `protobuf:"bytes,2,opt,name=binding_id,json=bindingId,proto3" json:"binding_id,omitempty"`
	PreviousRevision int64                           `protobuf:"varint,3,opt,name=previous_revision,json=previousRevision,proto3" json:"previous_revision,omitempty"`
	IdempotencyKey   string                          `protobuf:"bytes,4,opt,name=idempotency_key,json=idempotencyKey,proto3" json:"idempotency_key,omitempty"`
	// contains filtered or unexported fields
}

Complete removal of binding. Recovery of the binding after this operation is not possible

func (*DeleteBindingRequest) Descriptor deprecated

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

Deprecated: Use DeleteBindingRequest.ProtoReflect.Descriptor instead.

func (*DeleteBindingRequest) GetBindingId

func (x *DeleteBindingRequest) GetBindingId() string

func (*DeleteBindingRequest) GetIdempotencyKey

func (x *DeleteBindingRequest) GetIdempotencyKey() string

func (*DeleteBindingRequest) GetOperationParams

func (x *DeleteBindingRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*DeleteBindingRequest) GetPreviousRevision

func (x *DeleteBindingRequest) GetPreviousRevision() int64

func (*DeleteBindingRequest) ProtoMessage

func (*DeleteBindingRequest) ProtoMessage()

func (*DeleteBindingRequest) ProtoReflect

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

func (*DeleteBindingRequest) Reset

func (x *DeleteBindingRequest) Reset()

func (*DeleteBindingRequest) String

func (x *DeleteBindingRequest) String() string

type DeleteBindingResponse

type DeleteBindingResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // DeleteBindingResult
	// contains filtered or unexported fields
}

func (*DeleteBindingResponse) Descriptor deprecated

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

Deprecated: Use DeleteBindingResponse.ProtoReflect.Descriptor instead.

func (*DeleteBindingResponse) GetOperation

func (x *DeleteBindingResponse) GetOperation() *Ydb_Operations.Operation

func (*DeleteBindingResponse) ProtoMessage

func (*DeleteBindingResponse) ProtoMessage()

func (*DeleteBindingResponse) ProtoReflect

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

func (*DeleteBindingResponse) Reset

func (x *DeleteBindingResponse) Reset()

func (*DeleteBindingResponse) String

func (x *DeleteBindingResponse) String() string

type DeleteBindingResult

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

func (*DeleteBindingResult) Descriptor deprecated

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

Deprecated: Use DeleteBindingResult.ProtoReflect.Descriptor instead.

func (*DeleteBindingResult) ProtoMessage

func (*DeleteBindingResult) ProtoMessage()

func (*DeleteBindingResult) ProtoReflect

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

func (*DeleteBindingResult) Reset

func (x *DeleteBindingResult) Reset()

func (*DeleteBindingResult) String

func (x *DeleteBindingResult) String() string

type DeleteConnectionRequest

type DeleteConnectionRequest struct {
	OperationParams  *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	ConnectionId     string                          `protobuf:"bytes,2,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	PreviousRevision int64                           `protobuf:"varint,3,opt,name=previous_revision,json=previousRevision,proto3" json:"previous_revision,omitempty"`
	IdempotencyKey   string                          `protobuf:"bytes,4,opt,name=idempotency_key,json=idempotencyKey,proto3" json:"idempotency_key,omitempty"`
	// contains filtered or unexported fields
}

Complete removal of connection. Recovery of the connection after this operation is not possible

func (*DeleteConnectionRequest) Descriptor deprecated

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

Deprecated: Use DeleteConnectionRequest.ProtoReflect.Descriptor instead.

func (*DeleteConnectionRequest) GetConnectionId

func (x *DeleteConnectionRequest) GetConnectionId() string

func (*DeleteConnectionRequest) GetIdempotencyKey

func (x *DeleteConnectionRequest) GetIdempotencyKey() string

func (*DeleteConnectionRequest) GetOperationParams

func (x *DeleteConnectionRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*DeleteConnectionRequest) GetPreviousRevision

func (x *DeleteConnectionRequest) GetPreviousRevision() int64

func (*DeleteConnectionRequest) ProtoMessage

func (*DeleteConnectionRequest) ProtoMessage()

func (*DeleteConnectionRequest) ProtoReflect

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

func (*DeleteConnectionRequest) Reset

func (x *DeleteConnectionRequest) Reset()

func (*DeleteConnectionRequest) String

func (x *DeleteConnectionRequest) String() string

type DeleteConnectionResponse

type DeleteConnectionResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // DeleteConnectionResult
	// contains filtered or unexported fields
}

func (*DeleteConnectionResponse) Descriptor deprecated

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

Deprecated: Use DeleteConnectionResponse.ProtoReflect.Descriptor instead.

func (*DeleteConnectionResponse) GetOperation

func (*DeleteConnectionResponse) ProtoMessage

func (*DeleteConnectionResponse) ProtoMessage()

func (*DeleteConnectionResponse) ProtoReflect

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

func (*DeleteConnectionResponse) Reset

func (x *DeleteConnectionResponse) Reset()

func (*DeleteConnectionResponse) String

func (x *DeleteConnectionResponse) String() string

type DeleteConnectionResult

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

func (*DeleteConnectionResult) Descriptor deprecated

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

Deprecated: Use DeleteConnectionResult.ProtoReflect.Descriptor instead.

func (*DeleteConnectionResult) ProtoMessage

func (*DeleteConnectionResult) ProtoMessage()

func (*DeleteConnectionResult) ProtoReflect

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

func (*DeleteConnectionResult) Reset

func (x *DeleteConnectionResult) Reset()

func (*DeleteConnectionResult) String

func (x *DeleteConnectionResult) String() string

type DeleteQueryRequest

type DeleteQueryRequest struct {
	OperationParams  *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	QueryId          string                          `protobuf:"bytes,2,opt,name=query_id,json=queryId,proto3" json:"query_id,omitempty"`
	PreviousRevision int64                           `protobuf:"varint,3,opt,name=previous_revision,json=previousRevision,proto3" json:"previous_revision,omitempty"`
	IdempotencyKey   string                          `protobuf:"bytes,4,opt,name=idempotency_key,json=idempotencyKey,proto3" json:"idempotency_key,omitempty"`
	// contains filtered or unexported fields
}

Complete removal of query. Recovery of the query after this operation is not possible

func (*DeleteQueryRequest) Descriptor deprecated

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

Deprecated: Use DeleteQueryRequest.ProtoReflect.Descriptor instead.

func (*DeleteQueryRequest) GetIdempotencyKey

func (x *DeleteQueryRequest) GetIdempotencyKey() string

func (*DeleteQueryRequest) GetOperationParams

func (x *DeleteQueryRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*DeleteQueryRequest) GetPreviousRevision

func (x *DeleteQueryRequest) GetPreviousRevision() int64

func (*DeleteQueryRequest) GetQueryId

func (x *DeleteQueryRequest) GetQueryId() string

func (*DeleteQueryRequest) ProtoMessage

func (*DeleteQueryRequest) ProtoMessage()

func (*DeleteQueryRequest) ProtoReflect

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

func (*DeleteQueryRequest) Reset

func (x *DeleteQueryRequest) Reset()

func (*DeleteQueryRequest) String

func (x *DeleteQueryRequest) String() string

type DeleteQueryResponse

type DeleteQueryResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // DeleteQueryResult
	// contains filtered or unexported fields
}

func (*DeleteQueryResponse) Descriptor deprecated

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

Deprecated: Use DeleteQueryResponse.ProtoReflect.Descriptor instead.

func (*DeleteQueryResponse) GetOperation

func (x *DeleteQueryResponse) GetOperation() *Ydb_Operations.Operation

func (*DeleteQueryResponse) ProtoMessage

func (*DeleteQueryResponse) ProtoMessage()

func (*DeleteQueryResponse) ProtoReflect

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

func (*DeleteQueryResponse) Reset

func (x *DeleteQueryResponse) Reset()

func (*DeleteQueryResponse) String

func (x *DeleteQueryResponse) String() string

type DeleteQueryResult

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

func (*DeleteQueryResult) Descriptor deprecated

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

Deprecated: Use DeleteQueryResult.ProtoReflect.Descriptor instead.

func (*DeleteQueryResult) ProtoMessage

func (*DeleteQueryResult) ProtoMessage()

func (*DeleteQueryResult) ProtoReflect

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

func (*DeleteQueryResult) Reset

func (x *DeleteQueryResult) Reset()

func (*DeleteQueryResult) String

func (x *DeleteQueryResult) String() string

type DescribeBindingRequest

type DescribeBindingRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	BindingId       string                          `protobuf:"bytes,2,opt,name=binding_id,json=bindingId,proto3" json:"binding_id,omitempty"`
	// contains filtered or unexported fields
}

Getting information about the binding

func (*DescribeBindingRequest) Descriptor deprecated

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

Deprecated: Use DescribeBindingRequest.ProtoReflect.Descriptor instead.

func (*DescribeBindingRequest) GetBindingId

func (x *DescribeBindingRequest) GetBindingId() string

func (*DescribeBindingRequest) GetOperationParams

func (x *DescribeBindingRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*DescribeBindingRequest) ProtoMessage

func (*DescribeBindingRequest) ProtoMessage()

func (*DescribeBindingRequest) ProtoReflect

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

func (*DescribeBindingRequest) Reset

func (x *DescribeBindingRequest) Reset()

func (*DescribeBindingRequest) String

func (x *DescribeBindingRequest) String() string

type DescribeBindingResponse

type DescribeBindingResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // DescribeBindingResult
	// contains filtered or unexported fields
}

func (*DescribeBindingResponse) Descriptor deprecated

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

Deprecated: Use DescribeBindingResponse.ProtoReflect.Descriptor instead.

func (*DescribeBindingResponse) GetOperation

func (*DescribeBindingResponse) ProtoMessage

func (*DescribeBindingResponse) ProtoMessage()

func (*DescribeBindingResponse) ProtoReflect

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

func (*DescribeBindingResponse) Reset

func (x *DescribeBindingResponse) Reset()

func (*DescribeBindingResponse) String

func (x *DescribeBindingResponse) String() string

type DescribeBindingResult

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

func (*DescribeBindingResult) Descriptor deprecated

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

Deprecated: Use DescribeBindingResult.ProtoReflect.Descriptor instead.

func (*DescribeBindingResult) GetBinding

func (x *DescribeBindingResult) GetBinding() *Binding

func (*DescribeBindingResult) ProtoMessage

func (*DescribeBindingResult) ProtoMessage()

func (*DescribeBindingResult) ProtoReflect

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

func (*DescribeBindingResult) Reset

func (x *DescribeBindingResult) Reset()

func (*DescribeBindingResult) String

func (x *DescribeBindingResult) String() string

type DescribeConnectionRequest

type DescribeConnectionRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	ConnectionId    string                          `protobuf:"bytes,2,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	// contains filtered or unexported fields
}

Getting information about the connection

func (*DescribeConnectionRequest) Descriptor deprecated

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

Deprecated: Use DescribeConnectionRequest.ProtoReflect.Descriptor instead.

func (*DescribeConnectionRequest) GetConnectionId

func (x *DescribeConnectionRequest) GetConnectionId() string

func (*DescribeConnectionRequest) GetOperationParams

func (x *DescribeConnectionRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*DescribeConnectionRequest) ProtoMessage

func (*DescribeConnectionRequest) ProtoMessage()

func (*DescribeConnectionRequest) ProtoReflect

func (*DescribeConnectionRequest) Reset

func (x *DescribeConnectionRequest) Reset()

func (*DescribeConnectionRequest) String

func (x *DescribeConnectionRequest) String() string

type DescribeConnectionResponse

type DescribeConnectionResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // DescribeConnectionResult
	// contains filtered or unexported fields
}

func (*DescribeConnectionResponse) Descriptor deprecated

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

Deprecated: Use DescribeConnectionResponse.ProtoReflect.Descriptor instead.

func (*DescribeConnectionResponse) GetOperation

func (*DescribeConnectionResponse) ProtoMessage

func (*DescribeConnectionResponse) ProtoMessage()

func (*DescribeConnectionResponse) ProtoReflect

func (*DescribeConnectionResponse) Reset

func (x *DescribeConnectionResponse) Reset()

func (*DescribeConnectionResponse) String

func (x *DescribeConnectionResponse) String() string

type DescribeConnectionResult

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

func (*DescribeConnectionResult) Descriptor deprecated

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

Deprecated: Use DescribeConnectionResult.ProtoReflect.Descriptor instead.

func (*DescribeConnectionResult) GetConnection

func (x *DescribeConnectionResult) GetConnection() *Connection

func (*DescribeConnectionResult) ProtoMessage

func (*DescribeConnectionResult) ProtoMessage()

func (*DescribeConnectionResult) ProtoReflect

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

func (*DescribeConnectionResult) Reset

func (x *DescribeConnectionResult) Reset()

func (*DescribeConnectionResult) String

func (x *DescribeConnectionResult) String() string

type DescribeJobRequest

type DescribeJobRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	JobId           string                          `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

Getting information about the job

func (*DescribeJobRequest) Descriptor deprecated

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

Deprecated: Use DescribeJobRequest.ProtoReflect.Descriptor instead.

func (*DescribeJobRequest) GetJobId

func (x *DescribeJobRequest) GetJobId() string

func (*DescribeJobRequest) GetOperationParams

func (x *DescribeJobRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*DescribeJobRequest) ProtoMessage

func (*DescribeJobRequest) ProtoMessage()

func (*DescribeJobRequest) ProtoReflect

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

func (*DescribeJobRequest) Reset

func (x *DescribeJobRequest) Reset()

func (*DescribeJobRequest) String

func (x *DescribeJobRequest) String() string

type DescribeJobResponse

type DescribeJobResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // DescribeJobResult
	// contains filtered or unexported fields
}

func (*DescribeJobResponse) Descriptor deprecated

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

Deprecated: Use DescribeJobResponse.ProtoReflect.Descriptor instead.

func (*DescribeJobResponse) GetOperation

func (x *DescribeJobResponse) GetOperation() *Ydb_Operations.Operation

func (*DescribeJobResponse) ProtoMessage

func (*DescribeJobResponse) ProtoMessage()

func (*DescribeJobResponse) ProtoReflect

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

func (*DescribeJobResponse) Reset

func (x *DescribeJobResponse) Reset()

func (*DescribeJobResponse) String

func (x *DescribeJobResponse) String() string

type DescribeJobResult

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

func (*DescribeJobResult) Descriptor deprecated

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

Deprecated: Use DescribeJobResult.ProtoReflect.Descriptor instead.

func (*DescribeJobResult) GetJob

func (x *DescribeJobResult) GetJob() *Job

func (*DescribeJobResult) ProtoMessage

func (*DescribeJobResult) ProtoMessage()

func (*DescribeJobResult) ProtoReflect

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

func (*DescribeJobResult) Reset

func (x *DescribeJobResult) Reset()

func (*DescribeJobResult) String

func (x *DescribeJobResult) String() string

type DescribeQueryRequest

type DescribeQueryRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	QueryId         string                          `protobuf:"bytes,2,opt,name=query_id,json=queryId,proto3" json:"query_id,omitempty"`
	// contains filtered or unexported fields
}

Getting complete information about the query

func (*DescribeQueryRequest) Descriptor deprecated

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

Deprecated: Use DescribeQueryRequest.ProtoReflect.Descriptor instead.

func (*DescribeQueryRequest) GetOperationParams

func (x *DescribeQueryRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*DescribeQueryRequest) GetQueryId

func (x *DescribeQueryRequest) GetQueryId() string

func (*DescribeQueryRequest) ProtoMessage

func (*DescribeQueryRequest) ProtoMessage()

func (*DescribeQueryRequest) ProtoReflect

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

func (*DescribeQueryRequest) Reset

func (x *DescribeQueryRequest) Reset()

func (*DescribeQueryRequest) String

func (x *DescribeQueryRequest) String() string

type DescribeQueryResponse

type DescribeQueryResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // DescribeQueryResult
	// contains filtered or unexported fields
}

func (*DescribeQueryResponse) Descriptor deprecated

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

Deprecated: Use DescribeQueryResponse.ProtoReflect.Descriptor instead.

func (*DescribeQueryResponse) GetOperation

func (x *DescribeQueryResponse) GetOperation() *Ydb_Operations.Operation

func (*DescribeQueryResponse) ProtoMessage

func (*DescribeQueryResponse) ProtoMessage()

func (*DescribeQueryResponse) ProtoReflect

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

func (*DescribeQueryResponse) Reset

func (x *DescribeQueryResponse) Reset()

func (*DescribeQueryResponse) String

func (x *DescribeQueryResponse) String() string

type DescribeQueryResult

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

func (*DescribeQueryResult) Descriptor deprecated

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

Deprecated: Use DescribeQueryResult.ProtoReflect.Descriptor instead.

func (*DescribeQueryResult) GetQuery

func (x *DescribeQueryResult) GetQuery() *Query

func (*DescribeQueryResult) ProtoMessage

func (*DescribeQueryResult) ProtoMessage()

func (*DescribeQueryResult) ProtoReflect

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

func (*DescribeQueryResult) Reset

func (x *DescribeQueryResult) Reset()

func (*DescribeQueryResult) String

func (x *DescribeQueryResult) String() string

type ExecuteMode

type ExecuteMode int32
const (
	ExecuteMode_EXECUTE_MODE_UNSPECIFIED ExecuteMode = 0
	ExecuteMode_SAVE                     ExecuteMode = 1 // Save a query without changing its state
	ExecuteMode_PARSE                    ExecuteMode = 2 // Parse the query
	ExecuteMode_COMPILE                  ExecuteMode = 3 // Parse and compile the query
	ExecuteMode_VALIDATE                 ExecuteMode = 4 // Parse, compile and validate the query
	ExecuteMode_EXPLAIN                  ExecuteMode = 5 // High-level query plan that specifies only physical operations and non-temporary table names
	ExecuteMode_RUN                      ExecuteMode = 6 // Do all the previous + execution of the query
)

func (ExecuteMode) Descriptor

func (ExecuteMode) Enum

func (x ExecuteMode) Enum() *ExecuteMode

func (ExecuteMode) EnumDescriptor deprecated

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

Deprecated: Use ExecuteMode.Descriptor instead.

func (ExecuteMode) Number

func (x ExecuteMode) Number() protoreflect.EnumNumber

func (ExecuteMode) String

func (x ExecuteMode) String() string

func (ExecuteMode) Type

type GetQueryStatusRequest

type GetQueryStatusRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	QueryId         string                          `protobuf:"bytes,2,opt,name=query_id,json=queryId,proto3" json:"query_id,omitempty"`
	// contains filtered or unexported fields
}

Getting status of the query

func (*GetQueryStatusRequest) Descriptor deprecated

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

Deprecated: Use GetQueryStatusRequest.ProtoReflect.Descriptor instead.

func (*GetQueryStatusRequest) GetOperationParams

func (x *GetQueryStatusRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*GetQueryStatusRequest) GetQueryId

func (x *GetQueryStatusRequest) GetQueryId() string

func (*GetQueryStatusRequest) ProtoMessage

func (*GetQueryStatusRequest) ProtoMessage()

func (*GetQueryStatusRequest) ProtoReflect

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

func (*GetQueryStatusRequest) Reset

func (x *GetQueryStatusRequest) Reset()

func (*GetQueryStatusRequest) String

func (x *GetQueryStatusRequest) String() string

type GetQueryStatusResponse

type GetQueryStatusResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // GetQueryStatusResult
	// contains filtered or unexported fields
}

func (*GetQueryStatusResponse) Descriptor deprecated

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

Deprecated: Use GetQueryStatusResponse.ProtoReflect.Descriptor instead.

func (*GetQueryStatusResponse) GetOperation

func (x *GetQueryStatusResponse) GetOperation() *Ydb_Operations.Operation

func (*GetQueryStatusResponse) ProtoMessage

func (*GetQueryStatusResponse) ProtoMessage()

func (*GetQueryStatusResponse) ProtoReflect

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

func (*GetQueryStatusResponse) Reset

func (x *GetQueryStatusResponse) Reset()

func (*GetQueryStatusResponse) String

func (x *GetQueryStatusResponse) String() string

type GetQueryStatusResult

type GetQueryStatusResult struct {
	Status       QueryMeta_ComputeStatus `protobuf:"varint,1,opt,name=status,proto3,enum=FederatedQuery.QueryMeta_ComputeStatus" json:"status,omitempty"`
	MetaRevision int64                   `protobuf:"varint,2,opt,name=meta_revision,json=metaRevision,proto3" json:"meta_revision,omitempty"`
	// contains filtered or unexported fields
}

func (*GetQueryStatusResult) Descriptor deprecated

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

Deprecated: Use GetQueryStatusResult.ProtoReflect.Descriptor instead.

func (*GetQueryStatusResult) GetMetaRevision

func (x *GetQueryStatusResult) GetMetaRevision() int64

func (*GetQueryStatusResult) GetStatus

func (*GetQueryStatusResult) ProtoMessage

func (*GetQueryStatusResult) ProtoMessage()

func (*GetQueryStatusResult) ProtoReflect

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

func (*GetQueryStatusResult) Reset

func (x *GetQueryStatusResult) Reset()

func (*GetQueryStatusResult) String

func (x *GetQueryStatusResult) String() string

type GetResultDataRequest

type GetResultDataRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	QueryId         string                          `protobuf:"bytes,2,opt,name=query_id,json=queryId,proto3" json:"query_id,omitempty"`
	ResultSetIndex  int32                           `protobuf:"varint,3,opt,name=result_set_index,json=resultSetIndex,proto3" json:"result_set_index,omitempty"`
	Offset          int64                           `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"`
	Limit           int64                           `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

Getting the result of the query execution

func (*GetResultDataRequest) Descriptor deprecated

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

Deprecated: Use GetResultDataRequest.ProtoReflect.Descriptor instead.

func (*GetResultDataRequest) GetLimit

func (x *GetResultDataRequest) GetLimit() int64

func (*GetResultDataRequest) GetOffset

func (x *GetResultDataRequest) GetOffset() int64

func (*GetResultDataRequest) GetOperationParams

func (x *GetResultDataRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*GetResultDataRequest) GetQueryId

func (x *GetResultDataRequest) GetQueryId() string

func (*GetResultDataRequest) GetResultSetIndex

func (x *GetResultDataRequest) GetResultSetIndex() int32

func (*GetResultDataRequest) ProtoMessage

func (*GetResultDataRequest) ProtoMessage()

func (*GetResultDataRequest) ProtoReflect

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

func (*GetResultDataRequest) Reset

func (x *GetResultDataRequest) Reset()

func (*GetResultDataRequest) String

func (x *GetResultDataRequest) String() string

type GetResultDataResponse

type GetResultDataResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // GetResultDataResult
	// contains filtered or unexported fields
}

func (*GetResultDataResponse) Descriptor deprecated

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

Deprecated: Use GetResultDataResponse.ProtoReflect.Descriptor instead.

func (*GetResultDataResponse) GetOperation

func (x *GetResultDataResponse) GetOperation() *Ydb_Operations.Operation

func (*GetResultDataResponse) ProtoMessage

func (*GetResultDataResponse) ProtoMessage()

func (*GetResultDataResponse) ProtoReflect

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

func (*GetResultDataResponse) Reset

func (x *GetResultDataResponse) Reset()

func (*GetResultDataResponse) String

func (x *GetResultDataResponse) String() string

type GetResultDataResult

type GetResultDataResult struct {
	ResultSet *Ydb.ResultSet `protobuf:"bytes,1,opt,name=result_set,json=resultSet,proto3" json:"result_set,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResultDataResult) Descriptor deprecated

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

Deprecated: Use GetResultDataResult.ProtoReflect.Descriptor instead.

func (*GetResultDataResult) GetResultSet

func (x *GetResultDataResult) GetResultSet() *Ydb.ResultSet

func (*GetResultDataResult) ProtoMessage

func (*GetResultDataResult) ProtoMessage()

func (*GetResultDataResult) ProtoReflect

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

func (*GetResultDataResult) Reset

func (x *GetResultDataResult) Reset()

func (*GetResultDataResult) String

func (x *GetResultDataResult) String() string

type IamAuth

type IamAuth struct {

	// Types that are assignable to Identity:
	//
	//	*IamAuth_CurrentIam
	//	*IamAuth_ServiceAccount
	//	*IamAuth_None
	Identity isIamAuth_Identity `protobuf_oneof:"identity"`
	// contains filtered or unexported fields
}

func (*IamAuth) Descriptor deprecated

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

Deprecated: Use IamAuth.ProtoReflect.Descriptor instead.

func (*IamAuth) GetCurrentIam

func (x *IamAuth) GetCurrentIam() *CurrentIAMTokenAuth

func (*IamAuth) GetIdentity

func (m *IamAuth) GetIdentity() isIamAuth_Identity

func (*IamAuth) GetNone

func (x *IamAuth) GetNone() *NoneAuth

func (*IamAuth) GetServiceAccount

func (x *IamAuth) GetServiceAccount() *ServiceAccountAuth

func (*IamAuth) ProtoMessage

func (*IamAuth) ProtoMessage()

func (*IamAuth) ProtoReflect

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

func (*IamAuth) Reset

func (x *IamAuth) Reset()

func (*IamAuth) String

func (x *IamAuth) String() string

type IamAuth_CurrentIam

type IamAuth_CurrentIam struct {
	CurrentIam *CurrentIAMTokenAuth `protobuf:"bytes,1,opt,name=current_iam,json=currentIam,proto3,oneof"`
}

type IamAuth_None

type IamAuth_None struct {
	None *NoneAuth `protobuf:"bytes,3,opt,name=none,proto3,oneof"`
}

type IamAuth_ServiceAccount

type IamAuth_ServiceAccount struct {
	ServiceAccount *ServiceAccountAuth `protobuf:"bytes,2,opt,name=service_account,json=serviceAccount,proto3,oneof"`
}

type Job

type Job struct {
	Meta          *CommonMeta               `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	Text          string                    `protobuf:"bytes,2,opt,name=text,proto3" json:"text,omitempty"`
	QueryMeta     *QueryMeta                `protobuf:"bytes,3,opt,name=query_meta,json=queryMeta,proto3" json:"query_meta,omitempty"`
	Plan          *QueryPlan                `protobuf:"bytes,4,opt,name=plan,proto3" json:"plan,omitempty"`
	Issue         []*Ydb_Issue.IssueMessage `protobuf:"bytes,5,rep,name=issue,proto3" json:"issue,omitempty"`
	Statistics    *QueryStatistics          `protobuf:"bytes,6,opt,name=statistics,proto3" json:"statistics,omitempty"`
	ResultSetMeta []*ResultSetMeta          `protobuf:"bytes,7,rep,name=result_set_meta,json=resultSetMeta,proto3" json:"result_set_meta,omitempty"`
	Ast           *QueryAst                 `protobuf:"bytes,8,opt,name=ast,proto3" json:"ast,omitempty"`
	QueryName     string                    `protobuf:"bytes,9,opt,name=query_name,json=queryName,proto3" json:"query_name,omitempty"`
	Acl           *Acl                      `protobuf:"bytes,10,opt,name=acl,proto3" json:"acl,omitempty"`
	Automatic     bool                      `protobuf:"varint,11,opt,name=automatic,proto3" json:"automatic,omitempty"`
	ExpireAt      *timestamppb.Timestamp    `protobuf:"bytes,12,opt,name=expire_at,json=expireAt,proto3" json:"expire_at,omitempty"`
	Syntax        QueryContent_QuerySyntax  `protobuf:"varint,13,opt,name=syntax,proto3,enum=FederatedQuery.QueryContent_QuerySyntax" json:"syntax,omitempty"`
	// contains filtered or unexported fields
}

func (*Job) Descriptor deprecated

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

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetAcl

func (x *Job) GetAcl() *Acl

func (*Job) GetAst

func (x *Job) GetAst() *QueryAst

func (*Job) GetAutomatic

func (x *Job) GetAutomatic() bool

func (*Job) GetExpireAt

func (x *Job) GetExpireAt() *timestamppb.Timestamp

func (*Job) GetIssue

func (x *Job) GetIssue() []*Ydb_Issue.IssueMessage

func (*Job) GetMeta

func (x *Job) GetMeta() *CommonMeta

func (*Job) GetPlan

func (x *Job) GetPlan() *QueryPlan

func (*Job) GetQueryMeta

func (x *Job) GetQueryMeta() *QueryMeta

func (*Job) GetQueryName

func (x *Job) GetQueryName() string

func (*Job) GetResultSetMeta

func (x *Job) GetResultSetMeta() []*ResultSetMeta

func (*Job) GetStatistics

func (x *Job) GetStatistics() *QueryStatistics

func (*Job) GetSyntax

func (x *Job) GetSyntax() QueryContent_QuerySyntax

func (*Job) GetText

func (x *Job) GetText() string

func (*Job) ProtoMessage

func (*Job) ProtoMessage()

func (*Job) ProtoReflect

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

func (*Job) Reset

func (x *Job) Reset()

func (*Job) String

func (x *Job) String() string

type Limits

type Limits struct {
	VcpuRateLimit int64 `protobuf:"varint,1,opt,name=vcpu_rate_limit,json=vcpuRateLimit,proto3" json:"vcpu_rate_limit,omitempty"` // 0.01 vcpu per second
	FlowRateLimit int64 `protobuf:"varint,2,opt,name=flow_rate_limit,json=flowRateLimit,proto3" json:"flow_rate_limit,omitempty"` // Bytes per second
	VcpuTimeLimit int64 `protobuf:"varint,3,opt,name=vcpu_time_limit,json=vcpuTimeLimit,proto3" json:"vcpu_time_limit,omitempty"` // Milliseconds per second
	// Used only for analytics queries
	MaxResultSize int64 `protobuf:"varint,4,opt,name=max_result_size,json=maxResultSize,proto3" json:"max_result_size,omitempty"` // Bytes
	MaxResultRows int64 `protobuf:"varint,5,opt,name=max_result_rows,json=maxResultRows,proto3" json:"max_result_rows,omitempty"` // Count
	// Common limits
	MemoryLimit int64                `protobuf:"varint,6,opt,name=memory_limit,json=memoryLimit,proto3" json:"memory_limit,omitempty"` // Bytes
	ResultTtl   *durationpb.Duration `protobuf:"bytes,7,opt,name=result_ttl,json=resultTtl,proto3" json:"result_ttl,omitempty"`
	// Types that are assignable to Timeout:
	//
	//	*Limits_ExecutionTimeout
	//	*Limits_ExecutionDeadline
	Timeout isLimits_Timeout `protobuf_oneof:"timeout"`
	// contains filtered or unexported fields
}

func (*Limits) Descriptor deprecated

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

Deprecated: Use Limits.ProtoReflect.Descriptor instead.

func (*Limits) GetExecutionDeadline

func (x *Limits) GetExecutionDeadline() *timestamppb.Timestamp

func (*Limits) GetExecutionTimeout

func (x *Limits) GetExecutionTimeout() *durationpb.Duration

func (*Limits) GetFlowRateLimit

func (x *Limits) GetFlowRateLimit() int64

func (*Limits) GetMaxResultRows

func (x *Limits) GetMaxResultRows() int64

func (*Limits) GetMaxResultSize

func (x *Limits) GetMaxResultSize() int64

func (*Limits) GetMemoryLimit

func (x *Limits) GetMemoryLimit() int64

func (*Limits) GetResultTtl

func (x *Limits) GetResultTtl() *durationpb.Duration

func (*Limits) GetTimeout

func (m *Limits) GetTimeout() isLimits_Timeout

func (*Limits) GetVcpuRateLimit

func (x *Limits) GetVcpuRateLimit() int64

func (*Limits) GetVcpuTimeLimit

func (x *Limits) GetVcpuTimeLimit() int64

func (*Limits) ProtoMessage

func (*Limits) ProtoMessage()

func (*Limits) ProtoReflect

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

func (*Limits) Reset

func (x *Limits) Reset()

func (*Limits) String

func (x *Limits) String() string

type Limits_ExecutionDeadline

type Limits_ExecutionDeadline struct {
	ExecutionDeadline *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=execution_deadline,json=executionDeadline,proto3,oneof"`
}

type Limits_ExecutionTimeout

type Limits_ExecutionTimeout struct {
	ExecutionTimeout *durationpb.Duration `protobuf:"bytes,8,opt,name=execution_timeout,json=executionTimeout,proto3,oneof"`
}

type ListBindingsRequest

type ListBindingsRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	PageToken       string                          `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	Limit           int32                           `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	Filter          *ListBindingsRequest_Filter     `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

Getting information about bindings

func (*ListBindingsRequest) Descriptor deprecated

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

Deprecated: Use ListBindingsRequest.ProtoReflect.Descriptor instead.

func (*ListBindingsRequest) GetFilter

func (*ListBindingsRequest) GetLimit

func (x *ListBindingsRequest) GetLimit() int32

func (*ListBindingsRequest) GetOperationParams

func (x *ListBindingsRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*ListBindingsRequest) GetPageToken

func (x *ListBindingsRequest) GetPageToken() string

func (*ListBindingsRequest) ProtoMessage

func (*ListBindingsRequest) ProtoMessage()

func (*ListBindingsRequest) ProtoReflect

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

func (*ListBindingsRequest) Reset

func (x *ListBindingsRequest) Reset()

func (*ListBindingsRequest) String

func (x *ListBindingsRequest) String() string

type ListBindingsRequest_Filter

type ListBindingsRequest_Filter struct {
	ConnectionId string         `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	Name         string         `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // bindings whose name contains the filter.name substring
	CreatedByMe  bool           `protobuf:"varint,3,opt,name=created_by_me,json=createdByMe,proto3" json:"created_by_me,omitempty"`
	Visibility   Acl_Visibility `protobuf:"varint,4,opt,name=visibility,proto3,enum=FederatedQuery.Acl_Visibility" json:"visibility,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBindingsRequest_Filter) Descriptor deprecated

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

Deprecated: Use ListBindingsRequest_Filter.ProtoReflect.Descriptor instead.

func (*ListBindingsRequest_Filter) GetConnectionId

func (x *ListBindingsRequest_Filter) GetConnectionId() string

func (*ListBindingsRequest_Filter) GetCreatedByMe

func (x *ListBindingsRequest_Filter) GetCreatedByMe() bool

func (*ListBindingsRequest_Filter) GetName

func (x *ListBindingsRequest_Filter) GetName() string

func (*ListBindingsRequest_Filter) GetVisibility

func (x *ListBindingsRequest_Filter) GetVisibility() Acl_Visibility

func (*ListBindingsRequest_Filter) ProtoMessage

func (*ListBindingsRequest_Filter) ProtoMessage()

func (*ListBindingsRequest_Filter) ProtoReflect

func (*ListBindingsRequest_Filter) Reset

func (x *ListBindingsRequest_Filter) Reset()

func (*ListBindingsRequest_Filter) String

func (x *ListBindingsRequest_Filter) String() string

type ListBindingsResponse

type ListBindingsResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // ListBindingsResult
	// contains filtered or unexported fields
}

func (*ListBindingsResponse) Descriptor deprecated

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

Deprecated: Use ListBindingsResponse.ProtoReflect.Descriptor instead.

func (*ListBindingsResponse) GetOperation

func (x *ListBindingsResponse) GetOperation() *Ydb_Operations.Operation

func (*ListBindingsResponse) ProtoMessage

func (*ListBindingsResponse) ProtoMessage()

func (*ListBindingsResponse) ProtoReflect

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

func (*ListBindingsResponse) Reset

func (x *ListBindingsResponse) Reset()

func (*ListBindingsResponse) String

func (x *ListBindingsResponse) String() string

type ListBindingsResult

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

func (*ListBindingsResult) Descriptor deprecated

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

Deprecated: Use ListBindingsResult.ProtoReflect.Descriptor instead.

func (*ListBindingsResult) GetBinding

func (x *ListBindingsResult) GetBinding() []*BriefBinding

func (*ListBindingsResult) GetNextPageToken

func (x *ListBindingsResult) GetNextPageToken() string

func (*ListBindingsResult) ProtoMessage

func (*ListBindingsResult) ProtoMessage()

func (*ListBindingsResult) ProtoReflect

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

func (*ListBindingsResult) Reset

func (x *ListBindingsResult) Reset()

func (*ListBindingsResult) String

func (x *ListBindingsResult) String() string

type ListConnectionsRequest

type ListConnectionsRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	PageToken       string                          `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	Limit           int32                           `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	Filter          *ListConnectionsRequest_Filter  `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

Getting information about connections

func (*ListConnectionsRequest) Descriptor deprecated

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

Deprecated: Use ListConnectionsRequest.ProtoReflect.Descriptor instead.

func (*ListConnectionsRequest) GetFilter

func (*ListConnectionsRequest) GetLimit

func (x *ListConnectionsRequest) GetLimit() int32

func (*ListConnectionsRequest) GetOperationParams

func (x *ListConnectionsRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*ListConnectionsRequest) GetPageToken

func (x *ListConnectionsRequest) GetPageToken() string

func (*ListConnectionsRequest) ProtoMessage

func (*ListConnectionsRequest) ProtoMessage()

func (*ListConnectionsRequest) ProtoReflect

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

func (*ListConnectionsRequest) Reset

func (x *ListConnectionsRequest) Reset()

func (*ListConnectionsRequest) String

func (x *ListConnectionsRequest) String() string

type ListConnectionsRequest_Filter

type ListConnectionsRequest_Filter struct {
	Name           string                           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // connections whose name contains the filter.name substring
	CreatedByMe    bool                             `protobuf:"varint,2,opt,name=created_by_me,json=createdByMe,proto3" json:"created_by_me,omitempty"`
	ConnectionType ConnectionSetting_ConnectionType `` /* 157-byte string literal not displayed */
	Visibility     Acl_Visibility                   `protobuf:"varint,4,opt,name=visibility,proto3,enum=FederatedQuery.Acl_Visibility" json:"visibility,omitempty"`
	// contains filtered or unexported fields
}

func (*ListConnectionsRequest_Filter) Descriptor deprecated

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

Deprecated: Use ListConnectionsRequest_Filter.ProtoReflect.Descriptor instead.

func (*ListConnectionsRequest_Filter) GetConnectionType

func (*ListConnectionsRequest_Filter) GetCreatedByMe

func (x *ListConnectionsRequest_Filter) GetCreatedByMe() bool

func (*ListConnectionsRequest_Filter) GetName

func (*ListConnectionsRequest_Filter) GetVisibility

func (x *ListConnectionsRequest_Filter) GetVisibility() Acl_Visibility

func (*ListConnectionsRequest_Filter) ProtoMessage

func (*ListConnectionsRequest_Filter) ProtoMessage()

func (*ListConnectionsRequest_Filter) ProtoReflect

func (*ListConnectionsRequest_Filter) Reset

func (x *ListConnectionsRequest_Filter) Reset()

func (*ListConnectionsRequest_Filter) String

type ListConnectionsResponse

type ListConnectionsResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // ListConnectionsResult
	// contains filtered or unexported fields
}

func (*ListConnectionsResponse) Descriptor deprecated

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

Deprecated: Use ListConnectionsResponse.ProtoReflect.Descriptor instead.

func (*ListConnectionsResponse) GetOperation

func (*ListConnectionsResponse) ProtoMessage

func (*ListConnectionsResponse) ProtoMessage()

func (*ListConnectionsResponse) ProtoReflect

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

func (*ListConnectionsResponse) Reset

func (x *ListConnectionsResponse) Reset()

func (*ListConnectionsResponse) String

func (x *ListConnectionsResponse) String() string

type ListConnectionsResult

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

func (*ListConnectionsResult) Descriptor deprecated

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

Deprecated: Use ListConnectionsResult.ProtoReflect.Descriptor instead.

func (*ListConnectionsResult) GetConnection

func (x *ListConnectionsResult) GetConnection() []*Connection

func (*ListConnectionsResult) GetNextPageToken

func (x *ListConnectionsResult) GetNextPageToken() string

func (*ListConnectionsResult) ProtoMessage

func (*ListConnectionsResult) ProtoMessage()

func (*ListConnectionsResult) ProtoReflect

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

func (*ListConnectionsResult) Reset

func (x *ListConnectionsResult) Reset()

func (*ListConnectionsResult) String

func (x *ListConnectionsResult) String() string

type ListJobsRequest

type ListJobsRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	PageToken       string                          `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	Limit           int32                           `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	QueryId         string                          `protobuf:"bytes,5,opt,name=query_id,json=queryId,proto3" json:"query_id,omitempty"` // deprecated
	Filter          *ListJobsRequest_Filter         `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

Information about recent query runs

func (*ListJobsRequest) Descriptor deprecated

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

Deprecated: Use ListJobsRequest.ProtoReflect.Descriptor instead.

func (*ListJobsRequest) GetFilter

func (x *ListJobsRequest) GetFilter() *ListJobsRequest_Filter

func (*ListJobsRequest) GetLimit

func (x *ListJobsRequest) GetLimit() int32

func (*ListJobsRequest) GetOperationParams

func (x *ListJobsRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*ListJobsRequest) GetPageToken

func (x *ListJobsRequest) GetPageToken() string

func (*ListJobsRequest) GetQueryId

func (x *ListJobsRequest) GetQueryId() string

func (*ListJobsRequest) ProtoMessage

func (*ListJobsRequest) ProtoMessage()

func (*ListJobsRequest) ProtoReflect

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

func (*ListJobsRequest) Reset

func (x *ListJobsRequest) Reset()

func (*ListJobsRequest) String

func (x *ListJobsRequest) String() string

type ListJobsRequest_Filter

type ListJobsRequest_Filter struct {
	QueryId     string `protobuf:"bytes,1,opt,name=query_id,json=queryId,proto3" json:"query_id,omitempty"`
	CreatedByMe bool   `protobuf:"varint,2,opt,name=created_by_me,json=createdByMe,proto3" json:"created_by_me,omitempty"`
	// contains filtered or unexported fields
}

func (*ListJobsRequest_Filter) Descriptor deprecated

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

Deprecated: Use ListJobsRequest_Filter.ProtoReflect.Descriptor instead.

func (*ListJobsRequest_Filter) GetCreatedByMe

func (x *ListJobsRequest_Filter) GetCreatedByMe() bool

func (*ListJobsRequest_Filter) GetQueryId

func (x *ListJobsRequest_Filter) GetQueryId() string

func (*ListJobsRequest_Filter) ProtoMessage

func (*ListJobsRequest_Filter) ProtoMessage()

func (*ListJobsRequest_Filter) ProtoReflect

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

func (*ListJobsRequest_Filter) Reset

func (x *ListJobsRequest_Filter) Reset()

func (*ListJobsRequest_Filter) String

func (x *ListJobsRequest_Filter) String() string

type ListJobsResponse

type ListJobsResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // ListJobsResult
	// contains filtered or unexported fields
}

func (*ListJobsResponse) Descriptor deprecated

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

Deprecated: Use ListJobsResponse.ProtoReflect.Descriptor instead.

func (*ListJobsResponse) GetOperation

func (x *ListJobsResponse) GetOperation() *Ydb_Operations.Operation

func (*ListJobsResponse) ProtoMessage

func (*ListJobsResponse) ProtoMessage()

func (*ListJobsResponse) ProtoReflect

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

func (*ListJobsResponse) Reset

func (x *ListJobsResponse) Reset()

func (*ListJobsResponse) String

func (x *ListJobsResponse) String() string

type ListJobsResult

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

func (*ListJobsResult) Descriptor deprecated

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

Deprecated: Use ListJobsResult.ProtoReflect.Descriptor instead.

func (*ListJobsResult) GetJob

func (x *ListJobsResult) GetJob() []*BriefJob

func (*ListJobsResult) GetNextPageToken

func (x *ListJobsResult) GetNextPageToken() string

func (*ListJobsResult) ProtoMessage

func (*ListJobsResult) ProtoMessage()

func (*ListJobsResult) ProtoReflect

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

func (*ListJobsResult) Reset

func (x *ListJobsResult) Reset()

func (*ListJobsResult) String

func (x *ListJobsResult) String() string

type ListQueriesRequest

type ListQueriesRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	PageToken       string                          `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	Limit           int32                           `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	Filter          *ListQueriesRequest_Filter      `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

Getting brief information about queries

func (*ListQueriesRequest) Descriptor deprecated

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

Deprecated: Use ListQueriesRequest.ProtoReflect.Descriptor instead.

func (*ListQueriesRequest) GetFilter

func (*ListQueriesRequest) GetLimit

func (x *ListQueriesRequest) GetLimit() int32

func (*ListQueriesRequest) GetOperationParams

func (x *ListQueriesRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*ListQueriesRequest) GetPageToken

func (x *ListQueriesRequest) GetPageToken() string

func (*ListQueriesRequest) ProtoMessage

func (*ListQueriesRequest) ProtoMessage()

func (*ListQueriesRequest) ProtoReflect

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

func (*ListQueriesRequest) Reset

func (x *ListQueriesRequest) Reset()

func (*ListQueriesRequest) String

func (x *ListQueriesRequest) String() string

type ListQueriesRequest_Filter

type ListQueriesRequest_Filter struct {
	QueryType   QueryContent_QueryType    `` /* 132-byte string literal not displayed */
	Status      []QueryMeta_ComputeStatus `protobuf:"varint,2,rep,packed,name=status,proto3,enum=FederatedQuery.QueryMeta_ComputeStatus" json:"status,omitempty"`
	Mode        []ExecuteMode             `protobuf:"varint,3,rep,packed,name=mode,proto3,enum=FederatedQuery.ExecuteMode" json:"mode,omitempty"`
	Name        string                    `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"` // queries whose name contains the filter.name substring
	CreatedByMe bool                      `protobuf:"varint,5,opt,name=created_by_me,json=createdByMe,proto3" json:"created_by_me,omitempty"`
	Visibility  Acl_Visibility            `protobuf:"varint,6,opt,name=visibility,proto3,enum=FederatedQuery.Acl_Visibility" json:"visibility,omitempty"`
	Automatic   AutomaticType             `protobuf:"varint,7,opt,name=automatic,proto3,enum=FederatedQuery.AutomaticType" json:"automatic,omitempty"`
	// contains filtered or unexported fields
}

func (*ListQueriesRequest_Filter) Descriptor deprecated

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

Deprecated: Use ListQueriesRequest_Filter.ProtoReflect.Descriptor instead.

func (*ListQueriesRequest_Filter) GetAutomatic

func (x *ListQueriesRequest_Filter) GetAutomatic() AutomaticType

func (*ListQueriesRequest_Filter) GetCreatedByMe

func (x *ListQueriesRequest_Filter) GetCreatedByMe() bool

func (*ListQueriesRequest_Filter) GetMode

func (x *ListQueriesRequest_Filter) GetMode() []ExecuteMode

func (*ListQueriesRequest_Filter) GetName

func (x *ListQueriesRequest_Filter) GetName() string

func (*ListQueriesRequest_Filter) GetQueryType

func (*ListQueriesRequest_Filter) GetStatus

func (*ListQueriesRequest_Filter) GetVisibility

func (x *ListQueriesRequest_Filter) GetVisibility() Acl_Visibility

func (*ListQueriesRequest_Filter) ProtoMessage

func (*ListQueriesRequest_Filter) ProtoMessage()

func (*ListQueriesRequest_Filter) ProtoReflect

func (*ListQueriesRequest_Filter) Reset

func (x *ListQueriesRequest_Filter) Reset()

func (*ListQueriesRequest_Filter) String

func (x *ListQueriesRequest_Filter) String() string

type ListQueriesResponse

type ListQueriesResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // ListQueriesResult
	// contains filtered or unexported fields
}

func (*ListQueriesResponse) Descriptor deprecated

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

Deprecated: Use ListQueriesResponse.ProtoReflect.Descriptor instead.

func (*ListQueriesResponse) GetOperation

func (x *ListQueriesResponse) GetOperation() *Ydb_Operations.Operation

func (*ListQueriesResponse) ProtoMessage

func (*ListQueriesResponse) ProtoMessage()

func (*ListQueriesResponse) ProtoReflect

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

func (*ListQueriesResponse) Reset

func (x *ListQueriesResponse) Reset()

func (*ListQueriesResponse) String

func (x *ListQueriesResponse) String() string

type ListQueriesResult

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

func (*ListQueriesResult) Descriptor deprecated

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

Deprecated: Use ListQueriesResult.ProtoReflect.Descriptor instead.

func (*ListQueriesResult) GetNextPageToken

func (x *ListQueriesResult) GetNextPageToken() string

func (*ListQueriesResult) GetQuery

func (x *ListQueriesResult) GetQuery() []*BriefQuery

func (*ListQueriesResult) ProtoMessage

func (*ListQueriesResult) ProtoMessage()

func (*ListQueriesResult) ProtoReflect

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

func (*ListQueriesResult) Reset

func (x *ListQueriesResult) Reset()

func (*ListQueriesResult) String

func (x *ListQueriesResult) String() string

type ModifyBindingRequest

type ModifyBindingRequest struct {
	OperationParams  *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	BindingId        string                          `protobuf:"bytes,2,opt,name=binding_id,json=bindingId,proto3" json:"binding_id,omitempty"`
	Content          *BindingContent                 `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
	PreviousRevision int64                           `protobuf:"varint,4,opt,name=previous_revision,json=previousRevision,proto3" json:"previous_revision,omitempty"`
	IdempotencyKey   string                          `protobuf:"bytes,5,opt,name=idempotency_key,json=idempotencyKey,proto3" json:"idempotency_key,omitempty"`
	// contains filtered or unexported fields
}

Change binding information. All fields must be filled in the request. The binding changes completely

func (*ModifyBindingRequest) Descriptor deprecated

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

Deprecated: Use ModifyBindingRequest.ProtoReflect.Descriptor instead.

func (*ModifyBindingRequest) GetBindingId

func (x *ModifyBindingRequest) GetBindingId() string

func (*ModifyBindingRequest) GetContent

func (x *ModifyBindingRequest) GetContent() *BindingContent

func (*ModifyBindingRequest) GetIdempotencyKey

func (x *ModifyBindingRequest) GetIdempotencyKey() string

func (*ModifyBindingRequest) GetOperationParams

func (x *ModifyBindingRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*ModifyBindingRequest) GetPreviousRevision

func (x *ModifyBindingRequest) GetPreviousRevision() int64

func (*ModifyBindingRequest) ProtoMessage

func (*ModifyBindingRequest) ProtoMessage()

func (*ModifyBindingRequest) ProtoReflect

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

func (*ModifyBindingRequest) Reset

func (x *ModifyBindingRequest) Reset()

func (*ModifyBindingRequest) String

func (x *ModifyBindingRequest) String() string

type ModifyBindingResponse

type ModifyBindingResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // ModifyBindingResult
	// contains filtered or unexported fields
}

func (*ModifyBindingResponse) Descriptor deprecated

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

Deprecated: Use ModifyBindingResponse.ProtoReflect.Descriptor instead.

func (*ModifyBindingResponse) GetOperation

func (x *ModifyBindingResponse) GetOperation() *Ydb_Operations.Operation

func (*ModifyBindingResponse) ProtoMessage

func (*ModifyBindingResponse) ProtoMessage()

func (*ModifyBindingResponse) ProtoReflect

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

func (*ModifyBindingResponse) Reset

func (x *ModifyBindingResponse) Reset()

func (*ModifyBindingResponse) String

func (x *ModifyBindingResponse) String() string

type ModifyBindingResult

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

func (*ModifyBindingResult) Descriptor deprecated

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

Deprecated: Use ModifyBindingResult.ProtoReflect.Descriptor instead.

func (*ModifyBindingResult) ProtoMessage

func (*ModifyBindingResult) ProtoMessage()

func (*ModifyBindingResult) ProtoReflect

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

func (*ModifyBindingResult) Reset

func (x *ModifyBindingResult) Reset()

func (*ModifyBindingResult) String

func (x *ModifyBindingResult) String() string

type ModifyConnectionRequest

type ModifyConnectionRequest struct {
	OperationParams  *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	ConnectionId     string                          `protobuf:"bytes,2,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	Content          *ConnectionContent              `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
	PreviousRevision int64                           `protobuf:"varint,4,opt,name=previous_revision,json=previousRevision,proto3" json:"previous_revision,omitempty"`
	IdempotencyKey   string                          `protobuf:"bytes,5,opt,name=idempotency_key,json=idempotencyKey,proto3" json:"idempotency_key,omitempty"`
	// contains filtered or unexported fields
}

Change connection information. All fields must be filled in the request. The connection changes completely

func (*ModifyConnectionRequest) Descriptor deprecated

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

Deprecated: Use ModifyConnectionRequest.ProtoReflect.Descriptor instead.

func (*ModifyConnectionRequest) GetConnectionId

func (x *ModifyConnectionRequest) GetConnectionId() string

func (*ModifyConnectionRequest) GetContent

func (x *ModifyConnectionRequest) GetContent() *ConnectionContent

func (*ModifyConnectionRequest) GetIdempotencyKey

func (x *ModifyConnectionRequest) GetIdempotencyKey() string

func (*ModifyConnectionRequest) GetOperationParams

func (x *ModifyConnectionRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*ModifyConnectionRequest) GetPreviousRevision

func (x *ModifyConnectionRequest) GetPreviousRevision() int64

func (*ModifyConnectionRequest) ProtoMessage

func (*ModifyConnectionRequest) ProtoMessage()

func (*ModifyConnectionRequest) ProtoReflect

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

func (*ModifyConnectionRequest) Reset

func (x *ModifyConnectionRequest) Reset()

func (*ModifyConnectionRequest) String

func (x *ModifyConnectionRequest) String() string

type ModifyConnectionResponse

type ModifyConnectionResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // ModifyConnectionResult
	// contains filtered or unexported fields
}

func (*ModifyConnectionResponse) Descriptor deprecated

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

Deprecated: Use ModifyConnectionResponse.ProtoReflect.Descriptor instead.

func (*ModifyConnectionResponse) GetOperation

func (*ModifyConnectionResponse) ProtoMessage

func (*ModifyConnectionResponse) ProtoMessage()

func (*ModifyConnectionResponse) ProtoReflect

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

func (*ModifyConnectionResponse) Reset

func (x *ModifyConnectionResponse) Reset()

func (*ModifyConnectionResponse) String

func (x *ModifyConnectionResponse) String() string

type ModifyConnectionResult

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

func (*ModifyConnectionResult) Descriptor deprecated

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

Deprecated: Use ModifyConnectionResult.ProtoReflect.Descriptor instead.

func (*ModifyConnectionResult) ProtoMessage

func (*ModifyConnectionResult) ProtoMessage()

func (*ModifyConnectionResult) ProtoReflect

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

func (*ModifyConnectionResult) Reset

func (x *ModifyConnectionResult) Reset()

func (*ModifyConnectionResult) String

func (x *ModifyConnectionResult) String() string

type ModifyQueryRequest

type ModifyQueryRequest struct {
	OperationParams  *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	QueryId          string                          `protobuf:"bytes,2,opt,name=query_id,json=queryId,proto3" json:"query_id,omitempty"`
	Content          *QueryContent                   `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
	ExecuteMode      ExecuteMode                     `` /* 127-byte string literal not displayed */
	Disposition      *StreamingDisposition           `protobuf:"bytes,5,opt,name=disposition,proto3" json:"disposition,omitempty"`
	StateLoadMode    StateLoadMode                   `` /* 137-byte string literal not displayed */
	PreviousRevision int64                           `protobuf:"varint,7,opt,name=previous_revision,json=previousRevision,proto3" json:"previous_revision,omitempty"`
	IdempotencyKey   string                          `protobuf:"bytes,8,opt,name=idempotency_key,json=idempotencyKey,proto3" json:"idempotency_key,omitempty"`
	// contains filtered or unexported fields
}

Change query information with launch policy option. All fields must be filled in the request. The query changes completely

func (*ModifyQueryRequest) Descriptor deprecated

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

Deprecated: Use ModifyQueryRequest.ProtoReflect.Descriptor instead.

func (*ModifyQueryRequest) GetContent

func (x *ModifyQueryRequest) GetContent() *QueryContent

func (*ModifyQueryRequest) GetDisposition

func (x *ModifyQueryRequest) GetDisposition() *StreamingDisposition

func (*ModifyQueryRequest) GetExecuteMode

func (x *ModifyQueryRequest) GetExecuteMode() ExecuteMode

func (*ModifyQueryRequest) GetIdempotencyKey

func (x *ModifyQueryRequest) GetIdempotencyKey() string

func (*ModifyQueryRequest) GetOperationParams

func (x *ModifyQueryRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*ModifyQueryRequest) GetPreviousRevision

func (x *ModifyQueryRequest) GetPreviousRevision() int64

func (*ModifyQueryRequest) GetQueryId

func (x *ModifyQueryRequest) GetQueryId() string

func (*ModifyQueryRequest) GetStateLoadMode

func (x *ModifyQueryRequest) GetStateLoadMode() StateLoadMode

func (*ModifyQueryRequest) ProtoMessage

func (*ModifyQueryRequest) ProtoMessage()

func (*ModifyQueryRequest) ProtoReflect

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

func (*ModifyQueryRequest) Reset

func (x *ModifyQueryRequest) Reset()

func (*ModifyQueryRequest) String

func (x *ModifyQueryRequest) String() string

type ModifyQueryResponse

type ModifyQueryResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // ModifyQueryResult
	// contains filtered or unexported fields
}

func (*ModifyQueryResponse) Descriptor deprecated

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

Deprecated: Use ModifyQueryResponse.ProtoReflect.Descriptor instead.

func (*ModifyQueryResponse) GetOperation

func (x *ModifyQueryResponse) GetOperation() *Ydb_Operations.Operation

func (*ModifyQueryResponse) ProtoMessage

func (*ModifyQueryResponse) ProtoMessage()

func (*ModifyQueryResponse) ProtoReflect

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

func (*ModifyQueryResponse) Reset

func (x *ModifyQueryResponse) Reset()

func (*ModifyQueryResponse) String

func (x *ModifyQueryResponse) String() string

type ModifyQueryResult

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

func (*ModifyQueryResult) Descriptor deprecated

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

Deprecated: Use ModifyQueryResult.ProtoReflect.Descriptor instead.

func (*ModifyQueryResult) ProtoMessage

func (*ModifyQueryResult) ProtoMessage()

func (*ModifyQueryResult) ProtoReflect

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

func (*ModifyQueryResult) Reset

func (x *ModifyQueryResult) Reset()

func (*ModifyQueryResult) String

func (x *ModifyQueryResult) String() string

type Monitoring

type Monitoring struct {
	Project string   `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	Cluster string   `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Auth    *IamAuth `protobuf:"bytes,3,opt,name=auth,proto3" json:"auth,omitempty"`
	// contains filtered or unexported fields
}

func (*Monitoring) Descriptor deprecated

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

Deprecated: Use Monitoring.ProtoReflect.Descriptor instead.

func (*Monitoring) GetAuth

func (x *Monitoring) GetAuth() *IamAuth

func (*Monitoring) GetCluster

func (x *Monitoring) GetCluster() string

func (*Monitoring) GetProject

func (x *Monitoring) GetProject() string

func (*Monitoring) ProtoMessage

func (*Monitoring) ProtoMessage()

func (*Monitoring) ProtoReflect

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

func (*Monitoring) Reset

func (x *Monitoring) Reset()

func (*Monitoring) String

func (x *Monitoring) String() string

type NoneAuth

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

func (*NoneAuth) Descriptor deprecated

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

Deprecated: Use NoneAuth.ProtoReflect.Descriptor instead.

func (*NoneAuth) ProtoMessage

func (*NoneAuth) ProtoMessage()

func (*NoneAuth) ProtoReflect

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

func (*NoneAuth) Reset

func (x *NoneAuth) Reset()

func (*NoneAuth) String

func (x *NoneAuth) String() string

type ObjectStorageBinding

type ObjectStorageBinding struct {
	Subset []*ObjectStorageBinding_Subset `protobuf:"bytes,1,rep,name=subset,proto3" json:"subset,omitempty"`
	// contains filtered or unexported fields
}

func (*ObjectStorageBinding) Descriptor deprecated

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

Deprecated: Use ObjectStorageBinding.ProtoReflect.Descriptor instead.

func (*ObjectStorageBinding) GetSubset

func (*ObjectStorageBinding) ProtoMessage

func (*ObjectStorageBinding) ProtoMessage()

func (*ObjectStorageBinding) ProtoReflect

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

func (*ObjectStorageBinding) Reset

func (x *ObjectStorageBinding) Reset()

func (*ObjectStorageBinding) String

func (x *ObjectStorageBinding) String() string

type ObjectStorageBinding_Subset

type ObjectStorageBinding_Subset struct {
	PathPattern   string            `protobuf:"bytes,1,opt,name=path_pattern,json=pathPattern,proto3" json:"path_pattern,omitempty"`
	Format        string            `protobuf:"bytes,2,opt,name=format,proto3" json:"format,omitempty"`
	FormatSetting map[string]string `` /* 188-byte string literal not displayed */
	Compression   string            `protobuf:"bytes,4,opt,name=compression,proto3" json:"compression,omitempty"`
	Schema        *Schema           `protobuf:"bytes,5,opt,name=schema,proto3" json:"schema,omitempty"`
	// Partition projection is used to speed up the processing of highly partitioned
	// storages and automate the management of partitions. In partition projection, partition values and
	// locations are calculated from configuration rather than read from an object storage. Depending on the
	// specific characteristics of the query and underlying data, partition projection can significantly
	// reduce query execution time if it uses partitioning constraints on partition metadata retrieval. Similar
	// functionality is implemented in Athena: https://docs.aws.amazon.com/athena/latest/ug/partition-projection.html
	// Only enum, integer and date types are supported for path generation. When using projection, there must
	// be at least one element in partitioned_by. This behavior is introduced for symmetric query usage and
	// compatibility with Athena behavior.
	//
	// Example:
	// projection = {
	// "projection.enabled" : "true", // used to enable and disable partitioning
	// "projection.city.type" : "enum", // to generate the city column, the enum type will be used (enumeration of objects separated by commas)
	// "projection.city.values" : "Washington,Roma", // column values city Washington or Roma
	// "projection.code.type" : "enum", // to generate the code column, the enum type will be used (enumeration of objects separated by commas)
	// "projection.code.values" : "0,1", // column values code 0 or 1
	// "storage.location.template" : "/${city}/${code}/${device_id}" // the template to which the generated values will be substituted
	// }
	// partitioned_by = [ "city", "device_id" ] // a subset of columns that are included in partitioning
	// - If storage.location.template and partitioned_by are specified together, then the rule from storage.location.template will be used.
	// - If only partitioned_by is specified, then the Hive Metastore format will be used for storage.location.template: "/city=${city}/device_id=${device_id}"
	// The list of paths that correspond to described projection and partitioned_by values are:
	// "/Washington/0/${device_id}", "/Washington/1/${device_id}", "/Roma/0/${device_id}", "/Roma/1/${device_id}"
	Projection map[string]string `` /* 161-byte string literal not displayed */
	// By separating the data, it is possible to limit the amount of data scanned by each query, thereby improving
	// performance and reducing costs. Therefore, user data is partition by key (in practice, this is a partition by time).
	// The partitioned_by defines the keys on which to partition data. The columns described in partitioned_by
	// must be specified in the schema. If projection is not specified, the template will be generated according to
	// partitioned_by. Similar functionality is implemented in Athena: https://docs.aws.amazon.com/athena/latest/ug/partitions.html
	//
	// Example:
	// partitioned_by = [ "city", "code", "device_id" ]
	// The corresponding storage.location.template will be as follows:
	// "/city=${city}/code=${code}/device_id=${device_id}"
	PartitionedBy []string `protobuf:"bytes,7,rep,name=partitioned_by,json=partitionedBy,proto3" json:"partitioned_by,omitempty"`
	// contains filtered or unexported fields
}

func (*ObjectStorageBinding_Subset) Descriptor deprecated

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

Deprecated: Use ObjectStorageBinding_Subset.ProtoReflect.Descriptor instead.

func (*ObjectStorageBinding_Subset) GetCompression

func (x *ObjectStorageBinding_Subset) GetCompression() string

func (*ObjectStorageBinding_Subset) GetFormat

func (x *ObjectStorageBinding_Subset) GetFormat() string

func (*ObjectStorageBinding_Subset) GetFormatSetting

func (x *ObjectStorageBinding_Subset) GetFormatSetting() map[string]string

func (*ObjectStorageBinding_Subset) GetPartitionedBy

func (x *ObjectStorageBinding_Subset) GetPartitionedBy() []string

func (*ObjectStorageBinding_Subset) GetPathPattern

func (x *ObjectStorageBinding_Subset) GetPathPattern() string

func (*ObjectStorageBinding_Subset) GetProjection

func (x *ObjectStorageBinding_Subset) GetProjection() map[string]string

func (*ObjectStorageBinding_Subset) GetSchema

func (x *ObjectStorageBinding_Subset) GetSchema() *Schema

func (*ObjectStorageBinding_Subset) ProtoMessage

func (*ObjectStorageBinding_Subset) ProtoMessage()

func (*ObjectStorageBinding_Subset) ProtoReflect

func (*ObjectStorageBinding_Subset) Reset

func (x *ObjectStorageBinding_Subset) Reset()

func (*ObjectStorageBinding_Subset) String

func (x *ObjectStorageBinding_Subset) String() string

type ObjectStorageConnection

type ObjectStorageConnection struct {
	Bucket string   `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Auth   *IamAuth `protobuf:"bytes,2,opt,name=auth,proto3" json:"auth,omitempty"`
	// contains filtered or unexported fields
}

func (*ObjectStorageConnection) Descriptor deprecated

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

Deprecated: Use ObjectStorageConnection.ProtoReflect.Descriptor instead.

func (*ObjectStorageConnection) GetAuth

func (x *ObjectStorageConnection) GetAuth() *IamAuth

func (*ObjectStorageConnection) GetBucket

func (x *ObjectStorageConnection) GetBucket() string

func (*ObjectStorageConnection) ProtoMessage

func (*ObjectStorageConnection) ProtoMessage()

func (*ObjectStorageConnection) ProtoReflect

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

func (*ObjectStorageConnection) Reset

func (x *ObjectStorageConnection) Reset()

func (*ObjectStorageConnection) String

func (x *ObjectStorageConnection) String() string

type PostgreSQLCluster

type PostgreSQLCluster struct {
	DatabaseId   string   `protobuf:"bytes,1,opt,name=database_id,json=databaseId,proto3" json:"database_id,omitempty"`
	DatabaseName string   `protobuf:"bytes,8,opt,name=database_name,json=databaseName,proto3" json:"database_name,omitempty"`
	Login        string   `protobuf:"bytes,2,opt,name=login,proto3" json:"login,omitempty"`
	Password     string   `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"`
	Schema       string   `protobuf:"bytes,9,opt,name=schema,proto3" json:"schema,omitempty"`
	Auth         *IamAuth `protobuf:"bytes,4,opt,name=auth,proto3" json:"auth,omitempty"`
	// Just for the sake of simmetry with existing ClickHouse code
	Host   string `protobuf:"bytes,5,opt,name=host,proto3" json:"host,omitempty"`
	Port   int32  `protobuf:"varint,6,opt,name=port,proto3" json:"port,omitempty"`
	Secure bool   `protobuf:"varint,7,opt,name=secure,proto3" json:"secure,omitempty"`
	// contains filtered or unexported fields
}

func (*PostgreSQLCluster) Descriptor deprecated

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

Deprecated: Use PostgreSQLCluster.ProtoReflect.Descriptor instead.

func (*PostgreSQLCluster) GetAuth

func (x *PostgreSQLCluster) GetAuth() *IamAuth

func (*PostgreSQLCluster) GetDatabaseId

func (x *PostgreSQLCluster) GetDatabaseId() string

func (*PostgreSQLCluster) GetDatabaseName

func (x *PostgreSQLCluster) GetDatabaseName() string

func (*PostgreSQLCluster) GetHost

func (x *PostgreSQLCluster) GetHost() string

func (*PostgreSQLCluster) GetLogin

func (x *PostgreSQLCluster) GetLogin() string

func (*PostgreSQLCluster) GetPassword

func (x *PostgreSQLCluster) GetPassword() string

func (*PostgreSQLCluster) GetPort

func (x *PostgreSQLCluster) GetPort() int32

func (*PostgreSQLCluster) GetSchema

func (x *PostgreSQLCluster) GetSchema() string

func (*PostgreSQLCluster) GetSecure

func (x *PostgreSQLCluster) GetSecure() bool

func (*PostgreSQLCluster) ProtoMessage

func (*PostgreSQLCluster) ProtoMessage()

func (*PostgreSQLCluster) ProtoReflect

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

func (*PostgreSQLCluster) Reset

func (x *PostgreSQLCluster) Reset()

func (*PostgreSQLCluster) String

func (x *PostgreSQLCluster) String() string

type Query

type Query struct {
	Meta           *QueryMeta                `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	Content        *QueryContent             `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	Plan           *QueryPlan                `protobuf:"bytes,3,opt,name=plan,proto3" json:"plan,omitempty"`
	Issue          []*Ydb_Issue.IssueMessage `protobuf:"bytes,4,rep,name=issue,proto3" json:"issue,omitempty"`
	TransientIssue []*Ydb_Issue.IssueMessage `protobuf:"bytes,5,rep,name=transient_issue,json=transientIssue,proto3" json:"transient_issue,omitempty"`
	Statistics     *QueryStatistics          `protobuf:"bytes,6,opt,name=statistics,proto3" json:"statistics,omitempty"`
	ResultSetMeta  []*ResultSetMeta          `protobuf:"bytes,7,rep,name=result_set_meta,json=resultSetMeta,proto3" json:"result_set_meta,omitempty"`
	Ast            *QueryAst                 `protobuf:"bytes,8,opt,name=ast,proto3" json:"ast,omitempty"`
	// contains filtered or unexported fields
}

func (*Query) Descriptor deprecated

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

Deprecated: Use Query.ProtoReflect.Descriptor instead.

func (*Query) GetAst

func (x *Query) GetAst() *QueryAst

func (*Query) GetContent

func (x *Query) GetContent() *QueryContent

func (*Query) GetIssue

func (x *Query) GetIssue() []*Ydb_Issue.IssueMessage

func (*Query) GetMeta

func (x *Query) GetMeta() *QueryMeta

func (*Query) GetPlan

func (x *Query) GetPlan() *QueryPlan

func (*Query) GetResultSetMeta

func (x *Query) GetResultSetMeta() []*ResultSetMeta

func (*Query) GetStatistics

func (x *Query) GetStatistics() *QueryStatistics

func (*Query) GetTransientIssue

func (x *Query) GetTransientIssue() []*Ydb_Issue.IssueMessage

func (*Query) ProtoMessage

func (*Query) ProtoMessage()

func (*Query) ProtoReflect

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

func (*Query) Reset

func (x *Query) Reset()

func (*Query) String

func (x *Query) String() string

type QueryAction

type QueryAction int32
const (
	QueryAction_QUERY_ACTION_UNSPECIFIED QueryAction = 0
	QueryAction_PAUSE                    QueryAction = 1 // Pause the query, with the possibility of its quick resumption
	QueryAction_PAUSE_GRACEFULLY         QueryAction = 2 // Similar to PAUSE, only suspends the query allowing it to pause in checkpoint. Can work for a long time
	QueryAction_ABORT                    QueryAction = 3 // Stop the query
	QueryAction_ABORT_GRACEFULLY         QueryAction = 4 // Similar to ABORT, only stops the query in checkpoint
	QueryAction_RESUME                   QueryAction = 5 // Resumes the execution of the query. Works only for PAUSE queries
)

func (QueryAction) Descriptor

func (QueryAction) Enum

func (x QueryAction) Enum() *QueryAction

func (QueryAction) EnumDescriptor deprecated

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

Deprecated: Use QueryAction.Descriptor instead.

func (QueryAction) Number

func (x QueryAction) Number() protoreflect.EnumNumber

func (QueryAction) String

func (x QueryAction) String() string

func (QueryAction) Type

type QueryAst

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

func (*QueryAst) Descriptor deprecated

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

Deprecated: Use QueryAst.ProtoReflect.Descriptor instead.

func (*QueryAst) GetData

func (x *QueryAst) GetData() string

func (*QueryAst) ProtoMessage

func (*QueryAst) ProtoMessage()

func (*QueryAst) ProtoReflect

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

func (*QueryAst) Reset

func (x *QueryAst) Reset()

func (*QueryAst) String

func (x *QueryAst) String() string

type QueryContent

type QueryContent struct {
	Type        QueryContent_QueryType `protobuf:"varint,1,opt,name=type,proto3,enum=FederatedQuery.QueryContent_QueryType" json:"type,omitempty"`
	Name        string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Acl         *Acl                   `protobuf:"bytes,3,opt,name=acl,proto3" json:"acl,omitempty"`
	Limits      *Limits                `protobuf:"bytes,4,opt,name=limits,proto3" json:"limits,omitempty"`
	Text        string                 `protobuf:"bytes,5,opt,name=text,proto3" json:"text,omitempty"`               // The text of the query itself
	Automatic   bool                   `protobuf:"varint,6,opt,name=automatic,proto3" json:"automatic,omitempty"`    // Is used for queries that are created by automatic systems (robots, jdbc driver, ...)
	Description string                 `protobuf:"bytes,7,opt,name=description,proto3" json:"description,omitempty"` // Description of the query, there can be any text
	// Specified settings for query's executor
	// Well known settings are:
	// "executor" - type of executor for this query
	ExecutionSettings map[string]string `` /* 201-byte string literal not displayed */
	// Syntax of the text
	// By default it is "yql", but additional syntax "pg" (PostreSQL SQL frontend) is supported as well
	Syntax QueryContent_QuerySyntax `protobuf:"varint,11,opt,name=syntax,proto3,enum=FederatedQuery.QueryContent_QuerySyntax" json:"syntax,omitempty"`
	// contains filtered or unexported fields
}

Query information that the subject can change

func (*QueryContent) Descriptor deprecated

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

Deprecated: Use QueryContent.ProtoReflect.Descriptor instead.

func (*QueryContent) GetAcl

func (x *QueryContent) GetAcl() *Acl

func (*QueryContent) GetAutomatic

func (x *QueryContent) GetAutomatic() bool

func (*QueryContent) GetDescription

func (x *QueryContent) GetDescription() string

func (*QueryContent) GetExecutionSettings

func (x *QueryContent) GetExecutionSettings() map[string]string

func (*QueryContent) GetLimits

func (x *QueryContent) GetLimits() *Limits

func (*QueryContent) GetName

func (x *QueryContent) GetName() string

func (*QueryContent) GetSyntax

func (x *QueryContent) GetSyntax() QueryContent_QuerySyntax

func (*QueryContent) GetText

func (x *QueryContent) GetText() string

func (*QueryContent) GetType

func (x *QueryContent) GetType() QueryContent_QueryType

func (*QueryContent) ProtoMessage

func (*QueryContent) ProtoMessage()

func (*QueryContent) ProtoReflect

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

func (*QueryContent) Reset

func (x *QueryContent) Reset()

func (*QueryContent) String

func (x *QueryContent) String() string

type QueryContent_QuerySyntax

type QueryContent_QuerySyntax int32
const (
	QueryContent_QUERY_SYNTAX_UNSPECIFIED QueryContent_QuerySyntax = 0
	QueryContent_YQL_V1                   QueryContent_QuerySyntax = 1 // YQL version 1
	QueryContent_PG                       QueryContent_QuerySyntax = 2 // PostgresQL
)

func (QueryContent_QuerySyntax) Descriptor

func (QueryContent_QuerySyntax) Enum

func (QueryContent_QuerySyntax) EnumDescriptor deprecated

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

Deprecated: Use QueryContent_QuerySyntax.Descriptor instead.

func (QueryContent_QuerySyntax) Number

func (QueryContent_QuerySyntax) String

func (x QueryContent_QuerySyntax) String() string

func (QueryContent_QuerySyntax) Type

type QueryContent_QueryType

type QueryContent_QueryType int32
const (
	QueryContent_QUERY_TYPE_UNSPECIFIED QueryContent_QueryType = 0
	QueryContent_ANALYTICS              QueryContent_QueryType = 1 // Analytical query (used for analytical data processing for example to work with YDB, ClickHouse, ...)
	QueryContent_STREAMING              QueryContent_QueryType = 2 // Streaming query (used for streaming data processing, such as working with YDS)
)

func (QueryContent_QueryType) Descriptor

func (QueryContent_QueryType) Enum

func (QueryContent_QueryType) EnumDescriptor deprecated

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

Deprecated: Use QueryContent_QueryType.Descriptor instead.

func (QueryContent_QueryType) Number

func (QueryContent_QueryType) String

func (x QueryContent_QueryType) String() string

func (QueryContent_QueryType) Type

type QueryMeta

type QueryMeta struct {
	Common *CommonMeta `protobuf:"bytes,1,opt,name=common,proto3" json:"common,omitempty"`
	// Timeline (submitted_at <= started_at <= finished_at)
	//
	//	sumbitted_at
	//	           \ -> started_at
	//	                            \ -> finished_at
	SubmittedAt          *timestamppb.Timestamp  `protobuf:"bytes,14,opt,name=submitted_at,json=submittedAt,proto3" json:"submitted_at,omitempty"` // Time when the query was queued for execution
	StartedAt            *timestamppb.Timestamp  `protobuf:"bytes,2,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`        // Start time of query execution
	FinishedAt           *timestamppb.Timestamp  `protobuf:"bytes,3,opt,name=finished_at,json=finishedAt,proto3" json:"finished_at,omitempty"`     // Query completition time
	ExecuteMode          ExecuteMode             ``                                                                                                /* 127-byte string literal not displayed */
	Status               QueryMeta_ComputeStatus `protobuf:"varint,5,opt,name=status,proto3,enum=FederatedQuery.QueryMeta_ComputeStatus" json:"status,omitempty"`
	LastJobQueryRevision int64                   `` /* 126-byte string literal not displayed */
	LastJobId            string                  `protobuf:"bytes,7,opt,name=last_job_id,json=lastJobId,proto3" json:"last_job_id,omitempty"`
	ExpireAt             *timestamppb.Timestamp  `protobuf:"bytes,8,opt,name=expire_at,json=expireAt,proto3" json:"expire_at,omitempty"`
	ResultExpireAt       *timestamppb.Timestamp  `protobuf:"bytes,9,opt,name=result_expire_at,json=resultExpireAt,proto3" json:"result_expire_at,omitempty"`
	StartedBy            string                  `protobuf:"bytes,10,opt,name=started_by,json=startedBy,proto3" json:"started_by,omitempty"`
	// Types that are assignable to Action:
	//
	//	*QueryMeta_AbortedBy
	//	*QueryMeta_PausedBy
	Action isQueryMeta_Action `protobuf_oneof:"action"`
	// One of the versions of this query has fully saved checkpoint.
	// If this flag is not set streaming disposition mode "from last checkpoint" can't be used.
	HasSavedCheckpoints bool `protobuf:"varint,13,opt,name=has_saved_checkpoints,json=hasSavedCheckpoints,proto3" json:"has_saved_checkpoints,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryMeta) Descriptor deprecated

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

Deprecated: Use QueryMeta.ProtoReflect.Descriptor instead.

func (*QueryMeta) GetAbortedBy

func (x *QueryMeta) GetAbortedBy() string

func (*QueryMeta) GetAction

func (m *QueryMeta) GetAction() isQueryMeta_Action

func (*QueryMeta) GetCommon

func (x *QueryMeta) GetCommon() *CommonMeta

func (*QueryMeta) GetExecuteMode

func (x *QueryMeta) GetExecuteMode() ExecuteMode

func (*QueryMeta) GetExpireAt

func (x *QueryMeta) GetExpireAt() *timestamppb.Timestamp

func (*QueryMeta) GetFinishedAt

func (x *QueryMeta) GetFinishedAt() *timestamppb.Timestamp

func (*QueryMeta) GetHasSavedCheckpoints

func (x *QueryMeta) GetHasSavedCheckpoints() bool

func (*QueryMeta) GetLastJobId

func (x *QueryMeta) GetLastJobId() string

func (*QueryMeta) GetLastJobQueryRevision

func (x *QueryMeta) GetLastJobQueryRevision() int64

func (*QueryMeta) GetPausedBy

func (x *QueryMeta) GetPausedBy() string

func (*QueryMeta) GetResultExpireAt

func (x *QueryMeta) GetResultExpireAt() *timestamppb.Timestamp

func (*QueryMeta) GetStartedAt

func (x *QueryMeta) GetStartedAt() *timestamppb.Timestamp

func (*QueryMeta) GetStartedBy

func (x *QueryMeta) GetStartedBy() string

func (*QueryMeta) GetStatus

func (x *QueryMeta) GetStatus() QueryMeta_ComputeStatus

func (*QueryMeta) GetSubmittedAt

func (x *QueryMeta) GetSubmittedAt() *timestamppb.Timestamp

func (*QueryMeta) ProtoMessage

func (*QueryMeta) ProtoMessage()

func (*QueryMeta) ProtoReflect

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

func (*QueryMeta) Reset

func (x *QueryMeta) Reset()

func (*QueryMeta) String

func (x *QueryMeta) String() string

type QueryMeta_AbortedBy

type QueryMeta_AbortedBy struct {
	AbortedBy string `protobuf:"bytes,11,opt,name=aborted_by,json=abortedBy,proto3,oneof"`
}

type QueryMeta_ComputeStatus

type QueryMeta_ComputeStatus int32
const (
	QueryMeta_COMPUTE_STATUS_UNSPECIFIED QueryMeta_ComputeStatus = 0
	QueryMeta_STARTING                   QueryMeta_ComputeStatus = 1  // Start execution of the action on query
	QueryMeta_ABORTED_BY_USER            QueryMeta_ComputeStatus = 2  // Query aborted by user
	QueryMeta_ABORTED_BY_SYSTEM          QueryMeta_ComputeStatus = 3  // Query aborted by system
	QueryMeta_ABORTING_BY_USER           QueryMeta_ComputeStatus = 4  // Query aborting by user
	QueryMeta_ABORTING_BY_SYSTEM         QueryMeta_ComputeStatus = 5  // Query aborting by system
	QueryMeta_RESUMING                   QueryMeta_ComputeStatus = 6  // Resuming query execution from PAUSED status
	QueryMeta_RUNNING                    QueryMeta_ComputeStatus = 7  // Query started for execution
	QueryMeta_COMPLETED                  QueryMeta_ComputeStatus = 8  // Query completed successfully
	QueryMeta_COMPLETING                 QueryMeta_ComputeStatus = 12 // Finalizing query before become COMPLETED
	QueryMeta_FAILED                     QueryMeta_ComputeStatus = 9  // Query completed with errors
	QueryMeta_FAILING                    QueryMeta_ComputeStatus = 13 // Finalizing query before become FAILED
	QueryMeta_PAUSED                     QueryMeta_ComputeStatus = 11 // Query paused
	QueryMeta_PAUSING                    QueryMeta_ComputeStatus = 10 // Query starts pausing
)

func (QueryMeta_ComputeStatus) Descriptor

func (QueryMeta_ComputeStatus) Enum

func (QueryMeta_ComputeStatus) EnumDescriptor deprecated

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

Deprecated: Use QueryMeta_ComputeStatus.Descriptor instead.

func (QueryMeta_ComputeStatus) Number

func (QueryMeta_ComputeStatus) String

func (x QueryMeta_ComputeStatus) String() string

func (QueryMeta_ComputeStatus) Type

type QueryMeta_PausedBy

type QueryMeta_PausedBy struct {
	PausedBy string `protobuf:"bytes,12,opt,name=paused_by,json=pausedBy,proto3,oneof"`
}

type QueryPlan

type QueryPlan struct {
	Json string `protobuf:"bytes,1,opt,name=json,proto3" json:"json,omitempty"` // No validation because generated on server side
	// contains filtered or unexported fields
}

func (*QueryPlan) Descriptor deprecated

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

Deprecated: Use QueryPlan.ProtoReflect.Descriptor instead.

func (*QueryPlan) GetJson

func (x *QueryPlan) GetJson() string

func (*QueryPlan) ProtoMessage

func (*QueryPlan) ProtoMessage()

func (*QueryPlan) ProtoReflect

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

func (*QueryPlan) Reset

func (x *QueryPlan) Reset()

func (*QueryPlan) String

func (x *QueryPlan) String() string

type QueryStatistics

type QueryStatistics struct {
	Json string `protobuf:"bytes,1,opt,name=json,proto3" json:"json,omitempty"` // No validation because generated on server side
	// contains filtered or unexported fields
}

func (*QueryStatistics) Descriptor deprecated

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

Deprecated: Use QueryStatistics.ProtoReflect.Descriptor instead.

func (*QueryStatistics) GetJson

func (x *QueryStatistics) GetJson() string

func (*QueryStatistics) ProtoMessage

func (*QueryStatistics) ProtoMessage()

func (*QueryStatistics) ProtoReflect

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

func (*QueryStatistics) Reset

func (x *QueryStatistics) Reset()

func (*QueryStatistics) String

func (x *QueryStatistics) String() string

type ResultSetMeta

type ResultSetMeta struct {
	Column    []*Ydb.Column `protobuf:"bytes,1,rep,name=column,proto3" json:"column,omitempty"`
	RowsCount int64         `protobuf:"varint,2,opt,name=rows_count,json=rowsCount,proto3" json:"rows_count,omitempty"`
	Truncated bool          `protobuf:"varint,3,opt,name=truncated,proto3" json:"truncated,omitempty"`
	// contains filtered or unexported fields
}

func (*ResultSetMeta) Descriptor deprecated

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

Deprecated: Use ResultSetMeta.ProtoReflect.Descriptor instead.

func (*ResultSetMeta) GetColumn

func (x *ResultSetMeta) GetColumn() []*Ydb.Column

func (*ResultSetMeta) GetRowsCount

func (x *ResultSetMeta) GetRowsCount() int64

func (*ResultSetMeta) GetTruncated

func (x *ResultSetMeta) GetTruncated() bool

func (*ResultSetMeta) ProtoMessage

func (*ResultSetMeta) ProtoMessage()

func (*ResultSetMeta) ProtoReflect

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

func (*ResultSetMeta) Reset

func (x *ResultSetMeta) Reset()

func (*ResultSetMeta) String

func (x *ResultSetMeta) String() string

type Schema

type Schema struct {
	Column []*Ydb.Column `protobuf:"bytes,1,rep,name=column,proto3" json:"column,omitempty"`
	// contains filtered or unexported fields
}

func (*Schema) Descriptor deprecated

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

Deprecated: Use Schema.ProtoReflect.Descriptor instead.

func (*Schema) GetColumn

func (x *Schema) GetColumn() []*Ydb.Column

func (*Schema) ProtoMessage

func (*Schema) ProtoMessage()

func (*Schema) ProtoReflect

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

func (*Schema) Reset

func (x *Schema) Reset()

func (*Schema) String

func (x *Schema) String() string

type ServiceAccountAuth

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

func (*ServiceAccountAuth) Descriptor deprecated

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

Deprecated: Use ServiceAccountAuth.ProtoReflect.Descriptor instead.

func (*ServiceAccountAuth) GetId

func (x *ServiceAccountAuth) GetId() string

func (*ServiceAccountAuth) ProtoMessage

func (*ServiceAccountAuth) ProtoMessage()

func (*ServiceAccountAuth) ProtoReflect

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

func (*ServiceAccountAuth) Reset

func (x *ServiceAccountAuth) Reset()

func (*ServiceAccountAuth) String

func (x *ServiceAccountAuth) String() string

type StateLoadMode

type StateLoadMode int32
const (
	StateLoadMode_STATE_LOAD_MODE_UNSPECIFIED StateLoadMode = 0
	StateLoadMode_EMPTY                       StateLoadMode = 1 // Start the query with an empty state
	StateLoadMode_FROM_LAST_CHECKPOINT        StateLoadMode = 2 // Start the query with the state that is saved in the last checkpoint
)

func (StateLoadMode) Descriptor

func (StateLoadMode) Enum

func (x StateLoadMode) Enum() *StateLoadMode

func (StateLoadMode) EnumDescriptor deprecated

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

Deprecated: Use StateLoadMode.Descriptor instead.

func (StateLoadMode) Number

func (StateLoadMode) String

func (x StateLoadMode) String() string

func (StateLoadMode) Type

type StreamingDisposition

type StreamingDisposition struct {

	// Types that are assignable to Disposition:
	//
	//	*StreamingDisposition_Oldest
	//	*StreamingDisposition_Fresh
	//	*StreamingDisposition_FromTime_
	//	*StreamingDisposition_TimeAgo_
	//	*StreamingDisposition_FromLastCheckpoint_
	Disposition isStreamingDisposition_Disposition `protobuf_oneof:"disposition"`
	// contains filtered or unexported fields
}

For streaming queries only

func (*StreamingDisposition) Descriptor deprecated

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

Deprecated: Use StreamingDisposition.ProtoReflect.Descriptor instead.

func (*StreamingDisposition) GetDisposition

func (m *StreamingDisposition) GetDisposition() isStreamingDisposition_Disposition

func (*StreamingDisposition) GetFresh

func (x *StreamingDisposition) GetFresh() *emptypb.Empty

func (*StreamingDisposition) GetFromLastCheckpoint

func (*StreamingDisposition) GetFromTime

func (*StreamingDisposition) GetOldest

func (x *StreamingDisposition) GetOldest() *emptypb.Empty

func (*StreamingDisposition) GetTimeAgo

func (*StreamingDisposition) ProtoMessage

func (*StreamingDisposition) ProtoMessage()

func (*StreamingDisposition) ProtoReflect

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

func (*StreamingDisposition) Reset

func (x *StreamingDisposition) Reset()

func (*StreamingDisposition) String

func (x *StreamingDisposition) String() string

type StreamingDisposition_Fresh

type StreamingDisposition_Fresh struct {
	Fresh *emptypb.Empty `protobuf:"bytes,2,opt,name=fresh,proto3,oneof"` // Start processing with the fresh offset
}

type StreamingDisposition_FromLastCheckpoint

type StreamingDisposition_FromLastCheckpoint struct {

	// By default if new query streams set doesn't equal to old query streams set,
	// error will occur and query won't be allowed to load offsets for streams for the last checkpoint.
	// If this flag is set all offsets that can be matched with previous query checkpoint will be matched.
	// Others will use "fresh" streaming disposition.
	Force bool `protobuf:"varint,1,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamingDisposition_FromLastCheckpoint) Descriptor deprecated

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

Deprecated: Use StreamingDisposition_FromLastCheckpoint.ProtoReflect.Descriptor instead.

func (*StreamingDisposition_FromLastCheckpoint) GetForce

func (*StreamingDisposition_FromLastCheckpoint) ProtoMessage

func (*StreamingDisposition_FromLastCheckpoint) ProtoReflect

func (*StreamingDisposition_FromLastCheckpoint) Reset

func (*StreamingDisposition_FromLastCheckpoint) String

type StreamingDisposition_FromLastCheckpoint_

type StreamingDisposition_FromLastCheckpoint_ struct {
	FromLastCheckpoint *StreamingDisposition_FromLastCheckpoint `protobuf:"bytes,5,opt,name=from_last_checkpoint,json=fromLastCheckpoint,proto3,oneof"` // Start processing with offset which corresponds to the last checkpoint
}

type StreamingDisposition_FromTime

type StreamingDisposition_FromTime struct {
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamingDisposition_FromTime) Descriptor deprecated

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

Deprecated: Use StreamingDisposition_FromTime.ProtoReflect.Descriptor instead.

func (*StreamingDisposition_FromTime) GetTimestamp

func (*StreamingDisposition_FromTime) ProtoMessage

func (*StreamingDisposition_FromTime) ProtoMessage()

func (*StreamingDisposition_FromTime) ProtoReflect

func (*StreamingDisposition_FromTime) Reset

func (x *StreamingDisposition_FromTime) Reset()

func (*StreamingDisposition_FromTime) String

type StreamingDisposition_FromTime_

type StreamingDisposition_FromTime_ struct {
	FromTime *StreamingDisposition_FromTime `protobuf:"bytes,3,opt,name=from_time,json=fromTime,proto3,oneof"` // Start processing with offset from the specified time
}

type StreamingDisposition_Oldest

type StreamingDisposition_Oldest struct {
	Oldest *emptypb.Empty `protobuf:"bytes,1,opt,name=oldest,proto3,oneof"` // Start processing with the oldest offset
}

type StreamingDisposition_TimeAgo

type StreamingDisposition_TimeAgo struct {
	Duration *durationpb.Duration `protobuf:"bytes,1,opt,name=duration,proto3" json:"duration,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamingDisposition_TimeAgo) Descriptor deprecated

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

Deprecated: Use StreamingDisposition_TimeAgo.ProtoReflect.Descriptor instead.

func (*StreamingDisposition_TimeAgo) GetDuration

func (*StreamingDisposition_TimeAgo) ProtoMessage

func (*StreamingDisposition_TimeAgo) ProtoMessage()

func (*StreamingDisposition_TimeAgo) ProtoReflect

func (*StreamingDisposition_TimeAgo) Reset

func (x *StreamingDisposition_TimeAgo) Reset()

func (*StreamingDisposition_TimeAgo) String

type StreamingDisposition_TimeAgo_

type StreamingDisposition_TimeAgo_ struct {
	TimeAgo *StreamingDisposition_TimeAgo `protobuf:"bytes,4,opt,name=time_ago,json=timeAgo,proto3,oneof"` // Start processing with offset some time ago
}

type TestConnectionRequest

type TestConnectionRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	Setting         *ConnectionSetting              `protobuf:"bytes,2,opt,name=setting,proto3" json:"setting,omitempty"`
	// contains filtered or unexported fields
}

func (*TestConnectionRequest) Descriptor deprecated

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

Deprecated: Use TestConnectionRequest.ProtoReflect.Descriptor instead.

func (*TestConnectionRequest) GetOperationParams

func (x *TestConnectionRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*TestConnectionRequest) GetSetting

func (x *TestConnectionRequest) GetSetting() *ConnectionSetting

func (*TestConnectionRequest) ProtoMessage

func (*TestConnectionRequest) ProtoMessage()

func (*TestConnectionRequest) ProtoReflect

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

func (*TestConnectionRequest) Reset

func (x *TestConnectionRequest) Reset()

func (*TestConnectionRequest) String

func (x *TestConnectionRequest) String() string

type TestConnectionResponse

type TestConnectionResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` // TestConnectionResult
	// contains filtered or unexported fields
}

func (*TestConnectionResponse) Descriptor deprecated

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

Deprecated: Use TestConnectionResponse.ProtoReflect.Descriptor instead.

func (*TestConnectionResponse) GetOperation

func (x *TestConnectionResponse) GetOperation() *Ydb_Operations.Operation

func (*TestConnectionResponse) ProtoMessage

func (*TestConnectionResponse) ProtoMessage()

func (*TestConnectionResponse) ProtoReflect

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

func (*TestConnectionResponse) Reset

func (x *TestConnectionResponse) Reset()

func (*TestConnectionResponse) String

func (x *TestConnectionResponse) String() string

type TestConnectionResult

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

func (*TestConnectionResult) Descriptor deprecated

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

Deprecated: Use TestConnectionResult.ProtoReflect.Descriptor instead.

func (*TestConnectionResult) ProtoMessage

func (*TestConnectionResult) ProtoMessage()

func (*TestConnectionResult) ProtoReflect

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

func (*TestConnectionResult) Reset

func (x *TestConnectionResult) Reset()

func (*TestConnectionResult) String

func (x *TestConnectionResult) String() string

type YdbDatabase

type YdbDatabase struct {
	DatabaseId string   `protobuf:"bytes,1,opt,name=database_id,json=databaseId,proto3" json:"database_id,omitempty"`
	Auth       *IamAuth `protobuf:"bytes,2,opt,name=auth,proto3" json:"auth,omitempty"`
	// for internal usage
	Endpoint string `protobuf:"bytes,3,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Database string `protobuf:"bytes,4,opt,name=database,proto3" json:"database,omitempty"`
	Secure   bool   `protobuf:"varint,5,opt,name=secure,proto3" json:"secure,omitempty"`
	// contains filtered or unexported fields
}

func (*YdbDatabase) Descriptor deprecated

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

Deprecated: Use YdbDatabase.ProtoReflect.Descriptor instead.

func (*YdbDatabase) GetAuth

func (x *YdbDatabase) GetAuth() *IamAuth

func (*YdbDatabase) GetDatabase

func (x *YdbDatabase) GetDatabase() string

func (*YdbDatabase) GetDatabaseId

func (x *YdbDatabase) GetDatabaseId() string

func (*YdbDatabase) GetEndpoint

func (x *YdbDatabase) GetEndpoint() string

func (*YdbDatabase) GetSecure

func (x *YdbDatabase) GetSecure() bool

func (*YdbDatabase) ProtoMessage

func (*YdbDatabase) ProtoMessage()

func (*YdbDatabase) ProtoReflect

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

func (*YdbDatabase) Reset

func (x *YdbDatabase) Reset()

func (*YdbDatabase) String

func (x *YdbDatabase) String() string

Jump to

Keyboard shortcuts

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