lynkstor

package
v0.0.0-...-2f947a5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 24, 2019 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config 

type Config struct {

	// Database server hostname or IP. Leave blank if using unix sockets
	Host string `json:"host"`

	// Database server port. Leave blank if using unix sockets
	Port uint16 `json:"port"`

	// Password for authentication
	Auth string `json:"auth"`

	// A path of a UNIX socket file. Leave blank if using host and port
	Socket string `json:"socket"`

	// The connection timeout to a redis host (seconds)
	Timeout int `json:"timeout"`

	// Maximum number of connections
	MaxConn int `json:"maxconn"`
}

func NewConfig 

func NewConfig(copts connect.ConnOptions) Config

type Connector 

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

func NewConnector 

func NewConnector(cfg Config) (*Connector, error)

func (*Connector) Close 

func (c *Connector) Close() error

func (*Connector) Cmd 

func (c *Connector) Cmd(cmd string, args ...interface{}) skv.Result

func (*Connector) FoFileOpen 

func (cn *Connector) FoFileOpen(path string) (io.ReadSeeker, error)

func (*Connector) FoFilePut 

func (cn *Connector) FoFilePut(src_path, dst_path string) skv.Result

func (*Connector) FoGet 

func (cn *Connector) FoGet(path_key string) skv.Result

func (*Connector) FoMpGet 

func (cn *Connector) FoMpGet(sets skv.FileObjectEntryBlock) skv.Result

func (*Connector) FoMpInit 

func (cn *Connector) FoMpInit(sets skv.FileObjectEntryInit) skv.Result

func (*Connector) FoMpPut 

func (cn *Connector) FoMpPut(sets skv.FileObjectEntryBlock) skv.Result

func (*Connector) FoRevScan 

func (cn *Connector) FoRevScan(offset, cutset string, limit int) skv.Result

func (*Connector) FoScan 

func (cn *Connector) FoScan(offset, cutset string, limit int) skv.Result

func (*Connector) KvDel 

func (c *Connector) KvDel(keys ...[]byte) skv.Result

func (*Connector) KvGet 

func (c *Connector) KvGet(key []byte) skv.Result

func (*Connector) KvIncr 

func (c *Connector) KvIncr(key []byte, increment int64) skv.Result

func (*Connector) KvMeta 

func (c *Connector) KvMeta(key []byte) skv.Result

func (*Connector) KvNew 

func (c *Connector) KvNew(key []byte, value interface{}, opts *skv.KvWriteOptions) skv.Result

func (*Connector) KvProgDel 

func (cn *Connector) KvProgDel(key skv.KvProgKey, opts *skv.KvProgWriteOptions) skv.Result

func (*Connector) KvProgGet 

func (cn *Connector) KvProgGet(key skv.KvProgKey) skv.Result

func (*Connector) KvProgIncr 

func (cn *Connector) KvProgIncr(key skv.KvProgKey, incr int64) skv.Result

func (*Connector) KvProgMeta 

func (cn *Connector) KvProgMeta(key skv.KvProgKey) skv.Result

func (*Connector) KvProgNew 

func (cn *Connector) KvProgNew(key skv.KvProgKey, val skv.KvEntry, opts *skv.KvProgWriteOptions) skv.Result

func (*Connector) KvProgPut 

func (cn *Connector) KvProgPut(key skv.KvProgKey, val skv.KvEntry, opts *skv.KvProgWriteOptions) skv.Result

func (*Connector) KvProgRevScan 

func (cn *Connector) KvProgRevScan(offset, cutset skv.KvProgKey, limit int) skv.Result

func (*Connector) KvProgScan 

func (cn *Connector) KvProgScan(offset, cutset skv.KvProgKey, limit int) skv.Result

func (*Connector) KvPut 

func (c *Connector) KvPut(key []byte, value interface{}, opts *skv.KvWriteOptions) skv.Result

func (*Connector) KvRevScan 

func (c *Connector) KvRevScan(offset, cutset []byte, limit int) skv.Result

func (*Connector) KvScan 

func (c *Connector) KvScan(offset, cutset []byte, limit int) skv.Result

func (*Connector) PvDel 

func (cn *Connector) PvDel(path string, opts *skv.KvProgWriteOptions) skv.Result

func (*Connector) PvGet 

func (cn *Connector) PvGet(path string) skv.Result

func (*Connector) PvNew 

func (cn *Connector) PvNew(path string, value interface{}, opts *skv.KvProgWriteOptions) skv.Result

func (*Connector) PvPut 

func (cn *Connector) PvPut(path string, value interface{}, opts *skv.KvProgWriteOptions) skv.Result

func (*Connector) PvRevScan 

func (cn *Connector) PvRevScan(fold, offset, cutset string, limit int) skv.Result

func (*Connector) PvScan 

func (cn *Connector) PvScan(fold, offset, cutset string, limit int) skv.Result

type FoReadSeeker 

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

func (*FoReadSeeker) Read 

func (fo *FoReadSeeker) Read(b []byte) (n int, err error)

func (*FoReadSeeker) Seek 

func (fo *FoReadSeeker) Seek(offset int64, whence int) (int64, error)

type Result 

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

func (*Result) Bool 

func (rs *Result) Bool() bool

func (*Result) Bytes 

func (rs *Result) Bytes() []byte

func (*Result) Bytex 

func (rs *Result) Bytex() types.Bytex

func (*Result) Decode 

func (rs *Result) Decode(obj interface{}) error

func (*Result) ErrorString 

func (rs *Result) ErrorString() string

func (*Result) Float32 

func (rs *Result) Float32() float32

func (*Result) Float64 

func (rs *Result) Float64() float64

func (*Result) Int 

func (rs *Result) Int() int

func (*Result) Int16 

func (rs *Result) Int16() int16

func (*Result) Int32 

func (rs *Result) Int32() int32

func (*Result) Int64 

func (rs *Result) Int64() int64

func (*Result) Int8 

func (rs *Result) Int8() int8

func (*Result) KvEach 

func (rs *Result) KvEach(fn func(entry *skv.ResultEntry) int) int

func (*Result) KvEntry 

func (rs *Result) KvEntry(i int) *skv.ResultEntry

func (*Result) KvKey 

func (rs *Result) KvKey() []byte

func (*Result) KvLen 

func (rs *Result) KvLen() int

func (*Result) KvList 

func (rs *Result) KvList() []*skv.ResultEntry

func (*Result) KvPairs 

func (rs *Result) KvPairs() []skv.Result

func (*Result) KvSize 

func (rs *Result) KvSize() int

func (*Result) List 

func (rs *Result) List() []skv.Result

func (*Result) ListLen 

func (rs *Result) ListLen() int

func (*Result) Meta 

func (rs *Result) Meta() *skv.KvMeta

func (*Result) NotFound 

func (rs *Result) NotFound() bool

func (*Result) OK 

func (rs *Result) OK() bool

func (*Result) Status 

func (rs *Result) Status() uint8

func (*Result) String 

func (rs *Result) String() string

func (*Result) Uint 

func (rs *Result) Uint() uint

func (*Result) Uint16 

func (rs *Result) Uint16() uint16

func (*Result) Uint32 

func (rs *Result) Uint32() uint32

func (*Result) Uint64 

func (rs *Result) Uint64() uint64

func (*Result) Uint8 

func (rs *Result) Uint8() uint8

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.