store

Documentation

Index

• func AddValue(bucket string, key []byte, value []byte) error
• func AddValueCompress(bucket string, key []byte, value []byte) error
• func Count(o interface{}) (int, error)
• func Create(o interface{}) error
• func Delete(o interface{}) error
• func DeleteBucket(bucket string, key []byte, value []byte) error
• func DeleteValue(bucket string, key []byte, value []byte) error
• func Get(o interface{}) error
• func GetBy(field string, value interface{}, to interface{}) error
• func GetCompressedValue(bucket string, key []byte) []byte
• func GetValue(bucket string, key []byte) []byte
• func RegisterDBConnection(h *gorm.DB)
• func RegisterKVStoreHandler(h KVStore)
• func Save(o interface{}) error
• func Update(o interface{}) error
• type Cond
• type KVStore
• type ORM
• type Query
• type Result
  • func Search(o interface{}, q *Query) (error, Result)

Functions

func AddValue

func AddValue(bucket string, key []byte, value []byte) error

func AddValueCompress

func AddValueCompress(bucket string, key []byte, value []byte) error

func Count

func Count(o interface{}) (int, error)

func Create

func Create(o interface{}) error

func Delete

func Delete(o interface{}) error

func DeleteBucket

func DeleteBucket(bucket string, key []byte, value []byte) error

func DeleteValue

func DeleteValue(bucket string, key []byte, value []byte) error

func Get

func Get(o interface{}) error

func GetBy

func GetBy(field string, value interface{}, to interface{}) error

func GetCompressedValue

func GetCompressedValue(bucket string, key []byte) []byte

func GetValue

func GetValue(bucket string, key []byte) []byte

func RegisterDBConnection

func RegisterDBConnection(h *gorm.DB)

func RegisterKVStoreHandler

func RegisterKVStoreHandler(h KVStore)

func Save

func Save(o interface{}) error

func Update

func Update(o interface{}) error

Types

type Cond

type Cond struct {
	Name  string
	Value interface{}
}

type KVStore

type KVStore interface {
	Open() error

	Close() error

	GetValue(bucket string, key []byte) []byte

	GetCompressedValue(bucket string, key []byte) []byte

	AddValueCompress(bucket string, key []byte, value []byte) error

	AddValue(bucket string, key []byte, value []byte) error

	DeleteValue(bucket string, key []byte, value []byte) error

	DeleteBucket(bucket string, key []byte, value []byte) error
}

type ORM

type ORM interface {
	Save(o interface{}) error

	Update(o interface{}) error

	Delete(o interface{}) error

	Search(o interface{}, q *Query) (error, Result)

	Get(key string, value interface{}, to interface{}) error

	Count(o interface{}) (int, error)
}

type Query

type Query struct {
	Sort   string
	From   int
	Size   int
	Filter *Cond
}

type Result

type Result struct {
	Total  int
	Result interface{}
}

func Search

func Search(o interface{}, q *Query) (error, Result)