Ydb_FederatedQuery

package
v0.0.0-...-ea1f632 Latest Latest
Warning

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

 Go to latest Published: Nov 12, 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) Descriptor() protoreflect.EnumDescriptor

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 (x Acl_Visibility) Number() protoreflect.EnumNumber

func (Acl_Visibility) String 

func (x Acl_Visibility) String() string

func (Acl_Visibility) Type 

func (Acl_Visibility) Type() protoreflect.EnumType

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) Descriptor() protoreflect.EnumDescriptor

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 (x AutomaticType) Number() protoreflect.EnumNumber

func (AutomaticType) String 

func (x AutomaticType) String() string

func (AutomaticType) Type 

func (AutomaticType) Type() protoreflect.EnumType

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) Descriptor() protoreflect.EnumDescriptor

func (BindingSetting_BindingType) Enum 

func (x BindingSetting_BindingType) Enum() *BindingSetting_BindingType

func (BindingSetting_BindingType) EnumDescriptor deprecated 

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

Deprecated: Use BindingSetting_BindingType.Descriptor instead.

func (BindingSetting_BindingType) Number 

func (x BindingSetting_BindingType) Number() protoreflect.EnumNumber

func (BindingSetting_BindingType) String 

func (x BindingSetting_BindingType) String() string

func (BindingSetting_BindingType) Type 

func (BindingSetting_BindingType) Type() protoreflect.EnumType

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 (x *BriefBinding) GetType() BindingSetting_BindingType

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) Descriptor() protoreflect.EnumDescriptor

func (ConnectionSetting_ConnectionType) Enum 

func (x ConnectionSetting_ConnectionType) Enum() *ConnectionSetting_ConnectionType

func (ConnectionSetting_ConnectionType) EnumDescriptor deprecated 

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

Deprecated: Use ConnectionSetting_ConnectionType.Descriptor instead.

func (ConnectionSetting_ConnectionType) Number 

func (x ConnectionSetting_ConnectionType) Number() protoreflect.EnumNumber

func (ConnectionSetting_ConnectionType) String 

func (x ConnectionSetting_ConnectionType) String() string

func (ConnectionSetting_ConnectionType) Type 

func (ConnectionSetting_ConnectionType) Type() protoreflect.EnumType

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 (x *CreateConnectionResponse) GetOperation() *Ydb_Operations.Operation

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 (x *DeleteConnectionResponse) GetOperation() *Ydb_Operations.Operation

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 (x *DescribeBindingResponse) GetOperation() *Ydb_Operations.Operation

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 (x *DescribeConnectionRequest) ProtoReflect() protoreflect.Message

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 (x *DescribeConnectionResponse) GetOperation() *Ydb_Operations.Operation

func (*DescribeConnectionResponse) ProtoMessage 

func (*DescribeConnectionResponse) ProtoMessage()

func (*DescribeConnectionResponse) ProtoReflect 

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

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) Descriptor() protoreflect.EnumDescriptor

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 

func (ExecuteMode) Type() protoreflect.EnumType

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 (x *GetQueryStatusResult) GetStatus() QueryMeta_ComputeStatus

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 (x *ListBindingsRequest) GetFilter() *ListBindingsRequest_Filter

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 (x *ListBindingsRequest_Filter) ProtoReflect() protoreflect.Message

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 (x *ListConnectionsRequest) GetFilter() *ListConnectionsRequest_Filter

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 (x *ListConnectionsRequest_Filter) GetConnectionType() ConnectionSetting_ConnectionType

func (*ListConnectionsRequest_Filter) GetCreatedByMe 

func (x *ListConnectionsRequest_Filter) GetCreatedByMe() bool

func (*ListConnectionsRequest_Filter) GetName 

func (x *ListConnectionsRequest_Filter) GetName() string

func (*ListConnectionsRequest_Filter) GetVisibility 

func (x *ListConnectionsRequest_Filter) GetVisibility() Acl_Visibility

func (*ListConnectionsRequest_Filter) ProtoMessage 

func (*ListConnectionsRequest_Filter) ProtoMessage()

func (*ListConnectionsRequest_Filter) ProtoReflect 

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

func (*ListConnectionsRequest_Filter) Reset 

func (x *ListConnectionsRequest_Filter) Reset()

func (*ListConnectionsRequest_Filter) String 

func (x *ListConnectionsRequest_Filter) String() 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 (x *ListConnectionsResponse) GetOperation() *Ydb_Operations.Operation

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 (x *ListQueriesRequest) GetFilter() *ListQueriesRequest_Filter

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 (x *ListQueriesRequest_Filter) GetQueryType() QueryContent_QueryType

func (*ListQueriesRequest_Filter) GetStatus 

func (x *ListQueriesRequest_Filter) GetStatus() []QueryMeta_ComputeStatus

func (*ListQueriesRequest_Filter) GetVisibility 

func (x *ListQueriesRequest_Filter) GetVisibility() Acl_Visibility

func (*ListQueriesRequest_Filter) ProtoMessage 

func (*ListQueriesRequest_Filter) ProtoMessage()

func (*ListQueriesRequest_Filter) ProtoReflect 

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

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 (x *ModifyConnectionResponse) GetOperation() *Ydb_Operations.Operation

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 (x *ObjectStorageBinding) GetSubset() []*ObjectStorageBinding_Subset

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 (x *ObjectStorageBinding_Subset) ProtoReflect() protoreflect.Message

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) Descriptor() protoreflect.EnumDescriptor

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 

func (QueryAction) Type() protoreflect.EnumType

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) Descriptor() protoreflect.EnumDescriptor

func (QueryContent_QuerySyntax) Enum 

func (x QueryContent_QuerySyntax) Enum() *QueryContent_QuerySyntax

func (QueryContent_QuerySyntax) EnumDescriptor deprecated 

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

Deprecated: Use QueryContent_QuerySyntax.Descriptor instead.

func (QueryContent_QuerySyntax) Number 

func (x QueryContent_QuerySyntax) Number() protoreflect.EnumNumber

func (QueryContent_QuerySyntax) String 

func (x QueryContent_QuerySyntax) String() string

func (QueryContent_QuerySyntax) Type 

func (QueryContent_QuerySyntax) Type() protoreflect.EnumType

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) Descriptor() protoreflect.EnumDescriptor

func (QueryContent_QueryType) Enum 

func (x QueryContent_QueryType) Enum() *QueryContent_QueryType

func (QueryContent_QueryType) EnumDescriptor deprecated 

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

Deprecated: Use QueryContent_QueryType.Descriptor instead.

func (QueryContent_QueryType) Number 

func (x QueryContent_QueryType) Number() protoreflect.EnumNumber

func (QueryContent_QueryType) String 

func (x QueryContent_QueryType) String() string

func (QueryContent_QueryType) Type 

func (QueryContent_QueryType) Type() protoreflect.EnumType

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) Descriptor() protoreflect.EnumDescriptor

func (QueryMeta_ComputeStatus) Enum 

func (x QueryMeta_ComputeStatus) Enum() *QueryMeta_ComputeStatus

func (QueryMeta_ComputeStatus) EnumDescriptor deprecated 

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

Deprecated: Use QueryMeta_ComputeStatus.Descriptor instead.

func (QueryMeta_ComputeStatus) Number 

func (x QueryMeta_ComputeStatus) Number() protoreflect.EnumNumber

func (QueryMeta_ComputeStatus) String 

func (x QueryMeta_ComputeStatus) String() string

func (QueryMeta_ComputeStatus) Type 

func (QueryMeta_ComputeStatus) Type() protoreflect.EnumType

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) Descriptor() protoreflect.EnumDescriptor

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 (x StateLoadMode) Number() protoreflect.EnumNumber

func (StateLoadMode) String 

func (x StateLoadMode) String() string

func (StateLoadMode) Type 

func (StateLoadMode) Type() protoreflect.EnumType

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 (x *StreamingDisposition) GetFromLastCheckpoint() *StreamingDisposition_FromLastCheckpoint

func (*StreamingDisposition) GetFromTime 

func (x *StreamingDisposition) GetFromTime() *StreamingDisposition_FromTime

func (*StreamingDisposition) GetOldest 

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

func (*StreamingDisposition) GetTimeAgo 

func (x *StreamingDisposition) GetTimeAgo() *StreamingDisposition_TimeAgo

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 (x *StreamingDisposition_FromLastCheckpoint) GetForce() bool

func (*StreamingDisposition_FromLastCheckpoint) ProtoMessage 

func (*StreamingDisposition_FromLastCheckpoint) ProtoMessage()

func (*StreamingDisposition_FromLastCheckpoint) ProtoReflect 

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

func (*StreamingDisposition_FromLastCheckpoint) Reset 

func (x *StreamingDisposition_FromLastCheckpoint) Reset()

func (*StreamingDisposition_FromLastCheckpoint) String 

func (x *StreamingDisposition_FromLastCheckpoint) String() 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 (x *StreamingDisposition_FromTime) GetTimestamp() *timestamppb.Timestamp

func (*StreamingDisposition_FromTime) ProtoMessage 

func (*StreamingDisposition_FromTime) ProtoMessage()

func (*StreamingDisposition_FromTime) ProtoReflect 

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

func (*StreamingDisposition_FromTime) Reset 

func (x *StreamingDisposition_FromTime) Reset()

func (*StreamingDisposition_FromTime) String 

func (x *StreamingDisposition_FromTime) String() 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 (x *StreamingDisposition_TimeAgo) GetDuration() *durationpb.Duration

func (*StreamingDisposition_TimeAgo) ProtoMessage 

func (*StreamingDisposition_TimeAgo) ProtoMessage()

func (*StreamingDisposition_TimeAgo) ProtoReflect 

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

func (*StreamingDisposition_TimeAgo) Reset 

func (x *StreamingDisposition_TimeAgo) Reset()

func (*StreamingDisposition_TimeAgo) String 

func (x *StreamingDisposition_TimeAgo) String() 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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