redis

Documentation

Index

• type ClientProvider
• type ConnectionProvider
• type DefaultClientProvider
  • func NewDefaultClientProvider(connectionProvider ConnectionProvider) *DefaultClientProvider
  • func NewShardingDefaultClientProvider(connectionProvider ConnectionProvider, shardKeyProvider ShardKeyProvider) *DefaultClientProvider
  • func (p *DefaultClientProvider) CurrentClient(ctx context.Context) (reader redis.Cmdable, writer redis.Cmdable)
• type DefaultConnectionProvider
  • func NewDefaultConnectionProvider(client *redis.Client) *DefaultConnectionProvider
  • func (p *DefaultConnectionProvider) CurrentConnection(_ context.Context) *redis.Client
• type ShardKeyProvider
• type ShardingConnectionProvider
  • func NewShardingConnectionProvider(db []*redis.Client, maxSlot uint32, shardKeyProvider ShardKeyProvider) *ShardingConnectionProvider
  • func (p *ShardingConnectionProvider) CurrentConnection(ctx context.Context) *redis.Client
• type Transactor
  • func NewShardingTransactor(connectionProvider ConnectionProvider, shardKeyProvider ShardKeyProvider) *Transactor
  • func NewTransactor(connectionProvider ConnectionProvider) *Transactor
  • func (t *Transactor) Required(ctx context.Context, fn gotx.DoInTransaction, options ...gotx.Option) error
  • func (t *Transactor) RequiresNew(ctx context.Context, fn gotx.DoInTransaction, options ...gotx.Option) error

Types

type ClientProvider

type ClientProvider interface {
	CurrentClient(ctx context.Context) (reader redis.Cmdable, writer redis.Cmdable)
}

type ConnectionProvider

type ConnectionProvider interface {
	CurrentConnection(ctx context.Context) *redis.Client
}

type DefaultClientProvider

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

func NewDefaultClientProvider

func NewDefaultClientProvider(connectionProvider ConnectionProvider) *DefaultClientProvider

func NewShardingDefaultClientProvider

func NewShardingDefaultClientProvider(connectionProvider ConnectionProvider, shardKeyProvider ShardKeyProvider) *DefaultClientProvider

func (*DefaultClientProvider) CurrentClient

func (p *DefaultClientProvider) CurrentClient(ctx context.Context) (reader redis.Cmdable, writer redis.Cmdable)

type DefaultConnectionProvider

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

get redis client from field

func NewDefaultConnectionProvider

func NewDefaultConnectionProvider(client *redis.Client) *DefaultConnectionProvider

func (*DefaultConnectionProvider) CurrentConnection

func (p *DefaultConnectionProvider) CurrentConnection(_ context.Context) *redis.Client

type ShardKeyProvider

type ShardKeyProvider func(ctx context.Context) string

type ShardingConnectionProvider

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

get db by hash slot

func NewShardingConnectionProvider

func NewShardingConnectionProvider(db []*redis.Client, maxSlot uint32, shardKeyProvider ShardKeyProvider) *ShardingConnectionProvider

func (*ShardingConnectionProvider) CurrentConnection

func (p *ShardingConnectionProvider) CurrentConnection(ctx context.Context) *redis.Client

type Transactor

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

func NewShardingTransactor

func NewShardingTransactor(connectionProvider ConnectionProvider, shardKeyProvider ShardKeyProvider) *Transactor

func NewTransactor

func NewTransactor(connectionProvider ConnectionProvider) *Transactor

func (*Transactor) Required

func (t *Transactor) Required(ctx context.Context, fn gotx.DoInTransaction, options ...gotx.Option) error

func (*Transactor) RequiresNew

func (t *Transactor) RequiresNew(ctx context.Context, fn gotx.DoInTransaction, options ...gotx.Option) error