Documentation
¶
Index ¶
- Constants
- func FromContext(ctx context.Context) string
- func NewContext(ctx context.Context, namespace string) context.Context
- type Error
- type EventStore
- type Repo
- func (r *Repo) Close() error
- func (r *Repo) Find(ctx context.Context, id uuid.UUID) (eh.Entity, error)
- func (r *Repo) FindAll(ctx context.Context) ([]eh.Entity, error)
- func (r *Repo) InnerRepo(ctx context.Context) eh.ReadRepo
- func (r *Repo) Remove(ctx context.Context, id uuid.UUID) error
- func (r *Repo) Save(ctx context.Context, entity eh.Entity) error
Constants ¶
const DefaultNamespace = "default"
DefaultNamespace is the namespace to use if not set in the context.
Variables ¶
This section is empty.
Functions ¶
func FromContext ¶
FromContext returns the namespace from the context, or the default namespace.
Types ¶
type Error ¶
type Error struct {
// Err is the error.
Err error
// Namespace is the namespace for the error.
Namespace string
}
Error is an error that contains info about in which name space the underlying error occurred.
type EventStore ¶
type EventStore struct {
// contains filtered or unexported fields
}
EventStore is an event store with support for namespaces passed in the context.
func NewEventStore ¶
func NewEventStore(factory func(ns string) (eh.EventStore, error)) *EventStore
NewEventStore creates a new event store which will use the provided factory function to create new event stores for the provided namespace.
Usage:
eventStore := NewEventStore(func(ns string) (eh.EventStore, error) {
s, err := mongodb.NewEventStore("mongodb://", ns)
if err != nil {
return nil, err
}
return s, nil
})
Usage shared DB client:
client, err := mongo.Connect(ctx)
...
eventStore := NewEventStore(func(ns string) (eh.EventStore, error) {
s, err := mongodb.NewEventStoreWithClient(client, ns)
if err != nil {
return nil, err
}
return s, nil
})
func (*EventStore) Close ¶ added in v0.14.8
func (s *EventStore) Close() error
Close implements the Close method of the eventhorizon.EventStore interface.
type Repo ¶
type Repo struct {
// contains filtered or unexported fields
}
Repo is a repo with support for namespaces passed in the context.
func IntoRepo ¶
IntoRepo tries to convert a eh.ReadRepo into a Repo by recursively looking at inner repos. Returns nil if none was found.
func NewRepo ¶
func NewRepo(factory func(ns string) (eh.ReadWriteRepo, error)) *Repo
NewRepo creates a new repo which will use the provided factory function to create new repos for the provided namespace.
Usage:
repo := NewRepo(func(ns string) (eh.ReadWriteRepo, error) {
r, err := mongodb.NewRepo("mongodb://", "db", "model")
if err != nil {
return nil, err
}
r.SetEntityFactory(func() eh.Entity{
return &Model{}
})
return r, nil
})
Usage shared DB client:
client, err := mongo.Connect(ctx)
...
repo := NewRepo(func(ns string) (eh.ReadWriteRepo, error) {
r, err := mongodb.NewRepoWithClient(client, "db", "model")
if err != nil {
return nil, err
}
r.SetEntityFactory(func() eh.Entity{
return &Model{}
})
return r, nil
})
func (*Repo) Close ¶ added in v0.14.8
Close implements the Close method of the eventhorizon.WriteRepo interface.
func (*Repo) FindAll ¶
FindAll implements the FindAll method of the eventhorizon.ReadRepo interface.
func (*Repo) InnerRepo ¶
InnerRepo implements the InnerRepo method of the eventhorizon.ReadRepo interface.
Source Files