Skip to content

Commit 924f8ed

Browse files
kennethshackletonkennethshackleton
committed
Move pushiko-pools types under com.bloomberg.pushiko.pools
Signed-off-by: kshackleton1 <kshackleton1@bloomberg.net>
1 parent 746c2c0 commit 924f8ed

22 files changed

Lines changed: 30 additions & 30 deletions

File tree

‎pushiko-http/src/main/kotlin/com/bloomberg/pushiko/http/HttpClient.kt‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ import com.bloomberg.pushiko.commons.slf4j.Logger
2020
import com.bloomberg.pushiko.http.HttpClientProperties.Companion.OptionalHttpProperties
2121
import com.bloomberg.pushiko.http.exceptions.HttpClientClosedException
2222
import com.bloomberg.pushiko.http.netty.ChannelPool
23-
import com.bloomberg.pushiko.pool.exceptions.PoolClosedException
23+
import com.bloomberg.pushiko.pools.exceptions.PoolClosedException
2424
import io.netty.channel.EventLoopGroup
2525
import io.netty.handler.codec.http2.Http2Exception
2626
import io.netty.handler.codec.http2.Http2FrameLogger

‎pushiko-http/src/main/kotlin/com/bloomberg/pushiko/http/netty/ChannelPool.kt‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -41,8 +41,8 @@ package com.bloomberg.pushiko.http.netty
4141
import com.bloomberg.pushiko.health.Health
4242
import com.bloomberg.pushiko.health.Status
4343
import com.bloomberg.pushiko.http.IHttpClientProperties
44-
import com.bloomberg.pushiko.pool.CommonMuxPool
45-
import com.bloomberg.pushiko.pool.PoolConfiguration
44+
import com.bloomberg.pushiko.pools.CommonMuxPool
45+
import com.bloomberg.pushiko.pools.PoolConfiguration
4646
import io.netty.channel.Channel
4747
import io.netty.channel.EventLoopGroup
4848
import io.netty.handler.codec.http2.Http2FrameLogger

‎pushiko-http/src/main/kotlin/com/bloomberg/pushiko/http/netty/PoolableChannel.kt‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,8 +18,8 @@ package com.bloomberg.pushiko.http.netty
1818

1919
import com.bloomberg.pushiko.http.ConcurrentRequestWaterMark
2020
import com.bloomberg.pushiko.http.IHttpClientProperties
21-
import com.bloomberg.pushiko.pool.Poolable
22-
import com.bloomberg.pushiko.pool.WaterMarkScaleFactor
21+
import com.bloomberg.pushiko.pools.Poolable
22+
import com.bloomberg.pushiko.pools.WaterMarkScaleFactor
2323
import io.netty.channel.Channel
2424
import io.netty.handler.codec.http2.StreamBufferingEncoder
2525
import io.netty.util.AttributeKey

‎pushiko-http/src/main/kotlin/com/bloomberg/pushiko/http/netty/PoolableChannelFactory.kt‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,8 +17,8 @@
1717
package com.bloomberg.pushiko.http.netty
1818

1919
import com.bloomberg.pushiko.http.IHttpClientProperties
20-
import com.bloomberg.pushiko.pool.Factory
21-
import com.bloomberg.pushiko.pool.Recycler
20+
import com.bloomberg.pushiko.pools.Factory
21+
import com.bloomberg.pushiko.pools.Recycler
2222
import io.netty.channel.Channel
2323
import javax.annotation.concurrent.ThreadSafe
2424

‎pushiko-http/src/test/kotlin/com/bloomberg/pushiko/http/netty/ChannelSuspendPoolTest.kt‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,8 +16,8 @@
1616

1717
package com.bloomberg.pushiko.http.netty
1818

19-
import com.bloomberg.pushiko.pool.PoolConfiguration
20-
import com.bloomberg.pushiko.pool.exceptions.PoolClosedException
19+
import com.bloomberg.pushiko.pools.PoolConfiguration
20+
import com.bloomberg.pushiko.pools.exceptions.PoolClosedException
2121
import io.netty.channel.Channel
2222
import kotlinx.coroutines.Dispatchers
2323
import kotlinx.coroutines.ExperimentalCoroutinesApi

pushiko-pools/src/main/java/com/bloomberg/pushiko/pool/LazyPoolFactory.java renamed to pushiko-pools/src/main/java/com/bloomberg/pushiko/pools/LazyPoolFactory.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
* limitations under the License.
1515
*/
1616

17-
package com.bloomberg.pushiko.pool;
17+
package com.bloomberg.pushiko.pools;
1818

1919
import org.jetbrains.annotations.NotNull;
2020
import org.jetbrains.annotations.Nullable;

pushiko-pools/src/main/kotlin/com/bloomberg/pushiko/pool/CommonMuxPool.kt renamed to pushiko-pools/src/main/kotlin/com/bloomberg/pushiko/pools/CommonMuxPool.kt

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -36,14 +36,14 @@
3636
* THE SOFTWARE.
3737
*/
3838

39-
package com.bloomberg.pushiko.pool
39+
package com.bloomberg.pushiko.pools
4040

4141
import com.bloomberg.pushiko.commons.FifoBuffer
4242
import com.bloomberg.pushiko.commons.removeUntil
4343
import com.bloomberg.pushiko.commons.removeUntilInclusiveOrNull
4444
import com.bloomberg.pushiko.commons.slf4j.Logger
4545
import com.bloomberg.pushiko.commons.strings.commonPluralSuffix
46-
import com.bloomberg.pushiko.pool.exceptions.PendingAcquisitionLimitException
46+
import com.bloomberg.pushiko.pools.exceptions.PendingAcquisitionLimitException
4747
import kotlinx.coroutines.CancellableContinuation
4848
import kotlinx.coroutines.CoroutineStart
4949
import kotlinx.coroutines.Job

pushiko-pools/src/main/kotlin/com/bloomberg/pushiko/pool/Factory.kt renamed to pushiko-pools/src/main/kotlin/com/bloomberg/pushiko/pools/Factory.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
* limitations under the License.
1515
*/
1616

17-
package com.bloomberg.pushiko.pool
17+
package com.bloomberg.pushiko.pools
1818

1919
interface Factory<P : Any> {
2020
val allocations: Int

pushiko-pools/src/main/kotlin/com/bloomberg/pushiko/pool/LazyPool.kt renamed to pushiko-pools/src/main/kotlin/com/bloomberg/pushiko/pools/LazyPool.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
* limitations under the License.
1515
*/
1616

17-
package com.bloomberg.pushiko.pool
17+
package com.bloomberg.pushiko.pools
1818

1919
import kotlinx.coroutines.Dispatchers
2020
import kotlinx.coroutines.asCoroutineDispatcher

pushiko-pools/src/main/kotlin/com/bloomberg/pushiko/pool/PoolConfiguration.kt renamed to pushiko-pools/src/main/kotlin/com/bloomberg/pushiko/pools/PoolConfiguration.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
* limitations under the License.
1515
*/
1616

17-
package com.bloomberg.pushiko.pool
17+
package com.bloomberg.pushiko.pools
1818

1919
import javax.annotation.concurrent.ThreadSafe
2020
import kotlin.time.Duration

0 commit comments

Comments
 (0)