todo

Documentation

Index

• Constants
• func AddTask(ctx context.Context, p *AddTaskParams, ...) error
• func Create(ctx context.Context, cmd *CreateParams, metadata map[string]any) (*eventsourcing.Aggregate[*Todo], error)
• type AddTaskParams
• type CreateParams
• type Todo
  • func (t *Todo) AddTask(title, description string, dueDate *time.Time, status status)
  • func (t *Todo) StorageName() string
  • func (t *Todo) Type() string
  • func (t *Todo) Zero() eventsourcing.AggregateState

Constants

const AggregateType = "todo"

const TypeCreated = AggregateType + ".created.v1"

const TypeTaskAdded = AggregateType + ".task-added.v1" // or "task.added.v1" this semantic is up to you

Functions

func AddTask

func AddTask(ctx context.Context, p *AddTaskParams, existingTodo *eventsourcing.Aggregate[*Todo], metadata map[string]any) error

func Create

func Create(ctx context.Context, cmd *CreateParams, metadata map[string]any) (*eventsourcing.Aggregate[*Todo], error)

Types

type AddTaskParams

type AddTaskParams struct {
	Title       string     `json:"name"`
	Description string     `json:"description"`
	DueDate     *time.Time `json:"due_date"`
}

type CreateParams

type CreateParams struct {
	Name string `json:"name"`
}

type Todo

type Todo struct {
	Name      string     `json:"name"`
	Tasks     []task     `json:"tasks"`
	CreatedAt *time.Time `json:"created_at"`
	UpdatedAt *time.Time `json:"updated_at"`
}

func (*Todo) AddTask

func (t *Todo) AddTask(title, description string, dueDate *time.Time, status status)

func (*Todo) StorageName

func (t *Todo) StorageName() string

StorageName returns the name of the table or collection where the events are stored. If Todo do not implement this method, the default name used will be the AggregateType. By convention in some database server like Postgres, the table name should be in plural. This is why implementing this method is made possible here to override the table name.

func (*Todo) Type

func (t *Todo) Type() string

func (*Todo) Zero

func (t *Todo) Zero() eventsourcing.AggregateState