users

Documentation

Index

• Constants
• Variables
• func NewMockUserDao() *userDaoMock
• func NewUserGRPCHandler(service UserService, generic services.GenericService, ...) pb.UserServiceServer
• func NewUserHandler(user UserService, generic services.GenericService) *userHandler
• func PresentUser(user *User) openapi.User
• type ServiceLocator
  • func NewServiceLocator(env *environments.Env) ServiceLocator
• type User
  • func ConvertUser(user openapi.User) *User
  • func (d *User) BeforeCreate(tx *gorm.DB) error
• type UserDao
  • func NewUserDao(sessionFactory *db.SessionFactory) UserDao
• type UserIndex
• type UserList
  • func (l UserList) Index() UserIndex
• type UserPatchRequest
• type UserService
  • func NewUserService(lockFactory db.LockFactory, userDao UserDao, events services.EventService) UserService
  • func Service(s *environments.Services) UserService

Constants

const EventSource = "Users"

Variables

var (
	DisableAdvisoryLock     = false
	UseBlockingAdvisoryLock = true
)

Functions

func NewMockUserDao

func NewMockUserDao() *userDaoMock

func NewUserGRPCHandler

func NewUserGRPCHandler(service UserService, generic services.GenericService, brokerFunc func() *server.EventBroker) pb.UserServiceServer

func NewUserHandler

func NewUserHandler(user UserService, generic services.GenericService) *userHandler

func PresentUser

func PresentUser(user *User) openapi.User

Types

type ServiceLocator

type ServiceLocator func() UserService

func NewServiceLocator

func NewServiceLocator(env *environments.Env) ServiceLocator

type User

type User struct {
	api.Meta
	Username string  `json:"username"`
	Name     string  `json:"name"`
	Email    *string `json:"email"`
}

func ConvertUser

func ConvertUser(user openapi.User) *User

func (*User) BeforeCreate

func (d *User) BeforeCreate(tx *gorm.DB) error

type UserDao

type UserDao interface {
	Get(ctx context.Context, id string) (*User, error)
	Create(ctx context.Context, user *User) (*User, error)
	Replace(ctx context.Context, user *User) (*User, error)
	Delete(ctx context.Context, id string) error
	FindByIDs(ctx context.Context, ids []string) (UserList, error)
	All(ctx context.Context) (UserList, error)
}

func NewUserDao

func NewUserDao(sessionFactory *db.SessionFactory) UserDao

type UserIndex

type UserIndex map[string]*User

type UserList

type UserList []*User

func (UserList) Index

func (l UserList) Index() UserIndex

type UserPatchRequest

type UserPatchRequest struct {
	Username *string `json:"username,omitempty"`
	Name     *string `json:"name,omitempty"`
	Email    *string `json:"email,omitempty"`
}

type UserService

type UserService interface {
	Get(ctx context.Context, id string) (*User, *errors.ServiceError)
	Create(ctx context.Context, user *User) (*User, *errors.ServiceError)
	Replace(ctx context.Context, user *User) (*User, *errors.ServiceError)
	Delete(ctx context.Context, id string) *errors.ServiceError
	All(ctx context.Context) (UserList, *errors.ServiceError)

	FindByIDs(ctx context.Context, ids []string) (UserList, *errors.ServiceError)

	OnUpsert(ctx context.Context, id string) error
	OnDelete(ctx context.Context, id string) error
}

func NewUserService

func NewUserService(lockFactory db.LockFactory, userDao UserDao, events services.EventService) UserService

func Service

func Service(s *environments.Services) UserService