Documentation ¶
Index ¶
- type Client
- func (this *Client) ExecuteOnGroups(functionId string, groups []string, functionArgs interface{}) ([]interface{}, error)
- func (this *Client) ExecuteOnMembers(functionId string, members []string, functionArgs interface{}) ([]interface{}, error)
- func (this *Client) ExecuteOnRegion(functionId, region string, functionArgs interface{}, keyFilter []interface{}) ([]interface{}, error)
- func (this *Client) Get(region string, key interface{}, value ...interface{}) (interface{}, error)
- func (this *Client) GetAll(region string, keys interface{}) (map[interface{}]interface{}, map[interface{}]error, error)
- func (this *Client) Put(region string, key, value interface{}) error
- func (this *Client) PutAll(region string, entries interface{}) (map[interface{}]error, error)
- func (this *Client) PutIfAbsent(region string, key, value interface{}) error
- func (this *Client) QueryForListResult(query *Query) ([]interface{}, error)
- func (this *Client) QueryForSingleResult(query *Query) (interface{}, error)
- func (this *Client) QueryForTableResult(query *Query) (map[string][]interface{}, error)
- func (this *Client) Remove(region string, key interface{}) error
- func (this *Client) Size(region string) (int32, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
A Client provides the high-level API required to interact with a Geode cluster. The API supports the following key and value types:
int int16 int32 int64 byte bool float32 float64 []byte string CustomEncodedValue
In order to enable the protobuf protocol, the Geode servers must be started with the property:
geode.feature-protobuf-protocol=true
func NewGeodeClient ¶
func (*Client) ExecuteOnGroups ¶
func (this *Client) ExecuteOnGroups(functionId string, groups []string, functionArgs interface{}) ([]interface{}, error)
Execute a function on a list of group. This will execute on each member associated with the groups; returning a slice of results, one entry for each member.
func (*Client) ExecuteOnMembers ¶
func (this *Client) ExecuteOnMembers(functionId string, members []string, functionArgs interface{}) ([]interface{}, error)
Execute a function on a list of members, returning a slice of results, one entry for each member.
func (*Client) ExecuteOnRegion ¶
func (this *Client) ExecuteOnRegion(functionId, region string, functionArgs interface{}, keyFilter []interface{}) ([]interface{}, error)
Execute a function on a region. This will execute on all members hosting the region and return a slice of results; one entry for each member.
func (*Client) Get ¶
Get an entry from a region using the specified key. It is the callers' responsibility to perform any type-assertion on the returned value. If a single, optional value is passed, the data retrieved from the region will be attempted to be unmarshalled as JSON into the supplied value.
func (*Client) GetAll ¶
func (this *Client) GetAll(region string, keys interface{}) (map[interface{}]interface{}, map[interface{}]error, error)
GetAll returns the values of multiple keys. Keys must be passed as an array or slice. The returned values are a map of keys and values for those keys which were successfully retrieved, a map of keys and the relevant error for those keys which produced an error on retrieval and, finally, a single error which typically would be as a result of a key or value encoding error.
func (*Client) PutAll ¶
PutAll adds multiple key/value pairs to a single region. Entries must be in the form of a map. The returned values are either a map of individual keys and the associated error when attempting to add that key, or a single error which typically would be as a result of a key or value encoding error.
func (*Client) PutIfAbsent ¶
Put data into a region if the key is not present. key and value must be a supported type.
func (*Client) QueryForListResult ¶
Execute a query, returning a list of results.
func (*Client) QueryForSingleResult ¶
Execute a query, returning a single result value.
func (*Client) QueryForTableResult ¶
Execute a query, returning a map of column (or field) names and the associated values for each column.
Directories ¶
Path | Synopsis |
---|---|
connectorfakes
Code generated by counterfeiter.
|
Code generated by counterfeiter. |
Package org_apache_geode_internal_protocol_protobuf is a generated protocol buffer package.
|
Package org_apache_geode_internal_protocol_protobuf is a generated protocol buffer package. |
v1
Package org_apache_geode_internal_protocol_protobuf_v1 is a generated protocol buffer package.
|
Package org_apache_geode_internal_protocol_protobuf_v1 is a generated protocol buffer package. |