publisher

Documentation

Index

• type PublishableMessage
• type Publisher
  • func GetInstance() *Publisher
  • func (p *Publisher) Close() error
  • func (p *Publisher) PublishBlockData(blockData []common.BlockData) error
  • func (p *Publisher) PublishReorg(oldData []common.BlockData, newData []common.BlockData) error

Types

type PublishableMessage

type PublishableMessage[T common.BlockModel | common.TransactionModel | common.LogModel | common.TraceModel] struct {
	Data   T      `json:"data"`
	Status string `json:"status"`
}

type Publisher

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

func GetInstance

func GetInstance() *Publisher

GetInstance returns the singleton Publisher instance

func (*Publisher) Close

func (p *Publisher) Close() error

func (*Publisher) PublishBlockData

func (p *Publisher) PublishBlockData(blockData []common.BlockData) error

func (*Publisher) PublishReorg

func (p *Publisher) PublishReorg(oldData []common.BlockData, newData []common.BlockData) error