client

package

v0.5.4 Latest Latest Go to latest Published: Dec 1, 2024 License: MIT Imports: 10 Imported by: 8

Details

This section is empty.

This section is empty.

func RetrieveEventSourcingClientUrl() string

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

EventSourcingHttpClient is a client for interacting with the event sourcing HTTP API.

func NewEventSourcingHttpClient(urlStr string) (*EventSourcingHttpClient, error)

NewEventSourcingHttpClient creates a new EventSourcingHttpClient.

func (client *EventSourcingHttpClient) AddEvents(aggregateId string, events []models.ChangeTrackedEvent) error

AddEvents adds events to a given aggregate ID with validation.

func (client *EventSourcingHttpClient) AddEventsWithoutValidation(aggregateId string, events []models.ChangeTrackedEvent) error

AddEventsWithoutValidation adds events to a given aggregate ID without validation.

func (client *EventSourcingHttpClient) GetEventsOrdered(aggregateId string) (*EventsIterator, error)

GetEventsOrdered retrieves events for a given aggregate ID in order.

func (client *EventSourcingHttpClient) GetEventsSince(eventId string, limit int) ([]models.Event, error)

GetEventsSince retrieves events since a given event ID with a limit.

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

EventsIterator iterates over a list of events.

func NewEventIterator(events []models.Event) *EventsIterator

NewEventIterator creates a new EventsIterator.

func (e *EventsIterator) Current() *models.Event

Current returns the current event in the iterator.

func (e *EventsIterator) Next() (*models.Event, bool)

Next returns the next event in the iterator.

func (e *EventsIterator) Reset()

Reset resets the iterator to the beginning.