postgres

Documentation

Index

• type Options
• type Service
  • func Connect(options Options) (*Service, error)
  • func (s Service) Install() error
  • func (s Service) WriteMessage(data string, streamID string) error

Types

type Options

type Options struct {
	DatabaseName           string // default peque
	DatabaseUser           string // default peque
	DatabasePassword       string // default peque
	DatabaseHost           string // default localhost
	DatabasePort           int64  // default 5432
	DatabaseConnectTimeout int64  // default 0

	DatabaseSSLMode     string
	DatabaseSSLCert     string
	DatabaseSSLKey      string
	DatabaseSSLRootCert string
}

Options ...

type Service

type Service struct {
	Options Options
	// contains filtered or unexported fields
}

Service ...

func Connect

func Connect(options Options) (*Service, error)

Connect initializes a new Service

func (Service) Install

func (s Service) Install() error

Install messageDB on postgres server

func (Service) WriteMessage

func (s Service) WriteMessage(data string, streamID string) error

WriteMessage writes a new message to a stream