events

Documentation

Index

• Constants
• type BlockchainResetEvent
  • func (e *BlockchainResetEvent) EventID() eventbus.EventID
• type DatabaseInitCompletedEvent
  • func (e *DatabaseInitCompletedEvent) EventID() eventbus.EventID
• type DatabaseInitEvent
  • func (e *DatabaseInitEvent) EventID() eventbus.EventID
• type DeleteFlipEvent
  • func (DeleteFlipEvent) EventID() eventbus.EventID
• type FastSyncCompletedEvent
  • func (FastSyncCompletedEvent) EventID() eventbus.EventID
• type IpfsGcEvent
  • func (e *IpfsGcEvent) EventID() eventbus.EventID
• type IpfsPortChangedEvent
  • func (i IpfsPortChangedEvent) EventID() eventbus.EventID
• type NewBlockEvent
  • func (e *NewBlockEvent) EventID() eventbus.EventID
• type NewFlipEvent
  • func (NewFlipEvent) EventID() eventbus.EventID
• type NewFlipKeyEvent
  • func (e *NewFlipKeyEvent) EventID() eventbus.EventID
• type NewFlipKeysPackageEvent
  • func (e *NewFlipKeysPackageEvent) EventID() eventbus.EventID
• type NewTxEvent
  • func (e *NewTxEvent) EventID() eventbus.EventID
• type PeersEvent
  • func (e *PeersEvent) EventID() eventbus.EventID

Constants

const (
	NewTxEventID                 = eventbus.EventID("transaction-new")
	AddBlockEventID              = eventbus.EventID("block-add")
	NewFlipKeyID                 = eventbus.EventID("flip-key-new")
	FastSyncCompleted            = eventbus.EventID("fast-sync-completed")
	NewFlipEventID               = eventbus.EventID("flip-new")
	NewFlipKeysPackageID         = eventbus.EventID("flip-keys-package-new")
	IpfsPortChangedEventId       = eventbus.EventID("ipfs-port-changed")
	DeleteFlipEventID            = eventbus.EventID("flip-delete")
	PeersEventID                 = eventbus.EventID("peers")
	BlockchainResetEventID       = eventbus.EventID("chain-reset")
	DatabaseInitEventId          = eventbus.EventID("db-init")
	DatabaseInitCompletedEventId = eventbus.EventID("db-init-completed")
	IpfsGcEventId                = eventbus.EventID("ipfc-gc")
)

Types

type BlockchainResetEvent

type BlockchainResetEvent struct {
	Header      *types.Header
	RevertedTxs []*types.Transaction
}

func (*BlockchainResetEvent) EventID

func (e *BlockchainResetEvent) EventID() eventbus.EventID

type DatabaseInitCompletedEvent

type DatabaseInitCompletedEvent struct {
}

func (*DatabaseInitCompletedEvent) EventID

func (e *DatabaseInitCompletedEvent) EventID() eventbus.EventID

type DatabaseInitEvent

type DatabaseInitEvent struct {
	Message string
}

func (*DatabaseInitEvent) EventID

func (e *DatabaseInitEvent) EventID() eventbus.EventID

type DeleteFlipEvent

type DeleteFlipEvent struct {
	FlipCid []byte
}

func (DeleteFlipEvent) EventID

func (DeleteFlipEvent) EventID() eventbus.EventID

type FastSyncCompletedEvent

type FastSyncCompletedEvent struct {
}

func (FastSyncCompletedEvent) EventID

func (FastSyncCompletedEvent) EventID() eventbus.EventID

type IpfsGcEvent

type IpfsGcEvent struct {
	Message   string
	Completed bool
}

func (*IpfsGcEvent) EventID

func (e *IpfsGcEvent) EventID() eventbus.EventID

type IpfsPortChangedEvent

type IpfsPortChangedEvent struct {
	Host   core.Host
	PubSub *pubsub.PubSub
}

func (IpfsPortChangedEvent) EventID

func (i IpfsPortChangedEvent) EventID() eventbus.EventID

type NewBlockEvent

type NewBlockEvent struct {
	Block *types.Block
}

func (*NewBlockEvent) EventID

func (e *NewBlockEvent) EventID() eventbus.EventID

type NewFlipEvent

type NewFlipEvent struct {
	Flip *types.Flip
}

func (NewFlipEvent) EventID

func (NewFlipEvent) EventID() eventbus.EventID

type NewFlipKeyEvent

type NewFlipKeyEvent struct {
	Key     *types.PublicFlipKey
	ShardId common.ShardId
	Own     bool
}

func (*NewFlipKeyEvent) EventID

func (e *NewFlipKeyEvent) EventID() eventbus.EventID

type NewFlipKeysPackageEvent

type NewFlipKeysPackageEvent struct {
	Key     *types.PrivateFlipKeysPackage
	ShardId common.ShardId
	Own     bool
}

func (*NewFlipKeysPackageEvent) EventID

func (e *NewFlipKeysPackageEvent) EventID() eventbus.EventID

type NewTxEvent

type NewTxEvent struct {
	Tx       *types.Transaction
	Own      bool
	ShardId  common.ShardId
	Deferred bool
}

func (*NewTxEvent) EventID

func (e *NewTxEvent) EventID() eventbus.EventID

type PeersEvent

type PeersEvent struct {
	PeersData []iface.ConnectionInfo
	Time      time.Time
}

func (*PeersEvent) EventID

func (e *PeersEvent) EventID() eventbus.EventID