cloudevents

Documentation

Index

• type CloudEventSaver
  • func NewCloudEventSaver(postgresConfig natsservice.PostgresConfig) *CloudEventSaver
  • func (svc *CloudEventSaver) Logger() *logrus.Entry
  • func (svc *CloudEventSaver) Run(ctx context.Context, params ...interface{}) error
• type Database
  • func (d *Database) InsertEvent(topic string, e *event.Event, payload []byte, err error) error
  • func (d *Database) Open(dbConfig natsservice.PostgresConfig) error

Types

type CloudEventSaver

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

func NewCloudEventSaver(postgresConfig natsservice.PostgresConfig) *CloudEventSaver

func (*CloudEventSaver) Logger

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

func (*CloudEventSaver) Run

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

type Database

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

func (*Database) InsertEvent

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

func (*Database) Open

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