Documentation ¶
Index ¶
- Constants
- func DecodeValue(value *v1.EncodedValue, ref interface{}) (interface{}, error)
- func DecodeValueList(list *v1.EncodedValueList, ref interface{}) ([]interface{}, error)
- func EncodeList(list interface{}) ([]*v1.EncodedValue, error)
- func EncodeTable(table map[string][]interface{}) (*v1.Table, error)
- func EncodeValue(val interface{}) (*v1.EncodedValue, error)
- func EncodeValueList(list interface{}) (*v1.EncodedValueList, error)
- type AuthenticationError
- type ConnectionProvider
- type GeodeConnection
- type Pool
- func (this *Pool) AddConnection(c net.Conn, handshakeDone bool)
- func (this *Pool) AddCredentials(username, password string)
- func (this *Pool) AddLocator(host string, port int)
- func (this *Pool) AddServer(host string, port int)
- func (this *Pool) DiscardConnection(gConn *GeodeConnection)
- func (this *Pool) GetConnection() (*GeodeConnection, error)
- func (this *Pool) ReturnConnection(gConn *GeodeConnection)
- type Protobuf
- func (this *Protobuf) ExecuteOnGroups(functionId string, groups []string, functionArgs interface{}) ([]interface{}, error)
- func (this *Protobuf) ExecuteOnMembers(functionId string, members []string, functionArgs interface{}) ([]interface{}, error)
- func (this *Protobuf) ExecuteOnRegion(functionId, region string, functionArgs interface{}, keyFilter []interface{}) ([]interface{}, error)
- func (this *Protobuf) Get(region string, k interface{}, value interface{}) (interface{}, error)
- func (this *Protobuf) GetAll(region string, keys interface{}) (map[interface{}]interface{}, map[interface{}]error, error)
- func (this *Protobuf) Put(region string, k, v interface{}) (err error)
- func (this *Protobuf) PutAll(region string, entries interface{}) (map[interface{}]error, error)
- func (this *Protobuf) PutIfAbsent(region string, k, v interface{}) (err error)
- func (this *Protobuf) QueryListResult(query *query.Query) ([]interface{}, error)
- func (this *Protobuf) QuerySingleResult(query *query.Query) (interface{}, error)
- func (this *Protobuf) QueryTableResult(query *query.Query) (map[string][]interface{}, error)
- func (this *Protobuf) Remove(region string, k interface{}) error
- func (this *Protobuf) Size(r string) (int32, error)
- type RetryableError
Constants ¶
View Source
const MAJOR_VERSION uint32 = 1
View Source
const MINOR_VERSION uint32 = 1
Variables ¶
This section is empty.
Functions ¶
func DecodeValue ¶
func DecodeValue(value *v1.EncodedValue, ref interface{}) (interface{}, error)
func DecodeValueList ¶
func DecodeValueList(list *v1.EncodedValueList, ref interface{}) ([]interface{}, error)
func EncodeList ¶
func EncodeList(list interface{}) ([]*v1.EncodedValue, error)
func EncodeValue ¶
func EncodeValue(val interface{}) (*v1.EncodedValue, error)
func EncodeValueList ¶
func EncodeValueList(list interface{}) (*v1.EncodedValueList, error)
Types ¶
type AuthenticationError ¶
type AuthenticationError string
func (AuthenticationError) Error ¶
func (e AuthenticationError) Error() string
type ConnectionProvider ¶
type ConnectionProvider interface {
GetGeodeConnection() *GeodeConnection
}
type GeodeConnection ¶
type GeodeConnection struct {
// contains filtered or unexported fields
}
func (*GeodeConnection) GetRawConnection ¶
func (this *GeodeConnection) GetRawConnection() net.Conn
type Pool ¶
func (*Pool) AddCredentials ¶
func (*Pool) AddLocator ¶
func (*Pool) DiscardConnection ¶
func (this *Pool) DiscardConnection(gConn *GeodeConnection)
DiscardConnection is used publicly as it holds the necessary lock
func (*Pool) GetConnection ¶
func (this *Pool) GetConnection() (*GeodeConnection, error)
func (*Pool) ReturnConnection ¶
func (this *Pool) ReturnConnection(gConn *GeodeConnection)
type Protobuf ¶
type Protobuf struct {
// contains filtered or unexported fields
}
A Protobuf connector provides the low-level interface between a Client and the backend Geode servers. It should not be used directly; rather the Client API should be used.
func NewConnector ¶
func (*Protobuf) ExecuteOnGroups ¶
func (*Protobuf) ExecuteOnMembers ¶
func (*Protobuf) ExecuteOnRegion ¶
func (*Protobuf) PutIfAbsent ¶
func (*Protobuf) QueryListResult ¶
func (*Protobuf) QuerySingleResult ¶
func (*Protobuf) QueryTableResult ¶
type RetryableError ¶
type RetryableError struct {
Err error
}
func (*RetryableError) Error ¶
func (e *RetryableError) Error() string
Source Files ¶
Click to show internal directories.
Click to hide internal directories.