infra

package

v0.8.0 Latest Latest Go to latest Published: Nov 7, 2025 License: Apache-2.0 Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Config struct {
	DeliveryMQ *mqinfra.MQInfraConfig
	LogMQ      *mqinfra.MQInfraConfig
}

func (cfg *Config) SetSensiblePolicyDefaults()

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

func NewInfra(cfg Config, redisClient redis.Cmdable) Infra

func NewInfraWithProvider(lock Lock, provider InfraProvider) *Infra

NewInfraWithProvider creates an Infra instance with custom lock and provider (for testing)

func (infra *Infra) Declare(ctx context.Context) error

func (infra *Infra) Teardown(ctx context.Context) error

type InfraProvider interface {
	Exist(ctx context.Context) (bool, error)
	Declare(ctx context.Context) error
	Teardown(ctx context.Context) error
}

InfraProvider handles the actual infrastructure operations

type Lock interface {
	AttemptLock(ctx context.Context) (bool, error)
	Unlock(ctx context.Context) (bool, error)
}

func NewRedisLock(client redis.Cmdable, opts ...LockOption) Lock

NewRedisLock creates a new Redis-based distributed lock

type LockOption func(*redisLock)

LockOption configures a redisLock

func LockWithKey(key string) LockOption

LockWithKey sets a custom key for the lock

func LockWithTTL(ttl time.Duration) LockOption

LockWithTTL sets a custom TTL for the lock