Documentation
¶
Index ¶
- Constants
- type Connection
- func (con *Connection) Del(k string) error
- func (con *Connection) DropIndex(name string) error
- func (con *Connection) Get(k string) (string, time.Duration, error)
- func (con *Connection) GetBroadcasts(overhead, limit int) [][]byte
- func (con *Connection) Indexes() []query.Index
- func (con *Connection) LocalState(join bool) []byte
- func (con *Connection) MergeRemoteState(buf []byte, join bool)
- func (con *Connection) Name() string
- func (con *Connection) NodeMeta(limit int) []byte
- func (con *Connection) NotifyMsg(bytes []byte)
- func (con *Connection) Search(index string, criteria *query.Criteria) ([]query.Row, error)
- func (con *Connection) Set(k, v string) error
- func (con *Connection) SetWithTtl(k, v string, ttl time.Duration) error
- func (con *Connection) Shutdown()
- func (con *Connection) UpsertIndex(index query.Index) error
Constants ¶
View Source
const DefaultPort = 6080
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Connection ¶
type Connection struct {
// contains filtered or unexported fields
}
func NewConnection ¶
func NewConnection(address []string) (*Connection, error)
func (*Connection) Del ¶
func (con *Connection) Del(k string) error
func (*Connection) DropIndex ¶
func (con *Connection) DropIndex(name string) error
func (*Connection) GetBroadcasts ¶
func (con *Connection) GetBroadcasts(overhead, limit int) [][]byte
func (*Connection) Indexes ¶
func (con *Connection) Indexes() []query.Index
func (*Connection) LocalState ¶
func (con *Connection) LocalState(join bool) []byte
func (*Connection) MergeRemoteState ¶
func (con *Connection) MergeRemoteState(buf []byte, join bool)
func (*Connection) Name ¶
func (con *Connection) Name() string
func (*Connection) NodeMeta ¶
func (con *Connection) NodeMeta(limit int) []byte
func (*Connection) NotifyMsg ¶
func (con *Connection) NotifyMsg(bytes []byte)
func (*Connection) Set ¶
func (con *Connection) Set(k, v string) error
func (*Connection) SetWithTtl ¶
func (con *Connection) SetWithTtl(k, v string, ttl time.Duration) error
func (*Connection) Shutdown ¶
func (con *Connection) Shutdown()
func (*Connection) UpsertIndex ¶ added in v0.1.2
func (con *Connection) UpsertIndex(index query.Index) error
Source Files
Click to show internal directories.
Click to hide internal directories.