simple

Documentation

Index

• type ChangeEmail
• type ChangeEmailReply
• type ChangeName
• type ChangeNameReply
• type CommandBus
  • func NewCommandBus(addr []string) (*CommandBus, error)
  • func (c *CommandBus) Close() error
  • func (c *CommandBus) Listen(ctx context.Context) error
  • func (c *CommandBus) ReceiveChangeEmail(cr es.CommandReceiverFunc)
  • func (c *CommandBus) ReceiveChangeName(cr es.CommandReceiverFunc)
  • func (c *CommandBus) SendChangeEmail(ctx context.Context, streamID uuid.UUID, ce ChangeEmail) (ChangeEmailReply, error)
  • func (c *CommandBus) SendChangeName(ctx context.Context, streamID uuid.UUID, ce ChangeName) (ChangeNameReply, error)

Types

type ChangeEmail

type ChangeEmail struct {
	Email string
}

type ChangeEmailReply

type ChangeEmailReply struct {
	Confirm bool
}

type ChangeName

type ChangeName struct {
	Name string
}

type ChangeNameReply

type ChangeNameReply struct {
	Hash string
}

type CommandBus

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

func NewCommandBus

func NewCommandBus(addr []string) (*CommandBus, error)

func (*CommandBus) Close

func (c *CommandBus) Close() error

func (*CommandBus) Listen

func (c *CommandBus) Listen(ctx context.Context) error

func (*CommandBus) ReceiveChangeEmail

func (c *CommandBus) ReceiveChangeEmail(cr es.CommandReceiverFunc)

func (*CommandBus) ReceiveChangeName

func (c *CommandBus) ReceiveChangeName(cr es.CommandReceiverFunc)

func (*CommandBus) SendChangeEmail

func (c *CommandBus) SendChangeEmail(ctx context.Context, streamID uuid.UUID, ce ChangeEmail) (ChangeEmailReply, error)

func (*CommandBus) SendChangeName

func (c *CommandBus) SendChangeName(ctx context.Context, streamID uuid.UUID, ce ChangeName) (ChangeNameReply, error)