whisperv5

package

Go to main page

Versions in this module

v1

v1.5.8

Feb 1, 2017

Changes in this version

type Peer

+ func (p *Peer) ID() []byte

type Whisper

+ func (w *Whisper) SendP2PDirect(peer *Peer, envelope *Envelope) error

v1.5.7

Jan 16, 2017

v1.5.6

Jan 9, 2017

Changes in this version

+ func IsPubKeyEqual(a, b *ecdsa.PublicKey) bool

v1.5.5

Dec 14, 2016

Changes in this version

+ const AESNonceMaxLength

type Filter

+ func (f *Filter) MatchTopic(topic TopicType) bool

v1.5.4

Nov 28, 2016

v1.5.3

Nov 24, 2016

v1.5.2

Nov 18, 2016

v1.5.1

Nov 16, 2016

v1.5.0

Nov 15, 2016

Changes in this version

+ const DefaultTTL

+ const EnvelopeVersion

+ const MaxMessageLength

+ const MinimumPoW

+ const NumberOfMessageCodes

+ const ProtocolName

+ const ProtocolVersion

+ const ProtocolVersionStr

+ const SynchAllowance

+ const TopicLength

+ func BytesToIntBigEndian(b []byte) (res uint64)

+ func DeriveOneTimeKey(key []byte, salt []byte, version uint64) ([]byte, error)

+ func ValidatePublicKey(k *ecdsa.PublicKey) bool

+ type Envelope struct

+ AESNonce []byte

+ Data []byte

+ EnvNonce uint64

+ Expiry uint32

+ Salt []byte

+ TTL uint32

+ Topic TopicType

+ Version []byte

+ func NewEnvelope(ttl uint32, topic TopicType, salt []byte, aesNonce []byte, msg *SentMessage) *Envelope

+ func (e *Envelope) DecodeRLP(s *rlp.Stream) error

+ func (e *Envelope) Hash() common.Hash

+ func (e *Envelope) IsSymmetric() bool

+ func (e *Envelope) Open(watcher *Filter) (msg *ReceivedMessage)

+ func (e *Envelope) OpenAsymmetric(key *ecdsa.PrivateKey) (*ReceivedMessage, error)

+ func (e *Envelope) OpenSymmetric(key []byte) (msg *ReceivedMessage, err error)

+ func (e *Envelope) PoW() float64

+ func (e *Envelope) Seal(options *MessageParams)

+ func (e *Envelope) Ver() uint64

+ type Filter struct

+ AcceptP2P bool

+ KeyAsym *ecdsa.PrivateKey

+ KeySym []byte

+ Messages map[common.Hash]*ReceivedMessage

+ PoW float64

+ Src *ecdsa.PublicKey

+ SymKeyHash common.Hash

+ Topics []TopicType

+ func (f *Filter) MatchEnvelope(envelope *Envelope) bool

+ func (f *Filter) MatchMessage(msg *ReceivedMessage) bool

+ func (f *Filter) Retrieve() (all []*ReceivedMessage)

+ func (f *Filter) Trigger(msg *ReceivedMessage)

+ type Filters struct

+ func NewFilters(w *Whisper) *Filters

+ func (fs *Filters) Get(i int) *Filter

+ func (fs *Filters) Install(watcher *Filter) int

+ func (fs *Filters) NotifyWatchers(env *Envelope, messageCode uint64)

+ func (fs *Filters) Uninstall(id int)

+ type MailServer interface

+ Archive func(env *Envelope)

+ DeliverMail func(whisperPeer *Peer, data []byte)

+ type MessageParams struct

+ Dst *ecdsa.PublicKey

+ KeySym []byte

+ Padding []byte

+ Payload []byte

+ PoW float64

+ Src *ecdsa.PrivateKey

+ TTL uint32

+ Topic TopicType

+ WorkTime uint32

+ type Peer struct

+ type ReceivedMessage struct

+ Dst *ecdsa.PublicKey

+ EnvelopeHash common.Hash

+ EnvelopeVersion uint64

+ Padding []byte

+ Payload []byte

+ PoW float64

+ Raw []byte

+ Sent uint32

+ Signature []byte

+ Src *ecdsa.PublicKey

+ SymKeyHash common.Hash

+ TTL uint32

+ Topic TopicType

+ func (msg *ReceivedMessage) SigToPubKey() *ecdsa.PublicKey

+ func (msg *ReceivedMessage) Validate() bool

+ type SentMessage struct

+ Raw []byte

+ func NewSentMessage(params *MessageParams) *SentMessage

+ func (msg *SentMessage) Wrap(options *MessageParams) (envelope *Envelope, err error)

+ type TopicType [TopicLength]byte

+ func BytesToTopic(b []byte) (t TopicType)

+ func (t *TopicType) UnmarshalJSON(input []byte) error

+ func (topic *TopicType) String() string

+ type Whisper struct

+ func NewWhisper(server MailServer) *Whisper

+ func (w *Whisper) AddSymKey(name string, key []byte) error

+ func (w *Whisper) DeleteIdentity(key string)

+ func (w *Whisper) DeleteSymKey(name string)

+ func (w *Whisper) Envelopes() []*Envelope

+ func (w *Whisper) GenerateSymKey(name string) error

+ func (w *Whisper) GetFilter(id int) *Filter

+ func (w *Whisper) GetIdentity(pubKey string) *ecdsa.PrivateKey

+ func (w *Whisper) GetSymKey(name string) []byte

+ func (w *Whisper) HasIdentity(pubKey string) bool

+ func (w *Whisper) HasSymKey(name string) bool

+ func (w *Whisper) MarkPeerTrusted(peerID []byte) error

+ func (w *Whisper) Messages(id int) []*ReceivedMessage

+ func (w *Whisper) NewIdentity() *ecdsa.PrivateKey

+ func (w *Whisper) Protocols() []p2p.Protocol

+ func (w *Whisper) RequestHistoricMessages(peerID []byte, data []byte) error

+ func (w *Whisper) Send(envelope *Envelope) error

+ func (w *Whisper) SendP2PMessage(peerID []byte, envelope *Envelope) error

+ func (w *Whisper) Start(*p2p.Server) error

+ func (w *Whisper) Stop() error

+ func (w *Whisper) Unwatch(id int)

+ func (w *Whisper) Version() uint

+ func (w *Whisper) Watch(f *Filter) int

+ func (wh *Whisper) HandlePeer(peer *p2p.Peer, rw p2p.MsgReadWriter) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL