postgres

package

v0.8.1 Latest Latest Go to latest Published: Apr 30, 2024 License: Apache-2.0 Imports: 20 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/goto/stencil

Links

Open Source Insights

Documentation ¶

Index ¶

func Migrate(connURL string) error
func NewHTTPFSMigrator(DBConnURL string) (*migrate.Migrate, error)
type DB
- func NewStore(conn string) *DB
type NamespaceRepository
- func NewNamespaceRepository(dbc *DB) *NamespaceRepository
type NotificationEventRepository
- func NewNotificationEventRepository(dbc *DB) *NotificationEventRepository
type SchemaRepository
- func NewSchemaRepository(dbc *DB) *SchemaRepository
type SearchRepository
- func NewSearchRepository(dbc *DB) *SearchRepository
- func (r *SearchRepository) Search(ctx context.Context, req *search.SearchRequest) ([]*search.SearchHits, error)
- func (r *SearchRepository) SearchLatest(ctx context.Context, req *search.SearchRequest) ([]*search.SearchHits, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Migrate ¶

func Migrate(connURL string) error

Migrate to run up migrations

func NewHTTPFSMigrator ¶

func NewHTTPFSMigrator(DBConnURL string) (*migrate.Migrate, error)

NewHTTPFSMigrator reads the migrations from httpfs and returns the migrate.Migrate

Types ¶

type DB ¶

type DB struct {
	*pgxpool.Pool
}

DB represents postgres database instance

func NewStore ¶

func NewStore(conn string) *DB

NewStore create a postgres store

type NamespaceRepository ¶

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

func NewNamespaceRepository ¶

func NewNamespaceRepository(dbc *DB) *NamespaceRepository

func (*NamespaceRepository) Create ¶

func (r *NamespaceRepository) Create(ctx context.Context, ns namespace.Namespace) (namespace.Namespace, error)

func (*NamespaceRepository) Delete ¶

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

func (*NamespaceRepository) Get ¶

func (r *NamespaceRepository) Get(ctx context.Context, id string) (namespace.Namespace, error)

func (*NamespaceRepository) List ¶

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

func (*NamespaceRepository) Update ¶

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

type NotificationEventRepository ¶ added in v0.8.0

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

func NewNotificationEventRepository ¶ added in v0.8.0

func NewNotificationEventRepository(dbc *DB) *NotificationEventRepository

func (*NotificationEventRepository) Create ¶ added in v0.8.0

func (r *NotificationEventRepository) Create(ctx context.Context, event changedetector.NotificationEvent) (changedetector.NotificationEvent, error)

func (*NotificationEventRepository) GetByNameSpaceSchemaVersionAndSuccess ¶ added in v0.8.0

func (r *NotificationEventRepository) GetByNameSpaceSchemaVersionAndSuccess(ctx context.Context, namespace string, schemaID int32, versionID string, success bool) (changedetector.NotificationEvent, error)

func (*NotificationEventRepository) Update ¶ added in v0.8.0

func (r *NotificationEventRepository) Update(ctx context.Context, id string, success bool) (changedetector.NotificationEvent, error)

type SchemaRepository ¶

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

func NewSchemaRepository ¶

func NewSchemaRepository(dbc *DB) *SchemaRepository

func (*SchemaRepository) Create ¶

func (r *SchemaRepository) Create(ctx context.Context, namespace string, schemaName string, metadata *schema.Metadata, versionID string, file *schema.SchemaFile) (int32, error)

func (*SchemaRepository) Delete ¶

func (r *SchemaRepository) Delete(ctx context.Context, ns string, sc string) error

func (*SchemaRepository) DeleteVersion ¶

func (r *SchemaRepository) DeleteVersion(ctx context.Context, ns string, sc string, version int32) error

func (*SchemaRepository) Get ¶

func (r *SchemaRepository) Get(ctx context.Context, namespaceId, schemaName string, versionNumber int32) ([]byte, error)

func (*SchemaRepository) GetLatestVersion ¶

func (r *SchemaRepository) GetLatestVersion(ctx context.Context, namespaceId, schemaName string) (int32, error)

func (*SchemaRepository) GetMetadata ¶

func (r *SchemaRepository) GetMetadata(ctx context.Context, namespace, sc string) (*schema.Metadata, error)

func (*SchemaRepository) GetSchemaID ¶ added in v0.8.0

func (r *SchemaRepository) GetSchemaID(ctx context.Context, ns string, sc string) (int32, error)

func (*SchemaRepository) List ¶

func (r *SchemaRepository) List(ctx context.Context, namespaceID string) ([]schema.Schema, error)

func (*SchemaRepository) ListVersions ¶

func (r *SchemaRepository) ListVersions(ctx context.Context, ns string, sc string) ([]int32, error)

func (*SchemaRepository) UpdateMetadata ¶

func (r *SchemaRepository) UpdateMetadata(ctx context.Context, namespace, sc string, in *schema.Metadata) (*schema.Metadata, error)

type SearchRepository ¶

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

func NewSearchRepository ¶

func NewSearchRepository(dbc *DB) *SearchRepository

func (*SearchRepository) Search ¶

func (r *SearchRepository) Search(ctx context.Context, req *search.SearchRequest) ([]*search.SearchHits, error)

func (*SearchRepository) SearchLatest ¶

func (r *SearchRepository) SearchLatest(ctx context.Context, req *search.SearchRequest) ([]*search.SearchHits, error)

Source Files ¶

View all Source files

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