Documentation ¶
Index ¶
- func CreateTaskState(builder *flatbuffers.Builder, status byte, repeats uint32, created int64, ...) flatbuffers.UOffsetT
- func QueryAddIdxFrom(builder *flatbuffers.Builder, idxFrom flatbuffers.UOffsetT)
- func QueryAddIdxLast(builder *flatbuffers.Builder, idxLast flatbuffers.UOffsetT)
- func QueryAddIdxType(builder *flatbuffers.Builder, idxType uint16)
- func QueryAddLastKey(builder *flatbuffers.Builder, lastKey flatbuffers.UOffsetT)
- func QueryAddLimit(builder *flatbuffers.Builder, limit uint32)
- func QueryAddPage(builder *flatbuffers.Builder, page uint32)
- func QueryAddQueryID(builder *flatbuffers.Builder, queryID flatbuffers.UOffsetT)
- func QueryAddReverse(builder *flatbuffers.Builder, reverse bool)
- func QueryAddSize(builder *flatbuffers.Builder, size uint32)
- func QueryEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func QueryStart(builder *flatbuffers.Builder)
- func QueryStartIdxFromVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func QueryStartIdxLastVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func QueryStartLastKeyVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func QueryStartQueryIDVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func RowAddData(builder *flatbuffers.Builder, data flatbuffers.UOffsetT)
- func RowAddDrop(builder *flatbuffers.Builder, drop flatbuffers.UOffsetT)
- func RowEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func RowStart(builder *flatbuffers.Builder)
- func RowStartDataVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func RowStartDropVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func TaskAddCreator(builder *flatbuffers.Builder, creator flatbuffers.UOffsetT)
- func TaskAddHeaders(builder *flatbuffers.Builder, headers flatbuffers.UOffsetT)
- func TaskAddKey(builder *flatbuffers.Builder, key flatbuffers.UOffsetT)
- func TaskAddState(builder *flatbuffers.Builder, state flatbuffers.UOffsetT)
- func TaskEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func TaskHeaderAddName(builder *flatbuffers.Builder, name flatbuffers.UOffsetT)
- func TaskHeaderAddText(builder *flatbuffers.Builder, text flatbuffers.UOffsetT)
- func TaskHeaderEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func TaskHeaderStart(builder *flatbuffers.Builder)
- func TaskStart(builder *flatbuffers.Builder)
- func TaskStartHeadersVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func TaskStartKeyVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func TransactionAddStart(builder *flatbuffers.Builder, start int64)
- func TransactionAddStatus(builder *flatbuffers.Builder, status byte)
- func TransactionEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func TransactionStart(builder *flatbuffers.Builder)
- func TxPtrAddOp(builder *flatbuffers.Builder, op uint32)
- func TxPtrAddTx(builder *flatbuffers.Builder, tx flatbuffers.UOffsetT)
- func TxPtrEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func TxPtrStart(builder *flatbuffers.Builder)
- func TxPtrStartTxVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func ValueAddBlob(builder *flatbuffers.Builder, blob bool)
- func ValueAddData(builder *flatbuffers.Builder, data flatbuffers.UOffsetT)
- func ValueAddSize(builder *flatbuffers.Builder, size uint32)
- func ValueEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func ValueStart(builder *flatbuffers.Builder)
- func ValueStartDataVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- type Query
- func (rcv *Query) IdxFrom(j int) byte
- func (rcv *Query) IdxFromBytes() []byte
- func (rcv *Query) IdxFromLength() int
- func (rcv *Query) IdxLast(j int) byte
- func (rcv *Query) IdxLastBytes() []byte
- func (rcv *Query) IdxLastLength() int
- func (rcv *Query) IdxType() uint16
- func (rcv *Query) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *Query) LastKey(j int) byte
- func (rcv *Query) LastKeyBytes() []byte
- func (rcv *Query) LastKeyLength() int
- func (rcv *Query) Limit() uint32
- func (rcv *Query) MutateIdxFrom(j int, n byte) bool
- func (rcv *Query) MutateIdxLast(j int, n byte) bool
- func (rcv *Query) MutateIdxType(n uint16) bool
- func (rcv *Query) MutateLastKey(j int, n byte) bool
- func (rcv *Query) MutateLimit(n uint32) bool
- func (rcv *Query) MutatePage(n uint32) bool
- func (rcv *Query) MutateQueryID(j int, n byte) bool
- func (rcv *Query) MutateReverse(n bool) bool
- func (rcv *Query) MutateSize(n uint32) bool
- func (rcv *Query) Page() uint32
- func (rcv *Query) QueryID(j int) byte
- func (rcv *Query) QueryIDBytes() []byte
- func (rcv *Query) QueryIDLength() int
- func (rcv *Query) Reverse() bool
- func (rcv *Query) Size() uint32
- func (rcv *Query) Table() flatbuffers.Table
- func (rcv *Query) UnPack() *QueryT
- func (rcv *Query) UnPackTo(t *QueryT)
- type QueryT
- type Row
- func (rcv *Row) Data(j int) byte
- func (rcv *Row) DataBytes() []byte
- func (rcv *Row) DataLength() int
- func (rcv *Row) Drop(obj *TxPtr, j int) bool
- func (rcv *Row) DropLength() int
- func (rcv *Row) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *Row) MutateData(j int, n byte) bool
- func (rcv *Row) Table() flatbuffers.Table
- func (rcv *Row) UnPack() *RowT
- func (rcv *Row) UnPackTo(t *RowT)
- type RowT
- type Task
- func (rcv *Task) Creator() []byte
- func (rcv *Task) Headers(obj *TaskHeader, j int) bool
- func (rcv *Task) HeadersLength() int
- func (rcv *Task) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *Task) Key(j int) byte
- func (rcv *Task) KeyBytes() []byte
- func (rcv *Task) KeyLength() int
- func (rcv *Task) MutateKey(j int, n byte) bool
- func (rcv *Task) State(obj *TaskState) *TaskState
- func (rcv *Task) Table() flatbuffers.Table
- func (rcv *Task) UnPack() *TaskT
- func (rcv *Task) UnPackTo(t *TaskT)
- type TaskHeader
- type TaskHeaderT
- type TaskState
- func (rcv *TaskState) Created() int64
- func (rcv *TaskState) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *TaskState) MutateCreated(n int64) bool
- func (rcv *TaskState) MutatePlanned(n int64) bool
- func (rcv *TaskState) MutateRepeats(n uint32) bool
- func (rcv *TaskState) MutateStatus(n byte) bool
- func (rcv *TaskState) Planned() int64
- func (rcv *TaskState) Repeats() uint32
- func (rcv *TaskState) Status() byte
- func (rcv *TaskState) Table() flatbuffers.Table
- func (rcv *TaskState) UnPack() *TaskStateT
- func (rcv *TaskState) UnPackTo(t *TaskStateT)
- type TaskStateT
- type TaskT
- type Transaction
- func (rcv *Transaction) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *Transaction) MutateStart(n int64) bool
- func (rcv *Transaction) MutateStatus(n byte) bool
- func (rcv *Transaction) Start() int64
- func (rcv *Transaction) Status() byte
- func (rcv *Transaction) Table() flatbuffers.Table
- func (rcv *Transaction) UnPack() *TransactionT
- func (rcv *Transaction) UnPackTo(t *TransactionT)
- type TransactionT
- type TxPtr
- func (rcv *TxPtr) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *TxPtr) MutateOp(n uint32) bool
- func (rcv *TxPtr) MutateTx(j int, n byte) bool
- func (rcv *TxPtr) Op() uint32
- func (rcv *TxPtr) Table() flatbuffers.Table
- func (rcv *TxPtr) Tx(j int) byte
- func (rcv *TxPtr) TxBytes() []byte
- func (rcv *TxPtr) TxLength() int
- func (rcv *TxPtr) UnPack() *TxPtrT
- func (rcv *TxPtr) UnPackTo(t *TxPtrT)
- type TxPtrT
- type Value
- func (rcv *Value) Blob() bool
- func (rcv *Value) Data(j int) byte
- func (rcv *Value) DataBytes() []byte
- func (rcv *Value) DataLength() int
- func (rcv *Value) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *Value) MutateBlob(n bool) bool
- func (rcv *Value) MutateData(j int, n byte) bool
- func (rcv *Value) MutateSize(n uint32) bool
- func (rcv *Value) Size() uint32
- func (rcv *Value) Table() flatbuffers.Table
- func (rcv *Value) UnPack() *ValueT
- func (rcv *Value) UnPackTo(t *ValueT)
- type ValueT
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateTaskState ¶
func CreateTaskState(builder *flatbuffers.Builder, status byte, repeats uint32, created int64, planned int64) flatbuffers.UOffsetT
func QueryAddIdxFrom ¶
func QueryAddIdxFrom(builder *flatbuffers.Builder, idxFrom flatbuffers.UOffsetT)
func QueryAddIdxLast ¶
func QueryAddIdxLast(builder *flatbuffers.Builder, idxLast flatbuffers.UOffsetT)
func QueryAddIdxType ¶
func QueryAddIdxType(builder *flatbuffers.Builder, idxType uint16)
func QueryAddLastKey ¶
func QueryAddLastKey(builder *flatbuffers.Builder, lastKey flatbuffers.UOffsetT)
func QueryAddLimit ¶
func QueryAddLimit(builder *flatbuffers.Builder, limit uint32)
func QueryAddPage ¶
func QueryAddPage(builder *flatbuffers.Builder, page uint32)
func QueryAddQueryID ¶
func QueryAddQueryID(builder *flatbuffers.Builder, queryID flatbuffers.UOffsetT)
func QueryAddReverse ¶
func QueryAddReverse(builder *flatbuffers.Builder, reverse bool)
func QueryAddSize ¶
func QueryAddSize(builder *flatbuffers.Builder, size uint32)
func QueryEnd ¶
func QueryEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func QueryStart ¶
func QueryStart(builder *flatbuffers.Builder)
func QueryStartIdxFromVector ¶
func QueryStartIdxFromVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func QueryStartIdxLastVector ¶
func QueryStartIdxLastVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func QueryStartLastKeyVector ¶
func QueryStartLastKeyVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func QueryStartQueryIDVector ¶
func QueryStartQueryIDVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func RowAddData ¶
func RowAddData(builder *flatbuffers.Builder, data flatbuffers.UOffsetT)
func RowAddDrop ¶
func RowAddDrop(builder *flatbuffers.Builder, drop flatbuffers.UOffsetT)
func RowEnd ¶
func RowEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func RowStart ¶
func RowStart(builder *flatbuffers.Builder)
func RowStartDataVector ¶
func RowStartDataVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func RowStartDropVector ¶
func RowStartDropVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func TaskAddCreator ¶
func TaskAddCreator(builder *flatbuffers.Builder, creator flatbuffers.UOffsetT)
func TaskAddHeaders ¶
func TaskAddHeaders(builder *flatbuffers.Builder, headers flatbuffers.UOffsetT)
func TaskAddKey ¶
func TaskAddKey(builder *flatbuffers.Builder, key flatbuffers.UOffsetT)
func TaskAddState ¶
func TaskAddState(builder *flatbuffers.Builder, state flatbuffers.UOffsetT)
func TaskEnd ¶
func TaskEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func TaskHeaderAddName ¶
func TaskHeaderAddName(builder *flatbuffers.Builder, name flatbuffers.UOffsetT)
func TaskHeaderAddText ¶
func TaskHeaderAddText(builder *flatbuffers.Builder, text flatbuffers.UOffsetT)
func TaskHeaderEnd ¶
func TaskHeaderEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func TaskHeaderStart ¶
func TaskHeaderStart(builder *flatbuffers.Builder)
func TaskStart ¶
func TaskStart(builder *flatbuffers.Builder)
func TaskStartHeadersVector ¶
func TaskStartHeadersVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func TaskStartKeyVector ¶
func TaskStartKeyVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func TransactionAddStart ¶
func TransactionAddStart(builder *flatbuffers.Builder, start int64)
func TransactionAddStatus ¶
func TransactionAddStatus(builder *flatbuffers.Builder, status byte)
func TransactionEnd ¶
func TransactionEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func TransactionStart ¶
func TransactionStart(builder *flatbuffers.Builder)
func TxPtrAddOp ¶
func TxPtrAddOp(builder *flatbuffers.Builder, op uint32)
func TxPtrAddTx ¶
func TxPtrAddTx(builder *flatbuffers.Builder, tx flatbuffers.UOffsetT)
func TxPtrEnd ¶
func TxPtrEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func TxPtrStart ¶
func TxPtrStart(builder *flatbuffers.Builder)
func TxPtrStartTxVector ¶
func TxPtrStartTxVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func ValueAddBlob ¶
func ValueAddBlob(builder *flatbuffers.Builder, blob bool)
func ValueAddData ¶
func ValueAddData(builder *flatbuffers.Builder, data flatbuffers.UOffsetT)
func ValueAddSize ¶
func ValueAddSize(builder *flatbuffers.Builder, size uint32)
func ValueEnd ¶
func ValueEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func ValueStart ¶
func ValueStart(builder *flatbuffers.Builder)
func ValueStartDataVector ¶
func ValueStartDataVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
Types ¶
type Query ¶
type Query struct {
// contains filtered or unexported fields
}
func GetRootAsQuery ¶
func GetRootAsQuery(buf []byte, offset flatbuffers.UOffsetT) *Query
func (*Query) IdxFromBytes ¶
func (*Query) IdxFromLength ¶
func (*Query) IdxLastBytes ¶
func (*Query) IdxLastLength ¶
func (*Query) LastKeyBytes ¶
func (*Query) LastKeyLength ¶
func (*Query) MutateIdxType ¶
func (*Query) MutateLimit ¶
func (*Query) MutatePage ¶
func (*Query) MutateReverse ¶
func (*Query) MutateSize ¶
func (*Query) QueryIDBytes ¶
func (*Query) QueryIDLength ¶
func (*Query) Table ¶
func (rcv *Query) Table() flatbuffers.Table
type QueryT ¶
type QueryT struct { Size uint32 Page uint32 Limit uint32 Reverse bool IdxType uint16 LastKey []byte IdxFrom []byte IdxLast []byte QueryID []byte }
func (*QueryT) Pack ¶
func (t *QueryT) Pack(builder *flatbuffers.Builder) flatbuffers.UOffsetT
type Row ¶
type Row struct {
// contains filtered or unexported fields
}
func GetRootAsRow ¶
func GetRootAsRow(buf []byte, offset flatbuffers.UOffsetT) *Row
func (*Row) DataLength ¶
func (*Row) DropLength ¶
func (*Row) Table ¶
func (rcv *Row) Table() flatbuffers.Table
type RowT ¶
func (*RowT) Pack ¶
func (t *RowT) Pack(builder *flatbuffers.Builder) flatbuffers.UOffsetT
type Task ¶
type Task struct {
// contains filtered or unexported fields
}
func GetRootAsTask ¶
func GetRootAsTask(buf []byte, offset flatbuffers.UOffsetT) *Task
func (*Task) HeadersLength ¶
func (*Task) Table ¶
func (rcv *Task) Table() flatbuffers.Table
type TaskHeader ¶
type TaskHeader struct {
// contains filtered or unexported fields
}
func GetRootAsTaskHeader ¶
func GetRootAsTaskHeader(buf []byte, offset flatbuffers.UOffsetT) *TaskHeader
func (*TaskHeader) Init ¶
func (rcv *TaskHeader) Init(buf []byte, i flatbuffers.UOffsetT)
func (*TaskHeader) Name ¶
func (rcv *TaskHeader) Name() []byte
func (*TaskHeader) Table ¶
func (rcv *TaskHeader) Table() flatbuffers.Table
func (*TaskHeader) Text ¶
func (rcv *TaskHeader) Text() []byte
func (*TaskHeader) UnPack ¶
func (rcv *TaskHeader) UnPack() *TaskHeaderT
func (*TaskHeader) UnPackTo ¶
func (rcv *TaskHeader) UnPackTo(t *TaskHeaderT)
type TaskHeaderT ¶
func (*TaskHeaderT) Pack ¶
func (t *TaskHeaderT) Pack(builder *flatbuffers.Builder) flatbuffers.UOffsetT
type TaskState ¶
type TaskState struct {
// contains filtered or unexported fields
}
func (*TaskState) MutateCreated ¶
func (*TaskState) MutatePlanned ¶
func (*TaskState) MutateRepeats ¶
func (*TaskState) MutateStatus ¶
func (*TaskState) Table ¶
func (rcv *TaskState) Table() flatbuffers.Table
func (*TaskState) UnPack ¶
func (rcv *TaskState) UnPack() *TaskStateT
func (*TaskState) UnPackTo ¶
func (rcv *TaskState) UnPackTo(t *TaskStateT)
type TaskStateT ¶
func (*TaskStateT) Pack ¶
func (t *TaskStateT) Pack(builder *flatbuffers.Builder) flatbuffers.UOffsetT
type TaskT ¶
type TaskT struct { Key []byte State *TaskStateT Creator string Headers []*TaskHeaderT }
func (*TaskT) Pack ¶
func (t *TaskT) Pack(builder *flatbuffers.Builder) flatbuffers.UOffsetT
type Transaction ¶
type Transaction struct {
// contains filtered or unexported fields
}
func GetRootAsTransaction ¶
func GetRootAsTransaction(buf []byte, offset flatbuffers.UOffsetT) *Transaction
func (*Transaction) Init ¶
func (rcv *Transaction) Init(buf []byte, i flatbuffers.UOffsetT)
func (*Transaction) MutateStart ¶
func (rcv *Transaction) MutateStart(n int64) bool
func (*Transaction) MutateStatus ¶
func (rcv *Transaction) MutateStatus(n byte) bool
func (*Transaction) Start ¶
func (rcv *Transaction) Start() int64
func (*Transaction) Status ¶
func (rcv *Transaction) Status() byte
func (*Transaction) Table ¶
func (rcv *Transaction) Table() flatbuffers.Table
func (*Transaction) UnPack ¶
func (rcv *Transaction) UnPack() *TransactionT
func (*Transaction) UnPackTo ¶
func (rcv *Transaction) UnPackTo(t *TransactionT)
type TransactionT ¶
func (*TransactionT) Pack ¶
func (t *TransactionT) Pack(builder *flatbuffers.Builder) flatbuffers.UOffsetT
type TxPtr ¶
type TxPtr struct {
// contains filtered or unexported fields
}
func GetRootAsTxPtr ¶
func GetRootAsTxPtr(buf []byte, offset flatbuffers.UOffsetT) *TxPtr
func (*TxPtr) Table ¶
func (rcv *TxPtr) Table() flatbuffers.Table
type TxPtrT ¶
func (*TxPtrT) Pack ¶
func (t *TxPtrT) Pack(builder *flatbuffers.Builder) flatbuffers.UOffsetT
type Value ¶
type Value struct {
// contains filtered or unexported fields
}
func GetRootAsValue ¶
func GetRootAsValue(buf []byte, offset flatbuffers.UOffsetT) *Value
func (*Value) DataLength ¶
func (*Value) MutateBlob ¶
func (*Value) MutateSize ¶
func (*Value) Table ¶
func (rcv *Value) Table() flatbuffers.Table
Click to show internal directories.
Click to hide internal directories.