eventstore

README

eventstore-lib

This project is in alpha state. It can AND will continue breaking until version 1.0.0 is released

What Is It

TBD

Supported Go Versions

Version	Supported
<1.11	❌
1.11	✅
1.12	✅
1.13	✅
1.14	✅

License

The full functionality of this library is and stays open source and free to use for everyone. Visit our website and get in touch.

See the exact licensing terms here

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Documentation

Index

• type Config
• type Eventstore
  • func Start(conf Config) Eventstore
• type Service
  • func (es *Service) Filter(ctx context.Context, events models.Events, query models.SearchQuery) (err error)
  • func (es *Service) Health(ctx context.Context) error
  • func (es *Service) PushEvents(ctx context.Context, aggregates ...models.Aggregate) (err error)

Types

type Config

type Config struct {
	Repository repository.Repository
}

type Eventstore

type Eventstore interface {
	Health(ctx context.Context) error

	PushEvents(ctx context.Context, events ...models.Aggregate) error
	Filter(ctx context.Context, events models.Events, query models.SearchQuery) error
}

func Start

func Start(conf Config) Eventstore

type Service

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

func (*Service) Filter

func (es *Service) Filter(ctx context.Context, events models.Events, query models.SearchQuery) (err error)

func (*Service) Health

func (es *Service) Health(ctx context.Context) error

func (*Service) PushEvents

func (es *Service) PushEvents(ctx context.Context, aggregates ...models.Aggregate) (err error)