diff --git a/jetstream/src/internal_mod.ts b/jetstream/src/internal_mod.ts index 15fb2e72..8b391fcf 100644 --- a/jetstream/src/internal_mod.ts +++ b/jetstream/src/internal_mod.ts @@ -85,6 +85,7 @@ export type { export type { StreamNames } from "./jsbaseclient_api.ts"; export type { AccountLimits, + ApiError, ApiPagedRequest, ClusterInfo, ConsumerConfig, diff --git a/jetstream/src/mod.ts b/jetstream/src/mod.ts index 3bcb2d7e..7c313a65 100644 --- a/jetstream/src/mod.ts +++ b/jetstream/src/mod.ts @@ -39,6 +39,7 @@ export type { AbortOnMissingResource, AccountLimits, Advisory, + ApiError, ApiPagedRequest, Bind, BoundPushConsumerOptions, diff --git a/kv/src/kv.ts b/kv/src/kv.ts index 9878a96c..6f03b708 100644 --- a/kv/src/kv.ts +++ b/kv/src/kv.ts @@ -78,7 +78,6 @@ import type { KvEntry, KvOptions, KvPutOptions, - KvRemove, KvStatus, KvWatchEntry, KvWatchOptions, @@ -263,7 +262,7 @@ export class Kvm { } } -export class Bucket implements KV, KvRemove { +export class Bucket implements KV { js: JetStreamClient; jsm: JetStreamManager; stream!: string; @@ -328,20 +327,11 @@ export class Bucket implements KV, KvRemove { this.stream = sc.name = opts.streamName ?? this.bucketName(); sc.retention = RetentionPolicy.Limits; sc.max_msgs_per_subject = bo.history; - if (bo.maxBucketSize) { - bo.max_bytes = bo.maxBucketSize; - } if (bo.max_bytes) { sc.max_bytes = bo.max_bytes; } sc.max_msg_size = bo.maxValueSize; sc.storage = bo.storage; - const location = opts.placementCluster ?? ""; - if (location) { - opts.placement = {} as Placement; - opts.placement.cluster = location; - opts.placement.tags = []; - } if (opts.placement) { sc.placement = opts.placement; } diff --git a/kv/src/types.ts b/kv/src/types.ts index d963c6f6..ff4db821 100644 --- a/kv/src/types.ts +++ b/kv/src/types.ts @@ -86,10 +86,7 @@ export interface KvLimits { * The maximum number of bytes on the KV */ max_bytes: number; - /** - * @deprecated use max_bytes - */ - maxBucketSize: number; + /** * The maximum size of a value on the KV */ @@ -121,10 +118,6 @@ export interface KvLimits { * List of Stream names to replicate into this KV */ sources?: StreamSource[]; - /** - * @deprecated: use placement - */ - placementCluster: string; /** * deprecated: use storage @@ -149,12 +142,6 @@ export interface KvStatus extends KvLimits { */ values: number; - /** - * @deprecated - * FIXME: remove this on 1.8 - */ - bucket_location: string; - /** * The StreamInfo backing up the KV */ @@ -203,13 +190,6 @@ export interface KvOptions extends KvLimits { metadata?: Record; } -/** - * @deprecated use purge(k) - */ -export interface KvRemove { - remove(k: string): Promise; -} - export enum KvWatchInclude { /** * Include the last value for all the keys @@ -281,11 +261,6 @@ export interface RoKV { opts?: KvWatchOptions, ): Promise>; - /** - * @deprecated - this api is removed. - */ - close(): Promise; - /** * Returns information about the Kv */ diff --git a/obj/src/internal_mod.ts b/obj/src/internal_mod.ts index 97c06244..6e950a37 100644 --- a/obj/src/internal_mod.ts +++ b/obj/src/internal_mod.ts @@ -8,6 +8,7 @@ export type { ObjectStoreOptions, ObjectStorePutOpts, ObjectStoreStatus, + ObjectWatchInfo, Placement, } from "./types.ts"; diff --git a/obj/src/mod.ts b/obj/src/mod.ts index 786eb6a6..1a1fc163 100644 --- a/obj/src/mod.ts +++ b/obj/src/mod.ts @@ -8,6 +8,7 @@ export type { ObjectStoreOptions, ObjectStorePutOpts, ObjectStoreStatus, + ObjectWatchInfo, Placement, } from "./internal_mod.ts"; diff --git a/obj/src/types.ts b/obj/src/types.ts index 440e99f6..d8158341 100644 --- a/obj/src/types.ts +++ b/obj/src/types.ts @@ -161,10 +161,7 @@ export type ObjectStoreStatus = { */ compression: boolean; }; -/** - * @deprecated {@link ObjectStoreStatus} - */ -export type ObjectStoreInfo = ObjectStoreStatus; + export type ObjectStoreOptions = { /** * A description for the object store