Documentation ¶
Overview ¶
Package org_apache_geode_internal_protocol_protobuf_v1 is a generated protocol buffer package.
It is generated from these files:
v1/basicTypes.proto v1/clientProtocol.proto v1/connection_API.proto v1/locator_API.proto v1/region_API.proto v1/function_API.proto
It has these top-level messages:
Entry EncodedValueList Table EncodedValue Server Error KeyedError Message ErrorResponse HandshakeRequest HandshakeResponse DisconnectClientRequest DisconnectClientResponse GetServerRequest GetServerResponse PutRequest PutResponse PutIfAbsentRequest PutIfAbsentResponse GetRequest GetResponse PutAllRequest PutAllResponse GetAllRequest GetAllResponse RemoveRequest RemoveResponse GetRegionNamesRequest GetRegionNamesResponse GetSizeRequest GetSizeResponse OQLQueryRequest OQLQueryResponse KeySetRequest KeySetResponse ClearRequest ClearResponse ExecuteFunctionOnRegionRequest ExecuteFunctionOnRegionResponse ExecuteFunctionOnMemberRequest ExecuteFunctionOnMemberResponse ExecuteFunctionOnGroupRequest ExecuteFunctionOnGroupResponse
Index ¶
- Variables
- type ClearRequest
- type ClearResponse
- type DisconnectClientRequest
- type DisconnectClientResponse
- type EncodedValue
- func (*EncodedValue) Descriptor() ([]byte, []int)
- func (m *EncodedValue) GetBinaryResult() []byte
- func (m *EncodedValue) GetBooleanResult() bool
- func (m *EncodedValue) GetByteResult() int32
- func (m *EncodedValue) GetCustomObjectResult() []byte
- func (m *EncodedValue) GetDoubleResult() float64
- func (m *EncodedValue) GetFloatResult() float32
- func (m *EncodedValue) GetIntResult() int32
- func (m *EncodedValue) GetJsonObjectResult() string
- func (m *EncodedValue) GetLongResult() int64
- func (m *EncodedValue) GetNullResult() google_protobuf.NullValue
- func (m *EncodedValue) GetShortResult() int32
- func (m *EncodedValue) GetStringResult() string
- func (m *EncodedValue) GetValue() isEncodedValue_Value
- func (*EncodedValue) ProtoMessage()
- func (m *EncodedValue) Reset()
- func (m *EncodedValue) String() string
- func (*EncodedValue) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- type EncodedValueList
- type EncodedValue_BinaryResult
- type EncodedValue_BooleanResult
- type EncodedValue_ByteResult
- type EncodedValue_CustomObjectResult
- type EncodedValue_DoubleResult
- type EncodedValue_FloatResult
- type EncodedValue_IntResult
- type EncodedValue_JsonObjectResult
- type EncodedValue_LongResult
- type EncodedValue_NullResult
- type EncodedValue_ShortResult
- type EncodedValue_StringResult
- type Entry
- type Error
- type ErrorCode
- type ErrorResponse
- type ExecuteFunctionOnGroupRequest
- func (*ExecuteFunctionOnGroupRequest) Descriptor() ([]byte, []int)
- func (m *ExecuteFunctionOnGroupRequest) GetArguments() *EncodedValue
- func (m *ExecuteFunctionOnGroupRequest) GetFunctionID() string
- func (m *ExecuteFunctionOnGroupRequest) GetGroupName() []string
- func (*ExecuteFunctionOnGroupRequest) ProtoMessage()
- func (m *ExecuteFunctionOnGroupRequest) Reset()
- func (m *ExecuteFunctionOnGroupRequest) String() string
- type ExecuteFunctionOnGroupResponse
- type ExecuteFunctionOnMemberRequest
- func (*ExecuteFunctionOnMemberRequest) Descriptor() ([]byte, []int)
- func (m *ExecuteFunctionOnMemberRequest) GetArguments() *EncodedValue
- func (m *ExecuteFunctionOnMemberRequest) GetFunctionID() string
- func (m *ExecuteFunctionOnMemberRequest) GetMemberName() []string
- func (*ExecuteFunctionOnMemberRequest) ProtoMessage()
- func (m *ExecuteFunctionOnMemberRequest) Reset()
- func (m *ExecuteFunctionOnMemberRequest) String() string
- type ExecuteFunctionOnMemberResponse
- func (*ExecuteFunctionOnMemberResponse) Descriptor() ([]byte, []int)
- func (m *ExecuteFunctionOnMemberResponse) GetResults() []*EncodedValue
- func (*ExecuteFunctionOnMemberResponse) ProtoMessage()
- func (m *ExecuteFunctionOnMemberResponse) Reset()
- func (m *ExecuteFunctionOnMemberResponse) String() string
- type ExecuteFunctionOnRegionRequest
- func (*ExecuteFunctionOnRegionRequest) Descriptor() ([]byte, []int)
- func (m *ExecuteFunctionOnRegionRequest) GetArguments() *EncodedValue
- func (m *ExecuteFunctionOnRegionRequest) GetFunctionID() string
- func (m *ExecuteFunctionOnRegionRequest) GetKeyFilter() []*EncodedValue
- func (m *ExecuteFunctionOnRegionRequest) GetRegion() string
- func (*ExecuteFunctionOnRegionRequest) ProtoMessage()
- func (m *ExecuteFunctionOnRegionRequest) Reset()
- func (m *ExecuteFunctionOnRegionRequest) String() string
- type ExecuteFunctionOnRegionResponse
- func (*ExecuteFunctionOnRegionResponse) Descriptor() ([]byte, []int)
- func (m *ExecuteFunctionOnRegionResponse) GetResults() []*EncodedValue
- func (*ExecuteFunctionOnRegionResponse) ProtoMessage()
- func (m *ExecuteFunctionOnRegionResponse) Reset()
- func (m *ExecuteFunctionOnRegionResponse) String() string
- type GetAllRequest
- func (*GetAllRequest) Descriptor() ([]byte, []int)
- func (m *GetAllRequest) GetCallbackArg() *EncodedValue
- func (m *GetAllRequest) GetKey() []*EncodedValue
- func (m *GetAllRequest) GetRegionName() string
- func (*GetAllRequest) ProtoMessage()
- func (m *GetAllRequest) Reset()
- func (m *GetAllRequest) String() string
- type GetAllResponse
- type GetRegionNamesRequest
- type GetRegionNamesResponse
- type GetRequest
- type GetResponse
- type GetServerRequest
- type GetServerResponse
- type GetSizeRequest
- type GetSizeResponse
- type HandshakeRequest
- type HandshakeResponse
- type KeySetRequest
- type KeySetResponse
- type KeyedError
- type Message
- func (*Message) Descriptor() ([]byte, []int)
- func (m *Message) GetClearRequest() *ClearRequest
- func (m *Message) GetClearResponse() *ClearResponse
- func (m *Message) GetDisconnectClientRequest() *DisconnectClientRequest
- func (m *Message) GetDisconnectClientResponse() *DisconnectClientResponse
- func (m *Message) GetErrorResponse() *ErrorResponse
- func (m *Message) GetExecuteFunctionOnGroupRequest() *ExecuteFunctionOnGroupRequest
- func (m *Message) GetExecuteFunctionOnGroupResponse() *ExecuteFunctionOnGroupResponse
- func (m *Message) GetExecuteFunctionOnMemberRequest() *ExecuteFunctionOnMemberRequest
- func (m *Message) GetExecuteFunctionOnMemberResponse() *ExecuteFunctionOnMemberResponse
- func (m *Message) GetExecuteFunctionOnRegionRequest() *ExecuteFunctionOnRegionRequest
- func (m *Message) GetExecuteFunctionOnRegionResponse() *ExecuteFunctionOnRegionResponse
- func (m *Message) GetGetAllRequest() *GetAllRequest
- func (m *Message) GetGetAllResponse() *GetAllResponse
- func (m *Message) GetGetRegionNamesRequest() *GetRegionNamesRequest
- func (m *Message) GetGetRegionNamesResponse() *GetRegionNamesResponse
- func (m *Message) GetGetRequest() *GetRequest
- func (m *Message) GetGetResponse() *GetResponse
- func (m *Message) GetGetServerRequest() *GetServerRequest
- func (m *Message) GetGetServerResponse() *GetServerResponse
- func (m *Message) GetGetSizeRequest() *GetSizeRequest
- func (m *Message) GetGetSizeResponse() *GetSizeResponse
- func (m *Message) GetHandshakeRequest() *HandshakeRequest
- func (m *Message) GetHandshakeResponse() *HandshakeResponse
- func (m *Message) GetKeySetRequest() *KeySetRequest
- func (m *Message) GetKeySetResponse() *KeySetResponse
- func (m *Message) GetMessageType() isMessage_MessageType
- func (m *Message) GetOqlQueryRequest() *OQLQueryRequest
- func (m *Message) GetOqlQueryResponse() *OQLQueryResponse
- func (m *Message) GetPutAllRequest() *PutAllRequest
- func (m *Message) GetPutAllResponse() *PutAllResponse
- func (m *Message) GetPutIfAbsentRequest() *PutIfAbsentRequest
- func (m *Message) GetPutIfAbsentResponse() *PutIfAbsentResponse
- func (m *Message) GetPutRequest() *PutRequest
- func (m *Message) GetPutResponse() *PutResponse
- func (m *Message) GetRemoveRequest() *RemoveRequest
- func (m *Message) GetRemoveResponse() *RemoveResponse
- func (*Message) ProtoMessage()
- func (m *Message) Reset()
- func (m *Message) String() string
- func (*Message) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- type Message_ClearRequest
- type Message_ClearResponse
- type Message_DisconnectClientRequest
- type Message_DisconnectClientResponse
- type Message_ErrorResponse
- type Message_ExecuteFunctionOnGroupRequest
- type Message_ExecuteFunctionOnGroupResponse
- type Message_ExecuteFunctionOnMemberRequest
- type Message_ExecuteFunctionOnMemberResponse
- type Message_ExecuteFunctionOnRegionRequest
- type Message_ExecuteFunctionOnRegionResponse
- type Message_GetAllRequest
- type Message_GetAllResponse
- type Message_GetRegionNamesRequest
- type Message_GetRegionNamesResponse
- type Message_GetRequest
- type Message_GetResponse
- type Message_GetServerRequest
- type Message_GetServerResponse
- type Message_GetSizeRequest
- type Message_GetSizeResponse
- type Message_HandshakeRequest
- type Message_HandshakeResponse
- type Message_KeySetRequest
- type Message_KeySetResponse
- type Message_OqlQueryRequest
- type Message_OqlQueryResponse
- type Message_PutAllRequest
- type Message_PutAllResponse
- type Message_PutIfAbsentRequest
- type Message_PutIfAbsentResponse
- type Message_PutRequest
- type Message_PutResponse
- type Message_RemoveRequest
- type Message_RemoveResponse
- type OQLQueryRequest
- type OQLQueryResponse
- func (*OQLQueryResponse) Descriptor() ([]byte, []int)
- func (m *OQLQueryResponse) GetListResult() *EncodedValueList
- func (m *OQLQueryResponse) GetResult() isOQLQueryResponse_Result
- func (m *OQLQueryResponse) GetSingleResult() *EncodedValue
- func (m *OQLQueryResponse) GetTableResult() *Table
- func (*OQLQueryResponse) ProtoMessage()
- func (m *OQLQueryResponse) Reset()
- func (m *OQLQueryResponse) String() string
- func (*OQLQueryResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- type OQLQueryResponse_ListResult
- type OQLQueryResponse_SingleResult
- type OQLQueryResponse_TableResult
- type PutAllRequest
- type PutAllResponse
- type PutIfAbsentRequest
- type PutIfAbsentResponse
- type PutRequest
- type PutResponse
- type RemoveRequest
- type RemoveResponse
- type Server
- type Table
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrorCode_name = map[int32]string{
0: "INVALID_ERROR_CODE",
10: "AUTHENTICATION_REQUIRED",
11: "AUTHENTICATION_FAILED",
12: "ALREADY_AUTHENTICATED",
13: "AUTHENTICATION_NOT_SUPPORTED",
20: "AUTHORIZATION_FAILED",
50: "INVALID_REQUEST",
60: "UNSUPPORTED_OPERATION",
100: "SERVER_ERROR",
101: "NO_AVAILABLE_SERVER",
}
View Source
var ErrorCode_value = map[string]int32{
"INVALID_ERROR_CODE": 0,
"AUTHENTICATION_REQUIRED": 10,
"AUTHENTICATION_FAILED": 11,
"ALREADY_AUTHENTICATED": 12,
"AUTHENTICATION_NOT_SUPPORTED": 13,
"AUTHORIZATION_FAILED": 20,
"INVALID_REQUEST": 50,
"UNSUPPORTED_OPERATION": 60,
"SERVER_ERROR": 100,
"NO_AVAILABLE_SERVER": 101,
}
Functions ¶
This section is empty.
Types ¶
type ClearRequest ¶
type ClearRequest struct {
RegionName string `protobuf:"bytes,1,opt,name=regionName" json:"regionName,omitempty"`
}
func (*ClearRequest) Descriptor ¶
func (*ClearRequest) Descriptor() ([]byte, []int)
func (*ClearRequest) GetRegionName ¶
func (m *ClearRequest) GetRegionName() string
func (*ClearRequest) ProtoMessage ¶
func (*ClearRequest) ProtoMessage()
func (*ClearRequest) Reset ¶
func (m *ClearRequest) Reset()
func (*ClearRequest) String ¶
func (m *ClearRequest) String() string
type ClearResponse ¶
type ClearResponse struct { }
func (*ClearResponse) Descriptor ¶
func (*ClearResponse) Descriptor() ([]byte, []int)
func (*ClearResponse) ProtoMessage ¶
func (*ClearResponse) ProtoMessage()
func (*ClearResponse) Reset ¶
func (m *ClearResponse) Reset()
func (*ClearResponse) String ¶
func (m *ClearResponse) String() string
type DisconnectClientRequest ¶
type DisconnectClientRequest struct {
Reason string `protobuf:"bytes,1,opt,name=reason" json:"reason,omitempty"`
}
func (*DisconnectClientRequest) Descriptor ¶
func (*DisconnectClientRequest) Descriptor() ([]byte, []int)
func (*DisconnectClientRequest) GetReason ¶
func (m *DisconnectClientRequest) GetReason() string
func (*DisconnectClientRequest) ProtoMessage ¶
func (*DisconnectClientRequest) ProtoMessage()
func (*DisconnectClientRequest) Reset ¶
func (m *DisconnectClientRequest) Reset()
func (*DisconnectClientRequest) String ¶
func (m *DisconnectClientRequest) String() string
type DisconnectClientResponse ¶
type DisconnectClientResponse struct { }
func (*DisconnectClientResponse) Descriptor ¶
func (*DisconnectClientResponse) Descriptor() ([]byte, []int)
func (*DisconnectClientResponse) ProtoMessage ¶
func (*DisconnectClientResponse) ProtoMessage()
func (*DisconnectClientResponse) Reset ¶
func (m *DisconnectClientResponse) Reset()
func (*DisconnectClientResponse) String ¶
func (m *DisconnectClientResponse) String() string
type EncodedValue ¶
type EncodedValue struct { // Types that are valid to be assigned to Value: // *EncodedValue_IntResult // *EncodedValue_LongResult // *EncodedValue_ShortResult // *EncodedValue_ByteResult // *EncodedValue_BooleanResult // *EncodedValue_DoubleResult // *EncodedValue_FloatResult // *EncodedValue_BinaryResult // *EncodedValue_StringResult // *EncodedValue_JsonObjectResult // *EncodedValue_NullResult // *EncodedValue_CustomObjectResult Value isEncodedValue_Value `protobuf_oneof:"value"` }
func (*EncodedValue) Descriptor ¶
func (*EncodedValue) Descriptor() ([]byte, []int)
func (*EncodedValue) GetBinaryResult ¶
func (m *EncodedValue) GetBinaryResult() []byte
func (*EncodedValue) GetBooleanResult ¶
func (m *EncodedValue) GetBooleanResult() bool
func (*EncodedValue) GetByteResult ¶
func (m *EncodedValue) GetByteResult() int32
func (*EncodedValue) GetCustomObjectResult ¶
func (m *EncodedValue) GetCustomObjectResult() []byte
func (*EncodedValue) GetDoubleResult ¶
func (m *EncodedValue) GetDoubleResult() float64
func (*EncodedValue) GetFloatResult ¶
func (m *EncodedValue) GetFloatResult() float32
func (*EncodedValue) GetIntResult ¶
func (m *EncodedValue) GetIntResult() int32
func (*EncodedValue) GetJsonObjectResult ¶
func (m *EncodedValue) GetJsonObjectResult() string
func (*EncodedValue) GetLongResult ¶
func (m *EncodedValue) GetLongResult() int64
func (*EncodedValue) GetNullResult ¶
func (m *EncodedValue) GetNullResult() google_protobuf.NullValue
func (*EncodedValue) GetShortResult ¶
func (m *EncodedValue) GetShortResult() int32
func (*EncodedValue) GetStringResult ¶
func (m *EncodedValue) GetStringResult() string
func (*EncodedValue) GetValue ¶
func (m *EncodedValue) GetValue() isEncodedValue_Value
func (*EncodedValue) ProtoMessage ¶
func (*EncodedValue) ProtoMessage()
func (*EncodedValue) Reset ¶
func (m *EncodedValue) Reset()
func (*EncodedValue) String ¶
func (m *EncodedValue) String() string
func (*EncodedValue) XXX_OneofFuncs ¶
func (*EncodedValue) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
type EncodedValueList ¶
type EncodedValueList struct {
Element []*EncodedValue `protobuf:"bytes,1,rep,name=element" json:"element,omitempty"`
}
func (*EncodedValueList) Descriptor ¶
func (*EncodedValueList) Descriptor() ([]byte, []int)
func (*EncodedValueList) GetElement ¶
func (m *EncodedValueList) GetElement() []*EncodedValue
func (*EncodedValueList) ProtoMessage ¶
func (*EncodedValueList) ProtoMessage()
func (*EncodedValueList) Reset ¶
func (m *EncodedValueList) Reset()
func (*EncodedValueList) String ¶
func (m *EncodedValueList) String() string
type EncodedValue_BinaryResult ¶
type EncodedValue_BinaryResult struct {
BinaryResult []byte `protobuf:"bytes,8,opt,name=binaryResult,proto3,oneof"`
}
type EncodedValue_BooleanResult ¶
type EncodedValue_BooleanResult struct {
BooleanResult bool `protobuf:"varint,5,opt,name=booleanResult,oneof"`
}
type EncodedValue_ByteResult ¶
type EncodedValue_ByteResult struct {
ByteResult int32 `protobuf:"varint,4,opt,name=byteResult,oneof"`
}
type EncodedValue_CustomObjectResult ¶
type EncodedValue_CustomObjectResult struct {
CustomObjectResult []byte `protobuf:"bytes,12,opt,name=customObjectResult,proto3,oneof"`
}
type EncodedValue_DoubleResult ¶
type EncodedValue_DoubleResult struct {
DoubleResult float64 `protobuf:"fixed64,6,opt,name=doubleResult,oneof"`
}
type EncodedValue_FloatResult ¶
type EncodedValue_FloatResult struct {
FloatResult float32 `protobuf:"fixed32,7,opt,name=floatResult,oneof"`
}
type EncodedValue_IntResult ¶
type EncodedValue_IntResult struct {
IntResult int32 `protobuf:"varint,1,opt,name=intResult,oneof"`
}
type EncodedValue_JsonObjectResult ¶
type EncodedValue_JsonObjectResult struct {
JsonObjectResult string `protobuf:"bytes,10,opt,name=jsonObjectResult,oneof"`
}
type EncodedValue_LongResult ¶
type EncodedValue_LongResult struct {
LongResult int64 `protobuf:"varint,2,opt,name=longResult,oneof"`
}
type EncodedValue_NullResult ¶
type EncodedValue_NullResult struct {
NullResult google_protobuf.NullValue `protobuf:"varint,11,opt,name=nullResult,enum=google.protobuf.NullValue,oneof"`
}
type EncodedValue_ShortResult ¶
type EncodedValue_ShortResult struct {
ShortResult int32 `protobuf:"varint,3,opt,name=shortResult,oneof"`
}
type EncodedValue_StringResult ¶
type EncodedValue_StringResult struct {
StringResult string `protobuf:"bytes,9,opt,name=stringResult,oneof"`
}
type Entry ¶
type Entry struct { Key *EncodedValue `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"` Value *EncodedValue `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"` }
func (*Entry) Descriptor ¶
func (*Entry) GetKey ¶
func (m *Entry) GetKey() *EncodedValue
func (*Entry) GetValue ¶
func (m *Entry) GetValue() *EncodedValue
func (*Entry) ProtoMessage ¶
func (*Entry) ProtoMessage()
type Error ¶
type Error struct { ErrorCode ErrorCode `` /* 127-byte string literal not displayed */ Message string `protobuf:"bytes,2,opt,name=message" json:"message,omitempty"` }
func (*Error) Descriptor ¶
func (*Error) GetErrorCode ¶
func (*Error) GetMessage ¶
func (*Error) ProtoMessage ¶
func (*Error) ProtoMessage()
type ErrorCode ¶
type ErrorCode int32
const ( ErrorCode_INVALID_ERROR_CODE ErrorCode = 0 ErrorCode_AUTHENTICATION_REQUIRED ErrorCode = 10 ErrorCode_AUTHENTICATION_FAILED ErrorCode = 11 ErrorCode_ALREADY_AUTHENTICATED ErrorCode = 12 ErrorCode_AUTHENTICATION_NOT_SUPPORTED ErrorCode = 13 ErrorCode_AUTHORIZATION_FAILED ErrorCode = 20 ErrorCode_INVALID_REQUEST ErrorCode = 50 ErrorCode_UNSUPPORTED_OPERATION ErrorCode = 60 ErrorCode_SERVER_ERROR ErrorCode = 100 ErrorCode_NO_AVAILABLE_SERVER ErrorCode = 101 )
func (ErrorCode) EnumDescriptor ¶
type ErrorResponse ¶
type ErrorResponse struct {
Error *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}
func (*ErrorResponse) Descriptor ¶
func (*ErrorResponse) Descriptor() ([]byte, []int)
func (*ErrorResponse) GetError ¶
func (m *ErrorResponse) GetError() *Error
func (*ErrorResponse) ProtoMessage ¶
func (*ErrorResponse) ProtoMessage()
func (*ErrorResponse) Reset ¶
func (m *ErrorResponse) Reset()
func (*ErrorResponse) String ¶
func (m *ErrorResponse) String() string
type ExecuteFunctionOnGroupRequest ¶
type ExecuteFunctionOnGroupRequest struct { FunctionID string `protobuf:"bytes,1,opt,name=functionID" json:"functionID,omitempty"` GroupName []string `protobuf:"bytes,2,rep,name=groupName" json:"groupName,omitempty"` Arguments *EncodedValue `protobuf:"bytes,3,opt,name=arguments" json:"arguments,omitempty"` }
func (*ExecuteFunctionOnGroupRequest) Descriptor ¶
func (*ExecuteFunctionOnGroupRequest) Descriptor() ([]byte, []int)
func (*ExecuteFunctionOnGroupRequest) GetArguments ¶
func (m *ExecuteFunctionOnGroupRequest) GetArguments() *EncodedValue
func (*ExecuteFunctionOnGroupRequest) GetFunctionID ¶
func (m *ExecuteFunctionOnGroupRequest) GetFunctionID() string
func (*ExecuteFunctionOnGroupRequest) GetGroupName ¶
func (m *ExecuteFunctionOnGroupRequest) GetGroupName() []string
func (*ExecuteFunctionOnGroupRequest) ProtoMessage ¶
func (*ExecuteFunctionOnGroupRequest) ProtoMessage()
func (*ExecuteFunctionOnGroupRequest) Reset ¶
func (m *ExecuteFunctionOnGroupRequest) Reset()
func (*ExecuteFunctionOnGroupRequest) String ¶
func (m *ExecuteFunctionOnGroupRequest) String() string
type ExecuteFunctionOnGroupResponse ¶
type ExecuteFunctionOnGroupResponse struct {
Results []*EncodedValue `protobuf:"bytes,1,rep,name=results" json:"results,omitempty"`
}
func (*ExecuteFunctionOnGroupResponse) Descriptor ¶
func (*ExecuteFunctionOnGroupResponse) Descriptor() ([]byte, []int)
func (*ExecuteFunctionOnGroupResponse) GetResults ¶
func (m *ExecuteFunctionOnGroupResponse) GetResults() []*EncodedValue
func (*ExecuteFunctionOnGroupResponse) ProtoMessage ¶
func (*ExecuteFunctionOnGroupResponse) ProtoMessage()
func (*ExecuteFunctionOnGroupResponse) Reset ¶
func (m *ExecuteFunctionOnGroupResponse) Reset()
func (*ExecuteFunctionOnGroupResponse) String ¶
func (m *ExecuteFunctionOnGroupResponse) String() string
type ExecuteFunctionOnMemberRequest ¶
type ExecuteFunctionOnMemberRequest struct { FunctionID string `protobuf:"bytes,1,opt,name=functionID" json:"functionID,omitempty"` MemberName []string `protobuf:"bytes,2,rep,name=memberName" json:"memberName,omitempty"` Arguments *EncodedValue `protobuf:"bytes,3,opt,name=arguments" json:"arguments,omitempty"` }
func (*ExecuteFunctionOnMemberRequest) Descriptor ¶
func (*ExecuteFunctionOnMemberRequest) Descriptor() ([]byte, []int)
func (*ExecuteFunctionOnMemberRequest) GetArguments ¶
func (m *ExecuteFunctionOnMemberRequest) GetArguments() *EncodedValue
func (*ExecuteFunctionOnMemberRequest) GetFunctionID ¶
func (m *ExecuteFunctionOnMemberRequest) GetFunctionID() string
func (*ExecuteFunctionOnMemberRequest) GetMemberName ¶
func (m *ExecuteFunctionOnMemberRequest) GetMemberName() []string
func (*ExecuteFunctionOnMemberRequest) ProtoMessage ¶
func (*ExecuteFunctionOnMemberRequest) ProtoMessage()
func (*ExecuteFunctionOnMemberRequest) Reset ¶
func (m *ExecuteFunctionOnMemberRequest) Reset()
func (*ExecuteFunctionOnMemberRequest) String ¶
func (m *ExecuteFunctionOnMemberRequest) String() string
type ExecuteFunctionOnMemberResponse ¶
type ExecuteFunctionOnMemberResponse struct {
Results []*EncodedValue `protobuf:"bytes,1,rep,name=results" json:"results,omitempty"`
}
func (*ExecuteFunctionOnMemberResponse) Descriptor ¶
func (*ExecuteFunctionOnMemberResponse) Descriptor() ([]byte, []int)
func (*ExecuteFunctionOnMemberResponse) GetResults ¶
func (m *ExecuteFunctionOnMemberResponse) GetResults() []*EncodedValue
func (*ExecuteFunctionOnMemberResponse) ProtoMessage ¶
func (*ExecuteFunctionOnMemberResponse) ProtoMessage()
func (*ExecuteFunctionOnMemberResponse) Reset ¶
func (m *ExecuteFunctionOnMemberResponse) Reset()
func (*ExecuteFunctionOnMemberResponse) String ¶
func (m *ExecuteFunctionOnMemberResponse) String() string
type ExecuteFunctionOnRegionRequest ¶
type ExecuteFunctionOnRegionRequest struct { FunctionID string `protobuf:"bytes,1,opt,name=functionID" json:"functionID,omitempty"` Region string `protobuf:"bytes,2,opt,name=region" json:"region,omitempty"` Arguments *EncodedValue `protobuf:"bytes,3,opt,name=arguments" json:"arguments,omitempty"` KeyFilter []*EncodedValue `protobuf:"bytes,4,rep,name=keyFilter" json:"keyFilter,omitempty"` }
func (*ExecuteFunctionOnRegionRequest) Descriptor ¶
func (*ExecuteFunctionOnRegionRequest) Descriptor() ([]byte, []int)
func (*ExecuteFunctionOnRegionRequest) GetArguments ¶
func (m *ExecuteFunctionOnRegionRequest) GetArguments() *EncodedValue
func (*ExecuteFunctionOnRegionRequest) GetFunctionID ¶
func (m *ExecuteFunctionOnRegionRequest) GetFunctionID() string
func (*ExecuteFunctionOnRegionRequest) GetKeyFilter ¶
func (m *ExecuteFunctionOnRegionRequest) GetKeyFilter() []*EncodedValue
func (*ExecuteFunctionOnRegionRequest) GetRegion ¶
func (m *ExecuteFunctionOnRegionRequest) GetRegion() string
func (*ExecuteFunctionOnRegionRequest) ProtoMessage ¶
func (*ExecuteFunctionOnRegionRequest) ProtoMessage()
func (*ExecuteFunctionOnRegionRequest) Reset ¶
func (m *ExecuteFunctionOnRegionRequest) Reset()
func (*ExecuteFunctionOnRegionRequest) String ¶
func (m *ExecuteFunctionOnRegionRequest) String() string
type ExecuteFunctionOnRegionResponse ¶
type ExecuteFunctionOnRegionResponse struct {
Results []*EncodedValue `protobuf:"bytes,1,rep,name=results" json:"results,omitempty"`
}
func (*ExecuteFunctionOnRegionResponse) Descriptor ¶
func (*ExecuteFunctionOnRegionResponse) Descriptor() ([]byte, []int)
func (*ExecuteFunctionOnRegionResponse) GetResults ¶
func (m *ExecuteFunctionOnRegionResponse) GetResults() []*EncodedValue
func (*ExecuteFunctionOnRegionResponse) ProtoMessage ¶
func (*ExecuteFunctionOnRegionResponse) ProtoMessage()
func (*ExecuteFunctionOnRegionResponse) Reset ¶
func (m *ExecuteFunctionOnRegionResponse) Reset()
func (*ExecuteFunctionOnRegionResponse) String ¶
func (m *ExecuteFunctionOnRegionResponse) String() string
type GetAllRequest ¶
type GetAllRequest struct { RegionName string `protobuf:"bytes,1,opt,name=regionName" json:"regionName,omitempty"` Key []*EncodedValue `protobuf:"bytes,2,rep,name=key" json:"key,omitempty"` CallbackArg *EncodedValue `protobuf:"bytes,3,opt,name=callbackArg" json:"callbackArg,omitempty"` }
func (*GetAllRequest) Descriptor ¶
func (*GetAllRequest) Descriptor() ([]byte, []int)
func (*GetAllRequest) GetCallbackArg ¶
func (m *GetAllRequest) GetCallbackArg() *EncodedValue
func (*GetAllRequest) GetKey ¶
func (m *GetAllRequest) GetKey() []*EncodedValue
func (*GetAllRequest) GetRegionName ¶
func (m *GetAllRequest) GetRegionName() string
func (*GetAllRequest) ProtoMessage ¶
func (*GetAllRequest) ProtoMessage()
func (*GetAllRequest) Reset ¶
func (m *GetAllRequest) Reset()
func (*GetAllRequest) String ¶
func (m *GetAllRequest) String() string
type GetAllResponse ¶
type GetAllResponse struct { Entries []*Entry `protobuf:"bytes,1,rep,name=entries" json:"entries,omitempty"` Failures []*KeyedError `protobuf:"bytes,2,rep,name=failures" json:"failures,omitempty"` }
func (*GetAllResponse) Descriptor ¶
func (*GetAllResponse) Descriptor() ([]byte, []int)
func (*GetAllResponse) GetEntries ¶
func (m *GetAllResponse) GetEntries() []*Entry
func (*GetAllResponse) GetFailures ¶
func (m *GetAllResponse) GetFailures() []*KeyedError
func (*GetAllResponse) ProtoMessage ¶
func (*GetAllResponse) ProtoMessage()
func (*GetAllResponse) Reset ¶
func (m *GetAllResponse) Reset()
func (*GetAllResponse) String ¶
func (m *GetAllResponse) String() string
type GetRegionNamesRequest ¶
type GetRegionNamesRequest struct { }
func (*GetRegionNamesRequest) Descriptor ¶
func (*GetRegionNamesRequest) Descriptor() ([]byte, []int)
func (*GetRegionNamesRequest) ProtoMessage ¶
func (*GetRegionNamesRequest) ProtoMessage()
func (*GetRegionNamesRequest) Reset ¶
func (m *GetRegionNamesRequest) Reset()
func (*GetRegionNamesRequest) String ¶
func (m *GetRegionNamesRequest) String() string
type GetRegionNamesResponse ¶
type GetRegionNamesResponse struct {
Regions []string `protobuf:"bytes,1,rep,name=regions" json:"regions,omitempty"`
}
func (*GetRegionNamesResponse) Descriptor ¶
func (*GetRegionNamesResponse) Descriptor() ([]byte, []int)
func (*GetRegionNamesResponse) GetRegions ¶
func (m *GetRegionNamesResponse) GetRegions() []string
func (*GetRegionNamesResponse) ProtoMessage ¶
func (*GetRegionNamesResponse) ProtoMessage()
func (*GetRegionNamesResponse) Reset ¶
func (m *GetRegionNamesResponse) Reset()
func (*GetRegionNamesResponse) String ¶
func (m *GetRegionNamesResponse) String() string
type GetRequest ¶
type GetRequest struct { RegionName string `protobuf:"bytes,1,opt,name=regionName" json:"regionName,omitempty"` Key *EncodedValue `protobuf:"bytes,2,opt,name=key" json:"key,omitempty"` }
func (*GetRequest) Descriptor ¶
func (*GetRequest) Descriptor() ([]byte, []int)
func (*GetRequest) GetKey ¶
func (m *GetRequest) GetKey() *EncodedValue
func (*GetRequest) GetRegionName ¶
func (m *GetRequest) GetRegionName() string
func (*GetRequest) ProtoMessage ¶
func (*GetRequest) ProtoMessage()
func (*GetRequest) Reset ¶
func (m *GetRequest) Reset()
func (*GetRequest) String ¶
func (m *GetRequest) String() string
type GetResponse ¶
type GetResponse struct {
Result *EncodedValue `protobuf:"bytes,1,opt,name=result" json:"result,omitempty"`
}
func (*GetResponse) Descriptor ¶
func (*GetResponse) Descriptor() ([]byte, []int)
func (*GetResponse) GetResult ¶
func (m *GetResponse) GetResult() *EncodedValue
func (*GetResponse) ProtoMessage ¶
func (*GetResponse) ProtoMessage()
func (*GetResponse) Reset ¶
func (m *GetResponse) Reset()
func (*GetResponse) String ¶
func (m *GetResponse) String() string
type GetServerRequest ¶
type GetServerRequest struct { ExcludedServers []*Server `protobuf:"bytes,1,rep,name=excludedServers" json:"excludedServers,omitempty"` ServerGroup string `protobuf:"bytes,2,opt,name=serverGroup" json:"serverGroup,omitempty"` }
this will return failure code LOCATOR_ERROR if unable to find a suitable server
func (*GetServerRequest) Descriptor ¶
func (*GetServerRequest) Descriptor() ([]byte, []int)
func (*GetServerRequest) GetExcludedServers ¶
func (m *GetServerRequest) GetExcludedServers() []*Server
func (*GetServerRequest) GetServerGroup ¶
func (m *GetServerRequest) GetServerGroup() string
func (*GetServerRequest) ProtoMessage ¶
func (*GetServerRequest) ProtoMessage()
func (*GetServerRequest) Reset ¶
func (m *GetServerRequest) Reset()
func (*GetServerRequest) String ¶
func (m *GetServerRequest) String() string
type GetServerResponse ¶
type GetServerResponse struct {
Server *Server `protobuf:"bytes,1,opt,name=server" json:"server,omitempty"`
}
func (*GetServerResponse) Descriptor ¶
func (*GetServerResponse) Descriptor() ([]byte, []int)
func (*GetServerResponse) GetServer ¶
func (m *GetServerResponse) GetServer() *Server
func (*GetServerResponse) ProtoMessage ¶
func (*GetServerResponse) ProtoMessage()
func (*GetServerResponse) Reset ¶
func (m *GetServerResponse) Reset()
func (*GetServerResponse) String ¶
func (m *GetServerResponse) String() string
type GetSizeRequest ¶
type GetSizeRequest struct {
RegionName string `protobuf:"bytes,1,opt,name=regionName" json:"regionName,omitempty"`
}
func (*GetSizeRequest) Descriptor ¶
func (*GetSizeRequest) Descriptor() ([]byte, []int)
func (*GetSizeRequest) GetRegionName ¶
func (m *GetSizeRequest) GetRegionName() string
func (*GetSizeRequest) ProtoMessage ¶
func (*GetSizeRequest) ProtoMessage()
func (*GetSizeRequest) Reset ¶
func (m *GetSizeRequest) Reset()
func (*GetSizeRequest) String ¶
func (m *GetSizeRequest) String() string
type GetSizeResponse ¶
type GetSizeResponse struct {
Size int32 `protobuf:"varint,1,opt,name=size" json:"size,omitempty"`
}
func (*GetSizeResponse) Descriptor ¶
func (*GetSizeResponse) Descriptor() ([]byte, []int)
func (*GetSizeResponse) GetSize ¶
func (m *GetSizeResponse) GetSize() int32
func (*GetSizeResponse) ProtoMessage ¶
func (*GetSizeResponse) ProtoMessage()
func (*GetSizeResponse) Reset ¶
func (m *GetSizeResponse) Reset()
func (*GetSizeResponse) String ¶
func (m *GetSizeResponse) String() string
type HandshakeRequest ¶
type HandshakeRequest struct { // Credentials used to authenticate with the security service // Not required if the server does not have a security service enabled Credentials map[string]string `` /* 142-byte string literal not displayed */ // Set the serialization format for values. This should match the getID of a registered // org.apache.geode.protocol.serialization.ValueSerializer on the server side. // // If set any EncodedValue can be sent using EncodedValue.customObjectResult, and EncodedValues // sent by the server may also come back as EncodedValue.customObjectResult. // // If not set the server will attempt to convert non primative objects to JSON and // send them as EncodedValue.jsonResult. ValueFormat string `protobuf:"bytes,2,opt,name=valueFormat" json:"valueFormat,omitempty"` }
func (*HandshakeRequest) Descriptor ¶
func (*HandshakeRequest) Descriptor() ([]byte, []int)
func (*HandshakeRequest) GetCredentials ¶
func (m *HandshakeRequest) GetCredentials() map[string]string
func (*HandshakeRequest) GetValueFormat ¶
func (m *HandshakeRequest) GetValueFormat() string
func (*HandshakeRequest) ProtoMessage ¶
func (*HandshakeRequest) ProtoMessage()
func (*HandshakeRequest) Reset ¶
func (m *HandshakeRequest) Reset()
func (*HandshakeRequest) String ¶
func (m *HandshakeRequest) String() string
type HandshakeResponse ¶
type HandshakeResponse struct {
Authenticated bool `protobuf:"varint,1,opt,name=authenticated" json:"authenticated,omitempty"`
}
func (*HandshakeResponse) Descriptor ¶
func (*HandshakeResponse) Descriptor() ([]byte, []int)
func (*HandshakeResponse) GetAuthenticated ¶
func (m *HandshakeResponse) GetAuthenticated() bool
func (*HandshakeResponse) ProtoMessage ¶
func (*HandshakeResponse) ProtoMessage()
func (*HandshakeResponse) Reset ¶
func (m *HandshakeResponse) Reset()
func (*HandshakeResponse) String ¶
func (m *HandshakeResponse) String() string
type KeySetRequest ¶
type KeySetRequest struct {
RegionName string `protobuf:"bytes,1,opt,name=regionName" json:"regionName,omitempty"`
}
func (*KeySetRequest) Descriptor ¶
func (*KeySetRequest) Descriptor() ([]byte, []int)
func (*KeySetRequest) GetRegionName ¶
func (m *KeySetRequest) GetRegionName() string
func (*KeySetRequest) ProtoMessage ¶
func (*KeySetRequest) ProtoMessage()
func (*KeySetRequest) Reset ¶
func (m *KeySetRequest) Reset()
func (*KeySetRequest) String ¶
func (m *KeySetRequest) String() string
type KeySetResponse ¶
type KeySetResponse struct {
Keys []*EncodedValue `protobuf:"bytes,1,rep,name=keys" json:"keys,omitempty"`
}
func (*KeySetResponse) Descriptor ¶
func (*KeySetResponse) Descriptor() ([]byte, []int)
func (*KeySetResponse) GetKeys ¶
func (m *KeySetResponse) GetKeys() []*EncodedValue
func (*KeySetResponse) ProtoMessage ¶
func (*KeySetResponse) ProtoMessage()
func (*KeySetResponse) Reset ¶
func (m *KeySetResponse) Reset()
func (*KeySetResponse) String ¶
func (m *KeySetResponse) String() string
type KeyedError ¶
type KeyedError struct { Key *EncodedValue `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"` Error *Error `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"` }
func (*KeyedError) Descriptor ¶
func (*KeyedError) Descriptor() ([]byte, []int)
func (*KeyedError) GetError ¶
func (m *KeyedError) GetError() *Error
func (*KeyedError) GetKey ¶
func (m *KeyedError) GetKey() *EncodedValue
func (*KeyedError) ProtoMessage ¶
func (*KeyedError) ProtoMessage()
func (*KeyedError) Reset ¶
func (m *KeyedError) Reset()
func (*KeyedError) String ¶
func (m *KeyedError) String() string
type Message ¶
type Message struct { // Types that are valid to be assigned to MessageType: // *Message_ErrorResponse // *Message_PutRequest // *Message_PutResponse // *Message_GetRequest // *Message_GetResponse // *Message_PutAllRequest // *Message_PutAllResponse // *Message_GetAllRequest // *Message_GetAllResponse // *Message_RemoveRequest // *Message_RemoveResponse // *Message_GetServerRequest // *Message_GetServerResponse // *Message_GetRegionNamesRequest // *Message_GetRegionNamesResponse // *Message_GetSizeRequest // *Message_GetSizeResponse // *Message_ExecuteFunctionOnRegionRequest // *Message_ExecuteFunctionOnRegionResponse // *Message_ExecuteFunctionOnMemberRequest // *Message_ExecuteFunctionOnMemberResponse // *Message_HandshakeRequest // *Message_HandshakeResponse // *Message_ExecuteFunctionOnGroupRequest // *Message_ExecuteFunctionOnGroupResponse // *Message_OqlQueryRequest // *Message_OqlQueryResponse // *Message_KeySetRequest // *Message_KeySetResponse // *Message_DisconnectClientRequest // *Message_DisconnectClientResponse // *Message_ClearRequest // *Message_ClearResponse // *Message_PutIfAbsentRequest // *Message_PutIfAbsentResponse MessageType isMessage_MessageType `protobuf_oneof:"messageType"` }
func (*Message) Descriptor ¶
func (*Message) GetClearRequest ¶
func (m *Message) GetClearRequest() *ClearRequest
func (*Message) GetClearResponse ¶
func (m *Message) GetClearResponse() *ClearResponse
func (*Message) GetDisconnectClientRequest ¶
func (m *Message) GetDisconnectClientRequest() *DisconnectClientRequest
func (*Message) GetDisconnectClientResponse ¶
func (m *Message) GetDisconnectClientResponse() *DisconnectClientResponse
func (*Message) GetErrorResponse ¶
func (m *Message) GetErrorResponse() *ErrorResponse
func (*Message) GetExecuteFunctionOnGroupRequest ¶
func (m *Message) GetExecuteFunctionOnGroupRequest() *ExecuteFunctionOnGroupRequest
func (*Message) GetExecuteFunctionOnGroupResponse ¶
func (m *Message) GetExecuteFunctionOnGroupResponse() *ExecuteFunctionOnGroupResponse
func (*Message) GetExecuteFunctionOnMemberRequest ¶
func (m *Message) GetExecuteFunctionOnMemberRequest() *ExecuteFunctionOnMemberRequest
func (*Message) GetExecuteFunctionOnMemberResponse ¶
func (m *Message) GetExecuteFunctionOnMemberResponse() *ExecuteFunctionOnMemberResponse
func (*Message) GetExecuteFunctionOnRegionRequest ¶
func (m *Message) GetExecuteFunctionOnRegionRequest() *ExecuteFunctionOnRegionRequest
func (*Message) GetExecuteFunctionOnRegionResponse ¶
func (m *Message) GetExecuteFunctionOnRegionResponse() *ExecuteFunctionOnRegionResponse
func (*Message) GetGetAllRequest ¶
func (m *Message) GetGetAllRequest() *GetAllRequest
func (*Message) GetGetAllResponse ¶
func (m *Message) GetGetAllResponse() *GetAllResponse
func (*Message) GetGetRegionNamesRequest ¶
func (m *Message) GetGetRegionNamesRequest() *GetRegionNamesRequest
func (*Message) GetGetRegionNamesResponse ¶
func (m *Message) GetGetRegionNamesResponse() *GetRegionNamesResponse
func (*Message) GetGetRequest ¶
func (m *Message) GetGetRequest() *GetRequest
func (*Message) GetGetResponse ¶
func (m *Message) GetGetResponse() *GetResponse
func (*Message) GetGetServerRequest ¶
func (m *Message) GetGetServerRequest() *GetServerRequest
func (*Message) GetGetServerResponse ¶
func (m *Message) GetGetServerResponse() *GetServerResponse
func (*Message) GetGetSizeRequest ¶
func (m *Message) GetGetSizeRequest() *GetSizeRequest
func (*Message) GetGetSizeResponse ¶
func (m *Message) GetGetSizeResponse() *GetSizeResponse
func (*Message) GetHandshakeRequest ¶
func (m *Message) GetHandshakeRequest() *HandshakeRequest
func (*Message) GetHandshakeResponse ¶
func (m *Message) GetHandshakeResponse() *HandshakeResponse
func (*Message) GetKeySetRequest ¶
func (m *Message) GetKeySetRequest() *KeySetRequest
func (*Message) GetKeySetResponse ¶
func (m *Message) GetKeySetResponse() *KeySetResponse
func (*Message) GetMessageType ¶
func (m *Message) GetMessageType() isMessage_MessageType
func (*Message) GetOqlQueryRequest ¶
func (m *Message) GetOqlQueryRequest() *OQLQueryRequest
func (*Message) GetOqlQueryResponse ¶
func (m *Message) GetOqlQueryResponse() *OQLQueryResponse
func (*Message) GetPutAllRequest ¶
func (m *Message) GetPutAllRequest() *PutAllRequest
func (*Message) GetPutAllResponse ¶
func (m *Message) GetPutAllResponse() *PutAllResponse
func (*Message) GetPutIfAbsentRequest ¶
func (m *Message) GetPutIfAbsentRequest() *PutIfAbsentRequest
func (*Message) GetPutIfAbsentResponse ¶
func (m *Message) GetPutIfAbsentResponse() *PutIfAbsentResponse
func (*Message) GetPutRequest ¶
func (m *Message) GetPutRequest() *PutRequest
func (*Message) GetPutResponse ¶
func (m *Message) GetPutResponse() *PutResponse
func (*Message) GetRemoveRequest ¶
func (m *Message) GetRemoveRequest() *RemoveRequest
func (*Message) GetRemoveResponse ¶
func (m *Message) GetRemoveResponse() *RemoveResponse
func (*Message) ProtoMessage ¶
func (*Message) ProtoMessage()
type Message_ClearRequest ¶
type Message_ClearRequest struct {
ClearRequest *ClearRequest `protobuf:"bytes,32,opt,name=clearRequest,oneof"`
}
type Message_ClearResponse ¶
type Message_ClearResponse struct {
ClearResponse *ClearResponse `protobuf:"bytes,33,opt,name=clearResponse,oneof"`
}
type Message_DisconnectClientRequest ¶
type Message_DisconnectClientRequest struct {
DisconnectClientRequest *DisconnectClientRequest `protobuf:"bytes,30,opt,name=disconnectClientRequest,oneof"`
}
type Message_DisconnectClientResponse ¶
type Message_DisconnectClientResponse struct {
DisconnectClientResponse *DisconnectClientResponse `protobuf:"bytes,31,opt,name=disconnectClientResponse,oneof"`
}
type Message_ErrorResponse ¶
type Message_ErrorResponse struct {
ErrorResponse *ErrorResponse `protobuf:"bytes,1,opt,name=errorResponse,oneof"`
}
type Message_ExecuteFunctionOnGroupRequest ¶
type Message_ExecuteFunctionOnGroupRequest struct {
ExecuteFunctionOnGroupRequest *ExecuteFunctionOnGroupRequest `protobuf:"bytes,24,opt,name=executeFunctionOnGroupRequest,oneof"`
}
type Message_ExecuteFunctionOnGroupResponse ¶
type Message_ExecuteFunctionOnGroupResponse struct {
ExecuteFunctionOnGroupResponse *ExecuteFunctionOnGroupResponse `protobuf:"bytes,25,opt,name=executeFunctionOnGroupResponse,oneof"`
}
type Message_ExecuteFunctionOnMemberRequest ¶
type Message_ExecuteFunctionOnMemberRequest struct {
ExecuteFunctionOnMemberRequest *ExecuteFunctionOnMemberRequest `protobuf:"bytes,20,opt,name=executeFunctionOnMemberRequest,oneof"`
}
type Message_ExecuteFunctionOnMemberResponse ¶
type Message_ExecuteFunctionOnMemberResponse struct {
ExecuteFunctionOnMemberResponse *ExecuteFunctionOnMemberResponse `protobuf:"bytes,21,opt,name=executeFunctionOnMemberResponse,oneof"`
}
type Message_ExecuteFunctionOnRegionRequest ¶
type Message_ExecuteFunctionOnRegionRequest struct {
ExecuteFunctionOnRegionRequest *ExecuteFunctionOnRegionRequest `protobuf:"bytes,18,opt,name=executeFunctionOnRegionRequest,oneof"`
}
type Message_ExecuteFunctionOnRegionResponse ¶
type Message_ExecuteFunctionOnRegionResponse struct {
ExecuteFunctionOnRegionResponse *ExecuteFunctionOnRegionResponse `protobuf:"bytes,19,opt,name=executeFunctionOnRegionResponse,oneof"`
}
type Message_GetAllRequest ¶
type Message_GetAllRequest struct {
GetAllRequest *GetAllRequest `protobuf:"bytes,8,opt,name=getAllRequest,oneof"`
}
type Message_GetAllResponse ¶
type Message_GetAllResponse struct {
GetAllResponse *GetAllResponse `protobuf:"bytes,9,opt,name=getAllResponse,oneof"`
}
type Message_GetRegionNamesRequest ¶
type Message_GetRegionNamesRequest struct {
GetRegionNamesRequest *GetRegionNamesRequest `protobuf:"bytes,14,opt,name=getRegionNamesRequest,oneof"`
}
type Message_GetRegionNamesResponse ¶
type Message_GetRegionNamesResponse struct {
GetRegionNamesResponse *GetRegionNamesResponse `protobuf:"bytes,15,opt,name=getRegionNamesResponse,oneof"`
}
type Message_GetRequest ¶
type Message_GetRequest struct {
GetRequest *GetRequest `protobuf:"bytes,4,opt,name=getRequest,oneof"`
}
type Message_GetResponse ¶
type Message_GetResponse struct {
GetResponse *GetResponse `protobuf:"bytes,5,opt,name=getResponse,oneof"`
}
type Message_GetServerRequest ¶
type Message_GetServerRequest struct {
GetServerRequest *GetServerRequest `protobuf:"bytes,12,opt,name=getServerRequest,oneof"`
}
type Message_GetServerResponse ¶
type Message_GetServerResponse struct {
GetServerResponse *GetServerResponse `protobuf:"bytes,13,opt,name=getServerResponse,oneof"`
}
type Message_GetSizeRequest ¶
type Message_GetSizeRequest struct {
GetSizeRequest *GetSizeRequest `protobuf:"bytes,16,opt,name=getSizeRequest,oneof"`
}
type Message_GetSizeResponse ¶
type Message_GetSizeResponse struct {
GetSizeResponse *GetSizeResponse `protobuf:"bytes,17,opt,name=getSizeResponse,oneof"`
}
type Message_HandshakeRequest ¶
type Message_HandshakeRequest struct {
HandshakeRequest *HandshakeRequest `protobuf:"bytes,22,opt,name=handshakeRequest,oneof"`
}
type Message_HandshakeResponse ¶
type Message_HandshakeResponse struct {
HandshakeResponse *HandshakeResponse `protobuf:"bytes,23,opt,name=handshakeResponse,oneof"`
}
type Message_KeySetRequest ¶
type Message_KeySetRequest struct {
KeySetRequest *KeySetRequest `protobuf:"bytes,28,opt,name=keySetRequest,oneof"`
}
type Message_KeySetResponse ¶
type Message_KeySetResponse struct {
KeySetResponse *KeySetResponse `protobuf:"bytes,29,opt,name=keySetResponse,oneof"`
}
type Message_OqlQueryRequest ¶
type Message_OqlQueryRequest struct {
OqlQueryRequest *OQLQueryRequest `protobuf:"bytes,26,opt,name=oqlQueryRequest,oneof"`
}
type Message_OqlQueryResponse ¶
type Message_OqlQueryResponse struct {
OqlQueryResponse *OQLQueryResponse `protobuf:"bytes,27,opt,name=oqlQueryResponse,oneof"`
}
type Message_PutAllRequest ¶
type Message_PutAllRequest struct {
PutAllRequest *PutAllRequest `protobuf:"bytes,6,opt,name=putAllRequest,oneof"`
}
type Message_PutAllResponse ¶
type Message_PutAllResponse struct {
PutAllResponse *PutAllResponse `protobuf:"bytes,7,opt,name=putAllResponse,oneof"`
}
type Message_PutIfAbsentRequest ¶
type Message_PutIfAbsentRequest struct {
PutIfAbsentRequest *PutIfAbsentRequest `protobuf:"bytes,34,opt,name=putIfAbsentRequest,oneof"`
}
type Message_PutIfAbsentResponse ¶
type Message_PutIfAbsentResponse struct {
PutIfAbsentResponse *PutIfAbsentResponse `protobuf:"bytes,35,opt,name=putIfAbsentResponse,oneof"`
}
type Message_PutRequest ¶
type Message_PutRequest struct {
PutRequest *PutRequest `protobuf:"bytes,2,opt,name=putRequest,oneof"`
}
type Message_PutResponse ¶
type Message_PutResponse struct {
PutResponse *PutResponse `protobuf:"bytes,3,opt,name=putResponse,oneof"`
}
type Message_RemoveRequest ¶
type Message_RemoveRequest struct {
RemoveRequest *RemoveRequest `protobuf:"bytes,10,opt,name=removeRequest,oneof"`
}
type Message_RemoveResponse ¶
type Message_RemoveResponse struct {
RemoveResponse *RemoveResponse `protobuf:"bytes,11,opt,name=removeResponse,oneof"`
}
type OQLQueryRequest ¶
type OQLQueryRequest struct { Query string `protobuf:"bytes,1,opt,name=query" json:"query,omitempty"` BindParameter []*EncodedValue `protobuf:"bytes,2,rep,name=bindParameter" json:"bindParameter,omitempty"` }
func (*OQLQueryRequest) Descriptor ¶
func (*OQLQueryRequest) Descriptor() ([]byte, []int)
func (*OQLQueryRequest) GetBindParameter ¶
func (m *OQLQueryRequest) GetBindParameter() []*EncodedValue
func (*OQLQueryRequest) GetQuery ¶
func (m *OQLQueryRequest) GetQuery() string
func (*OQLQueryRequest) ProtoMessage ¶
func (*OQLQueryRequest) ProtoMessage()
func (*OQLQueryRequest) Reset ¶
func (m *OQLQueryRequest) Reset()
func (*OQLQueryRequest) String ¶
func (m *OQLQueryRequest) String() string
type OQLQueryResponse ¶
type OQLQueryResponse struct { // Types that are valid to be assigned to Result: // *OQLQueryResponse_SingleResult // *OQLQueryResponse_ListResult // *OQLQueryResponse_TableResult Result isOQLQueryResponse_Result `protobuf_oneof:"result"` }
Response to an OQL query. Depending on the query, it may return a single value, a list of values, or a table of values.
func (*OQLQueryResponse) Descriptor ¶
func (*OQLQueryResponse) Descriptor() ([]byte, []int)
func (*OQLQueryResponse) GetListResult ¶
func (m *OQLQueryResponse) GetListResult() *EncodedValueList
func (*OQLQueryResponse) GetResult ¶
func (m *OQLQueryResponse) GetResult() isOQLQueryResponse_Result
func (*OQLQueryResponse) GetSingleResult ¶
func (m *OQLQueryResponse) GetSingleResult() *EncodedValue
func (*OQLQueryResponse) GetTableResult ¶
func (m *OQLQueryResponse) GetTableResult() *Table
func (*OQLQueryResponse) ProtoMessage ¶
func (*OQLQueryResponse) ProtoMessage()
func (*OQLQueryResponse) Reset ¶
func (m *OQLQueryResponse) Reset()
func (*OQLQueryResponse) String ¶
func (m *OQLQueryResponse) String() string
func (*OQLQueryResponse) XXX_OneofFuncs ¶
func (*OQLQueryResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
type OQLQueryResponse_ListResult ¶
type OQLQueryResponse_ListResult struct {
ListResult *EncodedValueList `protobuf:"bytes,2,opt,name=listResult,oneof"`
}
type OQLQueryResponse_SingleResult ¶
type OQLQueryResponse_SingleResult struct {
SingleResult *EncodedValue `protobuf:"bytes,1,opt,name=singleResult,oneof"`
}
type OQLQueryResponse_TableResult ¶
type OQLQueryResponse_TableResult struct {
TableResult *Table `protobuf:"bytes,3,opt,name=tableResult,oneof"`
}
type PutAllRequest ¶
type PutAllRequest struct { RegionName string `protobuf:"bytes,1,opt,name=regionName" json:"regionName,omitempty"` Entry []*Entry `protobuf:"bytes,2,rep,name=entry" json:"entry,omitempty"` }
func (*PutAllRequest) Descriptor ¶
func (*PutAllRequest) Descriptor() ([]byte, []int)
func (*PutAllRequest) GetEntry ¶
func (m *PutAllRequest) GetEntry() []*Entry
func (*PutAllRequest) GetRegionName ¶
func (m *PutAllRequest) GetRegionName() string
func (*PutAllRequest) ProtoMessage ¶
func (*PutAllRequest) ProtoMessage()
func (*PutAllRequest) Reset ¶
func (m *PutAllRequest) Reset()
func (*PutAllRequest) String ¶
func (m *PutAllRequest) String() string
type PutAllResponse ¶
type PutAllResponse struct {
FailedKeys []*KeyedError `protobuf:"bytes,1,rep,name=failedKeys" json:"failedKeys,omitempty"`
}
func (*PutAllResponse) Descriptor ¶
func (*PutAllResponse) Descriptor() ([]byte, []int)
func (*PutAllResponse) GetFailedKeys ¶
func (m *PutAllResponse) GetFailedKeys() []*KeyedError
func (*PutAllResponse) ProtoMessage ¶
func (*PutAllResponse) ProtoMessage()
func (*PutAllResponse) Reset ¶
func (m *PutAllResponse) Reset()
func (*PutAllResponse) String ¶
func (m *PutAllResponse) String() string
type PutIfAbsentRequest ¶
type PutIfAbsentRequest struct { RegionName string `protobuf:"bytes,1,opt,name=regionName" json:"regionName,omitempty"` Entry *Entry `protobuf:"bytes,2,opt,name=entry" json:"entry,omitempty"` }
func (*PutIfAbsentRequest) Descriptor ¶
func (*PutIfAbsentRequest) Descriptor() ([]byte, []int)
func (*PutIfAbsentRequest) GetEntry ¶
func (m *PutIfAbsentRequest) GetEntry() *Entry
func (*PutIfAbsentRequest) GetRegionName ¶
func (m *PutIfAbsentRequest) GetRegionName() string
func (*PutIfAbsentRequest) ProtoMessage ¶
func (*PutIfAbsentRequest) ProtoMessage()
func (*PutIfAbsentRequest) Reset ¶
func (m *PutIfAbsentRequest) Reset()
func (*PutIfAbsentRequest) String ¶
func (m *PutIfAbsentRequest) String() string
type PutIfAbsentResponse ¶
type PutIfAbsentResponse struct {
OldValue *EncodedValue `protobuf:"bytes,1,opt,name=oldValue" json:"oldValue,omitempty"`
}
func (*PutIfAbsentResponse) Descriptor ¶
func (*PutIfAbsentResponse) Descriptor() ([]byte, []int)
func (*PutIfAbsentResponse) GetOldValue ¶
func (m *PutIfAbsentResponse) GetOldValue() *EncodedValue
func (*PutIfAbsentResponse) ProtoMessage ¶
func (*PutIfAbsentResponse) ProtoMessage()
func (*PutIfAbsentResponse) Reset ¶
func (m *PutIfAbsentResponse) Reset()
func (*PutIfAbsentResponse) String ¶
func (m *PutIfAbsentResponse) String() string
type PutRequest ¶
type PutRequest struct { RegionName string `protobuf:"bytes,1,opt,name=regionName" json:"regionName,omitempty"` Entry *Entry `protobuf:"bytes,2,opt,name=entry" json:"entry,omitempty"` }
func (*PutRequest) Descriptor ¶
func (*PutRequest) Descriptor() ([]byte, []int)
func (*PutRequest) GetEntry ¶
func (m *PutRequest) GetEntry() *Entry
func (*PutRequest) GetRegionName ¶
func (m *PutRequest) GetRegionName() string
func (*PutRequest) ProtoMessage ¶
func (*PutRequest) ProtoMessage()
func (*PutRequest) Reset ¶
func (m *PutRequest) Reset()
func (*PutRequest) String ¶
func (m *PutRequest) String() string
type PutResponse ¶
type PutResponse struct { }
func (*PutResponse) Descriptor ¶
func (*PutResponse) Descriptor() ([]byte, []int)
func (*PutResponse) ProtoMessage ¶
func (*PutResponse) ProtoMessage()
func (*PutResponse) Reset ¶
func (m *PutResponse) Reset()
func (*PutResponse) String ¶
func (m *PutResponse) String() string
type RemoveRequest ¶
type RemoveRequest struct { RegionName string `protobuf:"bytes,1,opt,name=regionName" json:"regionName,omitempty"` Key *EncodedValue `protobuf:"bytes,2,opt,name=key" json:"key,omitempty"` }
func (*RemoveRequest) Descriptor ¶
func (*RemoveRequest) Descriptor() ([]byte, []int)
func (*RemoveRequest) GetKey ¶
func (m *RemoveRequest) GetKey() *EncodedValue
func (*RemoveRequest) GetRegionName ¶
func (m *RemoveRequest) GetRegionName() string
func (*RemoveRequest) ProtoMessage ¶
func (*RemoveRequest) ProtoMessage()
func (*RemoveRequest) Reset ¶
func (m *RemoveRequest) Reset()
func (*RemoveRequest) String ¶
func (m *RemoveRequest) String() string
type RemoveResponse ¶
type RemoveResponse struct { }
func (*RemoveResponse) Descriptor ¶
func (*RemoveResponse) Descriptor() ([]byte, []int)
func (*RemoveResponse) ProtoMessage ¶
func (*RemoveResponse) ProtoMessage()
func (*RemoveResponse) Reset ¶
func (m *RemoveResponse) Reset()
func (*RemoveResponse) String ¶
func (m *RemoveResponse) String() string
type Server ¶
type Server struct { Hostname string `protobuf:"bytes,1,opt,name=hostname" json:"hostname,omitempty"` Port int32 `protobuf:"varint,2,opt,name=port" json:"port,omitempty"` }
func (*Server) Descriptor ¶
func (*Server) GetHostname ¶
func (*Server) ProtoMessage ¶
func (*Server) ProtoMessage()
type Table ¶
type Table struct { FieldName []string `protobuf:"bytes,1,rep,name=fieldName" json:"fieldName,omitempty"` Row []*EncodedValueList `protobuf:"bytes,2,rep,name=row" json:"row,omitempty"` }
Represents a table, such as the results of an OQL query. The field names and all rows should have the same number of elements.
func (*Table) Descriptor ¶
func (*Table) GetFieldName ¶
func (*Table) GetRow ¶
func (m *Table) GetRow() []*EncodedValueList
func (*Table) ProtoMessage ¶
func (*Table) ProtoMessage()
Click to show internal directories.
Click to hide internal directories.