event

Documentation

Index

• type AttestationHydrator
  • func NewAttestationHydrator(log logrus.FieldLogger, event *armiarma.TimedEthereumAttestation, ...) *AttestationHydrator
  • func (h *AttestationHydrator) CreateXatuEvent(ctx context.Context) (*xatu.DecoratedEvent, error)
  • func (h *AttestationHydrator) MarkAttestationAsSeen(ctx context.Context) error
  • func (h *AttestationHydrator) TimesSeen(ctx context.Context) (int, error)

Types

type AttestationHydrator

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

func NewAttestationHydrator

func NewAttestationHydrator(log logrus.FieldLogger, event *armiarma.TimedEthereumAttestation, beacon *ethereum.BeaconNode, duplicateCache *ttlcache.Cache[string, int], clientMeta *xatu.ClientMeta) *AttestationHydrator

func (*AttestationHydrator) CreateXatuEvent

func (h *AttestationHydrator) CreateXatuEvent(ctx context.Context) (*xatu.DecoratedEvent, error)

func (*AttestationHydrator) MarkAttestationAsSeen

func (h *AttestationHydrator) MarkAttestationAsSeen(ctx context.Context) error

func (*AttestationHydrator) TimesSeen

func (h *AttestationHydrator) TimesSeen(ctx context.Context) (int, error)