trace

package
v3.57.1 Latest Latest
Warning

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

 Go to latest Published: Mar 11, 2024 License: Apache-2.0 Imports: 7 Imported by: 19

Documentation

Index

Constants

View Source 
const (
	TopicWriterCompressMessagesReasonCompressData                = TopicWriterCompressMessagesReason("compress-on-send")           //nolint:lll
	TopicWriterCompressMessagesReasonCompressDataOnWriteReadData = TopicWriterCompressMessagesReason("compress-on-call-write")     //nolint:lll
	TopicWriterCompressMessagesReasonCodecsMeasure               = TopicWriterCompressMessagesReason("compress-on-codecs-measure") //nolint:lll
)

Variables

This section is empty.

Functions

func ClearContext 

func ClearContext(x interface{}) interface{}

func DatabaseSQLOnConnBegin added in v3.34.0 

func DatabaseSQLOnConnBegin(t *DatabaseSQL, c *context.Context, call call) func(tx tableTransactionInfo, _ error)

func DatabaseSQLOnConnClose added in v3.34.0 

func DatabaseSQLOnConnClose(t *DatabaseSQL, c *context.Context, call call) func(error)

func DatabaseSQLOnConnExec added in v3.34.0 

func DatabaseSQLOnConnExec(t *DatabaseSQL, c *context.Context, call call, query string, mode string, idempotent bool, idleTime time.Duration) func(error)

func DatabaseSQLOnConnIsTableExists added in v3.54.2 

func DatabaseSQLOnConnIsTableExists(t *DatabaseSQL, c *context.Context, call call, tableName string) func(exists bool, _ error)

func DatabaseSQLOnConnPing added in v3.34.0 

func DatabaseSQLOnConnPing(t *DatabaseSQL, c *context.Context, call call) func(error)

func DatabaseSQLOnConnPrepare added in v3.34.0 

func DatabaseSQLOnConnPrepare(t *DatabaseSQL, c *context.Context, call call, query string) func(error)

func DatabaseSQLOnConnQuery added in v3.34.0 

func DatabaseSQLOnConnQuery(t *DatabaseSQL, c *context.Context, call call, query string, mode string, idempotent bool, idleTime time.Duration) func(error)

func DatabaseSQLOnConnectorConnect added in v3.34.0 

func DatabaseSQLOnConnectorConnect(t *DatabaseSQL, c *context.Context, call call) func(_ error, session tableSessionInfo)

func DatabaseSQLOnDoTx added in v3.34.0 

func DatabaseSQLOnDoTx(t *DatabaseSQL, c *context.Context, call call, iD string, idempotent bool) func(error) func(attempts int, _ error)

func DatabaseSQLOnStmtClose added in v3.34.0 

func DatabaseSQLOnStmtClose(t *DatabaseSQL, stmtContext *context.Context, call call) func(error)

func DatabaseSQLOnStmtExec added in v3.34.0 

func DatabaseSQLOnStmtExec(t *DatabaseSQL, c *context.Context, call call, stmtContext context.Context, query string) func(error)

func DatabaseSQLOnStmtQuery added in v3.34.0 

func DatabaseSQLOnStmtQuery(t *DatabaseSQL, c *context.Context, call call, stmtContext context.Context, query string) func(error)

func DatabaseSQLOnTxCommit added in v3.34.0 

func DatabaseSQLOnTxCommit(t *DatabaseSQL, c *context.Context, call call, tx tableTransactionInfo) func(error)

func DatabaseSQLOnTxExec added in v3.34.2 

func DatabaseSQLOnTxExec(t *DatabaseSQL, c *context.Context, call call, txContext context.Context, tx tableTransactionInfo, query string, idempotent bool) func(error)

func DatabaseSQLOnTxPrepare added in v3.54.2 

func DatabaseSQLOnTxPrepare(t *DatabaseSQL, c *context.Context, call call, txContext *context.Context, tx tableTransactionInfo, query string) func(error)

func DatabaseSQLOnTxQuery added in v3.34.2 

func DatabaseSQLOnTxQuery(t *DatabaseSQL, c *context.Context, call call, txContext context.Context, tx tableTransactionInfo, query string, idempotent bool) func(error)

func DatabaseSQLOnTxRollback added in v3.34.0 

func DatabaseSQLOnTxRollback(t *DatabaseSQL, c *context.Context, call call, tx tableTransactionInfo) func(error)

func DiscoveryOnDiscover added in v3.10.0 

func DiscoveryOnDiscover(t *Discovery, c *context.Context, call call, address string, database string) func(location string, endpoints []EndpointInfo, _ error)

func DiscoveryOnWhoAmI added in v3.10.0 

func DiscoveryOnWhoAmI(t *Discovery, c *context.Context, call call) func(user string, groups []string, _ error)

func DriverOnBalancerChooseEndpoint added in v3.26.0 

func DriverOnBalancerChooseEndpoint(t *Driver, c *context.Context, call call) func(endpoint EndpointInfo, _ error)

func DriverOnBalancerClose added in v3.26.0 

func DriverOnBalancerClose(t *Driver, c *context.Context, call call) func(error)

func DriverOnBalancerClusterDiscoveryAttempt added in v3.42.9 

func DriverOnBalancerClusterDiscoveryAttempt(t *Driver, c *context.Context, call call, address string) func(error)

func DriverOnBalancerDialEntrypoint added in v3.42.9 

func DriverOnBalancerDialEntrypoint(t *Driver, c *context.Context, call call, address string) func(error)

func DriverOnBalancerInit added in v3.26.0 

func DriverOnBalancerInit(t *Driver, c *context.Context, call call, name string) func(error)

func DriverOnBalancerUpdate added in v3.26.0 

func DriverOnBalancerUpdate(t *Driver, c *context.Context, call call, needLocalDC bool) func(endpoints []EndpointInfo, added []EndpointInfo, dropped []EndpointInfo, localDC string, _ error)

func DriverOnClose added in v3.5.0 

func DriverOnClose(t *Driver, c *context.Context, call call) func(error)

func DriverOnConnAllow added in v3.25.1 

func DriverOnConnAllow(t *Driver, c *context.Context, call call, endpoint EndpointInfo, state ConnState) func(state ConnState)

func DriverOnConnBan added in v3.25.1 

func DriverOnConnBan(t *Driver, c *context.Context, call call, endpoint EndpointInfo, state ConnState, cause error) func(state ConnState)

func DriverOnConnClose added in v3.12.1 

func DriverOnConnClose(t *Driver, c *context.Context, call call, endpoint EndpointInfo) func(error)

func DriverOnConnDial added in v3.42.12 

func DriverOnConnDial(t *Driver, c *context.Context, call call, endpoint EndpointInfo) func(error)

func DriverOnConnInvoke 

func DriverOnConnInvoke(t *Driver, c *context.Context, call call, endpoint EndpointInfo, m Method) func(_ error, issues []Issue, opID string, state ConnState, metadata map[string][]string)

func DriverOnConnNewStream 

func DriverOnConnNewStream(t *Driver, c *context.Context, call call, endpoint EndpointInfo, m Method) func(error) func(_ error, state ConnState, metadata map[string][]string)

func DriverOnConnPark added in v3.12.1 

func DriverOnConnPark(t *Driver, c *context.Context, call call, endpoint EndpointInfo) func(error)

func DriverOnConnStateChange 

func DriverOnConnStateChange(t *Driver, c *context.Context, call call, endpoint EndpointInfo, state ConnState) func(state ConnState)

func DriverOnConnTake 

func DriverOnConnTake(t *Driver, c *context.Context, call call, endpoint EndpointInfo) func(error)

func DriverOnGetCredentials 

func DriverOnGetCredentials(t *Driver, c *context.Context, call call) func(token string, _ error)

func DriverOnInit added in v3.5.0 

func DriverOnInit(t *Driver, c *context.Context, call call, endpoint string, database string, secure bool) func(error)

func DriverOnNetClose 

func DriverOnNetClose(t *Driver, call call, address string) func(error)

func DriverOnNetDial 

func DriverOnNetDial(t *Driver, c *context.Context, call call, address string) func(error)

func DriverOnNetRead 

func DriverOnNetRead(t *Driver, call call, address string, buffer int) func(received int, _ error)

func DriverOnNetWrite 

func DriverOnNetWrite(t *Driver, call call, address string, bytes int) func(sent int, _ error)

func DriverOnPoolNew added in v3.54.2 

func DriverOnPoolNew(t *Driver, c *context.Context, call call) func()

func DriverOnPoolRelease added in v3.54.2 

func DriverOnPoolRelease(t *Driver, c *context.Context, call call) func(error)

func DriverOnRepeaterWakeUp added in v3.11.13 

func DriverOnRepeaterWakeUp(t *Driver, c *context.Context, call call, name string, event string) func(error)

func DriverOnResolve added in v3.11.0 

func DriverOnResolve(t *Driver, call call, target string, resolved []string) func(error)

func DriverOnWith added in v3.54.3 

func DriverOnWith(t *Driver, c *context.Context, call call, endpoint string, database string, secure bool) func(error)

func QueryOnDo added in v3.57.0 

func QueryOnDo(t *Query, c *context.Context, call call) func(error) func(attempts int, _ error)

func QueryOnDoTx added in v3.57.0 

func QueryOnDoTx(t *Query, c *context.Context, call call) func(error) func(attempts int, _ error)

func RetryOnRetry 

func RetryOnRetry(t *Retry, c *context.Context, iD string, call call, label string, idempotent bool, nestedCall bool) func(error) func(attempts int, _ error)

func SchemeOnDescribePath added in v3.54.2 

func SchemeOnDescribePath(t *Scheme, c *context.Context, call call, path string) func(entryType string, _ error)

func SchemeOnListDirectory added in v3.54.2 

func SchemeOnListDirectory(t *Scheme, c *context.Context, call call) func(error)

func SchemeOnMakeDirectory added in v3.54.2 

func SchemeOnMakeDirectory(t *Scheme, c *context.Context, call call, path string) func(error)

func SchemeOnModifyPermissions added in v3.54.2 

func SchemeOnModifyPermissions(t *Scheme, c *context.Context, call call, path string) func(error)

func SchemeOnRemoveDirectory added in v3.54.2 

func SchemeOnRemoveDirectory(t *Scheme, c *context.Context, call call, path string) func(error)

func ScriptingOnClose added in v3.13.1 

func ScriptingOnClose(t *Scripting, c *context.Context, call call) func(error)

func ScriptingOnExecute added in v3.10.0 

func ScriptingOnExecute(t *Scripting, c *context.Context, call call, query string, parameters scriptingQueryParameters) func(result scriptingResult, _ error)

func ScriptingOnExplain added in v3.10.0 

func ScriptingOnExplain(t *Scripting, c *context.Context, call call, query string) func(plan string, _ error)

func ScriptingOnStreamExecute added in v3.10.0 

func ScriptingOnStreamExecute(t *Scripting, c *context.Context, call call, query string, parameters scriptingQueryParameters) func(error) func(error)

func Stub 

func Stub(x interface{}, f func(name string, args ...interface{}))

Stub is a helper function that stubs all functional fields of x with given f.

func TableOnClose added in v3.13.1 

func TableOnClose(t *Table, c *context.Context, call call) func(error)

func TableOnCreateSession added in v3.15.0 

func TableOnCreateSession(t *Table, c *context.Context, call call) func(error) func(session tableSessionInfo, attempts int, _ error)

func TableOnDo added in v3.15.0 

func TableOnDo(t *Table, c *context.Context, call call, iD string, label string, idempotent bool, nestedCall bool) func(error) func(attempts int, _ error)

func TableOnDoTx added in v3.15.0 

func TableOnDoTx(t *Table, c *context.Context, call call, iD string, label string, idempotent bool, nestedCall bool) func(error) func(attempts int, _ error)

func TableOnInit added in v3.13.1 

func TableOnInit(t *Table, c *context.Context, call call) func(limit int, _ error)

func TableOnPoolGet 

func TableOnPoolGet(t *Table, c *context.Context, call call) func(session tableSessionInfo, attempts int, _ error)

func TableOnPoolPut 

func TableOnPoolPut(t *Table, c *context.Context, call call, session tableSessionInfo) func(error)

func TableOnPoolSessionAdd added in v3.33.0 

func TableOnPoolSessionAdd(t *Table, session tableSessionInfo)

func TableOnPoolSessionClose 

func TableOnPoolSessionClose(t *Table, c *context.Context, call call, session tableSessionInfo) func()

func TableOnPoolSessionNew 

func TableOnPoolSessionNew(t *Table, c *context.Context, call call) func(session tableSessionInfo, _ error)

func TableOnPoolSessionRemove added in v3.33.0 

func TableOnPoolSessionRemove(t *Table, session tableSessionInfo)

func TableOnPoolStateChange added in v3.11.0 

func TableOnPoolStateChange(t *Table, size int, event string)

func TableOnPoolWait 

func TableOnPoolWait(t *Table, c *context.Context, call call) func(session tableSessionInfo, _ error)

func TableOnSessionBulkUpsert added in v3.54.2 

func TableOnSessionBulkUpsert(t *Table, c *context.Context, call call, session tableSessionInfo) func(error)

func TableOnSessionDelete 

func TableOnSessionDelete(t *Table, c *context.Context, call call, session tableSessionInfo) func(error)

func TableOnSessionKeepAlive 

func TableOnSessionKeepAlive(t *Table, c *context.Context, call call, session tableSessionInfo) func(error)

func TableOnSessionNew 

func TableOnSessionNew(t *Table, c *context.Context, call call) func(session tableSessionInfo, _ error)

func TableOnSessionQueryExecute 

func TableOnSessionQueryExecute(t *Table, c *context.Context, call call, session tableSessionInfo, query tableDataQuery, parameters tableQueryParameters, keepInCache bool) func(tx tableTransactionInfo, prepared bool, result tableResult, _ error)

func TableOnSessionQueryExplain added in v3.10.0 

func TableOnSessionQueryExplain(t *Table, c *context.Context, call call, session tableSessionInfo, query string) func(aST string, plan string, _ error)

func TableOnSessionQueryPrepare 

func TableOnSessionQueryPrepare(t *Table, c *context.Context, call call, session tableSessionInfo, query string) func(result tableDataQuery, _ error)

func TableOnSessionQueryStreamExecute 

func TableOnSessionQueryStreamExecute(t *Table, c *context.Context, call call, session tableSessionInfo, query tableDataQuery, parameters tableQueryParameters) func(error) func(error)

func TableOnSessionQueryStreamRead 

func TableOnSessionQueryStreamRead(t *Table, c *context.Context, call call, session tableSessionInfo) func(error) func(error)

func TableOnSessionTransactionBegin 

func TableOnSessionTransactionBegin(t *Table, c *context.Context, call call, session tableSessionInfo) func(tx tableTransactionInfo, _ error)

func TableOnSessionTransactionCommit 

func TableOnSessionTransactionCommit(t *Table, c *context.Context, call call, session tableSessionInfo, tx tableTransactionInfo) func(error)

func TableOnSessionTransactionExecute added in v3.34.2 

func TableOnSessionTransactionExecute(t *Table, c *context.Context, call call, session tableSessionInfo, tx tableTransactionInfo, query tableDataQuery, parameters tableQueryParameters) func(result tableResult, _ error)

func TableOnSessionTransactionExecuteStatement added in v3.34.2 

func TableOnSessionTransactionExecuteStatement(t *Table, c *context.Context, call call, session tableSessionInfo, tx tableTransactionInfo, statementQuery tableDataQuery, parameters tableQueryParameters) func(result tableResult, _ error)

func TableOnSessionTransactionRollback 

func TableOnSessionTransactionRollback(t *Table, c *context.Context, call call, session tableSessionInfo, tx tableTransactionInfo) func(error)

func TopicOnReaderClose added in v3.32.0 

func TopicOnReaderClose(t *Topic, readerConnectionID string, closeReason error) func(closeError error)

func TopicOnReaderCommit added in v3.32.0 

func TopicOnReaderCommit(t *Topic, requestContext context.Context, topic string, partitionID int64, partitionSessionID int64, startOffset int64, endOffset int64) func(error)

func TopicOnReaderCommittedNotify added in v3.32.0 

func TopicOnReaderCommittedNotify(t *Topic, readerConnectionID string, topic string, partitionID int64, partitionSessionID int64, committedOffset int64)

func TopicOnReaderError added in v3.32.0 

func TopicOnReaderError(t *Topic, readerConnectionID string, e error)

func TopicOnReaderInit added in v3.32.0 

func TopicOnReaderInit(t *Topic, preInitReaderConnectionID string, initRequestInfo TopicReadStreamInitRequestInfo) func(readerConnectionID string, _ error)

func TopicOnReaderPartitionReadStartResponse added in v3.32.0 

func TopicOnReaderPartitionReadStartResponse(t *Topic, readerConnectionID string, partitionContext context.Context, topic string, partitionID int64, partitionSessionID int64) func(readOffset *int64, commitOffset *int64, _ error)

func TopicOnReaderPartitionReadStopResponse added in v3.32.0 

func TopicOnReaderPartitionReadStopResponse(t *Topic, readerConnectionID string, partitionContext context.Context, topic string, partitionID int64, partitionSessionID int64, committedOffset int64, graceful bool) func(error)

func TopicOnReaderReadMessages added in v3.32.0 

func TopicOnReaderReadMessages(t *Topic, requestContext context.Context, minCount int, maxCount int, freeBufferCapacity int) func(messagesCount int, topic string, partitionID int64, partitionSessionID int64, offsetStart int64, offsetEnd int64, freeBufferCapacity int, _ error)

func TopicOnReaderReceiveDataResponse added in v3.32.0 

func TopicOnReaderReceiveDataResponse(t *Topic, readerConnectionID string, localBufferSizeAfterReceive int, dataResponse TopicReaderDataResponseInfo) func(error)

func TopicOnReaderReconnect added in v3.32.0 

func TopicOnReaderReconnect(t *Topic, reason error) func(error)

func TopicOnReaderReconnectRequest added in v3.32.0 

func TopicOnReaderReconnectRequest(t *Topic, reason error, wasSent bool)

func TopicOnReaderSendCommitMessage added in v3.32.0 

func TopicOnReaderSendCommitMessage(t *Topic, commitsInfo TopicReaderStreamSendCommitMessageStartMessageInfo) func(error)

func TopicOnReaderSentDataRequest added in v3.32.0 

func TopicOnReaderSentDataRequest(t *Topic, readerConnectionID string, requestBytes int, localBufferSizeAfterSent int)

func TopicOnReaderStart added in v3.52.0 

func TopicOnReaderStart(t *Topic, readerID int64, consumer string)

func TopicOnReaderUnknownGrpcMessage added in v3.32.0 

func TopicOnReaderUnknownGrpcMessage(t *Topic, readerConnectionID string, e error)

func TopicOnReaderUpdateToken added in v3.32.0 

func TopicOnReaderUpdateToken(t *Topic, readerConnectionID string) func(tokenLen int, _ error) func(error)

func TopicOnWriterClose added in v3.38.0 

func TopicOnWriterClose(t *Topic, writerInstanceID string, reason error) func(error)

func TopicOnWriterCompressMessages added in v3.38.0 

func TopicOnWriterCompressMessages(t *Topic, writerInstanceID string, sessionID string, codec int32, firstSeqNo int64, messagesCount int, reason TopicWriterCompressMessagesReason) func(error)

func TopicOnWriterInitStream added in v3.38.0 

func TopicOnWriterInitStream(t *Topic, writerInstanceID string, topic string, producerID string) func(sessionID string, _ error)

func TopicOnWriterReadUnknownGrpcMessage added in v3.38.0 

func TopicOnWriterReadUnknownGrpcMessage(t *Topic, writerInstanceID string, sessionID string, e error)

func TopicOnWriterReconnect added in v3.38.0 

func TopicOnWriterReconnect(t *Topic, writerInstanceID string, topic string, producerID string, attempt int) func(error)

func TopicOnWriterSendMessages added in v3.38.0 

func TopicOnWriterSendMessages(t *Topic, writerInstanceID string, sessionID string, codec int32, firstSeqNo int64, messagesCount int) func(error)

func WithDefaultDetails added in v3.11.0 

func WithDefaultDetails(defaultDetails Details) matchDetailsOption

func WithPOSIXMatch added in v3.11.0 

func WithPOSIXMatch() matchDetailsOption

Types

type ConnState 

type ConnState interface {
	fmt.Stringer

	IsValid() bool
	Code() int
}

type Coordination added in v3.10.0 

type Coordination struct{}

Coordination specified trace of coordination client activity. gtrace:gen

func (*Coordination) Compose added in v3.10.0 

func (t *Coordination) Compose(x *Coordination, opts ...CoordinationComposeOption) *Coordination

Compose returns a new Coordination which has functional fields composed both from t and x.

type CoordinationComposeOption added in v3.17.0 

type CoordinationComposeOption func(o *coordinationComposeOptions)

CoordinationOption specified Coordination compose option

func WithCoordinationPanicCallback added in v3.17.0 

func WithCoordinationPanicCallback(cb func(e interface{})) CoordinationComposeOption

WithCoordinationPanicCallback specified behavior on panic

type DatabaseSQL added in v3.34.0 

type DatabaseSQL struct {
	OnConnectorConnect func(DatabaseSQLConnectorConnectStartInfo) func(DatabaseSQLConnectorConnectDoneInfo)

	OnConnPing          func(DatabaseSQLConnPingStartInfo) func(DatabaseSQLConnPingDoneInfo)
	OnConnPrepare       func(DatabaseSQLConnPrepareStartInfo) func(DatabaseSQLConnPrepareDoneInfo)
	OnConnClose         func(DatabaseSQLConnCloseStartInfo) func(DatabaseSQLConnCloseDoneInfo)
	OnConnBegin         func(DatabaseSQLConnBeginStartInfo) func(DatabaseSQLConnBeginDoneInfo)
	OnConnQuery         func(DatabaseSQLConnQueryStartInfo) func(DatabaseSQLConnQueryDoneInfo)
	OnConnExec          func(DatabaseSQLConnExecStartInfo) func(DatabaseSQLConnExecDoneInfo)
	OnConnIsTableExists func(DatabaseSQLConnIsTableExistsStartInfo) func(DatabaseSQLConnIsTableExistsDoneInfo)

	OnTxQuery    func(DatabaseSQLTxQueryStartInfo) func(DatabaseSQLTxQueryDoneInfo)
	OnTxExec     func(DatabaseSQLTxExecStartInfo) func(DatabaseSQLTxExecDoneInfo)
	OnTxPrepare  func(DatabaseSQLTxPrepareStartInfo) func(DatabaseSQLTxPrepareDoneInfo)
	OnTxCommit   func(DatabaseSQLTxCommitStartInfo) func(DatabaseSQLTxCommitDoneInfo)
	OnTxRollback func(DatabaseSQLTxRollbackStartInfo) func(DatabaseSQLTxRollbackDoneInfo)

	OnStmtQuery func(DatabaseSQLStmtQueryStartInfo) func(DatabaseSQLStmtQueryDoneInfo)
	OnStmtExec  func(DatabaseSQLStmtExecStartInfo) func(DatabaseSQLStmtExecDoneInfo)
	OnStmtClose func(DatabaseSQLStmtCloseStartInfo) func(DatabaseSQLStmtCloseDoneInfo)

	OnDoTx func(DatabaseSQLDoTxStartInfo) func(DatabaseSQLDoTxIntermediateInfo) func(DatabaseSQLDoTxDoneInfo)
}

DatabaseSQL specified trace of `database/sql` call activity. gtrace:gen

func (*DatabaseSQL) Compose added in v3.34.0 

func (t *DatabaseSQL) Compose(x *DatabaseSQL, opts ...DatabaseSQLComposeOption) *DatabaseSQL

Compose returns a new DatabaseSQL which has functional fields composed both from t and x.

type DatabaseSQLComposeOption added in v3.34.0 

type DatabaseSQLComposeOption func(o *databaseSQLComposeOptions)

DatabaseSQLOption specified DatabaseSQL compose option

func WithDatabaseSQLPanicCallback added in v3.34.0 

func WithDatabaseSQLPanicCallback(cb func(e interface{})) DatabaseSQLComposeOption

WithDatabaseSQLPanicCallback specified behavior on panic

type DatabaseSQLConnBeginDoneInfo added in v3.34.0 

type DatabaseSQLConnBeginDoneInfo struct {
	Tx    tableTransactionInfo
	Error error
}

type DatabaseSQLConnBeginStartInfo added in v3.34.0 

type DatabaseSQLConnBeginStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
}

type DatabaseSQLConnCloseDoneInfo added in v3.34.0 

type DatabaseSQLConnCloseDoneInfo struct {
	Error error
}

type DatabaseSQLConnCloseStartInfo added in v3.34.0 

type DatabaseSQLConnCloseStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
}

type DatabaseSQLConnExecDoneInfo added in v3.34.0 

type DatabaseSQLConnExecDoneInfo struct {
	Error error
}

type DatabaseSQLConnExecStartInfo added in v3.34.0 

type DatabaseSQLConnExecStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context    *context.Context
	Call       call
	Query      string
	Mode       string
	Idempotent bool
	IdleTime   time.Duration
}

type DatabaseSQLConnIsTableExistsDoneInfo added in v3.54.2 

type DatabaseSQLConnIsTableExistsDoneInfo struct {
	Exists bool
	Error  error
}

type DatabaseSQLConnIsTableExistsStartInfo added in v3.54.2 

type DatabaseSQLConnIsTableExistsStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context   *context.Context
	Call      call
	TableName string
}

type DatabaseSQLConnPingDoneInfo added in v3.34.0 

type DatabaseSQLConnPingDoneInfo struct {
	Error error
}

type DatabaseSQLConnPingStartInfo added in v3.34.0 

type DatabaseSQLConnPingStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
}

type DatabaseSQLConnPrepareDoneInfo added in v3.34.0 

type DatabaseSQLConnPrepareDoneInfo struct {
	Error error
}

type DatabaseSQLConnPrepareStartInfo added in v3.34.0 

type DatabaseSQLConnPrepareStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
	Query   string
}

type DatabaseSQLConnQueryDoneInfo added in v3.34.0 

type DatabaseSQLConnQueryDoneInfo struct {
	Error error
}

type DatabaseSQLConnQueryStartInfo added in v3.34.0 

type DatabaseSQLConnQueryStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context    *context.Context
	Call       call
	Query      string
	Mode       string
	Idempotent bool
	IdleTime   time.Duration
}

type DatabaseSQLConnectorConnectDoneInfo added in v3.34.0 

type DatabaseSQLConnectorConnectDoneInfo struct {
	Error   error
	Session tableSessionInfo
}

type DatabaseSQLConnectorConnectStartInfo added in v3.34.0 

type DatabaseSQLConnectorConnectStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
}

type DatabaseSQLDoTxDoneInfo added in v3.34.0 

type DatabaseSQLDoTxDoneInfo struct {
	Attempts int
	Error    error
}

type DatabaseSQLDoTxIntermediateInfo added in v3.34.0 

type DatabaseSQLDoTxIntermediateInfo struct {
	Error error
}

type DatabaseSQLDoTxStartInfo added in v3.34.0 

type DatabaseSQLDoTxStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context    *context.Context
	Call       call
	ID         string
	Idempotent bool
}

type DatabaseSQLStmtCloseDoneInfo added in v3.34.0 

type DatabaseSQLStmtCloseDoneInfo struct {
	Error error
}

type DatabaseSQLStmtCloseStartInfo added in v3.34.0 

type DatabaseSQLStmtCloseStartInfo struct {
	StmtContext *context.Context
	Call        call
}

type DatabaseSQLStmtExecDoneInfo added in v3.34.0 

type DatabaseSQLStmtExecDoneInfo struct {
	Error error
}

type DatabaseSQLStmtExecStartInfo added in v3.34.0 

type DatabaseSQLStmtExecStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context     *context.Context
	Call        call
	StmtContext context.Context
	Query       string
}

type DatabaseSQLStmtQueryDoneInfo added in v3.34.0 

type DatabaseSQLStmtQueryDoneInfo struct {
	Error error
}

type DatabaseSQLStmtQueryStartInfo added in v3.34.0 

type DatabaseSQLStmtQueryStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context     *context.Context
	Call        call
	StmtContext context.Context
	Query       string
}

type DatabaseSQLTxCommitDoneInfo added in v3.34.0 

type DatabaseSQLTxCommitDoneInfo struct {
	Error error
}

type DatabaseSQLTxCommitStartInfo added in v3.34.0 

type DatabaseSQLTxCommitStartInfo struct {
	// TxContext make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
	Tx      tableTransactionInfo
}

type DatabaseSQLTxExecDoneInfo added in v3.34.2 

type DatabaseSQLTxExecDoneInfo struct {
	Error error
}

type DatabaseSQLTxExecStartInfo added in v3.34.2 

type DatabaseSQLTxExecStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context   *context.Context
	Call      call
	TxContext context.Context
	Tx        tableTransactionInfo
	Query     string

	// Deprecated: all transactions are idempotent
	Idempotent bool
}

type DatabaseSQLTxPrepareDoneInfo added in v3.54.2 

type DatabaseSQLTxPrepareDoneInfo struct {
	Error error
}

type DatabaseSQLTxPrepareStartInfo added in v3.54.2 

type DatabaseSQLTxPrepareStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context   *context.Context
	Call      call
	TxContext *context.Context
	Tx        tableTransactionInfo
	Query     string
}

type DatabaseSQLTxQueryDoneInfo added in v3.34.2 

type DatabaseSQLTxQueryDoneInfo struct {
	Error error
}

type DatabaseSQLTxQueryStartInfo added in v3.34.2 

type DatabaseSQLTxQueryStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context   *context.Context
	Call      call
	TxContext context.Context
	Tx        tableTransactionInfo
	Query     string

	// Deprecated: all transactions are idempotent
	Idempotent bool
}

type DatabaseSQLTxRollbackDoneInfo added in v3.34.0 

type DatabaseSQLTxRollbackDoneInfo struct {
	Error error
}

type DatabaseSQLTxRollbackStartInfo added in v3.34.0 

type DatabaseSQLTxRollbackStartInfo struct {
	// TxContext make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
	Tx      tableTransactionInfo
}

type Detailer added in v3.46.0 

type Detailer interface {
	Details() Details
}

type Details added in v3.2.1 

type Details uint64
const (
	DriverNetEvents Details = 1 << iota // for bitmask: 1, 2, 4, 8, 16, 32, ...
	DriverConnEvents
	DriverBalancerEvents
	DriverResolverEvents
	DriverRepeaterEvents
	DriverCredentialsEvents

	TableSessionLifeCycleEvents
	TableSessionQueryInvokeEvents
	TableSessionQueryStreamEvents
	TableSessionTransactionEvents
	TablePoolLifeCycleEvents
	TablePoolSessionLifeCycleEvents
	TablePoolAPIEvents

	QuerySessionEvents
	QueryExecuteEvents
	QueryTransactionEvents
	QueryPoolEvents

	TopicControlPlaneEvents

	TopicReaderCustomerEvents

	TopicReaderStreamLifeCycleEvents
	TopicReaderStreamEvents
	TopicReaderMessageEvents
	TopicReaderPartitionEvents

	TopicWriterStreamLifeCycleEvents
	TopicWriterStreamEvents

	DatabaseSQLConnectorEvents
	DatabaseSQLConnEvents
	DatabaseSQLTxEvents
	DatabaseSQLStmtEvents

	RetryEvents

	DiscoveryEvents

	SchemeEvents

	ScriptingEvents

	RatelimiterEvents

	CoordinationEvents

	// Deprecated: has no effect now
	DriverClusterEvents

	DriverEvents = DriverConnEvents |
		DriverBalancerEvents |
		DriverResolverEvents |
		DriverRepeaterEvents |
		DriverCredentialsEvents

	TableEvents = TableSessionLifeCycleEvents |
		TableSessionQueryInvokeEvents |
		TableSessionQueryStreamEvents |
		TableSessionTransactionEvents |
		TablePoolLifeCycleEvents |
		TablePoolSessionLifeCycleEvents |
		TablePoolAPIEvents

	QueryEvents = QuerySessionEvents |
		QueryPoolEvents |
		QueryExecuteEvents |
		QueryTransactionEvents

	TablePoolEvents = TablePoolLifeCycleEvents |
		TablePoolSessionLifeCycleEvents |
		TablePoolAPIEvents

	TableSessionQueryEvents = TableSessionQueryInvokeEvents |
		TableSessionQueryStreamEvents
	TableSessionEvents = TableSessionLifeCycleEvents |
		TableSessionQueryEvents |
		TableSessionTransactionEvents

	TopicReaderEvents = TopicReaderCustomerEvents | TopicReaderStreamEvents | TopicReaderMessageEvents |
		TopicReaderPartitionEvents |
		TopicReaderStreamLifeCycleEvents

	TopicEvents = TopicControlPlaneEvents | TopicReaderEvents

	DatabaseSQLEvents = DatabaseSQLConnectorEvents |
		DatabaseSQLConnEvents |
		DatabaseSQLTxEvents |
		DatabaseSQLStmtEvents

	DetailsAll = ^Details(0) // All bits enabled
)

func MatchDetails added in v3.11.0 

func MatchDetails(pattern string, opts ...matchDetailsOption) (d Details)

func (Details) Details added in v3.42.2 

func (d Details) Details() Details

func (Details) String added in v3.6.2 

func (d Details) String() string

type Discovery added in v3.10.0 

type Discovery struct {
	OnDiscover func(DiscoveryDiscoverStartInfo) func(DiscoveryDiscoverDoneInfo)
	OnWhoAmI   func(DiscoveryWhoAmIStartInfo) func(DiscoveryWhoAmIDoneInfo)
}

Discovery specified trace of discovery client activity. gtrace:gen

func (*Discovery) Compose added in v3.10.0 

func (t *Discovery) Compose(x *Discovery, opts ...DiscoveryComposeOption) *Discovery

Compose returns a new Discovery which has functional fields composed both from t and x.

type DiscoveryComposeOption added in v3.17.0 

type DiscoveryComposeOption func(o *discoveryComposeOptions)

DiscoveryOption specified Discovery compose option

func WithDiscoveryPanicCallback added in v3.17.0 

func WithDiscoveryPanicCallback(cb func(e interface{})) DiscoveryComposeOption

WithDiscoveryPanicCallback specified behavior on panic

type DiscoveryDiscoverDoneInfo added in v3.15.0 

type DiscoveryDiscoverDoneInfo struct {
	Location  string
	Endpoints []EndpointInfo
	Error     error
}

type DiscoveryDiscoverStartInfo added in v3.15.0 

type DiscoveryDiscoverStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context  *context.Context
	Call     call
	Address  string
	Database string
}

type DiscoveryWhoAmIDoneInfo added in v3.15.0 

type DiscoveryWhoAmIDoneInfo struct {
	User   string
	Groups []string
	Error  error
}

type DiscoveryWhoAmIStartInfo added in v3.15.0 

type DiscoveryWhoAmIStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
}

type Driver 

type Driver struct {
	// Driver runtime events
	OnInit  func(DriverInitStartInfo) func(DriverInitDoneInfo)
	OnWith  func(DriverWithStartInfo) func(DriverWithDoneInfo)
	OnClose func(DriverCloseStartInfo) func(DriverCloseDoneInfo)

	// Pool of connections
	OnPoolNew     func(DriverConnPoolNewStartInfo) func(DriverConnPoolNewDoneInfo)
	OnPoolRelease func(DriverConnPoolReleaseStartInfo) func(DriverConnPoolReleaseDoneInfo)

	// Deprecated: driver not notificate about this event
	OnNetRead func(DriverNetReadStartInfo) func(DriverNetReadDoneInfo)
	// Deprecated: driver not notificate about this event
	OnNetWrite func(DriverNetWriteStartInfo) func(DriverNetWriteDoneInfo)
	// Deprecated: driver not notificate about this event
	OnNetDial func(DriverNetDialStartInfo) func(DriverNetDialDoneInfo)
	// Deprecated: driver not notificate about this event
	OnNetClose func(DriverNetCloseStartInfo) func(DriverNetCloseDoneInfo)

	// Resolver events
	OnResolve func(DriverResolveStartInfo) func(DriverResolveDoneInfo)

	// Conn events
	OnConnStateChange func(DriverConnStateChangeStartInfo) func(DriverConnStateChangeDoneInfo)
	OnConnInvoke      func(DriverConnInvokeStartInfo) func(DriverConnInvokeDoneInfo)
	OnConnNewStream   func(
		DriverConnNewStreamStartInfo,
	) func(
		DriverConnNewStreamRecvInfo,
	) func(
		DriverConnNewStreamDoneInfo,
	)
	// Deprecated: driver not notificate about this event
	OnConnTake  func(DriverConnTakeStartInfo) func(DriverConnTakeDoneInfo)
	OnConnDial  func(DriverConnDialStartInfo) func(DriverConnDialDoneInfo)
	OnConnPark  func(DriverConnParkStartInfo) func(DriverConnParkDoneInfo)
	OnConnBan   func(DriverConnBanStartInfo) func(DriverConnBanDoneInfo)
	OnConnAllow func(DriverConnAllowStartInfo) func(DriverConnAllowDoneInfo)
	OnConnClose func(DriverConnCloseStartInfo) func(DriverConnCloseDoneInfo)

	// Repeater events
	OnRepeaterWakeUp func(DriverRepeaterWakeUpStartInfo) func(DriverRepeaterWakeUpDoneInfo)

	// Balancer events
	OnBalancerInit func(DriverBalancerInitStartInfo) func(DriverBalancerInitDoneInfo)

	// Deprecated: driver not notificate about this event
	OnBalancerDialEntrypoint func(
		DriverBalancerDialEntrypointStartInfo,
	) func(
		DriverBalancerDialEntrypointDoneInfo,
	)
	OnBalancerClose          func(DriverBalancerCloseStartInfo) func(DriverBalancerCloseDoneInfo)
	OnBalancerChooseEndpoint func(
		DriverBalancerChooseEndpointStartInfo,
	) func(
		DriverBalancerChooseEndpointDoneInfo,
	)
	OnBalancerClusterDiscoveryAttempt func(
		DriverBalancerClusterDiscoveryAttemptStartInfo,
	) func(
		DriverBalancerClusterDiscoveryAttemptDoneInfo,
	)
	OnBalancerUpdate func(DriverBalancerUpdateStartInfo) func(DriverBalancerUpdateDoneInfo)

	// Credentials events
	OnGetCredentials func(DriverGetCredentialsStartInfo) func(DriverGetCredentialsDoneInfo)
}

Driver specified trace of common driver activity. gtrace:gen

func (*Driver) Compose 

func (t *Driver) Compose(x *Driver, opts ...DriverComposeOption) *Driver

Compose returns a new Driver which has functional fields composed both from t and x.

type DriverBalancerChooseEndpointDoneInfo added in v3.26.0 

type DriverBalancerChooseEndpointDoneInfo struct {
	Endpoint EndpointInfo
	Error    error
}

type DriverBalancerChooseEndpointStartInfo added in v3.26.0 

type DriverBalancerChooseEndpointStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
}

type DriverBalancerCloseDoneInfo added in v3.26.0 

type DriverBalancerCloseDoneInfo struct {
	Error error
}

type DriverBalancerCloseStartInfo added in v3.26.0 

type DriverBalancerCloseStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
}

type DriverBalancerClusterDiscoveryAttemptDoneInfo added in v3.42.9 

type DriverBalancerClusterDiscoveryAttemptDoneInfo struct {
	Error error
}

type DriverBalancerClusterDiscoveryAttemptStartInfo added in v3.42.9 

type DriverBalancerClusterDiscoveryAttemptStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
	Address string
}

type DriverBalancerDialEntrypointDoneInfo added in v3.42.9 

type DriverBalancerDialEntrypointDoneInfo struct {
	Error error
}

type DriverBalancerDialEntrypointStartInfo added in v3.42.9 

type DriverBalancerDialEntrypointStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
	Address string
}

type DriverBalancerInitDoneInfo added in v3.26.0 

type DriverBalancerInitDoneInfo struct {
	Error error
}

type DriverBalancerInitStartInfo added in v3.26.0 

type DriverBalancerInitStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
	Name    string
}

type DriverBalancerUpdateDoneInfo added in v3.26.0 

type DriverBalancerUpdateDoneInfo struct {
	Endpoints []EndpointInfo
	Added     []EndpointInfo
	Dropped   []EndpointInfo
	LocalDC   string
	// Deprecated: this field always nil
	Error error
}

type DriverBalancerUpdateStartInfo added in v3.26.0 

type DriverBalancerUpdateStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context     *context.Context
	Call        call
	NeedLocalDC bool
}

type DriverCloseDoneInfo added in v3.15.0 

type DriverCloseDoneInfo struct {
	Error error
}

type DriverCloseStartInfo added in v3.15.0 

type DriverCloseStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
}

type DriverComposeOption added in v3.17.0 

type DriverComposeOption func(o *driverComposeOptions)

DriverOption specified Driver compose option

func WithDriverPanicCallback added in v3.17.0 

func WithDriverPanicCallback(cb func(e interface{})) DriverComposeOption

WithDriverPanicCallback specified behavior on panic

type DriverConnAllowDoneInfo added in v3.25.1 

type DriverConnAllowDoneInfo struct {
	State ConnState
}

type DriverConnAllowStartInfo added in v3.25.1 

type DriverConnAllowStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context  *context.Context
	Call     call
	Endpoint EndpointInfo
	State    ConnState
}

type DriverConnBanDoneInfo added in v3.25.1 

type DriverConnBanDoneInfo struct {
	State ConnState
}

type DriverConnBanStartInfo added in v3.25.1 

type DriverConnBanStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context  *context.Context
	Call     call
	Endpoint EndpointInfo
	State    ConnState
	Cause    error
}

type DriverConnCloseDoneInfo added in v3.15.0 

type DriverConnCloseDoneInfo struct {
	Error error
}

type DriverConnCloseStartInfo added in v3.15.0 

type DriverConnCloseStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context  *context.Context
	Call     call
	Endpoint EndpointInfo
}

type DriverConnDialDoneInfo added in v3.42.12 

type DriverConnDialDoneInfo struct {
	Error error
}

type DriverConnDialStartInfo added in v3.42.12 

type DriverConnDialStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context  *context.Context
	Call     call
	Endpoint EndpointInfo
}

type DriverConnInvokeDoneInfo added in v3.15.0 

type DriverConnInvokeDoneInfo struct {
	Error    error
	Issues   []Issue
	OpID     string
	State    ConnState
	Metadata map[string][]string
}

type DriverConnInvokeStartInfo added in v3.15.0 

type DriverConnInvokeStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context  *context.Context
	Call     call
	Endpoint EndpointInfo
	Method   Method
}

type DriverConnNewStreamDoneInfo added in v3.15.0 

type DriverConnNewStreamDoneInfo struct {
	Error    error
	State    ConnState
	Metadata map[string][]string
}

type DriverConnNewStreamRecvInfo added in v3.15.0 

type DriverConnNewStreamRecvInfo struct {
	Error error
}

type DriverConnNewStreamStartInfo added in v3.15.0 

type DriverConnNewStreamStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context  *context.Context
	Call     call
	Endpoint EndpointInfo
	Method   Method
}

type DriverConnParkDoneInfo added in v3.15.0 

type DriverConnParkDoneInfo struct {
	Error error
}

type DriverConnParkStartInfo added in v3.15.0 

type DriverConnParkStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context  *context.Context
	Call     call
	Endpoint EndpointInfo
}

type DriverConnPoolNewDoneInfo added in v3.54.2 

type DriverConnPoolNewDoneInfo struct{}

type DriverConnPoolNewStartInfo added in v3.54.2 

type DriverConnPoolNewStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
}

type DriverConnPoolReleaseDoneInfo added in v3.54.2 

type DriverConnPoolReleaseDoneInfo struct {
	Error error
}

type DriverConnPoolReleaseStartInfo added in v3.54.2 

type DriverConnPoolReleaseStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
}

type DriverConnStateChangeDoneInfo added in v3.15.0 

type DriverConnStateChangeDoneInfo struct {
	State ConnState
}

type DriverConnStateChangeStartInfo added in v3.15.0 

type DriverConnStateChangeStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context  *context.Context
	Call     call
	Endpoint EndpointInfo
	State    ConnState
}

type DriverConnTakeDoneInfo added in v3.15.0 

type DriverConnTakeDoneInfo struct {
	Error error
}

type DriverConnTakeStartInfo added in v3.15.0 

type DriverConnTakeStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context  *context.Context
	Call     call
	Endpoint EndpointInfo
}

type DriverGetCredentialsDoneInfo added in v3.15.0 

type DriverGetCredentialsDoneInfo struct {
	Token string
	Error error
}

type DriverGetCredentialsStartInfo added in v3.15.0 

type DriverGetCredentialsStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
}

type DriverInitDoneInfo added in v3.15.0 

type DriverInitDoneInfo struct {
	Error error
}

type DriverInitStartInfo added in v3.15.0 

type DriverInitStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context  *context.Context
	Call     call
	Endpoint string
	Database string
	Secure   bool
}

type DriverNetCloseDoneInfo added in v3.15.0 

type DriverNetCloseDoneInfo struct {
	Error error
}

type DriverNetCloseStartInfo added in v3.15.0 

type DriverNetCloseStartInfo struct {
	Call    call
	Address string
}

type DriverNetDialDoneInfo added in v3.15.0 

type DriverNetDialDoneInfo struct {
	Error error
}

type DriverNetDialStartInfo added in v3.15.0 

type DriverNetDialStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
	Address string
}

type DriverNetReadDoneInfo added in v3.15.0 

type DriverNetReadDoneInfo struct {
	Received int
	Error    error
}

type DriverNetReadStartInfo added in v3.15.0 

type DriverNetReadStartInfo struct {
	Call    call
	Address string
	Buffer  int
}

type DriverNetWriteDoneInfo added in v3.15.0 

type DriverNetWriteDoneInfo struct {
	Sent  int
	Error error
}

type DriverNetWriteStartInfo added in v3.15.0 

type DriverNetWriteStartInfo struct {
	Call    call
	Address string
	Bytes   int
}

type DriverRepeaterWakeUpDoneInfo added in v3.25.0 

type DriverRepeaterWakeUpDoneInfo struct {
	Error error
}

type DriverRepeaterWakeUpStartInfo added in v3.25.0 

type DriverRepeaterWakeUpStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
	Name    string
	Event   string
}

type DriverResolveDoneInfo added in v3.15.0 

type DriverResolveDoneInfo struct {
	Error error
}

type DriverResolveStartInfo added in v3.15.0 

type DriverResolveStartInfo struct {
	Call     call
	Target   string
	Resolved []string
}

type DriverWithDoneInfo added in v3.54.3 

type DriverWithDoneInfo struct {
	Error error
}

type DriverWithStartInfo added in v3.54.3 

type DriverWithStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context  *context.Context
	Call     call
	Endpoint string
	Database string
	Secure   bool
}

type EndpointInfo added in v3.11.8 

type EndpointInfo interface {
	fmt.Stringer

	NodeID() uint32
	Address() string
	LocalDC() bool
	Location() string
	LoadFactor() float32
	LastUpdated() time.Time
}

type FieldStubber 

type FieldStubber struct {
	// OnStub is an optional callback that is called when field getting
	// stubbed.
	OnStub func(name string)

	// OnCall is an optional callback that will be called for each stubbed
	// field getting called.
	OnCall func(name string, args ...interface{})
}

FieldStubber contains options of filling all struct functional fields.

func (FieldStubber) Stub 

func (f FieldStubber) Stub(x reflect.Value)

Stub fills in given x struct.

type Issue 

type Issue interface {
	GetMessage() string
	GetIssueCode() uint32
	GetSeverity() uint32
}

Issue declare interface of operation error issues

type Method 

type Method string

Method represents rpc method.

func (Method) Name 

func (m Method) Name() (s string)

Name returns the rpc method name.

func (Method) Service 

func (m Method) Service() (s string)

Service returns the rpc service name.

func (Method) Split 

func (m Method) Split() (service, method string)

Split returns service name and method.

type OnReadStreamUpdateTokenDoneInfo added in v3.32.0 

type OnReadStreamUpdateTokenDoneInfo struct {
	Error error
}

type OnReadUnknownGrpcMessageInfo added in v3.31.0 

type OnReadUnknownGrpcMessageInfo struct {
	ReaderConnectionID string
	Error              error
}

type OnReadUpdateTokenMiddleTokenReceivedInfo added in v3.32.0 

type OnReadUpdateTokenMiddleTokenReceivedInfo struct {
	TokenLen int
	Error    error
}

type OnReadUpdateTokenStartInfo added in v3.32.0 

type OnReadUpdateTokenStartInfo struct {
	ReaderConnectionID string
}

type Query added in v3.57.0 

type Query struct {
	OnDo   func(QueryDoStartInfo) func(info QueryDoIntermediateInfo) func(QueryDoDoneInfo)
	OnDoTx func(QueryDoTxStartInfo) func(info QueryDoTxIntermediateInfo) func(QueryDoTxDoneInfo)
}

Query specified trace of retry call activity. gtrace:gen

func (*Query) Compose added in v3.57.0 

func (t *Query) Compose(x *Query, opts ...QueryComposeOption) *Query

Compose returns a new Query which has functional fields composed both from t and x.

type QueryComposeOption added in v3.57.0 

type QueryComposeOption func(o *queryComposeOptions)

QueryOption specified Query compose option

func WithQueryPanicCallback added in v3.57.0 

func WithQueryPanicCallback(cb func(e interface{})) QueryComposeOption

WithQueryPanicCallback specified behavior on panic

type QueryDoDoneInfo added in v3.57.0 

type QueryDoDoneInfo struct {
	Attempts int
	Error    error
}

type QueryDoIntermediateInfo added in v3.57.0 

type QueryDoIntermediateInfo struct {
	Error error
}

type QueryDoStartInfo added in v3.57.0 

type QueryDoStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
}

type QueryDoTxDoneInfo added in v3.57.0 

type QueryDoTxDoneInfo struct {
	Attempts int
	Error    error
}

type QueryDoTxIntermediateInfo added in v3.57.0 

type QueryDoTxIntermediateInfo struct {
	Error error
}

type QueryDoTxStartInfo added in v3.57.0 

type QueryDoTxStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
}

type Ratelimiter added in v3.10.0 

type Ratelimiter struct{}

Ratelimiter specified trace of ratelimiter client activity. gtrace:gen

func (*Ratelimiter) Compose added in v3.10.0 

func (t *Ratelimiter) Compose(x *Ratelimiter, opts ...RatelimiterComposeOption) *Ratelimiter

Compose returns a new Ratelimiter which has functional fields composed both from t and x.

type RatelimiterComposeOption added in v3.17.0 

type RatelimiterComposeOption func(o *ratelimiterComposeOptions)

RatelimiterOption specified Ratelimiter compose option

func WithRatelimiterPanicCallback added in v3.17.0 

func WithRatelimiterPanicCallback(cb func(e interface{})) RatelimiterComposeOption

WithRatelimiterPanicCallback specified behavior on panic

type Retry 

type Retry struct {
	OnRetry func(RetryLoopStartInfo) func(RetryLoopIntermediateInfo) func(RetryLoopDoneInfo)
}

Retry specified trace of retry call activity. gtrace:gen

func (*Retry) Compose 

func (t *Retry) Compose(x *Retry, opts ...RetryComposeOption) *Retry

Compose returns a new Retry which has functional fields composed both from t and x.

type RetryComposeOption added in v3.17.0 

type RetryComposeOption func(o *retryComposeOptions)

RetryOption specified Retry compose option

func WithRetryPanicCallback added in v3.17.0 

func WithRetryPanicCallback(cb func(e interface{})) RetryComposeOption

WithRetryPanicCallback specified behavior on panic

type RetryLoopDoneInfo 

type RetryLoopDoneInfo struct {
	Attempts int
	Error    error
}

type RetryLoopIntermediateInfo added in v3.10.0 

type RetryLoopIntermediateInfo struct {
	Error error
}

type RetryLoopStartInfo 

type RetryLoopStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context

	// Deprecated: use Label field instead
	ID string

	Call       call
	Label      string
	Idempotent bool

	NestedCall bool // a sign for detect Retry calls inside head Retry
}

type Scheme added in v3.10.0 

type Scheme struct {
	OnListDirectory     func(SchemeListDirectoryStartInfo) func(SchemeListDirectoryDoneInfo)
	OnDescribePath      func(SchemeDescribePathStartInfo) func(SchemeDescribePathDoneInfo)
	OnMakeDirectory     func(SchemeMakeDirectoryStartInfo) func(SchemeMakeDirectoryDoneInfo)
	OnRemoveDirectory   func(SchemeRemoveDirectoryStartInfo) func(SchemeRemoveDirectoryDoneInfo)
	OnModifyPermissions func(SchemeModifyPermissionsStartInfo) func(SchemeModifyPermissionsDoneInfo)
}

Scheme specified trace of scheme client activity. gtrace:gen

func (*Scheme) Compose added in v3.10.0 

func (t *Scheme) Compose(x *Scheme, opts ...SchemeComposeOption) *Scheme

Compose returns a new Scheme which has functional fields composed both from t and x.

type SchemeComposeOption added in v3.17.0 

type SchemeComposeOption func(o *schemeComposeOptions)

SchemeOption specified Scheme compose option

func WithSchemePanicCallback added in v3.17.0 

func WithSchemePanicCallback(cb func(e interface{})) SchemeComposeOption

WithSchemePanicCallback specified behavior on panic

type SchemeDescribePathDoneInfo added in v3.54.2 

type SchemeDescribePathDoneInfo struct {
	EntryType string
	Error     error
}

type SchemeDescribePathStartInfo added in v3.54.2 

type SchemeDescribePathStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
	Path    string
}

type SchemeListDirectoryDoneInfo added in v3.54.2 

type SchemeListDirectoryDoneInfo struct {
	Error error
}

type SchemeListDirectoryStartInfo added in v3.54.2 

type SchemeListDirectoryStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
}

type SchemeMakeDirectoryDoneInfo added in v3.54.2 

type SchemeMakeDirectoryDoneInfo struct {
	Error error
}

type SchemeMakeDirectoryStartInfo added in v3.54.2 

type SchemeMakeDirectoryStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
	Path    string
}

type SchemeModifyPermissionsDoneInfo added in v3.54.2 

type SchemeModifyPermissionsDoneInfo struct {
	Error error
}

type SchemeModifyPermissionsStartInfo added in v3.54.2 

type SchemeModifyPermissionsStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
	Path    string
}

type SchemeRemoveDirectoryDoneInfo added in v3.54.2 

type SchemeRemoveDirectoryDoneInfo struct {
	Error error
}

type SchemeRemoveDirectoryStartInfo added in v3.54.2 

type SchemeRemoveDirectoryStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
	Path    string
}

type Scripting added in v3.10.0 

type Scripting struct {
	OnExecute       func(ScriptingExecuteStartInfo) func(ScriptingExecuteDoneInfo)
	OnStreamExecute func(
		ScriptingStreamExecuteStartInfo,
	) func(
		ScriptingStreamExecuteIntermediateInfo,
	) func(
		ScriptingStreamExecuteDoneInfo,
	)
	OnExplain func(ScriptingExplainStartInfo) func(ScriptingExplainDoneInfo)
	OnClose   func(ScriptingCloseStartInfo) func(ScriptingCloseDoneInfo)
}

Scripting specified trace of scripting client activity. gtrace:gen

func (*Scripting) Compose added in v3.10.0 

func (t *Scripting) Compose(x *Scripting, opts ...ScriptingComposeOption) *Scripting

Compose returns a new Scripting which has functional fields composed both from t and x.

type ScriptingCloseDoneInfo added in v3.13.1 

type ScriptingCloseDoneInfo struct {
	Error error
}

type ScriptingCloseStartInfo added in v3.13.1 

type ScriptingCloseStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
}

type ScriptingComposeOption added in v3.17.0 

type ScriptingComposeOption func(o *scriptingComposeOptions)

ScriptingOption specified Scripting compose option

func WithScriptingPanicCallback added in v3.17.0 

func WithScriptingPanicCallback(cb func(e interface{})) ScriptingComposeOption

WithScriptingPanicCallback specified behavior on panic

type ScriptingExecuteDoneInfo added in v3.13.1 

type ScriptingExecuteDoneInfo struct {
	Result scriptingResult
	Error  error
}

type ScriptingExecuteStartInfo added in v3.13.1 

type ScriptingExecuteStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context    *context.Context
	Call       call
	Query      string
	Parameters scriptingQueryParameters
}

type ScriptingExplainDoneInfo added in v3.13.1 

type ScriptingExplainDoneInfo struct {
	Plan  string
	Error error
}

type ScriptingExplainStartInfo added in v3.13.1 

type ScriptingExplainStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
	Query   string
}

type ScriptingStreamExecuteDoneInfo added in v3.13.1 

type ScriptingStreamExecuteDoneInfo struct {
	Error error
}

type ScriptingStreamExecuteIntermediateInfo added in v3.13.1 

type ScriptingStreamExecuteIntermediateInfo struct {
	Error error
}

type ScriptingStreamExecuteStartInfo added in v3.13.1 

type ScriptingStreamExecuteStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context    *context.Context
	Call       call
	Query      string
	Parameters scriptingQueryParameters
}

type Table 

type Table struct {
	// Client events
	OnInit          func(TableInitStartInfo) func(TableInitDoneInfo)
	OnClose         func(TableCloseStartInfo) func(TableCloseDoneInfo)
	OnDo            func(TableDoStartInfo) func(info TableDoIntermediateInfo) func(TableDoDoneInfo)
	OnDoTx          func(TableDoTxStartInfo) func(info TableDoTxIntermediateInfo) func(TableDoTxDoneInfo)
	OnCreateSession func(
		TableCreateSessionStartInfo,
	) func(
		info TableCreateSessionIntermediateInfo,
	) func(
		TableCreateSessionDoneInfo,
	)
	// Session events
	OnSessionNew       func(TableSessionNewStartInfo) func(TableSessionNewDoneInfo)
	OnSessionDelete    func(TableSessionDeleteStartInfo) func(TableSessionDeleteDoneInfo)
	OnSessionKeepAlive func(TableKeepAliveStartInfo) func(TableKeepAliveDoneInfo)
	// Query events
	OnSessionBulkUpsert   func(TableBulkUpsertStartInfo) func(TableBulkUpsertDoneInfo)
	OnSessionQueryPrepare func(TablePrepareDataQueryStartInfo) func(TablePrepareDataQueryDoneInfo)
	OnSessionQueryExecute func(TableExecuteDataQueryStartInfo) func(TableExecuteDataQueryDoneInfo)
	OnSessionQueryExplain func(TableExplainQueryStartInfo) func(TableExplainQueryDoneInfo)
	// Stream events
	OnSessionQueryStreamExecute func(
		TableSessionQueryStreamExecuteStartInfo,
	) func(
		TableSessionQueryStreamExecuteIntermediateInfo,
	) func(
		TableSessionQueryStreamExecuteDoneInfo,
	)
	OnSessionQueryStreamRead func(
		TableSessionQueryStreamReadStartInfo,
	) func(
		TableSessionQueryStreamReadIntermediateInfo,
	) func(
		TableSessionQueryStreamReadDoneInfo,
	)
	// Transaction events
	OnSessionTransactionBegin func(TableSessionTransactionBeginStartInfo) func(
		TableSessionTransactionBeginDoneInfo,
	)
	OnSessionTransactionExecute func(TableTransactionExecuteStartInfo) func(
		TableTransactionExecuteDoneInfo,
	)
	OnSessionTransactionExecuteStatement func(TableTransactionExecuteStatementStartInfo) func(
		TableTransactionExecuteStatementDoneInfo,
	)
	OnSessionTransactionCommit func(TableSessionTransactionCommitStartInfo) func(
		TableSessionTransactionCommitDoneInfo,
	)
	OnSessionTransactionRollback func(TableSessionTransactionRollbackStartInfo) func(
		TableSessionTransactionRollbackDoneInfo,
	)
	// Pool state event
	OnPoolStateChange func(TablePoolStateChangeInfo)

	// Pool session lifecycle events
	OnPoolSessionAdd    func(info TablePoolSessionAddInfo)
	OnPoolSessionRemove func(info TablePoolSessionRemoveInfo)

	// OnPoolSessionNew is user-defined callback for listening events about creating sessions with
	// internal session pool calls
	//
	// Deprecated: use OnPoolSessionAdd callback
	OnPoolSessionNew func(TablePoolSessionNewStartInfo) func(TablePoolSessionNewDoneInfo)

	// OnPoolSessionClose is user-defined callback for listening sessionClose calls
	//
	// Deprecated: use OnPoolSessionRemove callback
	OnPoolSessionClose func(TablePoolSessionCloseStartInfo) func(TablePoolSessionCloseDoneInfo)
	// Pool common API events
	OnPoolPut  func(TablePoolPutStartInfo) func(TablePoolPutDoneInfo)
	OnPoolGet  func(TablePoolGetStartInfo) func(TablePoolGetDoneInfo)
	OnPoolWait func(TablePoolWaitStartInfo) func(TablePoolWaitDoneInfo)
}

Table specified trace of table client activity. gtrace:gen

func (*Table) Compose 

func (t *Table) Compose(x *Table, opts ...TableComposeOption) *Table

Compose returns a new Table which has functional fields composed both from t and x.

type TableBulkUpsertDoneInfo added in v3.54.2 

type TableBulkUpsertDoneInfo struct {
	Error error
}

type TableBulkUpsertStartInfo added in v3.54.2 

type TableBulkUpsertStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
	Session tableSessionInfo
}

type TableCloseDoneInfo added in v3.13.1 

type TableCloseDoneInfo struct {
	Error error
}

type TableCloseStartInfo added in v3.13.1 

type TableCloseStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
}

type TableComposeOption added in v3.17.0 

type TableComposeOption func(o *tableComposeOptions)

TableOption specified Table compose option

func WithTablePanicCallback added in v3.17.0 

func WithTablePanicCallback(cb func(e interface{})) TableComposeOption

WithTablePanicCallback specified behavior on panic

type TableCreateSessionDoneInfo added in v3.15.0 

type TableCreateSessionDoneInfo struct {
	Session  tableSessionInfo
	Attempts int
	Error    error
}

type TableCreateSessionIntermediateInfo added in v3.15.0 

type TableCreateSessionIntermediateInfo struct {
	Error error
}

type TableCreateSessionStartInfo added in v3.15.0 

type TableCreateSessionStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
}

type TableDoDoneInfo added in v3.15.0 

type TableDoDoneInfo struct {
	Attempts int
	Error    error
}

type TableDoIntermediateInfo added in v3.15.0 

type TableDoIntermediateInfo struct {
	Error error
}

type TableDoStartInfo added in v3.15.0 

type TableDoStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call

	// Deprecated: use Label field instead
	ID string

	Label      string
	Idempotent bool
	NestedCall bool // flag when Retry called inside head Retry
}

type TableDoTxDoneInfo added in v3.15.0 

type TableDoTxDoneInfo struct {
	Attempts int
	Error    error
}

type TableDoTxIntermediateInfo added in v3.15.0 

type TableDoTxIntermediateInfo struct {
	Error error
}

type TableDoTxStartInfo added in v3.15.0 

type TableDoTxStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call

	// Deprecated: use Label field instead
	ID string

	Label      string
	Idempotent bool
	NestedCall bool // flag when Retry called inside head Retry
}

type TableExecuteDataQueryDoneInfo added in v3.15.0 

type TableExecuteDataQueryDoneInfo struct {
	Tx       tableTransactionInfo
	Prepared bool
	Result   tableResult
	Error    error
}

type TableExecuteDataQueryStartInfo added in v3.15.0 

type TableExecuteDataQueryStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context     *context.Context
	Call        call
	Session     tableSessionInfo
	Query       tableDataQuery
	Parameters  tableQueryParameters
	KeepInCache bool
}

type TableExplainQueryDoneInfo added in v3.15.0 

type TableExplainQueryDoneInfo struct {
	AST   string
	Plan  string
	Error error
}

type TableExplainQueryStartInfo added in v3.15.0 

type TableExplainQueryStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
	Session tableSessionInfo
	Query   string
}

type TableInitDoneInfo added in v3.13.1 

type TableInitDoneInfo struct {
	Limit int
	Error error
}

type TableInitStartInfo added in v3.13.1 

type TableInitStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
}

type TableKeepAliveDoneInfo added in v3.15.0 

type TableKeepAliveDoneInfo struct {
	Error error
}

type TableKeepAliveStartInfo added in v3.15.0 

type TableKeepAliveStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
	Session tableSessionInfo
}

type TablePoolGetDoneInfo added in v3.15.0 

type TablePoolGetDoneInfo struct {
	Session  tableSessionInfo
	Attempts int
	Error    error
}

type TablePoolGetStartInfo added in v3.15.0 

type TablePoolGetStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
}

type TablePoolPutDoneInfo added in v3.15.0 

type TablePoolPutDoneInfo struct {
	Error error
}

type TablePoolPutStartInfo added in v3.15.0 

type TablePoolPutStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
	Session tableSessionInfo
}

type TablePoolSessionAddInfo added in v3.33.0 

type TablePoolSessionAddInfo struct {
	Session tableSessionInfo
}

type TablePoolSessionCloseDoneInfo added in v3.15.0 

type TablePoolSessionCloseDoneInfo struct{}

type TablePoolSessionCloseStartInfo added in v3.15.0 

type TablePoolSessionCloseStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
	Session tableSessionInfo
}

type TablePoolSessionNewDoneInfo added in v3.15.0 

type TablePoolSessionNewDoneInfo struct {
	Session tableSessionInfo
	Error   error
}

type TablePoolSessionNewStartInfo added in v3.15.0 

type TablePoolSessionNewStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
}

type TablePoolSessionRemoveInfo added in v3.33.0 

type TablePoolSessionRemoveInfo struct {
	Session tableSessionInfo
}

type TablePoolStateChangeInfo added in v3.26.10 

type TablePoolStateChangeInfo struct {
	Size  int
	Event string
}

type TablePoolWaitDoneInfo added in v3.15.0 

type TablePoolWaitDoneInfo struct {
	Session tableSessionInfo
	Error   error
}

TablePoolWaitDoneInfo means a wait iteration inside Get call is done Warning: Session and Error may be nil at the same time. This means that a wait iteration donned without any significant tableResultErr

type TablePoolWaitStartInfo added in v3.15.0 

type TablePoolWaitStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
}

type TablePrepareDataQueryDoneInfo added in v3.15.0 

type TablePrepareDataQueryDoneInfo struct {
	Result tableDataQuery
	Error  error
}

type TablePrepareDataQueryStartInfo added in v3.15.0 

type TablePrepareDataQueryStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
	Session tableSessionInfo
	Query   string
}

type TableSessionDeleteDoneInfo added in v3.15.0 

type TableSessionDeleteDoneInfo struct {
	Error error
}

type TableSessionDeleteStartInfo added in v3.15.0 

type TableSessionDeleteStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
	Session tableSessionInfo
}

type TableSessionNewDoneInfo added in v3.15.0 

type TableSessionNewDoneInfo struct {
	Session tableSessionInfo
	Error   error
}

type TableSessionNewStartInfo added in v3.15.0 

type TableSessionNewStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
}

type TableSessionQueryStreamExecuteDoneInfo added in v3.15.0 

type TableSessionQueryStreamExecuteDoneInfo struct {
	Error error
}

type TableSessionQueryStreamExecuteIntermediateInfo added in v3.15.0 

type TableSessionQueryStreamExecuteIntermediateInfo struct {
	Error error
}

type TableSessionQueryStreamExecuteStartInfo added in v3.15.0 

type TableSessionQueryStreamExecuteStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context    *context.Context
	Call       call
	Session    tableSessionInfo
	Query      tableDataQuery
	Parameters tableQueryParameters
}

type TableSessionQueryStreamReadDoneInfo added in v3.15.0 

type TableSessionQueryStreamReadDoneInfo struct {
	Error error
}

type TableSessionQueryStreamReadIntermediateInfo added in v3.15.0 

type TableSessionQueryStreamReadIntermediateInfo struct {
	Error error
}

type TableSessionQueryStreamReadStartInfo added in v3.15.0 

type TableSessionQueryStreamReadStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
	Session tableSessionInfo
}

type TableSessionTransactionBeginDoneInfo added in v3.15.0 

type TableSessionTransactionBeginDoneInfo struct {
	Tx    tableTransactionInfo
	Error error
}

type TableSessionTransactionBeginStartInfo added in v3.15.0 

type TableSessionTransactionBeginStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
	Session tableSessionInfo
}

type TableSessionTransactionCommitDoneInfo added in v3.15.0 

type TableSessionTransactionCommitDoneInfo struct {
	Error error
}

type TableSessionTransactionCommitStartInfo added in v3.15.0 

type TableSessionTransactionCommitStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
	Session tableSessionInfo
	Tx      tableTransactionInfo
}

type TableSessionTransactionRollbackDoneInfo added in v3.15.0 

type TableSessionTransactionRollbackDoneInfo struct {
	Error error
}

type TableSessionTransactionRollbackStartInfo added in v3.15.0 

type TableSessionTransactionRollbackStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context *context.Context
	Call    call
	Session tableSessionInfo
	Tx      tableTransactionInfo
}

type TableTransactionExecuteDoneInfo added in v3.34.2 

type TableTransactionExecuteDoneInfo struct {
	Result tableResult
	Error  error
}

type TableTransactionExecuteStartInfo added in v3.34.2 

type TableTransactionExecuteStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context    *context.Context
	Call       call
	Session    tableSessionInfo
	Tx         tableTransactionInfo
	Query      tableDataQuery
	Parameters tableQueryParameters
}

type TableTransactionExecuteStatementDoneInfo added in v3.34.2 

type TableTransactionExecuteStatementDoneInfo struct {
	Result tableResult
	Error  error
}

type TableTransactionExecuteStatementStartInfo added in v3.34.2 

type TableTransactionExecuteStatementStartInfo struct {
	// Context make available context in trace callback function.
	// Pointer to context provide replacement of context in trace callback function.
	// Warning: concurrent access to pointer on client side must be excluded.
	// Safe replacement of context are provided only inside callback function
	Context        *context.Context
	Call           call
	Session        tableSessionInfo
	Tx             tableTransactionInfo
	StatementQuery tableDataQuery
	Parameters     tableQueryParameters
}

type Topic added in v3.31.0 

type Topic struct {
	OnReaderStart func(info TopicReaderStartInfo)

	OnReaderReconnect        func(TopicReaderReconnectStartInfo) func(TopicReaderReconnectDoneInfo)
	OnReaderReconnectRequest func(TopicReaderReconnectRequestInfo)

	OnReaderPartitionReadStartResponse func(
		TopicReaderPartitionReadStartResponseStartInfo,
	) func(
		TopicReaderPartitionReadStartResponseDoneInfo,
	)
	OnReaderPartitionReadStopResponse func(
		TopicReaderPartitionReadStopResponseStartInfo,
	) func(
		TopicReaderPartitionReadStopResponseDoneInfo,
	)

	OnReaderCommit            func(TopicReaderCommitStartInfo) func(TopicReaderCommitDoneInfo)
	OnReaderSendCommitMessage func(TopicReaderSendCommitMessageStartInfo) func(TopicReaderSendCommitMessageDoneInfo)
	OnReaderCommittedNotify   func(TopicReaderCommittedNotifyInfo)
	OnReaderClose             func(TopicReaderCloseStartInfo) func(TopicReaderCloseDoneInfo)
	OnReaderInit              func(TopicReaderInitStartInfo) func(TopicReaderInitDoneInfo)
	OnReaderError             func(TopicReaderErrorInfo)
	OnReaderUpdateToken       func(
		OnReadUpdateTokenStartInfo,
	) func(
		OnReadUpdateTokenMiddleTokenReceivedInfo,
	) func(
		OnReadStreamUpdateTokenDoneInfo,
	)

	OnReaderSentDataRequest     func(TopicReaderSentDataRequestInfo)
	OnReaderReceiveDataResponse func(TopicReaderReceiveDataResponseStartInfo) func(TopicReaderReceiveDataResponseDoneInfo)
	OnReaderReadMessages        func(TopicReaderReadMessagesStartInfo) func(TopicReaderReadMessagesDoneInfo)
	OnReaderUnknownGrpcMessage  func(OnReadUnknownGrpcMessageInfo)

	OnWriterReconnect  func(TopicWriterReconnectStartInfo) func(TopicWriterReconnectDoneInfo)
	OnWriterInitStream func(TopicWriterInitStreamStartInfo) func(TopicWriterInitStreamDoneInfo)
	OnWriterClose      func(TopicWriterCloseStartInfo) func(TopicWriterCloseDoneInfo)

	OnWriterCompressMessages       func(TopicWriterCompressMessagesStartInfo) func(TopicWriterCompressMessagesDoneInfo)
	OnWriterSendMessages           func(TopicWriterSendMessagesStartInfo) func(TopicWriterSendMessagesDoneInfo)
	OnWriterReadUnknownGrpcMessage func(TopicOnWriterReadUnknownGrpcMessageInfo)
}

Topic specified trace of topic reader client activity. gtrace:gen

func (*Topic) Compose added in v3.31.0 

func (t *Topic) Compose(x *Topic, opts ...TopicComposeOption) *Topic

Compose returns a new Topic which has functional fields composed both from t and x.

type TopicComposeOption added in v3.31.0 

type TopicComposeOption func(o *topicComposeOptions)

TopicOption specified Topic compose option

func WithTopicPanicCallback added in v3.31.0 

func WithTopicPanicCallback(cb func(e interface{})) TopicComposeOption

WithTopicPanicCallback specified behavior on panic

type TopicOnWriterReadUnknownGrpcMessageInfo added in v3.38.0 

type TopicOnWriterReadUnknownGrpcMessageInfo struct {
	WriterInstanceID string
	SessionID        string
	Error            error
}

type TopicReadStreamInitRequestInfo added in v3.32.0 

type TopicReadStreamInitRequestInfo interface {
	GetConsumer() string
	GetTopics() []string
}

type TopicReaderCloseDoneInfo added in v3.32.0 

type TopicReaderCloseDoneInfo struct {
	CloseError error
}

type TopicReaderCloseStartInfo added in v3.32.0 

type TopicReaderCloseStartInfo struct {
	ReaderConnectionID string
	CloseReason        error
}

type TopicReaderCommitDoneInfo added in v3.32.0 

type TopicReaderCommitDoneInfo struct {
	Error error
}

type TopicReaderCommitStartInfo added in v3.32.0 

type TopicReaderCommitStartInfo struct {
	RequestContext     context.Context
	Topic              string
	PartitionID        int64
	PartitionSessionID int64
	StartOffset        int64
	EndOffset          int64
}

type TopicReaderCommittedNotifyInfo added in v3.32.0 

type TopicReaderCommittedNotifyInfo struct {
	ReaderConnectionID string
	Topic              string
	PartitionID        int64
	PartitionSessionID int64
	CommittedOffset    int64
}

type TopicReaderDataResponseInfo added in v3.32.0 

type TopicReaderDataResponseInfo interface {
	GetBytesSize() int
	GetPartitionBatchMessagesCounts() (partitionCount, batchCount, messagesCount int)
}

type TopicReaderErrorInfo added in v3.32.0 

type TopicReaderErrorInfo struct {
	ReaderConnectionID string
	Error              error
}

type TopicReaderInitDoneInfo added in v3.32.0 

type TopicReaderInitDoneInfo struct {
	ReaderConnectionID string
	Error              error
}

type TopicReaderInitStartInfo added in v3.32.0 

type TopicReaderInitStartInfo struct {
	PreInitReaderConnectionID string
	InitRequestInfo           TopicReadStreamInitRequestInfo
}

type TopicReaderPartitionReadStartResponseDoneInfo added in v3.32.0 

type TopicReaderPartitionReadStartResponseDoneInfo struct {
	ReadOffset   *int64
	CommitOffset *int64
	Error        error
}

type TopicReaderPartitionReadStartResponseStartInfo added in v3.32.0 

type TopicReaderPartitionReadStartResponseStartInfo struct {
	ReaderConnectionID string
	PartitionContext   context.Context
	Topic              string
	PartitionID        int64
	PartitionSessionID int64
}

type TopicReaderPartitionReadStopResponseDoneInfo added in v3.32.0 

type TopicReaderPartitionReadStopResponseDoneInfo struct {
	Error error
}

type TopicReaderPartitionReadStopResponseStartInfo added in v3.32.0 

type TopicReaderPartitionReadStopResponseStartInfo struct {
	ReaderConnectionID string
	PartitionContext   context.Context
	Topic              string
	PartitionID        int64
	PartitionSessionID int64
	CommittedOffset    int64
	Graceful           bool
}

type TopicReaderReadMessagesDoneInfo added in v3.32.0 

type TopicReaderReadMessagesDoneInfo struct {
	MessagesCount      int
	Topic              string
	PartitionID        int64
	PartitionSessionID int64
	OffsetStart        int64
	OffsetEnd          int64
	FreeBufferCapacity int
	Error              error
}

type TopicReaderReadMessagesStartInfo added in v3.32.0 

type TopicReaderReadMessagesStartInfo struct {
	RequestContext     context.Context
	MinCount           int
	MaxCount           int
	FreeBufferCapacity int
}

type TopicReaderReceiveDataResponseDoneInfo added in v3.32.0 

type TopicReaderReceiveDataResponseDoneInfo struct {
	Error error
}

type TopicReaderReceiveDataResponseStartInfo added in v3.32.0 

type TopicReaderReceiveDataResponseStartInfo struct {
	ReaderConnectionID          string
	LocalBufferSizeAfterReceive int
	DataResponse                TopicReaderDataResponseInfo
}

type TopicReaderReconnectDoneInfo added in v3.32.0 

type TopicReaderReconnectDoneInfo struct {
	Error error
}

type TopicReaderReconnectRequestInfo added in v3.32.0 

type TopicReaderReconnectRequestInfo struct {
	Reason  error
	WasSent bool
}

type TopicReaderReconnectStartInfo added in v3.32.0 

type TopicReaderReconnectStartInfo struct {
	Reason error
}

type TopicReaderSendCommitMessageDoneInfo added in v3.32.0 

type TopicReaderSendCommitMessageDoneInfo struct {
	Error error
}

type TopicReaderSendCommitMessageStartInfo added in v3.32.0 

type TopicReaderSendCommitMessageStartInfo struct {
	CommitsInfo TopicReaderStreamSendCommitMessageStartMessageInfo
}

type TopicReaderSentDataRequestInfo added in v3.32.0 

type TopicReaderSentDataRequestInfo struct {
	ReaderConnectionID       string
	RequestBytes             int
	LocalBufferSizeAfterSent int
}

type TopicReaderStartInfo added in v3.52.0 

type TopicReaderStartInfo struct {
	ReaderID int64
	Consumer string
}

type TopicReaderStreamCommitInfo added in v3.52.0 

type TopicReaderStreamCommitInfo struct {
	Topic              string
	PartitionID        int64
	PartitionSessionID int64
	StartOffset        int64
	EndOffset          int64
}

type TopicReaderStreamSendCommitMessageStartMessageInfo added in v3.32.0 

type TopicReaderStreamSendCommitMessageStartMessageInfo interface {
	GetCommitsInfo() []TopicReaderStreamCommitInfo
}

type TopicWriterCloseDoneInfo added in v3.38.0 

type TopicWriterCloseDoneInfo struct {
	Error error
}

type TopicWriterCloseStartInfo added in v3.38.0 

type TopicWriterCloseStartInfo struct {
	WriterInstanceID string
	Reason           error
}

type TopicWriterCompressMessagesDoneInfo added in v3.38.0 

type TopicWriterCompressMessagesDoneInfo struct {
	Error error
}

type TopicWriterCompressMessagesReason added in v3.38.0 

type TopicWriterCompressMessagesReason string

func (TopicWriterCompressMessagesReason) String added in v3.38.0 

func (r TopicWriterCompressMessagesReason) String() string

type TopicWriterCompressMessagesStartInfo added in v3.38.0 

type TopicWriterCompressMessagesStartInfo struct {
	WriterInstanceID string
	SessionID        string
	Codec            int32
	FirstSeqNo       int64
	MessagesCount    int
	Reason           TopicWriterCompressMessagesReason
}

type TopicWriterInitStreamDoneInfo added in v3.38.0 

type TopicWriterInitStreamDoneInfo struct {
	SessionID string
	Error     error
}

type TopicWriterInitStreamStartInfo added in v3.38.0 

type TopicWriterInitStreamStartInfo struct {
	WriterInstanceID string
	Topic            string
	ProducerID       string
}

type TopicWriterReconnectDoneInfo added in v3.38.0 

type TopicWriterReconnectDoneInfo struct {
	Error error
}

type TopicWriterReconnectStartInfo added in v3.38.0 

type TopicWriterReconnectStartInfo struct {
	WriterInstanceID string
	Topic            string
	ProducerID       string
	Attempt          int
}

type TopicWriterSendMessagesDoneInfo added in v3.38.0 

type TopicWriterSendMessagesDoneInfo struct {
	Error error
}

type TopicWriterSendMessagesStartInfo added in v3.38.0 

type TopicWriterSendMessagesStartInfo struct {
	WriterInstanceID string
	SessionID        string
	Codec            int32
	FirstSeqNo       int64
	MessagesCount    int
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

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