Versions in this module Expand all Collapse all v3 v3.80.13 Sep 25, 2024 v3.80.12 Sep 24, 2024 Changes in this version + const TopicWriterCompressMessagesReasonCodecsMeasure + const TopicWriterCompressMessagesReasonCompressData + const TopicWriterCompressMessagesReasonCompressDataOnWriteReadData + func CoordinationOnAlterNode(t *Coordination, c *context.Context, call call, path string) func(error) + func CoordinationOnClose(t *Coordination, c *context.Context, call call) func(error) + func CoordinationOnCreateNode(t *Coordination, c *context.Context, call call, path string) func(error) + func CoordinationOnDescribeNode(t *Coordination, c *context.Context, call call, path string) func(error) + func CoordinationOnDropNode(t *Coordination, c *context.Context, call call, path string) func(error) + func CoordinationOnNew(t *Coordination, c *context.Context, call call) func() + func CoordinationOnSession(t *Coordination, c *context.Context, call call, path string) func(error) + func CoordinationOnSessionClientTimeout(t *Coordination, lastGoodResponseTime time.Time, timeout time.Duration) + func CoordinationOnSessionKeepAliveTimeout(t *Coordination, lastGoodResponseTime time.Time, timeout time.Duration) + func CoordinationOnSessionReceive(t *Coordination) func(response *Ydb_Coordination.SessionResponse, _ error) + func CoordinationOnSessionReceiveUnexpected(t *Coordination, response *Ydb_Coordination.SessionResponse) + func CoordinationOnSessionSend(t *Coordination, request *Ydb_Coordination.SessionRequest) func(error) + func CoordinationOnSessionServerError(t *Coordination, failure *Ydb_Coordination.SessionResponse_Failure) + func CoordinationOnSessionServerExpire(t *Coordination, failure *Ydb_Coordination.SessionResponse_Failure) + func CoordinationOnSessionStart(t *Coordination) func(error) + func CoordinationOnSessionStartTimeout(t *Coordination, timeout time.Duration) + func CoordinationOnSessionStarted(t *Coordination, sessionID uint64, expectedSessionID uint64) + func CoordinationOnSessionStop(t *Coordination, sessionID uint64) + func CoordinationOnSessionStopTimeout(t *Coordination, timeout time.Duration) + func CoordinationOnSessionStopped(t *Coordination, sessionID uint64, expectedSessionID uint64) + func CoordinationOnStreamNew(t *Coordination) func(error) + func DatabaseSQLOnConnBegin(t *DatabaseSQL, c *context.Context, call call) func(tx txInfo, _ error) + func DatabaseSQLOnConnClose(t *DatabaseSQL, c *context.Context, call call) func(error) + func DatabaseSQLOnConnExec(t *DatabaseSQL, c *context.Context, call call, query string, mode string, ...) func(error) + func DatabaseSQLOnConnIsTableExists(t *DatabaseSQL, c *context.Context, call call, tableName string) func(exists bool, _ error) + func DatabaseSQLOnConnPing(t *DatabaseSQL, c *context.Context, call call) func(error) + func DatabaseSQLOnConnPrepare(t *DatabaseSQL, c *context.Context, call call, query string) func(error) + func DatabaseSQLOnConnQuery(t *DatabaseSQL, c *context.Context, call call, query string, mode string, ...) func(error) + func DatabaseSQLOnConnectorConnect(t *DatabaseSQL, c *context.Context, call call) func(_ error, session sessionInfo) + func DatabaseSQLOnDoTx(t *DatabaseSQL, c *context.Context, call call, iD string, idempotent bool) func(error) func(attempts int, _ error) + func DatabaseSQLOnStmtClose(t *DatabaseSQL, stmtContext *context.Context, call call) func(error) + func DatabaseSQLOnStmtExec(t *DatabaseSQL, c *context.Context, call call, stmtContext context.Context, ...) func(error) + func DatabaseSQLOnStmtQuery(t *DatabaseSQL, c *context.Context, call call, stmtContext context.Context, ...) func(error) + func DatabaseSQLOnTxCommit(t *DatabaseSQL, c *context.Context, call call, tx txInfo) func(error) + func DatabaseSQLOnTxExec(t *DatabaseSQL, c *context.Context, call call, txContext context.Context, ...) func(error) + func DatabaseSQLOnTxPrepare(t *DatabaseSQL, c *context.Context, call call, txContext context.Context, ...) func(error) + func DatabaseSQLOnTxQuery(t *DatabaseSQL, c *context.Context, call call, txContext context.Context, ...) func(error) + func DatabaseSQLOnTxRollback(t *DatabaseSQL, c *context.Context, call call, tx txInfo) func(error) + func DiscoveryOnDiscover(t *Discovery, c *context.Context, call call, address string, database string) func(location string, endpoints []EndpointInfo, _ error) + func DiscoveryOnWhoAmI(t *Discovery, c *context.Context, call call) func(user string, groups []string, _ error) + func DriverOnBalancerChooseEndpoint(t *Driver, c *context.Context, call call) func(endpoint EndpointInfo, _ error) + func DriverOnBalancerClose(t *Driver, c *context.Context, call call) func(error) + func DriverOnBalancerClusterDiscoveryAttempt(t *Driver, c *context.Context, call call, address string) func(error) + func DriverOnBalancerInit(t *Driver, c *context.Context, call call, name string) func(error) + func DriverOnBalancerUpdate(t *Driver, c *context.Context, call call, needLocalDC bool) ... + func DriverOnClose(t *Driver, c *context.Context, call call) func(error) + func DriverOnConnAllow(t *Driver, c *context.Context, call call, endpoint EndpointInfo, ...) func(state ConnState) + func DriverOnConnBan(t *Driver, c *context.Context, call call, endpoint EndpointInfo, ...) func(state ConnState) + func DriverOnConnClose(t *Driver, c *context.Context, call call, endpoint EndpointInfo) func(error) + func DriverOnConnDial(t *Driver, c *context.Context, call call, endpoint EndpointInfo) func(error) + func DriverOnConnInvoke(t *Driver, c *context.Context, call call, endpoint EndpointInfo, m Method) func(_ error, issues []Issue, opID string, state ConnState, ...) + func DriverOnConnNewStream(t *Driver, c *context.Context, call call, endpoint EndpointInfo, m Method) func(_ error, state ConnState) + func DriverOnConnPark(t *Driver, c *context.Context, call call, endpoint EndpointInfo) func(error) + func DriverOnConnStateChange(t *Driver, c *context.Context, call call, endpoint EndpointInfo, ...) func(state ConnState) + func DriverOnConnStreamCloseSend(t *Driver, c *context.Context, call call) func(error) + func DriverOnConnStreamFinish(t *Driver, c context.Context, call call, e error) + func DriverOnConnStreamRecvMsg(t *Driver, c *context.Context, call call) func(error) + func DriverOnConnStreamSendMsg(t *Driver, c *context.Context, call call) func(error) + func DriverOnGetCredentials(t *Driver, c *context.Context, call call) func(token string, _ error) + func DriverOnInit(t *Driver, c *context.Context, call call, endpoint string, database string, ...) func(error) + func DriverOnPoolNew(t *Driver, c *context.Context, call call) func() + func DriverOnPoolRelease(t *Driver, c *context.Context, call call) func(error) + func DriverOnRepeaterWakeUp(t *Driver, c *context.Context, call call, name string, event string) func(error) + func DriverOnResolve(t *Driver, call call, target string, resolved []string) func(error) + func DriverOnWith(t *Driver, c *context.Context, call call, endpoint string, database string, ...) func(error) + func QueryOnClose(t *Query, c *context.Context, call call) func(error) + func QueryOnDo(t *Query, c *context.Context, call call) func(attempts int, _ error) + func QueryOnDoTx(t *Query, c *context.Context, call call) func(attempts int, _ error) + func QueryOnExec(t *Query, c *context.Context, call call, query string) func(error) + func QueryOnNew(t *Query, c *context.Context, call call) func() + func QueryOnPoolChange(t *Query, limit int, index int, idle int, wait int, createInProgress int) + func QueryOnPoolClose(t *Query, c *context.Context, call call) func(error) + func QueryOnPoolGet(t *Query, c *context.Context, call call) func(session sessionInfo, attempts int, _ error) + func QueryOnPoolNew(t *Query, c *context.Context, call call) func(limit int) + func QueryOnPoolPut(t *Query, c *context.Context, call call, session sessionInfo) func(error) + func QueryOnPoolTry(t *Query, c *context.Context, call call) func(error) + func QueryOnPoolWith(t *Query, c *context.Context, call call) func(attempts int, _ error) + func QueryOnQuery(t *Query, c *context.Context, call call, query string) func(error) + func QueryOnQueryResultSet(t *Query, c *context.Context, call call, query string) func(error) + func QueryOnQueryRow(t *Query, c *context.Context, call call, query string) func(error) + func QueryOnResultClose(t *Query, c *context.Context, call call) func(error) + func QueryOnResultNew(t *Query, c *context.Context, call call) func(error) + func QueryOnResultNextPart(t *Query, c *context.Context, call call) func(stats *Ydb_TableStats.QueryStats, _ error) + func QueryOnResultNextResultSet(t *Query, c *context.Context, call call) func(error) + func QueryOnSessionAttach(t *Query, c *context.Context, call call, session sessionInfo) func(error) + func QueryOnSessionBegin(t *Query, c *context.Context, call call, session sessionInfo) func(_ error, tx txInfo) + func QueryOnSessionCreate(t *Query, c *context.Context, call call) func(session sessionInfo, _ error) + func QueryOnSessionDelete(t *Query, c *context.Context, call call, session sessionInfo) func(error) + func QueryOnSessionExec(t *Query, c *context.Context, call call, session sessionInfo, query string) func(error) + func QueryOnSessionQuery(t *Query, c *context.Context, call call, session sessionInfo, query string) func(error) + func QueryOnSessionQueryResultSet(t *Query, c *context.Context, call call, session sessionInfo, query string) func(error) + func QueryOnSessionQueryRow(t *Query, c *context.Context, call call, session sessionInfo, query string) func(error) + func QueryOnTxExec(t *Query, c *context.Context, call call, session sessionInfo, tx txInfo, ...) func(error) + func QueryOnTxQuery(t *Query, c *context.Context, call call, session sessionInfo, tx txInfo, ...) func(error) + func QueryOnTxQueryResultSet(t *Query, c *context.Context, call call, tx txInfo, query string) func(error) + func QueryOnTxQueryRow(t *Query, c *context.Context, call call, tx txInfo, query string) func(error) + func RetryOnRetry(t *Retry, c *context.Context, call call, label string, idempotent bool, ...) func(attempts int, _ error) + func SchemeOnDescribePath(t *Scheme, c *context.Context, call call, path string) func(entryType string, _ error) + func SchemeOnListDirectory(t *Scheme, c *context.Context, call call) func(error) + func SchemeOnMakeDirectory(t *Scheme, c *context.Context, call call, path string) func(error) + func SchemeOnModifyPermissions(t *Scheme, c *context.Context, call call, path string) func(error) + func SchemeOnRemoveDirectory(t *Scheme, c *context.Context, call call, path string) func(error) + func ScriptingOnClose(t *Scripting, c *context.Context, call call) func(error) + func ScriptingOnExecute(t *Scripting, c *context.Context, call call, query string, ...) func(result scriptingResult, _ error) + func ScriptingOnExplain(t *Scripting, c *context.Context, call call, query string) func(plan string, _ error) + func ScriptingOnStreamExecute(t *Scripting, c *context.Context, call call, query string, ...) func(error) func(error) + func TableOnClose(t *Table, c *context.Context, call call) func(error) + func TableOnCreateSession(t *Table, c *context.Context, call call) func(session sessionInfo, attempts int, _ error) + func TableOnDo(t *Table, c *context.Context, call call, label string, idempotent bool, ...) func(attempts int, _ error) + func TableOnDoTx(t *Table, c *context.Context, call call, label string, idempotent bool, ...) func(attempts int, _ error) + func TableOnInit(t *Table, c *context.Context, call call) func(limit int) + func TableOnPoolGet(t *Table, c *context.Context, call call) func(session sessionInfo, attempts int, _ error) + func TableOnPoolPut(t *Table, c *context.Context, call call, session sessionInfo) func(error) + func TableOnPoolSessionAdd(t *Table, session sessionInfo) + func TableOnPoolSessionRemove(t *Table, session sessionInfo) + func TableOnPoolStateChange(t *Table, limit int, index int, idle int, wait int, createInProgress int, ...) + func TableOnPoolWait(t *Table, c *context.Context, call call) func(session sessionInfo, _ error) + func TableOnPoolWith(t *Table, c *context.Context, call call) func(attempts int, _ error) + func TableOnSessionBulkUpsert(t *Table, c *context.Context, call call, session sessionInfo) func(error) + func TableOnSessionDelete(t *Table, c *context.Context, call call, session sessionInfo) func(error) + func TableOnSessionKeepAlive(t *Table, c *context.Context, call call, session sessionInfo) func(error) + func TableOnSessionNew(t *Table, c *context.Context, call call) func(session sessionInfo, _ error) + func TableOnSessionQueryExecute(t *Table, c *context.Context, call call, session sessionInfo, ...) func(tx txInfo, prepared bool, result tableResult, _ error) + func TableOnSessionQueryExplain(t *Table, c *context.Context, call call, session sessionInfo, query string) func(aST string, plan string, _ error) + func TableOnSessionQueryPrepare(t *Table, c *context.Context, call call, session sessionInfo, query string) func(result tableDataQuery, _ error) + func TableOnSessionQueryStreamExecute(t *Table, c *context.Context, call call, session sessionInfo, ...) func(error) + func TableOnSessionQueryStreamRead(t *Table, c *context.Context, call call, session sessionInfo) func(error) + func TableOnTxBegin(t *Table, c *context.Context, call call, session sessionInfo) func(tx txInfo, _ error) + func TableOnTxCommit(t *Table, c *context.Context, call call, session sessionInfo, tx txInfo) func(error) + func TableOnTxExecute(t *Table, c *context.Context, call call, session sessionInfo, tx txInfo, ...) func(result tableResult, _ error) + func TableOnTxExecuteStatement(t *Table, c *context.Context, call call, session sessionInfo, tx txInfo, ...) func(result tableResult, _ error) + func TableOnTxRollback(t *Table, c *context.Context, call call, session sessionInfo, tx txInfo) func(error) + func TopicOnReaderClose(t *Topic, readerConnectionID string, closeReason error) func(closeError error) + func TopicOnReaderCommit(t *Topic, requestContext *context.Context, topic string, partitionID int64, ...) func(error) + func TopicOnReaderCommittedNotify(t *Topic, readerConnectionID string, topic string, partitionID int64, ...) + func TopicOnReaderError(t *Topic, readerConnectionID string, e error) + func TopicOnReaderInit(t *Topic, preInitReaderConnectionID string, ...) func(readerConnectionID string, _ error) + func TopicOnReaderPartitionReadStartResponse(t *Topic, readerConnectionID string, partitionContext *context.Context, ...) func(readOffset *int64, commitOffset *int64, _ error) + func TopicOnReaderPartitionReadStopResponse(t *Topic, readerConnectionID string, partitionContext context.Context, ...) func(error) + func TopicOnReaderPopBatchTx(t *Topic, c *context.Context, readerID int64, transactionSessionID string, ...) func(startOffset int64, endOffset int64, messagesCount int, _ error) + func TopicOnReaderReadMessages(t *Topic, requestContext *context.Context, minCount int, maxCount int, ...) ... + func TopicOnReaderReceiveDataResponse(t *Topic, readerConnectionID string, localBufferSizeAfterReceive int, ...) func(error) + func TopicOnReaderReconnect(t *Topic, reason error) func(error) + func TopicOnReaderReconnectRequest(t *Topic, reason error, wasSent bool) + func TopicOnReaderSendCommitMessage(t *Topic, commitsInfo TopicReaderStreamSendCommitMessageStartMessageInfo) func(error) + func TopicOnReaderSentDataRequest(t *Topic, readerConnectionID string, requestBytes int, ...) + func TopicOnReaderStart(t *Topic, readerID int64, consumer string, e error) + func TopicOnReaderStreamPopBatchTx(t *Topic, c *context.Context, readerID int64, readerConnectionID string, ...) func(error) + func TopicOnReaderTransactionCompleted(t *Topic, c *context.Context, readerID int64, readerConnectionID string, ...) func() + func TopicOnReaderTransactionRollback(t *Topic, c *context.Context, readerID int64, readerConnectionID string, ...) func(rollbackError error) + func TopicOnReaderUnknownGrpcMessage(t *Topic, readerConnectionID string, e error) + func TopicOnReaderUpdateOffsetsInTransaction(t *Topic, c *context.Context, readerID int64, readerConnectionID string, ...) func(error) + func TopicOnReaderUpdateToken(t *Topic, readerConnectionID string) func(tokenLen int, _ error) func(error) + func TopicOnWriterAfterFinishTransaction(t *Topic, e error, sessionID string, transactionID string) func(closeError error) + func TopicOnWriterBeforeCommitTransaction(t *Topic, ctx *context.Context, kqpSessionID string, topicSessionID string, ...) func(_ error, topicSessionID string) + func TopicOnWriterClose(t *Topic, writerInstanceID string, reason error) func(error) + func TopicOnWriterCompressMessages(t *Topic, writerInstanceID string, sessionID string, codec int32, ...) func(error) + func TopicOnWriterInitStream(t *Topic, writerInstanceID string, topic string, producerID string) func(sessionID string, _ error) + func TopicOnWriterReadUnknownGrpcMessage(t *Topic, writerInstanceID string, sessionID string, e error) + func TopicOnWriterReceiveResult(t *Topic, writerInstanceID string, sessionID string, partitionID int64, ...) + func TopicOnWriterReconnect(t *Topic, writerInstanceID string, topic string, producerID string, ...) func(error) + func TopicOnWriterSendMessages(t *Topic, writerInstanceID string, sessionID string, codec int32, ...) func(error) + func WithDefaultDetails(defaultDetails Details) matchDetailsOption + func WithPOSIXMatch() matchDetailsOption + type ConnState interface + Code func() int + IsValid func() bool + type Coordination struct + OnAlterNode func(CoordinationAlterNodeStartInfo) func(CoordinationAlterNodeDoneInfo) + OnClose func(CoordinationCloseStartInfo) func(CoordinationCloseDoneInfo) + OnCreateNode func(CoordinationCreateNodeStartInfo) func(CoordinationCreateNodeDoneInfo) + OnDescribeNode func(CoordinationDescribeNodeStartInfo) func(CoordinationDescribeNodeDoneInfo) + OnDropNode func(CoordinationDropNodeStartInfo) func(CoordinationDropNodeDoneInfo) + OnNew func(CoordinationNewStartInfo) func(CoordinationNewDoneInfo) + OnSession func(CoordinationSessionStartInfo) func(CoordinationSessionDoneInfo) + OnSessionClientTimeout func(CoordinationSessionClientTimeoutInfo) + OnSessionKeepAliveTimeout func(CoordinationSessionKeepAliveTimeoutInfo) + OnSessionReceive func(CoordinationSessionReceiveStartInfo) func(CoordinationSessionReceiveDoneInfo) + OnSessionReceiveUnexpected func(CoordinationSessionReceiveUnexpectedInfo) + OnSessionSend func(CoordinationSessionSendStartInfo) func(CoordinationSessionSendDoneInfo) + OnSessionServerError func(CoordinationSessionServerErrorInfo) + OnSessionServerExpire func(CoordinationSessionServerExpireInfo) + OnSessionStart func(CoordinationSessionStartStartInfo) func(CoordinationSessionStartDoneInfo) + OnSessionStartTimeout func(CoordinationSessionStartTimeoutInfo) + OnSessionStarted func(CoordinationSessionStartedInfo) + OnSessionStop func(CoordinationSessionStopInfo) + OnSessionStopTimeout func(CoordinationSessionStopTimeoutInfo) + OnSessionStopped func(CoordinationSessionStoppedInfo) + OnStreamNew func(CoordinationStreamNewStartInfo) func(CoordinationStreamNewDoneInfo) + func (t *Coordination) Compose(x *Coordination, opts ...CoordinationComposeOption) *Coordination + type CoordinationAlterNodeDoneInfo struct + Error error + type CoordinationAlterNodeStartInfo struct + Call call + Context *context.Context + Path string + type CoordinationCloseDoneInfo struct + Error error + type CoordinationCloseStartInfo struct + Call call + Context *context.Context + type CoordinationComposeOption func(o *coordinationComposeOptions) + func WithCoordinationPanicCallback(cb func(e interface{})) CoordinationComposeOption + type CoordinationCreateNodeDoneInfo struct + Error error + type CoordinationCreateNodeStartInfo struct + Call call + Context *context.Context + Path string + type CoordinationDescribeNodeDoneInfo struct + Error error + type CoordinationDescribeNodeStartInfo struct + Call call + Context *context.Context + Path string + type CoordinationDropNodeDoneInfo struct + Error error + type CoordinationDropNodeStartInfo struct + Call call + Context *context.Context + Path string + type CoordinationNewDoneInfo struct + type CoordinationNewStartInfo struct + Call call + Context *context.Context + type CoordinationSessionClientTimeoutInfo struct + LastGoodResponseTime time.Time + Timeout time.Duration + type CoordinationSessionDoneInfo struct + Error error + type CoordinationSessionKeepAliveTimeoutInfo struct + LastGoodResponseTime time.Time + Timeout time.Duration + type CoordinationSessionReceiveDoneInfo struct + Error error + Response *Ydb_Coordination.SessionResponse + type CoordinationSessionReceiveStartInfo struct + type CoordinationSessionReceiveUnexpectedInfo struct + Response *Ydb_Coordination.SessionResponse + type CoordinationSessionSendDoneInfo struct + Error error + type CoordinationSessionSendStartInfo struct + Request *Ydb_Coordination.SessionRequest + type CoordinationSessionServerErrorInfo struct + Failure *Ydb_Coordination.SessionResponse_Failure + type CoordinationSessionServerExpireInfo struct + Failure *Ydb_Coordination.SessionResponse_Failure + type CoordinationSessionStartDoneInfo struct + Error error + type CoordinationSessionStartInfo struct + Call call + Context *context.Context + Path string + type CoordinationSessionStartStartInfo struct + type CoordinationSessionStartTimeoutInfo struct + Timeout time.Duration + type CoordinationSessionStartedInfo struct + ExpectedSessionID uint64 + SessionID uint64 + type CoordinationSessionStopInfo struct + SessionID uint64 + type CoordinationSessionStopTimeoutInfo struct + Timeout time.Duration + type CoordinationSessionStoppedInfo struct + ExpectedSessionID uint64 + SessionID uint64 + type CoordinationStreamNewDoneInfo struct + Error error + type CoordinationStreamNewStartInfo struct + type DatabaseSQL struct + OnConnBegin func(DatabaseSQLConnBeginStartInfo) func(DatabaseSQLConnBeginDoneInfo) + OnConnClose func(DatabaseSQLConnCloseStartInfo) func(DatabaseSQLConnCloseDoneInfo) + OnConnExec func(DatabaseSQLConnExecStartInfo) func(DatabaseSQLConnExecDoneInfo) + OnConnIsTableExists func(DatabaseSQLConnIsTableExistsStartInfo) func(DatabaseSQLConnIsTableExistsDoneInfo) + OnConnPing func(DatabaseSQLConnPingStartInfo) func(DatabaseSQLConnPingDoneInfo) + OnConnPrepare func(DatabaseSQLConnPrepareStartInfo) func(DatabaseSQLConnPrepareDoneInfo) + OnConnQuery func(DatabaseSQLConnQueryStartInfo) func(DatabaseSQLConnQueryDoneInfo) + OnConnectorConnect func(DatabaseSQLConnectorConnectStartInfo) func(DatabaseSQLConnectorConnectDoneInfo) + OnDoTx func(DatabaseSQLDoTxStartInfo) func(DatabaseSQLDoTxIntermediateInfo) func(DatabaseSQLDoTxDoneInfo) + OnStmtClose func(DatabaseSQLStmtCloseStartInfo) func(DatabaseSQLStmtCloseDoneInfo) + OnStmtExec func(DatabaseSQLStmtExecStartInfo) func(DatabaseSQLStmtExecDoneInfo) + OnStmtQuery func(DatabaseSQLStmtQueryStartInfo) func(DatabaseSQLStmtQueryDoneInfo) + OnTxCommit func(DatabaseSQLTxCommitStartInfo) func(DatabaseSQLTxCommitDoneInfo) + OnTxExec func(DatabaseSQLTxExecStartInfo) func(DatabaseSQLTxExecDoneInfo) + OnTxPrepare func(DatabaseSQLTxPrepareStartInfo) func(DatabaseSQLTxPrepareDoneInfo) + OnTxQuery func(DatabaseSQLTxQueryStartInfo) func(DatabaseSQLTxQueryDoneInfo) + OnTxRollback func(DatabaseSQLTxRollbackStartInfo) func(DatabaseSQLTxRollbackDoneInfo) + func (t *DatabaseSQL) Compose(x *DatabaseSQL, opts ...DatabaseSQLComposeOption) *DatabaseSQL + type DatabaseSQLComposeOption func(o *databaseSQLComposeOptions) + func WithDatabaseSQLPanicCallback(cb func(e interface{})) DatabaseSQLComposeOption + type DatabaseSQLConnBeginDoneInfo struct + Error error + Tx txInfo + type DatabaseSQLConnBeginStartInfo struct + Call call + Context *context.Context + type DatabaseSQLConnCloseDoneInfo struct + Error error + type DatabaseSQLConnCloseStartInfo struct + Call call + Context *context.Context + type DatabaseSQLConnExecDoneInfo struct + Error error + type DatabaseSQLConnExecStartInfo struct + Call call + Context *context.Context + Idempotent bool + IdleTime time.Duration + Mode string + Query string + type DatabaseSQLConnIsTableExistsDoneInfo struct + Error error + Exists bool + type DatabaseSQLConnIsTableExistsStartInfo struct + Call call + Context *context.Context + TableName string + type DatabaseSQLConnPingDoneInfo struct + Error error + type DatabaseSQLConnPingStartInfo struct + Call call + Context *context.Context + type DatabaseSQLConnPrepareDoneInfo struct + Error error + type DatabaseSQLConnPrepareStartInfo struct + Call call + Context *context.Context + Query string + type DatabaseSQLConnQueryDoneInfo struct + Error error + type DatabaseSQLConnQueryStartInfo struct + Call call + Context *context.Context + Idempotent bool + IdleTime time.Duration + Mode string + Query string + type DatabaseSQLConnectorConnectDoneInfo struct + Error error + Session sessionInfo + type DatabaseSQLConnectorConnectStartInfo struct + Call call + Context *context.Context + type DatabaseSQLDoTxDoneInfo struct + Attempts int + Error error + type DatabaseSQLDoTxIntermediateInfo struct + Error error + type DatabaseSQLDoTxStartInfo struct + Call call + Context *context.Context + ID string + Idempotent bool + type DatabaseSQLStmtCloseDoneInfo struct + Error error + type DatabaseSQLStmtCloseStartInfo struct + Call call + StmtContext *context.Context + type DatabaseSQLStmtExecDoneInfo struct + Error error + type DatabaseSQLStmtExecStartInfo struct + Call call + Context *context.Context + Query string + StmtContext context.Context + type DatabaseSQLStmtQueryDoneInfo struct + Error error + type DatabaseSQLStmtQueryStartInfo struct + Call call + Context *context.Context + Query string + StmtContext context.Context + type DatabaseSQLTxCommitDoneInfo struct + Error error + type DatabaseSQLTxCommitStartInfo struct + Call call + Context *context.Context + Tx txInfo + type DatabaseSQLTxExecDoneInfo struct + Error error + type DatabaseSQLTxExecStartInfo struct + Call call + Context *context.Context + Query string + Tx txInfo + TxContext context.Context + type DatabaseSQLTxPrepareDoneInfo struct + Error error + type DatabaseSQLTxPrepareStartInfo struct + Call call + Context *context.Context + Query string + Tx txInfo + TxContext context.Context + type DatabaseSQLTxQueryDoneInfo struct + Error error + type DatabaseSQLTxQueryStartInfo struct + Call call + Context *context.Context + Query string + Tx txInfo + TxContext context.Context + type DatabaseSQLTxRollbackDoneInfo struct + Error error + type DatabaseSQLTxRollbackStartInfo struct + Call call + Context *context.Context + Tx txInfo + type Detailer interface + Details func() Details + type Details uint64 + const CoordinationEvents + const DatabaseSQLConnEvents + const DatabaseSQLConnectorEvents + const DatabaseSQLEvents + const DatabaseSQLStmtEvents + const DatabaseSQLTxEvents + const DetailsAll + const DiscoveryEvents + const DriverBalancerEvents + const DriverConnEvents + const DriverConnStreamEvents + const DriverCredentialsEvents + const DriverEvents + const DriverNetEvents + const DriverRepeaterEvents + const DriverResolverEvents + const QueryEvents + const QueryPoolEvents + const QueryResultEvents + const QuerySessionEvents + const QueryTransactionEvents + const RatelimiterEvents + const RetryEvents + const SchemeEvents + const ScriptingEvents + const TableEvents + const TablePoolAPIEvents + const TablePoolEvents + const TablePoolLifeCycleEvents + const TablePoolSessionLifeCycleEvents + const TableSessionEvents + const TableSessionLifeCycleEvents + const TableSessionQueryEvents + const TableSessionQueryInvokeEvents + const TableSessionQueryStreamEvents + const TableSessionTransactionEvents + const TopicControlPlaneEvents + const TopicEvents + const TopicReaderCustomerEvents + const TopicReaderEvents + const TopicReaderMessageEvents + const TopicReaderPartitionEvents + const TopicReaderStreamEvents + const TopicReaderStreamLifeCycleEvents + const TopicReaderTransactionEvents + const TopicWriterStreamEvents + const TopicWriterStreamLifeCycleEvents + func MatchDetails(pattern string, opts ...matchDetailsOption) (d Details) + func (d Details) Details() Details + func (d Details) String() string + type Discovery struct + OnDiscover func(DiscoveryDiscoverStartInfo) func(DiscoveryDiscoverDoneInfo) + OnWhoAmI func(DiscoveryWhoAmIStartInfo) func(DiscoveryWhoAmIDoneInfo) + func (t *Discovery) Compose(x *Discovery, opts ...DiscoveryComposeOption) *Discovery + type DiscoveryComposeOption func(o *discoveryComposeOptions) + func WithDiscoveryPanicCallback(cb func(e interface{})) DiscoveryComposeOption + type DiscoveryDiscoverDoneInfo struct + Endpoints []EndpointInfo + Error error + Location string + type DiscoveryDiscoverStartInfo struct + Address string + Call call + Context *context.Context + Database string + type DiscoveryWhoAmIDoneInfo struct + Error error + Groups []string + User string + type DiscoveryWhoAmIStartInfo struct + Call call + Context *context.Context + type Driver struct + OnBalancerChooseEndpoint func(DriverBalancerChooseEndpointStartInfo) func(DriverBalancerChooseEndpointDoneInfo) + OnBalancerClose func(DriverBalancerCloseStartInfo) func(DriverBalancerCloseDoneInfo) + OnBalancerClusterDiscoveryAttempt func(DriverBalancerClusterDiscoveryAttemptStartInfo) func(DriverBalancerClusterDiscoveryAttemptDoneInfo) + OnBalancerInit func(DriverBalancerInitStartInfo) func(DriverBalancerInitDoneInfo) + OnBalancerUpdate func(DriverBalancerUpdateStartInfo) func(DriverBalancerUpdateDoneInfo) + OnClose func(DriverCloseStartInfo) func(DriverCloseDoneInfo) + OnConnAllow func(DriverConnAllowStartInfo) func(DriverConnAllowDoneInfo) + OnConnBan func(DriverConnBanStartInfo) func(DriverConnBanDoneInfo) + OnConnClose func(DriverConnCloseStartInfo) func(DriverConnCloseDoneInfo) + OnConnDial func(DriverConnDialStartInfo) func(DriverConnDialDoneInfo) + OnConnInvoke func(DriverConnInvokeStartInfo) func(DriverConnInvokeDoneInfo) + OnConnNewStream func(DriverConnNewStreamStartInfo) func(DriverConnNewStreamDoneInfo) + OnConnPark func(DriverConnParkStartInfo) func(DriverConnParkDoneInfo) + OnConnStateChange func(DriverConnStateChangeStartInfo) func(DriverConnStateChangeDoneInfo) + OnConnStreamCloseSend func(DriverConnStreamCloseSendStartInfo) func(DriverConnStreamCloseSendDoneInfo) + OnConnStreamFinish func(info DriverConnStreamFinishInfo) + OnConnStreamRecvMsg func(DriverConnStreamRecvMsgStartInfo) func(DriverConnStreamRecvMsgDoneInfo) + OnConnStreamSendMsg func(DriverConnStreamSendMsgStartInfo) func(DriverConnStreamSendMsgDoneInfo) + OnGetCredentials func(DriverGetCredentialsStartInfo) func(DriverGetCredentialsDoneInfo) + OnInit func(DriverInitStartInfo) func(DriverInitDoneInfo) + OnPoolNew func(DriverConnPoolNewStartInfo) func(DriverConnPoolNewDoneInfo) + OnPoolRelease func(DriverConnPoolReleaseStartInfo) func(DriverConnPoolReleaseDoneInfo) + OnRepeaterWakeUp func(DriverRepeaterWakeUpStartInfo) func(DriverRepeaterWakeUpDoneInfo) + OnResolve func(DriverResolveStartInfo) func(DriverResolveDoneInfo) + OnWith func(DriverWithStartInfo) func(DriverWithDoneInfo) + func (t *Driver) Compose(x *Driver, opts ...DriverComposeOption) *Driver + type DriverBalancerChooseEndpointDoneInfo struct + Endpoint EndpointInfo + Error error + type DriverBalancerChooseEndpointStartInfo struct + Call call + Context *context.Context + type DriverBalancerCloseDoneInfo struct + Error error + type DriverBalancerCloseStartInfo struct + Call call + Context *context.Context + type DriverBalancerClusterDiscoveryAttemptDoneInfo struct + Error error + type DriverBalancerClusterDiscoveryAttemptStartInfo struct + Address string + Call call + Context *context.Context + type DriverBalancerDialEntrypointDoneInfo struct + Error error + type DriverBalancerDialEntrypointStartInfo struct + Address string + Call call + Context *context.Context + type DriverBalancerInitDoneInfo struct + Error error + type DriverBalancerInitStartInfo struct + Call call + Context *context.Context + Name string + type DriverBalancerUpdateDoneInfo struct + Added []EndpointInfo + Dropped []EndpointInfo + Endpoints []EndpointInfo + LocalDC string + type DriverBalancerUpdateStartInfo struct + Call call + Context *context.Context + NeedLocalDC bool + type DriverCloseDoneInfo struct + Error error + type DriverCloseStartInfo struct + Call call + Context *context.Context + type DriverComposeOption func(o *driverComposeOptions) + func WithDriverPanicCallback(cb func(e interface{})) DriverComposeOption + type DriverConnAllowDoneInfo struct + State ConnState + type DriverConnAllowStartInfo struct + Call call + Context *context.Context + Endpoint EndpointInfo + State ConnState + type DriverConnBanDoneInfo struct + State ConnState + type DriverConnBanStartInfo struct + Call call + Cause error + Context *context.Context + Endpoint EndpointInfo + State ConnState + type DriverConnCloseDoneInfo struct + Error error + type DriverConnCloseStartInfo struct + Call call + Context *context.Context + Endpoint EndpointInfo + type DriverConnDialDoneInfo struct + Error error + type DriverConnDialStartInfo struct + Call call + Context *context.Context + Endpoint EndpointInfo + type DriverConnInvokeDoneInfo struct + Error error + Issues []Issue + Metadata map[string][]string + OpID string + State ConnState + type DriverConnInvokeStartInfo struct + Call call + Context *context.Context + Endpoint EndpointInfo + Method Method + type DriverConnNewStreamDoneInfo struct + Error error + State ConnState + type DriverConnNewStreamStartInfo struct + Call call + Context *context.Context + Endpoint EndpointInfo + Method Method + type DriverConnParkDoneInfo struct + Error error + type DriverConnParkStartInfo struct + Call call + Context *context.Context + Endpoint EndpointInfo + type DriverConnPoolNewDoneInfo struct + type DriverConnPoolNewStartInfo struct + Call call + Context *context.Context + type DriverConnPoolReleaseDoneInfo struct + Error error + type DriverConnPoolReleaseStartInfo struct + Call call + Context *context.Context + type DriverConnStateChangeDoneInfo struct + State ConnState + type DriverConnStateChangeStartInfo struct + Call call + Context *context.Context + Endpoint EndpointInfo + State ConnState + type DriverConnStreamCloseSendDoneInfo struct + Error error + type DriverConnStreamCloseSendStartInfo struct + Call call + Context *context.Context + type DriverConnStreamFinishInfo struct + Call call + Context context.Context + Error error + type DriverConnStreamRecvMsgDoneInfo struct + Error error + type DriverConnStreamRecvMsgStartInfo struct + Call call + Context *context.Context + type DriverConnStreamSendMsgDoneInfo struct + Error error + type DriverConnStreamSendMsgStartInfo struct + Call call + Context *context.Context + type DriverConnTakeDoneInfo struct + Error error + type DriverConnTakeStartInfo struct + Call call + Context *context.Context + Endpoint EndpointInfo + type DriverGetCredentialsDoneInfo struct + Error error + Token string + type DriverGetCredentialsStartInfo struct + Call call + Context *context.Context + type DriverInitDoneInfo struct + Error error + type DriverInitStartInfo struct + Call call + Context *context.Context + Database string + Endpoint string + Secure bool + type DriverNetCloseDoneInfo struct + Error error + type DriverNetCloseStartInfo struct + Address string + Call call + type DriverNetDialDoneInfo struct + Error error + type DriverNetDialStartInfo struct + Address string + Call call + Context *context.Context + type DriverNetReadDoneInfo struct + Error error + Received int + type DriverNetReadStartInfo struct + Address string + Buffer int + Call call + type DriverNetWriteDoneInfo struct + Error error + Sent int + type DriverNetWriteStartInfo struct + Address string + Bytes int + Call call + type DriverRepeaterWakeUpDoneInfo struct + Error error + type DriverRepeaterWakeUpStartInfo struct + Call call + Context *context.Context + Event string + Name string + type DriverResolveDoneInfo struct + Error error + type DriverResolveStartInfo struct + Call call + Resolved []string + Target string + type DriverWithDoneInfo struct + Error error + type DriverWithStartInfo struct + Call call + Context *context.Context + Database string + Endpoint string + Secure bool + type EndpointInfo interface + Address func() string + LastUpdated func() time.Time + LoadFactor func() float32 + LocalDC func() bool + Location func() string + NodeID func() uint32 + type Issue interface + GetIssueCode func() uint32 + GetMessage func() string + GetSeverity func() uint32 + type Method string + func (m Method) Name() (s string) + func (m Method) Service() (s string) + func (m Method) Split() (service, method string) + type OnReadStreamUpdateTokenDoneInfo struct + Error error + type OnReadUnknownGrpcMessageInfo struct + Error error + ReaderConnectionID string + type OnReadUpdateTokenMiddleTokenReceivedInfo struct + Error error + TokenLen int + type OnReadUpdateTokenStartInfo struct + ReaderConnectionID string + type Query struct + OnClose func(QueryCloseStartInfo) func(info QueryCloseDoneInfo) + OnDo func(QueryDoStartInfo) func(QueryDoDoneInfo) + OnDoTx func(QueryDoTxStartInfo) func(QueryDoTxDoneInfo) + OnExec func(QueryExecStartInfo) func(QueryExecDoneInfo) + OnNew func(QueryNewStartInfo) func(info QueryNewDoneInfo) + OnPoolChange func(QueryPoolChange) + OnPoolClose func(QueryPoolCloseStartInfo) func(QueryPoolCloseDoneInfo) + OnPoolGet func(QueryPoolGetStartInfo) func(QueryPoolGetDoneInfo) + OnPoolNew func(QueryPoolNewStartInfo) func(QueryPoolNewDoneInfo) + OnPoolPut func(QueryPoolPutStartInfo) func(QueryPoolPutDoneInfo) + OnPoolTry func(QueryPoolTryStartInfo) func(QueryPoolTryDoneInfo) + OnPoolWith func(QueryPoolWithStartInfo) func(QueryPoolWithDoneInfo) + OnQuery func(QueryQueryStartInfo) func(QueryQueryDoneInfo) + OnQueryResultSet func(QueryQueryResultSetStartInfo) func(QueryQueryResultSetDoneInfo) + OnQueryRow func(QueryQueryRowStartInfo) func(QueryQueryRowDoneInfo) + OnResultClose func(QueryResultCloseStartInfo) func(info QueryResultCloseDoneInfo) + OnResultNew func(QueryResultNewStartInfo) func(info QueryResultNewDoneInfo) + OnResultNextPart func(QueryResultNextPartStartInfo) func(info QueryResultNextPartDoneInfo) + OnResultNextResultSet func(QueryResultNextResultSetStartInfo) func(info QueryResultNextResultSetDoneInfo) + OnSessionAttach func(QuerySessionAttachStartInfo) func(info QuerySessionAttachDoneInfo) + OnSessionBegin func(QuerySessionBeginStartInfo) func(info QuerySessionBeginDoneInfo) + OnSessionCreate func(QuerySessionCreateStartInfo) func(info QuerySessionCreateDoneInfo) + OnSessionDelete func(QuerySessionDeleteStartInfo) func(info QuerySessionDeleteDoneInfo) + OnSessionExec func(QuerySessionExecStartInfo) func(info QuerySessionExecDoneInfo) + OnSessionQuery func(QuerySessionQueryStartInfo) func(info QuerySessionQueryDoneInfo) + OnSessionQueryResultSet func(QuerySessionQueryResultSetStartInfo) func(QuerySessionQueryResultSetDoneInfo) + OnSessionQueryRow func(QuerySessionQueryRowStartInfo) func(QuerySessionQueryRowDoneInfo) + OnTxExec func(QueryTxExecStartInfo) func(info QueryTxExecDoneInfo) + OnTxQuery func(QueryTxQueryStartInfo) func(info QueryTxQueryDoneInfo) + OnTxQueryResultSet func(QueryTxQueryResultSetStartInfo) func(QueryTxQueryResultSetDoneInfo) + OnTxQueryRow func(QueryTxQueryRowStartInfo) func(QueryTxQueryRowDoneInfo) + func (t *Query) Compose(x *Query, opts ...QueryComposeOption) *Query + type QueryCloseDoneInfo struct + Error error + type QueryCloseStartInfo struct + Call call + Context *context.Context + type QueryComposeOption func(o *queryComposeOptions) + func WithQueryPanicCallback(cb func(e interface{})) QueryComposeOption + type QueryDoDoneInfo struct + Attempts int + Error error + type QueryDoStartInfo struct + Call call + Context *context.Context + type QueryDoTxDoneInfo struct + Attempts int + Error error + type QueryDoTxStartInfo struct + Call call + Context *context.Context + type QueryExecDoneInfo struct + Error error + type QueryExecStartInfo struct + Call call + Context *context.Context + Query string + type QueryNewDoneInfo struct + type QueryNewStartInfo struct + Call call + Context *context.Context + type QueryPoolChange struct + CreateInProgress int + Idle int + Index int + Limit int + Wait int + type QueryPoolCloseDoneInfo struct + Error error + type QueryPoolCloseStartInfo struct + Call call + Context *context.Context + type QueryPoolGetDoneInfo struct + Attempts int + Error error + Session sessionInfo + type QueryPoolGetStartInfo struct + Call call + Context *context.Context + type QueryPoolNewDoneInfo struct + Limit int + type QueryPoolNewStartInfo struct + Call call + Context *context.Context + type QueryPoolPutDoneInfo struct + Error error + type QueryPoolPutStartInfo struct + Call call + Context *context.Context + Session sessionInfo + type QueryPoolTryDoneInfo struct + Error error + type QueryPoolTryStartInfo struct + Call call + Context *context.Context + type QueryPoolWithDoneInfo struct + Attempts int + Error error + type QueryPoolWithStartInfo struct + Call call + Context *context.Context + type QueryQueryDoneInfo struct + Error error + type QueryQueryResultSetDoneInfo struct + Error error + type QueryQueryResultSetStartInfo struct + Call call + Context *context.Context + Query string + type QueryQueryRowDoneInfo struct + Error error + type QueryQueryRowStartInfo struct + Call call + Context *context.Context + Query string + type QueryQueryStartInfo struct + Call call + Context *context.Context + Query string + type QueryReadResultSetDoneInfo struct + Error error + type QueryReadResultSetStartInfo struct + Call call + Context *context.Context + Query string + type QueryReadRowDoneInfo struct + Error error + type QueryReadRowStartInfo struct + Call call + Context *context.Context + Query string + type QueryResultCloseDoneInfo struct + Error error + type QueryResultCloseStartInfo struct + Call call + Context *context.Context + type QueryResultNewDoneInfo struct + Error error + type QueryResultNewStartInfo struct + Call call + Context *context.Context + type QueryResultNextPartDoneInfo struct + Error error + Stats *Ydb_TableStats.QueryStats + type QueryResultNextPartStartInfo struct + Call call + Context *context.Context + type QueryResultNextResultSetDoneInfo struct + Error error + type QueryResultNextResultSetStartInfo struct + Call call + Context *context.Context + type QuerySessionAttachDoneInfo struct + Error error + type QuerySessionAttachStartInfo struct + Call call + Context *context.Context + Session sessionInfo + type QuerySessionBeginDoneInfo struct + Error error + Tx txInfo + type QuerySessionBeginStartInfo struct + Call call + Context *context.Context + Session sessionInfo + type QuerySessionCreateDoneInfo struct + Error error + Session sessionInfo + type QuerySessionCreateStartInfo struct + Call call + Context *context.Context + type QuerySessionDeleteDoneInfo struct + Error error + type QuerySessionDeleteStartInfo struct + Call call + Context *context.Context + Session sessionInfo + type QuerySessionExecDoneInfo struct + Error error + type QuerySessionExecStartInfo struct + Call call + Context *context.Context + Query string + Session sessionInfo + type QuerySessionQueryDoneInfo struct + Error error + type QuerySessionQueryResultSetDoneInfo struct + Error error + type QuerySessionQueryResultSetStartInfo struct + Call call + Context *context.Context + Query string + Session sessionInfo + type QuerySessionQueryRowDoneInfo struct + Error error + type QuerySessionQueryRowStartInfo struct + Call call + Context *context.Context + Query string + Session sessionInfo + type QuerySessionQueryStartInfo struct + Call call + Context *context.Context + Query string + Session sessionInfo + type QueryTxExecDoneInfo struct + Error error + type QueryTxExecStartInfo struct + Call call + Context *context.Context + Query string + Session sessionInfo + Tx txInfo + type QueryTxQueryDoneInfo struct + Error error + type QueryTxQueryResultSetDoneInfo struct + Error error + type QueryTxQueryResultSetStartInfo struct + Call call + Context *context.Context + Query string + Tx txInfo + type QueryTxQueryRowDoneInfo struct + Error error + type QueryTxQueryRowStartInfo struct + Call call + Context *context.Context + Query string + Tx txInfo + type QueryTxQueryStartInfo struct + Call call + Context *context.Context + Query string + Session sessionInfo + Tx txInfo + type Ratelimiter struct + func (t *Ratelimiter) Compose(x *Ratelimiter, opts ...RatelimiterComposeOption) *Ratelimiter + type RatelimiterComposeOption func(o *ratelimiterComposeOptions) + func WithRatelimiterPanicCallback(cb func(e interface{})) RatelimiterComposeOption + type Retry struct + OnRetry func(RetryLoopStartInfo) func(RetryLoopDoneInfo) + func (t *Retry) Compose(x *Retry, opts ...RetryComposeOption) *Retry + type RetryComposeOption func(o *retryComposeOptions) + func WithRetryPanicCallback(cb func(e interface{})) RetryComposeOption + type RetryLoopDoneInfo struct + Attempts int + Error error + type RetryLoopStartInfo struct + Call call + Context *context.Context + Idempotent bool + Label string + NestedCall bool + type Scheme struct + OnDescribePath func(SchemeDescribePathStartInfo) func(SchemeDescribePathDoneInfo) + OnListDirectory func(SchemeListDirectoryStartInfo) func(SchemeListDirectoryDoneInfo) + OnMakeDirectory func(SchemeMakeDirectoryStartInfo) func(SchemeMakeDirectoryDoneInfo) + OnModifyPermissions func(SchemeModifyPermissionsStartInfo) func(SchemeModifyPermissionsDoneInfo) + OnRemoveDirectory func(SchemeRemoveDirectoryStartInfo) func(SchemeRemoveDirectoryDoneInfo) + func (t *Scheme) Compose(x *Scheme, opts ...SchemeComposeOption) *Scheme + type SchemeComposeOption func(o *schemeComposeOptions) + func WithSchemePanicCallback(cb func(e interface{})) SchemeComposeOption + type SchemeDescribePathDoneInfo struct + EntryType string + Error error + type SchemeDescribePathStartInfo struct + Call call + Context *context.Context + Path string + type SchemeListDirectoryDoneInfo struct + Error error + type SchemeListDirectoryStartInfo struct + Call call + Context *context.Context + type SchemeMakeDirectoryDoneInfo struct + Error error + type SchemeMakeDirectoryStartInfo struct + Call call + Context *context.Context + Path string + type SchemeModifyPermissionsDoneInfo struct + Error error + type SchemeModifyPermissionsStartInfo struct + Call call + Context *context.Context + Path string + type SchemeRemoveDirectoryDoneInfo struct + Error error + type SchemeRemoveDirectoryStartInfo struct + Call call + Context *context.Context + Path string + type Scripting struct + OnClose func(ScriptingCloseStartInfo) func(ScriptingCloseDoneInfo) + OnExecute func(ScriptingExecuteStartInfo) func(ScriptingExecuteDoneInfo) + OnExplain func(ScriptingExplainStartInfo) func(ScriptingExplainDoneInfo) + OnStreamExecute func(ScriptingStreamExecuteStartInfo) ... + func (t *Scripting) Compose(x *Scripting, opts ...ScriptingComposeOption) *Scripting + type ScriptingCloseDoneInfo struct + Error error + type ScriptingCloseStartInfo struct + Call call + Context *context.Context + type ScriptingComposeOption func(o *scriptingComposeOptions) + func WithScriptingPanicCallback(cb func(e interface{})) ScriptingComposeOption + type ScriptingExecuteDoneInfo struct + Error error + Result scriptingResult + type ScriptingExecuteStartInfo struct + Call call + Context *context.Context + Parameters scriptingQueryParameters + Query string + type ScriptingExplainDoneInfo struct + Error error + Plan string + type ScriptingExplainStartInfo struct + Call call + Context *context.Context + Query string + type ScriptingStreamExecuteDoneInfo struct + Error error + type ScriptingStreamExecuteIntermediateInfo struct + Error error + type ScriptingStreamExecuteStartInfo struct + Call call + Context *context.Context + Parameters scriptingQueryParameters + Query string + type Table struct + OnClose func(TableCloseStartInfo) func(TableCloseDoneInfo) + OnCreateSession func(TableCreateSessionStartInfo) func(TableCreateSessionDoneInfo) + OnDo func(TableDoStartInfo) func(TableDoDoneInfo) + OnDoTx func(TableDoTxStartInfo) func(TableDoTxDoneInfo) + OnInit func(TableInitStartInfo) func(TableInitDoneInfo) + OnPoolGet func(TablePoolGetStartInfo) func(TablePoolGetDoneInfo) + OnPoolPut func(TablePoolPutStartInfo) func(TablePoolPutDoneInfo) + OnPoolSessionAdd func(info TablePoolSessionAddInfo) + OnPoolSessionRemove func(info TablePoolSessionRemoveInfo) + OnPoolStateChange func(TablePoolStateChangeInfo) + OnPoolWait func(TablePoolWaitStartInfo) func(TablePoolWaitDoneInfo) + OnPoolWith func(TablePoolWithStartInfo) func(TablePoolWithDoneInfo) + OnSessionBulkUpsert func(TableBulkUpsertStartInfo) func(TableBulkUpsertDoneInfo) + OnSessionDelete func(TableSessionDeleteStartInfo) func(TableSessionDeleteDoneInfo) + OnSessionKeepAlive func(TableKeepAliveStartInfo) func(TableKeepAliveDoneInfo) + OnSessionNew func(TableSessionNewStartInfo) func(TableSessionNewDoneInfo) + OnSessionQueryExecute func(TableExecuteDataQueryStartInfo) func(TableExecuteDataQueryDoneInfo) + OnSessionQueryExplain func(TableExplainQueryStartInfo) func(TableExplainQueryDoneInfo) + OnSessionQueryPrepare func(TablePrepareDataQueryStartInfo) func(TablePrepareDataQueryDoneInfo) + OnSessionQueryStreamExecute func(TableSessionQueryStreamExecuteStartInfo) func(TableSessionQueryStreamExecuteDoneInfo) + OnSessionQueryStreamRead func(TableSessionQueryStreamReadStartInfo) func(TableSessionQueryStreamReadDoneInfo) + OnTxBegin func(TableTxBeginStartInfo) func(TableTxBeginDoneInfo) + OnTxCommit func(TableTxCommitStartInfo) func(TableTxCommitDoneInfo) + OnTxExecute func(TableTransactionExecuteStartInfo) func(TableTransactionExecuteDoneInfo) + OnTxExecuteStatement func(TableTransactionExecuteStatementStartInfo) func(TableTransactionExecuteStatementDoneInfo) + OnTxRollback func(TableTxRollbackStartInfo) func(TableTxRollbackDoneInfo) + func (t *Table) Compose(x *Table, opts ...TableComposeOption) *Table + type TableBulkUpsertDoneInfo struct + Error error + type TableBulkUpsertStartInfo struct + Call call + Context *context.Context + Session sessionInfo + type TableCloseDoneInfo struct + Error error + type TableCloseStartInfo struct + Call call + Context *context.Context + type TableComposeOption func(o *tableComposeOptions) + func WithTablePanicCallback(cb func(e interface{})) TableComposeOption + type TableCreateSessionDoneInfo struct + Attempts int + Error error + Session sessionInfo + type TableCreateSessionStartInfo struct + Call call + Context *context.Context + type TableDoDoneInfo struct + Attempts int + Error error + type TableDoStartInfo struct + Call call + Context *context.Context + Idempotent bool + Label string + NestedCall bool + type TableDoTxDoneInfo struct + Attempts int + Error error + type TableDoTxStartInfo struct + Call call + Context *context.Context + Idempotent bool + Label string + NestedCall bool + type TableExecuteDataQueryDoneInfo struct + Error error + Prepared bool + Result tableResult + Tx txInfo + type TableExecuteDataQueryStartInfo struct + Call call + Context *context.Context + KeepInCache bool + Parameters tableQueryParameters + Query tableDataQuery + Session sessionInfo + type TableExplainQueryDoneInfo struct + AST string + Error error + Plan string + type TableExplainQueryStartInfo struct + Call call + Context *context.Context + Query string + Session sessionInfo + type TableInitDoneInfo struct + Limit int + type TableInitStartInfo struct + Call call + Context *context.Context + type TableKeepAliveDoneInfo struct + Error error + type TableKeepAliveStartInfo struct + Call call + Context *context.Context + Session sessionInfo + type TablePoolGetDoneInfo struct + Attempts int + Error error + Session sessionInfo + type TablePoolGetStartInfo struct + Call call + Context *context.Context + type TablePoolPutDoneInfo struct + Error error + type TablePoolPutStartInfo struct + Call call + Context *context.Context + Session sessionInfo + type TablePoolSessionAddInfo struct + Session sessionInfo + type TablePoolSessionCloseDoneInfo struct + type TablePoolSessionCloseStartInfo struct + Call call + Context *context.Context + Session sessionInfo + type TablePoolSessionNewDoneInfo struct + Error error + Session sessionInfo + type TablePoolSessionNewStartInfo struct + Call call + Context *context.Context + type TablePoolSessionRemoveInfo struct + Session sessionInfo + type TablePoolStateChangeInfo struct + CreateInProgress int + Idle int + Index int + Limit int + Size int + Wait int + type TablePoolWaitDoneInfo struct + Error error + Session sessionInfo + type TablePoolWaitStartInfo struct + Call call + Context *context.Context + type TablePoolWithDoneInfo struct + Attempts int + Error error + type TablePoolWithStartInfo struct + Call call + Context *context.Context + type TablePrepareDataQueryDoneInfo struct + Error error + Result tableDataQuery + type TablePrepareDataQueryStartInfo struct + Call call + Context *context.Context + Query string + Session sessionInfo + type TableSessionDeleteDoneInfo struct + Error error + type TableSessionDeleteStartInfo struct + Call call + Context *context.Context + Session sessionInfo + type TableSessionNewDoneInfo struct + Error error + Session sessionInfo + type TableSessionNewStartInfo struct + Call call + Context *context.Context + type TableSessionQueryStreamExecuteDoneInfo struct + Error error + type TableSessionQueryStreamExecuteStartInfo struct + Call call + Context *context.Context + Parameters tableQueryParameters + Query tableDataQuery + Session sessionInfo + type TableSessionQueryStreamReadDoneInfo struct + Error error + type TableSessionQueryStreamReadStartInfo struct + Call call + Context *context.Context + Session sessionInfo + type TableTransactionExecuteDoneInfo struct + Error error + Result tableResult + type TableTransactionExecuteStartInfo struct + Call call + Context *context.Context + Parameters tableQueryParameters + Query tableDataQuery + Session sessionInfo + Tx txInfo + type TableTransactionExecuteStatementDoneInfo struct + Error error + Result tableResult + type TableTransactionExecuteStatementStartInfo struct + Call call + Context *context.Context + Parameters tableQueryParameters + Session sessionInfo + StatementQuery tableDataQuery + Tx txInfo + type TableTxBeginDoneInfo struct + Error error + Tx txInfo + type TableTxBeginStartInfo struct + Call call + Context *context.Context + Session sessionInfo + type TableTxCommitDoneInfo struct + Error error + type TableTxCommitStartInfo struct + Call call + Context *context.Context + Session sessionInfo + Tx txInfo + type TableTxRollbackDoneInfo struct + Error error + type TableTxRollbackStartInfo struct + Call call + Context *context.Context + Session sessionInfo + Tx txInfo + type Topic struct + OnReaderClose func(TopicReaderCloseStartInfo) func(TopicReaderCloseDoneInfo) + OnReaderCommit func(TopicReaderCommitStartInfo) func(TopicReaderCommitDoneInfo) + OnReaderCommittedNotify func(TopicReaderCommittedNotifyInfo) + OnReaderError func(TopicReaderErrorInfo) + OnReaderInit func(TopicReaderInitStartInfo) func(TopicReaderInitDoneInfo) + OnReaderPartitionReadStartResponse func(TopicReaderPartitionReadStartResponseStartInfo) func(TopicReaderPartitionReadStartResponseDoneInfo) + OnReaderPartitionReadStopResponse func(TopicReaderPartitionReadStopResponseStartInfo) func(TopicReaderPartitionReadStopResponseDoneInfo) + OnReaderPopBatchTx func(TopicReaderPopBatchTxStartInfo) func(TopicReaderPopBatchTxDoneInfo) + OnReaderReadMessages func(TopicReaderReadMessagesStartInfo) func(TopicReaderReadMessagesDoneInfo) + OnReaderReceiveDataResponse func(TopicReaderReceiveDataResponseStartInfo) func(TopicReaderReceiveDataResponseDoneInfo) + OnReaderReconnect func(TopicReaderReconnectStartInfo) func(TopicReaderReconnectDoneInfo) + OnReaderReconnectRequest func(TopicReaderReconnectRequestInfo) + OnReaderSendCommitMessage func(TopicReaderSendCommitMessageStartInfo) func(TopicReaderSendCommitMessageDoneInfo) + OnReaderSentDataRequest func(TopicReaderSentDataRequestInfo) + OnReaderStart func(info TopicReaderStartInfo) + OnReaderStreamPopBatchTx func(TopicReaderStreamPopBatchTxStartInfo) func(TopicReaderStreamPopBatchTxDoneInfo) + OnReaderTransactionCompleted func(TopicReaderTransactionCompletedStartInfo) func(TopicReaderTransactionCompletedDoneInfo) + OnReaderTransactionRollback func(TopicReaderTransactionRollbackStartInfo) func(TopicReaderTransactionRollbackDoneInfo) + OnReaderUnknownGrpcMessage func(OnReadUnknownGrpcMessageInfo) + OnReaderUpdateOffsetsInTransaction func(TopicReaderOnUpdateOffsetsInTransactionStartInfo) func(TopicReaderOnUpdateOffsetsInTransactionDoneInfo) + OnReaderUpdateToken func(OnReadUpdateTokenStartInfo) ... + OnWriterAfterFinishTransaction func(TopicOnWriterAfterFinishTransactionStartInfo) func(TopicOnWriterAfterFinishTransactionDoneInfo) + OnWriterBeforeCommitTransaction func(TopicOnWriterBeforeCommitTransactionStartInfo) func(TopicOnWriterBeforeCommitTransactionDoneInfo) + OnWriterClose func(TopicWriterCloseStartInfo) func(TopicWriterCloseDoneInfo) + OnWriterCompressMessages func(TopicWriterCompressMessagesStartInfo) func(TopicWriterCompressMessagesDoneInfo) + OnWriterInitStream func(TopicWriterInitStreamStartInfo) func(TopicWriterInitStreamDoneInfo) + OnWriterReadUnknownGrpcMessage func(TopicOnWriterReadUnknownGrpcMessageInfo) + OnWriterReceiveResult func(TopicWriterResultMessagesInfo) + OnWriterReconnect func(TopicWriterReconnectStartInfo) func(TopicWriterReconnectDoneInfo) + OnWriterSendMessages func(TopicWriterSendMessagesStartInfo) func(TopicWriterSendMessagesDoneInfo) + func (t *Topic) Compose(x *Topic, opts ...TopicComposeOption) *Topic + type TopicComposeOption func(o *topicComposeOptions) + func WithTopicPanicCallback(cb func(e interface{})) TopicComposeOption + type TopicOnWriterAfterFinishTransactionDoneInfo struct + CloseError error + type TopicOnWriterAfterFinishTransactionStartInfo struct + Error error + SessionID string + TransactionID string + type TopicOnWriterBeforeCommitTransactionDoneInfo struct + Error error + TopicSessionID string + type TopicOnWriterBeforeCommitTransactionStartInfo struct + Ctx *context.Context + KqpSessionID string + TopicSessionID string + TransactionID string + type TopicOnWriterReadUnknownGrpcMessageInfo struct + Error error + SessionID string + WriterInstanceID string + type TopicReadStreamInitRequestInfo interface + GetConsumer func() string + GetTopics func() []string + type TopicReaderCloseDoneInfo struct + CloseError error + type TopicReaderCloseStartInfo struct + CloseReason error + ReaderConnectionID string + type TopicReaderCommitDoneInfo struct + Error error + type TopicReaderCommitStartInfo struct + EndOffset int64 + PartitionID int64 + PartitionSessionID int64 + RequestContext *context.Context + StartOffset int64 + Topic string + type TopicReaderCommittedNotifyInfo struct + CommittedOffset int64 + PartitionID int64 + PartitionSessionID int64 + ReaderConnectionID string + Topic string + type TopicReaderDataResponseInfo interface + GetBytesSize func() int + GetPartitionBatchMessagesCounts func() (partitionCount, batchCount, messagesCount int) + type TopicReaderErrorInfo struct + Error error + ReaderConnectionID string + type TopicReaderInitDoneInfo struct + Error error + ReaderConnectionID string + type TopicReaderInitStartInfo struct + InitRequestInfo TopicReadStreamInitRequestInfo + PreInitReaderConnectionID string + type TopicReaderOnUpdateOffsetsInTransactionDoneInfo struct + Error error + type TopicReaderOnUpdateOffsetsInTransactionStartInfo struct + Context *context.Context + ReaderConnectionID string + ReaderID int64 + TransactionSessionID string + Tx txInfo + type TopicReaderPartitionReadStartResponseDoneInfo struct + CommitOffset *int64 + Error error + ReadOffset *int64 + type TopicReaderPartitionReadStartResponseStartInfo struct + PartitionContext *context.Context + PartitionID int64 + PartitionSessionID int64 + ReaderConnectionID string + Topic string + type TopicReaderPartitionReadStopResponseDoneInfo struct + Error error + type TopicReaderPartitionReadStopResponseStartInfo struct + CommittedOffset int64 + Graceful bool + PartitionContext context.Context + PartitionID int64 + PartitionSessionID int64 + ReaderConnectionID string + Topic string + type TopicReaderPopBatchTxDoneInfo struct + EndOffset int64 + Error error + MessagesCount int + StartOffset int64 + type TopicReaderPopBatchTxStartInfo struct + Context *context.Context + ReaderID int64 + TransactionSessionID string + Tx txInfo + type TopicReaderReadMessagesDoneInfo struct + Error error + FreeBufferCapacity int + MessagesCount int + OffsetEnd int64 + OffsetStart int64 + PartitionID int64 + PartitionSessionID int64 + Topic string + type TopicReaderReadMessagesStartInfo struct + FreeBufferCapacity int + MaxCount int + MinCount int + RequestContext *context.Context + type TopicReaderReceiveDataResponseDoneInfo struct + Error error + type TopicReaderReceiveDataResponseStartInfo struct + DataResponse TopicReaderDataResponseInfo + LocalBufferSizeAfterReceive int + ReaderConnectionID string + type TopicReaderReconnectDoneInfo struct + Error error + type TopicReaderReconnectRequestInfo struct + Reason error + WasSent bool + type TopicReaderReconnectStartInfo struct + Reason error + type TopicReaderSendCommitMessageDoneInfo struct + Error error + type TopicReaderSendCommitMessageStartInfo struct + CommitsInfo TopicReaderStreamSendCommitMessageStartMessageInfo + type TopicReaderSentDataRequestInfo struct + LocalBufferSizeAfterSent int + ReaderConnectionID string + RequestBytes int + type TopicReaderStartInfo struct + Consumer string + Error error + ReaderID int64 + type TopicReaderStreamCommitInfo struct + EndOffset int64 + PartitionID int64 + PartitionSessionID int64 + StartOffset int64 + Topic string + type TopicReaderStreamPopBatchTxDoneInfo struct + Error error + type TopicReaderStreamPopBatchTxStartInfo struct + Context *context.Context + ReaderConnectionID string + ReaderID int64 + TransactionSessionID string + Tx txInfo + type TopicReaderStreamSendCommitMessageStartMessageInfo interface + GetCommitsInfo func() []TopicReaderStreamCommitInfo + type TopicReaderTransactionCompletedDoneInfo struct + type TopicReaderTransactionCompletedStartInfo struct + Context *context.Context + ReaderConnectionID string + ReaderID int64 + TransactionResult error + TransactionSessionID string + Tx txInfo + type TopicReaderTransactionRollbackDoneInfo struct + RollbackError error + type TopicReaderTransactionRollbackStartInfo struct + Context *context.Context + ReaderConnectionID string + ReaderID int64 + TransactionSessionID string + Tx txInfo + type TopicWriterCloseDoneInfo struct + Error error + type TopicWriterCloseStartInfo struct + Reason error + WriterInstanceID string + type TopicWriterCompressMessagesDoneInfo struct + Error error + type TopicWriterCompressMessagesReason string + func (r TopicWriterCompressMessagesReason) String() string + type TopicWriterCompressMessagesStartInfo struct + Codec int32 + FirstSeqNo int64 + MessagesCount int + Reason TopicWriterCompressMessagesReason + SessionID string + WriterInstanceID string + type TopicWriterInitStreamDoneInfo struct + Error error + SessionID string + type TopicWriterInitStreamStartInfo struct + ProducerID string + Topic string + WriterInstanceID string + type TopicWriterReconnectDoneInfo struct + Error error + type TopicWriterReconnectStartInfo struct + Attempt int + ProducerID string + Topic string + WriterInstanceID string + type TopicWriterResultMessagesInfo struct + Acks TopicWriterResultMessagesInfoAcks + PartitionID int64 + SessionID string + WriterInstanceID string + type TopicWriterResultMessagesInfoAcks interface + GetAcks func() struct{ ... } + type TopicWriterSendMessagesDoneInfo struct + Error error + type TopicWriterSendMessagesStartInfo struct + Codec int32 + FirstSeqNo int64 + MessagesCount int + SessionID string + WriterInstanceID string
Go to main page