redis

Documentation

Overview

Package redis is a generated GoMock package.

Index

• type Config
• type Metrics
• type MockMetrics
  • func NewMockMetrics(ctrl *gomock.Controller) *MockMetrics
  • func (m *MockMetrics) DeltaUpDownCounter(ctx context.Context, name string, value float64, labels ...string)
  • func (m *MockMetrics) EXPECT() *MockMetricsMockRecorder
  • func (m *MockMetrics) IncrementCounter(ctx context.Context, name string, labels ...string)
  • func (m *MockMetrics) RecordHistogram(ctx context.Context, name string, value float64, labels ...string)
  • func (m *MockMetrics) SetGauge(name string, value float64)
• type MockMetricsMockRecorder
  • func (mr *MockMetricsMockRecorder) DeltaUpDownCounter(ctx, name, value interface{}, labels ...interface{}) *gomock.Call
  • func (mr *MockMetricsMockRecorder) IncrementCounter(ctx, name interface{}, labels ...interface{}) *gomock.Call
  • func (mr *MockMetricsMockRecorder) RecordHistogram(ctx, name, value interface{}, labels ...interface{}) *gomock.Call
  • func (mr *MockMetricsMockRecorder) SetGauge(name, value interface{}) *gomock.Call
• type QueryLog
  • func (ql QueryLog) String() string
• type Redis
  • func NewClient(c config.Config, logger datasource.Logger, metrics Metrics) *Redis
  • func (r *Redis) HealthCheck() datasource.Health

Types

type Config

type Config struct {
	HostName string
	Port     int
	Options  *redis.Options
}

type Metrics

type Metrics interface {
	IncrementCounter(ctx context.Context, name string, labels ...string)
	DeltaUpDownCounter(ctx context.Context, name string, value float64, labels ...string)
	RecordHistogram(ctx context.Context, name string, value float64, labels ...string)
	SetGauge(name string, value float64)
}

type MockMetrics

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

MockMetrics is a mock of Metrics interface.

func NewMockMetrics

func NewMockMetrics(ctrl *gomock.Controller) *MockMetrics

NewMockMetrics creates a new mock instance.

func (*MockMetrics) DeltaUpDownCounter

func (m *MockMetrics) DeltaUpDownCounter(ctx context.Context, name string, value float64, labels ...string)

DeltaUpDownCounter mocks base method.

func (*MockMetrics) EXPECT

func (m *MockMetrics) EXPECT() *MockMetricsMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockMetrics) IncrementCounter

func (m *MockMetrics) IncrementCounter(ctx context.Context, name string, labels ...string)

IncrementCounter mocks base method.

func (*MockMetrics) RecordHistogram

func (m *MockMetrics) RecordHistogram(ctx context.Context, name string, value float64, labels ...string)

RecordHistogram mocks base method.

func (*MockMetrics) SetGauge

func (m *MockMetrics) SetGauge(name string, value float64)

SetGauge mocks base method.

type MockMetricsMockRecorder

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

MockMetricsMockRecorder is the mock recorder for MockMetrics.

func (*MockMetricsMockRecorder) DeltaUpDownCounter

func (mr *MockMetricsMockRecorder) DeltaUpDownCounter(ctx, name, value interface{}, labels ...interface{}) *gomock.Call

DeltaUpDownCounter indicates an expected call of DeltaUpDownCounter.

func (*MockMetricsMockRecorder) IncrementCounter

func (mr *MockMetricsMockRecorder) IncrementCounter(ctx, name interface{}, labels ...interface{}) *gomock.Call

IncrementCounter indicates an expected call of IncrementCounter.

func (*MockMetricsMockRecorder) RecordHistogram

func (mr *MockMetricsMockRecorder) RecordHistogram(ctx, name, value interface{}, labels ...interface{}) *gomock.Call

RecordHistogram indicates an expected call of RecordHistogram.

func (*MockMetricsMockRecorder) SetGauge

func (mr *MockMetricsMockRecorder) SetGauge(name, value interface{}) *gomock.Call

SetGauge indicates an expected call of SetGauge.

type QueryLog

type QueryLog struct {
	Query    string      `json:"query"`
	Duration int64       `json:"duration"`
	Args     interface{} `json:"args,omitempty"`
}

QueryLog represents a logged Redis query.

func (QueryLog) String

func (ql QueryLog) String() string

type Redis

type Redis struct {
	*redis.Client
	// contains filtered or unexported fields
}

func NewClient

func NewClient(c config.Config, logger datasource.Logger, metrics Metrics) *Redis

NewClient return a redis client if connection is successful based on Config. In case of error, it returns an error as second parameter.

func (*Redis) HealthCheck

func (r *Redis) HealthCheck() datasource.Health