notifying

Documentation

Index

• func NewNotifyingStore(wrapped userz.Store, provider notifier.Notifier) userz.Store
• type NotifyingStore
  • func (s *NotifyingStore) Add(ctx context.Context, user *userz.UserData) (*userz.User, error)
  • func (s *NotifyingStore) List(ctx context.Context, filter *userz.Filter, pageSize uint) (userz.Iterator[[]*userz.User], error)
  • func (s *NotifyingStore) Page(ctx context.Context, filter *userz.Filter, params *userz.PageParams) ([]*userz.User, error)
  • func (s *NotifyingStore) Remove(ctx context.Context, id string) (*userz.User, error)
  • func (s *NotifyingStore) Update(ctx context.Context, id string, user *userz.UserData) (*userz.User, error)

Functions

func NewNotifyingStore

func NewNotifyingStore(wrapped userz.Store, provider notifier.Notifier) userz.Store

Types

type NotifyingStore

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

func (*NotifyingStore) Add

func (s *NotifyingStore) Add(ctx context.Context, user *userz.UserData) (*userz.User, error)

func (*NotifyingStore) List

func (s *NotifyingStore) List(ctx context.Context, filter *userz.Filter, pageSize uint) (userz.Iterator[[]*userz.User], error)

func (*NotifyingStore) Page

func (s *NotifyingStore) Page(ctx context.Context, filter *userz.Filter, params *userz.PageParams) ([]*userz.User, error)

func (*NotifyingStore) Remove

func (s *NotifyingStore) Remove(ctx context.Context, id string) (*userz.User, error)

func (*NotifyingStore) Update

func (s *NotifyingStore) Update(ctx context.Context, id string, user *userz.UserData) (*userz.User, error)