event

Sep 19, 2024

Changes in this version

type Event

+ func (e *Event[BT, T]) ReadBytes(r io.Reader) (err error)

+ func (e Event[BT, T]) WriteBytes(w io.Writer) (err error)

type ReadEvent

+ func (e *ReadEvent[BT, T]) ReadBytes(r io.Reader) (err error)

+ func (e ReadEvent[BT, T]) WriteBytes(w io.Writer) (err error)

type Type

+ func (t *Type) ReadBytes(r io.Reader) (err error)

+ func (t Type) WriteBytes(w io.Writer) (err error)

Jul 16, 2024

Changes in this version

+ var ErrInvalidType = fmt.Errorf("event type is invalid")

type Metadata

+ func (m *Metadata) ReadBytes(r io.Reader) (err error)

+ func (m Metadata) WriteBytes(w *bufio.Writer) (err error)

Apr 24, 2024

Changes in this version

+ var InvalidTypeError = fmt.Errorf("event type is invalid")

+ type Builder interface

+ BuildRead func() (ev ByteReadEvent, err error)

+ BuildStore func() (ev WriteEvent[[]byte], err error)

+ WithData func(data []byte) builder

+ WithMetadata func(data Metadata) builder

+ WithType func(t Type) builder

+ func NewBuilder() Builder

+ type ByteEvent Event[[]byte]

+ type ByteReadEvent ReadEvent[[]byte]

+ type ByteWriteEvent WriteEvent[[]byte]

+ type Event struct

+ Data T

+ Metadata Metadata

+ Type Type

+ type Metadata struct

+ Created time.Time

+ DataType string

+ EventType Type

+ Extra map[string]any

+ Key string

+ Stream string

+ Version string

+ type ReadEvent struct

+ Created time.Time

+ Position uint64

+ type ReadEventWAcc struct

+ Acc func()

+ CTX context.Context

+ type Type string

+ const Created

+ const Deleted

+ const Invalid

+ const Updated

+ func AllTypes() []Type

+ func TypeFromString(s string) Type

+ type WriteEvent struct

+ func (e *WriteEvent[T]) Close(status store.WriteStatus)

+ func (e *WriteEvent[T]) Done() <-chan store.WriteStatus

+ func (e *WriteEvent[T]) Event() *Event[T]

+ func (e *WriteEvent[T]) StatusChan() chan store.WriteStatus

+ func (e *WriteEvent[T]) Store() *store.WriteEvent

+ type WriteEventReadStatus interface

+ Close func(store.WriteStatus)

+ Done func() <-chan store.WriteStatus

+ Event func() *Event[T]

+ StatusChan func() chan store.WriteStatus

+ Store func() *store.WriteEvent

+ func Map[OT, NT any](e WriteEventReadStatus[OT], f func(OT) NT) WriteEventReadStatus[NT]

+ func NewWriteEvent[T any](e Event[T]) WriteEventReadStatus[T]

+ func NewWrite[T any](t Type, data T, m Metadata) WriteEventReadStatus[T]