Documentation ¶
Index ¶
- type BatchedRequest
- func (z *BatchedRequest) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *BatchedRequest) EncodeMsg(en *msgp.Writer) (err error)
- func (z *BatchedRequest) MarshalMsg(b []byte) (o []byte, err error)
- func (z *BatchedRequest) Msgsize() (s int)
- func (z *BatchedRequest) UnmarshalMsg(bts []byte) (o []byte, err error)
- type BatchedResponse
- func (z *BatchedResponse) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *BatchedResponse) EncodeMsg(en *msgp.Writer) (err error)
- func (z *BatchedResponse) MarshalMsg(b []byte) (o []byte, err error)
- func (z *BatchedResponse) Msgsize() (s int)
- func (z *BatchedResponse) UnmarshalMsg(bts []byte) (o []byte, err error)
- type Operation
- func (z *Operation) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *Operation) EncodeMsg(en *msgp.Writer) (err error)
- func (op Operation) Index() string
- func (z *Operation) MarshalMsg(b []byte) (o []byte, err error)
- func (z *Operation) Msgsize() (s int)
- func (z *Operation) UnmarshalMsg(bts []byte) (o []byte, err error)
- type OperationType
- func (z *OperationType) DecodeMsg(dc *msgp.Reader) (err error)
- func (z OperationType) EncodeMsg(en *msgp.Writer) (err error)
- func (z OperationType) MarshalMsg(b []byte) (o []byte, err error)
- func (z OperationType) Msgsize() (s int)
- func (op OperationType) String() string
- func (z *OperationType) UnmarshalMsg(bts []byte) (o []byte, err error)
- type Result
- type ResultStatus
- func (z *ResultStatus) DecodeMsg(dc *msgp.Reader) (err error)
- func (z ResultStatus) EncodeMsg(en *msgp.Writer) (err error)
- func (z ResultStatus) MarshalMsg(b []byte) (o []byte, err error)
- func (z ResultStatus) Msgsize() (s int)
- func (status ResultStatus) String() string
- func (z *ResultStatus) UnmarshalMsg(bts []byte) (o []byte, err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BatchedRequest ¶
type BatchedRequest struct {
Operations []Operation `msg:"operations"`
}
func (*BatchedRequest) DecodeMsg ¶
func (z *BatchedRequest) DecodeMsg(dc *msgp.Reader) (err error)
DecodeMsg implements msgp.Decodable
func (*BatchedRequest) EncodeMsg ¶
func (z *BatchedRequest) EncodeMsg(en *msgp.Writer) (err error)
EncodeMsg implements msgp.Encodable
func (*BatchedRequest) MarshalMsg ¶
func (z *BatchedRequest) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (*BatchedRequest) Msgsize ¶
func (z *BatchedRequest) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*BatchedRequest) UnmarshalMsg ¶
func (z *BatchedRequest) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
type BatchedResponse ¶
type BatchedResponse struct {
Results []Result `msg:"results"`
}
func (*BatchedResponse) DecodeMsg ¶
func (z *BatchedResponse) DecodeMsg(dc *msgp.Reader) (err error)
DecodeMsg implements msgp.Decodable
func (*BatchedResponse) EncodeMsg ¶
func (z *BatchedResponse) EncodeMsg(en *msgp.Writer) (err error)
EncodeMsg implements msgp.Encodable
func (*BatchedResponse) MarshalMsg ¶
func (z *BatchedResponse) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (*BatchedResponse) Msgsize ¶
func (z *BatchedResponse) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*BatchedResponse) UnmarshalMsg ¶
func (z *BatchedResponse) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
type Operation ¶
type Operation struct { Type OperationType `msg:"type"` Key []byte `msg:"key"` Value []byte `msg:"value"` }
func (*Operation) MarshalMsg ¶
MarshalMsg implements msgp.Marshaler
type OperationType ¶
type OperationType int
const ( SET OperationType = iota GET DELETE PING )
func (*OperationType) DecodeMsg ¶
func (z *OperationType) DecodeMsg(dc *msgp.Reader) (err error)
DecodeMsg implements msgp.Decodable
func (OperationType) EncodeMsg ¶
func (z OperationType) EncodeMsg(en *msgp.Writer) (err error)
EncodeMsg implements msgp.Encodable
func (OperationType) MarshalMsg ¶
func (z OperationType) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (OperationType) Msgsize ¶
func (z OperationType) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (OperationType) String ¶
func (op OperationType) String() string
func (*OperationType) UnmarshalMsg ¶
func (z *OperationType) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
type Result ¶
type Result struct { Status ResultStatus `msg:"status"` Message []byte `msg:"message"` }
func (*Result) MarshalMsg ¶
MarshalMsg implements msgp.Marshaler
type ResultStatus ¶
type ResultStatus int
const ( SUCCESS ResultStatus = iota FAILURE )
func (*ResultStatus) DecodeMsg ¶
func (z *ResultStatus) DecodeMsg(dc *msgp.Reader) (err error)
DecodeMsg implements msgp.Decodable
func (ResultStatus) EncodeMsg ¶
func (z ResultStatus) EncodeMsg(en *msgp.Writer) (err error)
EncodeMsg implements msgp.Encodable
func (ResultStatus) MarshalMsg ¶
func (z ResultStatus) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (ResultStatus) Msgsize ¶
func (z ResultStatus) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (ResultStatus) String ¶
func (status ResultStatus) String() string
func (*ResultStatus) UnmarshalMsg ¶
func (z *ResultStatus) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler