service

Documentation

Index

• type CircuitBreakerQuerier
  • func (q *CircuitBreakerQuerier) ExecContext(ctx context.Context, query string, args ...interface{}) (result sql.Result, err error)
  • func (q *CircuitBreakerQuerier) QueryContext(ctx context.Context, query string, args ...interface{}) (rows *sql.Rows, err error)
  • func (q *CircuitBreakerQuerier) QueryRowContext(ctx context.Context, query string, args ...interface{}) (row *sql.Row)
• type SailorAPI
  • func (s *SailorAPI) Run() error

Types

type CircuitBreakerQuerier

type CircuitBreakerQuerier struct {
	CB             *circuit.Breaker
	Timeout        time.Duration
	Querier        sqlexp.Querier
	SimulatedDelay time.Duration
}

func (*CircuitBreakerQuerier) ExecContext

func (q *CircuitBreakerQuerier) ExecContext(ctx context.Context, query string, args ...interface{}) (result sql.Result, err error)

func (*CircuitBreakerQuerier) QueryContext

func (q *CircuitBreakerQuerier) QueryContext(ctx context.Context, query string, args ...interface{}) (rows *sql.Rows, err error)

func (*CircuitBreakerQuerier) QueryRowContext

func (q *CircuitBreakerQuerier) QueryRowContext(ctx context.Context, query string, args ...interface{}) (row *sql.Row)

type SailorAPI

type SailorAPI struct {
	SailorDBPath          string
	SailorVirtualPath     string
	BindAddress           string
	SailorArtificialDelay time.Duration
	SailorBreakerRate     float64
	SailorBreakerSamples  int64
}

func (*SailorAPI) Run

func (s *SailorAPI) Run() error