eventbuffer

Documentation

Index

• type EventBufferProcessService
  • func NewEventBufferProcessService(ebr postgresRepository.EventBufferRepository, logger logger.Logger, ...) *EventBufferProcessService
  • func (eb *EventBufferProcessService) Dispatch(ctx context.Context) error
  • func (eb *EventBufferProcessService) HandleEvent(ctx context.Context, eventBuffer postgresEntity.EventBuffer) error
  • func (eb *EventBufferProcessService) Start(ctx context.Context)
  • func (eb *EventBufferProcessService) Stop()
• type EventBufferStoreService
  • func NewEventBufferStoreService(ebr postgresRepository.EventBufferRepository, logger logger.Logger) *EventBufferStoreService
  • func (eb *EventBufferStoreService) Delete(eventBuffer *postgresEntity.EventBuffer) error
  • func (eb *EventBufferStoreService) GetById(uuid string) (*postgresEntity.EventBuffer, error)
  • func (eb *EventBufferStoreService) Park(evt eventstore.Event, tenant string, uuid string, expiryTimestamp time.Time) error
  • func (eb *EventBufferStoreService) ParkBaseEvent(ctx context.Context, evt interface{}, tenant string, expiryTimestamp time.Time) error
  • func (eb *EventBufferStoreService) ParkBaseEventWithId(ctx context.Context, evt interface{}, tenant string, expiryTimestamp time.Time, ...) error
  • func (eb *EventBufferStoreService) Update(eventBuffer *postgresEntity.EventBuffer) error

Types

type EventBufferProcessService

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

func NewEventBufferProcessService

func NewEventBufferProcessService(ebr postgresRepository.EventBufferRepository, logger logger.Logger, grpc_clients *grpc_client.Clients) *EventBufferProcessService

func (*EventBufferProcessService) Dispatch

func (eb *EventBufferProcessService) Dispatch(ctx context.Context) error

Dispatch dispatches all expired events from event_buffer table, and delete them after dispatching

func (*EventBufferProcessService) HandleEvent

func (eb *EventBufferProcessService) HandleEvent(ctx context.Context, eventBuffer postgresEntity.EventBuffer) error

func (*EventBufferProcessService) Start

func (eb *EventBufferProcessService) Start(ctx context.Context)

func (*EventBufferProcessService) Stop

func (eb *EventBufferProcessService) Stop()

Stop stops the EventBufferWatcher

type EventBufferStoreService

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

func NewEventBufferStoreService

func NewEventBufferStoreService(ebr postgresRepository.EventBufferRepository, logger logger.Logger) *EventBufferStoreService

func (*EventBufferStoreService) Delete

func (eb *EventBufferStoreService) Delete(eventBuffer *postgresEntity.EventBuffer) error

func (*EventBufferStoreService) GetById

func (eb *EventBufferStoreService) GetById(uuid string) (*postgresEntity.EventBuffer, error)

func (*EventBufferStoreService) Park

func (eb *EventBufferStoreService) Park(
	evt eventstore.Event,
	tenant string,
	uuid string,
	expiryTimestamp time.Time,
) error

Deprecated

func (*EventBufferStoreService) ParkBaseEvent

func (eb *EventBufferStoreService) ParkBaseEvent(
	ctx context.Context,
	evt interface{},
	tenant string,
	expiryTimestamp time.Time,
) error

func (*EventBufferStoreService) ParkBaseEventWithId

func (eb *EventBufferStoreService) ParkBaseEventWithId(
	ctx context.Context,
	evt interface{},
	tenant string,
	expiryTimestamp time.Time,
	id string,
) error

func (*EventBufferStoreService) Update

func (eb *EventBufferStoreService) Update(eventBuffer *postgresEntity.EventBuffer) error