Versions in this module Expand all Collapse all v1 v1.8.0 Jul 10, 2017 v1.7.0 Jun 26, 2017 Changes in this version + const LogLevel + const MetricsDumpInterval + const PublishEnabled + const TopicARN + var ErrDecodingEvent = errors.New("Error Decoding PG Event") + func CheckTopic(svc *sns.SNS, arn string) error + func DecodePGEvent(encoded string) (aggId string, version int, payload []byte, typecode string, ...) + func EncodePGEvent(aggId string, version int, payload []byte, typecode string, ...) string + func PublishEvents(publisher *EventStorePublisher) + func SetLogLevel(logLevelEnvVarName string) error + type Event2Publish struct + AggregateId string + Payload []byte + Timestamp time.Time + Typecode string + Version int + type EventStorePublisher struct + func NewEvents2Pub(db *sql.DB, topicARN string) (*EventStorePublisher, error) + func (e2p *EventStorePublisher) AggsWithEvents() ([]Event2Publish, error) + func (e2p *EventStorePublisher) GetTableLock() (bool, error) + func (e2p *EventStorePublisher) InitMetricsSink() + func (e2p *EventStorePublisher) PublishEvent(e2pub *Event2Publish) error + func (e2p *EventStorePublisher) ReleaseTableLock() error
Go to main page