providerstest

Documentation

Index

• type ManualSyncProvider
  • func NewManualSyncProvider[R configuration.Role](provider configuration.AsynchronousProvider[R]) *ManualSyncProvider[R]
  • func (a *ManualSyncProvider[R]) Delete(ctx context.Context, ref configuration.Ref) error
  • func (a *ManualSyncProvider[R]) Key() configuration.ProviderKey
  • func (a *ManualSyncProvider[R]) Role() R
  • func (a *ManualSyncProvider[R]) Store(ctx context.Context, ref configuration.Ref, value []byte) (*url.URL, error)
  • func (a *ManualSyncProvider[R]) Sync(ctx context.Context, entries []configuration.Entry, ...) error
  • func (a *ManualSyncProvider[R]) SyncAndWait() error
  • func (a *ManualSyncProvider[R]) SyncInterval() time.Duration

Types

type ManualSyncProvider

type ManualSyncProvider[R configuration.Role] struct {
	// contains filtered or unexported fields
}

ManualSyncProvider prevents normal syncs by returning a very high sync interval when syncAndWait() is called, it starts returning a 0 sync interval and then then blocks until sync completes. See why we didn't use mock clocks to schedule syncs here: https://github.com/TBD54566975/ftl/issues/2092

func NewManualSyncProvider

func NewManualSyncProvider[R configuration.Role](provider configuration.AsynchronousProvider[R]) *ManualSyncProvider[R]

func (*ManualSyncProvider[R]) Delete

func (a *ManualSyncProvider[R]) Delete(ctx context.Context, ref configuration.Ref) error

func (*ManualSyncProvider[R]) Key

func (a *ManualSyncProvider[R]) Key() configuration.ProviderKey

func (*ManualSyncProvider[R]) Role

func (a *ManualSyncProvider[R]) Role() R

func (*ManualSyncProvider[R]) Store

func (a *ManualSyncProvider[R]) Store(ctx context.Context, ref configuration.Ref, value []byte) (*url.URL, error)

func (*ManualSyncProvider[R]) Sync

func (a *ManualSyncProvider[R]) Sync(ctx context.Context, entries []configuration.Entry, values *xsync.MapOf[configuration.Ref, configuration.SyncedValue]) error

func (*ManualSyncProvider[R]) SyncAndWait

func (a *ManualSyncProvider[R]) SyncAndWait() error

func (*ManualSyncProvider[R]) SyncInterval

func (a *ManualSyncProvider[R]) SyncInterval() time.Duration