kv

package
v0.0.0-...-3519da2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 7, 2019 License: MIT Imports: 8 Imported by: 0

Documentation

Index

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 Dial 

func Dial(url string) (Client, error)

func MakeClient 

func MakeClient(t Transport) (Client, error)

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) Init 

func (rcv *GetReply) Init(buf []byte, i flatbuffers.UOffsetT)

func (*GetReply) MutateVersion 

func (rcv *GetReply) MutateVersion(n uint64) bool

func (*GetReply) Table 

func (rcv *GetReply) Table() flatbuffers.Table

func (*GetReply) Value 

func (rcv *GetReply) Value() []byte

func (*GetReply) Version 

func (rcv *GetReply) Version() uint64

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) Init 

func (rcv *ListEntry) Init(buf []byte, i flatbuffers.UOffsetT)

func (*ListEntry) Key 

func (rcv *ListEntry) Key() []byte

func (*ListEntry) MutateVersion 

func (rcv *ListEntry) MutateVersion(n uint64) bool

func (*ListEntry) Table 

func (rcv *ListEntry) Table() flatbuffers.Table

func (*ListEntry) Version 

func (rcv *ListEntry) Version() uint64

type ListItem 

type ListItem struct {
	Key     string
	Version uint64
}

type ListReply 

type ListReply struct {
	// contains filtered or unexported fields
}

func GetRootAsListReply 

func GetRootAsListReply(buf []byte, offset flatbuffers.UOffsetT) *ListReply

func (*ListReply) Init 

func (rcv *ListReply) Init(buf []byte, i flatbuffers.UOffsetT)

func (*ListReply) Items 

func (rcv *ListReply) Items(obj *ListEntry, j int) bool

func (*ListReply) ItemsLength 

func (rcv *ListReply) ItemsLength() int

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) Actual 

func (rcv *Message) Actual(obj *flatbuffers.Table) bool

func (*Message) ActualType 

func (rcv *Message) ActualType() MessageKind

func (*Message) Init 

func (rcv *Message) Init(buf []byte, i flatbuffers.UOffsetT)

func (*Message) MutateActualType 

func (rcv *Message) MutateActualType(n MessageKind) bool

func (*Message) MutateReqId 

func (rcv *Message) MutateReqId(n uint64) bool

func (*Message) ReqId 

func (rcv *Message) ReqId() uint64

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 NngSocket 

type NngSocket struct {
	// contains filtered or unexported fields
}

func (*NngSocket) Close 

func (self *NngSocket) Close() error

func (*NngSocket) Recv 

func (self *NngSocket) Recv() ([]byte, error)

func (*NngSocket) Send 

func (self *NngSocket) 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) Init 

func (rcv *PingReply) Init(buf []byte, i flatbuffers.UOffsetT)

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) Init 

func (rcv *PutReply) Init(buf []byte, i flatbuffers.UOffsetT)

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

type Transport 

type Transport interface {
	Close() error
	Send(b []byte) error
	Recv() ([]byte, error)
}

func MakeNngSocket 

func MakeNngSocket(url string) (Transport, error)

func ShareNngSocket 

func ShareNngSocket(t Transport) (Transport, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.