Skip to content

Commit

Permalink
change package (#23)
Browse files Browse the repository at this point in the history
  • Loading branch information
@himadieievsv
himadieievsv authored Jan 4, 2024
1 parent 85b0366 commit 1c36420
Show file tree
Hide file tree
Showing 51 changed files with 296 additions and 153 deletions.
2 changes: 1 addition & 1 deletion build.gradle.kts
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@ allprojects {
apply(plugin = "org.jlleitschuh.gradle.ktlint")
apply(plugin = "idea")

group = "io.redpulsar"
group = "me.himadieiev.redpulsar"
version = "0.1.1"

repositories {
Expand Down
2 changes: 1 addition & 1 deletion redpulsar-core/build.gradle.kts
View file
Original file line number Diff line number Diff line change
@@ -1,3 +1,3 @@
group = "io.redpulsar-core"
group = "me.himadieiev.redpulsar-core"

dependencies {}
14 changes: 7 additions & 7 deletions ...sar/core/locks/ListeningCountDownLatch.kt → ...sar/core/locks/ListeningCountDownLatch.kt
View file
Original file line number Diff line number Diff line change
@@ -1,18 +1,18 @@
package io.redpulsar.core.locks
package me.himadieiev.redpulsar.core.locks

import io.redpulsar.core.locks.abstracts.backends.CountDownLatchBackend
import io.redpulsar.core.locks.api.CallResult
import io.redpulsar.core.locks.api.CountDownLatch
import io.redpulsar.core.locks.excecutors.executeWithRetry
import io.redpulsar.core.locks.excecutors.waitAnyJobs
import io.redpulsar.core.utils.failsafe
import kotlinx.coroutines.CoroutineName
import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.async
import kotlinx.coroutines.flow.first
import kotlinx.coroutines.runBlocking
import kotlinx.coroutines.withTimeout
import me.himadieiev.redpulsar.core.locks.abstracts.backends.CountDownLatchBackend
import me.himadieiev.redpulsar.core.locks.api.CallResult
import me.himadieiev.redpulsar.core.locks.api.CountDownLatch
import me.himadieiev.redpulsar.core.locks.excecutors.executeWithRetry
import me.himadieiev.redpulsar.core.locks.excecutors.waitAnyJobs
import me.himadieiev.redpulsar.core.utils.failsafe
import java.util.UUID
import java.util.concurrent.atomic.AtomicInteger
import kotlin.coroutines.cancellation.CancellationException
Expand Down
6 changes: 3 additions & 3 deletions ...kotlin/io/redpulsar/core/locks/RedLock.kt → ...imadieiev/redpulsar/core/locks/RedLock.kt
View file
Original file line number Diff line number Diff line change
@@ -1,9 +1,9 @@
package io.redpulsar.core.locks
package me.himadieiev.redpulsar.core.locks

import io.redpulsar.core.locks.abstracts.AbstractMultyInstanceLock
import io.redpulsar.core.locks.abstracts.backends.LocksBackend
import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.Dispatchers
import me.himadieiev.redpulsar.core.locks.abstracts.AbstractMultyInstanceLock
import me.himadieiev.redpulsar.core.locks.abstracts.backends.LocksBackend
import kotlin.time.Duration
import kotlin.time.Duration.Companion.milliseconds

Expand Down
6 changes: 3 additions & 3 deletions ...tlin/io/redpulsar/core/locks/Semaphore.kt → ...adieiev/redpulsar/core/locks/Semaphore.kt
View file
Original file line number Diff line number Diff line change
@@ -1,9 +1,9 @@
package io.redpulsar.core.locks
package me.himadieiev.redpulsar.core.locks

import io.redpulsar.core.locks.abstracts.AbstractMultyInstanceLock
import io.redpulsar.core.locks.abstracts.backends.LocksBackend
import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.Dispatchers
import me.himadieiev.redpulsar.core.locks.abstracts.AbstractMultyInstanceLock
import me.himadieiev.redpulsar.core.locks.abstracts.backends.LocksBackend
import kotlin.time.Duration
import kotlin.time.Duration.Companion.milliseconds

Expand Down
6 changes: 3 additions & 3 deletions ...lin/io/redpulsar/core/locks/SimpleLock.kt → ...dieiev/redpulsar/core/locks/SimpleLock.kt
View file
Original file line number Diff line number Diff line change
@@ -1,9 +1,9 @@
package io.redpulsar.core.locks
package me.himadieiev.redpulsar.core.locks

import io.redpulsar.core.locks.abstracts.AbstractLock
import io.redpulsar.core.locks.abstracts.backends.LocksBackend
import kotlinx.coroutines.delay
import kotlinx.coroutines.runBlocking
import me.himadieiev.redpulsar.core.locks.abstracts.AbstractLock
import me.himadieiev.redpulsar.core.locks.abstracts.backends.LocksBackend
import kotlin.time.Duration
import kotlin.time.Duration.Companion.milliseconds

Expand Down
6 changes: 3 additions & 3 deletions ...lsar/core/locks/abstracts/AbstractLock.kt → ...lsar/core/locks/abstracts/AbstractLock.kt
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package io.redpulsar.core.locks.abstracts
package me.himadieiev.redpulsar.core.locks.abstracts

import io.redpulsar.core.locks.abstracts.backends.LocksBackend
import io.redpulsar.core.locks.api.Lock
import me.himadieiev.redpulsar.core.locks.abstracts.backends.LocksBackend
import me.himadieiev.redpulsar.core.locks.api.Lock
import mu.KotlinLogging
import java.util.UUID
import kotlin.time.Duration
Expand Down
4 changes: 2 additions & 2 deletions ...ks/abstracts/AbstractMultyInstanceLock.kt → ...ks/abstracts/AbstractMultyInstanceLock.kt
View file
Original file line number Diff line number Diff line change
@@ -1,12 +1,12 @@
package io.redpulsar.core.locks.abstracts
package me.himadieiev.redpulsar.core.locks.abstracts

import io.redpulsar.core.locks.abstracts.backends.LocksBackend
import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.Job
import kotlinx.coroutines.delay
import kotlinx.coroutines.joinAll
import kotlinx.coroutines.launch
import kotlinx.coroutines.runBlocking
import me.himadieiev.redpulsar.core.locks.abstracts.backends.LocksBackend
import java.util.concurrent.atomic.AtomicInteger
import kotlin.coroutines.cancellation.CancellationException
import kotlin.system.measureTimeMillis
Expand Down
4 changes: 2 additions & 2 deletions ...redpulsar/core/locks/abstracts/Backend.kt → ...redpulsar/core/locks/abstracts/Backend.kt
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package io.redpulsar.core.locks.abstracts
package me.himadieiev.redpulsar.core.locks.abstracts

import io.redpulsar.core.utils.failsafe
import kotlinx.coroutines.flow.Flow
import me.himadieiev.redpulsar.core.utils.failsafe
import java.util.NoSuchElementException

/**
Expand Down
4 changes: 2 additions & 2 deletions ...stracts/backends/CountDownLatchBackend.kt → ...stracts/backends/CountDownLatchBackend.kt
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package io.redpulsar.core.locks.abstracts.backends
package me.himadieiev.redpulsar.core.locks.abstracts.backends

import io.redpulsar.core.locks.abstracts.Backend
import kotlinx.coroutines.flow.Flow
import me.himadieiev.redpulsar.core.locks.abstracts.Backend
import kotlin.time.Duration

/**
Expand Down
4 changes: 2 additions & 2 deletions .../locks/abstracts/backends/LocksBackend.kt → .../locks/abstracts/backends/LocksBackend.kt
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
package io.redpulsar.core.locks.abstracts.backends
package me.himadieiev.redpulsar.core.locks.abstracts.backends

import io.redpulsar.core.locks.abstracts.Backend
import me.himadieiev.redpulsar.core.locks.abstracts.Backend
import kotlin.time.Duration

/**
Expand Down
2 changes: 1 addition & 1 deletion ...edpulsar/core/locks/api/CountDownLatch.kt → ...edpulsar/core/locks/api/CountDownLatch.kt
View file
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package io.redpulsar.core.locks.api
package me.himadieiev.redpulsar.core.locks.api

import kotlin.time.Duration

Expand Down
2 changes: 1 addition & 1 deletion ...otlin/io/redpulsar/core/locks/api/Lock.kt → ...madieiev/redpulsar/core/locks/api/Lock.kt
View file
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package io.redpulsar.core.locks.api
package me.himadieiev.redpulsar.core.locks.api

import kotlin.time.Duration
import kotlin.time.Duration.Companion.seconds
Expand Down
2 changes: 1 addition & 1 deletion ...ore/locks/excecutors/ExecutorAdditions.kt → ...ore/locks/excecutors/ExecutorAdditions.kt
View file
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package io.redpulsar.core.locks.excecutors
package me.himadieiev.redpulsar.core.locks.excecutors

import kotlinx.coroutines.Job
import kotlinx.coroutines.joinAll
Expand Down
8 changes: 4 additions & 4 deletions ...locks/excecutors/MultyInstanceExecutor.kt → ...locks/excecutors/MultyInstanceExecutor.kt
View file
Original file line number Diff line number Diff line change
@@ -1,12 +1,12 @@
package io.redpulsar.core.locks.excecutors
package me.himadieiev.redpulsar.core.locks.excecutors

import io.redpulsar.core.locks.abstracts.Backend
import io.redpulsar.core.utils.withRetry
import io.redpulsar.core.utils.withTimeoutInThread
import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.Job
import kotlinx.coroutines.launch
import kotlinx.coroutines.runBlocking
import me.himadieiev.redpulsar.core.locks.abstracts.Backend
import me.himadieiev.redpulsar.core.utils.withRetry
import me.himadieiev.redpulsar.core.utils.withTimeoutInThread
import java.util.Collections
import kotlin.system.measureTimeMillis
import kotlin.time.Duration
Expand Down
2 changes: 1 addition & 1 deletion ...otlin/io/redpulsar/core/utils/Failsafe.kt → ...madieiev/redpulsar/core/utils/Failsafe.kt
View file
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package io.redpulsar.core.utils
package me.himadieiev.redpulsar.core.utils

import mu.KotlinLogging

Expand Down
2 changes: 1 addition & 1 deletion ...tlin/io/redpulsar/core/utils/WithRetry.kt → ...adieiev/redpulsar/core/utils/WithRetry.kt
View file
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package io.redpulsar.core.utils
package me.himadieiev.redpulsar.core.utils

import kotlinx.coroutines.delay
import kotlinx.coroutines.runBlocking
Expand Down
2 changes: 1 addition & 1 deletion ...dpulsar/core/utils/WithTimeoutInThread.kt → ...dpulsar/core/utils/WithTimeoutInThread.kt
View file
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package io.redpulsar.core.utils
package me.himadieiev.redpulsar.core.utils

import mu.KotlinLogging

Expand Down
Loading

0 comments on commit 1c36420

Please sign in to comment.