cloudevents

package

v1.1.42 Latest Latest Go to latest Published: Dec 6, 2023 License: Apache-2.0 Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type CloudEventSaver struct {
	natsservice.NatsService
	// contains filtered or unexported fields
}

CloudEventSaver listens to all cloud events and saves them in a postgresql database

func NewCloudEventSaver(postgresConfig natsservice.PostgresConfig, mysqlConfig natsservice.MysqlConfig) *CloudEventSaver

func (svc *CloudEventSaver) Logger() *logrus.Entry

func (svc *CloudEventSaver) Run(ctx context.Context, params ...interface{}) error

type CloudEventsDatabase struct {
	// contains filtered or unexported fields
}

func (d *CloudEventsDatabase) Cleanheartbeats() error

Cleanheartbeats keeps the last occurence for each heartbeat

func (d *CloudEventsDatabase) InsertEvent(topic string, e *event.Event, payload []byte, err error) error

func (d *CloudEventsDatabase) Open(dbConfig natsservice.PostgresConfig) error

type VariablesDatabase struct {
	// contains filtered or unexported fields
}

func (d *VariablesDatabase) Open(dbConfig natsservice.MysqlConfig) error