ddb

Nov 8, 2023

Changes in this version

type DdbLeaderElectionSettings

+ ClientName string

Oct 12, 2023

Changes in this version

+ const LeaderElectionTypeDdb

+ const LeaderElectionTypeStatic

+ func GetLeaderElectionConfigKey(name string) string

+ func GetLeaderElectionConfigKeyType(name string) string

+ func NewDdbLockProvider(ctx context.Context, config cfg.Config, logger log.Logger, ...) (conc.DistributedLockProvider, error)

+ func NewDdbLockProviderWithInterfaces(logger log.Logger, repo ddb.Repository, backOff backoff.BackOff, ...) conc.DistributedLockProvider

+ type DdbLeaderElection struct

+ func NewDdbLeaderElectionWithInterfaces(logger log.Logger, clock clock.Clock, repository ddb.Repository, ...) (*DdbLeaderElection, error)

+ func (e *DdbLeaderElection) IsLeader(ctx context.Context, memberId string) (bool, error)

+ func (e *DdbLeaderElection) Resign(ctx context.Context, memberId string) error

+ type DdbLeaderElectionItem struct

+ GroupId string

+ LeadingUntil int64

+ MemberId string

+ type DdbLeaderElectionSettings struct

+ GroupId string

+ LeaseDuration time.Duration

+ Naming TableNamingSettings

+ type DdbLockItem struct

+ Resource string

+ Token string

+ Ttl int64

+ type LeaderElection interface

+ IsLeader func(ctx context.Context, memberId string) (bool, error)

+ Resign func(ctx context.Context, memberId string) error

+ func NewDdbLeaderElection(ctx context.Context, config cfg.Config, logger log.Logger, name string) (LeaderElection, error)

+ func NewDdbLeaderElectionWithSettings(ctx context.Context, config cfg.Config, logger log.Logger, ...) (LeaderElection, error)

+ func NewLeaderElection(ctx context.Context, config cfg.Config, logger log.Logger, name string) (LeaderElection, error)

+ func NewStaticLeaderElection(_ context.Context, config cfg.Config, _ log.Logger, name string) (LeaderElection, error)

+ type LeaderElectionFactory func(ctx context.Context, config cfg.Config, logger log.Logger, name string) (LeaderElection, error)

+ type StaticLeaderElection struct

+ func NewStaticLeaderElectionWithSettings(settings *StaticLeaderElectionSettings) (*StaticLeaderElection, error)

+ func (e StaticLeaderElection) IsLeader(context.Context, string) (bool, error)

+ func (e StaticLeaderElection) Resign(context.Context, string) error

+ type StaticLeaderElectionSettings struct

+ Result bool

+ type TableNamingSettings struct

+ Pattern string