opensearchindex

Documentation

Index

• type Config
• type Index
  • func New(ctx context.Context, cfg Config) (*Index, error)
  • func (idx *Index) Organizations() bbl.OrganizationIndex
  • func (idx *Index) People() bbl.PersonIndex
  • func (idx *Index) Projects() bbl.ProjectIndex
  • func (idx *Index) Works() bbl.WorkIndex
• type OrganizationIdx
  • func (o *OrganizationIdx) Add(ctx context.Context, org *bbl.Organization) error
  • func (o *OrganizationIdx) Delete(ctx context.Context, id bbl.ID) error
  • func (o *OrganizationIdx) DeleteAll(ctx context.Context) error
  • func (o *OrganizationIdx) Reindex(ctx context.Context, all iter.Seq2[*bbl.Organization, error], ...) error
  • func (o *OrganizationIdx) Search(ctx context.Context, opts *bbl.SearchOpts) (*bbl.OrganizationHits, error)
• type PersonIdx
  • func (p *PersonIdx) Add(ctx context.Context, person *bbl.Person) error
  • func (p *PersonIdx) Delete(ctx context.Context, id bbl.ID) error
  • func (p *PersonIdx) DeleteAll(ctx context.Context) error
  • func (p *PersonIdx) Reindex(ctx context.Context, all iter.Seq2[*bbl.Person, error], ...) error
  • func (p *PersonIdx) Search(ctx context.Context, opts *bbl.SearchOpts) (*bbl.PersonHits, error)
• type ProjectIdx
  • func (p *ProjectIdx) Add(ctx context.Context, project *bbl.Project) error
  • func (p *ProjectIdx) Delete(ctx context.Context, id bbl.ID) error
  • func (p *ProjectIdx) DeleteAll(ctx context.Context) error
  • func (p *ProjectIdx) Reindex(ctx context.Context, all iter.Seq2[*bbl.Project, error], ...) error
  • func (p *ProjectIdx) Search(ctx context.Context, opts *bbl.SearchOpts) (*bbl.ProjectHits, error)
• type WorkIdx
  • func (w *WorkIdx) Add(ctx context.Context, work *bbl.Work) error
  • func (w *WorkIdx) Delete(ctx context.Context, id bbl.ID) error
  • func (w *WorkIdx) DeleteAll(ctx context.Context) error
  • func (w *WorkIdx) Reindex(ctx context.Context, all iter.Seq2[*bbl.Work, error], ...) error
  • func (w *WorkIdx) Search(ctx context.Context, opts *bbl.SearchOpts) (*bbl.WorkHits, error)

Types

type Config

type Config struct {
	Client *opensearchapi.Client
	OnFail func(ctx context.Context, id string, err error)
}

Config configures the OpenSearch index.

type Index

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

Index is the OpenSearch implementation of bbl.Index.

func New

func New(ctx context.Context, cfg Config) (*Index, error)

New creates a new OpenSearch Index, initializing aliases for all entity types.

func (*Index) Organizations

func (idx *Index) Organizations() bbl.OrganizationIndex

func (*Index) People

func (idx *Index) People() bbl.PersonIndex

func (*Index) Projects

func (idx *Index) Projects() bbl.ProjectIndex

func (*Index) Works

func (idx *Index) Works() bbl.WorkIndex

type OrganizationIdx

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

OrganizationIdx implements bbl.OrganizationIndex using OpenSearch.

func (*OrganizationIdx) Add

func (o *OrganizationIdx) Add(ctx context.Context, org *bbl.Organization) error

func (*OrganizationIdx) Delete

func (o *OrganizationIdx) Delete(ctx context.Context, id bbl.ID) error

func (*OrganizationIdx) DeleteAll

func (o *OrganizationIdx) DeleteAll(ctx context.Context) error

func (*OrganizationIdx) Reindex

func (o *OrganizationIdx) Reindex(ctx context.Context, all iter.Seq2[*bbl.Organization, error], changed func(since time.Time) iter.Seq2[*bbl.Organization, error]) error

func (*OrganizationIdx) Search

func (o *OrganizationIdx) Search(ctx context.Context, opts *bbl.SearchOpts) (*bbl.OrganizationHits, error)

type PersonIdx

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

PersonIdx implements bbl.PersonIndex using OpenSearch.

func (*PersonIdx) Add

func (p *PersonIdx) Add(ctx context.Context, person *bbl.Person) error

func (*PersonIdx) Delete

func (p *PersonIdx) Delete(ctx context.Context, id bbl.ID) error

func (*PersonIdx) DeleteAll

func (p *PersonIdx) DeleteAll(ctx context.Context) error

func (*PersonIdx) Reindex

func (p *PersonIdx) Reindex(ctx context.Context, all iter.Seq2[*bbl.Person, error], changed func(since time.Time) iter.Seq2[*bbl.Person, error]) error

func (*PersonIdx) Search

func (p *PersonIdx) Search(ctx context.Context, opts *bbl.SearchOpts) (*bbl.PersonHits, error)

type ProjectIdx

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

ProjectIdx implements bbl.ProjectIndex using OpenSearch.

func (*ProjectIdx) Add

func (p *ProjectIdx) Add(ctx context.Context, project *bbl.Project) error

func (*ProjectIdx) Delete

func (p *ProjectIdx) Delete(ctx context.Context, id bbl.ID) error

func (*ProjectIdx) DeleteAll

func (p *ProjectIdx) DeleteAll(ctx context.Context) error

func (*ProjectIdx) Reindex

func (p *ProjectIdx) Reindex(ctx context.Context, all iter.Seq2[*bbl.Project, error], changed func(since time.Time) iter.Seq2[*bbl.Project, error]) error

func (*ProjectIdx) Search

func (p *ProjectIdx) Search(ctx context.Context, opts *bbl.SearchOpts) (*bbl.ProjectHits, error)

type WorkIdx

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

WorkIdx implements bbl.WorkIndex using OpenSearch.

func (*WorkIdx) Add

func (w *WorkIdx) Add(ctx context.Context, work *bbl.Work) error

func (*WorkIdx) Delete

func (w *WorkIdx) Delete(ctx context.Context, id bbl.ID) error

func (*WorkIdx) DeleteAll

func (w *WorkIdx) DeleteAll(ctx context.Context) error

func (*WorkIdx) Reindex

func (w *WorkIdx) Reindex(ctx context.Context, all iter.Seq2[*bbl.Work, error], changed func(since time.Time) iter.Seq2[*bbl.Work, error]) error

func (*WorkIdx) Search

func (w *WorkIdx) Search(ctx context.Context, opts *bbl.SearchOpts) (*bbl.WorkHits, error)