adapter

Documentation

Index

• type TxManager
  • func NewTxManager[T any](rdb rdbadapter.DB) *TxManager[T]
  • func (tm *TxManager[T]) ContextWithNewTx(ctx context.Context) (context.Context, error)
  • func (tm *TxManager[T]) DoInTx(ctx context.Context, f func(ctx context.Context) (*T, error)) (res *T, err error)
• type UserGateway
  • func NewUserGateway(userIDManager *UserIDManager) *UserGateway
  • func (g *UserGateway) Create(ctx context.Context, input port.UserCreateInput) (*port.UserCreateOutput, error)
  • func (g *UserGateway) DeleteByID(ctx context.Context, input port.UserDeleteByIDInput) (*port.UserDeleteByIDOutput, error)
  • func (g *UserGateway) FindByEmail(ctx context.Context, input port.UserFindByEmailInput) (*port.UserFindByEmailOutput, error)
  • func (g *UserGateway) FindByID(ctx context.Context, input port.UserFindByIDInput) (*port.UserFindByIDOutput, error)
  • func (g *UserGateway) List(ctx context.Context, input port.UserListInput) (*port.UserListOutput, error)
• type UserIDManager
  • func NewUserIDManager(idManager id.IDManager) *UserIDManager
  • func (m *UserIDManager) Generate() (entity.UserID, error)
  • func (m *UserIDManager) Parse(v string) (entity.UserID, error)

Types

type TxManager

type TxManager[T any] struct {
	// contains filtered or unexported fields
}

func NewTxManager

func NewTxManager[T any](rdb rdbadapter.DB) *TxManager[T]

func (*TxManager[T]) ContextWithNewTx

func (tm *TxManager[T]) ContextWithNewTx(ctx context.Context) (context.Context, error)

func (*TxManager[T]) DoInTx

func (tm *TxManager[T]) DoInTx(ctx context.Context, f func(ctx context.Context) (*T, error)) (res *T, err error)

type UserGateway

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

UserGateway

func NewUserGateway

func NewUserGateway(userIDManager *UserIDManager) *UserGateway

func (*UserGateway) Create

func (g *UserGateway) Create(ctx context.Context, input port.UserCreateInput) (*port.UserCreateOutput, error)

func (*UserGateway) DeleteByID

func (g *UserGateway) DeleteByID(ctx context.Context, input port.UserDeleteByIDInput) (*port.UserDeleteByIDOutput, error)

func (*UserGateway) FindByEmail

func (g *UserGateway) FindByEmail(ctx context.Context, input port.UserFindByEmailInput) (*port.UserFindByEmailOutput, error)

func (*UserGateway) FindByID

func (g *UserGateway) FindByID(ctx context.Context, input port.UserFindByIDInput) (*port.UserFindByIDOutput, error)

func (*UserGateway) List

func (g *UserGateway) List(ctx context.Context, input port.UserListInput) (*port.UserListOutput, error)

type UserIDManager

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

UserIDManager

func NewUserIDManager

func NewUserIDManager(idManager id.IDManager) *UserIDManager

func (*UserIDManager) Generate

func (m *UserIDManager) Generate() (entity.UserID, error)

func (*UserIDManager) Parse

func (m *UserIDManager) Parse(v string) (entity.UserID, error)