blob: a8e631147427fcb48d3c6c20f25b2acf3aee77a4 [file] [log] [blame]
/*
* Copyright 2018-present Open Networking Foundation
* 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 kvstore
import (
"github.com/opencord/voltha-go/common/log"
)
const (
// Default timeout in seconds when making a kvstore request
defaultKVGetTimeout = 5
// Maximum channel buffer between publisher/subscriber goroutines
maxClientChannelBufferSize = 10
)
// These constants represent the event types returned by the KV client
const (
PUT = iota
DELETE
CONNECTIONDOWN
UNKNOWN
)
// KVPair is a common wrapper for key-value pairs returned from the KV store
type KVPair struct {
Key string
Value interface{}
Session string
Lease int64
}
func init() {
log.AddPackage(log.JSON, log.WarnLevel, nil)
}
// NewKVPair creates a new KVPair object
func NewKVPair(key string, value interface{}, session string, lease int64) *KVPair {
kv := new(KVPair)
kv.Key = key
kv.Value = value
kv.Session = session
kv.Lease = lease
return kv
}
// Event is generated by the KV client when a key change is detected
type Event struct {
EventType int
Key interface{}
Value interface{}
}
// NewEvent creates a new Event object
func NewEvent(eventType int, key interface{}, value interface{}) *Event {
evnt := new(Event)
evnt.EventType = eventType
evnt.Key = key
evnt.Value = value
return evnt
}
// Client represents the set of APIs a KV Client must implement
type Client interface {
List(key string, timeout int, lock ...bool) (map[string]*KVPair, error)
Get(key string, timeout int, lock ...bool) (*KVPair, error)
Put(key string, value interface{}, timeout int, lock ...bool) error
Delete(key string, timeout int, lock ...bool) error
Reserve(key string, value interface{}, ttl int64) (interface{}, error)
ReleaseReservation(key string) error
ReleaseAllReservations() error
RenewReservation(key string) error
Watch(key string) chan *Event
CloseWatch(key string, ch chan *Event)
Close()
}