publisher

Documentation

Index

• Constants
• Variables
• func PublishBlockEvents(blockApplied *publisherBlockApplied, publish func(*ISCEvent), ...)
• type ISCEvent
  • func (e *ISCEvent) String() string
• type Publisher
  • func NewPublisher(log *logger.Logger) *Publisher
  • func (p *Publisher) AccessNodesUpdated(chainID isc.ChainID, accessNodes []*cryptolib.PublicKey)
  • func (p *Publisher) BlockApplied(chainID isc.ChainID, block state.Block)
  • func (p *Publisher) Run(ctx context.Context)
  • func (p *Publisher) ServerNodesUpdated(chainID isc.ChainID, serverNodes []*cryptolib.PublicKey)

Constants

const (
	ISCEventKindNewBlock      = "new_block"
	ISCEventKindReceipt       = "receipt" // issuer will be the request sender
	ISCEventKindSmartContract = "contract"
)

const ISCEventIssuerVM = "vm"

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)
})

Functions

func PublishBlockEvents

func PublishBlockEvents(blockApplied *publisherBlockApplied, publish func(*ISCEvent), log *logger.Logger)

PublishBlockEvents extracts the events from a block, its returns a chan of ISCEvents so they can be filtered

Types

type ISCEvent

type ISCEvent struct {
	Kind      string
	Issuer    isc.AgentID // nil means issued by the VM
	RequestID isc.RequestID
	ChainID   isc.ChainID
	Content   string
}

func (*ISCEvent) String

func (e *ISCEvent) String() string

kind is not printed right now, because it is added when calling p.publish

type Publisher

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

func NewPublisher

func NewPublisher(log *logger.Logger) *Publisher

func (*Publisher) AccessNodesUpdated

func (p *Publisher) AccessNodesUpdated(chainID isc.ChainID, accessNodes []*cryptolib.PublicKey)

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

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.

func (*Publisher) ServerNodesUpdated

func (p *Publisher) ServerNodesUpdated(chainID isc.ChainID, serverNodes []*cryptolib.PublicKey)

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