hooks

Documentation

Index

• Variables
• type Code
  • func (c Code) GRPC() int
  • func (c Code) HTTP() int
  • func (c Code) Int() int
• type Config
• type MetricCollector
• type MetricsHook
  • func NewMetricsHook(config *Config, collector MetricCollector) *MetricsHook
  • func (h *MetricsHook) After(ctx context.Context, input *dbhook.HookInput) (context.Context, error)
  • func (h *MetricsHook) Before(ctx context.Context, input *dbhook.HookInput) (context.Context, error)
  • func (h *MetricsHook) Error(ctx context.Context, input *dbhook.HookInput) (context.Context, error)
• type ReconnectHook
  • func NewReconnectHook(config *Config) *ReconnectHook
  • func (rh *ReconnectHook) Error(ctx context.Context, input *dbhook.HookInput) (context.Context, error)
• type SimplerrHook
  • func NewSimplerrHook() *SimplerrHook
  • func (h *SimplerrHook) Error(ctx context.Context, input *dbhook.HookInput) (context.Context, error)
• type TracingHook
  • func NewTracingHook(tracer trace.Tracer, config *Config) *TracingHook
  • func (hook *TracingHook) After(ctx context.Context, input *dbhook.HookInput) (context.Context, error)
  • func (hook *TracingHook) Before(ctx context.Context, input *dbhook.HookInput) (context.Context, error)
  • func (hook *TracingHook) Error(ctx context.Context, input *dbhook.HookInput) (context.Context, error)

Variables

var ErrCanRetry = errors.New("connection reconnect")

Types

type Code

type Code int

const (
	DatabaseError Code = 2020
	BadConnection Code = 2021
	Reconnected   Code = 2022
)

func (Code) GRPC

func (c Code) GRPC() int

func (Code) HTTP

func (c Code) HTTP() int

func (Code) Int

func (c Code) Int() int

type Config

type Config struct {
	ReconnectFn func() error

	Addr           string
	User           string
	Database       string
	CertPath       string
	Type           string
	ReadTimeout    string
	WriteTimeout   string
	DataSourceName string
	DriverName     string
	Instance       string
}

Config is internal hook config with specified information.

type MetricCollector

type MetricCollector interface {
	SerializationFailureInc(dbType, dbAddr, dbName string)
	QueryDurationObserve(dbType, dbAddr, dbName, operation, table string, isError bool, since time.Duration)
}

type MetricsHook

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

func NewMetricsHook

func NewMetricsHook(config *Config, collector MetricCollector) *MetricsHook

func (*MetricsHook) After

func (h *MetricsHook) After(ctx context.Context, input *dbhook.HookInput) (context.Context, error)

func (*MetricsHook) Before

func (h *MetricsHook) Before(ctx context.Context, input *dbhook.HookInput) (context.Context, error)

func (*MetricsHook) Error

func (h *MetricsHook) Error(ctx context.Context, input *dbhook.HookInput) (context.Context, error)

type ReconnectHook

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

func NewReconnectHook

func NewReconnectHook(config *Config) *ReconnectHook

func (*ReconnectHook) Error

func (rh *ReconnectHook) Error(ctx context.Context, input *dbhook.HookInput) (context.Context, error)

type SimplerrHook

type SimplerrHook struct{}

func NewSimplerrHook

func NewSimplerrHook() *SimplerrHook

func (*SimplerrHook) Error

func (h *SimplerrHook) Error(ctx context.Context, input *dbhook.HookInput) (context.Context, error)

type TracingHook

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

func NewTracingHook

func NewTracingHook(tracer trace.Tracer, config *Config) *TracingHook

func (*TracingHook) After

func (hook *TracingHook) After(ctx context.Context, input *dbhook.HookInput) (context.Context, error)

func (*TracingHook) Before

func (hook *TracingHook) Before(ctx context.Context, input *dbhook.HookInput) (context.Context, error)

func (*TracingHook) Error

func (hook *TracingHook) Error(ctx context.Context, input *dbhook.HookInput) (context.Context, error)