processor

Documentation

Index

• type EventJobStatusProcessor
  • func NewEventJobStatusProcessor(queue string, jobRepository repository.JobRepository, ...) *EventJobStatusProcessor
  • func (p *EventJobStatusProcessor) Start()
• type RedisEventProcessor
  • func NewEventRedisProcessor(queue string, repository repository.EventStore, stream eventstream.EventStream, ...) *RedisEventProcessor
  • func (p *RedisEventProcessor) Start()
• type StreamEventStore
  • func NewEventStore(stream eventstream.EventStream) *StreamEventStore
  • func (n *StreamEventStore) ReportEvents(messages []*api.EventMessage) error

Types

type EventJobStatusProcessor

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

func NewEventJobStatusProcessor

func NewEventJobStatusProcessor(
	queue string,
	jobRepository repository.JobRepository,
	stream eventstream.EventStream,
	batcher eventstream.EventBatcher,
) *EventJobStatusProcessor

func (*EventJobStatusProcessor) Start

func (p *EventJobStatusProcessor) Start()

type RedisEventProcessor

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

func NewEventRedisProcessor

func NewEventRedisProcessor(
	queue string,
	repository repository.EventStore,
	stream eventstream.EventStream,
	batcher eventstream.EventBatcher,
) *RedisEventProcessor

func (*RedisEventProcessor) Start

func (p *RedisEventProcessor) Start()

type StreamEventStore

type StreamEventStore struct {
	PulsarSubmitServer *server.PulsarSubmitServer
	// contains filtered or unexported fields
}

func NewEventStore

func NewEventStore(stream eventstream.EventStream) *StreamEventStore

func (*StreamEventStore) ReportEvents

func (n *StreamEventStore) ReportEvents(messages []*api.EventMessage) error