Versions in this module Expand all Collapse all v0 v0.2.0 Mar 31, 2017 Changes in this version type Metrics + func (m *Metrics) Close() v0.1.0 Mar 29, 2017 Changes in this version + type EventstoreWriter struct + LiveReader *LiveReader + func New(confCtx *config.Context) *EventstoreWriter + func (e *EventstoreWriter) AppendToStream(streamName string, contentArr []string) (*types.AppendToStreamOutput, error) + func (e *EventstoreWriter) Close() + func (e *EventstoreWriter) CreateStream(streamName string) (*types.CreateStreamOutput, error) + func (e *EventstoreWriter) GetConfigurationContext() *config.Context + func (e *EventstoreWriter) SubscribeToStream(streamName string, subscriptionId string) error + func (e *EventstoreWriter) UnsubscribeFromStream(streamName string, subscriptionId string) error + type LiveReader struct + func NewLiveReader(writer *EventstoreWriter) *LiveReader + func (l *LiveReader) ReadIntoWriter(opts *rtypes.ReadOptions, writer io.Writer) error + type Metrics struct + AppendToStreamOps prometheus.Counter + AppendedLinesExclMeta prometheus.Counter + ChunkShippedToLongTermStorage prometheus.Counter + CreateStreamOps prometheus.Counter + LiveReaderReadOps prometheus.Counter + SubscribeToStreamOps prometheus.Counter + SubscriptionActivityEventsRaised prometheus.Counter + UnsubscribeFromStreamOps prometheus.Counter + func NewMetrics() *Metrics + type SubscriptionActivityTask struct + func NewSubscriptionActivityTask(writer *EventstoreWriter) *SubscriptionActivityTask + func (t *SubscriptionActivityTask) Close() + func (t *SubscriptionActivityTask) MarkOneDirty(cursorAfter *cursor.Cursor, tx *transaction.EventstoreTransaction) error