mirror of
https://github.com/hanzoai/psrpc.git
synced 2026-09-30 23:47:22 +00:00
zeekayandHanzo Dev
a58f1a5f91
hanzokv/go v9.22.0 renames its Go package from `redis` to `kv` (import path unchanged). Follow that through the fork so there is one vocabulary for the key-value bus: - bus_redis.go -> bus_kv.go, bus_redis_test.go -> bus_kv_test.go, bustest/redis.go -> bustest/kv.go - redisMessageBus -> kvMessageBus, and the same for its subscription, sublist, write-op, publish-queue and bustest server types - psrpc.NewRedisMessageBus -> psrpc.NewKVMessageBus, bus.NewRedisMessageBus -> bus.NewKVMessageBus - log messages and README say kv The dockertest image stays `redis:latest` and the pipelining doc link stays on redis.io: those name third-party artifacts, not our types. Co-authored-by: Hanzo Dev <[email protected]>
38 lines
1.0 KiB
Go
38 lines
1.0 KiB
Go
// Copyright 2023 LiveKit, Inc.
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
package psrpc
|
|
|
|
import (
|
|
"github.com/hanzokv/go/v9"
|
|
"github.com/nats-io/nats.go"
|
|
|
|
"github.com/hanzoai/psrpc/internal/bus"
|
|
)
|
|
|
|
type Channel = bus.Channel
|
|
type MessageBus bus.MessageBus
|
|
|
|
func NewLocalMessageBus() MessageBus {
|
|
return bus.NewLocalMessageBus()
|
|
}
|
|
|
|
func NewNatsMessageBus(nc *nats.Conn) MessageBus {
|
|
return bus.NewNatsMessageBus(nc)
|
|
}
|
|
|
|
func NewKVMessageBus(rc kv.UniversalClient) MessageBus {
|
|
return bus.NewKVMessageBus(rc)
|
|
}
|