kvdb

Apr 29, 2022

Changes in this version

+ func AreEqual(c *ClientConfig, d *ClientConfig) bool

+ func Open(ctx context.Context, cfg *ClientConfig) (keyvalue.Connection, error)

type ClientConfig

+ func (c *ClientConfig) Hash() uint32

type Option

+ func Connection(c keyvalue.Connection) Option

Mar 13, 2022

Changes in this version

+ const DefaultInsertCapacity

type Option

+ func InsertCapacity(n int) Option

Feb 22, 2022

Changes in this version

type ClientConfig

+ SSLDisabled bool

Nov 26, 2021

Changes in this version

type ClientConfig

+ MaxMessageSize int

Nov 22, 2021

Changes in this version

type Client

+ func (c *Client) AddKeys(ctx context.Context, dbName string, tableName string, rec record.Record) error

+ func (c *Client) DeleteKeys(ctx context.Context, dbName string, tableName string, keys []string) error

+ func (c *Client) RenameTable(ctx context.Context, dbName string, oldname string, newname string) error

Feb 25, 2021

Changes in this version

+ const DefaultMaxMessageSize

+ const DefaultReadBufferSize

+ const DefaultTCPPort

+ const DefaultWSPort

+ const DefaultWriteBufferSize

+ var ErrNilConfiguration = errors.New("illegal nil configuration data")

+ type Client struct

+ func NewClient(ctx context.Context, cfg *ClientConfig) (*Client, error)

+ func (c *Client) AddIndex(ctx context.Context, dbName string, tableName string, key string) error

+ func (c *Client) AddUniqueIndex(ctx context.Context, dbName string, tableName string, key string) error

+ func (c *Client) Close() error

+ func (c *Client) CountWhere(ctx context.Context, dbName string, tableName string, cond condition.Condition) (int64, error)

+ func (c *Client) CreateTable(ctx context.Context, dbName string, name string, template record.Record) error

+ func (c *Client) DeleteIndex(ctx context.Context, dbName string, tableName string, key string) error

+ func (c *Client) DeleteTable(ctx context.Context, dbName string, name string) error

+ func (c *Client) DeleteWhere(ctx context.Context, dbName string, tableName string, cond condition.Condition) (int64, error)

+ func (c *Client) DescribeTable(ctx context.Context, dbName string, tableName string) (record.Record, error)

+ func (c *Client) Insert(ctx context.Context, dbName string, tableName string, itr record.Iterator) (err error)

+ func (c *Client) InsertRecords(ctx context.Context, dbName string, tableName string, rs ...record.Record) (err error)

+ func (c *Client) ListIndices(ctx context.Context, dbName string, tableName string) ([]string, error)

+ func (c *Client) ListTables(ctx context.Context, dbName string) ([]string, error)

+ func (c *Client) SelectWhere(ctx context.Context, dbName string, tableName string, template record.Record, ...) (record.Iterator, error)

+ func (c *Client) SelectWhereLimit(ctx context.Context, dbName string, tableName string, template record.Record, ...) (record.Iterator, error)

+ func (c *Client) UpdateWhere(ctx context.Context, dbName string, tableName string, ...) (int64, error)

+ type ClientConfig struct

+ Address *address.Address

+ AppName string

+ SSLCert []byte

+ func DefaultConfig() *ClientConfig

+ func SetDefaultConfig(c *ClientConfig) *ClientConfig

+ func (c *ClientConfig) Copy() *ClientConfig

+ func (c *ClientConfig) URI() string

+ func (c *ClientConfig) URL(dbName string) string

+ func (c *ClientConfig) Validate() error

+ type DatabaseDriverFunc func(context.Context, string) (string, error)

+ type Option interface

+ func AddHandler(h handler.Interface) Option

+ func DatabaseDriver(f DatabaseDriverFunc) Option

+ func MaxMessageSize(size int) Option

+ func ReadBufferSize(size int) Option

+ func SSLCertAndKey(crt []byte, key []byte) Option

+ func WriteBufferSize(size int) Option

+ type Server struct

+ func New(options ...Option) (*Server, error)