Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Connection ¶
type Connection struct {
// contains filtered or unexported fields
}
func NewConnection ¶
func NewConnection(host string, l stream.Logger) (*Connection, error)
type EventsQuery ¶
type EventsQuery struct {
Query
// contains filtered or unexported fields
}
func (EventsQuery) Limit ¶
func (e EventsQuery) Limit(n int) EventsQuery
func (EventsQuery) String ¶
func (e EventsQuery) String() string
type EventsReader ¶
type EventsReader struct {
*Connection
// contains filtered or unexported fields
}
func NewEventsReader ¶
func NewEventsReader(c *Connection, q Query) *EventsReader
func (*EventsReader) Read ¶
func (r *EventsReader) Read(e Events) (n int, err error)
type EventsStore ¶
type EventsStore struct {
*Connection
}
func NewEventsStore ¶
func NewEventsStore(host string, l Logger) (*EventsStore, error)
func (*EventsStore) ReadWriter ¶
func (r *EventsStore) ReadWriter(s Sequence) ReadWriterAt
func (*EventsStore) Reader ¶
func (r *EventsStore) Reader(q Query) Reader
func (*EventsStore) Write ¶
func (r *EventsStore) Write(e Events) (n int, err error)
type EventsWriter ¶
type EventsWriter struct {
*Connection
// contains filtered or unexported fields
}
func NewEventsWriter ¶
func NewEventsWriter(c *Connection, id ...Sequence) *EventsWriter
func (*EventsWriter) Write ¶
func (w *EventsWriter) Write(e Events) (n int, err error)
type Table ¶
type Table[E Entity] struct {
*Connection
// contains filtered or unexported fields
}
func NewTable ¶
func NewTable[E Entity](c *Connection) (*Table[E], error)
Source Files
Click to show internal directories.
Click to hide internal directories.