Documentation
¶
Index ¶
- Variables
- func ErrorReplyAddCode(builder *flatbuffers.Builder, code uint16)
- func ErrorReplyAddMessage(builder *flatbuffers.Builder, message flatbuffers.UOffsetT)
- func ErrorReplyEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func ErrorReplyStart(builder *flatbuffers.Builder)
- func GetReplyAddValue(builder *flatbuffers.Builder, value flatbuffers.UOffsetT)
- func GetReplyAddVersion(builder *flatbuffers.Builder, version uint64)
- func GetReplyEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func GetReplyStart(builder *flatbuffers.Builder)
- func GetRequestAddBase(builder *flatbuffers.Builder, base flatbuffers.UOffsetT)
- func GetRequestAddKey(builder *flatbuffers.Builder, key flatbuffers.UOffsetT)
- func GetRequestAddVersion(builder *flatbuffers.Builder, version uint64)
- func GetRequestEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func GetRequestStart(builder *flatbuffers.Builder)
- func ListEntryAddKey(builder *flatbuffers.Builder, key flatbuffers.UOffsetT)
- func ListEntryAddVersion(builder *flatbuffers.Builder, version uint64)
- func ListEntryEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func ListEntryStart(builder *flatbuffers.Builder)
- func ListReplyAddItems(builder *flatbuffers.Builder, items flatbuffers.UOffsetT)
- func ListReplyEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func ListReplyStart(builder *flatbuffers.Builder)
- func ListReplyStartItemsVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func ListRequestAddBase(builder *flatbuffers.Builder, base flatbuffers.UOffsetT)
- func ListRequestAddMarker(builder *flatbuffers.Builder, marker flatbuffers.UOffsetT)
- func ListRequestAddMarkerVersion(builder *flatbuffers.Builder, markerVersion uint64)
- func ListRequestAddMax(builder *flatbuffers.Builder, max uint16)
- func ListRequestEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func ListRequestStart(builder *flatbuffers.Builder)
- func MessageAddActual(builder *flatbuffers.Builder, actual flatbuffers.UOffsetT)
- func MessageAddActualType(builder *flatbuffers.Builder, actualType MessageKind)
- func MessageAddReqId(builder *flatbuffers.Builder, reqId uint64)
- func MessageEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func MessageStart(builder *flatbuffers.Builder)
- func PingReplyEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func PingReplyStart(builder *flatbuffers.Builder)
- func PingRequestEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func PingRequestStart(builder *flatbuffers.Builder)
- func PutReplyEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func PutReplyStart(builder *flatbuffers.Builder)
- func PutRequestAddBase(builder *flatbuffers.Builder, base flatbuffers.UOffsetT)
- func PutRequestAddKey(builder *flatbuffers.Builder, key flatbuffers.UOffsetT)
- func PutRequestAddValue(builder *flatbuffers.Builder, value flatbuffers.UOffsetT)
- func PutRequestAddVersion(builder *flatbuffers.Builder, version uint64)
- func PutRequestEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func PutRequestStart(builder *flatbuffers.Builder)
- type Client
- type ErrorReply
- type GetReply
- type GetRequest
- type ListEntry
- type ListItem
- type ListReply
- type ListRequest
- func (rcv *ListRequest) Base() []byte
- func (rcv *ListRequest) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *ListRequest) Marker() []byte
- func (rcv *ListRequest) MarkerVersion() uint64
- func (rcv *ListRequest) Max() uint16
- func (rcv *ListRequest) MutateMarkerVersion(n uint64) bool
- func (rcv *ListRequest) MutateMax(n uint16) bool
- func (rcv *ListRequest) Table() flatbuffers.Table
- type Message
- func (rcv *Message) Actual(obj *flatbuffers.Table) bool
- func (rcv *Message) ActualType() MessageKind
- func (rcv *Message) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *Message) MutateActualType(n MessageKind) bool
- func (rcv *Message) MutateReqId(n uint64) bool
- func (rcv *Message) ReqId() uint64
- func (rcv *Message) Table() flatbuffers.Table
- type MessageKind
- type NngContext
- type NngSocket
- type PingReply
- type PingRequest
- type PutReply
- type PutRequest
- func (rcv *PutRequest) Base() []byte
- func (rcv *PutRequest) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *PutRequest) Key() []byte
- func (rcv *PutRequest) MutateVersion(n uint64) bool
- func (rcv *PutRequest) Table() flatbuffers.Table
- func (rcv *PutRequest) Value() []byte
- func (rcv *PutRequest) Version() uint64
- type Transport
Constants ¶
This section is empty.
Variables ¶
View Source
var EnumNamesMessageKind = map[MessageKind]string{ MessageKindNONE: "NONE", MessageKindPingRequest: "PingRequest", MessageKindPutRequest: "PutRequest", MessageKindGetRequest: "GetRequest", MessageKindListRequest: "ListRequest", MessageKindPingReply: "PingReply", MessageKindPutReply: "PutReply", MessageKindGetReply: "GetReply", MessageKindListReply: "ListReply", MessageKindErrorReply: "ErrorReply", }
View Source
var EnumValuesMessageKind = map[string]MessageKind{ "NONE": MessageKindNONE, "PingRequest": MessageKindPingRequest, "PutRequest": MessageKindPutRequest, "GetRequest": MessageKindGetRequest, "ListRequest": MessageKindListRequest, "PingReply": MessageKindPingReply, "PutReply": MessageKindPutReply, "GetReply": MessageKindGetReply, "ListReply": MessageKindListReply, "ErrorReply": MessageKindErrorReply, }
Functions ¶
func ErrorReplyAddCode ¶
func ErrorReplyAddCode(builder *flatbuffers.Builder, code uint16)
func ErrorReplyAddMessage ¶
func ErrorReplyAddMessage(builder *flatbuffers.Builder, message flatbuffers.UOffsetT)
func ErrorReplyEnd ¶
func ErrorReplyEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func ErrorReplyStart ¶
func ErrorReplyStart(builder *flatbuffers.Builder)
func GetReplyAddValue ¶
func GetReplyAddValue(builder *flatbuffers.Builder, value flatbuffers.UOffsetT)
func GetReplyAddVersion ¶
func GetReplyAddVersion(builder *flatbuffers.Builder, version uint64)
func GetReplyEnd ¶
func GetReplyEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func GetReplyStart ¶
func GetReplyStart(builder *flatbuffers.Builder)
func GetRequestAddBase ¶
func GetRequestAddBase(builder *flatbuffers.Builder, base flatbuffers.UOffsetT)
func GetRequestAddKey ¶
func GetRequestAddKey(builder *flatbuffers.Builder, key flatbuffers.UOffsetT)
func GetRequestAddVersion ¶
func GetRequestAddVersion(builder *flatbuffers.Builder, version uint64)
func GetRequestEnd ¶
func GetRequestEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func GetRequestStart ¶
func GetRequestStart(builder *flatbuffers.Builder)
func ListEntryAddKey ¶
func ListEntryAddKey(builder *flatbuffers.Builder, key flatbuffers.UOffsetT)
func ListEntryAddVersion ¶
func ListEntryAddVersion(builder *flatbuffers.Builder, version uint64)
func ListEntryEnd ¶
func ListEntryEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func ListEntryStart ¶
func ListEntryStart(builder *flatbuffers.Builder)
func ListReplyAddItems ¶
func ListReplyAddItems(builder *flatbuffers.Builder, items flatbuffers.UOffsetT)
func ListReplyEnd ¶
func ListReplyEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func ListReplyStart ¶
func ListReplyStart(builder *flatbuffers.Builder)
func ListReplyStartItemsVector ¶
func ListReplyStartItemsVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func ListRequestAddBase ¶
func ListRequestAddBase(builder *flatbuffers.Builder, base flatbuffers.UOffsetT)
func ListRequestAddMarker ¶
func ListRequestAddMarker(builder *flatbuffers.Builder, marker flatbuffers.UOffsetT)
func ListRequestAddMarkerVersion ¶
func ListRequestAddMarkerVersion(builder *flatbuffers.Builder, markerVersion uint64)
func ListRequestAddMax ¶
func ListRequestAddMax(builder *flatbuffers.Builder, max uint16)
func ListRequestEnd ¶
func ListRequestEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func ListRequestStart ¶
func ListRequestStart(builder *flatbuffers.Builder)
func MessageAddActual ¶
func MessageAddActual(builder *flatbuffers.Builder, actual flatbuffers.UOffsetT)
func MessageAddActualType ¶
func MessageAddActualType(builder *flatbuffers.Builder, actualType MessageKind)
func MessageAddReqId ¶
func MessageAddReqId(builder *flatbuffers.Builder, reqId uint64)
func MessageEnd ¶
func MessageEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func MessageStart ¶
func MessageStart(builder *flatbuffers.Builder)
func PingReplyEnd ¶
func PingReplyEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func PingReplyStart ¶
func PingReplyStart(builder *flatbuffers.Builder)
func PingRequestEnd ¶
func PingRequestEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func PingRequestStart ¶
func PingRequestStart(builder *flatbuffers.Builder)
func PutReplyEnd ¶
func PutReplyEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func PutReplyStart ¶
func PutReplyStart(builder *flatbuffers.Builder)
func PutRequestAddBase ¶
func PutRequestAddBase(builder *flatbuffers.Builder, base flatbuffers.UOffsetT)
func PutRequestAddKey ¶
func PutRequestAddKey(builder *flatbuffers.Builder, key flatbuffers.UOffsetT)
func PutRequestAddValue ¶
func PutRequestAddValue(builder *flatbuffers.Builder, value flatbuffers.UOffsetT)
func PutRequestAddVersion ¶
func PutRequestAddVersion(builder *flatbuffers.Builder, version uint64)
func PutRequestEnd ¶
func PutRequestEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func PutRequestStart ¶
func PutRequestStart(builder *flatbuffers.Builder)
Types ¶
type Client ¶
type Client interface { Close() error Ping() error Put(base, key string, value []byte) error Get(base, key string) ([]byte, error) List(base, marker string) ([]ListItem, error) }
func MakeClient ¶
type ErrorReply ¶
type ErrorReply struct {
// contains filtered or unexported fields
}
func GetRootAsErrorReply ¶
func GetRootAsErrorReply(buf []byte, offset flatbuffers.UOffsetT) *ErrorReply
func (*ErrorReply) Code ¶
func (rcv *ErrorReply) Code() uint16
func (*ErrorReply) Init ¶
func (rcv *ErrorReply) Init(buf []byte, i flatbuffers.UOffsetT)
func (*ErrorReply) Message ¶
func (rcv *ErrorReply) Message() []byte
func (*ErrorReply) MutateCode ¶
func (rcv *ErrorReply) MutateCode(n uint16) bool
func (*ErrorReply) Table ¶
func (rcv *ErrorReply) Table() flatbuffers.Table
type GetReply ¶
type GetReply struct {
// contains filtered or unexported fields
}
func GetRootAsGetReply ¶
func GetRootAsGetReply(buf []byte, offset flatbuffers.UOffsetT) *GetReply
func (*GetReply) MutateVersion ¶
func (*GetReply) Table ¶
func (rcv *GetReply) Table() flatbuffers.Table
type GetRequest ¶
type GetRequest struct {
// contains filtered or unexported fields
}
func GetRootAsGetRequest ¶
func GetRootAsGetRequest(buf []byte, offset flatbuffers.UOffsetT) *GetRequest
func (*GetRequest) Base ¶
func (rcv *GetRequest) Base() []byte
func (*GetRequest) Init ¶
func (rcv *GetRequest) Init(buf []byte, i flatbuffers.UOffsetT)
func (*GetRequest) Key ¶
func (rcv *GetRequest) Key() []byte
func (*GetRequest) MutateVersion ¶
func (rcv *GetRequest) MutateVersion(n uint64) bool
func (*GetRequest) Table ¶
func (rcv *GetRequest) Table() flatbuffers.Table
func (*GetRequest) Version ¶
func (rcv *GetRequest) Version() uint64
type ListEntry ¶
type ListEntry struct {
// contains filtered or unexported fields
}
func GetRootAsListEntry ¶
func GetRootAsListEntry(buf []byte, offset flatbuffers.UOffsetT) *ListEntry
func (*ListEntry) MutateVersion ¶
func (*ListEntry) Table ¶
func (rcv *ListEntry) Table() flatbuffers.Table
type ListReply ¶
type ListReply struct {
// contains filtered or unexported fields
}
func GetRootAsListReply ¶
func GetRootAsListReply(buf []byte, offset flatbuffers.UOffsetT) *ListReply
func (*ListReply) ItemsLength ¶
func (*ListReply) Table ¶
func (rcv *ListReply) Table() flatbuffers.Table
type ListRequest ¶
type ListRequest struct {
// contains filtered or unexported fields
}
func GetRootAsListRequest ¶
func GetRootAsListRequest(buf []byte, offset flatbuffers.UOffsetT) *ListRequest
func (*ListRequest) Base ¶
func (rcv *ListRequest) Base() []byte
func (*ListRequest) Init ¶
func (rcv *ListRequest) Init(buf []byte, i flatbuffers.UOffsetT)
func (*ListRequest) Marker ¶
func (rcv *ListRequest) Marker() []byte
func (*ListRequest) MarkerVersion ¶
func (rcv *ListRequest) MarkerVersion() uint64
func (*ListRequest) Max ¶
func (rcv *ListRequest) Max() uint16
func (*ListRequest) MutateMarkerVersion ¶
func (rcv *ListRequest) MutateMarkerVersion(n uint64) bool
func (*ListRequest) MutateMax ¶
func (rcv *ListRequest) MutateMax(n uint16) bool
func (*ListRequest) Table ¶
func (rcv *ListRequest) Table() flatbuffers.Table
type Message ¶
type Message struct {
// contains filtered or unexported fields
}
func GetRootAsMessage ¶
func GetRootAsMessage(buf []byte, offset flatbuffers.UOffsetT) *Message
func (*Message) ActualType ¶
func (rcv *Message) ActualType() MessageKind
func (*Message) MutateActualType ¶
func (rcv *Message) MutateActualType(n MessageKind) bool
func (*Message) MutateReqId ¶
func (*Message) Table ¶
func (rcv *Message) Table() flatbuffers.Table
type MessageKind ¶
type MessageKind byte
const ( MessageKindNONE MessageKind = 0 MessageKindPingRequest MessageKind = 1 MessageKindPutRequest MessageKind = 2 MessageKindGetRequest MessageKind = 3 MessageKindListRequest MessageKind = 4 MessageKindPingReply MessageKind = 5 MessageKindPutReply MessageKind = 6 MessageKindGetReply MessageKind = 7 MessageKindListReply MessageKind = 8 MessageKindErrorReply MessageKind = 9 )
func (MessageKind) String ¶
func (v MessageKind) String() string
type NngContext ¶
type NngContext struct {
// contains filtered or unexported fields
}
func (*NngContext) Close ¶
func (self *NngContext) Close() error
func (*NngContext) Recv ¶
func (self *NngContext) Recv() ([]byte, error)
func (*NngContext) Send ¶
func (self *NngContext) Send(buffer []byte) error
type PingReply ¶
type PingReply struct {
// contains filtered or unexported fields
}
func GetRootAsPingReply ¶
func GetRootAsPingReply(buf []byte, offset flatbuffers.UOffsetT) *PingReply
func (*PingReply) Table ¶
func (rcv *PingReply) Table() flatbuffers.Table
type PingRequest ¶
type PingRequest struct {
// contains filtered or unexported fields
}
func GetRootAsPingRequest ¶
func GetRootAsPingRequest(buf []byte, offset flatbuffers.UOffsetT) *PingRequest
func (*PingRequest) Init ¶
func (rcv *PingRequest) Init(buf []byte, i flatbuffers.UOffsetT)
func (*PingRequest) Table ¶
func (rcv *PingRequest) Table() flatbuffers.Table
type PutReply ¶
type PutReply struct {
// contains filtered or unexported fields
}
func GetRootAsPutReply ¶
func GetRootAsPutReply(buf []byte, offset flatbuffers.UOffsetT) *PutReply
func (*PutReply) Table ¶
func (rcv *PutReply) Table() flatbuffers.Table
type PutRequest ¶
type PutRequest struct {
// contains filtered or unexported fields
}
func GetRootAsPutRequest ¶
func GetRootAsPutRequest(buf []byte, offset flatbuffers.UOffsetT) *PutRequest
func (*PutRequest) Base ¶
func (rcv *PutRequest) Base() []byte
func (*PutRequest) Init ¶
func (rcv *PutRequest) Init(buf []byte, i flatbuffers.UOffsetT)
func (*PutRequest) Key ¶
func (rcv *PutRequest) Key() []byte
func (*PutRequest) MutateVersion ¶
func (rcv *PutRequest) MutateVersion(n uint64) bool
func (*PutRequest) Table ¶
func (rcv *PutRequest) Table() flatbuffers.Table
func (*PutRequest) Value ¶
func (rcv *PutRequest) Value() []byte
func (*PutRequest) Version ¶
func (rcv *PutRequest) Version() uint64
Click to show internal directories.
Click to hide internal directories.