publisher

Documentation

Index

• Constants
• func PublishBlockEvents(blockApplied *publisherBlockApplied, publish func(*ISCEvent), ...)
• type Events
• type ISCEvent
  • func (e *ISCEvent) String() string
• type PublishedEvent
• type Publisher
  • func New(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"

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 Events

type Events struct {
	Published *event.Event[*ISCEvent]
}

type ISCEvent

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

func (*ISCEvent) String

func (e *ISCEvent) String() string

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

type PublishedEvent

type PublishedEvent struct {
	MsgType string
	ChainID isc.ChainID
	Parts   []string
}

PublishedEvent contains the information about the published message.

type Publisher

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

func New

func New(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!