registration

Documentation

Index

• func NewUser(stream *actor.PID, rmu *actor.PID) actor.Actor
• func NewUserModelUpdate(query mysql.RegistrationUserExecutor) actor.Actor
• type User
  • func (u *User) IsStateExists(email string) bool
  • func (u *User) Receive(context actor.Context)
• type UserModelUpdate
  • func (u *UserModelUpdate) Receive(ctx actor.Context)

Functions

func NewUser

func NewUser(stream *actor.PID, rmu *actor.PID) actor.Actor

func NewUserModelUpdate

func NewUserModelUpdate(query mysql.RegistrationUserExecutor) actor.Actor

NewUserModelUpdate is constructor for UserModelUpdate

Types

type User

type User struct {
	persistence.Mixin
	// contains filtered or unexported fields
}

User is an actor to create user

func (*User) IsStateExists

func (u *User) IsStateExists(email string) bool

IsStateExists is a method to check state exists or not

func (*User) Receive

func (u *User) Receive(context actor.Context)

Receive is sent messages to be processed from the mailbox associated with the instance of the actor このアクターは永続化を行うため、persistence.Mixinを埋め込む 永続化を行い、Read Model更新アクターを起動する

type UserModelUpdate

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

UserModelUpdate is actor to update read model

func (*UserModelUpdate) Receive

func (u *UserModelUpdate) Receive(ctx actor.Context)

Receive is sent messages to be processed from the mailbox associated with the instance of the actor