bundle

Aug 3, 2020

Changes in this version

type AdministrativeRecord

+ RecordTypeCode func() uint64

+ type AdministrativeRecordManager struct

+ func GetAdministrativeRecordManager() *AdministrativeRecordManager

+ func NewAdministrativeRecordManager() *AdministrativeRecordManager

+ func (arm *AdministrativeRecordManager) IsKnown(typeCode uint64) (known bool)

+ func (arm *AdministrativeRecordManager) ReadAdministrativeRecord(r io.Reader) (ar AdministrativeRecord, err error)

+ func (arm *AdministrativeRecordManager) Register(ar AdministrativeRecord) (err error)

+ func (arm *AdministrativeRecordManager) Unregister(ar AdministrativeRecord)

+ func (arm *AdministrativeRecordManager) WriteAdministrativeRecord(ar AdministrativeRecord, w io.Writer) (err error)

type DtnEndpoint

+ Demux string

+ IsDtnNone bool

+ NodeName string

+ func (e DtnEndpoint) IsSingleton() bool

type EndpointID

+ func (eid EndpointID) IsSingleton() bool

type EndpointType

+ IsSingleton func() bool

type IpnEndpoint

+ func (_ IpnEndpoint) IsSingleton() bool

type StatusReport

+ func (sr *StatusReport) RecordTypeCode() uint64

Apr 16, 2020

Changes in this version

+ const ARTypeStatusReport

+ type AdministrativeRecord interface

+ TypeCode func() uint64

+ func NewAdministrativeRecordFromCbor(data []byte) (ar AdministrativeRecord, err error)

+ type BundleStatusItem struct

+ Asserted bool

+ StatusRequested bool

+ Time DtnTime

+ func NewBundleStatusItem(asserted bool) BundleStatusItem

+ func NewTimeReportingBundleStatusItem(time DtnTime) BundleStatusItem

+ func (bsi *BundleStatusItem) MarshalCbor(w io.Writer) error

+ func (bsi *BundleStatusItem) UnmarshalCbor(r io.Reader) error

+ func (bsi BundleStatusItem) String() string

type CanonicalBlock

+ func AdministrativeRecordToCbor(ar AdministrativeRecord) (blk CanonicalBlock, err error)

+ type StatusInformationPos int

+ const DeletedBundle

+ const DeliveredBundle

+ const ForwardedBundle

+ const ReceivedBundle

+ func (sip StatusInformationPos) String() string

+ type StatusReport struct

+ RefBundle BundleID

+ ReportReason StatusReportReason

+ StatusInformation []BundleStatusItem

+ func NewStatusReport(bndl Bundle, statusItem StatusInformationPos, reason StatusReportReason, ...) StatusReport

+ func (sr *StatusReport) MarshalCbor(w io.Writer) error

+ func (sr *StatusReport) TypeCode() uint64

+ func (sr *StatusReport) UnmarshalCbor(r io.Reader) error

+ func (sr StatusReport) StatusInformations() (sips []StatusInformationPos)

+ func (sr StatusReport) String() string

+ type StatusReportReason uint64

+ const BlockUnintelligible

+ const DepletedStorage

+ const DestEndpointUnintelligible

+ const ForwardUnidirectionalLink

+ const HopLimitExceeded

+ const LifetimeExpired

+ const NoInformation

+ const NoNextNodeContact

+ const NoRouteToDestination

+ const TransmissionCanceled

+ func (srr StatusReportReason) String() string

Apr 16, 2020

Changes in this version

type BlockControlFlags

+ func (bcf BlockControlFlags) MarshalJSON() ([]byte, error)

+ func (bcf BlockControlFlags) Strings() (fields []string)

type Bundle

+ func BuildFromMap(m map[string]interface{}) (bndl Bundle, err error)

+ func (b Bundle) MarshalJSON() ([]byte, error)

type BundleControlFlags

+ func (bcf BundleControlFlags) MarshalJSON() ([]byte, error)

+ func (bcf BundleControlFlags) Strings() (fields []string)

type CanonicalBlock

+ func (cb CanonicalBlock) MarshalJSON() ([]byte, error)

type CreationTimestamp

+ func (ct CreationTimestamp) MarshalJSON() ([]byte, error)

+ type DtnEndpoint struct

+ Ssp string

+ func (_ DtnEndpoint) CheckValid() error

+ func (_ DtnEndpoint) SchemeName() string

+ func (_ DtnEndpoint) SchemeNo() uint64

+ func (e *DtnEndpoint) UnmarshalCbor(r io.Reader) error

+ func (e DtnEndpoint) Authority() string

+ func (e DtnEndpoint) MarshalCbor(w io.Writer) error

+ func (e DtnEndpoint) Path() string

+ func (e DtnEndpoint) String() string

type EndpointID

+ EndpointType EndpointType

+ func (eid EndpointID) Authority() string

+ func (eid EndpointID) Path() string

+ type EndpointType interface

+ Authority func() string

+ MarshalCbor func(io.Writer) error

+ Path func() string

+ SchemeName func() string

+ SchemeNo func() uint64

+ func NewDtnEndpoint(uri string) (e EndpointType, err error)

+ func NewIpnEndpoint(uri string) (e EndpointType, err error)

+ type IpnEndpoint struct

+ Node uint64

+ Service uint64

+ func (e *IpnEndpoint) UnmarshalCbor(r io.Reader) error

+ func (e IpnEndpoint) Authority() string

+ func (e IpnEndpoint) CheckValid() error

+ func (e IpnEndpoint) MarshalCbor(w io.Writer) error

+ func (e IpnEndpoint) Path() string

+ func (e IpnEndpoint) SchemeName() string

+ func (e IpnEndpoint) SchemeNo() uint64

+ func (e IpnEndpoint) String() string

type PrimaryBlock

+ func (pb PrimaryBlock) MarshalJSON() ([]byte, error)

Dec 6, 2019

Changes in this version

+ func IsBundleReassemblable(bs []Bundle) bool

type Bundle

+ func ReassembleFragments(bs []Bundle) (b Bundle, err error)

+ func (b Bundle) Fragment(mtu int) (bs []Bundle, err error)

Dec 3, 2019

Changes in this version

type CanonicalBlock

+ func (cb CanonicalBlock) TypeCode() uint64

type ExtensionBlockManager

+ func (ebm *ExtensionBlockManager) ReadBlock(typeCode uint64, r io.Reader) (b ExtensionBlock, err error)

+ func (ebm *ExtensionBlockManager) WriteBlock(b ExtensionBlock, w io.Writer) error

+ type GenericExtensionBlock struct

+ func NewGenericExtensionBlock(data []byte, typeCode uint64) *GenericExtensionBlock

+ func (geb *GenericExtensionBlock) BlockTypeCode() uint64

+ func (geb *GenericExtensionBlock) CheckValid() error

+ func (geb *GenericExtensionBlock) MarshalBinary() ([]byte, error)

+ func (geb *GenericExtensionBlock) UnmarshalBinary(data []byte) error

type PayloadBlock

+ func (pb *PayloadBlock) MarshalBinary() ([]byte, error)

+ func (pb *PayloadBlock) UnmarshalBinary(data []byte) error

Aug 1, 2019

Changes in this version

type BundleID

+ func (bid BundleID) Scrub() BundleID

type CreationTimestamp

+ func (ct CreationTimestamp) IsZeroTime() bool

Jul 9, 2019

Changes in this version

+ const ExtBlockTypeBundleAgeBlock

+ const ExtBlockTypeHopCountBlock

+ const ExtBlockTypePayloadBlock

+ const ExtBlockTypePreviousNodeBlock

type BlockControlFlags

+ func (bcf BlockControlFlags) CheckValid() error

+ func (bcf BlockControlFlags) String() string

type Bundle

+ func ParseBundle(r io.Reader) (b Bundle, err error)

+ func (b *Bundle) MarshalCbor(w io.Writer) error

+ func (b *Bundle) UnmarshalCbor(r io.Reader) error

+ func (b *Bundle) WriteBundle(w io.Writer) error

+ func (b Bundle) CheckValid() (errs error)

type BundleAgeBlock

+ func (bab *BundleAgeBlock) Age() uint64

+ func (bab *BundleAgeBlock) BlockTypeCode() uint64

+ func (bab *BundleAgeBlock) Increment(offset uint64) uint64

+ func (bab *BundleAgeBlock) MarshalCbor(w io.Writer) error

+ func (bab *BundleAgeBlock) UnmarshalCbor(r io.Reader) error

+ func (pb *BundleAgeBlock) CheckValid() error

type BundleControlFlags

+ func (bcf BundleControlFlags) CheckValid() (errs error)

+ type BundleID struct

+ FragmentOffset uint64

+ IsFragment bool

+ SourceNode EndpointID

+ Timestamp CreationTimestamp

+ TotalDataLength uint64

+ func (bid *BundleID) MarshalCbor(w io.Writer) error

+ func (bid *BundleID) UnmarshalCbor(r io.Reader) error

+ func (bid BundleID) Len() uint64

+ func (bid BundleID) String() string

type CanonicalBlock

+ Value ExtensionBlock

+ func (cb *CanonicalBlock) MarshalCbor(w io.Writer) error

+ func (cb *CanonicalBlock) UnmarshalCbor(r io.Reader) error

+ func (cb CanonicalBlock) BlockTypeCode() uint64

+ func (cb CanonicalBlock) CheckValid() (errs error)

type CreationTimestamp

+ func (ct *CreationTimestamp) MarshalCbor(w io.Writer) error

+ func (ct *CreationTimestamp) UnmarshalCbor(r io.Reader) error

type EndpointID

+ func (eid *EndpointID) MarshalCbor(w io.Writer) error

+ func (eid *EndpointID) UnmarshalCbor(r io.Reader) error

+ func (eid EndpointID) CheckValid() error

+ type ExtensionBlock interface

+ BlockTypeCode func() uint64

+ type ExtensionBlockManager struct

+ func GetExtensionBlockManager() *ExtensionBlockManager

+ func NewExtensionBlockManager() *ExtensionBlockManager

+ func (ebm *ExtensionBlockManager) CreateBlock(typeCode uint64) (eb ExtensionBlock, err error)

+ func (ebm *ExtensionBlockManager) IsKnown(typeCode uint64) bool

+ func (ebm *ExtensionBlockManager) Register(eb ExtensionBlock) error

+ func (ebm *ExtensionBlockManager) Unregister(eb ExtensionBlock)

type HopCountBlock

+ Count uint64

+ Limit uint64

+ func (hcb *HopCountBlock) BlockTypeCode() uint64

+ func (hcb *HopCountBlock) Decrement()

+ func (hcb *HopCountBlock) Increment() bool

+ func (hcb *HopCountBlock) MarshalCbor(w io.Writer) error

+ func (hcb *HopCountBlock) UnmarshalCbor(r io.Reader) error

+ func (hcb HopCountBlock) IsExceeded() bool

+ func (pb *HopCountBlock) CheckValid() error

type PayloadBlock

+ func (pb *PayloadBlock) BlockTypeCode() uint64

+ func (pb *PayloadBlock) CheckValid() error

+ func (pb *PayloadBlock) Data() []byte

+ func (pb *PayloadBlock) MarshalCbor(w io.Writer) error

+ func (pb *PayloadBlock) UnmarshalCbor(r io.Reader) error

type PreviousNodeBlock

+ func (pb *PreviousNodeBlock) CheckValid() error

+ func (pnb *PreviousNodeBlock) BlockTypeCode() uint64

+ func (pnb *PreviousNodeBlock) Endpoint() EndpointID

+ func (pnb *PreviousNodeBlock) MarshalCbor(w io.Writer) error

+ func (pnb *PreviousNodeBlock) UnmarshalCbor(r io.Reader) error

type PrimaryBlock

+ func (pb *PrimaryBlock) MarshalCbor(w io.Writer) error

+ func (pb *PrimaryBlock) UnmarshalCbor(r io.Reader) error

+ func (pb PrimaryBlock) CheckValid() (errs error)

+ type Valid interface

+ CheckValid func() error

Jun 6, 2019

Changes in this version

+ type BlockControlFlags uint8

+ const DeleteBundle

+ const RemoveBlock

+ const ReplicateBlock

+ const StatusReportBlock

+ func (bcf BlockControlFlags) Has(flag BlockControlFlags) bool

+ type Bundle struct

+ CanonicalBlocks []CanonicalBlock

+ PrimaryBlock PrimaryBlock

+ func MustNewBundle(primary PrimaryBlock, canonicals []CanonicalBlock) Bundle

+ func NewBundle(primary PrimaryBlock, canonicals []CanonicalBlock) (b Bundle, err error)

+ func NewBundleFromCbor(data *[]byte) (b Bundle, err error)

+ func (b *Bundle) AddExtensionBlock(block CanonicalBlock)

+ func (b *Bundle) CalculateCRC()

+ func (b *Bundle) CheckCRC() bool

+ func (b *Bundle) ExtensionBlock(blockType CanonicalBlockType) (*CanonicalBlock, error)

+ func (b *Bundle) PayloadBlock() (*CanonicalBlock, error)

+ func (b *Bundle) SetCRCType(crcType CRCType)

+ func (b Bundle) ID() string

+ func (b Bundle) IsAdministrativeRecord() bool

+ func (b Bundle) String() string

+ func (b Bundle) ToCbor() []byte

+ type BundleBuilder struct

+ func Builder() *BundleBuilder

+ func (bldr *BundleBuilder) Build() (bndl Bundle, err error)

+ func (bldr *BundleBuilder) BundleAgeBlock(args ...interface{}) *BundleBuilder

+ func (bldr *BundleBuilder) BundleCtrlFlags(bcf BundleControlFlags) *BundleBuilder

+ func (bldr *BundleBuilder) CRC(crcType CRCType) *BundleBuilder

+ func (bldr *BundleBuilder) Canonical(args ...interface{}) *BundleBuilder

+ func (bldr *BundleBuilder) CreationTimestampEpoch() *BundleBuilder

+ func (bldr *BundleBuilder) CreationTimestampNow() *BundleBuilder

+ func (bldr *BundleBuilder) CreationTimestampTime(t time.Time) *BundleBuilder

+ func (bldr *BundleBuilder) Destination(eid interface{}) *BundleBuilder

+ func (bldr *BundleBuilder) Error() error

+ func (bldr *BundleBuilder) HopCountBlock(args ...interface{}) *BundleBuilder

+ func (bldr *BundleBuilder) Lifetime(duration interface{}) *BundleBuilder

+ func (bldr *BundleBuilder) PayloadBlock(args ...interface{}) *BundleBuilder

+ func (bldr *BundleBuilder) PreviousNodeBlock(args ...interface{}) *BundleBuilder

+ func (bldr *BundleBuilder) ReportTo(eid interface{}) *BundleBuilder

+ func (bldr *BundleBuilder) Source(eid interface{}) *BundleBuilder

+ type BundleControlFlags uint16

+ const AdministrativeRecordPayload

+ const ContainsManifest

+ const IsFragment

+ const MustNotFragmented

+ const RequestStatusTime

+ const RequestUserApplicationAck

+ const StatusRequestDeletion

+ const StatusRequestDelivery

+ const StatusRequestForward

+ const StatusRequestReception

+ func (bcf BundleControlFlags) Has(flag BundleControlFlags) bool

+ func (bcf BundleControlFlags) String() string

+ type CRCType uint

+ const CRC16

+ const CRC32

+ const CRCNo

+ func (c CRCType) String() string

+ type CanonicalBlock struct

+ BlockControlFlags BlockControlFlags

+ BlockNumber uint

+ BlockType CanonicalBlockType

+ CRC []byte

+ CRCType CRCType

+ Data interface{}

+ func NewBundleAgeBlock(blockNumber uint, blockControlFlags BlockControlFlags, time uint) CanonicalBlock

+ func NewCanonicalBlock(blockType CanonicalBlockType, blockNumber uint, ...) CanonicalBlock

+ func NewHopCountBlock(blockNumber uint, blockControlFlags BlockControlFlags, hopCount HopCount) CanonicalBlock

+ func NewPayloadBlock(blockControlFlags BlockControlFlags, data []byte) CanonicalBlock

+ func NewPreviousNodeBlock(blockNumber uint, blockControlFlags BlockControlFlags, prevNodeId EndpointID) CanonicalBlock

+ func (cb *CanonicalBlock) CalculateCRC()

+ func (cb *CanonicalBlock) CheckCRC() bool

+ func (cb *CanonicalBlock) CodecDecodeSelf(dec *codec.Decoder)

+ func (cb *CanonicalBlock) SetCRCType(crcType CRCType)

+ func (cb CanonicalBlock) CodecEncodeSelf(enc *codec.Encoder)

+ func (cb CanonicalBlock) GetCRCType() CRCType

+ func (cb CanonicalBlock) HasCRC() bool

+ func (cb CanonicalBlock) String() string

+ type CanonicalBlockType uint

+ const BundleAgeBlock

+ const ConfidentialityBlock

+ const FlowLabelBlock

+ const HopCountBlock

+ const IntegrityBlock

+ const ManifestBlock

+ const PayloadBlock

+ const PreviousNodeBlock

+ type CreationTimestamp [2]uint

+ func NewCreationTimestamp(time DtnTime, sequence uint) CreationTimestamp

+ func (ct CreationTimestamp) DtnTime() DtnTime

+ func (ct CreationTimestamp) SequenceNumber() uint

+ func (ct CreationTimestamp) String() string

+ type DtnTime uint

+ const DtnTimeEpoch

+ func DtnTimeFromTime(t time.Time) DtnTime

+ func DtnTimeNow() DtnTime

+ func (t DtnTime) String() string

+ func (t DtnTime) Time() time.Time

+ func (t DtnTime) Unix() int64

+ type EndpointID struct

+ SchemeName uint64

+ SchemeSpecificPart interface{}

+ func DtnNone() EndpointID

+ func MustNewEndpointID(eid string) EndpointID

+ func NewEndpointID(eid string) (e EndpointID, err error)

+ func (eid *EndpointID) CodecDecodeSelf(dec *codec.Decoder)

+ func (eid *EndpointID) CodecEncodeSelf(enc *codec.Encoder)

+ func (eid EndpointID) String() string

+ type HopCount struct

+ Count uint

+ Limit uint

+ func NewHopCount(limit uint) HopCount

+ func (hc *HopCount) Decrement()

+ func (hc *HopCount) Increment() bool

+ func (hc HopCount) IsExceeded() bool

+ func (hc HopCount) String() string

+ type PrimaryBlock struct

+ BundleControlFlags BundleControlFlags

+ CRC []byte

+ CRCType CRCType

+ CreationTimestamp CreationTimestamp

+ Destination EndpointID

+ FragmentOffset uint

+ Lifetime uint

+ ReportTo EndpointID

+ SourceNode EndpointID

+ TotalDataLength uint

+ Version uint

+ func NewPrimaryBlock(bundleControlFlags BundleControlFlags, destination EndpointID, ...) PrimaryBlock

+ func (pb *PrimaryBlock) CalculateCRC()

+ func (pb *PrimaryBlock) CheckCRC() bool

+ func (pb *PrimaryBlock) CodecDecodeSelf(dec *codec.Decoder)

+ func (pb *PrimaryBlock) CodecEncodeSelf(enc *codec.Encoder)

+ func (pb *PrimaryBlock) SetCRCType(crcType CRCType)

+ func (pb PrimaryBlock) GetCRCType() CRCType

+ func (pb PrimaryBlock) HasCRC() bool

+ func (pb PrimaryBlock) HasFragmentation() bool

+ func (pb PrimaryBlock) IsLifetimeExceeded() bool

+ func (pb PrimaryBlock) String() string