eventstream

package

v0.0.4 Latest Latest Go to latest Published: Jul 16, 2026 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/chirino/memory-service

Links

Open Source Insights

Documentation ¶

Index ¶

func AppendOutboxEvents(ctx context.Context, store registrystore.MemoryStore, ...) ([]registryeventbus.Event, bool, error)
func ConversationDeletedEvents(groups []registrystore.DeletedConversationGroup) []registryeventbus.Event
func EntryEventData(entry model.Entry, groupID uuid.UUID) map[string]any
func EntryRoleFromContent(content []byte) string
func PublishEvents(ctx context.Context, store registrystore.MemoryStore, ...) error
func ReplaySupported(ctx context.Context, store registrystore.MemoryStore, ...) error
type EntryDetailLoader
type EntryEventFilter
- func EntryEventFilterFromQuery(values url.Values) EntryEventFilter
- func NewEntryEventFilter(channels, contentTypes, roles []string) EntryEventFilter
- func (f EntryEventFilter) Matches(ctx context.Context, event registryeventbus.Event, load EntryDetailLoader) (bool, error)
type EntryEventMetadata
- func EntryMetadataFromEntry(entry model.Entry) EntryEventMetadata

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func AppendOutboxEvents ¶

func AppendOutboxEvents(ctx context.Context, store registrystore.MemoryStore, events ...registryeventbus.Event) ([]registryeventbus.Event, bool, error)

AppendOutboxEvents writes normalized business events into the store-backed outbox when the datastore supports that optional capability.

func ConversationDeletedEvents ¶

func ConversationDeletedEvents(groups []registrystore.DeletedConversationGroup) []registryeventbus.Event

func EntryEventData ¶

func EntryEventData(entry model.Entry, groupID uuid.UUID) map[string]any

func EntryRoleFromContent ¶

func EntryRoleFromContent(content []byte) string

func PublishEvents ¶

func PublishEvents(ctx context.Context, store registrystore.MemoryStore, bus registryeventbus.EventBus, events ...registryeventbus.Event) error

PublishEvents publishes committed events using their routing metadata.

func ReplaySupported ¶

func ReplaySupported(ctx context.Context, store registrystore.MemoryStore, outbox registrystore.EventOutboxStore) error

ReplaySupported reports whether the configured outbox implementation supports durable replay reads.

Types ¶

type EntryDetailLoader ¶

type EntryDetailLoader func(ctx context.Context, conversationID string, entryID uuid.UUID, channel *model.Channel) (*model.Entry, error)

type EntryEventFilter ¶

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

func EntryEventFilterFromQuery ¶

func EntryEventFilterFromQuery(values url.Values) EntryEventFilter

func NewEntryEventFilter ¶

func NewEntryEventFilter(channels, contentTypes, roles []string) EntryEventFilter

func (EntryEventFilter) Matches ¶

func (f EntryEventFilter) Matches(ctx context.Context, event registryeventbus.Event, load EntryDetailLoader) (bool, error)

type EntryEventMetadata ¶

type EntryEventMetadata struct {
	ConversationID string
	EntryID        uuid.UUID
	Channel        string
	ContentType    string
	Role           string
}

func EntryMetadataFromEntry ¶

func EntryMetadataFromEntry(entry model.Entry) EntryEventMetadata

Source Files ¶

View all Source files

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