Documentation ¶
Index ¶
- type ConsumerId
- type ConsumerOffset
- type ConsumerOffsetData
- type ConsumerTotals
- type Event
- type EventData
- type EventId
- type EventName
- type MaxEventCount
- type Payload
- type Period
- type ProducerId
- type SearchTerm
- type SelectEventsQuery
- type Sequence
- type StreamCount
- type StreamName
- type StreamTotals
- type System
- type Trigger
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConsumerId ¶
ConsumerId represents the consumer id
type ConsumerOffset ¶
type ConsumerOffset struct {
Offset int `json:"offset"`
}
ConsumerOffset represents consumer offset
func (ConsumerOffset) Increment ¶
func (c ConsumerOffset) Increment() ConsumerOffset
Increment increments consumer offset
type ConsumerOffsetData ¶
type ConsumerOffsetData struct { StreamName ConsumerId ConsumerOffset float64 EventName }
ConsumerOffsetData represents consumer calculated data
type ConsumerTotals ¶
type ConsumerTotals struct { StreamName ConsumerCount float64 }
ConsumerTotals represents consumer totals
type Event ¶
type Event struct { EventId string `json:"eventId"` EventData `json:"event"` System `json:"system"` Trigger `json:"trigger"` Payload `json:"payload"` }
Event represents event
type EventData ¶
type EventData struct { Name string `json:"name" validate:"required"` Version int `json:"version"` }
EventData contains event name and version
type EventName ¶
type EventName struct {
Name string `json:"name"`
}
EventName represents event name
type MaxEventCount ¶
type MaxEventCount struct {
Count int
}
MaxEventCount represents the max events count
type SearchTerm ¶
type SearchTerm struct {
Term string `validate:"required"`
}
SearchTerm describes the search term
type SelectEventsQuery ¶
type SelectEventsQuery struct { ConsumerId StreamName EventName MaxEventCount }
SelectEventsQuery represents the search query for events
type StreamTotals ¶
type StreamTotals struct { StreamName ProducerId EventCount float64 }
StreamTotals represents stream totals
Click to show internal directories.
Click to hide internal directories.