publisher

Documentation

Index

• Variables
• type Publisher
  • func NewPublisher(log *logger.Logger) *Publisher
  • func (p *Publisher) BlockApplied(chainID isc.ChainID, block state.Block)
  • func (p *Publisher) Run(ctx context.Context)

Variables

var Event = events.NewEvent(func(handler interface{}, params ...interface{}) {
	callback := handler.(func(msgType string, parts []string))
	msgType := params[0].(string)
	parts := params[1].([]string)
	callback(msgType, parts)
})

Types

type Publisher

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

func NewPublisher

func NewPublisher(log *logger.Logger) *Publisher

func (*Publisher) BlockApplied

func (p *Publisher) BlockApplied(chainID isc.ChainID, block state.Block)

Implements the chain.ChainListener interface. NOTE: Do not block the caller!

func (*Publisher) Run

func (p *Publisher) Run(ctx context.Context)

This is called by the component to run this.