unistack-org/micro
4
0
Fork 2
Code Issues 18 Pull Requests Actions Packages Projects Releases 331 Wiki Activity

Update events.go

Browse Source
This commit is contained in:
Asim Aslam
2020-08-22 09:20:53 +01:00
committed by GitHub
parent 6cda6ef92e
commit e80eab397a
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
events/events.go
View File

@@ -1,4 +1,4 @@
// Package events contains interfaces for managing events within distributed systems // Package events is for event streaming and storage
package events package events
import ( import (
@@ -14,13 +14,13 @@ var (
ErrEncodingMessage = errors.New("Error encoding message") ErrEncodingMessage = errors.New("Error encoding message")
) )
// Stream of events // Stream is an event streaming interface
type Stream interface { type Stream interface {
Publish(topic string, msg interface{}, opts ...PublishOption) error Publish(topic string, msg interface{}, opts ...PublishOption) error
Subscribe(topic string, opts ...SubscribeOption) (<-chan Event, error) Subscribe(topic string, opts ...SubscribeOption) (<-chan Event, error)
} }
// Store of events // Store is an event store interface
type Store interface { type Store interface {
Read(topic string, opts ...ReadOption) ([]*Event, error) Read(topic string, opts ...ReadOption) ([]*Event, error)
Write(event *Event, opts ...WriteOption) error Write(event *Event, opts ...WriteOption) error