processor

Documentation

Index

• type EventProcessor
  • func NewEventProcessor(repo repository.Repository, programID solana.PublicKey) *EventProcessor
  • func (p *EventProcessor) GetEventStats(ctx context.Context, from, to time.Time) (map[models.EventType]int64, error)
  • func (p *EventProcessor) ProcessEvent(ctx context.Context, signature string, slot uint64, blockTime time.Time, ...) error

Types

type EventProcessor

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

func NewEventProcessor

func NewEventProcessor(repo repository.Repository, programID solana.PublicKey) *EventProcessor

func (*EventProcessor) GetEventStats

func (p *EventProcessor) GetEventStats(ctx context.Context, from, to time.Time) (map[models.EventType]int64, error)

func (*EventProcessor) ProcessEvent

func (p *EventProcessor) ProcessEvent(ctx context.Context, signature string, slot uint64, blockTime time.Time, eventType models.EventType, eventData interface{}) error