compo

package

v0.0.0-...-0025a43 Latest Latest Go to latest Published: Oct 10, 2022 License: MIT Imports: 19 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

Repository

github.com/jassue/gin-wire

Documentation ¶

Index ¶

Variables
func NewSonyFlake() *sonyflake.Sonyflake
type Limiter
type LimiterManager
- func NewLimiterManager() *LimiterManager
- func (lm *LimiterManager) GetLimiter(r rate.Limit, b int, key string) *Limiter
type LockBuilder
- func NewLockBuilder(rdb *redis.Client) *LockBuilder
- func (lb *LockBuilder) NewLock(ctx context.Context, name string, seconds int64) LockInterface
type LockInterface
type Storage
- func NewStorage(c *config.Configuration, log *zap.Logger) *Storage

Constants ¶

This section is empty.

Variables ¶

View Source

var ProviderSet = wire.NewSet(
	NewSonyFlake,
	NewLockBuilder,
	NewStorage,
	casbin.NewEnforcer,
	mq.NewQueueLogger,
	rabbitmq.NewConnManager,
	rabbitmq.NewRabbitmqSender,
	rabbitmq.NewRabbitmqReceiver,
	NewLimiterManager,
)

ProviderSet is compo providers.

Functions ¶

func NewSonyFlake ¶

func NewSonyFlake() *sonyflake.Sonyflake

NewSonyFlake .

Types ¶

type Limiter ¶

type Limiter struct {
	L *rate.Limiter
	// contains filtered or unexported fields
}

type LimiterManager ¶

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

func NewLimiterManager ¶

func NewLimiterManager() *LimiterManager

func (*LimiterManager) GetLimiter ¶

func (lm *LimiterManager) GetLimiter(r rate.Limit, b int, key string) *Limiter

type LockBuilder ¶

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

func NewLockBuilder ¶

func NewLockBuilder(rdb *redis.Client) *LockBuilder

NewLockBuilder .

func (*LockBuilder) NewLock ¶

func (lb *LockBuilder) NewLock(ctx context.Context, name string, seconds int64) LockInterface

type LockInterface ¶

type LockInterface interface {
	Get() bool
	Block(seconds int64) bool
	Release() bool
	ForceRelease()
}

type Storage ¶

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

func NewStorage ¶

func NewStorage(c *config.Configuration, log *zap.Logger) *Storage

NewStorage .

func (*Storage) GetDefaultDiskType ¶

func (s *Storage) GetDefaultDiskType() string

func (*Storage) GetDisk ¶

func (s *Storage) GetDisk(disk ...string) (storage.Storage, error)

func (*Storage) IsLocal ¶

func (s *Storage) IsLocal() bool

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
casbin
mq
event
rabbitmq

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL