persistence

Documentation

Index

• type PostgresStore
  • func NewPostgresStore(dburl string, logger *log.Logger) (*PostgresStore, error)
  • func (ps *PostgresStore) Close() error
  • func (ps *PostgresStore) InsertMessage(msg *model.Message) error

Types

type PostgresStore

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

func NewPostgresStore

func NewPostgresStore(dburl string, logger *log.Logger) (*PostgresStore, error)

func (*PostgresStore) Close

func (ps *PostgresStore) Close() error

Close closes the database connection

func (*PostgresStore) InsertMessage

func (ps *PostgresStore) InsertMessage(msg *model.Message) error