xdb

Documentation

Index

• Constants
• func BackCient(name string, c *Client) bool
• func InitClientPool(name string, uri string, count uint8) error
• type Client
  • func GetClient(name string) (c *Client, err error)
  • func NewClient(name, uri string) (*Client, error)
  • func (This *Client) Close() error
  • func (This *Client) DelKeyVal(table, key string) error
  • func (This *Client) GetKeyVal(table, key string, data interface{}) ([]byte, error)
  • func (This *Client) GetKeyValBytes(table, key string) ([]byte, error)
  • func (This *Client) GetListByKeyPrefix(table, key string, data interface{}) ([]driver.ListValue, error)
  • func (This *Client) PutKeyVal(table, key string, data interface{}) error
  • func (This *Client) PutKeyValBytes(table, key string, val []byte) error
  • func (This *Client) SetPrefix(prefix string) *Client
• type PoolClient

Constants

const DEFAULT_PREFIX = "xdb"

Functions

func BackCient

func BackCient(name string, c *Client) bool

func InitClientPool

func InitClientPool(name string, uri string, count uint8) error

Types

type Client

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

func GetClient

func GetClient(name string) (c *Client, err error)

func NewClient

func NewClient(name, uri string) (*Client, error)

func (*Client) Close

func (This *Client) Close() error

func (*Client) DelKeyVal

func (This *Client) DelKeyVal(table, key string) error

func (*Client) GetKeyVal

func (This *Client) GetKeyVal(table, key string, data interface{}) ([]byte, error)

func (*Client) GetKeyValBytes

func (This *Client) GetKeyValBytes(table, key string) ([]byte, error)

func (*Client) GetListByKeyPrefix

func (This *Client) GetListByKeyPrefix(table, key string, data interface{}) ([]driver.ListValue, error)

func (*Client) PutKeyVal

func (This *Client) PutKeyVal(table, key string, data interface{}) error

func (*Client) PutKeyValBytes

func (This *Client) PutKeyValBytes(table, key string, val []byte) error

func (*Client) SetPrefix

func (This *Client) SetPrefix(prefix string) *Client

type PoolClient

type PoolClient struct {
	sync.RWMutex
	ClientChan         chan *Client
	Uri                string
	MaxClientCount     uint8
	CurrentClientCount uint8
	AvailableCount     uint8
}