Documentation
¶
Overview ¶
Package mock_yt is a generated GoMock package.
Index ¶
- type MockClient
- func (m *MockClient) AbortOperation(ctx context.Context, opID yt.OperationID, options *yt.AbortOperationOptions) error
- func (m *MockClient) AbortQuery(ctx context.Context, id yt.QueryID, options *yt.AbortQueryOptions) error
- func (m *MockClient) AbortTx(ctx context.Context, id yt.TxID, options *yt.AbortTxOptions) error
- func (m *MockClient) AddMaintenance(ctx context.Context, component yt.MaintenanceComponent, address string, ...) (*yt.AddMaintenanceResponse, error)
- func (m *MockClient) AddMember(ctx context.Context, group, member string, options *yt.AddMemberOptions) error
- func (m *MockClient) AlterQuery(ctx context.Context, id yt.QueryID, options *yt.AlterQueryOptions) error
- func (m *MockClient) AlterTable(ctx context.Context, path ypath.Path, options *yt.AlterTableOptions) error
- func (m *MockClient) AlterTableReplica(ctx context.Context, id yt.NodeID, options *yt.AlterTableReplicaOptions) error
- func (m *MockClient) AttachTx(ctx context.Context, txID yt.TxID, options *yt.AttachTxOptions) (yt.Tx, error)
- func (m *MockClient) BeginTabletTx(ctx context.Context, options *yt.StartTabletTxOptions) (yt.TabletTx, error)
- func (m *MockClient) BeginTx(ctx context.Context, options *yt.StartTxOptions) (yt.Tx, error)
- func (m *MockClient) BuildMasterSnapshots(ctx context.Context, options *yt.BuildMasterSnapshotsOptions) (*[]yt.BuildMasterSnapshot, error)
- func (m *MockClient) BuildSnapshot(ctx context.Context, options *yt.BuildSnapshotOptions) (*yt.BuildSnapshotResponse, error)
- func (m *MockClient) CheckPermission(ctx context.Context, user, permission string, path ypath.YPath, ...) (*yt.CheckPermissionResponse, error)
- func (m *MockClient) CheckPermissionByACL(ctx context.Context, user, permission string, ACL []yt.ACE, ...) (*yt.CheckPermissionResponse, error)
- func (m *MockClient) CommitTx(ctx context.Context, id yt.TxID, options *yt.CommitTxOptions) error
- func (m *MockClient) CompleteOperation(ctx context.Context, opID yt.OperationID, options *yt.CompleteOperationOptions) error
- func (m *MockClient) CopyNode(ctx context.Context, src, dst ypath.YPath, options *yt.CopyNodeOptions) (yt.NodeID, error)
- func (m *MockClient) CreateNode(ctx context.Context, path ypath.YPath, typ yt.NodeType, ...) (yt.NodeID, error)
- func (m *MockClient) CreateObject(ctx context.Context, typ yt.NodeType, options *yt.CreateObjectOptions) (yt.NodeID, error)
- func (m *MockClient) CreateQueueProducerSession(ctx context.Context, producerPath, queuePath ypath.Path, sessionID string, ...) (*yt.CreateQueueProducerSessionResult, error)
- func (m *MockClient) CreateTableBackup(ctx context.Context, manifest yt.BackupManifest, ...) error
- func (m *MockClient) DeleteRows(ctx context.Context, path ypath.Path, keys []any, ...) error
- func (m *MockClient) DestroyChunkLocations(ctx context.Context, nodeAddress string, recoverUnlinkedDisks bool, ...) (*yt.DestroyChunkLocationsResponse, error)
- func (m *MockClient) DisableChunkLocations(ctx context.Context, nodeAddress string, locationUUIDs []guid.GUID, ...) (*yt.DisableChunkLocationsResponse, error)
- func (m *MockClient) EXPECT() *MockClientMockRecorder
- func (m *MockClient) FreezeTable(ctx context.Context, path ypath.Path, options *yt.FreezeTableOptions) error
- func (m *MockClient) GenerateTimestamp(ctx context.Context, options *yt.GenerateTimestampOptions) (yt.Timestamp, error)
- func (m *MockClient) GetFileFromCache(ctx context.Context, md5 string, options *yt.GetFileFromCacheOptions) (ypath.YPath, error)
- func (m *MockClient) GetInSyncReplicas(ctx context.Context, path ypath.Path, ts yt.Timestamp, keys []any, ...) ([]yt.NodeID, error)
- func (m *MockClient) GetJobStderr(ctx context.Context, opID yt.OperationID, jobID yt.JobID, ...) ([]byte, error)
- func (m *MockClient) GetNode(ctx context.Context, path ypath.YPath, result any, options *yt.GetNodeOptions) error
- func (m *MockClient) GetOperation(ctx context.Context, opID yt.OperationID, options *yt.GetOperationOptions) (*yt.OperationStatus, error)
- func (m *MockClient) GetOperationByAlias(ctx context.Context, alias string, options *yt.GetOperationOptions) (*yt.OperationStatus, error)
- func (m *MockClient) GetQuery(ctx context.Context, id yt.QueryID, options *yt.GetQueryOptions) (*yt.Query, error)
- func (m *MockClient) GetQueryResult(ctx context.Context, id yt.QueryID, resultIndex int64, ...) (*yt.QueryResult, error)
- func (m *MockClient) InsertRowBatch(ctx context.Context, path ypath.Path, rowBatch yt.RowBatch, ...) error
- func (m *MockClient) InsertRows(ctx context.Context, path ypath.Path, rows []any, ...) error
- func (m *MockClient) IssueToken(ctx context.Context, user, password string, options *yt.IssueTokenOptions) (string, error)
- func (m *MockClient) LinkNode(ctx context.Context, target, link ypath.YPath, options *yt.LinkNodeOptions) (yt.NodeID, error)
- func (m *MockClient) ListJobs(ctx context.Context, opID yt.OperationID, options *yt.ListJobsOptions) (*yt.ListJobsResult, error)
- func (m *MockClient) ListNode(ctx context.Context, path ypath.YPath, result any, options *yt.ListNodeOptions) error
- func (m *MockClient) ListOperations(ctx context.Context, options *yt.ListOperationsOptions) (*yt.ListOperationsResult, error)
- func (m *MockClient) ListQueries(ctx context.Context, options *yt.ListQueriesOptions) (*yt.ListQueriesResult, error)
- func (m *MockClient) ListUserTokens(ctx context.Context, user, password string, options *yt.ListUserTokensOptions) ([]string, error)
- func (m *MockClient) LocateSkynetShare(ctx context.Context, path ypath.YPath, options *yt.LocateSkynetShareOptions) (yt.ShareLocation, error)
- func (m *MockClient) LockRows(ctx context.Context, path ypath.Path, locks []string, lockType yt.LockType, ...) error
- func (m *MockClient) LookupRows(ctx context.Context, path ypath.Path, keys []any, ...) (yt.TableReader, error)
- func (m *MockClient) MountTable(ctx context.Context, path ypath.Path, options *yt.MountTableOptions) error
- func (m *MockClient) MoveNode(ctx context.Context, src, dst ypath.YPath, options *yt.MoveNodeOptions) (yt.NodeID, error)
- func (m *MockClient) MultisetAttributes(ctx context.Context, path ypath.YPath, attributes map[string]any, ...) error
- func (m *MockClient) NewRowBatchWriter() yt.RowBatchWriter
- func (m *MockClient) NodeExists(ctx context.Context, path ypath.YPath, options *yt.NodeExistsOptions) (bool, error)
- func (m *MockClient) PingTx(ctx context.Context, id yt.TxID, options *yt.PingTxOptions) error
- func (m *MockClient) PushQueueProducer(ctx context.Context, producerPath, queuePath ypath.Path, sessionID string, ...) (*yt.PushQueueProducerResult, error)
- func (m *MockClient) PushQueueProducerBatch(ctx context.Context, producerPath, queuePath ypath.Path, sessionID string, ...) (*yt.PushQueueProducerResult, error)
- func (m *MockClient) PutFileToCache(ctx context.Context, path ypath.YPath, md5 string, ...) (ypath.YPath, error)
- func (m *MockClient) ReadFile(ctx context.Context, path ypath.YPath, options *yt.ReadFileOptions) (io.ReadCloser, error)
- func (m *MockClient) ReadQueryResult(ctx context.Context, id yt.QueryID, resultIndex int64, ...) (yt.TableReader, error)
- func (m *MockClient) ReadTable(ctx context.Context, path ypath.YPath, options *yt.ReadTableOptions) (yt.TableReader, error)
- func (m *MockClient) RemountTable(ctx context.Context, path ypath.Path, options *yt.RemountTableOptions) error
- func (m *MockClient) RemoveMaintenance(ctx context.Context, component yt.MaintenanceComponent, address string, ...) (*yt.RemoveMaintenanceResponse, error)
- func (m *MockClient) RemoveMember(ctx context.Context, group, member string, options *yt.RemoveMemberOptions) error
- func (m *MockClient) RemoveNode(ctx context.Context, path ypath.YPath, options *yt.RemoveNodeOptions) error
- func (m *MockClient) RemoveQueueProducerSession(ctx context.Context, producerPath, queuePath ypath.Path, sessionID string, ...) error
- func (m *MockClient) RequestRestart(ctx context.Context, nodeAddress string, options *yt.RequestRestartOptions) error
- func (m *MockClient) ReshardTable(ctx context.Context, path ypath.Path, options *yt.ReshardTableOptions) error
- func (m *MockClient) RestoreTableBackup(ctx context.Context, manifest yt.BackupManifest, ...) error
- func (m *MockClient) ResumeOperation(ctx context.Context, opID yt.OperationID, options *yt.ResumeOperationOptions) error
- func (m *MockClient) ResurrectChunkLocations(ctx context.Context, nodeAddress string, locationUUIDs []guid.GUID, ...) (*yt.ResurrectChunkLocationsResponse, error)
- func (m *MockClient) RevokeToken(ctx context.Context, user, password, token string, ...) error
- func (m *MockClient) SelectRows(ctx context.Context, query string, options *yt.SelectRowsOptions) (yt.TableReader, error)
- func (m *MockClient) SetNode(ctx context.Context, path ypath.YPath, value any, options *yt.SetNodeOptions) error
- func (m *MockClient) SetUserPassword(ctx context.Context, user, newPassword, currentPassword string, ...) error
- func (m *MockClient) StartOperation(ctx context.Context, opType yt.OperationType, spec any, ...) (yt.OperationID, error)
- func (m *MockClient) StartQuery(ctx context.Context, engine yt.QueryEngine, query string, ...) (yt.QueryID, error)
- func (m *MockClient) StartTabletTx(ctx context.Context, options *yt.StartTabletTxOptions) (yt.TxID, error)
- func (m *MockClient) StartTx(ctx context.Context, options *yt.StartTxOptions) (yt.TxID, error)
- func (m *MockClient) Stop()
- func (m *MockClient) SuspendOperation(ctx context.Context, opID yt.OperationID, options *yt.SuspendOperationOptions) error
- func (m *MockClient) TransferAccountResources(ctx context.Context, srcAccount, dstAccount string, resourceDelta any, ...) error
- func (m *MockClient) TransferPoolResources(ctx context.Context, srcPool, dstPool, poolTree string, resourceDelta any, ...) error
- func (m *MockClient) UnfreezeTable(ctx context.Context, path ypath.Path, options *yt.UnfreezeTableOptions) error
- func (m *MockClient) UnmountTable(ctx context.Context, path ypath.Path, options *yt.UnmountTableOptions) error
- func (m *MockClient) UpdateOperationParameters(ctx context.Context, opID yt.OperationID, params any, ...) error
- func (m *MockClient) WhoAmI(ctx context.Context, options *yt.WhoAmIOptions) (*yt.WhoAmIResult, error)
- func (m *MockClient) WriteFile(ctx context.Context, path ypath.YPath, options *yt.WriteFileOptions) (io.WriteCloser, error)
- func (m *MockClient) WriteTable(ctx context.Context, path ypath.YPath, options *yt.WriteTableOptions) (yt.TableWriter, error)
- type MockClientMockRecorder
- func (mr *MockClientMockRecorder) AbortOperation(ctx, opID, options any) *gomock.Call
- func (mr *MockClientMockRecorder) AbortQuery(ctx, id, options any) *gomock.Call
- func (mr *MockClientMockRecorder) AbortTx(ctx, id, options any) *gomock.Call
- func (mr *MockClientMockRecorder) AddMaintenance(ctx, component, address, maintenanceType, comment, options any) *gomock.Call
- func (mr *MockClientMockRecorder) AddMember(ctx, group, member, options any) *gomock.Call
- func (mr *MockClientMockRecorder) AlterQuery(ctx, id, options any) *gomock.Call
- func (mr *MockClientMockRecorder) AlterTable(ctx, path, options any) *gomock.Call
- func (mr *MockClientMockRecorder) AlterTableReplica(ctx, id, options any) *gomock.Call
- func (mr *MockClientMockRecorder) AttachTx(ctx, txID, options any) *gomock.Call
- func (mr *MockClientMockRecorder) BeginTabletTx(ctx, options any) *gomock.Call
- func (mr *MockClientMockRecorder) BeginTx(ctx, options any) *gomock.Call
- func (mr *MockClientMockRecorder) BuildMasterSnapshots(ctx, options any) *gomock.Call
- func (mr *MockClientMockRecorder) BuildSnapshot(ctx, options any) *gomock.Call
- func (mr *MockClientMockRecorder) CheckPermission(ctx, user, permission, path, options any) *gomock.Call
- func (mr *MockClientMockRecorder) CheckPermissionByACL(ctx, user, permission, ACL, options any) *gomock.Call
- func (mr *MockClientMockRecorder) CommitTx(ctx, id, options any) *gomock.Call
- func (mr *MockClientMockRecorder) CompleteOperation(ctx, opID, options any) *gomock.Call
- func (mr *MockClientMockRecorder) CopyNode(ctx, src, dst, options any) *gomock.Call
- func (mr *MockClientMockRecorder) CreateNode(ctx, path, typ, options any) *gomock.Call
- func (mr *MockClientMockRecorder) CreateObject(ctx, typ, options any) *gomock.Call
- func (mr *MockClientMockRecorder) CreateQueueProducerSession(ctx, producerPath, queuePath, sessionID, options any) *gomock.Call
- func (mr *MockClientMockRecorder) CreateTableBackup(ctx, manifest, options any) *gomock.Call
- func (mr *MockClientMockRecorder) DeleteRows(ctx, path, keys, options any) *gomock.Call
- func (mr *MockClientMockRecorder) DestroyChunkLocations(ctx, nodeAddress, recoverUnlinkedDisks, locationUUIDs, options any) *gomock.Call
- func (mr *MockClientMockRecorder) DisableChunkLocations(ctx, nodeAddress, locationUUIDs, options any) *gomock.Call
- func (mr *MockClientMockRecorder) FreezeTable(ctx, path, options any) *gomock.Call
- func (mr *MockClientMockRecorder) GenerateTimestamp(ctx, options any) *gomock.Call
- func (mr *MockClientMockRecorder) GetFileFromCache(ctx, md5, options any) *gomock.Call
- func (mr *MockClientMockRecorder) GetInSyncReplicas(ctx, path, ts, keys, options any) *gomock.Call
- func (mr *MockClientMockRecorder) GetJobStderr(ctx, opID, jobID, options any) *gomock.Call
- func (mr *MockClientMockRecorder) GetNode(ctx, path, result, options any) *gomock.Call
- func (mr *MockClientMockRecorder) GetOperation(ctx, opID, options any) *gomock.Call
- func (mr *MockClientMockRecorder) GetOperationByAlias(ctx, alias, options any) *gomock.Call
- func (mr *MockClientMockRecorder) GetQuery(ctx, id, options any) *gomock.Call
- func (mr *MockClientMockRecorder) GetQueryResult(ctx, id, resultIndex, options any) *gomock.Call
- func (mr *MockClientMockRecorder) InsertRowBatch(ctx, path, rowBatch, options any) *gomock.Call
- func (mr *MockClientMockRecorder) InsertRows(ctx, path, rows, options any) *gomock.Call
- func (mr *MockClientMockRecorder) IssueToken(ctx, user, password, options any) *gomock.Call
- func (mr *MockClientMockRecorder) LinkNode(ctx, target, link, options any) *gomock.Call
- func (mr *MockClientMockRecorder) ListJobs(ctx, opID, options any) *gomock.Call
- func (mr *MockClientMockRecorder) ListNode(ctx, path, result, options any) *gomock.Call
- func (mr *MockClientMockRecorder) ListOperations(ctx, options any) *gomock.Call
- func (mr *MockClientMockRecorder) ListQueries(ctx, options any) *gomock.Call
- func (mr *MockClientMockRecorder) ListUserTokens(ctx, user, password, options any) *gomock.Call
- func (mr *MockClientMockRecorder) LocateSkynetShare(ctx, path, options any) *gomock.Call
- func (mr *MockClientMockRecorder) LockRows(ctx, path, locks, lockType, keys, options any) *gomock.Call
- func (mr *MockClientMockRecorder) LookupRows(ctx, path, keys, options any) *gomock.Call
- func (mr *MockClientMockRecorder) MountTable(ctx, path, options any) *gomock.Call
- func (mr *MockClientMockRecorder) MoveNode(ctx, src, dst, options any) *gomock.Call
- func (mr *MockClientMockRecorder) MultisetAttributes(ctx, path, attributes, options any) *gomock.Call
- func (mr *MockClientMockRecorder) NewRowBatchWriter() *gomock.Call
- func (mr *MockClientMockRecorder) NodeExists(ctx, path, options any) *gomock.Call
- func (mr *MockClientMockRecorder) PingTx(ctx, id, options any) *gomock.Call
- func (mr *MockClientMockRecorder) PushQueueProducer(ctx, producerPath, queuePath, sessionID, epoch, rows, options any) *gomock.Call
- func (mr *MockClientMockRecorder) PushQueueProducerBatch(ctx, producerPath, queuePath, sessionID, epoch, rowBatch, options any) *gomock.Call
- func (mr *MockClientMockRecorder) PutFileToCache(ctx, path, md5, options any) *gomock.Call
- func (mr *MockClientMockRecorder) ReadFile(ctx, path, options any) *gomock.Call
- func (mr *MockClientMockRecorder) ReadQueryResult(ctx, id, resultIndex, options any) *gomock.Call
- func (mr *MockClientMockRecorder) ReadTable(ctx, path, options any) *gomock.Call
- func (mr *MockClientMockRecorder) RemountTable(ctx, path, options any) *gomock.Call
- func (mr *MockClientMockRecorder) RemoveMaintenance(ctx, component, address, options any) *gomock.Call
- func (mr *MockClientMockRecorder) RemoveMember(ctx, group, member, options any) *gomock.Call
- func (mr *MockClientMockRecorder) RemoveNode(ctx, path, options any) *gomock.Call
- func (mr *MockClientMockRecorder) RemoveQueueProducerSession(ctx, producerPath, queuePath, sessionID, options any) *gomock.Call
- func (mr *MockClientMockRecorder) RequestRestart(ctx, nodeAddress, options any) *gomock.Call
- func (mr *MockClientMockRecorder) ReshardTable(ctx, path, options any) *gomock.Call
- func (mr *MockClientMockRecorder) RestoreTableBackup(ctx, manifest, options any) *gomock.Call
- func (mr *MockClientMockRecorder) ResumeOperation(ctx, opID, options any) *gomock.Call
- func (mr *MockClientMockRecorder) ResurrectChunkLocations(ctx, nodeAddress, locationUUIDs, options any) *gomock.Call
- func (mr *MockClientMockRecorder) RevokeToken(ctx, user, password, token, options any) *gomock.Call
- func (mr *MockClientMockRecorder) SelectRows(ctx, query, options any) *gomock.Call
- func (mr *MockClientMockRecorder) SetNode(ctx, path, value, options any) *gomock.Call
- func (mr *MockClientMockRecorder) SetUserPassword(ctx, user, newPassword, currentPassword, options any) *gomock.Call
- func (mr *MockClientMockRecorder) StartOperation(ctx, opType, spec, options any) *gomock.Call
- func (mr *MockClientMockRecorder) StartQuery(ctx, engine, query, options any) *gomock.Call
- func (mr *MockClientMockRecorder) StartTabletTx(ctx, options any) *gomock.Call
- func (mr *MockClientMockRecorder) StartTx(ctx, options any) *gomock.Call
- func (mr *MockClientMockRecorder) Stop() *gomock.Call
- func (mr *MockClientMockRecorder) SuspendOperation(ctx, opID, options any) *gomock.Call
- func (mr *MockClientMockRecorder) TransferAccountResources(ctx, srcAccount, dstAccount, resourceDelta, options any) *gomock.Call
- func (mr *MockClientMockRecorder) TransferPoolResources(ctx, srcPool, dstPool, poolTree, resourceDelta, options any) *gomock.Call
- func (mr *MockClientMockRecorder) UnfreezeTable(ctx, path, options any) *gomock.Call
- func (mr *MockClientMockRecorder) UnmountTable(ctx, path, options any) *gomock.Call
- func (mr *MockClientMockRecorder) UpdateOperationParameters(ctx, opID, params, options any) *gomock.Call
- func (mr *MockClientMockRecorder) WhoAmI(ctx, options any) *gomock.Call
- func (mr *MockClientMockRecorder) WriteFile(ctx, path, options any) *gomock.Call
- func (mr *MockClientMockRecorder) WriteTable(ctx, path, options any) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockClient ¶
type MockClient struct {
// contains filtered or unexported fields
}
MockClient is a mock of Client interface.
func NewMockClient ¶
func NewMockClient(ctrl *gomock.Controller) *MockClient
NewMockClient creates a new mock instance.
func (*MockClient) AbortOperation ¶
func (m *MockClient) AbortOperation(ctx context.Context, opID yt.OperationID, options *yt.AbortOperationOptions) error
AbortOperation mocks base method.
func (*MockClient) AbortQuery ¶
func (m *MockClient) AbortQuery(ctx context.Context, id yt.QueryID, options *yt.AbortQueryOptions) error
AbortQuery mocks base method.
func (*MockClient) AbortTx ¶
func (m *MockClient) AbortTx(ctx context.Context, id yt.TxID, options *yt.AbortTxOptions) error
AbortTx mocks base method.
func (*MockClient) AddMaintenance ¶
func (m *MockClient) AddMaintenance(ctx context.Context, component yt.MaintenanceComponent, address string, maintenanceType yt.MaintenanceType, comment string, options *yt.AddMaintenanceOptions) (*yt.AddMaintenanceResponse, error)
AddMaintenance mocks base method.
func (*MockClient) AddMember ¶
func (m *MockClient) AddMember(ctx context.Context, group, member string, options *yt.AddMemberOptions) error
AddMember mocks base method.
func (*MockClient) AlterQuery ¶
func (m *MockClient) AlterQuery(ctx context.Context, id yt.QueryID, options *yt.AlterQueryOptions) error
AlterQuery mocks base method.
func (*MockClient) AlterTable ¶
func (m *MockClient) AlterTable(ctx context.Context, path ypath.Path, options *yt.AlterTableOptions) error
AlterTable mocks base method.
func (*MockClient) AlterTableReplica ¶
func (m *MockClient) AlterTableReplica(ctx context.Context, id yt.NodeID, options *yt.AlterTableReplicaOptions) error
AlterTableReplica mocks base method.
func (*MockClient) AttachTx ¶
func (m *MockClient) AttachTx(ctx context.Context, txID yt.TxID, options *yt.AttachTxOptions) (yt.Tx, error)
AttachTx mocks base method.
func (*MockClient) BeginTabletTx ¶
func (m *MockClient) BeginTabletTx(ctx context.Context, options *yt.StartTabletTxOptions) (yt.TabletTx, error)
BeginTabletTx mocks base method.
func (*MockClient) BeginTx ¶
func (m *MockClient) BeginTx(ctx context.Context, options *yt.StartTxOptions) (yt.Tx, error)
BeginTx mocks base method.
func (*MockClient) BuildMasterSnapshots ¶
func (m *MockClient) BuildMasterSnapshots(ctx context.Context, options *yt.BuildMasterSnapshotsOptions) (*[]yt.BuildMasterSnapshot, error)
BuildMasterSnapshots mocks base method.
func (*MockClient) BuildSnapshot ¶
func (m *MockClient) BuildSnapshot(ctx context.Context, options *yt.BuildSnapshotOptions) (*yt.BuildSnapshotResponse, error)
BuildSnapshot mocks base method.
func (*MockClient) CheckPermission ¶
func (m *MockClient) CheckPermission(ctx context.Context, user, permission string, path ypath.YPath, options *yt.CheckPermissionOptions) (*yt.CheckPermissionResponse, error)
CheckPermission mocks base method.
func (*MockClient) CheckPermissionByACL ¶
func (m *MockClient) CheckPermissionByACL(ctx context.Context, user, permission string, ACL []yt.ACE, options *yt.CheckPermissionByACLOptions) (*yt.CheckPermissionResponse, error)
CheckPermissionByACL mocks base method.
func (*MockClient) CommitTx ¶
func (m *MockClient) CommitTx(ctx context.Context, id yt.TxID, options *yt.CommitTxOptions) error
CommitTx mocks base method.
func (*MockClient) CompleteOperation ¶
func (m *MockClient) CompleteOperation(ctx context.Context, opID yt.OperationID, options *yt.CompleteOperationOptions) error
CompleteOperation mocks base method.
func (*MockClient) CopyNode ¶
func (m *MockClient) CopyNode(ctx context.Context, src, dst ypath.YPath, options *yt.CopyNodeOptions) (yt.NodeID, error)
CopyNode mocks base method.
func (*MockClient) CreateNode ¶
func (m *MockClient) CreateNode(ctx context.Context, path ypath.YPath, typ yt.NodeType, options *yt.CreateNodeOptions) (yt.NodeID, error)
CreateNode mocks base method.
func (*MockClient) CreateObject ¶
func (m *MockClient) CreateObject(ctx context.Context, typ yt.NodeType, options *yt.CreateObjectOptions) (yt.NodeID, error)
CreateObject mocks base method.
func (*MockClient) CreateQueueProducerSession ¶
func (m *MockClient) CreateQueueProducerSession(ctx context.Context, producerPath, queuePath ypath.Path, sessionID string, options *yt.CreateQueueProducerSessionOptions) (*yt.CreateQueueProducerSessionResult, error)
CreateQueueProducerSession mocks base method.
func (*MockClient) CreateTableBackup ¶
func (m *MockClient) CreateTableBackup(ctx context.Context, manifest yt.BackupManifest, options *yt.CreateTableBackupOptions) error
CreateTableBackup mocks base method.
func (*MockClient) DeleteRows ¶
func (m *MockClient) DeleteRows(ctx context.Context, path ypath.Path, keys []any, options *yt.DeleteRowsOptions) error
DeleteRows mocks base method.
func (*MockClient) DestroyChunkLocations ¶
func (m *MockClient) DestroyChunkLocations(ctx context.Context, nodeAddress string, recoverUnlinkedDisks bool, locationUUIDs []guid.GUID, options *yt.DestroyChunkLocationsOptions) (*yt.DestroyChunkLocationsResponse, error)
DestroyChunkLocations mocks base method.
func (*MockClient) DisableChunkLocations ¶
func (m *MockClient) DisableChunkLocations(ctx context.Context, nodeAddress string, locationUUIDs []guid.GUID, options *yt.DisableChunkLocationsOptions) (*yt.DisableChunkLocationsResponse, error)
DisableChunkLocations mocks base method.
func (*MockClient) EXPECT ¶
func (m *MockClient) EXPECT() *MockClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockClient) FreezeTable ¶
func (m *MockClient) FreezeTable(ctx context.Context, path ypath.Path, options *yt.FreezeTableOptions) error
FreezeTable mocks base method.
func (*MockClient) GenerateTimestamp ¶
func (m *MockClient) GenerateTimestamp(ctx context.Context, options *yt.GenerateTimestampOptions) (yt.Timestamp, error)
GenerateTimestamp mocks base method.
func (*MockClient) GetFileFromCache ¶
func (m *MockClient) GetFileFromCache(ctx context.Context, md5 string, options *yt.GetFileFromCacheOptions) (ypath.YPath, error)
GetFileFromCache mocks base method.
func (*MockClient) GetInSyncReplicas ¶
func (m *MockClient) GetInSyncReplicas(ctx context.Context, path ypath.Path, ts yt.Timestamp, keys []any, options *yt.GetInSyncReplicasOptions) ([]yt.NodeID, error)
GetInSyncReplicas mocks base method.
func (*MockClient) GetJobStderr ¶
func (m *MockClient) GetJobStderr(ctx context.Context, opID yt.OperationID, jobID yt.JobID, options *yt.GetJobStderrOptions) ([]byte, error)
GetJobStderr mocks base method.
func (*MockClient) GetNode ¶
func (m *MockClient) GetNode(ctx context.Context, path ypath.YPath, result any, options *yt.GetNodeOptions) error
GetNode mocks base method.
func (*MockClient) GetOperation ¶
func (m *MockClient) GetOperation(ctx context.Context, opID yt.OperationID, options *yt.GetOperationOptions) (*yt.OperationStatus, error)
GetOperation mocks base method.
func (*MockClient) GetOperationByAlias ¶
func (m *MockClient) GetOperationByAlias(ctx context.Context, alias string, options *yt.GetOperationOptions) (*yt.OperationStatus, error)
GetOperationByAlias mocks base method.
func (*MockClient) GetQuery ¶
func (m *MockClient) GetQuery(ctx context.Context, id yt.QueryID, options *yt.GetQueryOptions) (*yt.Query, error)
GetQuery mocks base method.
func (*MockClient) GetQueryResult ¶
func (m *MockClient) GetQueryResult(ctx context.Context, id yt.QueryID, resultIndex int64, options *yt.GetQueryResultOptions) (*yt.QueryResult, error)
GetQueryResult mocks base method.
func (*MockClient) InsertRowBatch ¶
func (m *MockClient) InsertRowBatch(ctx context.Context, path ypath.Path, rowBatch yt.RowBatch, options *yt.InsertRowsOptions) error
InsertRowBatch mocks base method.
func (*MockClient) InsertRows ¶
func (m *MockClient) InsertRows(ctx context.Context, path ypath.Path, rows []any, options *yt.InsertRowsOptions) error
InsertRows mocks base method.
func (*MockClient) IssueToken ¶
func (m *MockClient) IssueToken(ctx context.Context, user, password string, options *yt.IssueTokenOptions) (string, error)
IssueToken mocks base method.
func (*MockClient) LinkNode ¶
func (m *MockClient) LinkNode(ctx context.Context, target, link ypath.YPath, options *yt.LinkNodeOptions) (yt.NodeID, error)
LinkNode mocks base method.
func (*MockClient) ListJobs ¶
func (m *MockClient) ListJobs(ctx context.Context, opID yt.OperationID, options *yt.ListJobsOptions) (*yt.ListJobsResult, error)
ListJobs mocks base method.
func (*MockClient) ListNode ¶
func (m *MockClient) ListNode(ctx context.Context, path ypath.YPath, result any, options *yt.ListNodeOptions) error
ListNode mocks base method.
func (*MockClient) ListOperations ¶
func (m *MockClient) ListOperations(ctx context.Context, options *yt.ListOperationsOptions) (*yt.ListOperationsResult, error)
ListOperations mocks base method.
func (*MockClient) ListQueries ¶
func (m *MockClient) ListQueries(ctx context.Context, options *yt.ListQueriesOptions) (*yt.ListQueriesResult, error)
ListQueries mocks base method.
func (*MockClient) ListUserTokens ¶
func (m *MockClient) ListUserTokens(ctx context.Context, user, password string, options *yt.ListUserTokensOptions) ([]string, error)
ListUserTokens mocks base method.
func (*MockClient) LocateSkynetShare ¶
func (m *MockClient) LocateSkynetShare(ctx context.Context, path ypath.YPath, options *yt.LocateSkynetShareOptions) (yt.ShareLocation, error)
LocateSkynetShare mocks base method.
func (*MockClient) LockRows ¶
func (m *MockClient) LockRows(ctx context.Context, path ypath.Path, locks []string, lockType yt.LockType, keys []any, options *yt.LockRowsOptions) error
LockRows mocks base method.
func (*MockClient) LookupRows ¶
func (m *MockClient) LookupRows(ctx context.Context, path ypath.Path, keys []any, options *yt.LookupRowsOptions) (yt.TableReader, error)
LookupRows mocks base method.
func (*MockClient) MountTable ¶
func (m *MockClient) MountTable(ctx context.Context, path ypath.Path, options *yt.MountTableOptions) error
MountTable mocks base method.
func (*MockClient) MoveNode ¶
func (m *MockClient) MoveNode(ctx context.Context, src, dst ypath.YPath, options *yt.MoveNodeOptions) (yt.NodeID, error)
MoveNode mocks base method.
func (*MockClient) MultisetAttributes ¶
func (m *MockClient) MultisetAttributes(ctx context.Context, path ypath.YPath, attributes map[string]any, options *yt.MultisetAttributesOptions) error
MultisetAttributes mocks base method.
func (*MockClient) NewRowBatchWriter ¶
func (m *MockClient) NewRowBatchWriter() yt.RowBatchWriter
NewRowBatchWriter mocks base method.
func (*MockClient) NodeExists ¶
func (m *MockClient) NodeExists(ctx context.Context, path ypath.YPath, options *yt.NodeExistsOptions) (bool, error)
NodeExists mocks base method.
func (*MockClient) PingTx ¶
func (m *MockClient) PingTx(ctx context.Context, id yt.TxID, options *yt.PingTxOptions) error
PingTx mocks base method.
func (*MockClient) PushQueueProducer ¶
func (m *MockClient) PushQueueProducer(ctx context.Context, producerPath, queuePath ypath.Path, sessionID string, epoch int64, rows []any, options *yt.PushQueueProducerOptions) (*yt.PushQueueProducerResult, error)
PushQueueProducer mocks base method.
func (*MockClient) PushQueueProducerBatch ¶
func (m *MockClient) PushQueueProducerBatch(ctx context.Context, producerPath, queuePath ypath.Path, sessionID string, epoch int64, rowBatch yt.RowBatch, options *yt.PushQueueProducerOptions) (*yt.PushQueueProducerResult, error)
PushQueueProducerBatch mocks base method.
func (*MockClient) PutFileToCache ¶
func (m *MockClient) PutFileToCache(ctx context.Context, path ypath.YPath, md5 string, options *yt.PutFileToCacheOptions) (ypath.YPath, error)
PutFileToCache mocks base method.
func (*MockClient) ReadFile ¶
func (m *MockClient) ReadFile(ctx context.Context, path ypath.YPath, options *yt.ReadFileOptions) (io.ReadCloser, error)
ReadFile mocks base method.
func (*MockClient) ReadQueryResult ¶
func (m *MockClient) ReadQueryResult(ctx context.Context, id yt.QueryID, resultIndex int64, options *yt.ReadQueryResultOptions) (yt.TableReader, error)
ReadQueryResult mocks base method.
func (*MockClient) ReadTable ¶
func (m *MockClient) ReadTable(ctx context.Context, path ypath.YPath, options *yt.ReadTableOptions) (yt.TableReader, error)
ReadTable mocks base method.
func (*MockClient) RemountTable ¶
func (m *MockClient) RemountTable(ctx context.Context, path ypath.Path, options *yt.RemountTableOptions) error
RemountTable mocks base method.
func (*MockClient) RemoveMaintenance ¶
func (m *MockClient) RemoveMaintenance(ctx context.Context, component yt.MaintenanceComponent, address string, options *yt.RemoveMaintenanceOptions) (*yt.RemoveMaintenanceResponse, error)
RemoveMaintenance mocks base method.
func (*MockClient) RemoveMember ¶
func (m *MockClient) RemoveMember(ctx context.Context, group, member string, options *yt.RemoveMemberOptions) error
RemoveMember mocks base method.
func (*MockClient) RemoveNode ¶
func (m *MockClient) RemoveNode(ctx context.Context, path ypath.YPath, options *yt.RemoveNodeOptions) error
RemoveNode mocks base method.
func (*MockClient) RemoveQueueProducerSession ¶
func (m *MockClient) RemoveQueueProducerSession(ctx context.Context, producerPath, queuePath ypath.Path, sessionID string, options *yt.RemoveQueueProducerSessionOptions) error
RemoveQueueProducerSession mocks base method.
func (*MockClient) RequestRestart ¶
func (m *MockClient) RequestRestart(ctx context.Context, nodeAddress string, options *yt.RequestRestartOptions) error
RequestRestart mocks base method.
func (*MockClient) ReshardTable ¶
func (m *MockClient) ReshardTable(ctx context.Context, path ypath.Path, options *yt.ReshardTableOptions) error
ReshardTable mocks base method.
func (*MockClient) RestoreTableBackup ¶
func (m *MockClient) RestoreTableBackup(ctx context.Context, manifest yt.BackupManifest, options *yt.RestoreTableBackupOptions) error
RestoreTableBackup mocks base method.
func (*MockClient) ResumeOperation ¶
func (m *MockClient) ResumeOperation(ctx context.Context, opID yt.OperationID, options *yt.ResumeOperationOptions) error
ResumeOperation mocks base method.
func (*MockClient) ResurrectChunkLocations ¶
func (m *MockClient) ResurrectChunkLocations(ctx context.Context, nodeAddress string, locationUUIDs []guid.GUID, options *yt.ResurrectChunkLocationsOptions) (*yt.ResurrectChunkLocationsResponse, error)
ResurrectChunkLocations mocks base method.
func (*MockClient) RevokeToken ¶
func (m *MockClient) RevokeToken(ctx context.Context, user, password, token string, options *yt.RevokeTokenOptions) error
RevokeToken mocks base method.
func (*MockClient) SelectRows ¶
func (m *MockClient) SelectRows(ctx context.Context, query string, options *yt.SelectRowsOptions) (yt.TableReader, error)
SelectRows mocks base method.
func (*MockClient) SetNode ¶
func (m *MockClient) SetNode(ctx context.Context, path ypath.YPath, value any, options *yt.SetNodeOptions) error
SetNode mocks base method.
func (*MockClient) SetUserPassword ¶
func (m *MockClient) SetUserPassword(ctx context.Context, user, newPassword, currentPassword string, options *yt.SetUserPasswordOptions) error
SetUserPassword mocks base method.
func (*MockClient) StartOperation ¶
func (m *MockClient) StartOperation(ctx context.Context, opType yt.OperationType, spec any, options *yt.StartOperationOptions) (yt.OperationID, error)
StartOperation mocks base method.
func (*MockClient) StartQuery ¶
func (m *MockClient) StartQuery(ctx context.Context, engine yt.QueryEngine, query string, options *yt.StartQueryOptions) (yt.QueryID, error)
StartQuery mocks base method.
func (*MockClient) StartTabletTx ¶
func (m *MockClient) StartTabletTx(ctx context.Context, options *yt.StartTabletTxOptions) (yt.TxID, error)
StartTabletTx mocks base method.
func (*MockClient) StartTx ¶
func (m *MockClient) StartTx(ctx context.Context, options *yt.StartTxOptions) (yt.TxID, error)
StartTx mocks base method.
func (*MockClient) SuspendOperation ¶
func (m *MockClient) SuspendOperation(ctx context.Context, opID yt.OperationID, options *yt.SuspendOperationOptions) error
SuspendOperation mocks base method.
func (*MockClient) TransferAccountResources ¶
func (m *MockClient) TransferAccountResources(ctx context.Context, srcAccount, dstAccount string, resourceDelta any, options *yt.TransferAccountResourcesOptions) error
TransferAccountResources mocks base method.
func (*MockClient) TransferPoolResources ¶
func (m *MockClient) TransferPoolResources(ctx context.Context, srcPool, dstPool, poolTree string, resourceDelta any, options *yt.TransferPoolResourcesOptions) error
TransferPoolResources mocks base method.
func (*MockClient) UnfreezeTable ¶
func (m *MockClient) UnfreezeTable(ctx context.Context, path ypath.Path, options *yt.UnfreezeTableOptions) error
UnfreezeTable mocks base method.
func (*MockClient) UnmountTable ¶
func (m *MockClient) UnmountTable(ctx context.Context, path ypath.Path, options *yt.UnmountTableOptions) error
UnmountTable mocks base method.
func (*MockClient) UpdateOperationParameters ¶
func (m *MockClient) UpdateOperationParameters(ctx context.Context, opID yt.OperationID, params any, options *yt.UpdateOperationParametersOptions) error
UpdateOperationParameters mocks base method.
func (*MockClient) WhoAmI ¶
func (m *MockClient) WhoAmI(ctx context.Context, options *yt.WhoAmIOptions) (*yt.WhoAmIResult, error)
WhoAmI mocks base method.
func (*MockClient) WriteFile ¶
func (m *MockClient) WriteFile(ctx context.Context, path ypath.YPath, options *yt.WriteFileOptions) (io.WriteCloser, error)
WriteFile mocks base method.
func (*MockClient) WriteTable ¶
func (m *MockClient) WriteTable(ctx context.Context, path ypath.YPath, options *yt.WriteTableOptions) (yt.TableWriter, error)
WriteTable mocks base method.
type MockClientMockRecorder ¶
type MockClientMockRecorder struct {
// contains filtered or unexported fields
}
MockClientMockRecorder is the mock recorder for MockClient.
func (*MockClientMockRecorder) AbortOperation ¶
func (mr *MockClientMockRecorder) AbortOperation(ctx, opID, options any) *gomock.Call
AbortOperation indicates an expected call of AbortOperation.
func (*MockClientMockRecorder) AbortQuery ¶
func (mr *MockClientMockRecorder) AbortQuery(ctx, id, options any) *gomock.Call
AbortQuery indicates an expected call of AbortQuery.
func (*MockClientMockRecorder) AbortTx ¶
func (mr *MockClientMockRecorder) AbortTx(ctx, id, options any) *gomock.Call
AbortTx indicates an expected call of AbortTx.
func (*MockClientMockRecorder) AddMaintenance ¶
func (mr *MockClientMockRecorder) AddMaintenance(ctx, component, address, maintenanceType, comment, options any) *gomock.Call
AddMaintenance indicates an expected call of AddMaintenance.
func (*MockClientMockRecorder) AddMember ¶
func (mr *MockClientMockRecorder) AddMember(ctx, group, member, options any) *gomock.Call
AddMember indicates an expected call of AddMember.
func (*MockClientMockRecorder) AlterQuery ¶
func (mr *MockClientMockRecorder) AlterQuery(ctx, id, options any) *gomock.Call
AlterQuery indicates an expected call of AlterQuery.
func (*MockClientMockRecorder) AlterTable ¶
func (mr *MockClientMockRecorder) AlterTable(ctx, path, options any) *gomock.Call
AlterTable indicates an expected call of AlterTable.
func (*MockClientMockRecorder) AlterTableReplica ¶
func (mr *MockClientMockRecorder) AlterTableReplica(ctx, id, options any) *gomock.Call
AlterTableReplica indicates an expected call of AlterTableReplica.
func (*MockClientMockRecorder) AttachTx ¶
func (mr *MockClientMockRecorder) AttachTx(ctx, txID, options any) *gomock.Call
AttachTx indicates an expected call of AttachTx.
func (*MockClientMockRecorder) BeginTabletTx ¶
func (mr *MockClientMockRecorder) BeginTabletTx(ctx, options any) *gomock.Call
BeginTabletTx indicates an expected call of BeginTabletTx.
func (*MockClientMockRecorder) BeginTx ¶
func (mr *MockClientMockRecorder) BeginTx(ctx, options any) *gomock.Call
BeginTx indicates an expected call of BeginTx.
func (*MockClientMockRecorder) BuildMasterSnapshots ¶
func (mr *MockClientMockRecorder) BuildMasterSnapshots(ctx, options any) *gomock.Call
BuildMasterSnapshots indicates an expected call of BuildMasterSnapshots.
func (*MockClientMockRecorder) BuildSnapshot ¶
func (mr *MockClientMockRecorder) BuildSnapshot(ctx, options any) *gomock.Call
BuildSnapshot indicates an expected call of BuildSnapshot.
func (*MockClientMockRecorder) CheckPermission ¶
func (mr *MockClientMockRecorder) CheckPermission(ctx, user, permission, path, options any) *gomock.Call
CheckPermission indicates an expected call of CheckPermission.
func (*MockClientMockRecorder) CheckPermissionByACL ¶
func (mr *MockClientMockRecorder) CheckPermissionByACL(ctx, user, permission, ACL, options any) *gomock.Call
CheckPermissionByACL indicates an expected call of CheckPermissionByACL.
func (*MockClientMockRecorder) CommitTx ¶
func (mr *MockClientMockRecorder) CommitTx(ctx, id, options any) *gomock.Call
CommitTx indicates an expected call of CommitTx.
func (*MockClientMockRecorder) CompleteOperation ¶
func (mr *MockClientMockRecorder) CompleteOperation(ctx, opID, options any) *gomock.Call
CompleteOperation indicates an expected call of CompleteOperation.
func (*MockClientMockRecorder) CopyNode ¶
func (mr *MockClientMockRecorder) CopyNode(ctx, src, dst, options any) *gomock.Call
CopyNode indicates an expected call of CopyNode.
func (*MockClientMockRecorder) CreateNode ¶
func (mr *MockClientMockRecorder) CreateNode(ctx, path, typ, options any) *gomock.Call
CreateNode indicates an expected call of CreateNode.
func (*MockClientMockRecorder) CreateObject ¶
func (mr *MockClientMockRecorder) CreateObject(ctx, typ, options any) *gomock.Call
CreateObject indicates an expected call of CreateObject.
func (*MockClientMockRecorder) CreateQueueProducerSession ¶
func (mr *MockClientMockRecorder) CreateQueueProducerSession(ctx, producerPath, queuePath, sessionID, options any) *gomock.Call
CreateQueueProducerSession indicates an expected call of CreateQueueProducerSession.
func (*MockClientMockRecorder) CreateTableBackup ¶
func (mr *MockClientMockRecorder) CreateTableBackup(ctx, manifest, options any) *gomock.Call
CreateTableBackup indicates an expected call of CreateTableBackup.
func (*MockClientMockRecorder) DeleteRows ¶
func (mr *MockClientMockRecorder) DeleteRows(ctx, path, keys, options any) *gomock.Call
DeleteRows indicates an expected call of DeleteRows.
func (*MockClientMockRecorder) DestroyChunkLocations ¶
func (mr *MockClientMockRecorder) DestroyChunkLocations(ctx, nodeAddress, recoverUnlinkedDisks, locationUUIDs, options any) *gomock.Call
DestroyChunkLocations indicates an expected call of DestroyChunkLocations.
func (*MockClientMockRecorder) DisableChunkLocations ¶
func (mr *MockClientMockRecorder) DisableChunkLocations(ctx, nodeAddress, locationUUIDs, options any) *gomock.Call
DisableChunkLocations indicates an expected call of DisableChunkLocations.
func (*MockClientMockRecorder) FreezeTable ¶
func (mr *MockClientMockRecorder) FreezeTable(ctx, path, options any) *gomock.Call
FreezeTable indicates an expected call of FreezeTable.
func (*MockClientMockRecorder) GenerateTimestamp ¶
func (mr *MockClientMockRecorder) GenerateTimestamp(ctx, options any) *gomock.Call
GenerateTimestamp indicates an expected call of GenerateTimestamp.
func (*MockClientMockRecorder) GetFileFromCache ¶
func (mr *MockClientMockRecorder) GetFileFromCache(ctx, md5, options any) *gomock.Call
GetFileFromCache indicates an expected call of GetFileFromCache.
func (*MockClientMockRecorder) GetInSyncReplicas ¶
func (mr *MockClientMockRecorder) GetInSyncReplicas(ctx, path, ts, keys, options any) *gomock.Call
GetInSyncReplicas indicates an expected call of GetInSyncReplicas.
func (*MockClientMockRecorder) GetJobStderr ¶
func (mr *MockClientMockRecorder) GetJobStderr(ctx, opID, jobID, options any) *gomock.Call
GetJobStderr indicates an expected call of GetJobStderr.
func (*MockClientMockRecorder) GetNode ¶
func (mr *MockClientMockRecorder) GetNode(ctx, path, result, options any) *gomock.Call
GetNode indicates an expected call of GetNode.
func (*MockClientMockRecorder) GetOperation ¶
func (mr *MockClientMockRecorder) GetOperation(ctx, opID, options any) *gomock.Call
GetOperation indicates an expected call of GetOperation.
func (*MockClientMockRecorder) GetOperationByAlias ¶
func (mr *MockClientMockRecorder) GetOperationByAlias(ctx, alias, options any) *gomock.Call
GetOperationByAlias indicates an expected call of GetOperationByAlias.
func (*MockClientMockRecorder) GetQuery ¶
func (mr *MockClientMockRecorder) GetQuery(ctx, id, options any) *gomock.Call
GetQuery indicates an expected call of GetQuery.
func (*MockClientMockRecorder) GetQueryResult ¶
func (mr *MockClientMockRecorder) GetQueryResult(ctx, id, resultIndex, options any) *gomock.Call
GetQueryResult indicates an expected call of GetQueryResult.
func (*MockClientMockRecorder) InsertRowBatch ¶
func (mr *MockClientMockRecorder) InsertRowBatch(ctx, path, rowBatch, options any) *gomock.Call
InsertRowBatch indicates an expected call of InsertRowBatch.
func (*MockClientMockRecorder) InsertRows ¶
func (mr *MockClientMockRecorder) InsertRows(ctx, path, rows, options any) *gomock.Call
InsertRows indicates an expected call of InsertRows.
func (*MockClientMockRecorder) IssueToken ¶
func (mr *MockClientMockRecorder) IssueToken(ctx, user, password, options any) *gomock.Call
IssueToken indicates an expected call of IssueToken.
func (*MockClientMockRecorder) LinkNode ¶
func (mr *MockClientMockRecorder) LinkNode(ctx, target, link, options any) *gomock.Call
LinkNode indicates an expected call of LinkNode.
func (*MockClientMockRecorder) ListJobs ¶
func (mr *MockClientMockRecorder) ListJobs(ctx, opID, options any) *gomock.Call
ListJobs indicates an expected call of ListJobs.
func (*MockClientMockRecorder) ListNode ¶
func (mr *MockClientMockRecorder) ListNode(ctx, path, result, options any) *gomock.Call
ListNode indicates an expected call of ListNode.
func (*MockClientMockRecorder) ListOperations ¶
func (mr *MockClientMockRecorder) ListOperations(ctx, options any) *gomock.Call
ListOperations indicates an expected call of ListOperations.
func (*MockClientMockRecorder) ListQueries ¶
func (mr *MockClientMockRecorder) ListQueries(ctx, options any) *gomock.Call
ListQueries indicates an expected call of ListQueries.
func (*MockClientMockRecorder) ListUserTokens ¶
func (mr *MockClientMockRecorder) ListUserTokens(ctx, user, password, options any) *gomock.Call
ListUserTokens indicates an expected call of ListUserTokens.
func (*MockClientMockRecorder) LocateSkynetShare ¶
func (mr *MockClientMockRecorder) LocateSkynetShare(ctx, path, options any) *gomock.Call
LocateSkynetShare indicates an expected call of LocateSkynetShare.
func (*MockClientMockRecorder) LockRows ¶
func (mr *MockClientMockRecorder) LockRows(ctx, path, locks, lockType, keys, options any) *gomock.Call
LockRows indicates an expected call of LockRows.
func (*MockClientMockRecorder) LookupRows ¶
func (mr *MockClientMockRecorder) LookupRows(ctx, path, keys, options any) *gomock.Call
LookupRows indicates an expected call of LookupRows.
func (*MockClientMockRecorder) MountTable ¶
func (mr *MockClientMockRecorder) MountTable(ctx, path, options any) *gomock.Call
MountTable indicates an expected call of MountTable.
func (*MockClientMockRecorder) MoveNode ¶
func (mr *MockClientMockRecorder) MoveNode(ctx, src, dst, options any) *gomock.Call
MoveNode indicates an expected call of MoveNode.
func (*MockClientMockRecorder) MultisetAttributes ¶
func (mr *MockClientMockRecorder) MultisetAttributes(ctx, path, attributes, options any) *gomock.Call
MultisetAttributes indicates an expected call of MultisetAttributes.
func (*MockClientMockRecorder) NewRowBatchWriter ¶
func (mr *MockClientMockRecorder) NewRowBatchWriter() *gomock.Call
NewRowBatchWriter indicates an expected call of NewRowBatchWriter.
func (*MockClientMockRecorder) NodeExists ¶
func (mr *MockClientMockRecorder) NodeExists(ctx, path, options any) *gomock.Call
NodeExists indicates an expected call of NodeExists.
func (*MockClientMockRecorder) PingTx ¶
func (mr *MockClientMockRecorder) PingTx(ctx, id, options any) *gomock.Call
PingTx indicates an expected call of PingTx.
func (*MockClientMockRecorder) PushQueueProducer ¶
func (mr *MockClientMockRecorder) PushQueueProducer(ctx, producerPath, queuePath, sessionID, epoch, rows, options any) *gomock.Call
PushQueueProducer indicates an expected call of PushQueueProducer.
func (*MockClientMockRecorder) PushQueueProducerBatch ¶
func (mr *MockClientMockRecorder) PushQueueProducerBatch(ctx, producerPath, queuePath, sessionID, epoch, rowBatch, options any) *gomock.Call
PushQueueProducerBatch indicates an expected call of PushQueueProducerBatch.
func (*MockClientMockRecorder) PutFileToCache ¶
func (mr *MockClientMockRecorder) PutFileToCache(ctx, path, md5, options any) *gomock.Call
PutFileToCache indicates an expected call of PutFileToCache.
func (*MockClientMockRecorder) ReadFile ¶
func (mr *MockClientMockRecorder) ReadFile(ctx, path, options any) *gomock.Call
ReadFile indicates an expected call of ReadFile.
func (*MockClientMockRecorder) ReadQueryResult ¶
func (mr *MockClientMockRecorder) ReadQueryResult(ctx, id, resultIndex, options any) *gomock.Call
ReadQueryResult indicates an expected call of ReadQueryResult.
func (*MockClientMockRecorder) ReadTable ¶
func (mr *MockClientMockRecorder) ReadTable(ctx, path, options any) *gomock.Call
ReadTable indicates an expected call of ReadTable.
func (*MockClientMockRecorder) RemountTable ¶
func (mr *MockClientMockRecorder) RemountTable(ctx, path, options any) *gomock.Call
RemountTable indicates an expected call of RemountTable.
func (*MockClientMockRecorder) RemoveMaintenance ¶
func (mr *MockClientMockRecorder) RemoveMaintenance(ctx, component, address, options any) *gomock.Call
RemoveMaintenance indicates an expected call of RemoveMaintenance.
func (*MockClientMockRecorder) RemoveMember ¶
func (mr *MockClientMockRecorder) RemoveMember(ctx, group, member, options any) *gomock.Call
RemoveMember indicates an expected call of RemoveMember.
func (*MockClientMockRecorder) RemoveNode ¶
func (mr *MockClientMockRecorder) RemoveNode(ctx, path, options any) *gomock.Call
RemoveNode indicates an expected call of RemoveNode.
func (*MockClientMockRecorder) RemoveQueueProducerSession ¶
func (mr *MockClientMockRecorder) RemoveQueueProducerSession(ctx, producerPath, queuePath, sessionID, options any) *gomock.Call
RemoveQueueProducerSession indicates an expected call of RemoveQueueProducerSession.
func (*MockClientMockRecorder) RequestRestart ¶
func (mr *MockClientMockRecorder) RequestRestart(ctx, nodeAddress, options any) *gomock.Call
RequestRestart indicates an expected call of RequestRestart.
func (*MockClientMockRecorder) ReshardTable ¶
func (mr *MockClientMockRecorder) ReshardTable(ctx, path, options any) *gomock.Call
ReshardTable indicates an expected call of ReshardTable.
func (*MockClientMockRecorder) RestoreTableBackup ¶
func (mr *MockClientMockRecorder) RestoreTableBackup(ctx, manifest, options any) *gomock.Call
RestoreTableBackup indicates an expected call of RestoreTableBackup.
func (*MockClientMockRecorder) ResumeOperation ¶
func (mr *MockClientMockRecorder) ResumeOperation(ctx, opID, options any) *gomock.Call
ResumeOperation indicates an expected call of ResumeOperation.
func (*MockClientMockRecorder) ResurrectChunkLocations ¶
func (mr *MockClientMockRecorder) ResurrectChunkLocations(ctx, nodeAddress, locationUUIDs, options any) *gomock.Call
ResurrectChunkLocations indicates an expected call of ResurrectChunkLocations.
func (*MockClientMockRecorder) RevokeToken ¶
func (mr *MockClientMockRecorder) RevokeToken(ctx, user, password, token, options any) *gomock.Call
RevokeToken indicates an expected call of RevokeToken.
func (*MockClientMockRecorder) SelectRows ¶
func (mr *MockClientMockRecorder) SelectRows(ctx, query, options any) *gomock.Call
SelectRows indicates an expected call of SelectRows.
func (*MockClientMockRecorder) SetNode ¶
func (mr *MockClientMockRecorder) SetNode(ctx, path, value, options any) *gomock.Call
SetNode indicates an expected call of SetNode.
func (*MockClientMockRecorder) SetUserPassword ¶
func (mr *MockClientMockRecorder) SetUserPassword(ctx, user, newPassword, currentPassword, options any) *gomock.Call
SetUserPassword indicates an expected call of SetUserPassword.
func (*MockClientMockRecorder) StartOperation ¶
func (mr *MockClientMockRecorder) StartOperation(ctx, opType, spec, options any) *gomock.Call
StartOperation indicates an expected call of StartOperation.
func (*MockClientMockRecorder) StartQuery ¶
func (mr *MockClientMockRecorder) StartQuery(ctx, engine, query, options any) *gomock.Call
StartQuery indicates an expected call of StartQuery.
func (*MockClientMockRecorder) StartTabletTx ¶
func (mr *MockClientMockRecorder) StartTabletTx(ctx, options any) *gomock.Call
StartTabletTx indicates an expected call of StartTabletTx.
func (*MockClientMockRecorder) StartTx ¶
func (mr *MockClientMockRecorder) StartTx(ctx, options any) *gomock.Call
StartTx indicates an expected call of StartTx.
func (*MockClientMockRecorder) Stop ¶
func (mr *MockClientMockRecorder) Stop() *gomock.Call
Stop indicates an expected call of Stop.
func (*MockClientMockRecorder) SuspendOperation ¶
func (mr *MockClientMockRecorder) SuspendOperation(ctx, opID, options any) *gomock.Call
SuspendOperation indicates an expected call of SuspendOperation.
func (*MockClientMockRecorder) TransferAccountResources ¶
func (mr *MockClientMockRecorder) TransferAccountResources(ctx, srcAccount, dstAccount, resourceDelta, options any) *gomock.Call
TransferAccountResources indicates an expected call of TransferAccountResources.
func (*MockClientMockRecorder) TransferPoolResources ¶
func (mr *MockClientMockRecorder) TransferPoolResources(ctx, srcPool, dstPool, poolTree, resourceDelta, options any) *gomock.Call
TransferPoolResources indicates an expected call of TransferPoolResources.
func (*MockClientMockRecorder) UnfreezeTable ¶
func (mr *MockClientMockRecorder) UnfreezeTable(ctx, path, options any) *gomock.Call
UnfreezeTable indicates an expected call of UnfreezeTable.
func (*MockClientMockRecorder) UnmountTable ¶
func (mr *MockClientMockRecorder) UnmountTable(ctx, path, options any) *gomock.Call
UnmountTable indicates an expected call of UnmountTable.
func (*MockClientMockRecorder) UpdateOperationParameters ¶
func (mr *MockClientMockRecorder) UpdateOperationParameters(ctx, opID, params, options any) *gomock.Call
UpdateOperationParameters indicates an expected call of UpdateOperationParameters.
func (*MockClientMockRecorder) WhoAmI ¶
func (mr *MockClientMockRecorder) WhoAmI(ctx, options any) *gomock.Call
WhoAmI indicates an expected call of WhoAmI.
func (*MockClientMockRecorder) WriteFile ¶
func (mr *MockClientMockRecorder) WriteFile(ctx, path, options any) *gomock.Call
WriteFile indicates an expected call of WriteFile.
func (*MockClientMockRecorder) WriteTable ¶
func (mr *MockClientMockRecorder) WriteTable(ctx, path, options any) *gomock.Call
WriteTable indicates an expected call of WriteTable.