Documentation ¶
Index ¶
- Constants
- func NewCertPool() (*x509.CertPool, error)
- func NewTx(ctx context.Context, e Encoder, log log.Structured, stop *StopGroup, ...) (yt.Tx, error)
- type AbortOperationParams
- type AbortTxParams
- func (p *AbortTxParams) HTTPVerb() Verb
- func (p *AbortTxParams) Log() []log.Field
- func (p *AbortTxParams) MarshalHTTP(w *yson.Writer)
- func (p *AbortTxParams) MutatingOptions() **yt.MutatingOptions
- func (p *AbortTxParams) PrerequisiteOptions() **yt.PrerequisiteOptions
- func (p *AbortTxParams) TransactionOptions() **yt.TransactionOptions
- func (p *AbortTxParams) YPath() (ypath.YPath, bool)
- type AddMemberParams
- func (p *AddMemberParams) HTTPVerb() Verb
- func (p *AddMemberParams) Log() []log.Field
- func (p *AddMemberParams) MarshalHTTP(w *yson.Writer)
- func (p *AddMemberParams) MutatingOptions() **yt.MutatingOptions
- func (p *AddMemberParams) PrerequisiteOptions() **yt.PrerequisiteOptions
- func (p *AddMemberParams) YPath() (ypath.YPath, bool)
- type AlterTableParams
- type AlterTableReplicaParams
- type BuildMasterSnapshotsParams
- type Call
- type CallInterceptor
- type CallInvoker
- type CallResult
- type CheckPermissionParams
- func (p *CheckPermissionParams) HTTPVerb() Verb
- func (p *CheckPermissionParams) Log() []log.Field
- func (p *CheckPermissionParams) MarshalHTTP(w *yson.Writer)
- func (p *CheckPermissionParams) MasterReadOptions() **yt.MasterReadOptions
- func (p *CheckPermissionParams) PrerequisiteOptions() **yt.PrerequisiteOptions
- func (p *CheckPermissionParams) TransactionOptions() **yt.TransactionOptions
- func (p *CheckPermissionParams) YPath() (ypath.YPath, bool)
- type CommitTxParams
- func (p *CommitTxParams) HTTPVerb() Verb
- func (p *CommitTxParams) Log() []log.Field
- func (p *CommitTxParams) MarshalHTTP(w *yson.Writer)
- func (p *CommitTxParams) MutatingOptions() **yt.MutatingOptions
- func (p *CommitTxParams) PrerequisiteOptions() **yt.PrerequisiteOptions
- func (p *CommitTxParams) TransactionOptions() **yt.TransactionOptions
- func (p *CommitTxParams) YPath() (ypath.YPath, bool)
- type CompleteOperationParams
- type CopyNodeParams
- func (p *CopyNodeParams) HTTPVerb() Verb
- func (p *CopyNodeParams) Log() []log.Field
- func (p *CopyNodeParams) MarshalHTTP(w *yson.Writer)
- func (p *CopyNodeParams) MutatingOptions() **yt.MutatingOptions
- func (p *CopyNodeParams) PrerequisiteOptions() **yt.PrerequisiteOptions
- func (p *CopyNodeParams) TransactionOptions() **yt.TransactionOptions
- func (p *CopyNodeParams) YPath() (ypath.YPath, bool)
- type CreateNodeParams
- func (p *CreateNodeParams) AccessTrackingOptions() **yt.AccessTrackingOptions
- func (p *CreateNodeParams) HTTPVerb() Verb
- func (p *CreateNodeParams) Log() []log.Field
- func (p *CreateNodeParams) MarshalHTTP(w *yson.Writer)
- func (p *CreateNodeParams) MutatingOptions() **yt.MutatingOptions
- func (p *CreateNodeParams) PrerequisiteOptions() **yt.PrerequisiteOptions
- func (p *CreateNodeParams) TransactionOptions() **yt.TransactionOptions
- func (p *CreateNodeParams) YPath() (ypath.YPath, bool)
- type CreateObjectParams
- func (p *CreateObjectParams) AccessTrackingOptions() **yt.AccessTrackingOptions
- func (p *CreateObjectParams) HTTPVerb() Verb
- func (p *CreateObjectParams) Log() []log.Field
- func (p *CreateObjectParams) MarshalHTTP(w *yson.Writer)
- func (p *CreateObjectParams) MutatingOptions() **yt.MutatingOptions
- func (p *CreateObjectParams) PrerequisiteOptions() **yt.PrerequisiteOptions
- func (p *CreateObjectParams) YPath() (ypath.YPath, bool)
- type DeleteRowsParams
- type DestroyChunkLocationsParams
- type DisableChunkLocationsParams
- type Encoder
- func (e *Encoder) AbortOperation(ctx context.Context, opID yt.OperationID, options *yt.AbortOperationOptions) (err error)
- func (e *Encoder) AbortTx(ctx context.Context, id yt.TxID, options *yt.AbortTxOptions) (err error)
- func (e *Encoder) AddMember(ctx context.Context, group string, member string, options *yt.AddMemberOptions) (err error)
- func (e *Encoder) AlterTable(ctx context.Context, path ypath.Path, options *yt.AlterTableOptions) (err error)
- func (e *Encoder) AlterTableReplica(ctx context.Context, id yt.NodeID, options *yt.AlterTableReplicaOptions) (err error)
- func (e *Encoder) BuildMasterSnapshots(ctx context.Context, options *yt.BuildMasterSnapshotsOptions) (response *yt.BuildMasterSnapshotsResponse, err error)
- func (e *Encoder) CheckPermission(ctx context.Context, user string, permission yt.Permission, path ypath.YPath, ...) (response *yt.CheckPermissionResponse, err error)
- func (e *Encoder) CommitTx(ctx context.Context, id yt.TxID, options *yt.CommitTxOptions) (err error)
- func (e *Encoder) CompleteOperation(ctx context.Context, opID yt.OperationID, options *yt.CompleteOperationOptions) (err error)
- func (e *Encoder) CopyNode(ctx context.Context, src ypath.YPath, dst ypath.YPath, ...) (id yt.NodeID, err error)
- func (e *Encoder) CreateNode(ctx context.Context, path ypath.YPath, typ yt.NodeType, ...) (id yt.NodeID, err error)
- func (e *Encoder) CreateObject(ctx context.Context, typ yt.NodeType, options *yt.CreateObjectOptions) (id yt.NodeID, err error)
- func (e *Encoder) DeleteRows(ctx context.Context, path ypath.Path, keys []interface{}, ...) (err error)
- func (e *Encoder) DestroyChunkLocations(ctx context.Context, nodeAddress string, locationUuids []guid.GUID) (response *yt.DestroyChunkLocationsResponse, err error)
- func (e *Encoder) DisableChunkLocations(ctx context.Context, nodeAddress string, locationUuids []guid.GUID) (response *yt.DisableChunkLocationsResponse, err error)
- func (e *Encoder) FreezeTable(ctx context.Context, path ypath.Path, options *yt.FreezeTableOptions) (err error)
- func (e *Encoder) GenerateTimestamp(ctx context.Context, options *yt.GenerateTimestampOptions) (ts yt.Timestamp, err error)
- func (e *Encoder) GetFileFromCache(ctx context.Context, md5 string, options *yt.GetFileFromCacheOptions) (path ypath.YPath, err error)
- func (e *Encoder) GetInSyncReplicas(ctx context.Context, path ypath.Path, ts yt.Timestamp, keys []interface{}, ...) (ids []yt.NodeID, err error)
- func (e *Encoder) GetJobStderr(ctx context.Context, opID yt.OperationID, jobID yt.JobID, ...) (r []byte, err error)
- func (e *Encoder) GetNode(ctx context.Context, path ypath.YPath, result interface{}, ...) (err error)
- func (e *Encoder) GetOperation(ctx context.Context, opID yt.OperationID, options *yt.GetOperationOptions) (status *yt.OperationStatus, err error)
- func (e *Encoder) InsertRowBatch(ctx context.Context, path ypath.Path, batch yt.RowBatch, ...) (err error)
- func (e *Encoder) InsertRows(ctx context.Context, path ypath.Path, rows []interface{}, ...) (err error)
- func (e *Encoder) LinkNode(ctx context.Context, target ypath.YPath, link ypath.YPath, ...) (id yt.NodeID, err error)
- func (e *Encoder) ListJobs(ctx context.Context, opID yt.OperationID, options *yt.ListJobsOptions) (r *yt.ListJobsResult, err error)
- func (e *Encoder) ListNode(ctx context.Context, path ypath.YPath, result interface{}, ...) (err error)
- func (e *Encoder) ListOperations(ctx context.Context, options *yt.ListOperationsOptions) (operations *yt.ListOperationsResult, err error)
- func (e *Encoder) LocateSkynetShare(ctx context.Context, path ypath.YPath, options *yt.LocateSkynetShareOptions) (l yt.ShareLocation, err error)
- func (e *Encoder) LockNode(ctx context.Context, path ypath.YPath, mode yt.LockMode, ...) (lr yt.LockResult, err error)
- func (e *Encoder) LockRows(ctx context.Context, path ypath.Path, locks []string, lockType yt.LockType, ...) (err error)
- func (e *Encoder) LookupRows(ctx context.Context, path ypath.Path, keys []interface{}, ...) (r yt.TableReader, err error)
- func (e *Encoder) MountTable(ctx context.Context, path ypath.Path, options *yt.MountTableOptions) (err error)
- func (e *Encoder) MoveNode(ctx context.Context, src ypath.YPath, dst ypath.YPath, ...) (id yt.NodeID, err error)
- func (e *Encoder) MultisetAttributes(ctx context.Context, path ypath.YPath, attributes map[string]interface{}, ...) (err error)
- func (e *Encoder) NodeExists(ctx context.Context, path ypath.YPath, options *yt.NodeExistsOptions) (ok bool, err error)
- func (e *Encoder) PingTx(ctx context.Context, id yt.TxID, options *yt.PingTxOptions) (err error)
- func (e *Encoder) PutFileToCache(ctx context.Context, path ypath.YPath, md5 string, ...) (cachedPath ypath.YPath, err error)
- func (e *Encoder) ReadFile(ctx context.Context, path ypath.YPath, options *yt.ReadFileOptions) (r io.ReadCloser, err error)
- func (e *Encoder) ReadTable(ctx context.Context, path ypath.YPath, options *yt.ReadTableOptions) (r yt.TableReader, err error)
- func (e *Encoder) RemountTable(ctx context.Context, path ypath.Path, options *yt.RemountTableOptions) (err error)
- func (e *Encoder) RemoveMember(ctx context.Context, group string, member string, ...) (err error)
- func (e *Encoder) RemoveNode(ctx context.Context, path ypath.YPath, options *yt.RemoveNodeOptions) (err error)
- func (e *Encoder) ReshardTable(ctx context.Context, path ypath.Path, options *yt.ReshardTableOptions) (err error)
- func (e *Encoder) ResumeOperation(ctx context.Context, opID yt.OperationID, options *yt.ResumeOperationOptions) (err error)
- func (e *Encoder) ResurrectChunkLocations(ctx context.Context, nodeAddress string, locationUuids []guid.GUID) (response *yt.ResurrectChunkLocationsResponse, err error)
- func (e *Encoder) SelectRows(ctx context.Context, query string, options *yt.SelectRowsOptions) (r yt.TableReader, err error)
- func (e *Encoder) SetNode(ctx context.Context, path ypath.YPath, value interface{}, ...) (err error)
- func (e *Encoder) StartOperation(ctx context.Context, opType yt.OperationType, spec interface{}, ...) (opID yt.OperationID, err error)
- func (e *Encoder) StartTabletTx(ctx context.Context, options *yt.StartTabletTxOptions) (id yt.TxID, err error)
- func (e *Encoder) StartTx(ctx context.Context, options *yt.StartTxOptions) (id yt.TxID, err error)
- func (e *Encoder) SuspendOperation(ctx context.Context, opID yt.OperationID, options *yt.SuspendOperationOptions) (err error)
- func (e *Encoder) TransferAccountResources(ctx context.Context, srcAccount string, dstAccount string, ...) (err error)
- func (e *Encoder) TransferPoolResources(ctx context.Context, srcPool string, dstPool string, poolTree string, ...) (err error)
- func (e *Encoder) UnfreezeTable(ctx context.Context, path ypath.Path, options *yt.UnfreezeTableOptions) (err error)
- func (e *Encoder) UnlockNode(ctx context.Context, path ypath.YPath, options *yt.UnlockNodeOptions) (err error)
- func (e *Encoder) UnmountTable(ctx context.Context, path ypath.Path, options *yt.UnmountTableOptions) (err error)
- func (e *Encoder) UpdateOperationParameters(ctx context.Context, opID yt.OperationID, params interface{}, ...) (err error)
- func (e *Encoder) WriteFile(ctx context.Context, path ypath.YPath, options *yt.WriteFileOptions) (w io.WriteCloser, err error)
- func (e *Encoder) WriteTable(ctx context.Context, path ypath.YPath, options *yt.WriteTableOptions) (w yt.TableWriter, err error)
- func (e *Encoder) WriteTableRaw(ctx context.Context, path ypath.YPath, options *yt.WriteTableOptions, ...) (err error)
- type ErrorWrapper
- func (e *ErrorWrapper) Intercept(ctx context.Context, call *Call, next CallInvoker) (res *CallResult, err error)
- func (e *ErrorWrapper) Read(ctx context.Context, call *Call, next ReadInvoker) (r io.ReadCloser, err error)
- func (e *ErrorWrapper) Write(ctx context.Context, call *Call, next WriteInvoker) (w io.WriteCloser, err error)
- type FreezeTableParams
- func (p *FreezeTableParams) HTTPVerb() Verb
- func (p *FreezeTableParams) Log() []log.Field
- func (p *FreezeTableParams) MarshalHTTP(w *yson.Writer)
- func (p *FreezeTableParams) MutatingOptions() **yt.MutatingOptions
- func (p *FreezeTableParams) TabletRangeOptions() **yt.TabletRangeOptions
- func (p *FreezeTableParams) YPath() (ypath.YPath, bool)
- type GenerateTimestampParams
- type GetFileFromCacheParams
- func (p *GetFileFromCacheParams) HTTPVerb() Verb
- func (p *GetFileFromCacheParams) Log() []log.Field
- func (p *GetFileFromCacheParams) MarshalHTTP(w *yson.Writer)
- func (p *GetFileFromCacheParams) MasterReadOptions() **yt.MasterReadOptions
- func (p *GetFileFromCacheParams) ReadRetryOptions() **yt.ReadRetryOptions
- func (p *GetFileFromCacheParams) YPath() (ypath.YPath, bool)
- type GetInSyncReplicasParams
- type GetJobStderrParams
- type GetNodeParams
- func (p *GetNodeParams) AccessTrackingOptions() **yt.AccessTrackingOptions
- func (p *GetNodeParams) HTTPVerb() Verb
- func (p *GetNodeParams) Log() []log.Field
- func (p *GetNodeParams) MarshalHTTP(w *yson.Writer)
- func (p *GetNodeParams) MasterReadOptions() **yt.MasterReadOptions
- func (p *GetNodeParams) PrerequisiteOptions() **yt.PrerequisiteOptions
- func (p *GetNodeParams) ReadRetryOptions() **yt.ReadRetryOptions
- func (p *GetNodeParams) TransactionOptions() **yt.TransactionOptions
- func (p *GetNodeParams) YPath() (ypath.YPath, bool)
- type GetOperationParams
- func (p *GetOperationParams) HTTPVerb() Verb
- func (p *GetOperationParams) Log() []log.Field
- func (p *GetOperationParams) MarshalHTTP(w *yson.Writer)
- func (p *GetOperationParams) MasterReadOptions() **yt.MasterReadOptions
- func (p *GetOperationParams) ReadRetryOptions() **yt.ReadRetryOptions
- func (p *GetOperationParams) YPath() (ypath.YPath, bool)
- type InsertRowsParams
- type LinkNodeParams
- func (p *LinkNodeParams) HTTPVerb() Verb
- func (p *LinkNodeParams) Log() []log.Field
- func (p *LinkNodeParams) MarshalHTTP(w *yson.Writer)
- func (p *LinkNodeParams) MutatingOptions() **yt.MutatingOptions
- func (p *LinkNodeParams) PrerequisiteOptions() **yt.PrerequisiteOptions
- func (p *LinkNodeParams) TransactionOptions() **yt.TransactionOptions
- func (p *LinkNodeParams) YPath() (ypath.YPath, bool)
- type ListJobsParams
- type ListNodeParams
- func (p *ListNodeParams) AccessTrackingOptions() **yt.AccessTrackingOptions
- func (p *ListNodeParams) HTTPVerb() Verb
- func (p *ListNodeParams) Log() []log.Field
- func (p *ListNodeParams) MarshalHTTP(w *yson.Writer)
- func (p *ListNodeParams) MasterReadOptions() **yt.MasterReadOptions
- func (p *ListNodeParams) PrerequisiteOptions() **yt.PrerequisiteOptions
- func (p *ListNodeParams) ReadRetryOptions() **yt.ReadRetryOptions
- func (p *ListNodeParams) TransactionOptions() **yt.TransactionOptions
- func (p *ListNodeParams) YPath() (ypath.YPath, bool)
- type ListOperationsParams
- func (p *ListOperationsParams) HTTPVerb() Verb
- func (p *ListOperationsParams) Log() []log.Field
- func (p *ListOperationsParams) MarshalHTTP(w *yson.Writer)
- func (p *ListOperationsParams) MasterReadOptions() **yt.MasterReadOptions
- func (p *ListOperationsParams) ReadRetryOptions() **yt.ReadRetryOptions
- func (p *ListOperationsParams) YPath() (ypath.YPath, bool)
- type LocateSkynetShareParams
- type LockNodeParams
- func (p *LockNodeParams) HTTPVerb() Verb
- func (p *LockNodeParams) Log() []log.Field
- func (p *LockNodeParams) MarshalHTTP(w *yson.Writer)
- func (p *LockNodeParams) MutatingOptions() **yt.MutatingOptions
- func (p *LockNodeParams) TransactionOptions() **yt.TransactionOptions
- func (p *LockNodeParams) YPath() (ypath.YPath, bool)
- type LockRowsParams
- type LoggingInterceptor
- func (l *LoggingInterceptor) Intercept(ctx context.Context, call *Call, invoke CallInvoker) (res *CallResult, err error)
- func (l *LoggingInterceptor) Read(ctx context.Context, call *Call, invoke ReadInvoker) (r io.ReadCloser, err error)
- func (l *LoggingInterceptor) Write(ctx context.Context, call *Call, invoke WriteInvoker) (w io.WriteCloser, err error)
- type LookupRowsParams
- type MountTableParams
- func (p *MountTableParams) HTTPVerb() Verb
- func (p *MountTableParams) Log() []log.Field
- func (p *MountTableParams) MarshalHTTP(w *yson.Writer)
- func (p *MountTableParams) MutatingOptions() **yt.MutatingOptions
- func (p *MountTableParams) TabletRangeOptions() **yt.TabletRangeOptions
- func (p *MountTableParams) YPath() (ypath.YPath, bool)
- type MoveNodeParams
- func (p *MoveNodeParams) HTTPVerb() Verb
- func (p *MoveNodeParams) Log() []log.Field
- func (p *MoveNodeParams) MarshalHTTP(w *yson.Writer)
- func (p *MoveNodeParams) MutatingOptions() **yt.MutatingOptions
- func (p *MoveNodeParams) PrerequisiteOptions() **yt.PrerequisiteOptions
- func (p *MoveNodeParams) TransactionOptions() **yt.TransactionOptions
- func (p *MoveNodeParams) YPath() (ypath.YPath, bool)
- type MultisetAttributesParams
- func (p *MultisetAttributesParams) AccessTrackingOptions() **yt.AccessTrackingOptions
- func (p *MultisetAttributesParams) HTTPVerb() Verb
- func (p *MultisetAttributesParams) Log() []log.Field
- func (p *MultisetAttributesParams) MarshalHTTP(w *yson.Writer)
- func (p *MultisetAttributesParams) MutatingOptions() **yt.MutatingOptions
- func (p *MultisetAttributesParams) PrerequisiteOptions() **yt.PrerequisiteOptions
- func (p *MultisetAttributesParams) TransactionOptions() **yt.TransactionOptions
- func (p *MultisetAttributesParams) YPath() (ypath.YPath, bool)
- type MutatingParams
- type MutationRetrier
- type NodeExistsParams
- func (p *NodeExistsParams) AccessTrackingOptions() **yt.AccessTrackingOptions
- func (p *NodeExistsParams) HTTPVerb() Verb
- func (p *NodeExistsParams) Log() []log.Field
- func (p *NodeExistsParams) MarshalHTTP(w *yson.Writer)
- func (p *NodeExistsParams) MasterReadOptions() **yt.MasterReadOptions
- func (p *NodeExistsParams) ReadRetryOptions() **yt.ReadRetryOptions
- func (p *NodeExistsParams) TransactionOptions() **yt.TransactionOptions
- func (p *NodeExistsParams) YPath() (ypath.YPath, bool)
- type Params
- type PingTxParams
- type Pinger
- func (p *Pinger) CheckAlive() error
- func (p *Pinger) Config() *yt.Config
- func (p *Pinger) Ctx() context.Context
- func (p *Pinger) Finished() <-chan struct{}
- func (p *Pinger) ID() yt.TxID
- func (p *Pinger) OnTxError(err error)
- func (p *Pinger) Run()
- func (p *Pinger) Stop() *StopGroup
- func (p *Pinger) TryAbort(aborter func() error) error
- func (p *Pinger) TryCommit(committer func() error) error
- type ProxyBouncer
- func (b *ProxyBouncer) Intercept(ctx context.Context, call *Call, next CallInvoker) (res *CallResult, err error)
- func (b *ProxyBouncer) Read(ctx context.Context, call *Call, next ReadInvoker) (r io.ReadCloser, err error)
- func (b *ProxyBouncer) Write(ctx context.Context, call *Call, next WriteInvoker) (w io.WriteCloser, err error)
- type ProxySet
- type PutFileToCacheParams
- func (p *PutFileToCacheParams) HTTPVerb() Verb
- func (p *PutFileToCacheParams) Log() []log.Field
- func (p *PutFileToCacheParams) MarshalHTTP(w *yson.Writer)
- func (p *PutFileToCacheParams) MasterReadOptions() **yt.MasterReadOptions
- func (p *PutFileToCacheParams) MutatingOptions() **yt.MutatingOptions
- func (p *PutFileToCacheParams) PrerequisiteOptions() **yt.PrerequisiteOptions
- func (p *PutFileToCacheParams) YPath() (ypath.YPath, bool)
- type ReadFileParams
- func (p *ReadFileParams) AccessTrackingOptions() **yt.AccessTrackingOptions
- func (p *ReadFileParams) HTTPVerb() Verb
- func (p *ReadFileParams) Log() []log.Field
- func (p *ReadFileParams) MarshalHTTP(w *yson.Writer)
- func (p *ReadFileParams) TransactionOptions() **yt.TransactionOptions
- func (p *ReadFileParams) YPath() (ypath.YPath, bool)
- type ReadInterceptor
- type ReadInvoker
- type ReadRetryParams
- type ReadRowInterceptor
- type ReadRowInvoker
- type ReadTableParams
- func (p *ReadTableParams) AccessTrackingOptions() **yt.AccessTrackingOptions
- func (p *ReadTableParams) HTTPVerb() Verb
- func (p *ReadTableParams) Log() []log.Field
- func (p *ReadTableParams) MarshalHTTP(w *yson.Writer)
- func (p *ReadTableParams) TransactionOptions() **yt.TransactionOptions
- func (p *ReadTableParams) YPath() (ypath.YPath, bool)
- type RemountTableParams
- func (p *RemountTableParams) HTTPVerb() Verb
- func (p *RemountTableParams) Log() []log.Field
- func (p *RemountTableParams) MarshalHTTP(w *yson.Writer)
- func (p *RemountTableParams) MutatingOptions() **yt.MutatingOptions
- func (p *RemountTableParams) TabletRangeOptions() **yt.TabletRangeOptions
- func (p *RemountTableParams) YPath() (ypath.YPath, bool)
- type RemoveMemberParams
- func (p *RemoveMemberParams) HTTPVerb() Verb
- func (p *RemoveMemberParams) Log() []log.Field
- func (p *RemoveMemberParams) MarshalHTTP(w *yson.Writer)
- func (p *RemoveMemberParams) MutatingOptions() **yt.MutatingOptions
- func (p *RemoveMemberParams) PrerequisiteOptions() **yt.PrerequisiteOptions
- func (p *RemoveMemberParams) YPath() (ypath.YPath, bool)
- type RemoveNodeParams
- func (p *RemoveNodeParams) AccessTrackingOptions() **yt.AccessTrackingOptions
- func (p *RemoveNodeParams) HTTPVerb() Verb
- func (p *RemoveNodeParams) Log() []log.Field
- func (p *RemoveNodeParams) MarshalHTTP(w *yson.Writer)
- func (p *RemoveNodeParams) MutatingOptions() **yt.MutatingOptions
- func (p *RemoveNodeParams) PrerequisiteOptions() **yt.PrerequisiteOptions
- func (p *RemoveNodeParams) TransactionOptions() **yt.TransactionOptions
- func (p *RemoveNodeParams) YPath() (ypath.YPath, bool)
- type ReshardTableParams
- func (p *ReshardTableParams) HTTPVerb() Verb
- func (p *ReshardTableParams) Log() []log.Field
- func (p *ReshardTableParams) MarshalHTTP(w *yson.Writer)
- func (p *ReshardTableParams) MutatingOptions() **yt.MutatingOptions
- func (p *ReshardTableParams) TabletRangeOptions() **yt.TabletRangeOptions
- func (p *ReshardTableParams) YPath() (ypath.YPath, bool)
- type ResumeOperationParams
- type ResurrectChunkLocationsParams
- type Retrier
- func (r *Retrier) Intercept(ctx context.Context, call *Call, invoke CallInvoker) (res *CallResult, err error)
- func (r *Retrier) Read(ctx context.Context, call *Call, invoke ReadInvoker) (rc io.ReadCloser, err error)
- func (r *Retrier) Write(ctx context.Context, call *Call, invoke WriteInvoker) (w io.WriteCloser, err error)
- type SelectRowsParams
- func (p *SelectRowsParams) HTTPVerb() Verb
- func (p *SelectRowsParams) Log() []log.Field
- func (p *SelectRowsParams) MarshalHTTP(w *yson.Writer)
- func (p *SelectRowsParams) TimeoutOptions() **yt.TimeoutOptions
- func (p *SelectRowsParams) TransactionOptions() **yt.TransactionOptions
- func (p *SelectRowsParams) YPath() (ypath.YPath, bool)
- type SetNodeParams
- func (p *SetNodeParams) AccessTrackingOptions() **yt.AccessTrackingOptions
- func (p *SetNodeParams) HTTPVerb() Verb
- func (p *SetNodeParams) Log() []log.Field
- func (p *SetNodeParams) MarshalHTTP(w *yson.Writer)
- func (p *SetNodeParams) MutatingOptions() **yt.MutatingOptions
- func (p *SetNodeParams) PrerequisiteOptions() **yt.PrerequisiteOptions
- func (p *SetNodeParams) TransactionOptions() **yt.TransactionOptions
- func (p *SetNodeParams) YPath() (ypath.YPath, bool)
- type StartOperationParams
- func (p *StartOperationParams) HTTPVerb() Verb
- func (p *StartOperationParams) Log() []log.Field
- func (p *StartOperationParams) MarshalHTTP(w *yson.Writer)
- func (p *StartOperationParams) MutatingOptions() **yt.MutatingOptions
- func (p *StartOperationParams) TransactionOptions() **yt.TransactionOptions
- func (p *StartOperationParams) YPath() (ypath.YPath, bool)
- type StartTabletTxParams
- type StartTxParams
- func (p *StartTxParams) HTTPVerb() Verb
- func (p *StartTxParams) Log() []log.Field
- func (p *StartTxParams) MarshalHTTP(w *yson.Writer)
- func (p *StartTxParams) ReadRetryOptions() **yt.ReadRetryOptions
- func (p *StartTxParams) TransactionOptions() **yt.TransactionOptions
- func (p *StartTxParams) YPath() (ypath.YPath, bool)
- type StopGroup
- type SuspendOperationParams
- type TracingInterceptor
- func (t *TracingInterceptor) Intercept(ctx context.Context, call *Call, invoke CallInvoker) (res *CallResult, err error)
- func (t *TracingInterceptor) Read(ctx context.Context, call *Call, invoke ReadInvoker) (r io.ReadCloser, err error)
- func (t *TracingInterceptor) Write(ctx context.Context, call *Call, invoke WriteInvoker) (w io.WriteCloser, err error)
- type TransactionParams
- type TransferAccountResourcesParams
- func (p *TransferAccountResourcesParams) HTTPVerb() Verb
- func (p *TransferAccountResourcesParams) Log() []log.Field
- func (p *TransferAccountResourcesParams) MarshalHTTP(w *yson.Writer)
- func (p *TransferAccountResourcesParams) MutatingOptions() **yt.MutatingOptions
- func (p *TransferAccountResourcesParams) YPath() (ypath.YPath, bool)
- type TransferPoolResourcesParams
- func (p *TransferPoolResourcesParams) HTTPVerb() Verb
- func (p *TransferPoolResourcesParams) Log() []log.Field
- func (p *TransferPoolResourcesParams) MarshalHTTP(w *yson.Writer)
- func (p *TransferPoolResourcesParams) MutatingOptions() **yt.MutatingOptions
- func (p *TransferPoolResourcesParams) YPath() (ypath.YPath, bool)
- type TxInterceptor
- func (t *TxInterceptor) Abort() (err error)
- func (t *TxInterceptor) BeginTx(ctx context.Context, options *yt.StartTxOptions) (tx yt.Tx, err error)
- func (t *TxInterceptor) Commit() (err error)
- func (t *TxInterceptor) Finished() <-chan struct{}
- func (t *TxInterceptor) ID() yt.TxID
- func (t *TxInterceptor) Intercept(ctx context.Context, call *Call, next CallInvoker) (res *CallResult, err error)
- func (t *TxInterceptor) Read(ctx context.Context, call *Call, next ReadInvoker) (r io.ReadCloser, err error)
- func (t *TxInterceptor) ReadRow(ctx context.Context, call *Call, next ReadRowInvoker) (r yt.TableReader, err error)
- func (t *TxInterceptor) ReadTable(ctx context.Context, path ypath.YPath, options *yt.ReadTableOptions) (r yt.TableReader, err error)
- func (t *TxInterceptor) Write(ctx context.Context, call *Call, next WriteInvoker) (w io.WriteCloser, err error)
- func (t *TxInterceptor) WriteRow(ctx context.Context, call *Call, next WriteRowInvoker) (w yt.TableWriter, err error)
- type UnfreezeTableParams
- func (p *UnfreezeTableParams) HTTPVerb() Verb
- func (p *UnfreezeTableParams) Log() []log.Field
- func (p *UnfreezeTableParams) MarshalHTTP(w *yson.Writer)
- func (p *UnfreezeTableParams) MutatingOptions() **yt.MutatingOptions
- func (p *UnfreezeTableParams) TabletRangeOptions() **yt.TabletRangeOptions
- func (p *UnfreezeTableParams) YPath() (ypath.YPath, bool)
- type UnlockNodeParams
- func (p *UnlockNodeParams) HTTPVerb() Verb
- func (p *UnlockNodeParams) Log() []log.Field
- func (p *UnlockNodeParams) MarshalHTTP(w *yson.Writer)
- func (p *UnlockNodeParams) MutatingOptions() **yt.MutatingOptions
- func (p *UnlockNodeParams) TransactionOptions() **yt.TransactionOptions
- func (p *UnlockNodeParams) YPath() (ypath.YPath, bool)
- type UnmountTableParams
- func (p *UnmountTableParams) HTTPVerb() Verb
- func (p *UnmountTableParams) Log() []log.Field
- func (p *UnmountTableParams) MarshalHTTP(w *yson.Writer)
- func (p *UnmountTableParams) MutatingOptions() **yt.MutatingOptions
- func (p *UnmountTableParams) TabletRangeOptions() **yt.TabletRangeOptions
- func (p *UnmountTableParams) YPath() (ypath.YPath, bool)
- type UpdateOperationParametersParams
- type Verb
- type WriteFileParams
- func (p *WriteFileParams) HTTPVerb() Verb
- func (p *WriteFileParams) Log() []log.Field
- func (p *WriteFileParams) MarshalHTTP(w *yson.Writer)
- func (p *WriteFileParams) PrerequisiteOptions() **yt.PrerequisiteOptions
- func (p *WriteFileParams) TransactionOptions() **yt.TransactionOptions
- func (p *WriteFileParams) YPath() (ypath.YPath, bool)
- type WriteInterceptor
- type WriteInvoker
- type WriteRowInterceptor
- type WriteRowInvoker
- type WriteTableParams
- func (p *WriteTableParams) AccessTrackingOptions() **yt.AccessTrackingOptions
- func (p *WriteTableParams) HTTPVerb() Verb
- func (p *WriteTableParams) Log() []log.Field
- func (p *WriteTableParams) MarshalHTTP(w *yson.Writer)
- func (p *WriteTableParams) TransactionOptions() **yt.TransactionOptions
- func (p *WriteTableParams) YPath() (ypath.YPath, bool)
Constants ¶
View Source
const (
)Variables ¶
This section is empty.
Functions ¶
func NewCertPool ¶
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)
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
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
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
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)
type BuildMasterSnapshotsParams ¶
type BuildMasterSnapshotsParams struct {
// contains filtered or unexported fields
}
func NewBuildMasterSnapshotsParams ¶
func NewBuildMasterSnapshotsParams( options *yt.BuildMasterSnapshotsOptions, ) *BuildMasterSnapshotsParams
func (*BuildMasterSnapshotsParams) HTTPVerb ¶
func (p *BuildMasterSnapshotsParams) HTTPVerb() Verb
func (*BuildMasterSnapshotsParams) Log ¶
func (p *BuildMasterSnapshotsParams) Log() []log.Field
func (*BuildMasterSnapshotsParams) MarshalHTTP ¶
func (p *BuildMasterSnapshotsParams) MarshalHTTP(w *yson.Writer)
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
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
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)
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
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
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
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
type DestroyChunkLocationsParams ¶
type DestroyChunkLocationsParams struct {
// contains filtered or unexported fields
}
func NewDestroyChunkLocationsParams ¶
func NewDestroyChunkLocationsParams( nodeAddress string, locationUuids []guid.GUID, ) *DestroyChunkLocationsParams
func (*DestroyChunkLocationsParams) HTTPVerb ¶
func (p *DestroyChunkLocationsParams) HTTPVerb() Verb
func (*DestroyChunkLocationsParams) Log ¶
func (p *DestroyChunkLocationsParams) Log() []log.Field
func (*DestroyChunkLocationsParams) MarshalHTTP ¶
func (p *DestroyChunkLocationsParams) MarshalHTTP(w *yson.Writer)
type DisableChunkLocationsParams ¶
type DisableChunkLocationsParams struct {
// contains filtered or unexported fields
}
func NewDisableChunkLocationsParams ¶
func NewDisableChunkLocationsParams( nodeAddress string, locationUuids []guid.GUID, ) *DisableChunkLocationsParams
func (*DisableChunkLocationsParams) HTTPVerb ¶
func (p *DisableChunkLocationsParams) HTTPVerb() Verb
func (*DisableChunkLocationsParams) Log ¶
func (p *DisableChunkLocationsParams) Log() []log.Field
func (*DisableChunkLocationsParams) MarshalHTTP ¶
func (p *DisableChunkLocationsParams) MarshalHTTP(w *yson.Writer)
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) AlterTable ¶
func (*Encoder) AlterTableReplica ¶
func (*Encoder) BuildMasterSnapshots ¶
func (e *Encoder) BuildMasterSnapshots( ctx context.Context, options *yt.BuildMasterSnapshotsOptions, ) (response *yt.BuildMasterSnapshotsResponse, 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) CompleteOperation ¶
func (e *Encoder) CompleteOperation( ctx context.Context, opID yt.OperationID, options *yt.CompleteOperationOptions, ) (err error)
func (*Encoder) CreateNode ¶
func (*Encoder) CreateObject ¶
func (*Encoder) DeleteRows ¶
func (*Encoder) DestroyChunkLocations ¶
func (*Encoder) DisableChunkLocations ¶
func (*Encoder) FreezeTable ¶
func (*Encoder) GenerateTimestamp ¶
func (*Encoder) GetFileFromCache ¶
func (*Encoder) GetInSyncReplicas ¶
func (*Encoder) GetJobStderr ¶
func (*Encoder) GetOperation ¶
func (e *Encoder) GetOperation( ctx context.Context, opID yt.OperationID, options *yt.GetOperationOptions, ) (status *yt.OperationStatus, err error)
func (*Encoder) InsertRowBatch ¶
func (*Encoder) InsertRows ¶
func (*Encoder) ListJobs ¶
func (e *Encoder) ListJobs( ctx context.Context, opID yt.OperationID, options *yt.ListJobsOptions, ) (r *yt.ListJobsResult, err error)
func (*Encoder) ListOperations ¶
func (e *Encoder) ListOperations( ctx context.Context, options *yt.ListOperationsOptions, ) (operations *yt.ListOperationsResult, 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) LookupRows ¶
func (e *Encoder) LookupRows( ctx context.Context, path ypath.Path, keys []interface{}, options *yt.LookupRowsOptions, ) (r yt.TableReader, err error)
func (*Encoder) MountTable ¶
func (*Encoder) MultisetAttributes ¶
func (*Encoder) NodeExists ¶
func (*Encoder) PutFileToCache ¶
func (*Encoder) ReadFile ¶
func (e *Encoder) ReadFile( ctx context.Context, path ypath.YPath, options *yt.ReadFileOptions, ) (r io.ReadCloser, 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 (*Encoder) RemoveMember ¶
func (*Encoder) RemoveNode ¶
func (*Encoder) ReshardTable ¶
func (*Encoder) ResumeOperation ¶
func (e *Encoder) ResumeOperation( ctx context.Context, opID yt.OperationID, options *yt.ResumeOperationOptions, ) (err error)
func (*Encoder) ResurrectChunkLocations ¶
func (*Encoder) SelectRows ¶
func (e *Encoder) SelectRows( ctx context.Context, query string, options *yt.SelectRowsOptions, ) (r yt.TableReader, err error)
func (*Encoder) StartOperation ¶
func (e *Encoder) StartOperation( ctx context.Context, opType yt.OperationType, spec interface{}, options *yt.StartOperationOptions, ) (opID yt.OperationID, err error)
func (*Encoder) StartTabletTx ¶
func (*Encoder) SuspendOperation ¶
func (e *Encoder) SuspendOperation( ctx context.Context, opID yt.OperationID, options *yt.SuspendOperationOptions, ) (err error)
func (*Encoder) TransferAccountResources ¶
func (*Encoder) TransferPoolResources ¶
func (*Encoder) UnfreezeTable ¶
func (*Encoder) UnlockNode ¶
func (*Encoder) UnmountTable ¶
func (*Encoder) UpdateOperationParameters ¶
func (e *Encoder) UpdateOperationParameters( ctx context.Context, opID yt.OperationID, params interface{}, 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)
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
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)
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
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)
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)
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
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
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
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
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)
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
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
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)
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
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
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
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
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
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
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
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
type Pinger ¶
type Pinger struct {
// contains filtered or unexported fields
}
Pinger tracks server transaction state and performs periodic pings.
func (*Pinger) CheckAlive ¶
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 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
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
type ReadInterceptor ¶
type ReadInterceptor func(ctx context.Context, call *Call, invoke ReadInvoker) (r io.ReadCloser, err error)
type ReadInvoker ¶
func (ReadInvoker) Wrap ¶
func (c ReadInvoker) Wrap(interceptor ReadInterceptor) ReadInvoker
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 ¶
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
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
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
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
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
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)
type ResurrectChunkLocationsParams ¶
type ResurrectChunkLocationsParams struct {
// contains filtered or unexported fields
}
func NewResurrectChunkLocationsParams ¶
func NewResurrectChunkLocationsParams( nodeAddress string, locationUuids []guid.GUID, ) *ResurrectChunkLocationsParams
func (*ResurrectChunkLocationsParams) HTTPVerb ¶
func (p *ResurrectChunkLocationsParams) HTTPVerb() Verb
func (*ResurrectChunkLocationsParams) Log ¶
func (p *ResurrectChunkLocationsParams) Log() []log.Field
func (*ResurrectChunkLocationsParams) MarshalHTTP ¶
func (p *ResurrectChunkLocationsParams) MarshalHTTP(w *yson.Writer)
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 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
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
type StartOperationParams ¶
type StartOperationParams struct {
// contains filtered or unexported fields
}
func NewStartOperationParams ¶
func NewStartOperationParams( opType yt.OperationType, spec interface{}, 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
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)
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
type StopGroup ¶
type StopGroup struct {
// contains filtered or unexported fields
}
func NewStopGroup ¶
func NewStopGroup() *StopGroup
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)
type TracingInterceptor ¶
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 interface{}, 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
type TransferPoolResourcesParams ¶
type TransferPoolResourcesParams struct {
// contains filtered or unexported fields
}
func NewTransferPoolResourcesParams ¶
func NewTransferPoolResourcesParams( srcPool string, dstPool string, poolTree string, resourceDelta interface{}, 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
type TxInterceptor ¶
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
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
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
type UpdateOperationParametersParams ¶
type UpdateOperationParametersParams struct {
// contains filtered or unexported fields
}
func NewUpdateOperationParametersParams ¶
func NewUpdateOperationParametersParams( opID yt.OperationID, params interface{}, 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)
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" VerbDisableChunkLocations Verb = "disable_chunk_locations" VerbDestroyChunkLocations Verb = "destroy_chunk_locations" VerbResurrectChunkLocations Verb = "resurrect_chunk_locations" 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" VerbGetInSyncReplicas Verb = "get_in_sync_replicas" )
func (Verb) HTTPMethod ¶
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
type WriteInterceptor ¶
type WriteInterceptor func(ctx context.Context, call *Call, invoke WriteInvoker) (r io.WriteCloser, err error)
type WriteInvoker ¶
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 ¶
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
Source Files ¶
Click to show internal directories.
Click to hide internal directories.