repository

Documentation

Index

• type IKVRepository
  • func NewRedisRepository(ctx context.Context, config config.IConfig, logger *zap.Logger) (IKVRepository, error)
• type MockIKVRepository
  • func NewMockIKVRepository(t interface{ ... }) *MockIKVRepository
  • func (_m *MockIKVRepository) AddStreamEvent(ctx context.Context, streamKey string, streamId string, payload interface{}) (string, error)
  • func (_m *MockIKVRepository) AddToUnsortedSet(ctx context.Context, UnsortedSetKey string, objects ...*Object) (int64, error)
  • func (_m *MockIKVRepository) GetServerTimestamp(ctx context.Context) (int64, error)
  • func (_m *MockIKVRepository) Ping(ctx context.Context) (string, error)
• type Object

Types

type IKVRepository

type IKVRepository interface {
	GetServerTimestamp(ctx context.Context) (int64, error)
	Ping(ctx context.Context) (string, error)
	AddStreamEvent(ctx context.Context, streamKey string, streamId string, payload interface{}) (string, error)
	AddToUnsortedSet(ctx context.Context, UnsortedSetKey string, objects ...*Object) (int64, error)
}

interface of kv store and sql-like are quite different

func NewRedisRepository

func NewRedisRepository(ctx context.Context, config config.IConfig, logger *zap.Logger) (IKVRepository, error)

type MockIKVRepository

type MockIKVRepository struct {
	mock.Mock
}

MockIKVRepository is an autogenerated mock type for the IKVRepository type

func NewMockIKVRepository

func NewMockIKVRepository(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockIKVRepository

NewMockIKVRepository creates a new instance of MockIKVRepository. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockIKVRepository) AddStreamEvent

func (_m *MockIKVRepository) AddStreamEvent(ctx context.Context, streamKey string, streamId string, payload interface{}) (string, error)

AddStreamEvent provides a mock function with given fields: ctx, streamKey, streamId, payload

func (*MockIKVRepository) AddToUnsortedSet

func (_m *MockIKVRepository) AddToUnsortedSet(ctx context.Context, UnsortedSetKey string, objects ...*Object) (int64, error)

AddToUnsortedSet provides a mock function with given fields: ctx, UnsortedSetKey, objects

func (*MockIKVRepository) GetServerTimestamp

func (_m *MockIKVRepository) GetServerTimestamp(ctx context.Context) (int64, error)

GetServerTimestamp provides a mock function with given fields: ctx

func (*MockIKVRepository) Ping

func (_m *MockIKVRepository) Ping(ctx context.Context) (string, error)

Ping provides a mock function with given fields: ctx

type Object

type Object struct {
	Key        string
	Payload    interface{}
	Expiration time.Duration
}