postgres

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
  • func (r *NamespaceRepository) Create(ctx context.Context, ns namespace.Namespace) (namespace.Namespace, error)
  • func (r *NamespaceRepository) Delete(ctx context.Context, id string) error
  • func (r *NamespaceRepository) Get(ctx context.Context, id string) (namespace.Namespace, error)
  • func (r *NamespaceRepository) List(ctx context.Context) ([]namespace.Namespace, error)
  • func (r *NamespaceRepository) Update(ctx context.Context, ns namespace.Namespace) (namespace.Namespace, error)
• type NotificationEventRepository
  • func NewNotificationEventRepository(dbc *DB) *NotificationEventRepository
  • func (r *NotificationEventRepository) Create(ctx context.Context, event changedetector.NotificationEvent) (changedetector.NotificationEvent, error)
  • func (r *NotificationEventRepository) GetByNameSpaceSchemaVersionAndSuccess(ctx context.Context, namespace string, schemaID int32, versionID string, ...) (changedetector.NotificationEvent, error)
  • func (r *NotificationEventRepository) Update(ctx context.Context, id string, success bool) (changedetector.NotificationEvent, error)
• type SchemaRepository
  • func NewSchemaRepository(dbc *DB) *SchemaRepository
  • func (r *SchemaRepository) Create(ctx context.Context, request *schema.UpdateSchemaRequest, versionID string, ...) (int32, error)
  • func (r *SchemaRepository) Delete(ctx context.Context, ns string, sc string) error
  • func (r *SchemaRepository) DeleteVersion(ctx context.Context, ns string, sc string, version int32) error
  • func (r *SchemaRepository) Get(ctx context.Context, namespaceId, schemaName string, versionNumber int32) ([]byte, error)
  • func (r *SchemaRepository) GetLatestVersion(ctx context.Context, namespaceId, schemaName string) (int32, error)
  • func (r *SchemaRepository) GetMetadata(ctx context.Context, namespace, sc string) (*schema.Metadata, error)
  • func (r *SchemaRepository) GetSchemaID(ctx context.Context, ns string, sc string) (int32, error)
  • func (r *SchemaRepository) GetVersionCommitSHA(ctx context.Context, schemaID int32, version int32) (string, error)
  • func (r *SchemaRepository) List(ctx context.Context, namespaceID string) ([]schema.Schema, error)
  • func (r *SchemaRepository) ListVersions(ctx context.Context, ns string, sc string) ([]int32, error)
  • func (r *SchemaRepository) UpdateMetadata(ctx context.Context, namespace, sc string, in *schema.Metadata) (*schema.Metadata, error)
• 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)

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

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

func NewNotificationEventRepository

func NewNotificationEventRepository(dbc *DB) *NotificationEventRepository

func (*NotificationEventRepository) Create

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

func (*NotificationEventRepository) GetByNameSpaceSchemaVersionAndSuccess

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

func (*NotificationEventRepository) Update

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, request *schema.UpdateSchemaRequest, versionID string, commitSHA string) (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

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

func (*SchemaRepository) GetVersionCommitSHA

func (r *SchemaRepository) GetVersionCommitSHA(ctx context.Context, schemaID int32, version int32) (string, 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)