bus

Documentation

Index

• type Dispatcher
  • func NewDispatcher(factory storage.ListenerFactory, blocks storage.IBlock, txs storage.ITx) (*Dispatcher, error)
  • func (d *Dispatcher) Close() error
  • func (d *Dispatcher) Observe(channels ...string) *Observer
  • func (d *Dispatcher) Start(ctx context.Context)
• type Observer
  • func NewObserver(channels ...string) *Observer
  • func (observer Observer) Blocks() <-chan *storage.Block
  • func (observer Observer) Close() error
  • func (observer Observer) Txs() <-chan *storage.Tx

Types

type Dispatcher

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

func NewDispatcher

func NewDispatcher(
	factory storage.ListenerFactory,
	blocks storage.IBlock,
	txs storage.ITx,
) (*Dispatcher, error)

func (*Dispatcher) Close

func (d *Dispatcher) Close() error

func (*Dispatcher) Observe

func (d *Dispatcher) Observe(channels ...string) *Observer

func (*Dispatcher) Start

func (d *Dispatcher) Start(ctx context.Context)

type Observer

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

func NewObserver

func NewObserver(channels ...string) *Observer

func (Observer) Blocks

func (observer Observer) Blocks() <-chan *storage.Block

func (Observer) Close

func (observer Observer) Close() error

func (Observer) Txs

func (observer Observer) Txs() <-chan *storage.Tx