Versions in this module Expand all Collapse all v0 v0.1.1 Feb 25, 2019 Changes in this version + const MaxAddrs + const MaxInv + const MaxLength + const MaxTx + const MessageVersion + const ServiceFull + var ConnectionTimeout = 10 * time.Minute + var ErrIntOverflowMsg = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthMsg = fmt.Errorf("proto: negative length found during unmarshaling") + func TxType2DBHeader(typ tx.Type) (db.Header, error) + func Write(s *setting.Setting, m proto.Marshaler, cmd Command, conn io.Writer) error + type Addr struct + Address string + Service byte + func NewAddr(adr string, service byte) *Addr + func NewPopulatedAddr(r randyMsg, easy bool) *Addr + func (*Addr) Descriptor() ([]byte, []int) + func (*Addr) ProtoMessage() + func (dst *Addr) XXX_Merge(src proto.Message) + func (m *Addr) Marshal() (dAtA []byte, err error) + func (m *Addr) MarshalTo(dAtA []byte) (int, error) + func (m *Addr) Reset() + func (m *Addr) Size() (n int) + func (m *Addr) String() string + func (m *Addr) Unmarshal(dAtA []byte) error + func (m *Addr) XXX_DiscardUnknown() + func (m *Addr) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Addr) XXX_Size() int + func (m *Addr) XXX_Unmarshal(b []byte) error + func (this *Addr) Equal(that interface{}) bool + type Addrs []*Addr + func ReadAddrs(s *setting.Setting, buf []byte) (Addrs, error) + type AddrsProto struct + Addrs []*Addr + func NewPopulatedAddrsProto(r randyMsg, easy bool) *AddrsProto + func (*AddrsProto) Descriptor() ([]byte, []int) + func (*AddrsProto) ProtoMessage() + func (dst *AddrsProto) XXX_Merge(src proto.Message) + func (m *AddrsProto) Marshal() (dAtA []byte, err error) + func (m *AddrsProto) MarshalTo(dAtA []byte) (int, error) + func (m *AddrsProto) Reset() + func (m *AddrsProto) Size() (n int) + func (m *AddrsProto) String() string + func (m *AddrsProto) Unmarshal(dAtA []byte) error + func (m *AddrsProto) XXX_DiscardUnknown() + func (m *AddrsProto) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AddrsProto) XXX_Size() int + func (m *AddrsProto) XXX_Unmarshal(b []byte) error + func (this *AddrsProto) Equal(that interface{}) bool + type Command byte + const CmdAddr + const CmdClose + const CmdConsensusMessage + const CmdFollowingHash + const CmdGetAddr + const CmdGetData + const CmdGetFollowingHash + const CmdGetLeaves + const CmdInv + const CmdLeaves + const CmdPing + const CmdPong + const CmdTxs + const CmdVerack + const CmdVersion + func ReadHeader(s *setting.Setting, conn io.Reader) (Command, []byte, error) + func (c Command) String() string + type Hashes struct + Hashes []github_com_AidosKuneen_aklib_tx.Hash + func NewPopulatedHashes(r randyMsg, easy bool) *Hashes + func (*Hashes) Descriptor() ([]byte, []int) + func (*Hashes) ProtoMessage() + func (dst *Hashes) XXX_Merge(src proto.Message) + func (m *Hashes) Marshal() (dAtA []byte, err error) + func (m *Hashes) MarshalTo(dAtA []byte) (int, error) + func (m *Hashes) Reset() + func (m *Hashes) Size() (n int) + func (m *Hashes) String() string + func (m *Hashes) Unmarshal(dAtA []byte) error + func (m *Hashes) XXX_DiscardUnknown() + func (m *Hashes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Hashes) XXX_Size() int + func (m *Hashes) XXX_Unmarshal(b []byte) error + func (this *Hashes) Equal(that interface{}) bool + type InvType byte + const InvTxNormal + const InvTxRewardFee + const InvTxRewardTicket + func TxType2InvType(typ tx.Type) (InvType, error) + func (it InvType) ToTxType() (tx.Type, error) + type Inventories []*Inventory + func ReadInventories(buf []byte) (Inventories, error) + type InventoriesProto struct + Inventories []*Inventory + func NewPopulatedInventoriesProto(r randyMsg, easy bool) *InventoriesProto + func (*InventoriesProto) Descriptor() ([]byte, []int) + func (*InventoriesProto) ProtoMessage() + func (dst *InventoriesProto) XXX_Merge(src proto.Message) + func (m *InventoriesProto) Marshal() (dAtA []byte, err error) + func (m *InventoriesProto) MarshalTo(dAtA []byte) (int, error) + func (m *InventoriesProto) Reset() + func (m *InventoriesProto) Size() (n int) + func (m *InventoriesProto) String() string + func (m *InventoriesProto) Unmarshal(dAtA []byte) error + func (m *InventoriesProto) XXX_DiscardUnknown() + func (m *InventoriesProto) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *InventoriesProto) XXX_Size() int + func (m *InventoriesProto) XXX_Unmarshal(b []byte) error + func (this *InventoriesProto) Equal(that interface{}) bool + type Inventory struct + Hash []byte + Type InvType + func NewPopulatedInventory(r randyMsg, easy bool) *Inventory + func (*Inventory) Descriptor() ([]byte, []int) + func (*Inventory) ProtoMessage() + func (dst *Inventory) XXX_Merge(src proto.Message) + func (m *Inventory) Marshal() (dAtA []byte, err error) + func (m *Inventory) MarshalTo(dAtA []byte) (int, error) + func (m *Inventory) Reset() + func (m *Inventory) Size() (n int) + func (m *Inventory) String() string + func (m *Inventory) Unmarshal(dAtA []byte) error + func (m *Inventory) XXX_DiscardUnknown() + func (m *Inventory) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Inventory) XXX_Size() int + func (m *Inventory) XXX_Unmarshal(b []byte) error + func (this *Inventory) Equal(that interface{}) bool + type Nonce [32]byte + func ReadNonce(buf []byte) (*Nonce, error) + type NonceProto struct + Nonce []byte + func NewPopulatedNonceProto(r randyMsg, easy bool) *NonceProto + func (*NonceProto) Descriptor() ([]byte, []int) + func (*NonceProto) ProtoMessage() + func (dst *NonceProto) XXX_Merge(src proto.Message) + func (m *NonceProto) Marshal() (dAtA []byte, err error) + func (m *NonceProto) MarshalTo(dAtA []byte) (int, error) + func (m *NonceProto) Reset() + func (m *NonceProto) Size() (n int) + func (m *NonceProto) String() string + func (m *NonceProto) Unmarshal(dAtA []byte) error + func (m *NonceProto) XXX_DiscardUnknown() + func (m *NonceProto) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *NonceProto) XXX_Size() int + func (m *NonceProto) XXX_Unmarshal(b []byte) error + func (this *NonceProto) Equal(that interface{}) bool + type Tx struct + Tx *tx.Transaction + Type InvType + func NewPopulatedTx(r randyMsg, easy bool) *Tx + func (*Tx) Descriptor() ([]byte, []int) + func (*Tx) ProtoMessage() + func (dst *Tx) XXX_Merge(src proto.Message) + func (m *Tx) Marshal() (dAtA []byte, err error) + func (m *Tx) MarshalTo(dAtA []byte) (int, error) + func (m *Tx) Reset() + func (m *Tx) Size() (n int) + func (m *Tx) String() string + func (m *Tx) Unmarshal(dAtA []byte) error + func (m *Tx) XXX_DiscardUnknown() + func (m *Tx) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Tx) XXX_Size() int + func (m *Tx) XXX_Unmarshal(b []byte) error + func (this *Tx) Equal(that interface{}) bool + type Txs []*Tx + func ReadTxs(buf []byte) (Txs, error) + type TxsProto struct + Txs []*Tx + func NewPopulatedTxsProto(r randyMsg, easy bool) *TxsProto + func (*TxsProto) Descriptor() ([]byte, []int) + func (*TxsProto) ProtoMessage() + func (dst *TxsProto) XXX_Merge(src proto.Message) + func (m *TxsProto) Marshal() (dAtA []byte, err error) + func (m *TxsProto) MarshalTo(dAtA []byte) (int, error) + func (m *TxsProto) Reset() + func (m *TxsProto) Size() (n int) + func (m *TxsProto) String() string + func (m *TxsProto) Unmarshal(dAtA []byte) error + func (m *TxsProto) XXX_DiscardUnknown() + func (m *TxsProto) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TxsProto) XXX_Size() int + func (m *TxsProto) XXX_Unmarshal(b []byte) error + func (this *TxsProto) Equal(that interface{}) bool + type Version struct + AddrFrom Addr + AddrTo Addr + Nonce uint64 + UserAgent string + Version uint16 + func NewPopulatedVersion(r randyMsg, easy bool) *Version + func NewVersion(s *setting.Setting, to Addr, nonce uint64) *Version + func ReadVersion(s *setting.Setting, buf []byte, verNonce uint64) (*Version, error) + func (*Version) Descriptor() ([]byte, []int) + func (*Version) ProtoMessage() + func (dst *Version) XXX_Merge(src proto.Message) + func (m *Version) Marshal() (dAtA []byte, err error) + func (m *Version) MarshalTo(dAtA []byte) (int, error) + func (m *Version) Reset() + func (m *Version) Size() (n int) + func (m *Version) String() string + func (m *Version) Unmarshal(dAtA []byte) error + func (m *Version) XXX_DiscardUnknown() + func (m *Version) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Version) XXX_Size() int + func (m *Version) XXX_Unmarshal(b []byte) error + func (this *Version) Equal(that interface{}) bool