Get current second

Getters & Setters

Parse the UID into elements which are used to generate the UID. <br> Such as timestamp & workerId & sequence... @param uid @return Parsed info

Start executors such as schedule

Allocate bits for UID according to delta seconds & workerId & sequence<br> <b>Note that: </b>The highest bit will always be 0 for sign @param deltaSe

Calculate slot index with the slot sequence (sequence % bufferSize)

Check UIDs are all unique

Check UIDs are all unique

Do generating

Do generating

Getters & Setters

Get a unique ID @return UID @throws UidGenerateException

Padding buffer fill the slots until to catch the cursor

Parse date by 'yyyy-MM-dd' pattern @param str @return

Parse date without Checked exception @param str @param pattern @return @throws RuntimeException when ParseException occurred

Reject put buffer request @param ringBuffer @param uid

Add {@link WorkerNodeEntity} @param workerNodeEntity

Assign worker id for {@link com.baidu.fsg.uid.impl.DefaultUidGenerator} @return assigned worker id

Padding buffer in the thread pool

Build worker node entity by IP and PORT

Format date by 'yyyy-MM-dd HH:mm:ss' pattern @param date @return

Format date by 'yyyy-MM-dd' pattern @param date @return

Retrieve docker host @return empty string if not a docker

Retrieve docker port @return empty string if not a docker

Get the method invoker's class name @param depth @return

Retrieve local address @return the string local address

Retrieve the first validated local ip address(the Public and LAN ip addresses are validated). @return the local address @throws SocketException the s

Get next millisecond

Get sequence for different naming prefix @param invoker @return

Getters

Initialize flags as CAN_PUT_FLAG

Initialize RingBuffer & RingBufferPaddingExecutor

Whether a docker @return

Get UID @return UID @throws UidGenerateException in the case: Clock moved backwards; Exceeds the max timestamp

Provides UID in one second @param momentInSecond @return

Put an UID in the ring & tail moved<br> We use 'synchronized' to guarantee the UID fill in slot & publish new tail sequence as atomic operations<br>

Reject take buffer request @param ringBuffer

Retrieve host & port from environment

Setters

Shutdown executors

Take an UID of the ring at the next cursor, this is a lock free operation by using atomic cursor<p> Before getting the UID, we also check whether rea

Worker run

Woker run

Constructor with timestampBits, workerIdBits, sequenceBits<br> The highest bit used for sign, so <code>63</code> bits for timestampBits, workerIdBits,

Constructor with {@link RingBuffer} and {@link BufferedUidProvider}, default use schedule @param ringBuffer {@link RingBuffer} @param uidProvider {@l

Constructors

Constructors from {@link AtomicLong}

Constructor with buffer size, paddingFactor default as {@value #DEFAULT_PADDING_PERCENT} @param bufferSize must be positive & a power of 2

Default constructor

Constructor with field of type

Assign worker id base on database.<p> If there is host name & port in the environment, we considered that the node runs in Docker container<br> Otherw

Discard policy for {@link RejectedPutBufferHandler}, we just do logging

Policy for {@link RejectedTakeBufferHandler}, throws {@link RuntimeException} after logging

Format date into string @param date @param pattern @return

Get current day using format date by 'yyyy-MM-dd HH:mm:ss' pattern @return @author yebo

Getters

Get {@link WorkerNodeEntity} by node host @param host @param port @return

Whether is padding @return

Get the UIDs in the same specified second under the max sequence @param currentSecond @return UID list, size of {@link BitsAllocator#getMaxSequence()

Parse the bounded value into ValuedEnum @param clz @param value @return

Parse date by 'yyyy-MM-dd HH:mm:ss' pattern @param str @return

Setters for spring property