Skip to content

feature: introduce "Event" handling #90

@jpmcb

Description

@jpmcb

Some orgs pump AI agent sessions into persistent Kafka topics. We should explore implementing a event.Publisher interface for Kafka.

type Event struct {
    Type      Type
    Key       string        // partition key (root hash for session grouping)
    Node      *merkle.Node
    Timestamp time.Time
}

type Publisher interface {
    Publish(ctx context.Context, event Event) error
    Close() error
}

We can then build a pkg/event/kafka/ implementor of the Publisher interface.

Metadata

Metadata

Assignees

Labels

No labels
No labels

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions