sqlite

package
v0.2.10 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 21, 2026 License: MPL-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CatalogRepository

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

func (*CatalogRepository) GetCurrent

func (r *CatalogRepository) GetCurrent(
	ctx context.Context,
	rootID artifactstore.RootID,
) (catalog.Snapshot, error)

type Publisher

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

func (*Publisher) Publish

func (p *Publisher) Publish(
	ctx context.Context,
	publication refresh.Publication,
) (catalog.Snapshot, error)

type RecordRepository

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

func (*RecordRepository) Delete

func (r *RecordRepository) Delete(
	ctx context.Context,
	id artifactstore.RecordID,
	expectedRevision uint64,
) error

func (*RecordRepository) Get

func (*RecordRepository) ListByRoot

func (r *RecordRepository) ListByRoot(
	ctx context.Context,
	rootID artifactstore.RootID,
) ([]record.Record, error)

func (*RecordRepository) Update

func (r *RecordRepository) Update(
	ctx context.Context,
	value record.Record,
	expectedRevision uint64,
) error

type RootRepository

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

func (*RootRepository) Attach

func (r *RootRepository) Attach(
	ctx context.Context,
	value root.Attachment,
	expectedRootRevision uint64,
) (root.Root, error)

func (*RootRepository) Create

func (r *RootRepository) Create(
	ctx context.Context,
	value root.Root,
	attachments []root.Attachment,
) error

func (*RootRepository) Detach

func (r *RootRepository) Detach(
	ctx context.Context,
	rootID artifactstore.RootID,
	sourceID artifactstore.SourceID,
	expectedRootRevision uint64,
	expectedAttachmentRevision uint64,
	modifiedAt time.Time,
) (root.Root, error)

func (*RootRepository) Get

func (r *RootRepository) Get(
	ctx context.Context,
	id artifactstore.RootID,
	includeDeleted bool,
) (root.Root, error)

func (*RootRepository) GetAttachment

func (r *RootRepository) GetAttachment(
	ctx context.Context,
	rootID artifactstore.RootID,
	sourceID artifactstore.SourceID,
) (root.Attachment, error)

func (*RootRepository) List

func (r *RootRepository) List(
	ctx context.Context,
	includeDeleted bool,
) ([]root.Root, error)

func (*RootRepository) ListAttachments

func (r *RootRepository) ListAttachments(
	ctx context.Context,
	rootID artifactstore.RootID,
) ([]root.Attachment, error)

func (*RootRepository) Update

func (r *RootRepository) Update(
	ctx context.Context,
	value root.Root,
	expectedRevision uint64,
) error

func (*RootRepository) UpdateAttachment

func (r *RootRepository) UpdateAttachment(
	ctx context.Context,
	value root.Attachment,
	expectedRootRevision uint64,
	expectedAttachmentRevision uint64,
) (root.Root, error)

type SourceRepository

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

func (*SourceRepository) Create

func (r *SourceRepository) Create(
	ctx context.Context,
	value source.Source,
) error

func (*SourceRepository) Delete

func (r *SourceRepository) Delete(
	ctx context.Context,
	id artifactstore.SourceID,
	expectedRevision uint64,
) error

func (*SourceRepository) Get

func (*SourceRepository) List

func (r *SourceRepository) List(
	ctx context.Context,
) ([]source.Source, error)

func (*SourceRepository) Update

func (r *SourceRepository) Update(
	ctx context.Context,
	value source.Source,
	expectedRevision uint64,
) error

type Store

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

func Open

func Open(
	ctx context.Context,
	path string,
) (*Store, error)

func (*Store) Catalogs

func (s *Store) Catalogs() *CatalogRepository

func (*Store) Close

func (s *Store) Close() error

func (*Store) Publisher

func (s *Store) Publisher() *Publisher

func (*Store) Records

func (s *Store) Records() *RecordRepository

func (*Store) Roots

func (s *Store) Roots() *RootRepository

func (*Store) Sources

func (s *Store) Sources() *SourceRepository

Jump to

Keyboard shortcuts

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