qmfsdb

Documentation

Index

• type Database
  • func Open(ctx context.Context, localDBFilename string, opts *Options) (*Database, error)
  • func (d *Database) Close() error
  • func (d *Database) DeleteFile(ctx context.Context, req *pb.DeleteFileRequest) (*pb.DeleteFileResponse, error)
  • func (d *Database) GetDatabaseMetadata(ctx context.Context, req *pb.GetDatabaseMetadataRequest) (*pb.GetDatabaseMetadataResponse, error)
  • func (d *Database) GetEntity(ctx context.Context, req *pb.GetEntityRequest) (*pb.GetEntityResponse, error)
  • func (d *Database) ListEntityFiles(ctx context.Context) ([]EntityFile, error)
  • func (d *Database) ListNamespaces(ctx context.Context, req *pb.ListNamespacesRequest) (*pb.ListNamespacesResponse, error)
  • func (d *Database) QueryEntities(req *pb.QueryEntitiesRequest, stream pb.QMetadataService_QueryEntitiesServer) error
  • func (d *Database) ReadFile(ctx context.Context, req *pb.ReadFileRequest) (*pb.ReadFileResponse, error)
  • func (d *Database) WriteFile(ctx context.Context, req *pb.WriteFileRequest) (*pb.WriteFileResponse, error)
• type EntityFile
• type MaybeString
• type Options

Types

type Database

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

func Open

func Open(ctx context.Context, localDBFilename string, opts *Options) (*Database, error)

func (*Database) Close

func (d *Database) Close() error

func (*Database) DeleteFile

func (d *Database) DeleteFile(ctx context.Context, req *pb.DeleteFileRequest) (*pb.DeleteFileResponse, error)

func (*Database) GetDatabaseMetadata

func (d *Database) GetDatabaseMetadata(ctx context.Context, req *pb.GetDatabaseMetadataRequest) (*pb.GetDatabaseMetadataResponse, error)

func (*Database) GetEntity

func (d *Database) GetEntity(ctx context.Context, req *pb.GetEntityRequest) (*pb.GetEntityResponse, error)

func (*Database) ListEntityFiles

func (d *Database) ListEntityFiles(ctx context.Context) ([]EntityFile, error)

func (*Database) ListNamespaces

func (d *Database) ListNamespaces(ctx context.Context, req *pb.ListNamespacesRequest) (*pb.ListNamespacesResponse, error)

func (*Database) QueryEntities

func (d *Database) QueryEntities(req *pb.QueryEntitiesRequest, stream pb.QMetadataService_QueryEntitiesServer) error

func (*Database) ReadFile

func (d *Database) ReadFile(ctx context.Context, req *pb.ReadFileRequest) (*pb.ReadFileResponse, error)

func (*Database) WriteFile

func (d *Database) WriteFile(ctx context.Context, req *pb.WriteFileRequest) (*pb.WriteFileResponse, error)

type EntityFile

type EntityFile struct {
	EntityID string `sql:"entity_id"`
	Filename string `sql:"filename"`
}

type MaybeString

type MaybeString struct {
	Value string
	Err   error
}

type Options

type Options struct {
	ChangeHook func()
}