sync

Documentation

Overview

@generated by the gondn_tlv_gen, DO NOT modify manually

Index

• type StateVector
  • func ParseStateVector(reader enc.ParseReader, ignoreCritical bool) (*StateVector, error)
  • func (value *StateVector) Bytes() []byte
  • func (value *StateVector) Encode() enc.Wire
• type StateVectorAppParam
  • func ParseStateVectorAppParam(reader enc.ParseReader, ignoreCritical bool) (*StateVectorAppParam, error)
  • func (value *StateVectorAppParam) Bytes() []byte
  • func (value *StateVectorAppParam) Encode() enc.Wire
• type StateVectorAppParamEncoder
  • func (encoder *StateVectorAppParamEncoder) Encode(value *StateVectorAppParam) enc.Wire
  • func (encoder *StateVectorAppParamEncoder) EncodeInto(value *StateVectorAppParam, buf []byte)
  • func (encoder *StateVectorAppParamEncoder) Init(value *StateVectorAppParam)
• type StateVectorAppParamParsingContext
  • func (context *StateVectorAppParamParsingContext) Init()
  • func (context *StateVectorAppParamParsingContext) Parse(reader enc.ParseReader, ignoreCritical bool) (*StateVectorAppParam, error)
• type StateVectorEncoder
  • func (encoder *StateVectorEncoder) Encode(value *StateVector) enc.Wire
  • func (encoder *StateVectorEncoder) EncodeInto(value *StateVector, buf []byte)
  • func (encoder *StateVectorEncoder) Init(value *StateVector)
• type StateVectorEntry
  • func ParseStateVectorEntry(reader enc.ParseReader, ignoreCritical bool) (*StateVectorEntry, error)
  • func (value *StateVectorEntry) Bytes() []byte
  • func (value *StateVectorEntry) Encode() enc.Wire
• type StateVectorEntryEncoder
  • func (encoder *StateVectorEntryEncoder) Encode(value *StateVectorEntry) enc.Wire
  • func (encoder *StateVectorEntryEncoder) EncodeInto(value *StateVectorEntry, buf []byte)
  • func (encoder *StateVectorEntryEncoder) Init(value *StateVectorEntry)
• type StateVectorEntryParsingContext
  • func (context *StateVectorEntryParsingContext) Init()
  • func (context *StateVectorEntryParsingContext) Parse(reader enc.ParseReader, ignoreCritical bool) (*StateVectorEntry, error)
• type StateVectorParsingContext
  • func (context *StateVectorParsingContext) Init()
  • func (context *StateVectorParsingContext) Parse(reader enc.ParseReader, ignoreCritical bool) (*StateVector, error)
• type SvSync
  • func NewSvSync(engine ndn.Engine, groupPrefix enc.Name, onUpdate func(SvSyncUpdate)) *SvSync
  • func (s *SvSync) GetSeqNo(nodeId enc.Name) uint64
  • func (s *SvSync) IncrSeqNo(nodeId enc.Name) uint64
  • func (s *SvSync) SetSeqNo(nodeId enc.Name, seqNo uint64) error
  • func (s *SvSync) Start() (err error)
  • func (s *SvSync) Stop()
• type SvSyncUpdate

Types

type StateVector

type StateVector struct {
	//+field:sequence:*StateVectorEntry:struct:StateVectorEntry
	Entries []*StateVectorEntry `tlv:"0xca"`
}

func ParseStateVector

func ParseStateVector(reader enc.ParseReader, ignoreCritical bool) (*StateVector, error)

func (*StateVector) Bytes

func (value *StateVector) Bytes() []byte

func (*StateVector) Encode

func (value *StateVector) Encode() enc.Wire

type StateVectorAppParam

type StateVectorAppParam struct {
	//+field:struct:StateVector
	StateVector *StateVector `tlv:"0xc9"`
}

func ParseStateVectorAppParam

func ParseStateVectorAppParam(reader enc.ParseReader, ignoreCritical bool) (*StateVectorAppParam, error)

func (*StateVectorAppParam) Bytes

func (value *StateVectorAppParam) Bytes() []byte

func (*StateVectorAppParam) Encode

func (value *StateVectorAppParam) Encode() enc.Wire

type StateVectorAppParamEncoder

type StateVectorAppParamEncoder struct {
	StateVector_encoder StateVectorEncoder
	// contains filtered or unexported fields
}

func (*StateVectorAppParamEncoder) Encode

func (encoder *StateVectorAppParamEncoder) Encode(value *StateVectorAppParam) enc.Wire

func (*StateVectorAppParamEncoder) EncodeInto

func (encoder *StateVectorAppParamEncoder) EncodeInto(value *StateVectorAppParam, buf []byte)

func (*StateVectorAppParamEncoder) Init

func (encoder *StateVectorAppParamEncoder) Init(value *StateVectorAppParam)

type StateVectorAppParamParsingContext

type StateVectorAppParamParsingContext struct {
	StateVector_context StateVectorParsingContext
}

func (*StateVectorAppParamParsingContext) Init

func (context *StateVectorAppParamParsingContext) Init()

func (*StateVectorAppParamParsingContext) Parse

func (context *StateVectorAppParamParsingContext) Parse(reader enc.ParseReader, ignoreCritical bool) (*StateVectorAppParam, error)

type StateVectorEncoder

type StateVectorEncoder struct {
	Entries_subencoder []struct {
		Entries_encoder StateVectorEntryEncoder
	}
	// contains filtered or unexported fields
}

func (*StateVectorEncoder) Encode

func (encoder *StateVectorEncoder) Encode(value *StateVector) enc.Wire

func (*StateVectorEncoder) EncodeInto

func (encoder *StateVectorEncoder) EncodeInto(value *StateVector, buf []byte)

func (*StateVectorEncoder) Init

func (encoder *StateVectorEncoder) Init(value *StateVector)

type StateVectorEntry

type StateVectorEntry struct {
	//+field:name
	NodeId enc.Name `tlv:"0x07"`
	//+field:natural
	SeqNo uint64 `tlv:"0xcc"`
}

func ParseStateVectorEntry

func ParseStateVectorEntry(reader enc.ParseReader, ignoreCritical bool) (*StateVectorEntry, error)

func (*StateVectorEntry) Bytes

func (value *StateVectorEntry) Bytes() []byte

func (*StateVectorEntry) Encode

func (value *StateVectorEntry) Encode() enc.Wire

type StateVectorEntryEncoder

type StateVectorEntryEncoder struct {
	NodeId_length uint
	// contains filtered or unexported fields
}

func (*StateVectorEntryEncoder) Encode

func (encoder *StateVectorEntryEncoder) Encode(value *StateVectorEntry) enc.Wire

func (*StateVectorEntryEncoder) EncodeInto

func (encoder *StateVectorEntryEncoder) EncodeInto(value *StateVectorEntry, buf []byte)

func (*StateVectorEntryEncoder) Init

func (encoder *StateVectorEntryEncoder) Init(value *StateVectorEntry)

type StateVectorEntryParsingContext

type StateVectorEntryParsingContext struct {
}

func (*StateVectorEntryParsingContext) Init

func (context *StateVectorEntryParsingContext) Init()

func (*StateVectorEntryParsingContext) Parse

func (context *StateVectorEntryParsingContext) Parse(reader enc.ParseReader, ignoreCritical bool) (*StateVectorEntry, error)

type StateVectorParsingContext

type StateVectorParsingContext struct {
	Entries_context StateVectorEntryParsingContext
}

func (*StateVectorParsingContext) Init

func (context *StateVectorParsingContext) Init()

func (*StateVectorParsingContext) Parse

func (context *StateVectorParsingContext) Parse(reader enc.ParseReader, ignoreCritical bool) (*StateVector, error)

type SvSync

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

func NewSvSync

func NewSvSync(
	engine ndn.Engine,
	groupPrefix enc.Name,
	onUpdate func(SvSyncUpdate),
) *SvSync

func (*SvSync) GetSeqNo

func (s *SvSync) GetSeqNo(nodeId enc.Name) uint64

func (*SvSync) IncrSeqNo

func (s *SvSync) IncrSeqNo(nodeId enc.Name) uint64

func (*SvSync) SetSeqNo

func (s *SvSync) SetSeqNo(nodeId enc.Name, seqNo uint64) error

func (*SvSync) Start

func (s *SvSync) Start() (err error)

func (*SvSync) Stop

func (s *SvSync) Stop()

type SvSyncUpdate

type SvSyncUpdate struct {
	NodeId enc.Name
	High   uint64
	Low    uint64
}