idalloc

Documentation

Index

• func NewMAllocator(allocator Allocator) allocator.Interface
• type Allocator
  • func NewIDAllocator(rc types.RootCoordClient) Allocator
  • func NewTSOAllocator(rc types.RootCoordClient) Allocator

Functions

func NewMAllocator

func NewMAllocator(allocator Allocator) allocator.Interface

Types

type Allocator

type Allocator interface {
	// Allocate allocates a timestamp.
	Allocate(ctx context.Context) (uint64, error)

	// Sync expire the local allocator messages,
	// syncs the local allocator and remote allocator.
	Sync()

	// SyncIfExpired syncs the local allocator and remote allocator if the duration since last sync operation is greater than expire.
	SyncIfExpired(expire time.Duration)
}

func NewIDAllocator

func NewIDAllocator(rc types.RootCoordClient) Allocator

NewIDAllocator creates a new allocator.

func NewTSOAllocator

func NewTSOAllocator(rc types.RootCoordClient) Allocator

NewTSOAllocator creates a new allocator.