Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

sphinx

package module

Go to main page

Versions in this module

v1

v1.0.4

Mar 4, 2020

v1.0.3

Mar 4, 2020

v1.0.2

Mar 4, 2020

Changes in this version

+ const AddressSize

+ const AmtForwardSize

+ const HMACSize

+ const LegacyHopDataSize

+ const MaxPayloadSize

+ const NumPaddingBytes

+ const OutgoingCLTVSize

+ const RealmByteSize

+ var ErrMaxRoutingInfoSizeExceeded = fmt.Errorf("max routing info size of %v bytes exceeded", routingInfoSize)

+ var ErrVarIntNotCanonical = errors.New("decoded varint is not canonical")

+ func BlankPacketFiller(_ *btcec.PrivateKey, _ *[routingInfoSize]byte) error

+ func DeterministicPacketFiller(sessionKey *btcec.PrivateKey, mixHeader *[routingInfoSize]byte) error

+ func RandPacketFiller(_ *btcec.PrivateKey, mixHeader *[routingInfoSize]byte) error

+ func ReadVarInt(r io.Reader, buf *[8]byte) (uint64, error)

+ func WriteVarInt(w io.Writer, val uint64, buf *[8]byte) error

+ type DecryptedError struct

+ Message []byte

+ Sender *btcec.PublicKey

+ SenderIdx int

+ type HopPayload struct

+ HMAC [HMACSize]byte

+ Payload []byte

+ Type PayloadType

+ func NewHopPayload(hopData *HopData, eob []byte) (HopPayload, error)

+ func (hp *HopPayload) Decode(r io.Reader) error

+ func (hp *HopPayload) Encode(w io.Writer) error

+ func (hp *HopPayload) HopData() (*HopData, error)

+ func (hp *HopPayload) NumBytes() int

+ type OnionHop struct

+ HopPayload HopPayload

+ NodePub btcec.PublicKey

+ func (o OnionHop) IsEmpty() bool

+ type PacketFiller func(*btcec.PrivateKey, *[routingInfoSize]byte) error

+ type PayloadType uint8

+ const PayloadLegacy

+ const PayloadTLV

+ type PaymentPath [NumMaxHops]OnionHop

+ func (p *PaymentPath) NodeKeys() []*btcec.PublicKey

+ func (p *PaymentPath) TotalPayloadSize() int

+ func (p *PaymentPath) TrueRouteLength() int

type ProcessedPacket

+ Payload HopPayload

v0

v0.0.4

Apr 4, 2019

v0.0.3

Apr 4, 2019

v0.0.2

Apr 4, 2019

Changes in this version

+ const ExitNode

+ const Failure

+ const HashPrefixSize

+ const MoreHops

+ const NumMaxHops

+ var ErrAlreadyCommitted = errors.New("cannot add to batch after committing")

+ var ErrInvalidOnionHMAC = fmt.Errorf("invalid mismatched mac")

+ var ErrInvalidOnionKey = fmt.Errorf(...)

+ var ErrInvalidOnionVersion = fmt.Errorf("invalid onion packet version")

+ var ErrLogEntryNotFound = fmt.Errorf("sphinx packet is not in log")

+ var ErrReplayedPacket = fmt.Errorf("sphinx packet replay attempted")

+ func DisableLog()

+ func UseLogger(logger btclog.Logger)

+ type Batch struct

+ ID []byte

+ IsCommitted bool

+ ReplaySet *ReplaySet

+ func NewBatch(id []byte) *Batch

+ func (b *Batch) ForEach(fn func(seqNum uint16, hashPrefix *HashPrefix, cltv uint32) error) error

+ func (b *Batch) Put(seqNum uint16, hashPrefix *HashPrefix, cltv uint32) error

+ type Circuit struct

+ PaymentPath []*btcec.PublicKey

+ SessionKey *btcec.PrivateKey

+ func (c *Circuit) Decode(r io.Reader) error

+ func (c *Circuit) Encode(w io.Writer) error

+ type Hash256 [sha256.Size]byte

+ type HashPrefix [HashPrefixSize]byte

+ type HopData struct

+ ExtraBytes [padSize]byte

+ ForwardAmount uint64

+ HMAC [hmacSize]byte

+ NextAddress [addressSize]byte

+ OutgoingCltv uint32

+ Realm byte

+ func (hd *HopData) Decode(r io.Reader) error

+ func (hd *HopData) Encode(w io.Writer) error

+ type MemoryReplayLog struct

+ func NewMemoryReplayLog() *MemoryReplayLog

+ func (rl *MemoryReplayLog) Delete(hash *HashPrefix) error

+ func (rl *MemoryReplayLog) Get(hash *HashPrefix) (uint32, error)

+ func (rl *MemoryReplayLog) Put(hash *HashPrefix, cltv uint32) error

+ func (rl *MemoryReplayLog) PutBatch(batch *Batch) (*ReplaySet, error)

+ func (rl *MemoryReplayLog) Start() error

+ func (rl *MemoryReplayLog) Stop() error

+ type OnionErrorDecrypter struct

+ func NewOnionErrorDecrypter(circuit *Circuit) *OnionErrorDecrypter

+ func (o *OnionErrorDecrypter) DecryptError(encryptedData []byte) (*btcec.PublicKey, []byte, error)

+ type OnionErrorEncrypter struct

+ func NewOnionErrorEncrypter(router *Router, ephemeralKey *btcec.PublicKey) (*OnionErrorEncrypter, error)

+ func (o *OnionErrorEncrypter) Decode(r io.Reader) error

+ func (o *OnionErrorEncrypter) Encode(w io.Writer) error

+ func (o *OnionErrorEncrypter) EncryptError(initial bool, data []byte) []byte

+ type OnionPacket struct

+ EphemeralKey *btcec.PublicKey

+ HeaderMAC [hmacSize]byte

+ RoutingInfo [routingInfoSize]byte

+ Version byte

+ func NewOnionPacket(paymentPath []*btcec.PublicKey, sessionKey *btcec.PrivateKey, ...) (*OnionPacket, error)

+ func (f *OnionPacket) Decode(r io.Reader) error

+ func (f *OnionPacket) Encode(w io.Writer) error

+ type ProcessCode int

+ func (p ProcessCode) String() string

+ type ProcessedPacket struct

+ Action ProcessCode

+ ForwardingInstructions HopData

+ NextPacket *OnionPacket

+ type ReplayLog interface

+ Delete func(*HashPrefix) error

+ Get func(*HashPrefix) (uint32, error)

+ Put func(*HashPrefix, uint32) error

+ PutBatch func(*Batch) (*ReplaySet, error)

+ Start func() error

+ Stop func() error

+ type ReplaySet struct

+ func NewReplaySet() *ReplaySet

+ func (rs *ReplaySet) Add(idx uint16)

+ func (rs *ReplaySet) Contains(idx uint16) bool

+ func (rs *ReplaySet) Decode(r io.Reader) error

+ func (rs *ReplaySet) Encode(w io.Writer) error

+ func (rs *ReplaySet) Merge(rs2 *ReplaySet)

+ func (rs *ReplaySet) Size() int

+ type Router struct

+ func NewRouter(nodeKey *btcec.PrivateKey, net *chaincfg.Params, log ReplayLog) *Router

+ func (r *Router) BeginTxn(id []byte, nels int) *Tx

+ func (r *Router) ProcessOnionPacket(onionPkt *OnionPacket, assocData []byte, incomingCltv uint32) (*ProcessedPacket, error)

+ func (r *Router) ReconstructOnionPacket(onionPkt *OnionPacket, assocData []byte) (*ProcessedPacket, error)

+ func (r *Router) Start() error

+ func (r *Router) Stop()

+ type Tx struct

+ func (t *Tx) Commit() ([]ProcessedPacket, *ReplaySet, error)

+ func (t *Tx) ProcessOnionPacket(seqNum uint16, onionPkt *OnionPacket, assocData []byte, incomingCltv uint32) error