event

Documentation

Index

• type CARenewNetworkCert
• type CARenewNetworkCertError
• type Cipher
• type DirectoryAssetBundle
• type DirectoryEvent
• type DirectorySyndicateStart
• type DirectorySyndicateStop
• type NetworkCertUpdate
• type NetworkCertUpdateError
• type NetworkPeerBindings
• type NetworkPeerClose
• type NetworkPeerCountUpdate
• type NetworkPeerOpen
• type NetworkStart
• type NetworkStop
• type Notification
• type NotificationDismiss
• type Observers
  • func NewObservers(logger *zap.Logger, q queue.Queue, c Cipher) *Observers
  • func (o *Observers) Chan() chan any
  • func (o *Observers) EmitGlobal(v proto.Message)
  • func (o *Observers) EmitLocal(v any)
  • func (o *Observers) Events() (chan any, func())
  • func (o *Observers) Notify(ch any)
  • func (o *Observers) StopNotifying(ch any)
• type PeerAdd
• type PeerRemove

Types

type CARenewNetworkCert

type CARenewNetworkCert struct {
	Network     *network.Network
	Certificate *certificate.Certificate
}

CARenewNetworkCert ...

type CARenewNetworkCertError

type CARenewNetworkCertError struct {
	Network *network.Network
	Error   error
}

CARenewNetworkCertError ...

type Cipher

type Cipher interface {
	Seal(p []byte) ([]byte, error)
	Open(b []byte) ([]byte, error)
}

type DirectoryAssetBundle

type DirectoryAssetBundle struct {
	NetworkID   uint64
	NetworkKey  []byte
	AssetBundle *networkv1directory.AssetBundle
}

type DirectoryEvent

type DirectoryEvent struct {
	NetworkID  uint64
	NetworkKey []byte
	Broadcast  *networkv1directory.EventBroadcast
}

type DirectorySyndicateStart

type DirectorySyndicateStart struct {
	Network *networkv1.Network
}

type DirectorySyndicateStop

type DirectorySyndicateStop struct {
	Network *networkv1.Network
}

type NetworkCertUpdate

type NetworkCertUpdate struct {
	Network *networkv1.Network
}

NetworkCertUpdate ...

type NetworkCertUpdateError

type NetworkCertUpdateError struct {
	Network *networkv1.Network
	Error   error
}

NetworkCertUpdateError ...

type NetworkPeerBindings

type NetworkPeerBindings struct {
	PeerID      uint64
	NetworkKeys [][]byte
}

NetworkPeerBindings ...

type NetworkPeerClose

type NetworkPeerClose struct {
	PeerID     uint64
	NetworkID  uint64
	NetworkKey []byte
}

NetworkPeerClose ...

type NetworkPeerCountUpdate

type NetworkPeerCountUpdate struct {
	NetworkID uint64
	PeerCount int
}

NetworkPeerCountUpdate ...

type NetworkPeerOpen

type NetworkPeerOpen struct {
	PeerID     uint64
	NetworkID  uint64
	NetworkKey []byte
}

NetworkPeerOpen ...

type NetworkStart

type NetworkStart struct {
	Network *networkv1.Network
}

NetworkStart ...

type NetworkStop

type NetworkStop struct {
	Network *networkv1.Network
}

NetworkStop ...

type Notification

type Notification struct {
	Notification *notificationv1.Notification
}

Notification ...

type NotificationDismiss

type NotificationDismiss struct {
	ID uint64
}

NotificationDismiss ...

type Observers

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

Observers ...

func NewObservers

func NewObservers(logger *zap.Logger, q queue.Queue, c Cipher) *Observers

func (*Observers) Chan

func (o *Observers) Chan() chan any

func (*Observers) EmitGlobal

func (o *Observers) EmitGlobal(v proto.Message)

EmitGlobal ...

func (*Observers) EmitLocal

func (o *Observers) EmitLocal(v any)

EmitLocal ...

func (*Observers) Events

func (o *Observers) Events() (chan any, func())

func (*Observers) Notify

func (o *Observers) Notify(ch any)

Notify ...

func (*Observers) StopNotifying

func (o *Observers) StopNotifying(ch any)

StopNotifying ...

type PeerAdd

type PeerAdd struct {
	ID     uint64
	HostID kademlia.ID
}

PeerAdd ...

type PeerRemove

type PeerRemove struct {
	ID     uint64
	HostID kademlia.ID
}

PeerRemove ...