internal

package
v0.0.17 Latest Latest
Warning

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

 Go to latest Published: Apr 14, 2024 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	CodeBalancerServiceUnavailable = 1000000
)

Variables

This section is empty.

Functions

func NewCertPool 

func NewCertPool() (*x509.CertPool, error)

func NewTx 

func NewTx(
	ctx context.Context,
	e Encoder,
	log log.Structured,
	stop *StopGroup,
	config *yt.Config,
	options *yt.StartTxOptions,
) (yt.Tx, error)

Types

type AbortOperationParams 

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

func NewAbortOperationParams 

func NewAbortOperationParams(
	opID yt.OperationID,
	options *yt.AbortOperationOptions,
) *AbortOperationParams

func (*AbortOperationParams) HTTPVerb 

func (p *AbortOperationParams) HTTPVerb() Verb

func (*AbortOperationParams) Log 

func (p *AbortOperationParams) Log() []log.Field

func (*AbortOperationParams) MarshalHTTP 

func (p *AbortOperationParams) MarshalHTTP(w *yson.Writer)

func (*AbortOperationParams) YPath 

func (p *AbortOperationParams) YPath() (ypath.YPath, bool)

type AbortQueryParams added in v0.0.10 

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

func NewAbortQueryParams added in v0.0.10 

func NewAbortQueryParams(
	id yt.QueryID,
	options *yt.AbortQueryOptions,
) *AbortQueryParams

func (*AbortQueryParams) HTTPVerb added in v0.0.10 

func (p *AbortQueryParams) HTTPVerb() Verb

func (*AbortQueryParams) Log added in v0.0.10 

func (p *AbortQueryParams) Log() []log.Field

func (*AbortQueryParams) MarshalHTTP added in v0.0.10 

func (p *AbortQueryParams) MarshalHTTP(w *yson.Writer)

func (*AbortQueryParams) QueryTrackerOptions added in v0.0.10 

func (p *AbortQueryParams) QueryTrackerOptions() **yt.QueryTrackerOptions

func (*AbortQueryParams) YPath added in v0.0.10 

func (p *AbortQueryParams) YPath() (ypath.YPath, bool)

type AbortTxParams 

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

func NewAbortTxParams 

func NewAbortTxParams(
	id yt.TxID,
	options *yt.AbortTxOptions,
) *AbortTxParams

func (*AbortTxParams) HTTPVerb 

func (p *AbortTxParams) HTTPVerb() Verb

func (*AbortTxParams) Log 

func (p *AbortTxParams) Log() []log.Field

func (*AbortTxParams) MarshalHTTP 

func (p *AbortTxParams) MarshalHTTP(w *yson.Writer)

func (*AbortTxParams) MutatingOptions 

func (p *AbortTxParams) MutatingOptions() **yt.MutatingOptions

func (*AbortTxParams) PrerequisiteOptions 

func (p *AbortTxParams) PrerequisiteOptions() **yt.PrerequisiteOptions

func (*AbortTxParams) TransactionOptions 

func (p *AbortTxParams) TransactionOptions() **yt.TransactionOptions

func (*AbortTxParams) YPath 

func (p *AbortTxParams) YPath() (ypath.YPath, bool)

type AddMaintenanceParams added in v0.0.7 

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

func NewAddMaintenanceParams added in v0.0.7 

func NewAddMaintenanceParams(
	component yt.MaintenanceComponent,
	address string,
	maintenanceType yt.MaintenanceType,
	comment string,
	options *yt.AddMaintenanceOptions,
) *AddMaintenanceParams

func (*AddMaintenanceParams) HTTPVerb added in v0.0.7 

func (p *AddMaintenanceParams) HTTPVerb() Verb

func (*AddMaintenanceParams) Log added in v0.0.7 

func (p *AddMaintenanceParams) Log() []log.Field

func (*AddMaintenanceParams) MarshalHTTP added in v0.0.7 

func (p *AddMaintenanceParams) MarshalHTTP(w *yson.Writer)

func (*AddMaintenanceParams) YPath added in v0.0.7 

func (p *AddMaintenanceParams) YPath() (ypath.YPath, bool)

type AddMemberParams 

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

func NewAddMemberParams 

func NewAddMemberParams(
	group string,
	member string,
	options *yt.AddMemberOptions,
) *AddMemberParams

func (*AddMemberParams) HTTPVerb 

func (p *AddMemberParams) HTTPVerb() Verb

func (*AddMemberParams) Log 

func (p *AddMemberParams) Log() []log.Field

func (*AddMemberParams) MarshalHTTP 

func (p *AddMemberParams) MarshalHTTP(w *yson.Writer)

func (*AddMemberParams) MutatingOptions 

func (p *AddMemberParams) MutatingOptions() **yt.MutatingOptions

func (*AddMemberParams) PrerequisiteOptions 

func (p *AddMemberParams) PrerequisiteOptions() **yt.PrerequisiteOptions

func (*AddMemberParams) YPath 

func (p *AddMemberParams) YPath() (ypath.YPath, bool)

type AlterQueryParams added in v0.0.10 

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

func NewAlterQueryParams added in v0.0.10 

func NewAlterQueryParams(
	id yt.QueryID,
	options *yt.AlterQueryOptions,
) *AlterQueryParams

func (*AlterQueryParams) HTTPVerb added in v0.0.10 

func (p *AlterQueryParams) HTTPVerb() Verb

func (*AlterQueryParams) Log added in v0.0.10 

func (p *AlterQueryParams) Log() []log.Field

func (*AlterQueryParams) MarshalHTTP added in v0.0.10 

func (p *AlterQueryParams) MarshalHTTP(w *yson.Writer)

func (*AlterQueryParams) QueryTrackerOptions added in v0.0.10 

func (p *AlterQueryParams) QueryTrackerOptions() **yt.QueryTrackerOptions

func (*AlterQueryParams) YPath added in v0.0.10 

func (p *AlterQueryParams) YPath() (ypath.YPath, bool)

type AlterTableParams 

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

func NewAlterTableParams 

func NewAlterTableParams(
	path ypath.Path,
	options *yt.AlterTableOptions,
) *AlterTableParams

func (*AlterTableParams) HTTPVerb 

func (p *AlterTableParams) HTTPVerb() Verb

func (*AlterTableParams) Log 

func (p *AlterTableParams) Log() []log.Field

func (*AlterTableParams) MarshalHTTP 

func (p *AlterTableParams) MarshalHTTP(w *yson.Writer)

func (*AlterTableParams) MutatingOptions 

func (p *AlterTableParams) MutatingOptions() **yt.MutatingOptions

func (*AlterTableParams) YPath 

func (p *AlterTableParams) YPath() (ypath.YPath, bool)

type AlterTableReplicaParams 

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

func NewAlterTableReplicaParams 

func NewAlterTableReplicaParams(
	id yt.NodeID,
	options *yt.AlterTableReplicaOptions,
) *AlterTableReplicaParams

func (*AlterTableReplicaParams) HTTPVerb 

func (p *AlterTableReplicaParams) HTTPVerb() Verb

func (*AlterTableReplicaParams) Log 

func (p *AlterTableReplicaParams) Log() []log.Field

func (*AlterTableReplicaParams) MarshalHTTP 

func (p *AlterTableReplicaParams) MarshalHTTP(w *yson.Writer)

func (*AlterTableReplicaParams) YPath 

func (p *AlterTableReplicaParams) YPath() (ypath.YPath, bool)

type BuildMasterSnapshotsParams added in v0.0.4 

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

func NewBuildMasterSnapshotsParams added in v0.0.4 

func NewBuildMasterSnapshotsParams(
	options *yt.BuildMasterSnapshotsOptions,
) *BuildMasterSnapshotsParams

func (*BuildMasterSnapshotsParams) HTTPVerb added in v0.0.4 

func (p *BuildMasterSnapshotsParams) HTTPVerb() Verb

func (*BuildMasterSnapshotsParams) Log added in v0.0.4 

func (p *BuildMasterSnapshotsParams) Log() []log.Field

func (*BuildMasterSnapshotsParams) MarshalHTTP added in v0.0.4 

func (p *BuildMasterSnapshotsParams) MarshalHTTP(w *yson.Writer)

func (*BuildMasterSnapshotsParams) YPath added in v0.0.4 

func (p *BuildMasterSnapshotsParams) YPath() (ypath.YPath, bool)

type BuildSnapshotParams added in v0.0.5 

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

func NewBuildSnapshotParams added in v0.0.5 

func NewBuildSnapshotParams(
	options *yt.BuildSnapshotOptions,
) *BuildSnapshotParams

func (*BuildSnapshotParams) HTTPVerb added in v0.0.5 

func (p *BuildSnapshotParams) HTTPVerb() Verb

func (*BuildSnapshotParams) Log added in v0.0.5 

func (p *BuildSnapshotParams) Log() []log.Field

func (*BuildSnapshotParams) MarshalHTTP added in v0.0.5 

func (p *BuildSnapshotParams) MarshalHTTP(w *yson.Writer)

func (*BuildSnapshotParams) YPath added in v0.0.5 

func (p *BuildSnapshotParams) YPath() (ypath.YPath, bool)

type Call 

type Call struct {
	Params Params
	CallID guid.GUID

	YSONValue []byte
	RowBatch  yt.RowBatch

	RequestedProxy string
	SelectedProxy  string
	Backoff        backoff.BackOff
	DisableRetries bool

	OnRspParams func(b []byte) error
}

type CallInterceptor 

type CallInterceptor func(ctx context.Context, call *Call, invoke CallInvoker) (res *CallResult, err error)

type CallInvoker 

type CallInvoker func(ctx context.Context, call *Call) (res *CallResult, err error)

func (CallInvoker) Wrap 

func (c CallInvoker) Wrap(interceptor CallInterceptor) CallInvoker

type CallResult 

type CallResult struct {
	YSONValue []byte
}

type CheckPermissionParams 

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

func NewCheckPermissionParams 

func NewCheckPermissionParams(
	user string,
	permission yt.Permission,
	path ypath.YPath,
	options *yt.CheckPermissionOptions,
) *CheckPermissionParams

func (*CheckPermissionParams) HTTPVerb 

func (p *CheckPermissionParams) HTTPVerb() Verb

func (*CheckPermissionParams) Log 

func (p *CheckPermissionParams) Log() []log.Field

func (*CheckPermissionParams) MarshalHTTP 

func (p *CheckPermissionParams) MarshalHTTP(w *yson.Writer)

func (*CheckPermissionParams) MasterReadOptions 

func (p *CheckPermissionParams) MasterReadOptions() **yt.MasterReadOptions

func (*CheckPermissionParams) PrerequisiteOptions 

func (p *CheckPermissionParams) PrerequisiteOptions() **yt.PrerequisiteOptions

func (*CheckPermissionParams) TransactionOptions 

func (p *CheckPermissionParams) TransactionOptions() **yt.TransactionOptions

func (*CheckPermissionParams) YPath 

func (p *CheckPermissionParams) YPath() (ypath.YPath, bool)

type CommitTxParams 

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

func NewCommitTxParams 

func NewCommitTxParams(
	id yt.TxID,
	options *yt.CommitTxOptions,
) *CommitTxParams

func (*CommitTxParams) HTTPVerb 

func (p *CommitTxParams) HTTPVerb() Verb

func (*CommitTxParams) Log 

func (p *CommitTxParams) Log() []log.Field

func (*CommitTxParams) MarshalHTTP 

func (p *CommitTxParams) MarshalHTTP(w *yson.Writer)

func (*CommitTxParams) MutatingOptions 

func (p *CommitTxParams) MutatingOptions() **yt.MutatingOptions

func (*CommitTxParams) PrerequisiteOptions 

func (p *CommitTxParams) PrerequisiteOptions() **yt.PrerequisiteOptions

func (*CommitTxParams) TransactionOptions 

func (p *CommitTxParams) TransactionOptions() **yt.TransactionOptions

func (*CommitTxParams) YPath 

func (p *CommitTxParams) YPath() (ypath.YPath, bool)

type CompleteOperationParams 

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

func NewCompleteOperationParams 

func NewCompleteOperationParams(
	opID yt.OperationID,
	options *yt.CompleteOperationOptions,
) *CompleteOperationParams

func (*CompleteOperationParams) HTTPVerb 

func (p *CompleteOperationParams) HTTPVerb() Verb

func (*CompleteOperationParams) Log 

func (p *CompleteOperationParams) Log() []log.Field

func (*CompleteOperationParams) MarshalHTTP 

func (p *CompleteOperationParams) MarshalHTTP(w *yson.Writer)

func (*CompleteOperationParams) YPath 

func (p *CompleteOperationParams) YPath() (ypath.YPath, bool)

type CopyNodeParams 

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

func NewCopyNodeParams 

func NewCopyNodeParams(
	src ypath.YPath,
	dst ypath.YPath,
	options *yt.CopyNodeOptions,
) *CopyNodeParams

func (*CopyNodeParams) HTTPVerb 

func (p *CopyNodeParams) HTTPVerb() Verb

func (*CopyNodeParams) Log 

func (p *CopyNodeParams) Log() []log.Field

func (*CopyNodeParams) MarshalHTTP 

func (p *CopyNodeParams) MarshalHTTP(w *yson.Writer)

func (*CopyNodeParams) MutatingOptions 

func (p *CopyNodeParams) MutatingOptions() **yt.MutatingOptions

func (*CopyNodeParams) PrerequisiteOptions 

func (p *CopyNodeParams) PrerequisiteOptions() **yt.PrerequisiteOptions

func (*CopyNodeParams) TransactionOptions 

func (p *CopyNodeParams) TransactionOptions() **yt.TransactionOptions

func (*CopyNodeParams) YPath 

func (p *CopyNodeParams) YPath() (ypath.YPath, bool)

type CreateNodeParams 

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

func NewCreateNodeParams 

func NewCreateNodeParams(
	path ypath.YPath,
	typ yt.NodeType,
	options *yt.CreateNodeOptions,
) *CreateNodeParams

func (*CreateNodeParams) AccessTrackingOptions 

func (p *CreateNodeParams) AccessTrackingOptions() **yt.AccessTrackingOptions

func (*CreateNodeParams) HTTPVerb 

func (p *CreateNodeParams) HTTPVerb() Verb

func (*CreateNodeParams) Log 

func (p *CreateNodeParams) Log() []log.Field

func (*CreateNodeParams) MarshalHTTP 

func (p *CreateNodeParams) MarshalHTTP(w *yson.Writer)

func (*CreateNodeParams) MutatingOptions 

func (p *CreateNodeParams) MutatingOptions() **yt.MutatingOptions

func (*CreateNodeParams) PrerequisiteOptions 

func (p *CreateNodeParams) PrerequisiteOptions() **yt.PrerequisiteOptions

func (*CreateNodeParams) TransactionOptions 

func (p *CreateNodeParams) TransactionOptions() **yt.TransactionOptions

func (*CreateNodeParams) YPath 

func (p *CreateNodeParams) YPath() (ypath.YPath, bool)

type CreateObjectParams 

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

func NewCreateObjectParams 

func NewCreateObjectParams(
	typ yt.NodeType,
	options *yt.CreateObjectOptions,
) *CreateObjectParams

func (*CreateObjectParams) AccessTrackingOptions 

func (p *CreateObjectParams) AccessTrackingOptions() **yt.AccessTrackingOptions

func (*CreateObjectParams) HTTPVerb 

func (p *CreateObjectParams) HTTPVerb() Verb

func (*CreateObjectParams) Log 

func (p *CreateObjectParams) Log() []log.Field

func (*CreateObjectParams) MarshalHTTP 

func (p *CreateObjectParams) MarshalHTTP(w *yson.Writer)

func (*CreateObjectParams) MutatingOptions 

func (p *CreateObjectParams) MutatingOptions() **yt.MutatingOptions

func (*CreateObjectParams) PrerequisiteOptions 

func (p *CreateObjectParams) PrerequisiteOptions() **yt.PrerequisiteOptions

func (*CreateObjectParams) YPath 

func (p *CreateObjectParams) YPath() (ypath.YPath, bool)

type CreateTableBackupParams added in v0.0.10 

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

func NewCreateTableBackupParams added in v0.0.10 

func NewCreateTableBackupParams(
	manifest yt.BackupManifest,
	options *yt.CreateTableBackupOptions,
) *CreateTableBackupParams

func (*CreateTableBackupParams) HTTPVerb added in v0.0.10 

func (p *CreateTableBackupParams) HTTPVerb() Verb

func (*CreateTableBackupParams) Log added in v0.0.10 

func (p *CreateTableBackupParams) Log() []log.Field

func (*CreateTableBackupParams) MarshalHTTP added in v0.0.10 

func (p *CreateTableBackupParams) MarshalHTTP(w *yson.Writer)

func (*CreateTableBackupParams) TimeoutOptions added in v0.0.10 

func (p *CreateTableBackupParams) TimeoutOptions() **yt.TimeoutOptions

func (*CreateTableBackupParams) YPath added in v0.0.10 

func (p *CreateTableBackupParams) YPath() (ypath.YPath, bool)

type DeleteRowsParams 

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

func NewDeleteRowsParams 

func NewDeleteRowsParams(
	path ypath.Path,
	options *yt.DeleteRowsOptions,
) *DeleteRowsParams

func (*DeleteRowsParams) HTTPVerb 

func (p *DeleteRowsParams) HTTPVerb() Verb

func (*DeleteRowsParams) Log 

func (p *DeleteRowsParams) Log() []log.Field

func (*DeleteRowsParams) MarshalHTTP 

func (p *DeleteRowsParams) MarshalHTTP(w *yson.Writer)

func (*DeleteRowsParams) TransactionOptions 

func (p *DeleteRowsParams) TransactionOptions() **yt.TransactionOptions

func (*DeleteRowsParams) YPath 

func (p *DeleteRowsParams) YPath() (ypath.YPath, bool)

type DestroyChunkLocationsParams added in v0.0.3 

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

func NewDestroyChunkLocationsParams added in v0.0.3 

func NewDestroyChunkLocationsParams(
	nodeAddress string,
	recoverUnlinkedDisks bool,
	locationUUIDs []guid.GUID,
	options *yt.DestroyChunkLocationsOptions,
) *DestroyChunkLocationsParams

func (*DestroyChunkLocationsParams) HTTPVerb added in v0.0.3 

func (p *DestroyChunkLocationsParams) HTTPVerb() Verb

func (*DestroyChunkLocationsParams) Log added in v0.0.3 

func (p *DestroyChunkLocationsParams) Log() []log.Field

func (*DestroyChunkLocationsParams) MarshalHTTP added in v0.0.3 

func (p *DestroyChunkLocationsParams) MarshalHTTP(w *yson.Writer)

func (*DestroyChunkLocationsParams) YPath added in v0.0.3 

func (p *DestroyChunkLocationsParams) YPath() (ypath.YPath, bool)

type DisableChunkLocationsParams added in v0.0.3 

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

func NewDisableChunkLocationsParams added in v0.0.3 

func NewDisableChunkLocationsParams(
	nodeAddress string,
	locationUUIDs []guid.GUID,
	options *yt.DisableChunkLocationsOptions,
) *DisableChunkLocationsParams

func (*DisableChunkLocationsParams) HTTPVerb added in v0.0.3 

func (p *DisableChunkLocationsParams) HTTPVerb() Verb

func (*DisableChunkLocationsParams) Log added in v0.0.3 

func (p *DisableChunkLocationsParams) Log() []log.Field

func (*DisableChunkLocationsParams) MarshalHTTP added in v0.0.3 

func (p *DisableChunkLocationsParams) MarshalHTTP(w *yson.Writer)

func (*DisableChunkLocationsParams) YPath added in v0.0.3 

func (p *DisableChunkLocationsParams) YPath() (ypath.YPath, bool)

type Encoder 

type Encoder struct {
	StartCall func() *Call

	Invoke         CallInvoker
	InvokeRead     ReadInvoker
	InvokeWrite    WriteInvoker
	InvokeReadRow  ReadRowInvoker
	InvokeWriteRow WriteRowInvoker
}

Encoder is adapter between typed and untyped layer of API.

func (*Encoder) AbortOperation 

func (e *Encoder) AbortOperation(
	ctx context.Context,
	opID yt.OperationID,
	options *yt.AbortOperationOptions,
) (err error)

func (*Encoder) AbortQuery added in v0.0.10 

func (e *Encoder) AbortQuery(
	ctx context.Context,
	id yt.QueryID,
	options *yt.AbortQueryOptions,
) (err error)

func (*Encoder) AbortTx 

func (e *Encoder) AbortTx(
	ctx context.Context,
	id yt.TxID,
	options *yt.AbortTxOptions,
) (err error)

func (*Encoder) AddMaintenance added in v0.0.7 

func (e *Encoder) AddMaintenance(
	ctx context.Context,
	component yt.MaintenanceComponent,
	address string,
	maintenanceType yt.MaintenanceType,
	comment string,
	options *yt.AddMaintenanceOptions,
) (response *yt.AddMaintenanceResponse, err error)

func (*Encoder) AddMember 

func (e *Encoder) AddMember(
	ctx context.Context,
	group string,
	member string,
	options *yt.AddMemberOptions,
) (err error)

func (*Encoder) AlterQuery added in v0.0.10 

func (e *Encoder) AlterQuery(
	ctx context.Context,
	id yt.QueryID,
	options *yt.AlterQueryOptions,
) (err error)

func (*Encoder) AlterTable 

func (e *Encoder) AlterTable(
	ctx context.Context,
	path ypath.Path,
	options *yt.AlterTableOptions,
) (err error)

func (*Encoder) AlterTableReplica 

func (e *Encoder) AlterTableReplica(
	ctx context.Context,
	id yt.NodeID,
	options *yt.AlterTableReplicaOptions,
) (err error)

func (*Encoder) BuildMasterSnapshots added in v0.0.4 

func (e *Encoder) BuildMasterSnapshots(
	ctx context.Context,
	options *yt.BuildMasterSnapshotsOptions,
) (response *yt.BuildMasterSnapshotsResponse, err error)

func (*Encoder) BuildSnapshot added in v0.0.5 

func (e *Encoder) BuildSnapshot(
	ctx context.Context,
	options *yt.BuildSnapshotOptions,
) (response *yt.BuildSnapshotResponse, err error)

func (*Encoder) CheckPermission 

func (e *Encoder) CheckPermission(
	ctx context.Context,
	user string,
	permission yt.Permission,
	path ypath.YPath,
	options *yt.CheckPermissionOptions,
) (response *yt.CheckPermissionResponse, err error)

func (*Encoder) CommitTx 

func (e *Encoder) CommitTx(
	ctx context.Context,
	id yt.TxID,
	options *yt.CommitTxOptions,
) (err error)

func (*Encoder) CompleteOperation 

func (e *Encoder) CompleteOperation(
	ctx context.Context,
	opID yt.OperationID,
	options *yt.CompleteOperationOptions,
) (err error)

func (*Encoder) CopyNode 

func (e *Encoder) CopyNode(
	ctx context.Context,
	src ypath.YPath,
	dst ypath.YPath,
	options *yt.CopyNodeOptions,
) (id yt.NodeID, err error)

func (*Encoder) CreateNode 

func (e *Encoder) CreateNode(
	ctx context.Context,
	path ypath.YPath,
	typ yt.NodeType,
	options *yt.CreateNodeOptions,
) (id yt.NodeID, err error)

func (*Encoder) CreateObject 

func (e *Encoder) CreateObject(
	ctx context.Context,
	typ yt.NodeType,
	options *yt.CreateObjectOptions,
) (id yt.NodeID, err error)

func (*Encoder) CreateTableBackup added in v0.0.10 

func (e *Encoder) CreateTableBackup(
	ctx context.Context,
	manifest yt.BackupManifest,
	options *yt.CreateTableBackupOptions,
) (err error)

func (*Encoder) DeleteRows 

func (e *Encoder) DeleteRows(
	ctx context.Context,
	path ypath.Path,
	keys []any,
	options *yt.DeleteRowsOptions,
) (err error)

func (*Encoder) DestroyChunkLocations added in v0.0.3 

func (e *Encoder) DestroyChunkLocations(
	ctx context.Context,
	nodeAddress string,
	recoverUnlinkedDisks bool,
	locationUUIDs []guid.GUID,
	options *yt.DestroyChunkLocationsOptions,
) (response *yt.DestroyChunkLocationsResponse, err error)

func (*Encoder) DisableChunkLocations added in v0.0.3 

func (e *Encoder) DisableChunkLocations(
	ctx context.Context,
	nodeAddress string,
	locationUUIDs []guid.GUID,
	options *yt.DisableChunkLocationsOptions,
) (response *yt.DisableChunkLocationsResponse, err error)

func (*Encoder) FreezeTable 

func (e *Encoder) FreezeTable(
	ctx context.Context,
	path ypath.Path,
	options *yt.FreezeTableOptions,
) (err error)

func (*Encoder) GenerateTimestamp 

func (e *Encoder) GenerateTimestamp(
	ctx context.Context,
	options *yt.GenerateTimestampOptions,
) (ts yt.Timestamp, err error)

func (*Encoder) GetFileFromCache 

func (e *Encoder) GetFileFromCache(
	ctx context.Context,
	md5 string,
	options *yt.GetFileFromCacheOptions,
) (path ypath.YPath, err error)

func (*Encoder) GetInSyncReplicas 

func (e *Encoder) GetInSyncReplicas(
	ctx context.Context,
	path ypath.Path,
	ts yt.Timestamp,
	keys []any,
	options *yt.GetInSyncReplicasOptions,
) (ids []yt.NodeID, err error)

func (*Encoder) GetJobStderr 

func (e *Encoder) GetJobStderr(
	ctx context.Context,
	opID yt.OperationID,
	jobID yt.JobID,
	options *yt.GetJobStderrOptions,
) (r []byte, err error)

func (*Encoder) GetNode 

func (e *Encoder) GetNode(
	ctx context.Context,
	path ypath.YPath,
	result any,
	options *yt.GetNodeOptions,
) (err error)

func (*Encoder) GetOperation 

func (e *Encoder) GetOperation(
	ctx context.Context,
	opID yt.OperationID,
	options *yt.GetOperationOptions,
) (status *yt.OperationStatus, err error)

func (*Encoder) GetOperationByAlias added in v0.0.14 

func (e *Encoder) GetOperationByAlias(
	ctx context.Context,
	alias string,
	options *yt.GetOperationOptions,
) (status *yt.OperationStatus, err error)

func (*Encoder) GetQuery added in v0.0.10 

func (e *Encoder) GetQuery(
	ctx context.Context,
	id yt.QueryID,
	options *yt.GetQueryOptions,
) (query *yt.Query, err error)

func (*Encoder) GetQueryResult added in v0.0.10 

func (e *Encoder) GetQueryResult(
	ctx context.Context,
	id yt.QueryID,
	resultIndex int64,
	options *yt.GetQueryResultOptions,
) (result *yt.QueryResult, err error)

func (*Encoder) InsertRowBatch 

func (e *Encoder) InsertRowBatch(
	ctx context.Context,
	path ypath.Path,
	batch yt.RowBatch,
	options *yt.InsertRowsOptions,
) (err error)

func (*Encoder) InsertRows 

func (e *Encoder) InsertRows(
	ctx context.Context,
	path ypath.Path,
	rows []any,
	options *yt.InsertRowsOptions,
) (err error)

func (*Encoder) IssueToken added in v0.0.17 

func (e *Encoder) IssueToken(
	ctx context.Context,
	user string,
	password string,
	options *yt.IssueTokenOptions,
) (token string, err error)

func (*Encoder) LinkNode 

func (e *Encoder) LinkNode(
	ctx context.Context,
	target ypath.YPath,
	link ypath.YPath,
	options *yt.LinkNodeOptions,
) (id yt.NodeID, err error)

func (*Encoder) ListJobs 

func (e *Encoder) ListJobs(
	ctx context.Context,
	opID yt.OperationID,
	options *yt.ListJobsOptions,
) (r *yt.ListJobsResult, err error)

func (*Encoder) ListNode 

func (e *Encoder) ListNode(
	ctx context.Context,
	path ypath.YPath,
	result any,
	options *yt.ListNodeOptions,
) (err error)

func (*Encoder) ListOperations 

func (e *Encoder) ListOperations(
	ctx context.Context,
	options *yt.ListOperationsOptions,
) (operations *yt.ListOperationsResult, err error)

func (*Encoder) ListQueries added in v0.0.10 

func (e *Encoder) ListQueries(
	ctx context.Context,
	options *yt.ListQueriesOptions,
) (result *yt.ListQueriesResult, err error)

func (*Encoder) ListUserTokens added in v0.0.17 

func (e *Encoder) ListUserTokens(
	ctx context.Context,
	user string,
	password string,
	options *yt.ListUserTokensOptions,
) (tokens []string, err error)

func (*Encoder) LocateSkynetShare 

func (e *Encoder) LocateSkynetShare(
	ctx context.Context,
	path ypath.YPath,
	options *yt.LocateSkynetShareOptions,
) (l yt.ShareLocation, err error)

func (*Encoder) LockNode 

func (e *Encoder) LockNode(
	ctx context.Context,
	path ypath.YPath,
	mode yt.LockMode,
	options *yt.LockNodeOptions,
) (lr yt.LockResult, err error)

func (*Encoder) LockRows 

func (e *Encoder) LockRows(
	ctx context.Context,
	path ypath.Path,
	locks []string,
	lockType yt.LockType,
	keys []any,
	options *yt.LockRowsOptions,
) (err error)

func (*Encoder) LookupRows 

func (e *Encoder) LookupRows(
	ctx context.Context,
	path ypath.Path,
	keys []any,
	options *yt.LookupRowsOptions,
) (r yt.TableReader, err error)

func (*Encoder) MountTable 

func (e *Encoder) MountTable(
	ctx context.Context,
	path ypath.Path,
	options *yt.MountTableOptions,
) (err error)

func (*Encoder) MoveNode 

func (e *Encoder) MoveNode(
	ctx context.Context,
	src ypath.YPath,
	dst ypath.YPath,
	options *yt.MoveNodeOptions,
) (id yt.NodeID, err error)

func (*Encoder) MultisetAttributes 

func (e *Encoder) MultisetAttributes(
	ctx context.Context,
	path ypath.YPath,
	attributes map[string]any,
	options *yt.MultisetAttributesOptions,
) (err error)

func (*Encoder) NodeExists 

func (e *Encoder) NodeExists(
	ctx context.Context,
	path ypath.YPath,
	options *yt.NodeExistsOptions,
) (ok bool, err error)

func (*Encoder) PingTx 

func (e *Encoder) PingTx(
	ctx context.Context,
	id yt.TxID,
	options *yt.PingTxOptions,
) (err error)

func (*Encoder) PutFileToCache 

func (e *Encoder) PutFileToCache(
	ctx context.Context,
	path ypath.YPath,
	md5 string,
	options *yt.PutFileToCacheOptions,
) (cachedPath ypath.YPath, err error)

func (*Encoder) ReadFile 

func (e *Encoder) ReadFile(
	ctx context.Context,
	path ypath.YPath,
	options *yt.ReadFileOptions,
) (r io.ReadCloser, err error)

func (*Encoder) ReadQueryResult added in v0.0.10 

func (e *Encoder) ReadQueryResult(
	ctx context.Context,
	id yt.QueryID,
	resultIndex int64,
	options *yt.ReadQueryResultOptions,
) (r yt.TableReader, err error)

func (*Encoder) ReadTable 

func (e *Encoder) ReadTable(
	ctx context.Context,
	path ypath.YPath,
	options *yt.ReadTableOptions,
) (r yt.TableReader, err error)

func (*Encoder) RemountTable 

func (e *Encoder) RemountTable(
	ctx context.Context,
	path ypath.Path,
	options *yt.RemountTableOptions,
) (err error)

func (*Encoder) RemoveMaintenance added in v0.0.7 

func (e *Encoder) RemoveMaintenance(
	ctx context.Context,
	component yt.MaintenanceComponent,
	address string,
	options *yt.RemoveMaintenanceOptions,
) (response *yt.RemoveMaintenanceResponse, err error)

func (*Encoder) RemoveMember 

func (e *Encoder) RemoveMember(
	ctx context.Context,
	group string,
	member string,
	options *yt.RemoveMemberOptions,
) (err error)

func (*Encoder) RemoveNode 

func (e *Encoder) RemoveNode(
	ctx context.Context,
	path ypath.YPath,
	options *yt.RemoveNodeOptions,
) (err error)

func (*Encoder) RequestRestart added in v0.0.10 

func (e *Encoder) RequestRestart(
	ctx context.Context,
	nodeAddress string,
	options *yt.RequestRestartOptions,
) (err error)

func (*Encoder) ReshardTable 

func (e *Encoder) ReshardTable(
	ctx context.Context,
	path ypath.Path,
	options *yt.ReshardTableOptions,
) (err error)

func (*Encoder) RestoreTableBackup added in v0.0.10 

func (e *Encoder) RestoreTableBackup(
	ctx context.Context,
	manifest yt.BackupManifest,
	options *yt.RestoreTableBackupOptions,
) (err error)

func (*Encoder) ResumeOperation 

func (e *Encoder) ResumeOperation(
	ctx context.Context,
	opID yt.OperationID,
	options *yt.ResumeOperationOptions,
) (err error)

func (*Encoder) ResurrectChunkLocations added in v0.0.3 

func (e *Encoder) ResurrectChunkLocations(
	ctx context.Context,
	nodeAddress string,
	locationUUIDs []guid.GUID,
	options *yt.ResurrectChunkLocationsOptions,
) (response *yt.ResurrectChunkLocationsResponse, err error)

func (*Encoder) RevokeToken added in v0.0.17 

func (e *Encoder) RevokeToken(
	ctx context.Context,
	user string,
	password string,
	token string,
	options *yt.RevokeTokenOptions,
) (err error)

func (*Encoder) SelectRows 

func (e *Encoder) SelectRows(
	ctx context.Context,
	query string,
	options *yt.SelectRowsOptions,
) (r yt.TableReader, err error)

func (*Encoder) SetNode 

func (e *Encoder) SetNode(
	ctx context.Context,
	path ypath.YPath,
	value any,
	options *yt.SetNodeOptions,
) (err error)

func (*Encoder) SetUserPassword added in v0.0.17 

func (e *Encoder) SetUserPassword(
	ctx context.Context,
	user string,
	newPassword string,
	currentPassword string,
	options *yt.SetUserPasswordOptions,
) (err error)

func (*Encoder) StartOperation 

func (e *Encoder) StartOperation(
	ctx context.Context,
	opType yt.OperationType,
	spec any,
	options *yt.StartOperationOptions,
) (opID yt.OperationID, err error)

func (*Encoder) StartQuery added in v0.0.10 

func (e *Encoder) StartQuery(
	ctx context.Context,
	engine yt.QueryEngine,
	query string,
	options *yt.StartQueryOptions,
) (id yt.QueryID, err error)

func (*Encoder) StartTabletTx 

func (e *Encoder) StartTabletTx(
	ctx context.Context,
	options *yt.StartTabletTxOptions,
) (id yt.TxID, err error)

func (*Encoder) StartTx 

func (e *Encoder) StartTx(
	ctx context.Context,
	options *yt.StartTxOptions,
) (id yt.TxID, err error)

func (*Encoder) SuspendOperation 

func (e *Encoder) SuspendOperation(
	ctx context.Context,
	opID yt.OperationID,
	options *yt.SuspendOperationOptions,
) (err error)

func (*Encoder) TransferAccountResources 

func (e *Encoder) TransferAccountResources(
	ctx context.Context,
	srcAccount string,
	dstAccount string,
	resourceDelta any,
	options *yt.TransferAccountResourcesOptions,
) (err error)

func (*Encoder) TransferPoolResources 

func (e *Encoder) TransferPoolResources(
	ctx context.Context,
	srcPool string,
	dstPool string,
	poolTree string,
	resourceDelta any,
	options *yt.TransferPoolResourcesOptions,
) (err error)

func (*Encoder) UnfreezeTable 

func (e *Encoder) UnfreezeTable(
	ctx context.Context,
	path ypath.Path,
	options *yt.UnfreezeTableOptions,
) (err error)

func (*Encoder) UnlockNode 

func (e *Encoder) UnlockNode(
	ctx context.Context,
	path ypath.YPath,
	options *yt.UnlockNodeOptions,
) (err error)

func (*Encoder) UnmountTable 

func (e *Encoder) UnmountTable(
	ctx context.Context,
	path ypath.Path,
	options *yt.UnmountTableOptions,
) (err error)

func (*Encoder) UpdateOperationParameters 

func (e *Encoder) UpdateOperationParameters(
	ctx context.Context,
	opID yt.OperationID,
	params any,
	options *yt.UpdateOperationParametersOptions,
) (err error)

func (*Encoder) WriteFile 

func (e *Encoder) WriteFile(
	ctx context.Context,
	path ypath.YPath,
	options *yt.WriteFileOptions,
) (w io.WriteCloser, err error)

func (*Encoder) WriteTable 

func (e *Encoder) WriteTable(
	ctx context.Context,
	path ypath.YPath,
	options *yt.WriteTableOptions,
) (w yt.TableWriter, err error)

func (*Encoder) WriteTableRaw 

func (e *Encoder) WriteTableRaw(
	ctx context.Context,
	path ypath.YPath,
	options *yt.WriteTableOptions,
	body *bytes.Buffer,
) (err error)

type ErrorWrapper 

type ErrorWrapper struct{}

func (*ErrorWrapper) Intercept 

func (e *ErrorWrapper) Intercept(ctx context.Context, call *Call, next CallInvoker) (res *CallResult, err error)

func (*ErrorWrapper) Read 

func (e *ErrorWrapper) Read(ctx context.Context, call *Call, next ReadInvoker) (r io.ReadCloser, err error)

func (*ErrorWrapper) Write 

func (e *ErrorWrapper) Write(ctx context.Context, call *Call, next WriteInvoker) (w io.WriteCloser, err error)

type FreezeTableParams 

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

func NewFreezeTableParams 

func NewFreezeTableParams(
	path ypath.Path,
	options *yt.FreezeTableOptions,
) *FreezeTableParams

func (*FreezeTableParams) HTTPVerb 

func (p *FreezeTableParams) HTTPVerb() Verb

func (*FreezeTableParams) Log 

func (p *FreezeTableParams) Log() []log.Field

func (*FreezeTableParams) MarshalHTTP 

func (p *FreezeTableParams) MarshalHTTP(w *yson.Writer)

func (*FreezeTableParams) MutatingOptions 

func (p *FreezeTableParams) MutatingOptions() **yt.MutatingOptions

func (*FreezeTableParams) TabletRangeOptions 

func (p *FreezeTableParams) TabletRangeOptions() **yt.TabletRangeOptions

func (*FreezeTableParams) YPath 

func (p *FreezeTableParams) YPath() (ypath.YPath, bool)

type GenerateTimestampParams 

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

func NewGenerateTimestampParams 

func NewGenerateTimestampParams(
	options *yt.GenerateTimestampOptions,
) *GenerateTimestampParams

func (*GenerateTimestampParams) HTTPVerb 

func (p *GenerateTimestampParams) HTTPVerb() Verb

func (*GenerateTimestampParams) Log 

func (p *GenerateTimestampParams) Log() []log.Field

func (*GenerateTimestampParams) MarshalHTTP 

func (p *GenerateTimestampParams) MarshalHTTP(w *yson.Writer)

func (*GenerateTimestampParams) YPath 

func (p *GenerateTimestampParams) YPath() (ypath.YPath, bool)

type GetFileFromCacheParams 

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

func NewGetFileFromCacheParams 

func NewGetFileFromCacheParams(
	md5 string,
	options *yt.GetFileFromCacheOptions,
) *GetFileFromCacheParams

func (*GetFileFromCacheParams) HTTPVerb 

func (p *GetFileFromCacheParams) HTTPVerb() Verb

func (*GetFileFromCacheParams) Log 

func (p *GetFileFromCacheParams) Log() []log.Field

func (*GetFileFromCacheParams) MarshalHTTP 

func (p *GetFileFromCacheParams) MarshalHTTP(w *yson.Writer)

func (*GetFileFromCacheParams) MasterReadOptions 

func (p *GetFileFromCacheParams) MasterReadOptions() **yt.MasterReadOptions

func (*GetFileFromCacheParams) ReadRetryOptions 

func (p *GetFileFromCacheParams) ReadRetryOptions() **yt.ReadRetryOptions

func (*GetFileFromCacheParams) YPath 

func (p *GetFileFromCacheParams) YPath() (ypath.YPath, bool)

type GetInSyncReplicasParams 

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

func NewGetInSyncReplicasParams 

func NewGetInSyncReplicasParams(
	path ypath.Path,
	ts yt.Timestamp,
	options *yt.GetInSyncReplicasOptions,
) *GetInSyncReplicasParams

func (*GetInSyncReplicasParams) HTTPVerb 

func (p *GetInSyncReplicasParams) HTTPVerb() Verb

func (*GetInSyncReplicasParams) Log 

func (p *GetInSyncReplicasParams) Log() []log.Field

func (*GetInSyncReplicasParams) MarshalHTTP 

func (p *GetInSyncReplicasParams) MarshalHTTP(w *yson.Writer)

func (*GetInSyncReplicasParams) YPath 

func (p *GetInSyncReplicasParams) YPath() (ypath.YPath, bool)

type GetJobStderrParams 

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

func NewGetJobStderrParams 

func NewGetJobStderrParams(
	opID yt.OperationID,
	jobID yt.JobID,
	options *yt.GetJobStderrOptions,
) *GetJobStderrParams

func (*GetJobStderrParams) HTTPVerb 

func (p *GetJobStderrParams) HTTPVerb() Verb

func (*GetJobStderrParams) Log 

func (p *GetJobStderrParams) Log() []log.Field

func (*GetJobStderrParams) MarshalHTTP 

func (p *GetJobStderrParams) MarshalHTTP(w *yson.Writer)

func (*GetJobStderrParams) YPath 

func (p *GetJobStderrParams) YPath() (ypath.YPath, bool)

type GetNodeParams 

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

func NewGetNodeParams 

func NewGetNodeParams(
	path ypath.YPath,
	options *yt.GetNodeOptions,
) *GetNodeParams

func (*GetNodeParams) AccessTrackingOptions 

func (p *GetNodeParams) AccessTrackingOptions() **yt.AccessTrackingOptions

func (*GetNodeParams) HTTPVerb 

func (p *GetNodeParams) HTTPVerb() Verb

func (*GetNodeParams) Log 

func (p *GetNodeParams) Log() []log.Field

func (*GetNodeParams) MarshalHTTP 

func (p *GetNodeParams) MarshalHTTP(w *yson.Writer)

func (*GetNodeParams) MasterReadOptions 

func (p *GetNodeParams) MasterReadOptions() **yt.MasterReadOptions

func (*GetNodeParams) PrerequisiteOptions 

func (p *GetNodeParams) PrerequisiteOptions() **yt.PrerequisiteOptions

func (*GetNodeParams) ReadRetryOptions 

func (p *GetNodeParams) ReadRetryOptions() **yt.ReadRetryOptions

func (*GetNodeParams) TransactionOptions 

func (p *GetNodeParams) TransactionOptions() **yt.TransactionOptions

func (*GetNodeParams) YPath 

func (p *GetNodeParams) YPath() (ypath.YPath, bool)

type GetOperationByAliasParams added in v0.0.14 

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

func NewGetOperationByAliasParams added in v0.0.14 

func NewGetOperationByAliasParams(
	alias string,
	options *yt.GetOperationOptions,
) *GetOperationByAliasParams

func (*GetOperationByAliasParams) HTTPVerb added in v0.0.14 

func (p *GetOperationByAliasParams) HTTPVerb() Verb

func (*GetOperationByAliasParams) Log added in v0.0.14 

func (p *GetOperationByAliasParams) Log() []log.Field

func (*GetOperationByAliasParams) MarshalHTTP added in v0.0.14 

func (p *GetOperationByAliasParams) MarshalHTTP(w *yson.Writer)

func (*GetOperationByAliasParams) YPath added in v0.0.14 

func (p *GetOperationByAliasParams) YPath() (ypath.YPath, bool)

type GetOperationParams 

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

func NewGetOperationParams 

func NewGetOperationParams(
	opID yt.OperationID,
	options *yt.GetOperationOptions,
) *GetOperationParams

func (*GetOperationParams) HTTPVerb 

func (p *GetOperationParams) HTTPVerb() Verb

func (*GetOperationParams) Log 

func (p *GetOperationParams) Log() []log.Field

func (*GetOperationParams) MarshalHTTP 

func (p *GetOperationParams) MarshalHTTP(w *yson.Writer)

func (*GetOperationParams) MasterReadOptions 

func (p *GetOperationParams) MasterReadOptions() **yt.MasterReadOptions

func (*GetOperationParams) ReadRetryOptions 

func (p *GetOperationParams) ReadRetryOptions() **yt.ReadRetryOptions

func (*GetOperationParams) YPath 

func (p *GetOperationParams) YPath() (ypath.YPath, bool)

type GetQueryParams added in v0.0.10 

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

func NewGetQueryParams added in v0.0.10 

func NewGetQueryParams(
	id yt.QueryID,
	options *yt.GetQueryOptions,
) *GetQueryParams

func (*GetQueryParams) HTTPVerb added in v0.0.10 

func (p *GetQueryParams) HTTPVerb() Verb

func (*GetQueryParams) Log added in v0.0.10 

func (p *GetQueryParams) Log() []log.Field

func (*GetQueryParams) MarshalHTTP added in v0.0.10 

func (p *GetQueryParams) MarshalHTTP(w *yson.Writer)

func (*GetQueryParams) QueryTrackerOptions added in v0.0.10 

func (p *GetQueryParams) QueryTrackerOptions() **yt.QueryTrackerOptions

func (*GetQueryParams) YPath added in v0.0.10 

func (p *GetQueryParams) YPath() (ypath.YPath, bool)

type GetQueryResultParams added in v0.0.10 

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

func NewGetQueryResultParams added in v0.0.10 

func NewGetQueryResultParams(
	id yt.QueryID,
	resultIndex int64,
	options *yt.GetQueryResultOptions,
) *GetQueryResultParams

func (*GetQueryResultParams) HTTPVerb added in v0.0.10 

func (p *GetQueryResultParams) HTTPVerb() Verb

func (*GetQueryResultParams) Log added in v0.0.10 

func (p *GetQueryResultParams) Log() []log.Field

func (*GetQueryResultParams) MarshalHTTP added in v0.0.10 

func (p *GetQueryResultParams) MarshalHTTP(w *yson.Writer)

func (*GetQueryResultParams) QueryTrackerOptions added in v0.0.10 

func (p *GetQueryResultParams) QueryTrackerOptions() **yt.QueryTrackerOptions

func (*GetQueryResultParams) YPath added in v0.0.10 

func (p *GetQueryResultParams) YPath() (ypath.YPath, bool)

type InsertRowsParams 

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

func NewInsertRowsParams 

func NewInsertRowsParams(
	path ypath.Path,
	options *yt.InsertRowsOptions,
) *InsertRowsParams

func (*InsertRowsParams) HTTPVerb 

func (p *InsertRowsParams) HTTPVerb() Verb

func (*InsertRowsParams) Log 

func (p *InsertRowsParams) Log() []log.Field

func (*InsertRowsParams) MarshalHTTP 

func (p *InsertRowsParams) MarshalHTTP(w *yson.Writer)

func (*InsertRowsParams) TransactionOptions 

func (p *InsertRowsParams) TransactionOptions() **yt.TransactionOptions

func (*InsertRowsParams) YPath 

func (p *InsertRowsParams) YPath() (ypath.YPath, bool)

type IssueTokenParams added in v0.0.17 

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

func NewIssueTokenParams added in v0.0.17 

func NewIssueTokenParams(
	user string,
	password string,
	options *yt.IssueTokenOptions,
) *IssueTokenParams

func (*IssueTokenParams) HTTPVerb added in v0.0.17 

func (p *IssueTokenParams) HTTPVerb() Verb

func (*IssueTokenParams) Log added in v0.0.17 

func (p *IssueTokenParams) Log() []log.Field

func (*IssueTokenParams) MarshalHTTP added in v0.0.17 

func (p *IssueTokenParams) MarshalHTTP(w *yson.Writer)

func (*IssueTokenParams) YPath added in v0.0.17 

func (p *IssueTokenParams) YPath() (ypath.YPath, bool)

type LinkNodeParams 

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

func NewLinkNodeParams 

func NewLinkNodeParams(
	target ypath.YPath,
	link ypath.YPath,
	options *yt.LinkNodeOptions,
) *LinkNodeParams

func (*LinkNodeParams) HTTPVerb 

func (p *LinkNodeParams) HTTPVerb() Verb

func (*LinkNodeParams) Log 

func (p *LinkNodeParams) Log() []log.Field

func (*LinkNodeParams) MarshalHTTP 

func (p *LinkNodeParams) MarshalHTTP(w *yson.Writer)

func (*LinkNodeParams) MutatingOptions 

func (p *LinkNodeParams) MutatingOptions() **yt.MutatingOptions

func (*LinkNodeParams) PrerequisiteOptions 

func (p *LinkNodeParams) PrerequisiteOptions() **yt.PrerequisiteOptions

func (*LinkNodeParams) TransactionOptions 

func (p *LinkNodeParams) TransactionOptions() **yt.TransactionOptions

func (*LinkNodeParams) YPath 

func (p *LinkNodeParams) YPath() (ypath.YPath, bool)

type ListJobsParams 

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

func NewListJobsParams 

func NewListJobsParams(
	opID yt.OperationID,
	options *yt.ListJobsOptions,
) *ListJobsParams

func (*ListJobsParams) HTTPVerb 

func (p *ListJobsParams) HTTPVerb() Verb

func (*ListJobsParams) Log 

func (p *ListJobsParams) Log() []log.Field

func (*ListJobsParams) MarshalHTTP 

func (p *ListJobsParams) MarshalHTTP(w *yson.Writer)

func (*ListJobsParams) YPath 

func (p *ListJobsParams) YPath() (ypath.YPath, bool)

type ListNodeParams 

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

func NewListNodeParams 

func NewListNodeParams(
	path ypath.YPath,
	options *yt.ListNodeOptions,
) *ListNodeParams

func (*ListNodeParams) AccessTrackingOptions 

func (p *ListNodeParams) AccessTrackingOptions() **yt.AccessTrackingOptions

func (*ListNodeParams) HTTPVerb 

func (p *ListNodeParams) HTTPVerb() Verb

func (*ListNodeParams) Log 

func (p *ListNodeParams) Log() []log.Field

func (*ListNodeParams) MarshalHTTP 

func (p *ListNodeParams) MarshalHTTP(w *yson.Writer)

func (*ListNodeParams) MasterReadOptions 

func (p *ListNodeParams) MasterReadOptions() **yt.MasterReadOptions

func (*ListNodeParams) PrerequisiteOptions 

func (p *ListNodeParams) PrerequisiteOptions() **yt.PrerequisiteOptions

func (*ListNodeParams) ReadRetryOptions 

func (p *ListNodeParams) ReadRetryOptions() **yt.ReadRetryOptions

func (*ListNodeParams) TransactionOptions 

func (p *ListNodeParams) TransactionOptions() **yt.TransactionOptions

func (*ListNodeParams) YPath 

func (p *ListNodeParams) YPath() (ypath.YPath, bool)

type ListOperationsParams 

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

func NewListOperationsParams 

func NewListOperationsParams(
	options *yt.ListOperationsOptions,
) *ListOperationsParams

func (*ListOperationsParams) HTTPVerb 

func (p *ListOperationsParams) HTTPVerb() Verb

func (*ListOperationsParams) Log 

func (p *ListOperationsParams) Log() []log.Field

func (*ListOperationsParams) MarshalHTTP 

func (p *ListOperationsParams) MarshalHTTP(w *yson.Writer)

func (*ListOperationsParams) MasterReadOptions 

func (p *ListOperationsParams) MasterReadOptions() **yt.MasterReadOptions

func (*ListOperationsParams) ReadRetryOptions 

func (p *ListOperationsParams) ReadRetryOptions() **yt.ReadRetryOptions

func (*ListOperationsParams) YPath 

func (p *ListOperationsParams) YPath() (ypath.YPath, bool)

type ListQueriesParams added in v0.0.10 

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

func NewListQueriesParams added in v0.0.10 

func NewListQueriesParams(
	options *yt.ListQueriesOptions,
) *ListQueriesParams

func (*ListQueriesParams) HTTPVerb added in v0.0.10 

func (p *ListQueriesParams) HTTPVerb() Verb

func (*ListQueriesParams) Log added in v0.0.10 

func (p *ListQueriesParams) Log() []log.Field

func (*ListQueriesParams) MarshalHTTP added in v0.0.10 

func (p *ListQueriesParams) MarshalHTTP(w *yson.Writer)

func (*ListQueriesParams) QueryTrackerOptions added in v0.0.10 

func (p *ListQueriesParams) QueryTrackerOptions() **yt.QueryTrackerOptions

func (*ListQueriesParams) YPath added in v0.0.10 

func (p *ListQueriesParams) YPath() (ypath.YPath, bool)

type ListUserTokensParams added in v0.0.17 

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

func NewListUserTokensParams added in v0.0.17 

func NewListUserTokensParams(
	user string,
	password string,
	options *yt.ListUserTokensOptions,
) *ListUserTokensParams

func (*ListUserTokensParams) HTTPVerb added in v0.0.17 

func (p *ListUserTokensParams) HTTPVerb() Verb

func (*ListUserTokensParams) Log added in v0.0.17 

func (p *ListUserTokensParams) Log() []log.Field

func (*ListUserTokensParams) MarshalHTTP added in v0.0.17 

func (p *ListUserTokensParams) MarshalHTTP(w *yson.Writer)

func (*ListUserTokensParams) YPath added in v0.0.17 

func (p *ListUserTokensParams) YPath() (ypath.YPath, bool)

type LocateSkynetShareParams 

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

func NewLocateSkynetShareParams 

func NewLocateSkynetShareParams(
	path ypath.YPath,
	options *yt.LocateSkynetShareOptions,
) *LocateSkynetShareParams

func (*LocateSkynetShareParams) HTTPVerb 

func (p *LocateSkynetShareParams) HTTPVerb() Verb

func (*LocateSkynetShareParams) Log 

func (p *LocateSkynetShareParams) Log() []log.Field

func (*LocateSkynetShareParams) MarshalHTTP 

func (p *LocateSkynetShareParams) MarshalHTTP(w *yson.Writer)

func (*LocateSkynetShareParams) YPath 

func (p *LocateSkynetShareParams) YPath() (ypath.YPath, bool)

type LockNodeParams 

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

func NewLockNodeParams 

func NewLockNodeParams(
	path ypath.YPath,
	mode yt.LockMode,
	options *yt.LockNodeOptions,
) *LockNodeParams

func (*LockNodeParams) HTTPVerb 

func (p *LockNodeParams) HTTPVerb() Verb

func (*LockNodeParams) Log 

func (p *LockNodeParams) Log() []log.Field

func (*LockNodeParams) MarshalHTTP 

func (p *LockNodeParams) MarshalHTTP(w *yson.Writer)

func (*LockNodeParams) MutatingOptions 

func (p *LockNodeParams) MutatingOptions() **yt.MutatingOptions

func (*LockNodeParams) TransactionOptions 

func (p *LockNodeParams) TransactionOptions() **yt.TransactionOptions

func (*LockNodeParams) YPath 

func (p *LockNodeParams) YPath() (ypath.YPath, bool)

type LockRowsParams 

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

func NewLockRowsParams 

func NewLockRowsParams(
	path ypath.Path,
	locks []string,
	lockType yt.LockType,
	options *yt.LockRowsOptions,
) *LockRowsParams

func (*LockRowsParams) HTTPVerb 

func (p *LockRowsParams) HTTPVerb() Verb

func (*LockRowsParams) Log 

func (p *LockRowsParams) Log() []log.Field

func (*LockRowsParams) MarshalHTTP 

func (p *LockRowsParams) MarshalHTTP(w *yson.Writer)

func (*LockRowsParams) TransactionOptions 

func (p *LockRowsParams) TransactionOptions() **yt.TransactionOptions

func (*LockRowsParams) YPath 

func (p *LockRowsParams) YPath() (ypath.YPath, bool)

type LoggingInterceptor 

type LoggingInterceptor struct {
	log.Structured
}

func (*LoggingInterceptor) Intercept 

func (l *LoggingInterceptor) Intercept(ctx context.Context, call *Call, invoke CallInvoker) (res *CallResult, err error)

func (*LoggingInterceptor) Read 

func (l *LoggingInterceptor) Read(ctx context.Context, call *Call, invoke ReadInvoker) (r io.ReadCloser, err error)

func (*LoggingInterceptor) Write 

func (l *LoggingInterceptor) Write(ctx context.Context, call *Call, invoke WriteInvoker) (w io.WriteCloser, err error)

type LookupRowsParams 

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

func NewLookupRowsParams 

func NewLookupRowsParams(
	path ypath.Path,
	options *yt.LookupRowsOptions,
) *LookupRowsParams

func (*LookupRowsParams) HTTPVerb 

func (p *LookupRowsParams) HTTPVerb() Verb

func (*LookupRowsParams) Log 

func (p *LookupRowsParams) Log() []log.Field

func (*LookupRowsParams) MarshalHTTP 

func (p *LookupRowsParams) MarshalHTTP(w *yson.Writer)

func (*LookupRowsParams) TransactionOptions 

func (p *LookupRowsParams) TransactionOptions() **yt.TransactionOptions

func (*LookupRowsParams) YPath 

func (p *LookupRowsParams) YPath() (ypath.YPath, bool)

type MountTableParams 

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

func NewMountTableParams 

func NewMountTableParams(
	path ypath.Path,
	options *yt.MountTableOptions,
) *MountTableParams

func (*MountTableParams) HTTPVerb 

func (p *MountTableParams) HTTPVerb() Verb

func (*MountTableParams) Log 

func (p *MountTableParams) Log() []log.Field

func (*MountTableParams) MarshalHTTP 

func (p *MountTableParams) MarshalHTTP(w *yson.Writer)

func (*MountTableParams) MutatingOptions 

func (p *MountTableParams) MutatingOptions() **yt.MutatingOptions

func (*MountTableParams) TabletRangeOptions 

func (p *MountTableParams) TabletRangeOptions() **yt.TabletRangeOptions

func (*MountTableParams) YPath 

func (p *MountTableParams) YPath() (ypath.YPath, bool)

type MoveNodeParams 

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

func NewMoveNodeParams 

func NewMoveNodeParams(
	src ypath.YPath,
	dst ypath.YPath,
	options *yt.MoveNodeOptions,
) *MoveNodeParams

func (*MoveNodeParams) HTTPVerb 

func (p *MoveNodeParams) HTTPVerb() Verb

func (*MoveNodeParams) Log 

func (p *MoveNodeParams) Log() []log.Field

func (*MoveNodeParams) MarshalHTTP 

func (p *MoveNodeParams) MarshalHTTP(w *yson.Writer)

func (*MoveNodeParams) MutatingOptions 

func (p *MoveNodeParams) MutatingOptions() **yt.MutatingOptions

func (*MoveNodeParams) PrerequisiteOptions 

func (p *MoveNodeParams) PrerequisiteOptions() **yt.PrerequisiteOptions

func (*MoveNodeParams) TransactionOptions 

func (p *MoveNodeParams) TransactionOptions() **yt.TransactionOptions

func (*MoveNodeParams) YPath 

func (p *MoveNodeParams) YPath() (ypath.YPath, bool)

type MultisetAttributesParams 

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

func NewMultisetAttributesParams 

func NewMultisetAttributesParams(
	path ypath.YPath,
	options *yt.MultisetAttributesOptions,
) *MultisetAttributesParams

func (*MultisetAttributesParams) AccessTrackingOptions 

func (p *MultisetAttributesParams) AccessTrackingOptions() **yt.AccessTrackingOptions

func (*MultisetAttributesParams) HTTPVerb 

func (p *MultisetAttributesParams) HTTPVerb() Verb

func (*MultisetAttributesParams) Log 

func (p *MultisetAttributesParams) Log() []log.Field

func (*MultisetAttributesParams) MarshalHTTP 

func (p *MultisetAttributesParams) MarshalHTTP(w *yson.Writer)

func (*MultisetAttributesParams) MutatingOptions 

func (p *MultisetAttributesParams) MutatingOptions() **yt.MutatingOptions

func (*MultisetAttributesParams) PrerequisiteOptions 

func (p *MultisetAttributesParams) PrerequisiteOptions() **yt.PrerequisiteOptions

func (*MultisetAttributesParams) TransactionOptions 

func (p *MultisetAttributesParams) TransactionOptions() **yt.TransactionOptions

func (*MultisetAttributesParams) YPath 

func (p *MultisetAttributesParams) YPath() (ypath.YPath, bool)

type MutatingParams 

type MutatingParams interface {
	MutatingOptions() **yt.MutatingOptions
}

type MutationRetrier 

type MutationRetrier struct {
	Log log.Structured
}

func (*MutationRetrier) Intercept 

func (r *MutationRetrier) Intercept(ctx context.Context, call *Call, invoke CallInvoker) (res *CallResult, err error)

type NodeExistsParams 

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

func NewNodeExistsParams 

func NewNodeExistsParams(
	path ypath.YPath,
	options *yt.NodeExistsOptions,
) *NodeExistsParams

func (*NodeExistsParams) AccessTrackingOptions 

func (p *NodeExistsParams) AccessTrackingOptions() **yt.AccessTrackingOptions

func (*NodeExistsParams) HTTPVerb 

func (p *NodeExistsParams) HTTPVerb() Verb

func (*NodeExistsParams) Log 

func (p *NodeExistsParams) Log() []log.Field

func (*NodeExistsParams) MarshalHTTP 

func (p *NodeExistsParams) MarshalHTTP(w *yson.Writer)

func (*NodeExistsParams) MasterReadOptions 

func (p *NodeExistsParams) MasterReadOptions() **yt.MasterReadOptions

func (*NodeExistsParams) ReadRetryOptions 

func (p *NodeExistsParams) ReadRetryOptions() **yt.ReadRetryOptions

func (*NodeExistsParams) TransactionOptions 

func (p *NodeExistsParams) TransactionOptions() **yt.TransactionOptions

func (*NodeExistsParams) YPath 

func (p *NodeExistsParams) YPath() (ypath.YPath, bool)

type Params 

type Params interface {
	HTTPVerb() Verb

	YPath() (ypath.YPath, bool)
	Log() []log.Field

	MarshalHTTP(w *yson.Writer)
}

type PingTxParams 

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

func NewPingTxParams 

func NewPingTxParams(
	id yt.TxID,
	options *yt.PingTxOptions,
) *PingTxParams

func (*PingTxParams) HTTPVerb 

func (p *PingTxParams) HTTPVerb() Verb

func (*PingTxParams) Log 

func (p *PingTxParams) Log() []log.Field

func (*PingTxParams) MarshalHTTP 

func (p *PingTxParams) MarshalHTTP(w *yson.Writer)

func (*PingTxParams) TransactionOptions 

func (p *PingTxParams) TransactionOptions() **yt.TransactionOptions

func (*PingTxParams) YPath 

func (p *PingTxParams) YPath() (ypath.YPath, bool)

type Pinger 

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

Pinger tracks server transaction state and performs periodic pings.

func NewPinger 

func NewPinger(
	ctx context.Context,
	yc yt.LowLevelTxClient,
	txID yt.TxID,
	config *yt.Config,
	stop *StopGroup,
) *Pinger

func (*Pinger) CheckAlive 

func (p *Pinger) CheckAlive() error

func (*Pinger) Config 

func (p *Pinger) Config() *yt.Config

func (*Pinger) Ctx 

func (p *Pinger) Ctx() context.Context

func (*Pinger) Finished 

func (p *Pinger) Finished() <-chan struct{}

func (*Pinger) ID 

func (p *Pinger) ID() yt.TxID

func (*Pinger) OnTxError 

func (p *Pinger) OnTxError(err error)

OnTxError may be optionally invoked to snoop transaction state from failure of other commands.

func (*Pinger) Run 

func (p *Pinger) Run()

func (*Pinger) Stop 

func (p *Pinger) Stop() *StopGroup

func (*Pinger) TryAbort 

func (p *Pinger) TryAbort(aborter func() error) error

func (*Pinger) TryCommit 

func (p *Pinger) TryCommit(committer func() error) error

type ProxyBouncer 

type ProxyBouncer struct {
	Log log.Structured

	ProxySet *ProxySet
}

func (*ProxyBouncer) Intercept 

func (b *ProxyBouncer) Intercept(ctx context.Context, call *Call, next CallInvoker) (res *CallResult, err error)

func (*ProxyBouncer) Read 

func (b *ProxyBouncer) Read(ctx context.Context, call *Call, next ReadInvoker) (r io.ReadCloser, err error)

func (*ProxyBouncer) Write 

func (b *ProxyBouncer) Write(ctx context.Context, call *Call, next WriteInvoker) (w io.WriteCloser, err error)

type ProxySet 

type ProxySet struct {
	UpdatePeriod time.Duration
	BanDuration  time.Duration
	UpdateFn     func() ([]string, error)

	ActiveSetSize int
	// contains filtered or unexported fields
}

func (*ProxySet) BanProxy 

func (s *ProxySet) BanProxy(name string)

func (*ProxySet) PickRandom 

func (s *ProxySet) PickRandom(ctx context.Context) (string, error)

type PutFileToCacheParams 

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

func NewPutFileToCacheParams 

func NewPutFileToCacheParams(
	path ypath.YPath,
	md5 string,
	options *yt.PutFileToCacheOptions,
) *PutFileToCacheParams

func (*PutFileToCacheParams) HTTPVerb 

func (p *PutFileToCacheParams) HTTPVerb() Verb

func (*PutFileToCacheParams) Log 

func (p *PutFileToCacheParams) Log() []log.Field

func (*PutFileToCacheParams) MarshalHTTP 

func (p *PutFileToCacheParams) MarshalHTTP(w *yson.Writer)

func (*PutFileToCacheParams) MasterReadOptions 

func (p *PutFileToCacheParams) MasterReadOptions() **yt.MasterReadOptions

func (*PutFileToCacheParams) MutatingOptions 

func (p *PutFileToCacheParams) MutatingOptions() **yt.MutatingOptions

func (*PutFileToCacheParams) PrerequisiteOptions 

func (p *PutFileToCacheParams) PrerequisiteOptions() **yt.PrerequisiteOptions

func (*PutFileToCacheParams) YPath 

func (p *PutFileToCacheParams) YPath() (ypath.YPath, bool)

type ReadFileParams 

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

func NewReadFileParams 

func NewReadFileParams(
	path ypath.YPath,
	options *yt.ReadFileOptions,
) *ReadFileParams

func (*ReadFileParams) AccessTrackingOptions 

func (p *ReadFileParams) AccessTrackingOptions() **yt.AccessTrackingOptions

func (*ReadFileParams) HTTPVerb 

func (p *ReadFileParams) HTTPVerb() Verb

func (*ReadFileParams) Log 

func (p *ReadFileParams) Log() []log.Field

func (*ReadFileParams) MarshalHTTP 

func (p *ReadFileParams) MarshalHTTP(w *yson.Writer)

func (*ReadFileParams) TransactionOptions 

func (p *ReadFileParams) TransactionOptions() **yt.TransactionOptions

func (*ReadFileParams) YPath 

func (p *ReadFileParams) YPath() (ypath.YPath, bool)

type ReadInterceptor 

type ReadInterceptor func(ctx context.Context, call *Call, invoke ReadInvoker) (r io.ReadCloser, err error)

type ReadInvoker 

type ReadInvoker func(ctx context.Context, call *Call) (r io.ReadCloser, err error)

func (ReadInvoker) Wrap 

func (c ReadInvoker) Wrap(interceptor ReadInterceptor) ReadInvoker

type ReadQueryResultParams added in v0.0.10 

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

func NewReadQueryResultParams added in v0.0.10 

func NewReadQueryResultParams(
	id yt.QueryID,
	resultIndex int64,
	options *yt.ReadQueryResultOptions,
) *ReadQueryResultParams

func (*ReadQueryResultParams) HTTPVerb added in v0.0.10 

func (p *ReadQueryResultParams) HTTPVerb() Verb

func (*ReadQueryResultParams) Log added in v0.0.10 

func (p *ReadQueryResultParams) Log() []log.Field

func (*ReadQueryResultParams) MarshalHTTP added in v0.0.10 

func (p *ReadQueryResultParams) MarshalHTTP(w *yson.Writer)

func (*ReadQueryResultParams) QueryTrackerOptions added in v0.0.10 

func (p *ReadQueryResultParams) QueryTrackerOptions() **yt.QueryTrackerOptions

func (*ReadQueryResultParams) YPath added in v0.0.10 

func (p *ReadQueryResultParams) YPath() (ypath.YPath, bool)

type ReadRetryParams 

type ReadRetryParams interface {
	ReadRetryOptions() **yt.ReadRetryOptions
}

type ReadRowInterceptor 

type ReadRowInterceptor func(ctx context.Context, call *Call, invoke ReadRowInvoker) (r yt.TableReader, err error)

type ReadRowInvoker 

type ReadRowInvoker func(ctx context.Context, call *Call) (r yt.TableReader, err error)

func (ReadRowInvoker) Wrap 

func (c ReadRowInvoker) Wrap(interceptor ReadRowInterceptor) ReadRowInvoker

type ReadTableParams 

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

func NewReadTableParams 

func NewReadTableParams(
	path ypath.YPath,
	options *yt.ReadTableOptions,
) *ReadTableParams

func (*ReadTableParams) AccessTrackingOptions 

func (p *ReadTableParams) AccessTrackingOptions() **yt.AccessTrackingOptions

func (*ReadTableParams) HTTPVerb 

func (p *ReadTableParams) HTTPVerb() Verb

func (*ReadTableParams) Log 

func (p *ReadTableParams) Log() []log.Field

func (*ReadTableParams) MarshalHTTP 

func (p *ReadTableParams) MarshalHTTP(w *yson.Writer)

func (*ReadTableParams) TransactionOptions 

func (p *ReadTableParams) TransactionOptions() **yt.TransactionOptions

func (*ReadTableParams) YPath 

func (p *ReadTableParams) YPath() (ypath.YPath, bool)

type RemountTableParams 

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

func NewRemountTableParams 

func NewRemountTableParams(
	path ypath.Path,
	options *yt.RemountTableOptions,
) *RemountTableParams

func (*RemountTableParams) HTTPVerb 

func (p *RemountTableParams) HTTPVerb() Verb

func (*RemountTableParams) Log 

func (p *RemountTableParams) Log() []log.Field

func (*RemountTableParams) MarshalHTTP 

func (p *RemountTableParams) MarshalHTTP(w *yson.Writer)

func (*RemountTableParams) MutatingOptions 

func (p *RemountTableParams) MutatingOptions() **yt.MutatingOptions

func (*RemountTableParams) TabletRangeOptions 

func (p *RemountTableParams) TabletRangeOptions() **yt.TabletRangeOptions

func (*RemountTableParams) YPath 

func (p *RemountTableParams) YPath() (ypath.YPath, bool)

type RemoveMaintenanceParams added in v0.0.7 

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

func NewRemoveMaintenanceParams added in v0.0.7 

func NewRemoveMaintenanceParams(
	component yt.MaintenanceComponent,
	address string,
	options *yt.RemoveMaintenanceOptions,
) *RemoveMaintenanceParams

func (*RemoveMaintenanceParams) HTTPVerb added in v0.0.7 

func (p *RemoveMaintenanceParams) HTTPVerb() Verb

func (*RemoveMaintenanceParams) Log added in v0.0.7 

func (p *RemoveMaintenanceParams) Log() []log.Field

func (*RemoveMaintenanceParams) MarshalHTTP added in v0.0.7 

func (p *RemoveMaintenanceParams) MarshalHTTP(w *yson.Writer)

func (*RemoveMaintenanceParams) YPath added in v0.0.7 

func (p *RemoveMaintenanceParams) YPath() (ypath.YPath, bool)

type RemoveMemberParams 

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

func NewRemoveMemberParams 

func NewRemoveMemberParams(
	group string,
	member string,
	options *yt.RemoveMemberOptions,
) *RemoveMemberParams

func (*RemoveMemberParams) HTTPVerb 

func (p *RemoveMemberParams) HTTPVerb() Verb

func (*RemoveMemberParams) Log 

func (p *RemoveMemberParams) Log() []log.Field

func (*RemoveMemberParams) MarshalHTTP 

func (p *RemoveMemberParams) MarshalHTTP(w *yson.Writer)

func (*RemoveMemberParams) MutatingOptions 

func (p *RemoveMemberParams) MutatingOptions() **yt.MutatingOptions

func (*RemoveMemberParams) PrerequisiteOptions 

func (p *RemoveMemberParams) PrerequisiteOptions() **yt.PrerequisiteOptions

func (*RemoveMemberParams) YPath 

func (p *RemoveMemberParams) YPath() (ypath.YPath, bool)

type RemoveNodeParams 

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

func NewRemoveNodeParams 

func NewRemoveNodeParams(
	path ypath.YPath,
	options *yt.RemoveNodeOptions,
) *RemoveNodeParams

func (*RemoveNodeParams) AccessTrackingOptions 

func (p *RemoveNodeParams) AccessTrackingOptions() **yt.AccessTrackingOptions

func (*RemoveNodeParams) HTTPVerb 

func (p *RemoveNodeParams) HTTPVerb() Verb

func (*RemoveNodeParams) Log 

func (p *RemoveNodeParams) Log() []log.Field

func (*RemoveNodeParams) MarshalHTTP 

func (p *RemoveNodeParams) MarshalHTTP(w *yson.Writer)

func (*RemoveNodeParams) MutatingOptions 

func (p *RemoveNodeParams) MutatingOptions() **yt.MutatingOptions

func (*RemoveNodeParams) PrerequisiteOptions 

func (p *RemoveNodeParams) PrerequisiteOptions() **yt.PrerequisiteOptions

func (*RemoveNodeParams) TransactionOptions 

func (p *RemoveNodeParams) TransactionOptions() **yt.TransactionOptions

func (*RemoveNodeParams) YPath 

func (p *RemoveNodeParams) YPath() (ypath.YPath, bool)

type RequestRestartParams added in v0.0.10 

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

func NewRequestRestartParams added in v0.0.10 

func NewRequestRestartParams(
	nodeAddress string,
	options *yt.RequestRestartOptions,
) *RequestRestartParams

func (*RequestRestartParams) HTTPVerb added in v0.0.10 

func (p *RequestRestartParams) HTTPVerb() Verb

func (*RequestRestartParams) Log added in v0.0.10 

func (p *RequestRestartParams) Log() []log.Field

func (*RequestRestartParams) MarshalHTTP added in v0.0.10 

func (p *RequestRestartParams) MarshalHTTP(w *yson.Writer)

func (*RequestRestartParams) YPath added in v0.0.10 

func (p *RequestRestartParams) YPath() (ypath.YPath, bool)

type ReshardTableParams 

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

func NewReshardTableParams 

func NewReshardTableParams(
	path ypath.Path,
	options *yt.ReshardTableOptions,
) *ReshardTableParams

func (*ReshardTableParams) HTTPVerb 

func (p *ReshardTableParams) HTTPVerb() Verb

func (*ReshardTableParams) Log 

func (p *ReshardTableParams) Log() []log.Field

func (*ReshardTableParams) MarshalHTTP 

func (p *ReshardTableParams) MarshalHTTP(w *yson.Writer)

func (*ReshardTableParams) MutatingOptions 

func (p *ReshardTableParams) MutatingOptions() **yt.MutatingOptions

func (*ReshardTableParams) TabletRangeOptions 

func (p *ReshardTableParams) TabletRangeOptions() **yt.TabletRangeOptions

func (*ReshardTableParams) YPath 

func (p *ReshardTableParams) YPath() (ypath.YPath, bool)

type RestoreTableBackupParams added in v0.0.10 

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

func NewRestoreTableBackupParams added in v0.0.10 

func NewRestoreTableBackupParams(
	manifest yt.BackupManifest,
	options *yt.RestoreTableBackupOptions,
) *RestoreTableBackupParams

func (*RestoreTableBackupParams) HTTPVerb added in v0.0.10 

func (p *RestoreTableBackupParams) HTTPVerb() Verb

func (*RestoreTableBackupParams) Log added in v0.0.10 

func (p *RestoreTableBackupParams) Log() []log.Field

func (*RestoreTableBackupParams) MarshalHTTP added in v0.0.10 

func (p *RestoreTableBackupParams) MarshalHTTP(w *yson.Writer)

func (*RestoreTableBackupParams) TimeoutOptions added in v0.0.10 

func (p *RestoreTableBackupParams) TimeoutOptions() **yt.TimeoutOptions

func (*RestoreTableBackupParams) YPath added in v0.0.10 

func (p *RestoreTableBackupParams) YPath() (ypath.YPath, bool)

type ResumeOperationParams 

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

func NewResumeOperationParams 

func NewResumeOperationParams(
	opID yt.OperationID,
	options *yt.ResumeOperationOptions,
) *ResumeOperationParams

func (*ResumeOperationParams) HTTPVerb 

func (p *ResumeOperationParams) HTTPVerb() Verb

func (*ResumeOperationParams) Log 

func (p *ResumeOperationParams) Log() []log.Field

func (*ResumeOperationParams) MarshalHTTP 

func (p *ResumeOperationParams) MarshalHTTP(w *yson.Writer)

func (*ResumeOperationParams) YPath 

func (p *ResumeOperationParams) YPath() (ypath.YPath, bool)

type ResurrectChunkLocationsParams added in v0.0.3 

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

func NewResurrectChunkLocationsParams added in v0.0.3 

func NewResurrectChunkLocationsParams(
	nodeAddress string,
	locationUUIDs []guid.GUID,
	options *yt.ResurrectChunkLocationsOptions,
) *ResurrectChunkLocationsParams

func (*ResurrectChunkLocationsParams) HTTPVerb added in v0.0.3 

func (p *ResurrectChunkLocationsParams) HTTPVerb() Verb

func (*ResurrectChunkLocationsParams) Log added in v0.0.3 

func (p *ResurrectChunkLocationsParams) Log() []log.Field

func (*ResurrectChunkLocationsParams) MarshalHTTP added in v0.0.3 

func (p *ResurrectChunkLocationsParams) MarshalHTTP(w *yson.Writer)

func (*ResurrectChunkLocationsParams) YPath added in v0.0.3 

func (p *ResurrectChunkLocationsParams) YPath() (ypath.YPath, bool)

type Retrier 

type Retrier struct {
	ProxySet *ProxySet
	Config   *yt.Config

	Log log.Structured
}

func (*Retrier) Intercept 

func (r *Retrier) Intercept(ctx context.Context, call *Call, invoke CallInvoker) (res *CallResult, err error)

func (*Retrier) Read 

func (r *Retrier) Read(ctx context.Context, call *Call, invoke ReadInvoker) (rc io.ReadCloser, err error)

func (*Retrier) Write 

func (r *Retrier) Write(ctx context.Context, call *Call, invoke WriteInvoker) (w io.WriteCloser, err error)

type RevokeTokenParams added in v0.0.17 

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

func NewRevokeTokenParams added in v0.0.17 

func NewRevokeTokenParams(
	user string,
	password string,
	token string,
	options *yt.RevokeTokenOptions,
) *RevokeTokenParams

func (*RevokeTokenParams) HTTPVerb added in v0.0.17 

func (p *RevokeTokenParams) HTTPVerb() Verb

func (*RevokeTokenParams) Log added in v0.0.17 

func (p *RevokeTokenParams) Log() []log.Field

func (*RevokeTokenParams) MarshalHTTP added in v0.0.17 

func (p *RevokeTokenParams) MarshalHTTP(w *yson.Writer)

func (*RevokeTokenParams) YPath added in v0.0.17 

func (p *RevokeTokenParams) YPath() (ypath.YPath, bool)

type SelectRowsParams 

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

func NewSelectRowsParams 

func NewSelectRowsParams(
	query string,
	options *yt.SelectRowsOptions,
) *SelectRowsParams

func (*SelectRowsParams) HTTPVerb 

func (p *SelectRowsParams) HTTPVerb() Verb

func (*SelectRowsParams) Log 

func (p *SelectRowsParams) Log() []log.Field

func (*SelectRowsParams) MarshalHTTP 

func (p *SelectRowsParams) MarshalHTTP(w *yson.Writer)

func (*SelectRowsParams) TimeoutOptions 

func (p *SelectRowsParams) TimeoutOptions() **yt.TimeoutOptions

func (*SelectRowsParams) TransactionOptions 

func (p *SelectRowsParams) TransactionOptions() **yt.TransactionOptions

func (*SelectRowsParams) YPath 

func (p *SelectRowsParams) YPath() (ypath.YPath, bool)

type SetNodeParams 

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

func NewSetNodeParams 

func NewSetNodeParams(
	path ypath.YPath,
	options *yt.SetNodeOptions,
) *SetNodeParams

func (*SetNodeParams) AccessTrackingOptions 

func (p *SetNodeParams) AccessTrackingOptions() **yt.AccessTrackingOptions

func (*SetNodeParams) HTTPVerb 

func (p *SetNodeParams) HTTPVerb() Verb

func (*SetNodeParams) Log 

func (p *SetNodeParams) Log() []log.Field

func (*SetNodeParams) MarshalHTTP 

func (p *SetNodeParams) MarshalHTTP(w *yson.Writer)

func (*SetNodeParams) MutatingOptions 

func (p *SetNodeParams) MutatingOptions() **yt.MutatingOptions

func (*SetNodeParams) PrerequisiteOptions 

func (p *SetNodeParams) PrerequisiteOptions() **yt.PrerequisiteOptions

func (*SetNodeParams) TransactionOptions 

func (p *SetNodeParams) TransactionOptions() **yt.TransactionOptions

func (*SetNodeParams) YPath 

func (p *SetNodeParams) YPath() (ypath.YPath, bool)

type SetUserPasswordParams added in v0.0.17 

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

func NewSetUserPasswordParams added in v0.0.17 

func NewSetUserPasswordParams(
	user string,
	newPassword string,
	currentPassword string,
	options *yt.SetUserPasswordOptions,
) *SetUserPasswordParams

func (*SetUserPasswordParams) HTTPVerb added in v0.0.17 

func (p *SetUserPasswordParams) HTTPVerb() Verb

func (*SetUserPasswordParams) Log added in v0.0.17 

func (p *SetUserPasswordParams) Log() []log.Field

func (*SetUserPasswordParams) MarshalHTTP added in v0.0.17 

func (p *SetUserPasswordParams) MarshalHTTP(w *yson.Writer)

func (*SetUserPasswordParams) YPath added in v0.0.17 

func (p *SetUserPasswordParams) YPath() (ypath.YPath, bool)

type StartOperationParams 

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

func NewStartOperationParams 

func NewStartOperationParams(
	opType yt.OperationType,
	spec any,
	options *yt.StartOperationOptions,
) *StartOperationParams

func (*StartOperationParams) HTTPVerb 

func (p *StartOperationParams) HTTPVerb() Verb

func (*StartOperationParams) Log 

func (p *StartOperationParams) Log() []log.Field

func (*StartOperationParams) MarshalHTTP 

func (p *StartOperationParams) MarshalHTTP(w *yson.Writer)

func (*StartOperationParams) MutatingOptions 

func (p *StartOperationParams) MutatingOptions() **yt.MutatingOptions

func (*StartOperationParams) TransactionOptions 

func (p *StartOperationParams) TransactionOptions() **yt.TransactionOptions

func (*StartOperationParams) YPath 

func (p *StartOperationParams) YPath() (ypath.YPath, bool)

type StartQueryParams added in v0.0.10 

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

func NewStartQueryParams added in v0.0.10 

func NewStartQueryParams(
	engine yt.QueryEngine,
	query string,
	options *yt.StartQueryOptions,
) *StartQueryParams

func (*StartQueryParams) HTTPVerb added in v0.0.10 

func (p *StartQueryParams) HTTPVerb() Verb

func (*StartQueryParams) Log added in v0.0.10 

func (p *StartQueryParams) Log() []log.Field

func (*StartQueryParams) MarshalHTTP added in v0.0.10 

func (p *StartQueryParams) MarshalHTTP(w *yson.Writer)

func (*StartQueryParams) QueryTrackerOptions added in v0.0.10 

func (p *StartQueryParams) QueryTrackerOptions() **yt.QueryTrackerOptions

func (*StartQueryParams) YPath added in v0.0.10 

func (p *StartQueryParams) YPath() (ypath.YPath, bool)

type StartTabletTxParams 

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

func NewStartTabletTxParams 

func NewStartTabletTxParams(
	options *yt.StartTabletTxOptions,
) *StartTabletTxParams

func (*StartTabletTxParams) HTTPVerb 

func (p *StartTabletTxParams) HTTPVerb() Verb

func (*StartTabletTxParams) Log 

func (p *StartTabletTxParams) Log() []log.Field

func (*StartTabletTxParams) MarshalHTTP 

func (p *StartTabletTxParams) MarshalHTTP(w *yson.Writer)

func (*StartTabletTxParams) YPath 

func (p *StartTabletTxParams) YPath() (ypath.YPath, bool)

type StartTxParams 

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

func NewStartTxParams 

func NewStartTxParams(
	options *yt.StartTxOptions,
) *StartTxParams

func (*StartTxParams) HTTPVerb 

func (p *StartTxParams) HTTPVerb() Verb

func (*StartTxParams) Log 

func (p *StartTxParams) Log() []log.Field

func (*StartTxParams) MarshalHTTP 

func (p *StartTxParams) MarshalHTTP(w *yson.Writer)

func (*StartTxParams) ReadRetryOptions 

func (p *StartTxParams) ReadRetryOptions() **yt.ReadRetryOptions

func (*StartTxParams) TransactionOptions 

func (p *StartTxParams) TransactionOptions() **yt.TransactionOptions

func (*StartTxParams) YPath 

func (p *StartTxParams) YPath() (ypath.YPath, bool)

type StopGroup 

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

func NewStopGroup 

func NewStopGroup() *StopGroup

func (*StopGroup) C 

func (l *StopGroup) C() <-chan struct{}

func (*StopGroup) Context 

func (l *StopGroup) Context() context.Context

func (*StopGroup) Done 

func (l *StopGroup) Done()

func (*StopGroup) Stop 

func (l *StopGroup) Stop()

func (*StopGroup) TryAdd 

func (l *StopGroup) TryAdd() bool

type SuspendOperationParams 

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

func NewSuspendOperationParams 

func NewSuspendOperationParams(
	opID yt.OperationID,
	options *yt.SuspendOperationOptions,
) *SuspendOperationParams

func (*SuspendOperationParams) HTTPVerb 

func (p *SuspendOperationParams) HTTPVerb() Verb

func (*SuspendOperationParams) Log 

func (p *SuspendOperationParams) Log() []log.Field

func (*SuspendOperationParams) MarshalHTTP 

func (p *SuspendOperationParams) MarshalHTTP(w *yson.Writer)

func (*SuspendOperationParams) YPath 

func (p *SuspendOperationParams) YPath() (ypath.YPath, bool)

type TracingInterceptor 

type TracingInterceptor struct {
	opentracing.Tracer
}

func (*TracingInterceptor) Intercept 

func (t *TracingInterceptor) Intercept(ctx context.Context, call *Call, invoke CallInvoker) (res *CallResult, err error)

func (*TracingInterceptor) Read 

func (t *TracingInterceptor) Read(ctx context.Context, call *Call, invoke ReadInvoker) (r io.ReadCloser, err error)

func (*TracingInterceptor) Write 

func (t *TracingInterceptor) Write(ctx context.Context, call *Call, invoke WriteInvoker) (w io.WriteCloser, err error)

type TransactionParams 

type TransactionParams interface {
	TransactionOptions() **yt.TransactionOptions
}

type TransferAccountResourcesParams 

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

func NewTransferAccountResourcesParams 

func NewTransferAccountResourcesParams(
	srcAccount string,
	dstAccount string,
	resourceDelta any,
	options *yt.TransferAccountResourcesOptions,
) *TransferAccountResourcesParams

func (*TransferAccountResourcesParams) HTTPVerb 

func (p *TransferAccountResourcesParams) HTTPVerb() Verb

func (*TransferAccountResourcesParams) Log 

func (p *TransferAccountResourcesParams) Log() []log.Field

func (*TransferAccountResourcesParams) MarshalHTTP 

func (p *TransferAccountResourcesParams) MarshalHTTP(w *yson.Writer)

func (*TransferAccountResourcesParams) MutatingOptions 

func (p *TransferAccountResourcesParams) MutatingOptions() **yt.MutatingOptions

func (*TransferAccountResourcesParams) YPath 

func (p *TransferAccountResourcesParams) YPath() (ypath.YPath, bool)

type TransferPoolResourcesParams 

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

func NewTransferPoolResourcesParams 

func NewTransferPoolResourcesParams(
	srcPool string,
	dstPool string,
	poolTree string,
	resourceDelta any,
	options *yt.TransferPoolResourcesOptions,
) *TransferPoolResourcesParams

func (*TransferPoolResourcesParams) HTTPVerb 

func (p *TransferPoolResourcesParams) HTTPVerb() Verb

func (*TransferPoolResourcesParams) Log 

func (p *TransferPoolResourcesParams) Log() []log.Field

func (*TransferPoolResourcesParams) MarshalHTTP 

func (p *TransferPoolResourcesParams) MarshalHTTP(w *yson.Writer)

func (*TransferPoolResourcesParams) MutatingOptions 

func (p *TransferPoolResourcesParams) MutatingOptions() **yt.MutatingOptions

func (*TransferPoolResourcesParams) YPath 

func (p *TransferPoolResourcesParams) YPath() (ypath.YPath, bool)

type TxInterceptor 

type TxInterceptor struct {
	Encoder
	Client Encoder
	// contains filtered or unexported fields
}

func (*TxInterceptor) Abort 

func (t *TxInterceptor) Abort() (err error)

func (*TxInterceptor) BeginTx 

func (t *TxInterceptor) BeginTx(ctx context.Context, options *yt.StartTxOptions) (tx yt.Tx, err error)

func (*TxInterceptor) Commit 

func (t *TxInterceptor) Commit() (err error)

func (*TxInterceptor) Finished 

func (t *TxInterceptor) Finished() <-chan struct{}

func (*TxInterceptor) ID 

func (t *TxInterceptor) ID() yt.TxID

func (*TxInterceptor) Intercept 

func (t *TxInterceptor) Intercept(ctx context.Context, call *Call, next CallInvoker) (res *CallResult, err error)

func (*TxInterceptor) Read 

func (t *TxInterceptor) Read(ctx context.Context, call *Call, next ReadInvoker) (r io.ReadCloser, err error)

func (*TxInterceptor) ReadRow 

func (t *TxInterceptor) ReadRow(ctx context.Context, call *Call, next ReadRowInvoker) (r yt.TableReader, err error)

func (*TxInterceptor) ReadTable 

func (t *TxInterceptor) ReadTable(
	ctx context.Context,
	path ypath.YPath,
	options *yt.ReadTableOptions,
) (r yt.TableReader, err error)

func (*TxInterceptor) Write 

func (t *TxInterceptor) Write(ctx context.Context, call *Call, next WriteInvoker) (w io.WriteCloser, err error)

func (*TxInterceptor) WriteRow 

func (t *TxInterceptor) WriteRow(ctx context.Context, call *Call, next WriteRowInvoker) (w yt.TableWriter, err error)

type UnfreezeTableParams 

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

func NewUnfreezeTableParams 

func NewUnfreezeTableParams(
	path ypath.Path,
	options *yt.UnfreezeTableOptions,
) *UnfreezeTableParams

func (*UnfreezeTableParams) HTTPVerb 

func (p *UnfreezeTableParams) HTTPVerb() Verb

func (*UnfreezeTableParams) Log 

func (p *UnfreezeTableParams) Log() []log.Field

func (*UnfreezeTableParams) MarshalHTTP 

func (p *UnfreezeTableParams) MarshalHTTP(w *yson.Writer)

func (*UnfreezeTableParams) MutatingOptions 

func (p *UnfreezeTableParams) MutatingOptions() **yt.MutatingOptions

func (*UnfreezeTableParams) TabletRangeOptions 

func (p *UnfreezeTableParams) TabletRangeOptions() **yt.TabletRangeOptions

func (*UnfreezeTableParams) YPath 

func (p *UnfreezeTableParams) YPath() (ypath.YPath, bool)

type UnlockNodeParams 

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

func NewUnlockNodeParams 

func NewUnlockNodeParams(
	path ypath.YPath,
	options *yt.UnlockNodeOptions,
) *UnlockNodeParams

func (*UnlockNodeParams) HTTPVerb 

func (p *UnlockNodeParams) HTTPVerb() Verb

func (*UnlockNodeParams) Log 

func (p *UnlockNodeParams) Log() []log.Field

func (*UnlockNodeParams) MarshalHTTP 

func (p *UnlockNodeParams) MarshalHTTP(w *yson.Writer)

func (*UnlockNodeParams) MutatingOptions 

func (p *UnlockNodeParams) MutatingOptions() **yt.MutatingOptions

func (*UnlockNodeParams) TransactionOptions 

func (p *UnlockNodeParams) TransactionOptions() **yt.TransactionOptions

func (*UnlockNodeParams) YPath 

func (p *UnlockNodeParams) YPath() (ypath.YPath, bool)

type UnmountTableParams 

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

func NewUnmountTableParams 

func NewUnmountTableParams(
	path ypath.Path,
	options *yt.UnmountTableOptions,
) *UnmountTableParams

func (*UnmountTableParams) HTTPVerb 

func (p *UnmountTableParams) HTTPVerb() Verb

func (*UnmountTableParams) Log 

func (p *UnmountTableParams) Log() []log.Field

func (*UnmountTableParams) MarshalHTTP 

func (p *UnmountTableParams) MarshalHTTP(w *yson.Writer)

func (*UnmountTableParams) MutatingOptions 

func (p *UnmountTableParams) MutatingOptions() **yt.MutatingOptions

func (*UnmountTableParams) TabletRangeOptions 

func (p *UnmountTableParams) TabletRangeOptions() **yt.TabletRangeOptions

func (*UnmountTableParams) YPath 

func (p *UnmountTableParams) YPath() (ypath.YPath, bool)

type UpdateOperationParametersParams 

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

func NewUpdateOperationParametersParams 

func NewUpdateOperationParametersParams(
	opID yt.OperationID,
	params any,
	options *yt.UpdateOperationParametersOptions,
) *UpdateOperationParametersParams

func (*UpdateOperationParametersParams) HTTPVerb 

func (p *UpdateOperationParametersParams) HTTPVerb() Verb

func (*UpdateOperationParametersParams) Log 

func (p *UpdateOperationParametersParams) Log() []log.Field

func (*UpdateOperationParametersParams) MarshalHTTP 

func (p *UpdateOperationParametersParams) MarshalHTTP(w *yson.Writer)

func (*UpdateOperationParametersParams) YPath 

func (p *UpdateOperationParametersParams) YPath() (ypath.YPath, bool)

type Verb 

type Verb string
const (
	VerbCreate             Verb = "create"
	VerbExists             Verb = "exists"
	VerbRemove             Verb = "remove"
	VerbGet                Verb = "get"
	VerbSet                Verb = "set"
	VerbMultisetAttributes Verb = "multiset_attributes"
	VerbList               Verb = "list"
	VerbCopy               Verb = "copy"
	VerbMove               Verb = "move"
	VerbLink               Verb = "link"

	VerbWriteFile        Verb = "write_file"
	VerbReadFile         Verb = "read_file"
	VerbPutFileToCache   Verb = "put_file_to_cache"
	VerbGetFileFromCache Verb = "get_file_from_cache"

	VerbWriteTable Verb = "write_table"
	VerbReadTable  Verb = "read_table"

	VerbListOperations Verb = "list_operations"
	VerbStartOperation Verb = "start_operation"
	VerbGetOperation   Verb = "get_operation"
	VerbListJobs       Verb = "list_jobs"
	VerbGetJobStderr   Verb = "get_job_stderr"

	VerbStartTransaction  Verb = "start_transaction"
	VerbPingTransaction   Verb = "ping_transaction"
	VerbAbortTransaction  Verb = "abort_transaction"
	VerbCommitTransaction Verb = "commit_transaction"

	VerbAddMember    Verb = "add_member"
	VerbRemoveMember Verb = "remove_member"

	VerbBuildMasterSnapshots Verb = "build_master_snapshots"
	VerbBuildSnapshot        Verb = "build_snapshot"

	VerbDisableChunkLocations   Verb = "disable_chunk_locations"
	VerbDestroyChunkLocations   Verb = "destroy_chunk_locations"
	VerbResurrectChunkLocations Verb = "resurrect_chunk_locations"

	VerbRequestRestart Verb = "request_restart"

	VerbTransferAccountResources Verb = "transfer_account_resources"
	VerbTransferPoolResources    Verb = "transfer_pool_resources"

	VerbLock   Verb = "lock"
	VerbUnlock Verb = "unlock"

	VerbInsertRows Verb = "insert_rows"
	VerbLookupRows Verb = "lookup_rows"
	VerbDeleteRows Verb = "delete_rows"
	VerbSelectRows Verb = "select_rows"
	VerbLockRows   Verb = "lock_rows"

	VerbMountTable   Verb = "mount_table"
	VerbUnmountTable Verb = "unmount_table"
	VerbRemountTable Verb = "remount_table"
	VerbReshardTable Verb = "reshard_table"

	VerbGenerateTimestamp Verb = "generate_timestamp"

	VerbLocateSkynetShare Verb = "locate_skynet_share"

	VerbGetInSyncReplicas Verb = "get_in_sync_replicas"

	VerbStartQuery      Verb = "start_query"
	VerbAbortQuery      Verb = "abort_query"
	VerbGetQuery        Verb = "get_query"
	VerbListQueries     Verb = "list_queries"
	VerbGetQueryResult  Verb = "get_query_result"
	VerbReadQueryResult Verb = "read_query_result"
	VerbAlterQuery      Verb = "alter_query"
)

func (Verb) HTTPMethod 

func (v Verb) HTTPMethod() string

func (Verb) IsHeavy 

func (v Verb) IsHeavy() bool

func (Verb) String 

func (v Verb) String() string

type WriteFileParams 

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

func NewWriteFileParams 

func NewWriteFileParams(
	path ypath.YPath,
	options *yt.WriteFileOptions,
) *WriteFileParams

func (*WriteFileParams) HTTPVerb 

func (p *WriteFileParams) HTTPVerb() Verb

func (*WriteFileParams) Log 

func (p *WriteFileParams) Log() []log.Field

func (*WriteFileParams) MarshalHTTP 

func (p *WriteFileParams) MarshalHTTP(w *yson.Writer)

func (*WriteFileParams) PrerequisiteOptions 

func (p *WriteFileParams) PrerequisiteOptions() **yt.PrerequisiteOptions

func (*WriteFileParams) TransactionOptions 

func (p *WriteFileParams) TransactionOptions() **yt.TransactionOptions

func (*WriteFileParams) YPath 

func (p *WriteFileParams) YPath() (ypath.YPath, bool)

type WriteInterceptor 

type WriteInterceptor func(ctx context.Context, call *Call, invoke WriteInvoker) (r io.WriteCloser, err error)

type WriteInvoker 

type WriteInvoker func(ctx context.Context, call *Call) (r io.WriteCloser, err error)

func (WriteInvoker) Wrap 

func (c WriteInvoker) Wrap(interceptor WriteInterceptor) WriteInvoker

type WriteRowInterceptor 

type WriteRowInterceptor func(ctx context.Context, call *Call, invoke WriteRowInvoker) (r yt.TableWriter, err error)

type WriteRowInvoker 

type WriteRowInvoker func(ctx context.Context, call *Call) (r yt.TableWriter, err error)

func (WriteRowInvoker) Wrap 

func (c WriteRowInvoker) Wrap(interceptor WriteRowInterceptor) WriteRowInvoker

type WriteTableParams 

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

func NewWriteTableParams 

func NewWriteTableParams(
	path ypath.YPath,
	options *yt.WriteTableOptions,
) *WriteTableParams

func (*WriteTableParams) AccessTrackingOptions 

func (p *WriteTableParams) AccessTrackingOptions() **yt.AccessTrackingOptions

func (*WriteTableParams) HTTPVerb 

func (p *WriteTableParams) HTTPVerb() Verb

func (*WriteTableParams) Log 

func (p *WriteTableParams) Log() []log.Field

func (*WriteTableParams) MarshalHTTP 

func (p *WriteTableParams) MarshalHTTP(w *yson.Writer)

func (*WriteTableParams) TransactionOptions 

func (p *WriteTableParams) TransactionOptions() **yt.TransactionOptions

func (*WriteTableParams) YPath 

func (p *WriteTableParams) YPath() (ypath.YPath, bool)

Source Files

View all Source files

Directories

Path Synopsis

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.