kvdb

type Config struct {
	// common
	Endpoints []string `json:"endpoints"`
	Username  string   `json:"username"`
	Password  string   `json:"password"`
	// Etcd tls
	Tls *TlsConfig `json:"tls"`
}

type Database interface {
	// Get values from database by key
	Get(ctx context.Context, key string) (v []*KV, err error)
	// GetPrefix values from database by prefixed key
	GetPrefix(ctx context.Context, key string) (v []*KV, err error)
	// Set value to database
	Set(ctx context.Context, key string, value interface{}, opts ...SetOption) (err error)
	// Delete value from database
	Delete(ctx context.Context, key string) (err error)
	// Watch database changes
	Watch(ctx context.Context, key string, handler WatchHandler) (err error)
	// Locker distribute lock
	Locker(ctx context.Context, topic string) (locker sync.Locker, err error)
}

type Etcd struct {
	// contains filtered or unexported fields
}

type Event struct {
	KV
	Type EventType
}

type EventType string

type KV struct {
	Key   string
	Value *g.Var
}

type Message struct {
	Id        string `json:"id"`
	Topic     string `json:"topic"`
	Payload   any    `json:"payload"`
	From      string `json:"from"`
	ExpiredAt int64  `json:"expired_at"`
	HasAck    bool   `json:"has_ack"`
	Err       string `json:"err"`
}

type MessageHandler interface {
	Handle(ctx context.Context, msg *Message)
	After(ctx context.Context, msg *Message)
}

type Mutex struct {
	sync.Locker
	// contains filtered or unexported fields
}

type SetOption func(cfg *setConfig)

type Storage interface {
	// Get value
	Get(ctx context.Context, key ...string) (v []*KV, err error)
	// Set value
	Set(ctx context.Context, key string, value interface{}) (err error)
	// SetTTL set value with ttl in second
	SetTTL(ctx context.Context, key string, value interface{}, ttl int64, keepalive ...bool) (err error)
	// Delete value
	Delete(ctx context.Context, key string) (err error)
}

type StorageConfig struct {
	Separator string `json:"separator"`
}

type StorageEventHandler func(t EventType, key string, value interface{})

type TlsConfig struct {
	InsecureSkipVerify bool `json:"insecure_skip_verify"`
}

type WatchHandler func(ctx context.Context, e Event)