Skip to content

Commit ebe784e

Browse files
authored
Merge pull request #96 from LavaGames/main
handle cases where bucket or entry doesn't exist
2 parents 270a14b + 9c8689b commit ebe784e

File tree

2 files changed

+12
-0
lines changed

2 files changed

+12
-0
lines changed

jetstream/resource_kv_bucket.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -172,6 +172,10 @@ func resourceKVBucketRead(d *schema.ResourceData, m any) error {
172172
}
173173
bucket, err := js.KeyValue(name)
174174
if err != nil {
175+
if err == nats.ErrBucketNotFound {
176+
d.SetId("")
177+
return nil
178+
}
175179
return err
176180
}
177181
status, err := bucket.Status()

jetstream/resource_kv_entry.go

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -93,10 +93,18 @@ func resourceKVEntryRead(d *schema.ResourceData, m any) error {
9393
}
9494
kv, err := js.KeyValue(bucket)
9595
if err != nil {
96+
if err == nats.ErrBucketNotFound {
97+
d.SetId("")
98+
return nil
99+
}
96100
return err
97101
}
98102
entry, err := kv.Get(key)
99103
if err != nil {
104+
if err == nats.ErrKeyNotFound {
105+
d.SetId("")
106+
return nil
107+
}
100108
return err
101109
}
102110

0 commit comments

Comments
 (0)