flexitype

Sep 10, 2026

Changes in this version

type Service

+ func (s *Service) Drain(ctx context.Context) error

Aug 9, 2026

retracted

Changes in this version

type APIConfig

+ MediaURLSecret string

Aug 8, 2026

Changes in this version

type Option

+ func WithOutboxMaxAttempts(n int) Option

+ func WithOutboxRetryCeiling(d time.Duration) Option

+ func WithParkedRetention(d time.Duration) Option

type Service

+ func (s *Service) BootstrapAdminWithToken(ctx context.Context, tenantName, accountName, token string) (bool, error)

Aug 7, 2026

Changes in this version

type Option

+ func WithClock(now func() time.Time) Option

Jul 28, 2026

Changes in this version

type APIConfig

+ AllowAnonymous bool

+ AuthRateLimiter *ratelimit.Limiter

+ DisableConsole bool

+ MaxImportBytes int64

+ MaxMediaBytes int64

+ TenantRateLimiter *ratelimit.Limiter

+ type DeliveryLoops struct

+ Pruner bool

+ Relay bool

+ Worker bool

+ func AllDeliveryLoops() DeliveryLoops

type Option

+ func WithDeadLetterRetention(d time.Duration) Option

+ func WithFailClosedACL() Option

+ func WithGraphQLFederation() Option

+ func WithTimeZone(loc *time.Location) Option

+ func WithWebhookTimeout(d time.Duration) Option

type Service

+ func (s *Service) Context(ctx context.Context) context.Context

+ func (s *Service) NewAPIHandler(cfg APIConfig) (http.Handler, error)

+ func (s *Service) SchemaDrift(ctx context.Context) ([]int, error)

Jul 18, 2026

Changes in this version

type Option

+ func WithCleanupObserver(fn func(err error)) Option

type Service

+ func (s *Service) RecomputeComputed(ctx context.Context, tenant valueobjects.TenantID) (int, error)

Jul 12, 2026

Changes in this version

+ type APIConfig struct

+ Accounts serviceaccount.Authenticator

+ EnableProvisioning bool

+ Health *health.Service

+ Logger *logger.Logger

+ Metrics *metrics.Metrics

+ RateLimiter *ratelimit.Limiter

+ type Option func(*options)

+ func WithBackgroundErrorObserver(fn func(err error)) Option

+ func WithBlobStore(s blob.Store) Option

+ func WithDeliveryWorker(opts ...webhook.WorkerOption) Option

+ func WithDispatchObserver(fn func(ctx context.Context, err error)) Option

+ func WithEventRetention(d time.Duration) Option

+ func WithHandler(h events.Handler, opts ...events.RegisterOption) Option

+ func WithHandlerFunc(name string, fn func(ctx context.Context, env events.Envelope) error, ...) Option

+ func WithOutbox(opts ...outbox.RelayOption) Option

+ func WithPublisher(name string, pub events.Publisher, topicFn events.TopicFunc) Option

+ func WithRollbackObserver(fn func(ctx context.Context, err error)) Option

+ func WithSearchIndex() Option

+ func WithWebhook(name string, cfg events.WebhookConfig, opts ...events.RegisterOption) Option

+ func WithWebhookAllowPrivate() Option

+ func WithoutActivityLog() Option

+ func WithoutSearch() Option

+ type Service struct

+ func New(pool *sqlx.DB, opts ...Option) *Service

+ func NewInMemory(opts ...Option) *Service

+ func (s *Service) APIHandler(cfg APIConfig) http.Handler

+ func (s *Service) AdminInteractor() *admin.Interactor

+ func (s *Service) BootstrapAdmin(ctx context.Context, tenantName, accountName string) (string, error)

+ func (s *Service) Dispatcher() *events.Dispatcher

+ func (s *Service) EnsureWebhookSubscription(ctx context.Context, name, url, secret string, eventTypes ...string) error

+ func (s *Service) Factory() application.Factory

+ func (s *Service) GraphQLEngine() *gql.Engine

+ func (s *Service) Interactors(ctx context.Context) *application.Interactors

+ func (s *Service) Migrate(ctx context.Context) error

+ func (s *Service) NewAccountLookup(ttl time.Duration) serviceaccount.Authenticator

+ func (s *Service) ReindexSearch(ctx context.Context, tenant valueobjects.TenantID) (int, error)

+ func (s *Service) RunChangeSetScheduler(ctx context.Context, interval time.Duration)

+ func (s *Service) RunOutboxRelay(ctx context.Context)