memory

Documentation

Index

• Variables
• type NameSpaceStore
  • func NewNameSpaceStore() *NameSpaceStore
  • func (ms *NameSpaceStore) Delete(id string) error
  • func (ms *NameSpaceStore) Get(id string) (*domain.Namespace, error)
  • func (ms *NameSpaceStore) GetWithBase(base string) (*domain.Namespace, error)
  • func (ms *NameSpaceStore) GetWithPrefix(prefix string) (*domain.Namespace, error)
  • func (ms *NameSpaceStore) Len() int
  • func (ms *NameSpaceStore) List() ([]*domain.Namespace, error)
  • func (ms *NameSpaceStore) Put(ns *domain.Namespace) error
• type OrganizationStore
  • func NewOrganizationStore() *OrganizationStore
  • func (ms *OrganizationStore) Delete(ctx context.Context, id domain.OrganizationID) error
  • func (ms *OrganizationStore) Filter(ctx context.Context, filter ...domain.OrganizationFilter) ([]*domain.Organization, error)
  • func (ms *OrganizationStore) Get(ctx context.Context, id domain.OrganizationID) (*domain.Organization, error)
  • func (ms *OrganizationStore) Put(ctx context.Context, org *domain.Organization) error
  • func (ms *OrganizationStore) Shutdown(ctx context.Context) error
• type TextIndex
  • func DecodeTextIndex(r io.Reader) (*TextIndex, error)
  • func NewTextIndex() *TextIndex
  • func (ti *TextIndex) AppendBytes(b []byte, docID ...int) error
  • func (ti *TextIndex) AppendString(text string, docID ...int) error
  • func (ti *TextIndex) Encode(w io.Writer) error
  • func (ti *TextIndex) Search(query *search.QueryTerm) (*search.Matches, error)
• type TextQuery
  • func NewTextQuery(q *search.QueryTerm) *TextQuery
  • func NewTextQueryFromString(query string) (*TextQuery, error)
  • func (tq *TextQuery) AppendString(text string, docID int) error
  • func (tq *TextQuery) Highlight(text string, docID int) (string, bool)
  • func (tq *TextQuery) PerformSearch() (bool, error)
  • func (tq *TextQuery) Reset()
  • func (tq *TextQuery) SetTextIndex(ti *TextIndex)

Variables

var (
	ErrSearchNoMatch = errors.New("the search query does not match the index")
)

Types

type NameSpaceStore

type NameSpaceStore struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

NameSpaceStore is the default namespace.Store for namespace.Service.

Note: mutations in this store are ephemeral.

func NewNameSpaceStore

func NewNameSpaceStore() *NameSpaceStore

NewNameSpaceStore creates an in-memory namespace.Store.

func (*NameSpaceStore) Delete

func (ms *NameSpaceStore) Delete(id string) error

Delete removes a NameSpace from the store.

When the Namespace is not found it returns an domain.ErrNameSpaceNotFound error.

func (*NameSpaceStore) Get

func (ms *NameSpaceStore) Get(id string) (*domain.Namespace, error)

func (*NameSpaceStore) GetWithBase

func (ms *NameSpaceStore) GetWithBase(base string) (*domain.Namespace, error)

GetWithBase returns a NameSpace from the store if the base URI is found.

func (*NameSpaceStore) GetWithPrefix

func (ms *NameSpaceStore) GetWithPrefix(prefix string) (*domain.Namespace, error)

GetWithPrefix returns a NameSpace from the store if the prefix is found.

func (*NameSpaceStore) Len

func (ms *NameSpaceStore) Len() int

Len returns the number of stored namespaces. Alternatives Base or Prefixes don't count towards the total.

func (*NameSpaceStore) List

func (ms *NameSpaceStore) List() ([]*domain.Namespace, error)

List returns a list of all the stored NameSpace objects. An error is only returned when the underlying datastructure is unavailable.

func (*NameSpaceStore) Put

func (ms *NameSpaceStore) Put(ns *domain.Namespace) error

Put stores the NameSpace in the Store

type OrganizationStore

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

func NewOrganizationStore

func NewOrganizationStore() *OrganizationStore

func (*OrganizationStore) Delete

func (ms *OrganizationStore) Delete(ctx context.Context, id domain.OrganizationID) error

func (*OrganizationStore) Filter

func (ms *OrganizationStore) Filter(ctx context.Context, filter ...domain.OrganizationFilter) ([]*domain.Organization, error)

Filter returns a subset of the available domains. When the filter returns no result domain.ErrOrgNotFound is returned.

func (*OrganizationStore) Get

func (ms *OrganizationStore) Get(ctx context.Context, id domain.OrganizationID) (*domain.Organization, error)

func (*OrganizationStore) Put

func (ms *OrganizationStore) Put(ctx context.Context, org *domain.Organization) error

func (*OrganizationStore) Shutdown

func (ms *OrganizationStore) Shutdown(ctx context.Context) error

type TextIndex

type TextIndex struct {
	Terms map[string]*search.Vectors

	DocCount int
	Docs     map[int]bool
	// contains filtered or unexported fields
}

TestIndex is a single document full-text index. This means that all data you append to it will have its position incremented and appends to the known state. It is not replaced. To reset the index to an empty state you have to call the reset method.

func DecodeTextIndex

func DecodeTextIndex(r io.Reader) (*TextIndex, error)

func NewTextIndex

func NewTextIndex() *TextIndex

func (*TextIndex) AppendBytes

func (ti *TextIndex) AppendBytes(b []byte, docID ...int) error

AppendBytes extract words from bytes and updates the TextIndex.

func (*TextIndex) AppendString

func (ti *TextIndex) AppendString(text string, docID ...int) error

AppendString extract words from bytes and updates the TextIndex.

func (*TextIndex) Encode

func (ti *TextIndex) Encode(w io.Writer) error

func (*TextIndex) Search

func (ti *TextIndex) Search(query *search.QueryTerm) (*search.Matches, error)

type TextQuery

type TextQuery struct {
	Hits         *search.Matches
	EmStartTag   string
	EmStyleClass string
	// contains filtered or unexported fields
}

func NewTextQuery

func NewTextQuery(q *search.QueryTerm) *TextQuery

func NewTextQueryFromString

func NewTextQueryFromString(query string) (*TextQuery, error)

func (*TextQuery) AppendString

func (tq *TextQuery) AppendString(text string, docID int) error

func (*TextQuery) Highlight

func (tq *TextQuery) Highlight(text string, docID int) (string, bool)

func (*TextQuery) PerformSearch

func (tq *TextQuery) PerformSearch() (bool, error)

func (*TextQuery) Reset

func (tq *TextQuery) Reset()

func (*TextQuery) SetTextIndex

func (tq *TextQuery) SetTextIndex(ti *TextIndex)