postgres

Documentation

Index

• type Client
  • func NewClient(ctx context.Context, config bootstrapConfig.Database, ...) (*Client, errors.EdgeX)
  • func (c Client) CloseSession()
  • func (c Client) Disconnect() error
  • func (c Client) RemoveFromStore(o interfaces.StoredObject) error
  • func (c Client) RetrieveFromStore(appServiceKey string) ([]interfaces.StoredObject, error)
  • func (c Client) Store(o interfaces.StoredObject) (string, error)
  • func (c Client) Update(o interfaces.StoredObject) error

Types

type Client

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

func NewClient

func NewClient(ctx context.Context, config bootstrapConfig.Database, credentials bootstrapConfig.Credentials, baseScriptPath, extScriptPath string, lc logger.LoggingClient) (*Client, errors.EdgeX)

NewClient returns a pointer to the Postgres client

func (Client) CloseSession

func (c Client) CloseSession()

CloseSession closes the connections to postgres

func (Client) Disconnect

func (c Client) Disconnect() error

Disconnect ends the connection.

func (Client) RemoveFromStore

func (c Client) RemoveFromStore(o interfaces.StoredObject) error

RemoveFromStore removes an object from the store table by StoredObject ID

func (Client) RetrieveFromStore

func (c Client) RetrieveFromStore(appServiceKey string) ([]interfaces.StoredObject, error)

RetrieveFromStore gets an object from the table with content column contains the appServiceKey

func (Client) Store

func (c Client) Store(o interfaces.StoredObject) (string, error)

Store persists a stored object to the store table and returns the assigned UUID

func (Client) Update

func (c Client) Update(o interfaces.StoredObject) error

Update replaces the data currently in the store table by the StoredObject ID