Versions in this module Expand all Collapse all v0 v0.1.8 Aug 30, 2024 Changes in this version + var EventStoreDB *sql.DB + func SetEventStoreDB(psqlInfo string) + type Dispatcher map[string]func(*map[string]any) (map[string]interface{}, error) + type Event struct + Args map[string]any + Id string + Projection any + func NewEvent(projection any, args map[string]any) Event + type EventStore struct + Dispatcher *Dispatcher + Done chan bool + Wg sync.WaitGroup + func NewEventStore(dispatcher *Dispatcher) *EventStore + func (eventstore *EventStore) Broadcast() error + func (eventstore *EventStore) GetEvent() any + func (eventstore *EventStore) Publish(event Event) + func (eventstore *EventStore) Query(projection string) map[string](map[string]any) + func (eventstore *EventStore) Run() + func (eventstore *EventStore) Setup(dbname string) + type EventStoreListener struct + OnBye chan bool + OnDescription chan string + type EventStoreNode struct + DC webrtc.DataChannel + Listner EventStoreListener + func NewEventStoreNode(dispatcher Dispatcher) *EventStoreNode + func (eventstore *EventStoreNode) HandleDataChannel(id string, event *Event) + func (eventstore *EventStoreNode) Publish(event string) + func (eventstore *EventStoreNode) Subscribe(event Event) + type Serializer struct + func NewSerializer() *Serializer + func (serializer *Serializer) Deserialize(data []byte) map[string]any + func (serializer *Serializer) Serialize(data map[string]any) []byte
Go to main page