client

func (s *Service) CreateStreamSnapshot(
	ctx context.Context,
	tenantId string,
	topic string,
	stream string,
	lastSnapshottedEventId string,
	snapshotEvent *dto.PublishEvent,
) error

func (s *Service) GetEvent(
	ctx context.Context,
	tenantId string,
	topic string,
	eventId string,
) (*dto.SubscriptionEvent, error)

func (s *Service) GetLastEvent(ctx context.Context, tenantId string, topic string) (*dto.SubscriptionEvent, error)

func (s *Service) GetLastEventByTypes(
	ctx context.Context,
	tenantId string,
	topic string,
	types []string,
) (*dto.SubscriptionEvent, error)

func (s *Service) GetLastHandledEvent(
	ctx context.Context,
	tenantId string,
	topic string,
) (*dto.SubscriptionEvent, error)

func (s *Service) IntroduceGdprOnEventField(
	ctx context.Context,
	tenantId string,
	topic string,
	eventId string,
	fieldName string,
	defaultValue string,
) error

func (s *Service) InvalidateGdprData(ctx context.Context, tenantId string, topic string, gdprId string) error

func (s *Service) IsStreamEmpty(ctx context.Context, tenant string, topic string, stream string) (bool, error)

func (s *Service) IterateAllEvents(
	ctx context.Context,
	tenant string,
	topic string,
	types []string,
	perPage int,
	queueSize int,
	handler dto.IterateHandlerFunc,
) error

func (s *Service) IterateAllEventsAfterEvent(
	ctx context.Context,
	tenant string,
	topic string,
	types []string,
	eventId string,
	perPage int,
	queueSize int,
	handler dto.IterateHandlerFunc,
) error

func (s *Service) IterateStream(
	ctx context.Context,
	tenant string,
	topic string,
	stream string,
	deploymentId int64,
	perPage int,
	queueSize int,
	doNotUseSnapshots bool,
	handler dto.IterateHandlerFunc,
) error

func (s *Service) IterateStreamAfterEvent(
	ctx context.Context,
	tenant string,
	topic string,
	stream string,
	eventId string,
	deploymentId int64,
	perPage int,
	queueSize int,
	doNotUseSnapshots bool,
	handler dto.IterateHandlerFunc,
) error

func (s *Service) ListErroneousEvents(
	ctx context.Context,
	tenantId string,
	topic string,
	eventTypes []string,
	limit int64,
) ([]*dto.ErroneousEvent, error)

func (s *Service) NewSubscription(
	topics []string,
	ignoreUnhandledEvents bool,
	deploymentId int64,
	parallelTopicProcessing bool,
) *Subscription

func (s *Service) Publish(ctx context.Context, topic string, events []*dto.PublishEvent) error

func (s *Service) RenameEventType(ctx context.Context, topic string, oldEventType string, newEventType string) error

func (s *Service) ResendErroneousEvent(
	ctx context.Context,
	tenantId string,
	topic string,
	consumerGroup string,
	eventId string,
) error

func (s *Service) WaitForTransactionalConsistency(
	ctx context.Context,
	tenantId string,
	topic string,
	correlationId string,
	consumerGroups []string,
) error

func (s *Subscription) Start() error

func (s *Subscription) Stop()

func (s *Subscription) UseHandler(eventType string, handlerFunc dto.HandlerFunc)

func (s *Subscription) UseHandlerForAllEventTypes(handlerFunc dto.HandlerFunc)