postgres

package

Go to main page

Versions in this module

v0

v0.5.0

Mar 30, 2023

Changes in this version

+ const DefaultMaxResultSize

+ var ErrNamespaceNotFound = errors.New("namespace not found")

type AssetModel

+ NamespaceID string

type Client

+ func (c *Client) ExecContext(ctx context.Context, query string, args ...interface{}) (result sql.Result, err error)

+ func (c *Client) GetContext(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ func (c *Client) MigrateDown(cfg Config) (ver uint, err error)

+ func (c *Client) QueryFn(ctx context.Context, f func(*sqlx.Conn) error) error

+ func (c *Client) SelectContext(ctx context.Context, dest interface{}, query string, args ...interface{}) error

type DiscussionModel

+ NamespaceID string

type LineageEdgeModel

+ NamespaceID string

type LineageRepository

+ func (repo *LineageRepository) DeleteByURN(ctx context.Context, urn string) error

+ type NamespaceModel struct

+ CreatedAt time.Time

+ DeletedAt *time.Time

+ ID uuid.UUID

+ Metadata JSONMap

+ Name string

+ State string

+ UpdatedAt time.Time

+ func BuildNamespaceModel(ns namespace.Namespace) (*NamespaceModel, error)

+ type NamespaceRepository struct

+ func NewNamespaceRepository(c *Client) *NamespaceRepository

+ func (n *NamespaceRepository) Create(ctx context.Context, ns *namespace.Namespace) (string, error)

+ func (n *NamespaceRepository) GetByID(ctx context.Context, uuid uuid.UUID) (*namespace.Namespace, error)

+ func (n *NamespaceRepository) GetByName(ctx context.Context, name string) (*namespace.Namespace, error)

+ func (n *NamespaceRepository) List(ctx context.Context) ([]*namespace.Namespace, error)

+ func (n *NamespaceRepository) Update(ctx context.Context, ns *namespace.Namespace) error

type TagModel

+ NamespaceID string

type TagTemplateFieldModel

+ NamespaceID uuid.UUID

type TagTemplateModel

+ NamespaceID uuid.UUID

type UserModel

+ NamespaceID string

v0.4.0

Mar 9, 2023

v0.3.1

Feb 22, 2023

Changes in this version

type AssetModel

+ URL string

type AssetRepository

+ func (r *AssetRepository) GetByVersionWithID(ctx context.Context, id string, version string) (asset.Asset, error)

+ func (r *AssetRepository) GetByVersionWithURN(ctx context.Context, urn string, version string) (asset.Asset, error)

v0.3.1-rc2

Jan 24, 2023

v0.3.1-rc1

Jan 17, 2023

v0.3.0

Jan 2, 2023

Changes in this version

+ type AssetProbeModel struct

+ AssetURN string

+ CreatedAt time.Time

+ ID string

+ Metadata JSONMap

+ Status string

+ StatusReason string

+ Timestamp time.Time

type AssetRepository

+ func (r *AssetRepository) AddProbe(ctx context.Context, assetURN string, probe *asset.Probe) error

+ func (r *AssetRepository) DeleteByID(ctx context.Context, id string) error

+ func (r *AssetRepository) DeleteByURN(ctx context.Context, urn string) error

+ func (r *AssetRepository) GetByURN(ctx context.Context, urn string) (asset.Asset, error)

+ func (r *AssetRepository) GetProbes(ctx context.Context, assetURN string) ([]asset.Probe, error)

+ func (r *AssetRepository) GetProbesWithFilter(ctx context.Context, flt asset.ProbesFilter) (map[string][]asset.Probe, error)

v0.2.4

Jul 12, 2022

v0.2.3

Jun 14, 2022

Changes in this version

type AssetRepository

+ func (r *AssetRepository) GetTypes(ctx context.Context, flt asset.Filter) (map[asset.Type]int, error)

v0.2.2

Jun 7, 2022

v0.2.1

May 23, 2022

Changes in this version

+ const DEFAULT_MAX_RESULT_SIZE

+ type AssetModel struct

+ Changelog types.JSONText

+ CreatedAt time.Time

+ Data JSONMap

+ Description string

+ ID string

+ Labels JSONMap

+ Name string

+ Owners types.JSONText

+ Service string

+ Type string

+ URN string

+ UpdatedAt time.Time

+ UpdatedBy UserModel

+ Version string

+ type AssetRepository struct

+ func NewAssetRepository(c *Client, userRepo *UserRepository, defaultGetMaxSize int, ...) (*AssetRepository, error)

+ func (r *AssetRepository) BuildFilterQuery(builder sq.SelectBuilder, flt asset.Filter) sq.SelectBuilder

+ func (r *AssetRepository) Delete(ctx context.Context, id string) error

+ func (r *AssetRepository) Find(ctx context.Context, assetURN string, assetType asset.Type, ...) (ast asset.Asset, err error)

+ func (r *AssetRepository) GetAll(ctx context.Context, flt asset.Filter) ([]asset.Asset, error)

+ func (r *AssetRepository) GetByID(ctx context.Context, id string) (ast asset.Asset, err error)

+ func (r *AssetRepository) GetByVersion(ctx context.Context, id string, version string) (ast asset.Asset, err error)

+ func (r *AssetRepository) GetCount(ctx context.Context, flt asset.Filter) (total int, err error)

+ func (r *AssetRepository) GetVersionHistory(ctx context.Context, flt asset.Filter, id string) (avs []asset.Asset, err error)

+ func (r *AssetRepository) Upsert(ctx context.Context, ast *asset.Asset) (string, error)

+ type Client struct

+ func NewClient(cfg Config) (*Client, error)

+ func (c *Client) Close() error

+ func (c *Client) ExecQueries(ctx context.Context, queries []string) error

+ func (c *Client) Migrate(cfg Config) (err error)

+ func (c *Client) RunWithinTx(ctx context.Context, f func(tx *sqlx.Tx) error) error

+ type Config struct

+ Host string

+ Name string

+ Password string

+ Port int

+ SSLMode string

+ User string

+ func (c *Config) ConnectionURL() *url.URL

+ type DiscussionModel struct

+ Assets pq.StringArray

+ Assignees pq.StringArray

+ Body string

+ CreatedAt time.Time

+ ID string

+ Labels pq.StringArray

+ Owner UserModel

+ State string

+ Title string

+ Type string

+ UpdatedAt time.Time

+ type DiscussionRepository struct

+ func NewDiscussionRepository(c *Client, defaultGetMaxSize int) (*DiscussionRepository, error)

+ func (r *DiscussionRepository) Create(ctx context.Context, dsc *discussion.Discussion) (string, error)

+ func (r *DiscussionRepository) CreateComment(ctx context.Context, cmt *discussion.Comment) (string, error)

+ func (r *DiscussionRepository) DeleteComment(ctx context.Context, cid string, did string) error

+ func (r *DiscussionRepository) Get(ctx context.Context, did string) (discussion.Discussion, error)

+ func (r *DiscussionRepository) GetAll(ctx context.Context, flt discussion.Filter) ([]discussion.Discussion, error)

+ func (r *DiscussionRepository) GetAllComments(ctx context.Context, did string, flt discussion.Filter) ([]discussion.Comment, error)

+ func (r *DiscussionRepository) GetComment(ctx context.Context, cid string, did string) (discussion.Comment, error)

+ func (r *DiscussionRepository) Patch(ctx context.Context, dsc *discussion.Discussion) error

+ func (r *DiscussionRepository) UpdateComment(ctx context.Context, cmt *discussion.Comment) error

+ type JSONMap map[string]interface

+ func (m *JSONMap) Scan(value interface{}) error

+ func (m *JSONMap) UnmarshalJSON(b []byte) error

+ func (m JSONMap) MarshalJSON() ([]byte, error)

+ func (m JSONMap) Value() (driver.Value, error)

+ type LineageEdgeModel struct

+ Prop JSONMap

+ Source string

+ Target string

+ type LineageGraphModel []LineageEdgeModel

+ type LineageRepository struct

+ func NewLineageRepository(client *Client) (*LineageRepository, error)

+ func (repo *LineageRepository) GetGraph(ctx context.Context, node asset.LineageNode) (asset.LineageGraph, error)

+ func (repo *LineageRepository) Upsert(ctx context.Context, node asset.LineageNode, ...) error

+ type StarClauses struct

+ Limit int

+ Offset int

+ SortDirectionKey string

+ SortKey string

+ type StarRepository struct

+ func NewStarRepository(c *Client) (*StarRepository, error)

+ func (r *StarRepository) Create(ctx context.Context, userID string, assetID string) (string, error)

+ func (r *StarRepository) Delete(ctx context.Context, userID string, assetID string) error

+ func (r *StarRepository) GetAllAssetsByUserID(ctx context.Context, flt star.Filter, userID string) ([]asset.Asset, error)

+ func (r *StarRepository) GetAssetByUserID(ctx context.Context, userID string, assetID string) (asset.Asset, error)

+ func (r *StarRepository) GetStargazers(ctx context.Context, flt star.Filter, assetID string) ([]user.User, error)

+ type TagJoinTemplateFieldModel struct

+ Field TagTemplateFieldModel

+ Template TagTemplateModel

+ type TagJoinTemplateFieldModels []TagJoinTemplateFieldModel

+ type TagJoinTemplateTagFieldModel struct

+ Field TagTemplateFieldModel

+ Tag TagModel

+ Template TagTemplateModel

+ type TagJoinTemplateTagFieldModels []TagJoinTemplateTagFieldModel

+ type TagModel struct

+ AssetID string

+ CreatedAt time.Time

+ Field TagTemplateFieldModel

+ FieldID uint

+ ID uint

+ UpdatedAt time.Time

+ Value string

+ type TagModels []TagModel

+ type TagRepository struct

+ func NewTagRepository(client *Client) (*TagRepository, error)

+ func (r *TagRepository) Create(ctx context.Context, domainTag *tag.Tag) error

+ func (r *TagRepository) Delete(ctx context.Context, domainTag tag.Tag) error

+ func (r *TagRepository) Read(ctx context.Context, filter tag.Tag) ([]tag.Tag, error)

+ func (r *TagRepository) Update(ctx context.Context, domainTag *tag.Tag) error

+ type TagTemplateFieldModel struct

+ CreatedAt time.Time

+ DataType string

+ Description string

+ DisplayName string

+ ID uint

+ Options *string

+ Required bool

+ Template TagTemplateModel

+ TemplateURN string

+ URN string

+ UpdatedAt time.Time

+ type TagTemplateFieldModels []TagTemplateFieldModel

+ type TagTemplateModel struct

+ CreatedAt time.Time

+ Description string

+ DisplayName string

+ Fields TagTemplateFieldModels

+ URN string

+ UpdatedAt time.Time

+ type TagTemplateModels []TagTemplateModel

+ type TagTemplateRepository struct

+ func NewTagTemplateRepository(c *Client) (*TagTemplateRepository, error)

+ func (r *TagTemplateRepository) Create(ctx context.Context, templateDomain *tag.Template) error

+ func (r *TagTemplateRepository) Delete(ctx context.Context, templateURN string) error

+ func (r *TagTemplateRepository) Read(ctx context.Context, templateURN string) ([]tag.Template, error)

+ func (r *TagTemplateRepository) ReadAll(ctx context.Context) ([]tag.Template, error)

+ func (r *TagTemplateRepository) Update(ctx context.Context, targetURN string, templateDomain *tag.Template) error

+ type UserModel struct

+ CreatedAt sql.NullTime

+ Email sql.NullString

+ ID sql.NullString

+ Provider sql.NullString

+ UUID sql.NullString

+ UpdatedAt sql.NullTime

+ type UserModels []UserModel

+ type UserRepository struct

+ func NewUserRepository(c *Client) (*UserRepository, error)

+ func (r *UserRepository) Create(ctx context.Context, ud *user.User) (string, error)

+ func (r *UserRepository) CreateWithTx(ctx context.Context, tx *sqlx.Tx, ud *user.User) (string, error)

+ func (r *UserRepository) GetByEmail(ctx context.Context, email string) (user.User, error)

+ func (r *UserRepository) GetByUUID(ctx context.Context, uuid string) (user.User, error)

+ func (r *UserRepository) UpsertByEmail(ctx context.Context, ud *user.User) (string, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL