singleton_task

package module

v1.0.0 Latest Latest Go to latest Published: Oct 19, 2022 License: MIT Imports: 9 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/skynet2/singleton-task

Links

Open Source Insights

README ¶

singleton-task

Description

Due to the nature of microservices, k8s etc., we have multiple pods\instances of the same service, but in some cases, there is a the requirement to run the specific job in a single instance, for example, some parsing jobs with rate limiting, database migrations, etc. Here come the leader election algorithms.

This implementation is targeted for redlock approach

Installation

go get github.com/skynet2/singleton-task

Quickstart

Documentation ¶

Index ¶

type Fn
type Singleton
- func NewSingletonRedLock(locker *redislock.Client, key string, fn Fn, ctx context.Context, ...) Singleton

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Fn ¶

type Fn func(ctx context.Context)

type Singleton ¶

type Singleton interface {
	Close() error
	StartAsync() error
}

func NewSingletonRedLock ¶

func NewSingletonRedLock(
	locker *redislock.Client,
	key string,
	fn Fn,
	ctx context.Context,
	ttl time.Duration,
) Singleton

Source Files ¶

View all Source files

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