txresolver

Documentation

Index

• type TxConnection
• type TxResolver
  • func NewTxResolver(ch chan *discovery.TabletHealth, txConn TxConnection) *TxResolver
  • func (tr *TxResolver) Start()
  • func (tr *TxResolver) Stop()

Types

type TxConnection

type TxConnection interface {
	ResolveTransactions(ctx context.Context, target *querypb.Target) error
}

type TxResolver

type TxResolver struct {
	// contains filtered or unexported fields
}

func NewTxResolver

func NewTxResolver(ch chan *discovery.TabletHealth, txConn TxConnection) *TxResolver

func (*TxResolver) Start

func (tr *TxResolver) Start()

func (*TxResolver) Stop

func (tr *TxResolver) Stop()