gotx

package

v0.0.0-...-4e871e4 Latest Latest Go to latest Published: Jun 13, 2021 License: MIT Imports: 4 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

func NewShardingTransactor(connectionProvider ConnectionProvider, shardKeyProvider ShardKeyProvider) gotx.Transactor

func NewTransactor(connectionProvider ConnectionProvider) gotx.Transactor

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

------------------------------------ Client ------------------------------------

func NewDefaultClientProvider(connectionProvider ConnectionProvider) ClientProvider

func NewShardingDefaultClientProvider(connectionProvider ConnectionProvider, shardKeyProvider ShardKeyProvider) ClientProvider

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

-------------------------------- Connection --------------------------------

func NewDefaultConnectionProvider(client *redis.Client) ConnectionProvider

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

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

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

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

get redis client from field

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

type ShardKeyProvider func(ctx context.Context) string

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

get db by hash slot

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

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

------------------------------------ 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