peerfb

package
v0.9.0 Latest Latest
Warning

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

 Go to latest Published: Sep 4, 2026 License: MIT Imports: 2 Imported by: 0

Documentation

Index

Constants

View Source 
const RequestIdentifier = "RHZA"

Variables

View Source 
var EnumNamesOperation = map[Operation]string{
	OperationNone:              "None",
	OperationRecord:            "Record",
	OperationPropose:           "Propose",
	OperationLearned:           "Learned",
	OperationSync:              "Sync",
	OperationReadIndex:         "ReadIndex",
	OperationStageValue:        "StageValue",
	OperationFetchValue:        "FetchValue",
	OperationPrepareCheckpoint: "PrepareCheckpoint",
}
View Source 
var EnumValuesOperation = map[string]Operation{
	"None":              OperationNone,
	"Record":            OperationRecord,
	"Propose":           OperationPropose,
	"Learned":           OperationLearned,
	"Sync":              OperationSync,
	"ReadIndex":         OperationReadIndex,
	"StageValue":        OperationStageValue,
	"FetchValue":        OperationFetchValue,
	"PrepareCheckpoint": OperationPrepareCheckpoint,
}

Functions

func DecidedValueAddCertificate 

func DecidedValueAddCertificate(builder *flatbuffers.Builder, certificate flatbuffers.UOffsetT)

func DecidedValueAddHash 

func DecidedValueAddHash(builder *flatbuffers.Builder, hash flatbuffers.UOffsetT)

func DecidedValueAddSlot 

func DecidedValueAddSlot(builder *flatbuffers.Builder, slot uint64)

func DecidedValueAddValue 

func DecidedValueAddValue(builder *flatbuffers.Builder, value flatbuffers.UOffsetT)

func DecidedValueEnd 

func DecidedValueEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func DecidedValueStart 

func DecidedValueStart(builder *flatbuffers.Builder)

func DecidedValueStartCertificateVector 

func DecidedValueStartCertificateVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func DecidedValueStartHashVector 

func DecidedValueStartHashVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func DecidedValueStartValueVector 

func DecidedValueStartValueVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func DecisionAddProposal 

func DecisionAddProposal(builder *flatbuffers.Builder, proposal flatbuffers.UOffsetT)

func DecisionAddSlot 

func DecisionAddSlot(builder *flatbuffers.Builder, slot uint64)

func DecisionAddStep 

func DecisionAddStep(builder *flatbuffers.Builder, step uint64)

func DecisionAddSummaries 

func DecisionAddSummaries(builder *flatbuffers.Builder, summaries flatbuffers.UOffsetT)

func DecisionEnd 

func DecisionEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func DecisionStart 

func DecisionStart(builder *flatbuffers.Builder)

func DecisionStartSummariesVector 

func DecisionStartSummariesVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func FinishDecidedValueBuffer 

func FinishDecidedValueBuffer(builder *flatbuffers.Builder, offset flatbuffers.UOffsetT)

func FinishDecisionBuffer 

func FinishDecisionBuffer(builder *flatbuffers.Builder, offset flatbuffers.UOffsetT)

func FinishProposalBuffer 

func FinishProposalBuffer(builder *flatbuffers.Builder, offset flatbuffers.UOffsetT)

func FinishRecordRequestBuffer 

func FinishRecordRequestBuffer(builder *flatbuffers.Builder, offset flatbuffers.UOffsetT)

func FinishRequestBuffer 

func FinishRequestBuffer(builder *flatbuffers.Builder, offset flatbuffers.UOffsetT)

func FinishResponseBuffer 

func FinishResponseBuffer(builder *flatbuffers.Builder, offset flatbuffers.UOffsetT)

func FinishSizePrefixedDecidedValueBuffer 

func FinishSizePrefixedDecidedValueBuffer(builder *flatbuffers.Builder, offset flatbuffers.UOffsetT)

func FinishSizePrefixedDecisionBuffer 

func FinishSizePrefixedDecisionBuffer(builder *flatbuffers.Builder, offset flatbuffers.UOffsetT)

func FinishSizePrefixedProposalBuffer 

func FinishSizePrefixedProposalBuffer(builder *flatbuffers.Builder, offset flatbuffers.UOffsetT)

func FinishSizePrefixedRecordRequestBuffer 

func FinishSizePrefixedRecordRequestBuffer(builder *flatbuffers.Builder, offset flatbuffers.UOffsetT)

func FinishSizePrefixedRequestBuffer 

func FinishSizePrefixedRequestBuffer(builder *flatbuffers.Builder, offset flatbuffers.UOffsetT)

func FinishSizePrefixedResponseBuffer 

func FinishSizePrefixedResponseBuffer(builder *flatbuffers.Builder, offset flatbuffers.UOffsetT)

func FinishSizePrefixedSummaryBuffer 

func FinishSizePrefixedSummaryBuffer(builder *flatbuffers.Builder, offset flatbuffers.UOffsetT)

func FinishSummaryBuffer 

func FinishSummaryBuffer(builder *flatbuffers.Builder, offset flatbuffers.UOffsetT)

func ProposalAddHash 

func ProposalAddHash(builder *flatbuffers.Builder, hash flatbuffers.UOffsetT)

func ProposalAddPriority 

func ProposalAddPriority(builder *flatbuffers.Builder, priority flatbuffers.UOffsetT)

func ProposalAddProposerId 

func ProposalAddProposerId(builder *flatbuffers.Builder, proposerId flatbuffers.UOffsetT)

func ProposalAddValue 

func ProposalAddValue(builder *flatbuffers.Builder, value flatbuffers.UOffsetT)

func ProposalEnd 

func ProposalEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func ProposalStart 

func ProposalStart(builder *flatbuffers.Builder)

func ProposalStartHashVector 

func ProposalStartHashVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func ProposalStartPriorityVector 

func ProposalStartPriorityVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func ProposalStartValueVector 

func ProposalStartValueVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func RecordRequestAddProposal 

func RecordRequestAddProposal(builder *flatbuffers.Builder, proposal flatbuffers.UOffsetT)

func RecordRequestAddSlot 

func RecordRequestAddSlot(builder *flatbuffers.Builder, slot uint64)

func RecordRequestAddStep 

func RecordRequestAddStep(builder *flatbuffers.Builder, step uint64)

func RecordRequestEnd 

func RecordRequestEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func RecordRequestStart 

func RecordRequestStart(builder *flatbuffers.Builder)

func RequestAddClusterId 

func RequestAddClusterId(builder *flatbuffers.Builder, clusterId flatbuffers.UOffsetT)

func RequestAddConfigId 

func RequestAddConfigId(builder *flatbuffers.Builder, configId uint64)

func RequestAddDecision 

func RequestAddDecision(builder *flatbuffers.Builder, decision flatbuffers.UOffsetT)

func RequestAddFrom 

func RequestAddFrom(builder *flatbuffers.Builder, from uint64)

func RequestAddHash 

func RequestAddHash(builder *flatbuffers.Builder, hash flatbuffers.UOffsetT)

func RequestAddLimit 

func RequestAddLimit(builder *flatbuffers.Builder, limit uint32)

func RequestAddMagic 

func RequestAddMagic(builder *flatbuffers.Builder, magic uint32)

func RequestAddOperation 

func RequestAddOperation(builder *flatbuffers.Builder, operation Operation)

func RequestAddRecord 

func RequestAddRecord(builder *flatbuffers.Builder, record flatbuffers.UOffsetT)

func RequestAddSenderId 

func RequestAddSenderId(builder *flatbuffers.Builder, senderId flatbuffers.UOffsetT)

func RequestAddToken 

func RequestAddToken(builder *flatbuffers.Builder, token flatbuffers.UOffsetT)

func RequestAddValue 

func RequestAddValue(builder *flatbuffers.Builder, value flatbuffers.UOffsetT)

func RequestBufferHasIdentifier 

func RequestBufferHasIdentifier(buf []byte) bool

func RequestEnd 

func RequestEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func RequestStart 

func RequestStart(builder *flatbuffers.Builder)

func RequestStartHashVector 

func RequestStartHashVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func RequestStartValueVector 

func RequestStartValueVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func ResponseAddClusterId 

func ResponseAddClusterId(builder *flatbuffers.Builder, clusterId flatbuffers.UOffsetT)

func ResponseAddConfigId 

func ResponseAddConfigId(builder *flatbuffers.Builder, configId uint64)

func ResponseAddDecided 

func ResponseAddDecided(builder *flatbuffers.Builder, decided flatbuffers.UOffsetT)

func ResponseAddDecisions 

func ResponseAddDecisions(builder *flatbuffers.Builder, decisions flatbuffers.UOffsetT)

func ResponseAddError 

func ResponseAddError(builder *flatbuffers.Builder, error flatbuffers.UOffsetT)

func ResponseAddErrorCode 

func ResponseAddErrorCode(builder *flatbuffers.Builder, errorCode uint16)

func ResponseAddMagic 

func ResponseAddMagic(builder *flatbuffers.Builder, magic uint32)

func ResponseAddProposerId 

func ResponseAddProposerId(builder *flatbuffers.Builder, proposerId flatbuffers.UOffsetT)

func ResponseAddSummary 

func ResponseAddSummary(builder *flatbuffers.Builder, summary flatbuffers.UOffsetT)

func ResponseAddTip 

func ResponseAddTip(builder *flatbuffers.Builder, tip uint64)

func ResponseAddValue 

func ResponseAddValue(builder *flatbuffers.Builder, value flatbuffers.UOffsetT)

func ResponseEnd 

func ResponseEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func ResponseStart 

func ResponseStart(builder *flatbuffers.Builder)

func ResponseStartDecisionsVector 

func ResponseStartDecisionsVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func ResponseStartValueVector 

func ResponseStartValueVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func SizePrefixedRequestBufferHasIdentifier 

func SizePrefixedRequestBufferHasIdentifier(buf []byte) bool

func SummaryAddAggregatePrior 

func SummaryAddAggregatePrior(builder *flatbuffers.Builder, aggregatePrior flatbuffers.UOffsetT)

func SummaryAddFirstCurrent 

func SummaryAddFirstCurrent(builder *flatbuffers.Builder, firstCurrent flatbuffers.UOffsetT)

func SummaryAddRecorderId 

func SummaryAddRecorderId(builder *flatbuffers.Builder, recorderId flatbuffers.UOffsetT)

func SummaryAddStep 

func SummaryAddStep(builder *flatbuffers.Builder, step uint64)

func SummaryEnd 

func SummaryEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func SummaryStart 

func SummaryStart(builder *flatbuffers.Builder)

Types

type DecidedValue 

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

func GetRootAsDecidedValue 

func GetRootAsDecidedValue(buf []byte, offset flatbuffers.UOffsetT) *DecidedValue

func GetSizePrefixedRootAsDecidedValue 

func GetSizePrefixedRootAsDecidedValue(buf []byte, offset flatbuffers.UOffsetT) *DecidedValue

func (*DecidedValue) Certificate 

func (rcv *DecidedValue) Certificate(j int) byte

func (*DecidedValue) CertificateBytes 

func (rcv *DecidedValue) CertificateBytes() []byte

func (*DecidedValue) CertificateLength 

func (rcv *DecidedValue) CertificateLength() int

func (*DecidedValue) Hash 

func (rcv *DecidedValue) Hash(j int) byte

func (*DecidedValue) HashBytes 

func (rcv *DecidedValue) HashBytes() []byte

func (*DecidedValue) HashLength 

func (rcv *DecidedValue) HashLength() int

func (*DecidedValue) Init 

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

func (*DecidedValue) MutateCertificate 

func (rcv *DecidedValue) MutateCertificate(j int, n byte) bool

func (*DecidedValue) MutateHash 

func (rcv *DecidedValue) MutateHash(j int, n byte) bool

func (*DecidedValue) MutateSlot 

func (rcv *DecidedValue) MutateSlot(n uint64) bool

func (*DecidedValue) MutateValue 

func (rcv *DecidedValue) MutateValue(j int, n byte) bool

func (*DecidedValue) Slot 

func (rcv *DecidedValue) Slot() uint64

func (*DecidedValue) Table 

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

func (*DecidedValue) UnPack 

func (rcv *DecidedValue) UnPack() *DecidedValueT

func (*DecidedValue) UnPackTo 

func (rcv *DecidedValue) UnPackTo(t *DecidedValueT)

func (*DecidedValue) Value 

func (rcv *DecidedValue) Value(j int) byte

func (*DecidedValue) ValueBytes 

func (rcv *DecidedValue) ValueBytes() []byte

func (*DecidedValue) ValueLength 

func (rcv *DecidedValue) ValueLength() int

type DecidedValueT 

type DecidedValueT struct {
	Slot        uint64 `json:"slot"`
	Hash        []byte `json:"hash"`
	Value       []byte `json:"value"`
	Certificate []byte `json:"certificate"`
}

func (*DecidedValueT) Pack 

func (t *DecidedValueT) Pack(builder *flatbuffers.Builder) flatbuffers.UOffsetT

type Decision 

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

func GetRootAsDecision 

func GetRootAsDecision(buf []byte, offset flatbuffers.UOffsetT) *Decision

func GetSizePrefixedRootAsDecision 

func GetSizePrefixedRootAsDecision(buf []byte, offset flatbuffers.UOffsetT) *Decision

func (*Decision) Init 

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

func (*Decision) MutateSlot 

func (rcv *Decision) MutateSlot(n uint64) bool

func (*Decision) MutateStep 

func (rcv *Decision) MutateStep(n uint64) bool

func (*Decision) Proposal 

func (rcv *Decision) Proposal(obj *Proposal) *Proposal

func (*Decision) Slot 

func (rcv *Decision) Slot() uint64

func (*Decision) Step 

func (rcv *Decision) Step() uint64

func (*Decision) Summaries 

func (rcv *Decision) Summaries(obj *Summary, j int) bool

func (*Decision) SummariesLength 

func (rcv *Decision) SummariesLength() int

func (*Decision) Table 

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

func (*Decision) UnPack 

func (rcv *Decision) UnPack() *DecisionT

func (*Decision) UnPackTo 

func (rcv *Decision) UnPackTo(t *DecisionT)

type DecisionT 

type DecisionT struct {
	Slot      uint64      `json:"slot"`
	Step      uint64      `json:"step"`
	Proposal  *ProposalT  `json:"proposal"`
	Summaries []*SummaryT `json:"summaries"`
}

func (*DecisionT) Pack 

func (t *DecisionT) Pack(builder *flatbuffers.Builder) flatbuffers.UOffsetT

type Operation 

type Operation byte
const (
	OperationNone              Operation = 0
	OperationRecord            Operation = 1
	OperationPropose           Operation = 2
	OperationLearned           Operation = 3
	OperationSync              Operation = 4
	OperationReadIndex         Operation = 5
	OperationStageValue        Operation = 6
	OperationFetchValue        Operation = 7
	OperationPrepareCheckpoint Operation = 8
)

func (Operation) String 

func (v Operation) String() string

type Proposal 

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

func GetRootAsProposal 

func GetRootAsProposal(buf []byte, offset flatbuffers.UOffsetT) *Proposal

func GetSizePrefixedRootAsProposal 

func GetSizePrefixedRootAsProposal(buf []byte, offset flatbuffers.UOffsetT) *Proposal

func (*Proposal) Hash 

func (rcv *Proposal) Hash(j int) byte

func (*Proposal) HashBytes 

func (rcv *Proposal) HashBytes() []byte

func (*Proposal) HashLength 

func (rcv *Proposal) HashLength() int

func (*Proposal) Init 

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

func (*Proposal) MutateHash 

func (rcv *Proposal) MutateHash(j int, n byte) bool

func (*Proposal) MutatePriority 

func (rcv *Proposal) MutatePriority(j int, n byte) bool

func (*Proposal) MutateValue 

func (rcv *Proposal) MutateValue(j int, n byte) bool

func (*Proposal) Priority 

func (rcv *Proposal) Priority(j int) byte

func (*Proposal) PriorityBytes 

func (rcv *Proposal) PriorityBytes() []byte

func (*Proposal) PriorityLength 

func (rcv *Proposal) PriorityLength() int

func (*Proposal) ProposerId 

func (rcv *Proposal) ProposerId() []byte

func (*Proposal) Table 

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

func (*Proposal) UnPack 

func (rcv *Proposal) UnPack() *ProposalT

func (*Proposal) UnPackTo 

func (rcv *Proposal) UnPackTo(t *ProposalT)

func (*Proposal) Value 

func (rcv *Proposal) Value(j int) byte

func (*Proposal) ValueBytes 

func (rcv *Proposal) ValueBytes() []byte

func (*Proposal) ValueLength 

func (rcv *Proposal) ValueLength() int

type ProposalT 

type ProposalT struct {
	Priority   []byte `json:"priority"`
	ProposerId string `json:"proposer_id"`
	Hash       []byte `json:"hash"`
	Value      []byte `json:"value"`
}

func (*ProposalT) Pack 

func (t *ProposalT) Pack(builder *flatbuffers.Builder) flatbuffers.UOffsetT

type RecordRequest 

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

func GetRootAsRecordRequest 

func GetRootAsRecordRequest(buf []byte, offset flatbuffers.UOffsetT) *RecordRequest

func GetSizePrefixedRootAsRecordRequest 

func GetSizePrefixedRootAsRecordRequest(buf []byte, offset flatbuffers.UOffsetT) *RecordRequest

func (*RecordRequest) Init 

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

func (*RecordRequest) MutateSlot 

func (rcv *RecordRequest) MutateSlot(n uint64) bool

func (*RecordRequest) MutateStep 

func (rcv *RecordRequest) MutateStep(n uint64) bool

func (*RecordRequest) Proposal 

func (rcv *RecordRequest) Proposal(obj *Proposal) *Proposal

func (*RecordRequest) Slot 

func (rcv *RecordRequest) Slot() uint64

func (*RecordRequest) Step 

func (rcv *RecordRequest) Step() uint64

func (*RecordRequest) Table 

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

func (*RecordRequest) UnPack 

func (rcv *RecordRequest) UnPack() *RecordRequestT

func (*RecordRequest) UnPackTo 

func (rcv *RecordRequest) UnPackTo(t *RecordRequestT)

type RecordRequestT 

type RecordRequestT struct {
	Slot     uint64     `json:"slot"`
	Step     uint64     `json:"step"`
	Proposal *ProposalT `json:"proposal"`
}

func (*RecordRequestT) Pack 

func (t *RecordRequestT) Pack(builder *flatbuffers.Builder) flatbuffers.UOffsetT

type Request 

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

func GetRootAsRequest 

func GetRootAsRequest(buf []byte, offset flatbuffers.UOffsetT) *Request

func GetSizePrefixedRootAsRequest 

func GetSizePrefixedRootAsRequest(buf []byte, offset flatbuffers.UOffsetT) *Request

func (*Request) ClusterId 

func (rcv *Request) ClusterId() []byte

func (*Request) ConfigId 

func (rcv *Request) ConfigId() uint64

func (*Request) Decision 

func (rcv *Request) Decision(obj *Decision) *Decision

func (*Request) From 

func (rcv *Request) From() uint64

func (*Request) Hash 

func (rcv *Request) Hash(j int) byte

func (*Request) HashBytes 

func (rcv *Request) HashBytes() []byte

func (*Request) HashLength 

func (rcv *Request) HashLength() int

func (*Request) Init 

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

func (*Request) Limit 

func (rcv *Request) Limit() uint32

func (*Request) Magic 

func (rcv *Request) Magic() uint32

func (*Request) MutateConfigId 

func (rcv *Request) MutateConfigId(n uint64) bool

func (*Request) MutateFrom 

func (rcv *Request) MutateFrom(n uint64) bool

func (*Request) MutateHash 

func (rcv *Request) MutateHash(j int, n byte) bool

func (*Request) MutateLimit 

func (rcv *Request) MutateLimit(n uint32) bool

func (*Request) MutateMagic 

func (rcv *Request) MutateMagic(n uint32) bool

func (*Request) MutateOperation 

func (rcv *Request) MutateOperation(n Operation) bool

func (*Request) MutateValue 

func (rcv *Request) MutateValue(j int, n byte) bool

func (*Request) Operation 

func (rcv *Request) Operation() Operation

func (*Request) Record 

func (rcv *Request) Record(obj *RecordRequest) *RecordRequest

func (*Request) SenderId 

func (rcv *Request) SenderId() []byte

func (*Request) Table 

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

func (*Request) Token 

func (rcv *Request) Token() []byte

func (*Request) UnPack 

func (rcv *Request) UnPack() *RequestT

func (*Request) UnPackTo 

func (rcv *Request) UnPackTo(t *RequestT)

func (*Request) Value 

func (rcv *Request) Value(j int) byte

func (*Request) ValueBytes 

func (rcv *Request) ValueBytes() []byte

func (*Request) ValueLength 

func (rcv *Request) ValueLength() int

type RequestT 

type RequestT struct {
	Magic     uint32          `json:"magic"`
	Operation Operation       `json:"operation"`
	ClusterId string          `json:"cluster_id"`
	SenderId  string          `json:"sender_id"`
	ConfigId  uint64          `json:"config_id"`
	Token     string          `json:"token"`
	Record    *RecordRequestT `json:"record"`
	Value     []byte          `json:"value"`
	Decision  *DecisionT      `json:"decision"`
	From      uint64          `json:"from"`
	Limit     uint32          `json:"limit"`
	Hash      []byte          `json:"hash"`
}

func (*RequestT) Pack 

func (t *RequestT) Pack(builder *flatbuffers.Builder) flatbuffers.UOffsetT

type Response 

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

func GetRootAsResponse 

func GetRootAsResponse(buf []byte, offset flatbuffers.UOffsetT) *Response

func GetSizePrefixedRootAsResponse 

func GetSizePrefixedRootAsResponse(buf []byte, offset flatbuffers.UOffsetT) *Response

func (*Response) ClusterId 

func (rcv *Response) ClusterId() []byte

func (*Response) ConfigId 

func (rcv *Response) ConfigId() uint64

func (*Response) Decided 

func (rcv *Response) Decided(obj *DecidedValue) *DecidedValue

func (*Response) Decisions 

func (rcv *Response) Decisions(obj *DecidedValue, j int) bool

func (*Response) DecisionsLength 

func (rcv *Response) DecisionsLength() int

func (*Response) Error 

func (rcv *Response) Error() []byte

func (*Response) ErrorCode 

func (rcv *Response) ErrorCode() uint16

func (*Response) Init 

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

func (*Response) Magic 

func (rcv *Response) Magic() uint32

func (*Response) MutateConfigId 

func (rcv *Response) MutateConfigId(n uint64) bool

func (*Response) MutateErrorCode 

func (rcv *Response) MutateErrorCode(n uint16) bool

func (*Response) MutateMagic 

func (rcv *Response) MutateMagic(n uint32) bool

func (*Response) MutateTip 

func (rcv *Response) MutateTip(n uint64) bool

func (*Response) MutateValue 

func (rcv *Response) MutateValue(j int, n byte) bool

func (*Response) ProposerId 

func (rcv *Response) ProposerId() []byte

func (*Response) Summary 

func (rcv *Response) Summary(obj *Summary) *Summary

func (*Response) Table 

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

func (*Response) Tip 

func (rcv *Response) Tip() uint64

func (*Response) UnPack 

func (rcv *Response) UnPack() *ResponseT

func (*Response) UnPackTo 

func (rcv *Response) UnPackTo(t *ResponseT)

func (*Response) Value 

func (rcv *Response) Value(j int) byte

func (*Response) ValueBytes 

func (rcv *Response) ValueBytes() []byte

func (*Response) ValueLength 

func (rcv *Response) ValueLength() int

type ResponseT 

type ResponseT struct {
	Magic      uint32           `json:"magic"`
	Error      string           `json:"error"`
	Summary    *SummaryT        `json:"summary"`
	Decided    *DecidedValueT   `json:"decided"`
	ClusterId  string           `json:"cluster_id"`
	ProposerId string           `json:"proposer_id"`
	ConfigId   uint64           `json:"config_id"`
	Tip        uint64           `json:"tip"`
	Decisions  []*DecidedValueT `json:"decisions"`
	ErrorCode  uint16           `json:"error_code"`
	Value      []byte           `json:"value"`
}

func (*ResponseT) Pack 

func (t *ResponseT) Pack(builder *flatbuffers.Builder) flatbuffers.UOffsetT

type Summary 

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

func GetRootAsSummary 

func GetRootAsSummary(buf []byte, offset flatbuffers.UOffsetT) *Summary

func GetSizePrefixedRootAsSummary 

func GetSizePrefixedRootAsSummary(buf []byte, offset flatbuffers.UOffsetT) *Summary

func (*Summary) AggregatePrior 

func (rcv *Summary) AggregatePrior(obj *Proposal) *Proposal

func (*Summary) FirstCurrent 

func (rcv *Summary) FirstCurrent(obj *Proposal) *Proposal

func (*Summary) Init 

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

func (*Summary) MutateStep 

func (rcv *Summary) MutateStep(n uint64) bool

func (*Summary) RecorderId 

func (rcv *Summary) RecorderId() []byte

func (*Summary) Step 

func (rcv *Summary) Step() uint64

func (*Summary) Table 

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

func (*Summary) UnPack 

func (rcv *Summary) UnPack() *SummaryT

func (*Summary) UnPackTo 

func (rcv *Summary) UnPackTo(t *SummaryT)

type SummaryT 

type SummaryT struct {
	RecorderId     string     `json:"recorder_id"`
	Step           uint64     `json:"step"`
	FirstCurrent   *ProposalT `json:"first_current"`
	AggregatePrior *ProposalT `json:"aggregate_prior"`
}

func (*SummaryT) Pack 

func (t *SummaryT) Pack(builder *flatbuffers.Builder) flatbuffers.UOffsetT

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.