client

package

v0.41.0 Latest Latest Go to latest Published: Jul 15, 2025 License: MIT Imports: 12 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/fraym/freym-api

Links

Open Source Insights

Documentation ¶

Index ¶

func NewHandler(ignoreUnhandledEvents bool) *handler
type LastEventCheckFunc
type Service
- func NewService(ctx context.Context, config *config.Config, client managementpb.ServiceClient, ...) (*Service, error)
type Subscription

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewHandler ¶

func NewHandler(ignoreUnhandledEvents bool) *handler

Types ¶

type LastEventCheckFunc ¶

type LastEventCheckFunc func(ctx context.Context, lastEvent *dto.SubscriptionEvent) bool

type Service ¶

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

func NewService ¶

func NewService(
	ctx context.Context,
	config *config.Config,
	client managementpb.ServiceClient,
	logger golog.Logger,
) (*Service, error)

func (*Service) CreateStreamSnapshot ¶

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

func (*Service) GetEvent ¶

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

func (*Service) GetLastEvent ¶

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

func (*Service) GetLastEventByTypes ¶

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

func (*Service) GetLastHandledEvent ¶ added in v0.41.0

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

func (*Service) IntroduceGdprOnEventField ¶

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

func (*Service) InvalidateGdprData ¶

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

func (*Service) IsStreamEmpty ¶

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

func (*Service) IterateAllEvents ¶

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

func (*Service) IterateAllEventsAfterEvent ¶

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

func (*Service) IterateStream ¶

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

func (*Service) IterateStreamAfterEvent ¶

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

func (*Service) NewSubscription ¶

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

func (*Service) Publish ¶

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

func (*Service) RenameEventType ¶ added in v0.35.0

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

type Subscription ¶

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

func (*Subscription) Start ¶

func (s *Subscription) Start() error

func (*Subscription) Stop ¶

func (s *Subscription) Stop()

func (*Subscription) UseHandler ¶

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

func (*Subscription) UseHandlerForAllEventTypes ¶

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL