arpfuckery

type AdmissionPolicy func(*HavePacket) bool

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

type ClientOpts struct {
	ObjectCapacity               int
	SweepInterval                time.Duration
	ReannounceInterval           time.Duration
	DefaultReceivedIncompleteTTL time.Duration
	DefaultReceivedCompleteTTL   time.Duration
	DefaultCreatedCompleteTTL    time.Duration
	WantRetryDelay               time.Duration
	WantMaxRetries               int
	QueueHaveCapacity            int
	QueueWantCapacity            int
	QueueOwnedCapacity           int
	QueueReplicaCapacity         int
	SeenFragCapacity             int
	SeenFragTTL                  time.Duration
	ReplicaDelay                 time.Duration
	ReplicaJitter                time.Duration
	OptimisticBurstMaxSize       uint64
	OptimisticBurstFrags         uint16
	AdmissionPolicy              AdmissionPolicy
	AutoPinOwned                 bool
	AutoPinReceived              bool
	Logger                       *log.Logger
}

type FragPacket struct {
	ObjectID  ObjectID // half a sha256 hash
	FragIndex uint16   // index of the fragment
	Payload   []byte   // arbitrary payload

	// not marshaled
	SourceMAC net.HardwareAddr
}

type FragmentRef struct {
	ObjectID  ObjectID
	FragIndex uint16
}

type HavePacket struct {
	ObjectID   ObjectID   // half a sha256 hash
	ObjectSize uint64     // it would be very funny to use the full extent of this
	ObjectHash ObjectHash // sha256 hash of the entire object
	FragCount  uint16     // number of fragments in the object
	Metadata   []byte     // arbitrary metadata idk what this will look like, can't be fragmented...

	// not marshaled
	SourceMAC net.HardwareAddr
}

type Object struct {
	ID        ObjectID
	Size      uint64
	Hash      ObjectHash
	FragCount uint16
	Metadata  []byte

	Created     time.Time
	CompletedAt time.Time
	Expires     time.Time
	LastHave    time.Time
	LastRetry   time.Time
	NextWant    time.Time
	Source      net.HardwareAddr
	Retries     int
	Owned       bool
	Pinned      bool
	Complete    bool

	Fragments map[uint16][]byte
	Data      []byte
}

type ObjectEvent struct {
	Kind   ObjectEventKind
	Object ObjectSnapshot
}

type ObjectEventKind string

type ObjectHash [32]byte

type ObjectID [16]byte

type ObjectSnapshot struct {
	ID            ObjectID
	Size          uint64
	Hash          ObjectHash
	FragCount     uint16
	Metadata      []byte
	Created       time.Time
	CompletedAt   time.Time
	Expires       time.Time
	LastHave      time.Time
	LastRetry     time.Time
	NextWant      time.Time
	Source        net.HardwareAddr
	Retries       int
	Owned         bool
	Pinned        bool
	Complete      bool
	ReceivedFrags uint16
	ReceivedBytes uint64
	Data          []byte
}

type Packet interface {
	MarshalBinary() ([]byte, error)
	Source() net.HardwareAddr
}

type WantPacket struct {
	ObjectID  ObjectID // half a sha256 hash
	FragCount uint16   // number of fragments wanted
	Frags     []uint16 // list of fragment indicies wanted

	// not marshaled
	SourceMAC net.HardwareAddr
}