publisher

Documentation

Index

• Constants
• type Config
• type EventProvider
• type EventPublisher
  • func New(cfg Config) (*EventPublisher, error)
  • func (l *EventPublisher) Start(ctx context.Context) error
  • func (l *EventPublisher) Wait() <-chan error
• type EventSigner

Constants

const LoggerTag = "EVENT_PUBLISHER"

Types

type Config

type Config struct {
	// Providers is a list of event providers.
	Providers []EventProvider

	// EventSigner is a list of Signers used to sign events.
	Signers []EventSigner

	// Transport is used to send events to the Oracle network.
	Transport transport.Service

	// Logger is a current logger interface used by the EventPublisher.
	Logger log.Logger
}

Config is the configuration for the EventPublisher.

type EventProvider

type EventProvider interface {
	Start(ctx context.Context) error
	Events() chan *messages.Event
}

EventProvider provides events to EventPublisher.

type EventPublisher

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

EventPublisher collects event messages from event providers, signs them and publishes them using the transport interface.

func New

func New(cfg Config) (*EventPublisher, error)

New returns a new instance of the EventPublisher struct.

func (*EventPublisher) Start

func (l *EventPublisher) Start(ctx context.Context) error

Start implements the supervisor.Service interface.

func (*EventPublisher) Wait

func (l *EventPublisher) Wait() <-chan error

Wait implements the supervisor.Service interface.

type EventSigner

type EventSigner interface {
	Sign(event *messages.Event) (bool, error)
}

EventSigner signs events.