From e80eab397a24600cd6fbe6467d26cd41bb57b597 Mon Sep 17 00:00:00 2001 From: Asim Aslam Date: Sat, 22 Aug 2020 09:20:53 +0100 Subject: [PATCH] Update events.go --- events/events.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/events/events.go b/events/events.go index 91f7134a..f64e264b 100644 --- a/events/events.go +++ b/events/events.go @@ -1,4 +1,4 @@ -// Package events contains interfaces for managing events within distributed systems +// Package events is for event streaming and storage package events import ( @@ -14,13 +14,13 @@ var ( ErrEncodingMessage = errors.New("Error encoding message") ) -// Stream of events +// Stream is an event streaming interface type Stream interface { Publish(topic string, msg interface{}, opts ...PublishOption) error Subscribe(topic string, opts ...SubscribeOption) (<-chan Event, error) } -// Store of events +// Store is an event store interface type Store interface { Read(topic string, opts ...ReadOption) ([]*Event, error) Write(event *Event, opts ...WriteOption) error