Skip to content

Commit

Permalink
remove dead code
Browse files Browse the repository at this point in the history
  • Loading branch information
jakubwro committed Jan 27, 2024
1 parent 94acb94 commit 5068420
Show file tree
Hide file tree
Showing 3 changed files with 0 additions and 22 deletions.
1 change: 0 additions & 1 deletion src/jetstream/api/api.jl
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,6 @@ end
include("stream.jl")
include("consumer.jl")
include("errors.jl")
include("keyvalue.jl")
include("validate.jl")
include("show.jl")
include("convert.jl")
12 changes: 0 additions & 12 deletions src/jetstream/api/convert.jl
Original file line number Diff line number Diff line change
Expand Up @@ -29,15 +29,3 @@ function convert(::Type{Union{T, ApiError}}, msg::NATS.Msg) where { T <: ApiResp
StructTypes.constructfrom(T, response)
end
end

function convert(::Type{KeyValueEntry}, msg::NATS.Msg)
splitted = split(msg.reply_to, ".")
bucket = splitted[3]
key = msg.subject
value = NATS.payload(msg)
_, _, stream, cons, _, seq, _, nanos, rem = splitted
seq = splitted[7]
revision = splitted[6]

KeyValueEntry(bucket, key, value, parse(UInt64, seq), NanoDate(), 0, :none)
end
9 changes: 0 additions & 9 deletions src/jetstream/api/keyvalue.jl

This file was deleted.

0 comments on commit 5068420

Please sign in to comment.