postgres

Documentation

Index

• Constants
• func NewTodoReadModelProjector(eventStore eventstore.EventStore, pool *pgxpool.Pool) *eventstore.ReadModelProjector
• type TodoFinder
  • func NewTodoFinder(db *pgxpool.Pool) *TodoFinder
  • func (f *TodoFinder) Find(ctx context.Context, todoID string) (todo.TodoView, error)
  • func (f *TodoFinder) FindAll(ctx context.Context) ([]todo.TodoView, error)
• type TodoReadModel
  • func NewTodoReadModel(client *pg.Client) *TodoReadModel
  • func (r *TodoReadModel) Delete(ctx context.Context) error
  • func (r *TodoReadModel) Init(ctx context.Context) error
  • func (r *TodoReadModel) IsInitialized(ctx context.Context) (bool, error)
  • func (r *TodoReadModel) Persist(ctx context.Context) error
  • func (r *TodoReadModel) Reset(ctx context.Context) error
  • func (r *TodoReadModel) Stack(method string, args ...map[string]interface{})
• type TodoRepository
  • func NewTodoRepository(eventStore eventstore.EventStore) *TodoRepository
  • func (t *TodoRepository) Get(ctx context.Context, todoID uuid.UUID) (*todo.Todo, error)
  • func (t *TodoRepository) Save(ctx context.Context, todo *todo.Todo) error

Constants

const TodoStream = "todos"

const TodoTable = "app_todo"

Functions

func NewTodoReadModelProjector

func NewTodoReadModelProjector(eventStore eventstore.EventStore, pool *pgxpool.Pool) *eventstore.ReadModelProjector

Types

type TodoFinder

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

func NewTodoFinder

func NewTodoFinder(db *pgxpool.Pool) *TodoFinder

func (*TodoFinder) Find

func (f *TodoFinder) Find(ctx context.Context, todoID string) (todo.TodoView, error)

func (*TodoFinder) FindAll

func (f *TodoFinder) FindAll(ctx context.Context) ([]todo.TodoView, error)

type TodoReadModel

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

func NewTodoReadModel

func NewTodoReadModel(client *pg.Client) *TodoReadModel

func (*TodoReadModel) Delete

func (r *TodoReadModel) Delete(ctx context.Context) error

func (*TodoReadModel) Init

func (r *TodoReadModel) Init(ctx context.Context) error

func (*TodoReadModel) IsInitialized

func (r *TodoReadModel) IsInitialized(ctx context.Context) (bool, error)

func (*TodoReadModel) Persist

func (r *TodoReadModel) Persist(ctx context.Context) error

func (*TodoReadModel) Reset

func (r *TodoReadModel) Reset(ctx context.Context) error

func (*TodoReadModel) Stack

func (r *TodoReadModel) Stack(method string, args ...map[string]interface{})

type TodoRepository

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

func NewTodoRepository

func NewTodoRepository(eventStore eventstore.EventStore) *TodoRepository

func (*TodoRepository) Get

func (t *TodoRepository) Get(ctx context.Context, todoID uuid.UUID) (*todo.Todo, error)

func (*TodoRepository) Save

func (t *TodoRepository) Save(ctx context.Context, todo *todo.Todo) error