v1

Documentation

Index

• Constants
• func BatchFromProto(req *pb.BatchObjectsRequest, ...) ([]*models.Object, map[int]int, map[int]error)
• func ExtractFilters(filterIn *pb.Filters, authorizedGetClass func(string) (*models.Class, error), ...) (filters.Clause, error)
• func NewBoolValue(v bool) *pb.Value
• func NewDateValue(v string) *pb.Value
• func NewGeoValue(v *models.GeoCoordinates) *pb.Value
• func NewIntValue(v int64) *pb.Value
• func NewNumberValue(v float64) *pb.Value
• func NewObjectValue(v *pb.Properties) *pb.Value
• func NewStringValue(v string) *pb.Value
• func NewTextValue(v string) *pb.Value
• func NewUuidValue(v string) *pb.Value
• type Mapper
  • func NewMapping(uses125 bool) *Mapper
  • func (m *Mapper) NewNestedValue(v interface{}, dt schema.DataType, parent schema.PropertyInterface, ...) (*pb.Value, error)
  • func (m *Mapper) NewNilValue() *pb.Value
  • func (m *Mapper) NewPrimitiveValue(v interface{}, dt schema.DataType) (*pb.Value, error)
• type NestedProperty
  • func (p *NestedProperty) GetName() string
  • func (p *NestedProperty) GetNestedProperties() []*models.NestedProperty
• type Parser
  • func NewParser(uses127Api bool, authorizedGetClass func(string) (*models.Class, error)) *Parser
  • func (p *Parser) Search(req *pb.SearchRequest, config *config.Config) (dto.GetParams, error)
• type Property
  • func (p *Property) GetName() string
  • func (p *Property) GetNestedProperties() []*models.NestedProperty
• type Replier
  • func NewReplier(uses123 bool, uses125 bool, uses127 bool, ...) *Replier
  • func (r *Replier) Search(res []interface{}, start time.Time, searchParams dto.GetParams, ...) (*pb.SearchReply, error)
• type Service
  • func NewService(traverser *traverser.Traverser, authComposer composer.TokenFunc, ...) *Service
  • func (s *Service) BatchDelete(ctx context.Context, req *pb.BatchDeleteRequest) (*pb.BatchDeleteReply, error)
  • func (s *Service) BatchObjects(ctx context.Context, req *pb.BatchObjectsRequest) (*pb.BatchObjectsReply, error)
  • func (s *Service) Check(ctx context.Context, request *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)
  • func (s *Service) Search(ctx context.Context, req *pb.SearchRequest) (*pb.SearchReply, error)
  • func (s *Service) TenantsGet(ctx context.Context, req *pb.TenantsGetRequest) (*pb.TenantsGetReply, error)
  • func (s *Service) Watch(request *grpc_health_v1.HealthCheckRequest, ...) error

Constants

const BEACON_START = "weaviate://localhost/"

Functions

func BatchFromProto

func BatchFromProto(req *pb.BatchObjectsRequest, authorizedGetClass func(string, string) (*models.Class, error)) ([]*models.Object, map[int]int, map[int]error)

func ExtractFilters

func ExtractFilters(filterIn *pb.Filters, authorizedGetClass func(string) (*models.Class, error), className string) (filters.Clause, error)

func NewBoolValue

func NewBoolValue(v bool) *pb.Value

NewBoolValue constructs a new boolean Value.

func NewDateValue

func NewDateValue(v string) *pb.Value

NewDateValue constructs a new string Value.

func NewGeoValue

func NewGeoValue(v *models.GeoCoordinates) *pb.Value

NewGeoValue constructs a new geo Value.

func NewIntValue

func NewIntValue(v int64) *pb.Value

NewIntValue constructs a new number Value.

func NewNumberValue

func NewNumberValue(v float64) *pb.Value

NewNumberValue constructs a new number Value.

func NewObjectValue

func NewObjectValue(v *pb.Properties) *pb.Value

NewObjectValue constructs a new struct Value.

func NewStringValue

func NewStringValue(v string) *pb.Value

NewStringValue constructs a new string Value.

func NewTextValue

func NewTextValue(v string) *pb.Value

func NewUuidValue

func NewUuidValue(v string) *pb.Value

NewUuidValue constructs a new string Value.

Types

type Mapper

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

func NewMapping

func NewMapping(uses125 bool) *Mapper

func (*Mapper) NewNestedValue

func (m *Mapper) NewNestedValue(v interface{}, dt schema.DataType, parent schema.PropertyInterface, prop search.SelectProperty) (*pb.Value, error)

func (*Mapper) NewNilValue

func (m *Mapper) NewNilValue() *pb.Value

NewNilValue constructs a new nil Value.

func (*Mapper) NewPrimitiveValue

func (m *Mapper) NewPrimitiveValue(v interface{}, dt schema.DataType) (*pb.Value, error)

type NestedProperty

type NestedProperty struct {
	*models.NestedProperty
}

func (*NestedProperty) GetName

func (p *NestedProperty) GetName() string

func (*NestedProperty) GetNestedProperties

func (p *NestedProperty) GetNestedProperties() []*models.NestedProperty

type Parser

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

func NewParser

func NewParser(uses127Api bool, authorizedGetClass func(string) (*models.Class, error)) *Parser

func (*Parser) Search

func (p *Parser) Search(req *pb.SearchRequest, config *config.Config) (dto.GetParams, error)

type Property

type Property struct {
	*models.Property
}

func (*Property) GetName

func (p *Property) GetName() string

func (*Property) GetNestedProperties

func (p *Property) GetNestedProperties() []*models.NestedProperty

type Replier

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

func NewReplier

func NewReplier(uses123 bool,
	uses125 bool,
	uses127 bool,
	generativeParams generativeQueryParamsGetter,
	logger logrus.FieldLogger,
) *Replier

func (*Replier) Search

func (r *Replier) Search(res []interface{}, start time.Time, searchParams dto.GetParams, scheme schema.Schema) (*pb.SearchReply, error)

type Service

type Service struct {
	pb.UnimplementedWeaviateServer
	// contains filtered or unexported fields
}

func NewService

func NewService(traverser *traverser.Traverser, authComposer composer.TokenFunc,
	allowAnonymousAccess bool, schemaManager *schemaManager.Manager,
	batchManager *objects.BatchManager, config *config.Config, authorization authorization.Authorizer,
	logger logrus.FieldLogger,
) *Service

func (*Service) BatchDelete

func (s *Service) BatchDelete(ctx context.Context, req *pb.BatchDeleteRequest) (*pb.BatchDeleteReply, error)

func (*Service) BatchObjects

func (s *Service) BatchObjects(ctx context.Context, req *pb.BatchObjectsRequest) (*pb.BatchObjectsReply, error)

func (*Service) Check

func (s *Service) Check(ctx context.Context, request *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)

func (*Service) Search

func (s *Service) Search(ctx context.Context, req *pb.SearchRequest) (*pb.SearchReply, error)

func (*Service) TenantsGet

func (s *Service) TenantsGet(ctx context.Context, req *pb.TenantsGetRequest) (*pb.TenantsGetReply, error)

func (*Service) Watch

func (s *Service) Watch(request *grpc_health_v1.HealthCheckRequest, server grpc_health_v1.Health_WatchServer) error