global

Documentation

Index

• Variables
• type ID
  • func NewID(conf *config.AppConfig, client pb.IdSvcClient) *ID
  • func (i *ID) Generate(ctx context.Context) int64
• type Lock
  • func (l *Lock) Release() error
• type Locker
  • func NewLocker(client *etcd.Client) *Locker
  • func (l *Locker) Acquire(key string, opts ...LockerOpt) (*Lock, error)
• type LockerOpt
  • func WithAcquireTimeout(timeout time.Duration) LockerOpt
  • func WithLockTTL(ttl time.Duration) LockerOpt
  • func WithTry(try bool) LockerOpt
• type Operation
• type Transaction
  • func NewTransaction(conf *config.AppConfig) *Transaction
  • func (t *Transaction) TCC(tccFunc dtmgrpc.TccGlobalFunc) (string, error)

Variables

var ProviderSet = wire.NewSet(NewID, NewLocker, NewTransaction)

Types

type ID

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

func NewID

func NewID(conf *config.AppConfig, client pb.IdSvcClient) *ID

func (*ID) Generate

func (i *ID) Generate(ctx context.Context) int64

type Lock

type Lock struct {
	*sync.Mutex
	// contains filtered or unexported fields
}

func (*Lock) Release

func (l *Lock) Release() error

type Locker

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

func NewLocker

func NewLocker(client *etcd.Client) *Locker

func (*Locker) Acquire

func (l *Locker) Acquire(key string, opts ...LockerOpt) (*Lock, error)

type LockerOpt

type LockerOpt func(op *Operation)

func WithAcquireTimeout

func WithAcquireTimeout(timeout time.Duration) LockerOpt

func WithLockTTL

func WithLockTTL(ttl time.Duration) LockerOpt

func WithTry

func WithTry(try bool) LockerOpt

type Operation

type Operation struct {
	AcquireTimeout time.Duration
	TTL            time.Duration
	Try            bool
}

type Transaction

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

func NewTransaction

func NewTransaction(conf *config.AppConfig) *Transaction

func (*Transaction) TCC

func (t *Transaction) TCC(tccFunc dtmgrpc.TccGlobalFunc) (string, error)