cloudevents

Documentation

Index

• type 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 DatabaseConfig) error
• type DatabaseConfig

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 (*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 DatabaseConfig) error

type DatabaseConfig

type DatabaseConfig struct {
	DBHost string `ini:"dbhost,omitempty"`
	DBname string `ini:"dbname,omitempty"`
	DBuser string `ini:"dbuser,omitempty"`
	DBpass string `ini:"dbpass,omitempty"`
	DBPort int    `ini:"dbport,omitempty"`
}