trace

type ClusterGetDoneInfo struct {
	Endpoint endpointInfo
	Error    error
}

type ClusterGetStartInfo struct {
	Context context.Context
}

type ClusterInsertDoneInfo struct {
	State ConnState
}

type ClusterInsertStartInfo struct {
	Context  context.Context
	Endpoint endpointInfo
}

type ClusterRemoveDoneInfo struct {
	State ConnState
}

type ClusterRemoveStartInfo struct {
	Context  context.Context
	Endpoint endpointInfo
}

type ClusterUpdateDoneInfo struct {
	State ConnState
}

type ClusterUpdateStartInfo struct {
	Context  context.Context
	Endpoint endpointInfo
}

type ConnInvokeDoneInfo struct {
	Error  error
	Issues []Issue
	OpID   string
	State  ConnState
}

type ConnInvokeStartInfo struct {
	Context  context.Context
	Endpoint endpointInfo
	Method   Method
}

type ConnNewStreamDoneInfo struct {
	State ConnState
	Error error
}

type ConnNewStreamRecvInfo struct {
	Error error
}

type ConnNewStreamStartInfo struct {
	Context  context.Context
	Endpoint endpointInfo
	Method   Method
}

type ConnReleaseDoneInfo struct {
	Lock int
}

type ConnReleaseStartInfo struct {
	Context  context.Context
	Endpoint endpointInfo
}

type ConnState interface {
	IsValid() bool
	String() string
	Code() int
}

type ConnStateChangeDoneInfo struct {
	State ConnState
}

type ConnStateChangeStartInfo struct {
	Context  context.Context
	Endpoint endpointInfo
	State    ConnState
}

type ConnTakeDoneInfo struct {
	Lock  int
	Error error
}

type ConnTakeStartInfo struct {
	Context  context.Context
	Endpoint endpointInfo
}

type Details uint64

type DiscoveryDoneInfo struct {
	Endpoints []string
	Error     error
}

type DiscoveryStartInfo struct {
	Context context.Context
}

type Driver struct {
	// Network events
	OnNetRead  func(NetReadStartInfo) func(NetReadDoneInfo)
	OnNetWrite func(NetWriteStartInfo) func(NetWriteDoneInfo)
	OnNetDial  func(NetDialStartInfo) func(NetDialDoneInfo)
	OnNetClose func(NetCloseStartInfo) func(NetCloseDoneInfo)

	// Conn events
	OnConnStateChange func(ConnStateChangeStartInfo) func(ConnStateChangeDoneInfo)
	OnConnInvoke      func(ConnInvokeStartInfo) func(ConnInvokeDoneInfo)
	OnConnNewStream   func(ConnNewStreamStartInfo) func(ConnNewStreamRecvInfo) func(ConnNewStreamDoneInfo)
	OnConnTake        func(ConnTakeStartInfo) func(ConnTakeDoneInfo)
	OnConnRelease     func(ConnReleaseStartInfo) func(ConnReleaseDoneInfo)

	// Cluster events
	OnClusterGet    func(ClusterGetStartInfo) func(ClusterGetDoneInfo)
	OnClusterInsert func(ClusterInsertStartInfo) func(ClusterInsertDoneInfo)
	OnClusterUpdate func(ClusterUpdateStartInfo) func(ClusterUpdateDoneInfo)
	OnClusterRemove func(ClusterRemoveStartInfo) func(ClusterRemoveDoneInfo)
	OnPessimizeNode func(PessimizeNodeStartInfo) func(PessimizeNodeDoneInfo)

	// Credentials events
	OnGetCredentials func(GetCredentialsStartInfo) func(GetCredentialsDoneInfo)

	// Discovery events
	OnDiscovery func(DiscoveryStartInfo) func(DiscoveryDoneInfo)
}

type ExecuteDataQueryStartInfo struct {
	Context    context.Context
	Session    sessionInfo
	Tx         transactionInfo
	Query      dataQuery
	Parameters queryParameters
}

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{})
}

type GetCredentialsDoneInfo struct {
	TokenOk bool
	Error   error
}

type GetCredentialsStartInfo struct {
	Context context.Context
}

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

type KeepAliveDoneInfo struct {
	Error error
}

type KeepAliveStartInfo struct {
	Context context.Context
	Session sessionInfo
}

type Method string

type NetCloseDoneInfo struct {
	Error error
}

type NetCloseStartInfo struct {
	Address string
}

type NetDialDoneInfo struct {
	Error error
}

type NetDialStartInfo struct {
	Address string
}

type NetReadDoneInfo struct {
	Received int
	Error    error
}

type NetReadStartInfo struct {
	Address string
	Buffer  int
}

type NetWriteDoneInfo struct {
	Sent  int
	Error error
}

type NetWriteStartInfo struct {
	Address string
	Bytes   int
}

type PessimizeNodeDoneInfo struct {
	State ConnState
	Error error
}

type PessimizeNodeStartInfo struct {
	Context  context.Context
	Endpoint endpointInfo
	State    ConnState
	Cause    error
}

type PoolCloseDoneInfo struct {
	Error error
}

type PoolCloseStartInfo struct {
	Context context.Context
}

type PoolGetDoneInfo struct {
	Session  sessionInfo
	Attempts int
	Error    error
}

type PoolGetStartInfo struct {
	Context context.Context
}

type PoolInitDoneInfo struct {
	Limit            int
	KeepAliveMinSize int
}

type PoolInitStartInfo struct {
	Context context.Context
}

type PoolPutDoneInfo struct {
	Error error
}

type PoolPutStartInfo struct {
	Context context.Context
	Session sessionInfo
}

type PoolRetryDoneInfo struct {
	Attempts int
	Error    error
}

type PoolRetryInternalInfo struct {
	Error error
}

type PoolRetryStartInfo struct {
	Context    context.Context
	Idempotent bool
}

type PoolSessionCloseDoneInfo struct {
}

type PoolSessionCloseStartInfo struct {
	Context context.Context
	Session sessionInfo
}

type PoolSessionNewDoneInfo struct {
	Session sessionInfo
	Error   error
}

type PoolSessionNewStartInfo struct {
	Context context.Context
}

type PoolTakeDoneInfo struct {
	Took  bool
	Error error
}

type PoolTakeStartInfo struct {
	Context context.Context
	Session sessionInfo
}

type PoolTakeWaitInfo struct {
}

type PoolWaitDoneInfo struct {
	Session sessionInfo
	Error   error
}

type PoolWaitStartInfo struct {
	Context context.Context
}

type PrepareDataQueryDoneInfo struct {
	Result dataQuery
	Error  error
}

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

type RetryLoopDoneInfo struct {
	Context context.Context
	Latency time.Duration
	Err     error
}

type RetryLoopStartInfo struct {
	Context context.Context
}

type SessionDeleteDoneInfo struct {
	Error error
}

type SessionDeleteStartInfo struct {
	Context context.Context
	Session sessionInfo
}

type SessionNewDoneInfo struct {
	Session sessionInfo
	Error   error
}

type SessionNewStartInfo struct {
	Context context.Context
}

type SessionQueryPrepareDoneInfo struct {
	Prepared bool
	Result   result
	Error    error
}

type SessionQueryPrepareStartInfo struct {
	Context context.Context
	Session sessionInfo
	Query   string
}

type SessionQueryStreamExecuteDoneInfo struct {
	Result streamResult
	Error  error
}

type SessionQueryStreamExecuteStartInfo struct {
	Context    context.Context
	Session    sessionInfo
	Query      dataQuery
	Parameters queryParameters
}

type SessionQueryStreamReadDoneInfo struct {
	Result streamResult
	Error  error
}

type SessionQueryStreamReadStartInfo struct {
	Context context.Context
	Session sessionInfo
}

type SessionTransactionBeginDoneInfo struct {
	Tx    transactionInfo
	Error error
}

type SessionTransactionBeginStartInfo struct {
	Context context.Context
	Session sessionInfo
}

type SessionTransactionCommitDoneInfo struct {
	Error error
}

type SessionTransactionCommitStartInfo struct {
	Context context.Context
	Session sessionInfo
	Tx      transactionInfo
}

type SessionTransactionRollbackDoneInfo struct {
	Error error
}

type SessionTransactionRollbackStartInfo struct {
	Context context.Context
	Session sessionInfo
	Tx      transactionInfo
}

type Table struct {
	// Session events
	OnSessionNew       func(SessionNewStartInfo) func(SessionNewDoneInfo)
	OnSessionDelete    func(SessionDeleteStartInfo) func(SessionDeleteDoneInfo)
	OnSessionKeepAlive func(KeepAliveStartInfo) func(KeepAliveDoneInfo)
	// Query events
	OnSessionQueryPrepare func(SessionQueryPrepareStartInfo) func(PrepareDataQueryDoneInfo)
	OnSessionQueryExecute func(ExecuteDataQueryStartInfo) func(SessionQueryPrepareDoneInfo)
	// Stream events
	OnSessionQueryStreamExecute func(SessionQueryStreamExecuteStartInfo) func(SessionQueryStreamExecuteDoneInfo)
	OnSessionQueryStreamRead    func(SessionQueryStreamReadStartInfo) func(SessionQueryStreamReadDoneInfo)
	// Transaction events
	OnSessionTransactionBegin    func(SessionTransactionBeginStartInfo) func(SessionTransactionBeginDoneInfo)
	OnSessionTransactionCommit   func(SessionTransactionCommitStartInfo) func(SessionTransactionCommitDoneInfo)
	OnSessionTransactionRollback func(SessionTransactionRollbackStartInfo) func(SessionTransactionRollbackDoneInfo)
	// Pool events
	OnPoolInit  func(PoolInitStartInfo) func(PoolInitDoneInfo)
	OnPoolClose func(PoolCloseStartInfo) func(PoolCloseDoneInfo)
	OnPoolRetry func(PoolRetryStartInfo) func(info PoolRetryInternalInfo) func(PoolRetryDoneInfo)
	// Pool session lifecycle events
	OnPoolSessionNew   func(PoolSessionNewStartInfo) func(PoolSessionNewDoneInfo)
	OnPoolSessionClose func(PoolSessionCloseStartInfo) func(PoolSessionCloseDoneInfo)
	// Pool common API events
	OnPoolPut func(PoolPutStartInfo) func(PoolPutDoneInfo)
	// Pool native API events
	OnPoolGet  func(PoolGetStartInfo) func(PoolGetDoneInfo)
	OnPoolWait func(PoolWaitStartInfo) func(PoolWaitDoneInfo)
	// Pool ydbsql API events
	OnPoolTake func(PoolTakeStartInfo) func(PoolTakeWaitInfo) func(PoolTakeDoneInfo)
}