Versions in this module Expand all Collapse all v2 v2.1.0 Sep 15, 2022 v2.0.0 Sep 14, 2021 Changes in this version + func AggregateProjectorCreateSchema(projectionTable string, streamName goengine.StreamName, streamTable string) []string + func NewSingleStreamStrategy(converter goengine.MessagePayloadConverter) (sql.PersistenceStrategy, error) + func StreamProjectorCreateSchema(projectionTable string, streamName goengine.StreamName, streamTable string) []string + type SingleStreamManager struct + func NewSingleStreamManager(db *sql.DB, logger goengine.Logger, metrics driverSQL.Metrics) (*SingleStreamManager, error) + func (m *SingleStreamManager) NewAggregateProjector(eventStream goengine.StreamName, aggregateTypeName string, ...) (*driverSQL.AggregateProjector, error) + func (m *SingleStreamManager) NewEventStore() (*postgres.EventStore, error) + func (m *SingleStreamManager) NewStreamProjector(projectionTable string, projection goengine.Projection, ...) (*driverSQL.StreamProjector, error) + func (m *SingleStreamManager) PersistenceStrategy() driverSQL.PersistenceStrategy + func (m *SingleStreamManager) RegisterPayloads(initiators map[string]json.PayloadInitiator) error + type SingleStreamStrategy struct + func (s *SingleStreamStrategy) CreateSchema(tableName string) []string + func (s *SingleStreamStrategy) EventColumnNames() []string + func (s *SingleStreamStrategy) GenerateTableName(streamName goengine.StreamName) (string, error) + func (s *SingleStreamStrategy) InsertColumnNames() []string + func (s *SingleStreamStrategy) PrepareData(messages []goengine.Message) ([]interface{}, error) + func (s *SingleStreamStrategy) PrepareSearch(matcher metadata.Matcher) ([]byte, []interface{}) Other modules containing this package github.com/hellofresh/goengine
Go to main page