gosignal

package module

v0.2.3 Latest Latest Go to latest Published: Apr 8, 2024 License: MIT Imports: 1 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/Howard3/gosignal

Links

Open Source Insights

README ¶

GoSignal

GitHub go.mod Go version GitHub license

GoSignal is an event-driven architecture framework designed for Go applications, focusing on simplicity and minimal dependencies. It facilitates the development of applications with a focus on event sourcing and domain-driven design.

Disclaimer

This project is in its early stages of development and is subject to significant changes. It is not recommended for production use at this time.

Documentation

For detailed documentation, refer to the Go documentation pages:

Main Queue: Core functionality for event-driven operations. Read more on pkg.go.dev
Sourcing: Manages event sourcing, aggregates, etc. Read more on pkg.go.dev
Drivers Package: Contains drivers for different data sources, with the capability to add more. This package aims to keep dependencies low. View on GitHub

Contributing

Contributions are welcome! Please refer to the contributing guidelines for more information.

License

This project is licensed under the MIT License - see the LICENSE file for details.

Documentation ¶

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Event ¶

type Event struct {
	Type        string    // Type of event
	Data        []byte    // Data of the event
	Version     uint64    // Version of the event
	Timestamp   time.Time // Timestamp of the event
	AggregateID string    // AggregateID of the event
}

Event is a struct that represents an event in the system

type Queue ¶

type Queue interface {
	Send(messageType string, message []byte) error
	Subscribe(messageType string) (id string, ch chan QueueMessage, err error)
	Unsubscribe(messageType, id string) error
}

type QueueMessage ¶

type QueueMessage interface {
	Attempts() int
	Message() []byte
	Ack() error
	Nack() error
	Retry(RetryParams) error
	Type() string // Type returns the message type, this is the same value in Send() and Subscribe()
}

type RetryParams ¶

type RetryParams struct {
	BackoffUntil time.Time
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
drivers
eventstore
queue
snapshots
sourcing

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL