hedera

Documentation

Index

• func NewHederaPublisher(cfg config.HederaConfig, logger interfaces.Logger) (interfaces.StreamProvider, error)
• type HederaPublisher
  • func (p *HederaPublisher) Close() error
  • func (p *HederaPublisher) Connect() error
  • func (p *HederaPublisher) Publish(msg message.PublishWrapper) error

Functions

func NewHederaPublisher

func NewHederaPublisher(cfg config.HederaConfig, logger interfaces.Logger) (interfaces.StreamProvider, error)

Types

type HederaPublisher

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

func (*HederaPublisher) Close

func (p *HederaPublisher) Close() error

Close notifies parties aware of Hedera topics that the stream is closing

func (*HederaPublisher) Connect

func (p *HederaPublisher) Connect() error

Connect initiates the connection to Hedera via the Hedera Client. No need for manual initiation. Instead, topics used to publish annotations will be broadcasted according to configuration

func (*HederaPublisher) Publish

func (p *HederaPublisher) Publish(msg message.PublishWrapper) error