qdrant

package
v0.0.0-...-bfbcaf2 Latest Latest
Warning

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

Go to latest
Published: Apr 25, 2024 License: MIT Imports: 21 Imported by: 6

Documentation

Overview

Package qdrant provides primitives to interact with the openapi HTTP API.

Code generated by github.com/deepmap/oapi-codegen version v1.12.4 DO NOT EDIT.

Index

Constants

View Source
const (
	PayloadTypeKeyword = "keyword"
	PayloadTypeFloat   = "float"
	PayloadTypeInt     = "integer"
	PayloadTypeGeo     = "geo"
	PayloadTypeText    = "text"
)

Create indexes

Variables

This section is empty.

Functions

func NewClearPayloadRequest

func NewClearPayloadRequest(server string, collectionName string, params *ClearPayloadParams, body ClearPayloadJSONRequestBody) (*http.Request, error)

NewClearPayloadRequest calls the generic ClearPayload builder with application/json body

func NewClearPayloadRequestWithBody

func NewClearPayloadRequestWithBody(server string, collectionName string, params *ClearPayloadParams, contentType string, body io.Reader) (*http.Request, error)

NewClearPayloadRequestWithBody generates requests for ClearPayload with any type of body

func NewClientWithResponses

func NewClientWithResponses(server string, opts ...ClientOption) (*ClientWithResponses, HttpRequestDoer, error)

NewClientWithResponses creates a new ClientWithResponses, which wraps Client with return type handling

func NewClusterStatusRequest

func NewClusterStatusRequest(server string) (*http.Request, error)

NewClusterStatusRequest generates requests for ClusterStatus

func NewCollectionClusterInfoRequest

func NewCollectionClusterInfoRequest(server string, collectionName string) (*http.Request, error)

NewCollectionClusterInfoRequest generates requests for CollectionClusterInfo

func NewCountPointsRequest

func NewCountPointsRequest(server string, collectionName string, body CountPointsJSONRequestBody) (*http.Request, error)

NewCountPointsRequest calls the generic CountPoints builder with application/json body

func NewCountPointsRequestWithBody

func NewCountPointsRequestWithBody(server string, collectionName string, contentType string, body io.Reader) (*http.Request, error)

NewCountPointsRequestWithBody generates requests for CountPoints with any type of body

func NewCreateCollectionRequest

func NewCreateCollectionRequest(server string, collectionName string, params *CreateCollectionParams, body CreateCollectionJSONRequestBody) (*http.Request, error)

NewCreateCollectionRequest calls the generic CreateCollection builder with application/json body

func NewCreateCollectionRequestWithBody

func NewCreateCollectionRequestWithBody(server string, collectionName string, params *CreateCollectionParams, contentType string, body io.Reader) (*http.Request, error)

NewCreateCollectionRequestWithBody generates requests for CreateCollection with any type of body

func NewCreateFieldIndexRequest

func NewCreateFieldIndexRequest(server string, collectionName string, params *CreateFieldIndexParams, body CreateFieldIndexJSONRequestBody) (*http.Request, error)

NewCreateFieldIndexRequest calls the generic CreateFieldIndex builder with application/json body

func NewCreateFieldIndexRequestWithBody

func NewCreateFieldIndexRequestWithBody(server string, collectionName string, params *CreateFieldIndexParams, contentType string, body io.Reader) (*http.Request, error)

NewCreateFieldIndexRequestWithBody generates requests for CreateFieldIndex with any type of body

func NewCreateFullSnapshotRequest

func NewCreateFullSnapshotRequest(server string) (*http.Request, error)

NewCreateFullSnapshotRequest generates requests for CreateFullSnapshot

func NewCreateSnapshotRequest

func NewCreateSnapshotRequest(server string, collectionName string) (*http.Request, error)

NewCreateSnapshotRequest generates requests for CreateSnapshot

func NewDeleteCollectionRequest

func NewDeleteCollectionRequest(server string, collectionName string, params *DeleteCollectionParams) (*http.Request, error)

NewDeleteCollectionRequest generates requests for DeleteCollection

func NewDeleteFieldIndexRequest

func NewDeleteFieldIndexRequest(server string, collectionName string, fieldName string, params *DeleteFieldIndexParams) (*http.Request, error)

NewDeleteFieldIndexRequest generates requests for DeleteFieldIndex

func NewDeleteFullSnapshotRequest

func NewDeleteFullSnapshotRequest(server string, snapshotName string) (*http.Request, error)

NewDeleteFullSnapshotRequest generates requests for DeleteFullSnapshot

func NewDeletePayloadRequest

func NewDeletePayloadRequest(server string, collectionName string, params *DeletePayloadParams, body DeletePayloadJSONRequestBody) (*http.Request, error)

NewDeletePayloadRequest calls the generic DeletePayload builder with application/json body

func NewDeletePayloadRequestWithBody

func NewDeletePayloadRequestWithBody(server string, collectionName string, params *DeletePayloadParams, contentType string, body io.Reader) (*http.Request, error)

NewDeletePayloadRequestWithBody generates requests for DeletePayload with any type of body

func NewDeletePointsRequest

func NewDeletePointsRequest(server string, collectionName string, params *DeletePointsParams, body DeletePointsJSONRequestBody) (*http.Request, error)

NewDeletePointsRequest calls the generic DeletePoints builder with application/json body

func NewDeletePointsRequestWithBody

func NewDeletePointsRequestWithBody(server string, collectionName string, params *DeletePointsParams, contentType string, body io.Reader) (*http.Request, error)

NewDeletePointsRequestWithBody generates requests for DeletePoints with any type of body

func NewDeleteSnapshotRequest

func NewDeleteSnapshotRequest(server string, collectionName string, snapshotName string) (*http.Request, error)

NewDeleteSnapshotRequest generates requests for DeleteSnapshot

func NewGetCollectionAliasesRequest

func NewGetCollectionAliasesRequest(server string, collectionName string) (*http.Request, error)

NewGetCollectionAliasesRequest generates requests for GetCollectionAliases

func NewGetCollectionRequest

func NewGetCollectionRequest(server string, collectionName string) (*http.Request, error)

NewGetCollectionRequest generates requests for GetCollection

func NewGetCollectionsAliasesRequest

func NewGetCollectionsAliasesRequest(server string) (*http.Request, error)

NewGetCollectionsAliasesRequest generates requests for GetCollectionsAliases

func NewGetCollectionsRequest

func NewGetCollectionsRequest(server string) (*http.Request, error)

NewGetCollectionsRequest generates requests for GetCollections

func NewGetFullSnapshotRequest

func NewGetFullSnapshotRequest(server string, snapshotName string) (*http.Request, error)

NewGetFullSnapshotRequest generates requests for GetFullSnapshot

func NewGetLocksRequest

func NewGetLocksRequest(server string) (*http.Request, error)

NewGetLocksRequest generates requests for GetLocks

func NewGetPointRequest

func NewGetPointRequest(server string, collectionName string, id ExtendedPointId, params *GetPointParams) (*http.Request, error)

NewGetPointRequest generates requests for GetPoint

func NewGetPointsRequest

func NewGetPointsRequest(server string, collectionName string, params *GetPointsParams, body GetPointsJSONRequestBody) (*http.Request, error)

NewGetPointsRequest calls the generic GetPoints builder with application/json body

func NewGetPointsRequestWithBody

func NewGetPointsRequestWithBody(server string, collectionName string, params *GetPointsParams, contentType string, body io.Reader) (*http.Request, error)

NewGetPointsRequestWithBody generates requests for GetPoints with any type of body

func NewGetSnapshotRequest

func NewGetSnapshotRequest(server string, collectionName string, snapshotName string) (*http.Request, error)

NewGetSnapshotRequest generates requests for GetSnapshot

func NewListFullSnapshotsRequest

func NewListFullSnapshotsRequest(server string) (*http.Request, error)

NewListFullSnapshotsRequest generates requests for ListFullSnapshots

func NewListSnapshotsRequest

func NewListSnapshotsRequest(server string, collectionName string) (*http.Request, error)

NewListSnapshotsRequest generates requests for ListSnapshots

func NewMetricsRequest

func NewMetricsRequest(server string, params *MetricsParams) (*http.Request, error)

NewMetricsRequest generates requests for Metrics

func NewOverwritePayloadRequest

func NewOverwritePayloadRequest(server string, collectionName string, params *OverwritePayloadParams, body OverwritePayloadJSONRequestBody) (*http.Request, error)

NewOverwritePayloadRequest calls the generic OverwritePayload builder with application/json body

func NewOverwritePayloadRequestWithBody

func NewOverwritePayloadRequestWithBody(server string, collectionName string, params *OverwritePayloadParams, contentType string, body io.Reader) (*http.Request, error)

NewOverwritePayloadRequestWithBody generates requests for OverwritePayload with any type of body

func NewPostLocksRequest

func NewPostLocksRequest(server string, body PostLocksJSONRequestBody) (*http.Request, error)

NewPostLocksRequest calls the generic PostLocks builder with application/json body

func NewPostLocksRequestWithBody

func NewPostLocksRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)

NewPostLocksRequestWithBody generates requests for PostLocks with any type of body

func NewRecommendBatchPointsRequest

func NewRecommendBatchPointsRequest(server string, collectionName string, params *RecommendBatchPointsParams, body RecommendBatchPointsJSONRequestBody) (*http.Request, error)

NewRecommendBatchPointsRequest calls the generic RecommendBatchPoints builder with application/json body

func NewRecommendBatchPointsRequestWithBody

func NewRecommendBatchPointsRequestWithBody(server string, collectionName string, params *RecommendBatchPointsParams, contentType string, body io.Reader) (*http.Request, error)

NewRecommendBatchPointsRequestWithBody generates requests for RecommendBatchPoints with any type of body

func NewRecommendPointsRequest

func NewRecommendPointsRequest(server string, collectionName string, params *RecommendPointsParams, body RecommendPointsJSONRequestBody) (*http.Request, error)

NewRecommendPointsRequest calls the generic RecommendPoints builder with application/json body

func NewRecommendPointsRequestWithBody

func NewRecommendPointsRequestWithBody(server string, collectionName string, params *RecommendPointsParams, contentType string, body io.Reader) (*http.Request, error)

NewRecommendPointsRequestWithBody generates requests for RecommendPoints with any type of body

func NewRecoverCurrentPeerRequest

func NewRecoverCurrentPeerRequest(server string) (*http.Request, error)

NewRecoverCurrentPeerRequest generates requests for RecoverCurrentPeer

func NewRecoverFromSnapshotRequest

func NewRecoverFromSnapshotRequest(server string, collectionName string, params *RecoverFromSnapshotParams, body RecoverFromSnapshotJSONRequestBody) (*http.Request, error)

NewRecoverFromSnapshotRequest calls the generic RecoverFromSnapshot builder with application/json body

func NewRecoverFromSnapshotRequestWithBody

func NewRecoverFromSnapshotRequestWithBody(server string, collectionName string, params *RecoverFromSnapshotParams, contentType string, body io.Reader) (*http.Request, error)

NewRecoverFromSnapshotRequestWithBody generates requests for RecoverFromSnapshot with any type of body

func NewRemovePeerRequest

func NewRemovePeerRequest(server string, peerId int, params *RemovePeerParams) (*http.Request, error)

NewRemovePeerRequest generates requests for RemovePeer

func NewScrollPointsRequest

func NewScrollPointsRequest(server string, collectionName string, params *ScrollPointsParams, body ScrollPointsJSONRequestBody) (*http.Request, error)

NewScrollPointsRequest calls the generic ScrollPoints builder with application/json body

func NewScrollPointsRequestWithBody

func NewScrollPointsRequestWithBody(server string, collectionName string, params *ScrollPointsParams, contentType string, body io.Reader) (*http.Request, error)

NewScrollPointsRequestWithBody generates requests for ScrollPoints with any type of body

func NewSearchBatchPointsRequest

func NewSearchBatchPointsRequest(server string, collectionName string, params *SearchBatchPointsParams, body SearchBatchPointsJSONRequestBody) (*http.Request, error)

NewSearchBatchPointsRequest calls the generic SearchBatchPoints builder with application/json body

func NewSearchBatchPointsRequestWithBody

func NewSearchBatchPointsRequestWithBody(server string, collectionName string, params *SearchBatchPointsParams, contentType string, body io.Reader) (*http.Request, error)

NewSearchBatchPointsRequestWithBody generates requests for SearchBatchPoints with any type of body

func NewSearchPointsRequest

func NewSearchPointsRequest(server string, collectionName string, params *SearchPointsParams, body SearchPointsJSONRequestBody) (*http.Request, error)

NewSearchPointsRequest calls the generic SearchPoints builder with application/json body

func NewSearchPointsRequestWithBody

func NewSearchPointsRequestWithBody(server string, collectionName string, params *SearchPointsParams, contentType string, body io.Reader) (*http.Request, error)

NewSearchPointsRequestWithBody generates requests for SearchPoints with any type of body

func NewSetPayloadRequest

func NewSetPayloadRequest(server string, collectionName string, params *SetPayloadParams, body SetPayloadJSONRequestBody) (*http.Request, error)

NewSetPayloadRequest calls the generic SetPayload builder with application/json body

func NewSetPayloadRequestWithBody

func NewSetPayloadRequestWithBody(server string, collectionName string, params *SetPayloadParams, contentType string, body io.Reader) (*http.Request, error)

NewSetPayloadRequestWithBody generates requests for SetPayload with any type of body

func NewTelemetryRequest

func NewTelemetryRequest(server string, params *TelemetryParams) (*http.Request, error)

NewTelemetryRequest generates requests for Telemetry

func NewUpdateAliasesRequest

func NewUpdateAliasesRequest(server string, params *UpdateAliasesParams, body UpdateAliasesJSONRequestBody) (*http.Request, error)

NewUpdateAliasesRequest calls the generic UpdateAliases builder with application/json body

func NewUpdateAliasesRequestWithBody

func NewUpdateAliasesRequestWithBody(server string, params *UpdateAliasesParams, contentType string, body io.Reader) (*http.Request, error)

NewUpdateAliasesRequestWithBody generates requests for UpdateAliases with any type of body

func NewUpdateCollectionClusterRequest

func NewUpdateCollectionClusterRequest(server string, collectionName string, params *UpdateCollectionClusterParams, body UpdateCollectionClusterJSONRequestBody) (*http.Request, error)

NewUpdateCollectionClusterRequest calls the generic UpdateCollectionCluster builder with application/json body

func NewUpdateCollectionClusterRequestWithBody

func NewUpdateCollectionClusterRequestWithBody(server string, collectionName string, params *UpdateCollectionClusterParams, contentType string, body io.Reader) (*http.Request, error)

NewUpdateCollectionClusterRequestWithBody generates requests for UpdateCollectionCluster with any type of body

func NewUpdateCollectionRequest

func NewUpdateCollectionRequest(server string, collectionName string, params *UpdateCollectionParams, body UpdateCollectionJSONRequestBody) (*http.Request, error)

NewUpdateCollectionRequest calls the generic UpdateCollection builder with application/json body

func NewUpdateCollectionRequestWithBody

func NewUpdateCollectionRequestWithBody(server string, collectionName string, params *UpdateCollectionParams, contentType string, body io.Reader) (*http.Request, error)

NewUpdateCollectionRequestWithBody generates requests for UpdateCollection with any type of body

func NewUpsertPointsRequest

func NewUpsertPointsRequest(server string, collectionName string, params *UpsertPointsParams, body UpsertPointsJSONRequestBody) (*http.Request, error)

NewUpsertPointsRequest calls the generic UpsertPoints builder with application/json body

func NewUpsertPointsRequestWithBody

func NewUpsertPointsRequestWithBody(server string, collectionName string, params *UpsertPointsParams, contentType string, body io.Reader) (*http.Request, error)

NewUpsertPointsRequestWithBody generates requests for UpsertPoints with any type of body

Types

type AbortTransferOperation

type AbortTransferOperation struct {
	AbortTransfer MoveShard `json:"abort_transfer"`
}

AbortTransferOperation defines model for AbortTransferOperation.

type AliasDescription

type AliasDescription struct {
	AliasName      string `json:"alias_name"`
	CollectionName string `json:"collection_name"`
}

AliasDescription defines model for AliasDescription.

type AliasOperations

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

AliasOperations Group of all the possible operations related to collection aliases

func (AliasOperations) AsCreateAliasOperation

func (t AliasOperations) AsCreateAliasOperation() (CreateAliasOperation, error)

AsCreateAliasOperation returns the union data inside the AliasOperations as a CreateAliasOperation

func (AliasOperations) AsDeleteAliasOperation

func (t AliasOperations) AsDeleteAliasOperation() (DeleteAliasOperation, error)

AsDeleteAliasOperation returns the union data inside the AliasOperations as a DeleteAliasOperation

func (AliasOperations) AsRenameAliasOperation

func (t AliasOperations) AsRenameAliasOperation() (RenameAliasOperation, error)

AsRenameAliasOperation returns the union data inside the AliasOperations as a RenameAliasOperation

func (*AliasOperations) FromCreateAliasOperation

func (t *AliasOperations) FromCreateAliasOperation(v CreateAliasOperation) error

FromCreateAliasOperation overwrites any union data inside the AliasOperations as the provided CreateAliasOperation

func (*AliasOperations) FromDeleteAliasOperation

func (t *AliasOperations) FromDeleteAliasOperation(v DeleteAliasOperation) error

FromDeleteAliasOperation overwrites any union data inside the AliasOperations as the provided DeleteAliasOperation

func (*AliasOperations) FromRenameAliasOperation

func (t *AliasOperations) FromRenameAliasOperation(v RenameAliasOperation) error

FromRenameAliasOperation overwrites any union data inside the AliasOperations as the provided RenameAliasOperation

func (AliasOperations) MarshalJSON

func (t AliasOperations) MarshalJSON() ([]byte, error)

func (*AliasOperations) MergeCreateAliasOperation

func (t *AliasOperations) MergeCreateAliasOperation(v CreateAliasOperation) error

MergeCreateAliasOperation performs a merge with any union data inside the AliasOperations, using the provided CreateAliasOperation

func (*AliasOperations) MergeDeleteAliasOperation

func (t *AliasOperations) MergeDeleteAliasOperation(v DeleteAliasOperation) error

MergeDeleteAliasOperation performs a merge with any union data inside the AliasOperations, using the provided DeleteAliasOperation

func (*AliasOperations) MergeRenameAliasOperation

func (t *AliasOperations) MergeRenameAliasOperation(v RenameAliasOperation) error

MergeRenameAliasOperation performs a merge with any union data inside the AliasOperations, using the provided RenameAliasOperation

func (*AliasOperations) UnmarshalJSON

func (t *AliasOperations) UnmarshalJSON(b []byte) error

type AnyVariants

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

AnyVariants defines model for AnyVariants.

func (AnyVariants) AsAnyVariants0

func (t AnyVariants) AsAnyVariants0() (AnyVariants0, error)

AsAnyVariants0 returns the union data inside the AnyVariants as a AnyVariants0

func (AnyVariants) AsAnyVariants1

func (t AnyVariants) AsAnyVariants1() (AnyVariants1, error)

AsAnyVariants1 returns the union data inside the AnyVariants as a AnyVariants1

func (*AnyVariants) FromAnyVariants0

func (t *AnyVariants) FromAnyVariants0(v AnyVariants0) error

FromAnyVariants0 overwrites any union data inside the AnyVariants as the provided AnyVariants0

func (*AnyVariants) FromAnyVariants1

func (t *AnyVariants) FromAnyVariants1(v AnyVariants1) error

FromAnyVariants1 overwrites any union data inside the AnyVariants as the provided AnyVariants1

func (AnyVariants) MarshalJSON

func (t AnyVariants) MarshalJSON() ([]byte, error)

func (*AnyVariants) MergeAnyVariants0

func (t *AnyVariants) MergeAnyVariants0(v AnyVariants0) error

MergeAnyVariants0 performs a merge with any union data inside the AnyVariants, using the provided AnyVariants0

func (*AnyVariants) MergeAnyVariants1

func (t *AnyVariants) MergeAnyVariants1(v AnyVariants1) error

MergeAnyVariants1 performs a merge with any union data inside the AnyVariants, using the provided AnyVariants1

func (*AnyVariants) UnmarshalJSON

func (t *AnyVariants) UnmarshalJSON(b []byte) error

type AnyVariants0

type AnyVariants0 = []string

AnyVariants0 defines model for .

type AnyVariants1

type AnyVariants1 = []int64

AnyVariants1 defines model for .

type AppBuildTelemetry

type AppBuildTelemetry struct {
	Features *AppBuildTelemetry_Features `json:"features,omitempty"`
	Name     string                      `json:"name"`
	System   *AppBuildTelemetry_System   `json:"system,omitempty"`
	Version  string                      `json:"version"`
}

AppBuildTelemetry defines model for AppBuildTelemetry.

type AppBuildTelemetryFeatures1

type AppBuildTelemetryFeatures1 = interface{}

AppBuildTelemetryFeatures1 defines model for .

type AppBuildTelemetrySystem1

type AppBuildTelemetrySystem1 = interface{}

AppBuildTelemetrySystem1 defines model for .

type AppBuildTelemetry_Features

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

AppBuildTelemetry_Features defines model for AppBuildTelemetry.Features.

func (AppBuildTelemetry_Features) AsAppBuildTelemetryFeatures1

func (t AppBuildTelemetry_Features) AsAppBuildTelemetryFeatures1() (AppBuildTelemetryFeatures1, error)

AsAppBuildTelemetryFeatures1 returns the union data inside the AppBuildTelemetry_Features as a AppBuildTelemetryFeatures1

func (AppBuildTelemetry_Features) AsAppFeaturesTelemetry

func (t AppBuildTelemetry_Features) AsAppFeaturesTelemetry() (AppFeaturesTelemetry, error)

AsAppFeaturesTelemetry returns the union data inside the AppBuildTelemetry_Features as a AppFeaturesTelemetry

func (*AppBuildTelemetry_Features) FromAppBuildTelemetryFeatures1

func (t *AppBuildTelemetry_Features) FromAppBuildTelemetryFeatures1(v AppBuildTelemetryFeatures1) error

FromAppBuildTelemetryFeatures1 overwrites any union data inside the AppBuildTelemetry_Features as the provided AppBuildTelemetryFeatures1

func (*AppBuildTelemetry_Features) FromAppFeaturesTelemetry

func (t *AppBuildTelemetry_Features) FromAppFeaturesTelemetry(v AppFeaturesTelemetry) error

FromAppFeaturesTelemetry overwrites any union data inside the AppBuildTelemetry_Features as the provided AppFeaturesTelemetry

func (AppBuildTelemetry_Features) MarshalJSON

func (t AppBuildTelemetry_Features) MarshalJSON() ([]byte, error)

func (*AppBuildTelemetry_Features) MergeAppBuildTelemetryFeatures1

func (t *AppBuildTelemetry_Features) MergeAppBuildTelemetryFeatures1(v AppBuildTelemetryFeatures1) error

MergeAppBuildTelemetryFeatures1 performs a merge with any union data inside the AppBuildTelemetry_Features, using the provided AppBuildTelemetryFeatures1

func (*AppBuildTelemetry_Features) MergeAppFeaturesTelemetry

func (t *AppBuildTelemetry_Features) MergeAppFeaturesTelemetry(v AppFeaturesTelemetry) error

MergeAppFeaturesTelemetry performs a merge with any union data inside the AppBuildTelemetry_Features, using the provided AppFeaturesTelemetry

func (*AppBuildTelemetry_Features) UnmarshalJSON

func (t *AppBuildTelemetry_Features) UnmarshalJSON(b []byte) error

type AppBuildTelemetry_System

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

AppBuildTelemetry_System defines model for AppBuildTelemetry.System.

func (AppBuildTelemetry_System) AsAppBuildTelemetrySystem1

func (t AppBuildTelemetry_System) AsAppBuildTelemetrySystem1() (AppBuildTelemetrySystem1, error)

AsAppBuildTelemetrySystem1 returns the union data inside the AppBuildTelemetry_System as a AppBuildTelemetrySystem1

func (AppBuildTelemetry_System) AsRunningEnvironmentTelemetry

func (t AppBuildTelemetry_System) AsRunningEnvironmentTelemetry() (RunningEnvironmentTelemetry, error)

AsRunningEnvironmentTelemetry returns the union data inside the AppBuildTelemetry_System as a RunningEnvironmentTelemetry

func (*AppBuildTelemetry_System) FromAppBuildTelemetrySystem1

func (t *AppBuildTelemetry_System) FromAppBuildTelemetrySystem1(v AppBuildTelemetrySystem1) error

FromAppBuildTelemetrySystem1 overwrites any union data inside the AppBuildTelemetry_System as the provided AppBuildTelemetrySystem1

func (*AppBuildTelemetry_System) FromRunningEnvironmentTelemetry

func (t *AppBuildTelemetry_System) FromRunningEnvironmentTelemetry(v RunningEnvironmentTelemetry) error

FromRunningEnvironmentTelemetry overwrites any union data inside the AppBuildTelemetry_System as the provided RunningEnvironmentTelemetry

func (AppBuildTelemetry_System) MarshalJSON

func (t AppBuildTelemetry_System) MarshalJSON() ([]byte, error)

func (*AppBuildTelemetry_System) MergeAppBuildTelemetrySystem1

func (t *AppBuildTelemetry_System) MergeAppBuildTelemetrySystem1(v AppBuildTelemetrySystem1) error

MergeAppBuildTelemetrySystem1 performs a merge with any union data inside the AppBuildTelemetry_System, using the provided AppBuildTelemetrySystem1

func (*AppBuildTelemetry_System) MergeRunningEnvironmentTelemetry

func (t *AppBuildTelemetry_System) MergeRunningEnvironmentTelemetry(v RunningEnvironmentTelemetry) error

MergeRunningEnvironmentTelemetry performs a merge with any union data inside the AppBuildTelemetry_System, using the provided RunningEnvironmentTelemetry

func (*AppBuildTelemetry_System) UnmarshalJSON

func (t *AppBuildTelemetry_System) UnmarshalJSON(b []byte) error

type AppFeaturesTelemetry

type AppFeaturesTelemetry struct {
	Debug               bool `json:"debug"`
	ServiceDebugFeature bool `json:"service_debug_feature"`
	WebFeature          bool `json:"web_feature"`
}

AppFeaturesTelemetry defines model for AppFeaturesTelemetry.

type Batch

type Batch struct {
	Ids      []ExtendedPointId      `json:"ids"`
	Payloads *[]Batch_Payloads_Item `json:"payloads"`
	Vectors  BatchVectorStruct      `json:"vectors"`
}

Batch defines model for Batch.

type BatchPayloads1

type BatchPayloads1 = interface{}

BatchPayloads1 defines model for .

type BatchVectorStruct

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

BatchVectorStruct defines model for BatchVectorStruct.

func (BatchVectorStruct) AsBatchVectorStruct0

func (t BatchVectorStruct) AsBatchVectorStruct0() (BatchVectorStruct0, error)

AsBatchVectorStruct0 returns the union data inside the BatchVectorStruct as a BatchVectorStruct0

func (BatchVectorStruct) AsBatchVectorStruct1

func (t BatchVectorStruct) AsBatchVectorStruct1() (BatchVectorStruct1, error)

AsBatchVectorStruct1 returns the union data inside the BatchVectorStruct as a BatchVectorStruct1

func (*BatchVectorStruct) FromBatchVectorStruct0

func (t *BatchVectorStruct) FromBatchVectorStruct0(v BatchVectorStruct0) error

FromBatchVectorStruct0 overwrites any union data inside the BatchVectorStruct as the provided BatchVectorStruct0

func (*BatchVectorStruct) FromBatchVectorStruct1

func (t *BatchVectorStruct) FromBatchVectorStruct1(v BatchVectorStruct1) error

FromBatchVectorStruct1 overwrites any union data inside the BatchVectorStruct as the provided BatchVectorStruct1

func (BatchVectorStruct) MarshalJSON

func (t BatchVectorStruct) MarshalJSON() ([]byte, error)

func (*BatchVectorStruct) MergeBatchVectorStruct0

func (t *BatchVectorStruct) MergeBatchVectorStruct0(v BatchVectorStruct0) error

MergeBatchVectorStruct0 performs a merge with any union data inside the BatchVectorStruct, using the provided BatchVectorStruct0

func (*BatchVectorStruct) MergeBatchVectorStruct1

func (t *BatchVectorStruct) MergeBatchVectorStruct1(v BatchVectorStruct1) error

MergeBatchVectorStruct1 performs a merge with any union data inside the BatchVectorStruct, using the provided BatchVectorStruct1

func (*BatchVectorStruct) UnmarshalJSON

func (t *BatchVectorStruct) UnmarshalJSON(b []byte) error

type BatchVectorStruct0

type BatchVectorStruct0 = [][]float32

BatchVectorStruct0 defines model for .

type BatchVectorStruct1

type BatchVectorStruct1 map[string][][]float32

BatchVectorStruct1 defines model for .

type Batch_Payloads_Item

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

Batch_Payloads_Item defines model for Batch.payloads.Item.

func (Batch_Payloads_Item) AsBatchPayloads1

func (t Batch_Payloads_Item) AsBatchPayloads1() (BatchPayloads1, error)

AsBatchPayloads1 returns the union data inside the Batch_Payloads_Item as a BatchPayloads1

func (Batch_Payloads_Item) AsPayload

func (t Batch_Payloads_Item) AsPayload() (Payload, error)

AsPayload returns the union data inside the Batch_Payloads_Item as a Payload

func (*Batch_Payloads_Item) FromBatchPayloads1

func (t *Batch_Payloads_Item) FromBatchPayloads1(v BatchPayloads1) error

FromBatchPayloads1 overwrites any union data inside the Batch_Payloads_Item as the provided BatchPayloads1

func (*Batch_Payloads_Item) FromPayload

func (t *Batch_Payloads_Item) FromPayload(v Payload) error

FromPayload overwrites any union data inside the Batch_Payloads_Item as the provided Payload

func (Batch_Payloads_Item) MarshalJSON

func (t Batch_Payloads_Item) MarshalJSON() ([]byte, error)

func (*Batch_Payloads_Item) MergeBatchPayloads1

func (t *Batch_Payloads_Item) MergeBatchPayloads1(v BatchPayloads1) error

MergeBatchPayloads1 performs a merge with any union data inside the Batch_Payloads_Item, using the provided BatchPayloads1

func (*Batch_Payloads_Item) MergePayload

func (t *Batch_Payloads_Item) MergePayload(v Payload) error

MergePayload performs a merge with any union data inside the Batch_Payloads_Item, using the provided Payload

func (*Batch_Payloads_Item) UnmarshalJSON

func (t *Batch_Payloads_Item) UnmarshalJSON(b []byte) error

type BinaryQuantization

type BinaryQuantization struct {
	Binary BinaryQuantizationConfig `json:"binary"`
}

type BinaryQuantizationConfig

type BinaryQuantizationConfig struct {
	// AlwaysRam If true - quantized vectors always will be stored in RAM, ignoring the config of main storage
	AlwaysRam *bool `json:"always_ram"`
}

type ChangeAliasesOperation

type ChangeAliasesOperation struct {
	Actions []AliasOperations `json:"actions"`
}

ChangeAliasesOperation Operation for performing changes of collection aliases. Alias changes are atomic, meaning that no collection modifications can happen between alias operations.

type ClearPayloadJSONRequestBody

type ClearPayloadJSONRequestBody = PointsSelector

ClearPayloadJSONRequestBody defines body for ClearPayload for application/json ContentType.

type ClearPayloadParams

type ClearPayloadParams struct {
	// Wait If true, wait for changes to actually happen
	Wait *bool `form:"wait,omitempty" json:"wait,omitempty"`

	// Ordering define ordering guarantees for the operation
	Ordering *WriteOrdering `form:"ordering,omitempty" json:"ordering,omitempty"`
}

ClearPayloadParams defines parameters for ClearPayload.

type ClearPayloadResponse

type ClearPayloadResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		Result *UpdateResult `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseClearPayloadResponse

func ParseClearPayloadResponse(rsp *http.Response) (*ClearPayloadResponse, error)

ParseClearPayloadResponse parses an HTTP response from a ClearPayloadWithResponse call

func (ClearPayloadResponse) Status

func (r ClearPayloadResponse) Status() string

Status returns HTTPResponse.Status

func (ClearPayloadResponse) StatusCode

func (r ClearPayloadResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type Client

type Client struct {
	// The endpoint of the server conforming to this interface, with scheme,
	// https://api.deepmap.com for example. This can contain a path relative
	// to the server, such as https://api.deepmap.com/dev-test, and all the
	// paths in the swagger spec will be appended to the server.
	Server string

	// Doer for performing requests, typically a *http.Client with any
	// customized settings, such as certificate chains.
	Client HttpRequestDoer

	// A list of callbacks for modifying requests which are generated before sending over
	// the network.
	RequestEditors []RequestEditorFn
}

Client which conforms to the OpenAPI3 specification for this service.

func NewClient

func NewClient(server string, opts ...ClientOption) (*Client, error)

Creates a new Client, with reasonable defaults

func (*Client) ClearPayload

func (c *Client) ClearPayload(ctx context.Context, collectionName string, params *ClearPayloadParams, body ClearPayloadJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ClearPayloadWithBody

func (c *Client) ClearPayloadWithBody(ctx context.Context, collectionName string, params *ClearPayloadParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ClusterStatus

func (c *Client) ClusterStatus(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) CollectionClusterInfo

func (c *Client) CollectionClusterInfo(ctx context.Context, collectionName string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) CountPoints

func (c *Client) CountPoints(ctx context.Context, collectionName string, body CountPointsJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) CountPointsWithBody

func (c *Client) CountPointsWithBody(ctx context.Context, collectionName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) CreateCollection

func (c *Client) CreateCollection(ctx context.Context, collectionName string, params *CreateCollectionParams, body CreateCollectionJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) CreateCollectionWithBody

func (c *Client) CreateCollectionWithBody(ctx context.Context, collectionName string, params *CreateCollectionParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) CreateFieldIndex

func (c *Client) CreateFieldIndex(ctx context.Context, collectionName string, params *CreateFieldIndexParams, body CreateFieldIndexJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) CreateFieldIndexWithBody

func (c *Client) CreateFieldIndexWithBody(ctx context.Context, collectionName string, params *CreateFieldIndexParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) CreateFullSnapshot

func (c *Client) CreateFullSnapshot(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) CreateSnapshot

func (c *Client) CreateSnapshot(ctx context.Context, collectionName string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DeleteCollection

func (c *Client) DeleteCollection(ctx context.Context, collectionName string, params *DeleteCollectionParams, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DeleteFieldIndex

func (c *Client) DeleteFieldIndex(ctx context.Context, collectionName string, fieldName string, params *DeleteFieldIndexParams, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DeleteFullSnapshot

func (c *Client) DeleteFullSnapshot(ctx context.Context, snapshotName string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DeletePayload

func (c *Client) DeletePayload(ctx context.Context, collectionName string, params *DeletePayloadParams, body DeletePayloadJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DeletePayloadWithBody

func (c *Client) DeletePayloadWithBody(ctx context.Context, collectionName string, params *DeletePayloadParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DeletePoints

func (c *Client) DeletePoints(ctx context.Context, collectionName string, params *DeletePointsParams, body DeletePointsJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DeletePointsWithBody

func (c *Client) DeletePointsWithBody(ctx context.Context, collectionName string, params *DeletePointsParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DeleteSnapshot

func (c *Client) DeleteSnapshot(ctx context.Context, collectionName string, snapshotName string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetCollection

func (c *Client) GetCollection(ctx context.Context, collectionName string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetCollectionAliases

func (c *Client) GetCollectionAliases(ctx context.Context, collectionName string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetCollections

func (c *Client) GetCollections(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetCollectionsAliases

func (c *Client) GetCollectionsAliases(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetFullSnapshot

func (c *Client) GetFullSnapshot(ctx context.Context, snapshotName string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetLocks

func (c *Client) GetLocks(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetPoint

func (c *Client) GetPoint(ctx context.Context, collectionName string, id ExtendedPointId, params *GetPointParams, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetPoints

func (c *Client) GetPoints(ctx context.Context, collectionName string, params *GetPointsParams, body GetPointsJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetPointsWithBody

func (c *Client) GetPointsWithBody(ctx context.Context, collectionName string, params *GetPointsParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetSnapshot

func (c *Client) GetSnapshot(ctx context.Context, collectionName string, snapshotName string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ListFullSnapshots

func (c *Client) ListFullSnapshots(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ListSnapshots

func (c *Client) ListSnapshots(ctx context.Context, collectionName string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) Metrics

func (c *Client) Metrics(ctx context.Context, params *MetricsParams, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) OverwritePayload

func (c *Client) OverwritePayload(ctx context.Context, collectionName string, params *OverwritePayloadParams, body OverwritePayloadJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) OverwritePayloadWithBody

func (c *Client) OverwritePayloadWithBody(ctx context.Context, collectionName string, params *OverwritePayloadParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) PostLocks

func (c *Client) PostLocks(ctx context.Context, body PostLocksJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) PostLocksWithBody

func (c *Client) PostLocksWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) RecommendBatchPoints

func (c *Client) RecommendBatchPoints(ctx context.Context, collectionName string, params *RecommendBatchPointsParams, body RecommendBatchPointsJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) RecommendBatchPointsWithBody

func (c *Client) RecommendBatchPointsWithBody(ctx context.Context, collectionName string, params *RecommendBatchPointsParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) RecommendPoints

func (c *Client) RecommendPoints(ctx context.Context, collectionName string, params *RecommendPointsParams, body RecommendPointsJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) RecommendPointsWithBody

func (c *Client) RecommendPointsWithBody(ctx context.Context, collectionName string, params *RecommendPointsParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) RecoverCurrentPeer

func (c *Client) RecoverCurrentPeer(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) RecoverFromSnapshot

func (c *Client) RecoverFromSnapshot(ctx context.Context, collectionName string, params *RecoverFromSnapshotParams, body RecoverFromSnapshotJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) RecoverFromSnapshotWithBody

func (c *Client) RecoverFromSnapshotWithBody(ctx context.Context, collectionName string, params *RecoverFromSnapshotParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) RemovePeer

func (c *Client) RemovePeer(ctx context.Context, peerId int, params *RemovePeerParams, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ScrollPoints

func (c *Client) ScrollPoints(ctx context.Context, collectionName string, params *ScrollPointsParams, body ScrollPointsJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ScrollPointsWithBody

func (c *Client) ScrollPointsWithBody(ctx context.Context, collectionName string, params *ScrollPointsParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) SearchBatchPoints

func (c *Client) SearchBatchPoints(ctx context.Context, collectionName string, params *SearchBatchPointsParams, body SearchBatchPointsJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) SearchBatchPointsWithBody

func (c *Client) SearchBatchPointsWithBody(ctx context.Context, collectionName string, params *SearchBatchPointsParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) SearchPoints

func (c *Client) SearchPoints(ctx context.Context, collectionName string, params *SearchPointsParams, body SearchPointsJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) SearchPointsWithBody

func (c *Client) SearchPointsWithBody(ctx context.Context, collectionName string, params *SearchPointsParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) SetPayload

func (c *Client) SetPayload(ctx context.Context, collectionName string, params *SetPayloadParams, body SetPayloadJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) SetPayloadWithBody

func (c *Client) SetPayloadWithBody(ctx context.Context, collectionName string, params *SetPayloadParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) Telemetry

func (c *Client) Telemetry(ctx context.Context, params *TelemetryParams, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) UpdateAliases

func (c *Client) UpdateAliases(ctx context.Context, params *UpdateAliasesParams, body UpdateAliasesJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) UpdateAliasesWithBody

func (c *Client) UpdateAliasesWithBody(ctx context.Context, params *UpdateAliasesParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) UpdateCollection

func (c *Client) UpdateCollection(ctx context.Context, collectionName string, params *UpdateCollectionParams, body UpdateCollectionJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) UpdateCollectionCluster

func (c *Client) UpdateCollectionCluster(ctx context.Context, collectionName string, params *UpdateCollectionClusterParams, body UpdateCollectionClusterJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) UpdateCollectionClusterWithBody

func (c *Client) UpdateCollectionClusterWithBody(ctx context.Context, collectionName string, params *UpdateCollectionClusterParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) UpdateCollectionWithBody

func (c *Client) UpdateCollectionWithBody(ctx context.Context, collectionName string, params *UpdateCollectionParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) UpsertPoints

func (c *Client) UpsertPoints(ctx context.Context, collectionName string, params *UpsertPointsParams, body UpsertPointsJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) UpsertPointsWithBody

func (c *Client) UpsertPointsWithBody(ctx context.Context, collectionName string, params *UpsertPointsParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

type ClientInterface

type ClientInterface interface {
	// GetCollectionsAliases request
	GetCollectionsAliases(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

	// ClusterStatus request
	ClusterStatus(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

	// RemovePeer request
	RemovePeer(ctx context.Context, peerId int, params *RemovePeerParams, reqEditors ...RequestEditorFn) (*http.Response, error)

	// RecoverCurrentPeer request
	RecoverCurrentPeer(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetCollections request
	GetCollections(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

	// UpdateAliases request with any body
	UpdateAliasesWithBody(ctx context.Context, params *UpdateAliasesParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	UpdateAliases(ctx context.Context, params *UpdateAliasesParams, body UpdateAliasesJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DeleteCollection request
	DeleteCollection(ctx context.Context, collectionName string, params *DeleteCollectionParams, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetCollection request
	GetCollection(ctx context.Context, collectionName string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// UpdateCollection request with any body
	UpdateCollectionWithBody(ctx context.Context, collectionName string, params *UpdateCollectionParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	UpdateCollection(ctx context.Context, collectionName string, params *UpdateCollectionParams, body UpdateCollectionJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// CreateCollection request with any body
	CreateCollectionWithBody(ctx context.Context, collectionName string, params *CreateCollectionParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	CreateCollection(ctx context.Context, collectionName string, params *CreateCollectionParams, body CreateCollectionJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetCollectionAliases request
	GetCollectionAliases(ctx context.Context, collectionName string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// CollectionClusterInfo request
	CollectionClusterInfo(ctx context.Context, collectionName string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// UpdateCollectionCluster request with any body
	UpdateCollectionClusterWithBody(ctx context.Context, collectionName string, params *UpdateCollectionClusterParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	UpdateCollectionCluster(ctx context.Context, collectionName string, params *UpdateCollectionClusterParams, body UpdateCollectionClusterJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// CreateFieldIndex request with any body
	CreateFieldIndexWithBody(ctx context.Context, collectionName string, params *CreateFieldIndexParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	CreateFieldIndex(ctx context.Context, collectionName string, params *CreateFieldIndexParams, body CreateFieldIndexJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DeleteFieldIndex request
	DeleteFieldIndex(ctx context.Context, collectionName string, fieldName string, params *DeleteFieldIndexParams, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetPoints request with any body
	GetPointsWithBody(ctx context.Context, collectionName string, params *GetPointsParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	GetPoints(ctx context.Context, collectionName string, params *GetPointsParams, body GetPointsJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// UpsertPoints request with any body
	UpsertPointsWithBody(ctx context.Context, collectionName string, params *UpsertPointsParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	UpsertPoints(ctx context.Context, collectionName string, params *UpsertPointsParams, body UpsertPointsJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// CountPoints request with any body
	CountPointsWithBody(ctx context.Context, collectionName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	CountPoints(ctx context.Context, collectionName string, body CountPointsJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DeletePoints request with any body
	DeletePointsWithBody(ctx context.Context, collectionName string, params *DeletePointsParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	DeletePoints(ctx context.Context, collectionName string, params *DeletePointsParams, body DeletePointsJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// SetPayload request with any body
	SetPayloadWithBody(ctx context.Context, collectionName string, params *SetPayloadParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	SetPayload(ctx context.Context, collectionName string, params *SetPayloadParams, body SetPayloadJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// OverwritePayload request with any body
	OverwritePayloadWithBody(ctx context.Context, collectionName string, params *OverwritePayloadParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	OverwritePayload(ctx context.Context, collectionName string, params *OverwritePayloadParams, body OverwritePayloadJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// ClearPayload request with any body
	ClearPayloadWithBody(ctx context.Context, collectionName string, params *ClearPayloadParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	ClearPayload(ctx context.Context, collectionName string, params *ClearPayloadParams, body ClearPayloadJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DeletePayload request with any body
	DeletePayloadWithBody(ctx context.Context, collectionName string, params *DeletePayloadParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	DeletePayload(ctx context.Context, collectionName string, params *DeletePayloadParams, body DeletePayloadJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// RecommendPoints request with any body
	RecommendPointsWithBody(ctx context.Context, collectionName string, params *RecommendPointsParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	RecommendPoints(ctx context.Context, collectionName string, params *RecommendPointsParams, body RecommendPointsJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// RecommendBatchPoints request with any body
	RecommendBatchPointsWithBody(ctx context.Context, collectionName string, params *RecommendBatchPointsParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	RecommendBatchPoints(ctx context.Context, collectionName string, params *RecommendBatchPointsParams, body RecommendBatchPointsJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// ScrollPoints request with any body
	ScrollPointsWithBody(ctx context.Context, collectionName string, params *ScrollPointsParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	ScrollPoints(ctx context.Context, collectionName string, params *ScrollPointsParams, body ScrollPointsJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// SearchPoints request with any body
	SearchPointsWithBody(ctx context.Context, collectionName string, params *SearchPointsParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	SearchPoints(ctx context.Context, collectionName string, params *SearchPointsParams, body SearchPointsJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// SearchBatchPoints request with any body
	SearchBatchPointsWithBody(ctx context.Context, collectionName string, params *SearchBatchPointsParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	SearchBatchPoints(ctx context.Context, collectionName string, params *SearchBatchPointsParams, body SearchBatchPointsJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetPoint request
	GetPoint(ctx context.Context, collectionName string, id ExtendedPointId, params *GetPointParams, reqEditors ...RequestEditorFn) (*http.Response, error)

	// ListSnapshots request
	ListSnapshots(ctx context.Context, collectionName string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// CreateSnapshot request
	CreateSnapshot(ctx context.Context, collectionName string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// RecoverFromSnapshot request with any body
	RecoverFromSnapshotWithBody(ctx context.Context, collectionName string, params *RecoverFromSnapshotParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	RecoverFromSnapshot(ctx context.Context, collectionName string, params *RecoverFromSnapshotParams, body RecoverFromSnapshotJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DeleteSnapshot request
	DeleteSnapshot(ctx context.Context, collectionName string, snapshotName string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetSnapshot request
	GetSnapshot(ctx context.Context, collectionName string, snapshotName string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetLocks request
	GetLocks(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

	// PostLocks request with any body
	PostLocksWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	PostLocks(ctx context.Context, body PostLocksJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// Metrics request
	Metrics(ctx context.Context, params *MetricsParams, reqEditors ...RequestEditorFn) (*http.Response, error)

	// ListFullSnapshots request
	ListFullSnapshots(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

	// CreateFullSnapshot request
	CreateFullSnapshot(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DeleteFullSnapshot request
	DeleteFullSnapshot(ctx context.Context, snapshotName string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetFullSnapshot request
	GetFullSnapshot(ctx context.Context, snapshotName string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// Telemetry request
	Telemetry(ctx context.Context, params *TelemetryParams, reqEditors ...RequestEditorFn) (*http.Response, error)
}

The interface specification for the client above.

type ClientOption

type ClientOption func(*Client) error

ClientOption allows setting custom parameters during construction

func WithBaseURL

func WithBaseURL(baseURL string) ClientOption

WithBaseURL overrides the baseURL.

func WithHTTPClient

func WithHTTPClient(doer HttpRequestDoer) ClientOption

WithHTTPClient allows overriding the default Doer, which is automatically created using http.Client. This is useful for tests.

func WithRequestEditorFn

func WithRequestEditorFn(fn RequestEditorFn) ClientOption

WithRequestEditorFn allows setting up a callback function, which will be called right before sending the request. This can be used to mutate the request.

type ClientWithResponses

type ClientWithResponses struct {
	ClientInterface
}

ClientWithResponses builds on ClientInterface to offer response payloads

func (*ClientWithResponses) ClearPayloadWithBodyWithResponse

func (c *ClientWithResponses) ClearPayloadWithBodyWithResponse(ctx context.Context, collectionName string, params *ClearPayloadParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*ClearPayloadResponse, error)

ClearPayloadWithBodyWithResponse request with arbitrary body returning *ClearPayloadResponse

func (*ClientWithResponses) ClearPayloadWithResponse

func (c *ClientWithResponses) ClearPayloadWithResponse(ctx context.Context, collectionName string, params *ClearPayloadParams, body ClearPayloadJSONRequestBody, reqEditors ...RequestEditorFn) (*ClearPayloadResponse, error)

func (*ClientWithResponses) ClusterStatusWithResponse

func (c *ClientWithResponses) ClusterStatusWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ClusterStatusResponse, error)

ClusterStatusWithResponse request returning *ClusterStatusResponse

func (*ClientWithResponses) CollectionClusterInfoWithResponse

func (c *ClientWithResponses) CollectionClusterInfoWithResponse(ctx context.Context, collectionName string, reqEditors ...RequestEditorFn) (*CollectionClusterInfoResponse, error)

CollectionClusterInfoWithResponse request returning *CollectionClusterInfoResponse

func (*ClientWithResponses) CountPointsWithBodyWithResponse

func (c *ClientWithResponses) CountPointsWithBodyWithResponse(ctx context.Context, collectionName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*CountPointsResponse, error)

CountPointsWithBodyWithResponse request with arbitrary body returning *CountPointsResponse

func (*ClientWithResponses) CountPointsWithResponse

func (c *ClientWithResponses) CountPointsWithResponse(ctx context.Context, collectionName string, body CountPointsJSONRequestBody, reqEditors ...RequestEditorFn) (*CountPointsResponse, error)

func (*ClientWithResponses) CreateCollectionWithBodyWithResponse

func (c *ClientWithResponses) CreateCollectionWithBodyWithResponse(ctx context.Context, collectionName string, params *CreateCollectionParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*CreateCollectionResponse, error)

CreateCollectionWithBodyWithResponse request with arbitrary body returning *CreateCollectionResponse

func (*ClientWithResponses) CreateCollectionWithResponse

func (c *ClientWithResponses) CreateCollectionWithResponse(ctx context.Context, collectionName string, params *CreateCollectionParams, body CreateCollectionJSONRequestBody, reqEditors ...RequestEditorFn) (*CreateCollectionResponse, error)

func (*ClientWithResponses) CreateFieldIndexWithBodyWithResponse

func (c *ClientWithResponses) CreateFieldIndexWithBodyWithResponse(ctx context.Context, collectionName string, params *CreateFieldIndexParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*CreateFieldIndexResponse, error)

CreateFieldIndexWithBodyWithResponse request with arbitrary body returning *CreateFieldIndexResponse

func (*ClientWithResponses) CreateFieldIndexWithResponse

func (c *ClientWithResponses) CreateFieldIndexWithResponse(ctx context.Context, collectionName string, params *CreateFieldIndexParams, body CreateFieldIndexJSONRequestBody, reqEditors ...RequestEditorFn) (*CreateFieldIndexResponse, error)

func (*ClientWithResponses) CreateFullSnapshotWithResponse

func (c *ClientWithResponses) CreateFullSnapshotWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*CreateFullSnapshotResponse, error)

CreateFullSnapshotWithResponse request returning *CreateFullSnapshotResponse

func (*ClientWithResponses) CreateSnapshotWithResponse

func (c *ClientWithResponses) CreateSnapshotWithResponse(ctx context.Context, collectionName string, reqEditors ...RequestEditorFn) (*CreateSnapshotResponse, error)

CreateSnapshotWithResponse request returning *CreateSnapshotResponse

func (*ClientWithResponses) DeleteCollectionWithResponse

func (c *ClientWithResponses) DeleteCollectionWithResponse(ctx context.Context, collectionName string, params *DeleteCollectionParams, reqEditors ...RequestEditorFn) (*DeleteCollectionResponse, error)

DeleteCollectionWithResponse request returning *DeleteCollectionResponse

func (*ClientWithResponses) DeleteFieldIndexWithResponse

func (c *ClientWithResponses) DeleteFieldIndexWithResponse(ctx context.Context, collectionName string, fieldName string, params *DeleteFieldIndexParams, reqEditors ...RequestEditorFn) (*DeleteFieldIndexResponse, error)

DeleteFieldIndexWithResponse request returning *DeleteFieldIndexResponse

func (*ClientWithResponses) DeleteFullSnapshotWithResponse

func (c *ClientWithResponses) DeleteFullSnapshotWithResponse(ctx context.Context, snapshotName string, reqEditors ...RequestEditorFn) (*DeleteFullSnapshotResponse, error)

DeleteFullSnapshotWithResponse request returning *DeleteFullSnapshotResponse

func (*ClientWithResponses) DeletePayloadWithBodyWithResponse

func (c *ClientWithResponses) DeletePayloadWithBodyWithResponse(ctx context.Context, collectionName string, params *DeletePayloadParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*DeletePayloadResponse, error)

DeletePayloadWithBodyWithResponse request with arbitrary body returning *DeletePayloadResponse

func (*ClientWithResponses) DeletePayloadWithResponse

func (c *ClientWithResponses) DeletePayloadWithResponse(ctx context.Context, collectionName string, params *DeletePayloadParams, body DeletePayloadJSONRequestBody, reqEditors ...RequestEditorFn) (*DeletePayloadResponse, error)

func (*ClientWithResponses) DeletePointsWithBodyWithResponse

func (c *ClientWithResponses) DeletePointsWithBodyWithResponse(ctx context.Context, collectionName string, params *DeletePointsParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*DeletePointsResponse, error)

DeletePointsWithBodyWithResponse request with arbitrary body returning *DeletePointsResponse

func (*ClientWithResponses) DeletePointsWithResponse

func (c *ClientWithResponses) DeletePointsWithResponse(ctx context.Context, collectionName string, params *DeletePointsParams, body DeletePointsJSONRequestBody, reqEditors ...RequestEditorFn) (*DeletePointsResponse, error)

func (*ClientWithResponses) DeleteSnapshotWithResponse

func (c *ClientWithResponses) DeleteSnapshotWithResponse(ctx context.Context, collectionName string, snapshotName string, reqEditors ...RequestEditorFn) (*DeleteSnapshotResponse, error)

DeleteSnapshotWithResponse request returning *DeleteSnapshotResponse

func (*ClientWithResponses) GetCollectionAliasesWithResponse

func (c *ClientWithResponses) GetCollectionAliasesWithResponse(ctx context.Context, collectionName string, reqEditors ...RequestEditorFn) (*GetCollectionAliasesResponse, error)

GetCollectionAliasesWithResponse request returning *GetCollectionAliasesResponse

func (*ClientWithResponses) GetCollectionWithResponse

func (c *ClientWithResponses) GetCollectionWithResponse(ctx context.Context, collectionName string, reqEditors ...RequestEditorFn) (*GetCollectionResponse, error)

GetCollectionWithResponse request returning *GetCollectionResponse

func (*ClientWithResponses) GetCollectionsAliasesWithResponse

func (c *ClientWithResponses) GetCollectionsAliasesWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*GetCollectionsAliasesResponse, error)

GetCollectionsAliasesWithResponse request returning *GetCollectionsAliasesResponse

func (*ClientWithResponses) GetCollectionsWithResponse

func (c *ClientWithResponses) GetCollectionsWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*GetCollectionsResponse, error)

GetCollectionsWithResponse request returning *GetCollectionsResponse

func (*ClientWithResponses) GetFullSnapshotWithResponse

func (c *ClientWithResponses) GetFullSnapshotWithResponse(ctx context.Context, snapshotName string, reqEditors ...RequestEditorFn) (*GetFullSnapshotResponse, error)

GetFullSnapshotWithResponse request returning *GetFullSnapshotResponse

func (*ClientWithResponses) GetLocksWithResponse

func (c *ClientWithResponses) GetLocksWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*GetLocksResponse, error)

GetLocksWithResponse request returning *GetLocksResponse

func (*ClientWithResponses) GetPointWithResponse

func (c *ClientWithResponses) GetPointWithResponse(ctx context.Context, collectionName string, id ExtendedPointId, params *GetPointParams, reqEditors ...RequestEditorFn) (*GetPointResponse, error)

GetPointWithResponse request returning *GetPointResponse

func (*ClientWithResponses) GetPointsWithBodyWithResponse

func (c *ClientWithResponses) GetPointsWithBodyWithResponse(ctx context.Context, collectionName string, params *GetPointsParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*GetPointsResponse, error)

GetPointsWithBodyWithResponse request with arbitrary body returning *GetPointsResponse

func (*ClientWithResponses) GetPointsWithResponse

func (c *ClientWithResponses) GetPointsWithResponse(ctx context.Context, collectionName string, params *GetPointsParams, body GetPointsJSONRequestBody, reqEditors ...RequestEditorFn) (*GetPointsResponse, error)

func (*ClientWithResponses) GetSnapshotWithResponse

func (c *ClientWithResponses) GetSnapshotWithResponse(ctx context.Context, collectionName string, snapshotName string, reqEditors ...RequestEditorFn) (*GetSnapshotResponse, error)

GetSnapshotWithResponse request returning *GetSnapshotResponse

func (*ClientWithResponses) ListFullSnapshotsWithResponse

func (c *ClientWithResponses) ListFullSnapshotsWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ListFullSnapshotsResponse, error)

ListFullSnapshotsWithResponse request returning *ListFullSnapshotsResponse

func (*ClientWithResponses) ListSnapshotsWithResponse

func (c *ClientWithResponses) ListSnapshotsWithResponse(ctx context.Context, collectionName string, reqEditors ...RequestEditorFn) (*ListSnapshotsResponse, error)

ListSnapshotsWithResponse request returning *ListSnapshotsResponse

func (*ClientWithResponses) MetricsWithResponse

func (c *ClientWithResponses) MetricsWithResponse(ctx context.Context, params *MetricsParams, reqEditors ...RequestEditorFn) (*MetricsResponse, error)

MetricsWithResponse request returning *MetricsResponse

func (*ClientWithResponses) OverwritePayloadWithBodyWithResponse

func (c *ClientWithResponses) OverwritePayloadWithBodyWithResponse(ctx context.Context, collectionName string, params *OverwritePayloadParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*OverwritePayloadResponse, error)

OverwritePayloadWithBodyWithResponse request with arbitrary body returning *OverwritePayloadResponse

func (*ClientWithResponses) OverwritePayloadWithResponse

func (c *ClientWithResponses) OverwritePayloadWithResponse(ctx context.Context, collectionName string, params *OverwritePayloadParams, body OverwritePayloadJSONRequestBody, reqEditors ...RequestEditorFn) (*OverwritePayloadResponse, error)

func (*ClientWithResponses) PostLocksWithBodyWithResponse

func (c *ClientWithResponses) PostLocksWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*PostLocksResponse, error)

PostLocksWithBodyWithResponse request with arbitrary body returning *PostLocksResponse

func (*ClientWithResponses) PostLocksWithResponse

func (c *ClientWithResponses) PostLocksWithResponse(ctx context.Context, body PostLocksJSONRequestBody, reqEditors ...RequestEditorFn) (*PostLocksResponse, error)

func (*ClientWithResponses) RecommendBatchPointsWithBodyWithResponse

func (c *ClientWithResponses) RecommendBatchPointsWithBodyWithResponse(ctx context.Context, collectionName string, params *RecommendBatchPointsParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*RecommendBatchPointsResponse, error)

RecommendBatchPointsWithBodyWithResponse request with arbitrary body returning *RecommendBatchPointsResponse

func (*ClientWithResponses) RecommendBatchPointsWithResponse

func (c *ClientWithResponses) RecommendBatchPointsWithResponse(ctx context.Context, collectionName string, params *RecommendBatchPointsParams, body RecommendBatchPointsJSONRequestBody, reqEditors ...RequestEditorFn) (*RecommendBatchPointsResponse, error)

func (*ClientWithResponses) RecommendPointsWithBodyWithResponse

func (c *ClientWithResponses) RecommendPointsWithBodyWithResponse(ctx context.Context, collectionName string, params *RecommendPointsParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*RecommendPointsResponse, error)

RecommendPointsWithBodyWithResponse request with arbitrary body returning *RecommendPointsResponse

func (*ClientWithResponses) RecommendPointsWithResponse

func (c *ClientWithResponses) RecommendPointsWithResponse(ctx context.Context, collectionName string, params *RecommendPointsParams, body RecommendPointsJSONRequestBody, reqEditors ...RequestEditorFn) (*RecommendPointsResponse, error)

func (*ClientWithResponses) RecoverCurrentPeerWithResponse

func (c *ClientWithResponses) RecoverCurrentPeerWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*RecoverCurrentPeerResponse, error)

RecoverCurrentPeerWithResponse request returning *RecoverCurrentPeerResponse

func (*ClientWithResponses) RecoverFromSnapshotWithBodyWithResponse

func (c *ClientWithResponses) RecoverFromSnapshotWithBodyWithResponse(ctx context.Context, collectionName string, params *RecoverFromSnapshotParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*RecoverFromSnapshotResponse, error)

RecoverFromSnapshotWithBodyWithResponse request with arbitrary body returning *RecoverFromSnapshotResponse

func (*ClientWithResponses) RecoverFromSnapshotWithResponse

func (c *ClientWithResponses) RecoverFromSnapshotWithResponse(ctx context.Context, collectionName string, params *RecoverFromSnapshotParams, body RecoverFromSnapshotJSONRequestBody, reqEditors ...RequestEditorFn) (*RecoverFromSnapshotResponse, error)

func (*ClientWithResponses) RemovePeerWithResponse

func (c *ClientWithResponses) RemovePeerWithResponse(ctx context.Context, peerId int, params *RemovePeerParams, reqEditors ...RequestEditorFn) (*RemovePeerResponse, error)

RemovePeerWithResponse request returning *RemovePeerResponse

func (*ClientWithResponses) ScrollPointsWithBodyWithResponse

func (c *ClientWithResponses) ScrollPointsWithBodyWithResponse(ctx context.Context, collectionName string, params *ScrollPointsParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*ScrollPointsResponse, error)

ScrollPointsWithBodyWithResponse request with arbitrary body returning *ScrollPointsResponse

func (*ClientWithResponses) ScrollPointsWithResponse

func (c *ClientWithResponses) ScrollPointsWithResponse(ctx context.Context, collectionName string, params *ScrollPointsParams, body ScrollPointsJSONRequestBody, reqEditors ...RequestEditorFn) (*ScrollPointsResponse, error)

func (*ClientWithResponses) SearchBatchPointsWithBodyWithResponse

func (c *ClientWithResponses) SearchBatchPointsWithBodyWithResponse(ctx context.Context, collectionName string, params *SearchBatchPointsParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*SearchBatchPointsResponse, error)

SearchBatchPointsWithBodyWithResponse request with arbitrary body returning *SearchBatchPointsResponse

func (*ClientWithResponses) SearchBatchPointsWithResponse

func (c *ClientWithResponses) SearchBatchPointsWithResponse(ctx context.Context, collectionName string, params *SearchBatchPointsParams, body SearchBatchPointsJSONRequestBody, reqEditors ...RequestEditorFn) (*SearchBatchPointsResponse, error)

func (*ClientWithResponses) SearchPointsWithBodyWithResponse

func (c *ClientWithResponses) SearchPointsWithBodyWithResponse(ctx context.Context, collectionName string, params *SearchPointsParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*SearchPointsResponse, error)

SearchPointsWithBodyWithResponse request with arbitrary body returning *SearchPointsResponse

func (*ClientWithResponses) SearchPointsWithResponse

func (c *ClientWithResponses) SearchPointsWithResponse(ctx context.Context, collectionName string, params *SearchPointsParams, body SearchPointsJSONRequestBody, reqEditors ...RequestEditorFn) (*SearchPointsResponse, error)

func (*ClientWithResponses) SetPayloadWithBodyWithResponse

func (c *ClientWithResponses) SetPayloadWithBodyWithResponse(ctx context.Context, collectionName string, params *SetPayloadParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*SetPayloadResponse, error)

SetPayloadWithBodyWithResponse request with arbitrary body returning *SetPayloadResponse

func (*ClientWithResponses) SetPayloadWithResponse

func (c *ClientWithResponses) SetPayloadWithResponse(ctx context.Context, collectionName string, params *SetPayloadParams, body SetPayloadJSONRequestBody, reqEditors ...RequestEditorFn) (*SetPayloadResponse, error)

func (*ClientWithResponses) TelemetryWithResponse

func (c *ClientWithResponses) TelemetryWithResponse(ctx context.Context, params *TelemetryParams, reqEditors ...RequestEditorFn) (*TelemetryResponse, error)

TelemetryWithResponse request returning *TelemetryResponse

func (*ClientWithResponses) UpdateAliasesWithBodyWithResponse

func (c *ClientWithResponses) UpdateAliasesWithBodyWithResponse(ctx context.Context, params *UpdateAliasesParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*UpdateAliasesResponse, error)

UpdateAliasesWithBodyWithResponse request with arbitrary body returning *UpdateAliasesResponse

func (*ClientWithResponses) UpdateAliasesWithResponse

func (c *ClientWithResponses) UpdateAliasesWithResponse(ctx context.Context, params *UpdateAliasesParams, body UpdateAliasesJSONRequestBody, reqEditors ...RequestEditorFn) (*UpdateAliasesResponse, error)

func (*ClientWithResponses) UpdateCollectionClusterWithBodyWithResponse

func (c *ClientWithResponses) UpdateCollectionClusterWithBodyWithResponse(ctx context.Context, collectionName string, params *UpdateCollectionClusterParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*UpdateCollectionClusterResponse, error)

UpdateCollectionClusterWithBodyWithResponse request with arbitrary body returning *UpdateCollectionClusterResponse

func (*ClientWithResponses) UpdateCollectionClusterWithResponse

func (c *ClientWithResponses) UpdateCollectionClusterWithResponse(ctx context.Context, collectionName string, params *UpdateCollectionClusterParams, body UpdateCollectionClusterJSONRequestBody, reqEditors ...RequestEditorFn) (*UpdateCollectionClusterResponse, error)

func (*ClientWithResponses) UpdateCollectionWithBodyWithResponse

func (c *ClientWithResponses) UpdateCollectionWithBodyWithResponse(ctx context.Context, collectionName string, params *UpdateCollectionParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*UpdateCollectionResponse, error)

UpdateCollectionWithBodyWithResponse request with arbitrary body returning *UpdateCollectionResponse

func (*ClientWithResponses) UpdateCollectionWithResponse

func (c *ClientWithResponses) UpdateCollectionWithResponse(ctx context.Context, collectionName string, params *UpdateCollectionParams, body UpdateCollectionJSONRequestBody, reqEditors ...RequestEditorFn) (*UpdateCollectionResponse, error)

func (*ClientWithResponses) UpsertPointsWithBodyWithResponse

func (c *ClientWithResponses) UpsertPointsWithBodyWithResponse(ctx context.Context, collectionName string, params *UpsertPointsParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*UpsertPointsResponse, error)

UpsertPointsWithBodyWithResponse request with arbitrary body returning *UpsertPointsResponse

func (*ClientWithResponses) UpsertPointsWithResponse

func (c *ClientWithResponses) UpsertPointsWithResponse(ctx context.Context, collectionName string, params *UpsertPointsParams, body UpsertPointsJSONRequestBody, reqEditors ...RequestEditorFn) (*UpsertPointsResponse, error)

type ClientWithResponsesInterface

type ClientWithResponsesInterface interface {
	// GetCollectionsAliases request
	GetCollectionsAliasesWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*GetCollectionsAliasesResponse, error)

	// ClusterStatus request
	ClusterStatusWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ClusterStatusResponse, error)

	// RemovePeer request
	RemovePeerWithResponse(ctx context.Context, peerId int, params *RemovePeerParams, reqEditors ...RequestEditorFn) (*RemovePeerResponse, error)

	// RecoverCurrentPeer request
	RecoverCurrentPeerWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*RecoverCurrentPeerResponse, error)

	// GetCollections request
	GetCollectionsWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*GetCollectionsResponse, error)

	// UpdateAliases request with any body
	UpdateAliasesWithBodyWithResponse(ctx context.Context, params *UpdateAliasesParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*UpdateAliasesResponse, error)

	UpdateAliasesWithResponse(ctx context.Context, params *UpdateAliasesParams, body UpdateAliasesJSONRequestBody, reqEditors ...RequestEditorFn) (*UpdateAliasesResponse, error)

	// DeleteCollection request
	DeleteCollectionWithResponse(ctx context.Context, collectionName string, params *DeleteCollectionParams, reqEditors ...RequestEditorFn) (*DeleteCollectionResponse, error)

	// GetCollection request
	GetCollectionWithResponse(ctx context.Context, collectionName string, reqEditors ...RequestEditorFn) (*GetCollectionResponse, error)

	// UpdateCollection request with any body
	UpdateCollectionWithBodyWithResponse(ctx context.Context, collectionName string, params *UpdateCollectionParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*UpdateCollectionResponse, error)

	UpdateCollectionWithResponse(ctx context.Context, collectionName string, params *UpdateCollectionParams, body UpdateCollectionJSONRequestBody, reqEditors ...RequestEditorFn) (*UpdateCollectionResponse, error)

	// CreateCollection request with any body
	CreateCollectionWithBodyWithResponse(ctx context.Context, collectionName string, params *CreateCollectionParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*CreateCollectionResponse, error)

	CreateCollectionWithResponse(ctx context.Context, collectionName string, params *CreateCollectionParams, body CreateCollectionJSONRequestBody, reqEditors ...RequestEditorFn) (*CreateCollectionResponse, error)

	// GetCollectionAliases request
	GetCollectionAliasesWithResponse(ctx context.Context, collectionName string, reqEditors ...RequestEditorFn) (*GetCollectionAliasesResponse, error)

	// CollectionClusterInfo request
	CollectionClusterInfoWithResponse(ctx context.Context, collectionName string, reqEditors ...RequestEditorFn) (*CollectionClusterInfoResponse, error)

	// UpdateCollectionCluster request with any body
	UpdateCollectionClusterWithBodyWithResponse(ctx context.Context, collectionName string, params *UpdateCollectionClusterParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*UpdateCollectionClusterResponse, error)

	UpdateCollectionClusterWithResponse(ctx context.Context, collectionName string, params *UpdateCollectionClusterParams, body UpdateCollectionClusterJSONRequestBody, reqEditors ...RequestEditorFn) (*UpdateCollectionClusterResponse, error)

	// CreateFieldIndex request with any body
	CreateFieldIndexWithBodyWithResponse(ctx context.Context, collectionName string, params *CreateFieldIndexParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*CreateFieldIndexResponse, error)

	CreateFieldIndexWithResponse(ctx context.Context, collectionName string, params *CreateFieldIndexParams, body CreateFieldIndexJSONRequestBody, reqEditors ...RequestEditorFn) (*CreateFieldIndexResponse, error)

	// DeleteFieldIndex request
	DeleteFieldIndexWithResponse(ctx context.Context, collectionName string, fieldName string, params *DeleteFieldIndexParams, reqEditors ...RequestEditorFn) (*DeleteFieldIndexResponse, error)

	// GetPoints request with any body
	GetPointsWithBodyWithResponse(ctx context.Context, collectionName string, params *GetPointsParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*GetPointsResponse, error)

	GetPointsWithResponse(ctx context.Context, collectionName string, params *GetPointsParams, body GetPointsJSONRequestBody, reqEditors ...RequestEditorFn) (*GetPointsResponse, error)

	// UpsertPoints request with any body
	UpsertPointsWithBodyWithResponse(ctx context.Context, collectionName string, params *UpsertPointsParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*UpsertPointsResponse, error)

	UpsertPointsWithResponse(ctx context.Context, collectionName string, params *UpsertPointsParams, body UpsertPointsJSONRequestBody, reqEditors ...RequestEditorFn) (*UpsertPointsResponse, error)

	// CountPoints request with any body
	CountPointsWithBodyWithResponse(ctx context.Context, collectionName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*CountPointsResponse, error)

	CountPointsWithResponse(ctx context.Context, collectionName string, body CountPointsJSONRequestBody, reqEditors ...RequestEditorFn) (*CountPointsResponse, error)

	// DeletePoints request with any body
	DeletePointsWithBodyWithResponse(ctx context.Context, collectionName string, params *DeletePointsParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*DeletePointsResponse, error)

	DeletePointsWithResponse(ctx context.Context, collectionName string, params *DeletePointsParams, body DeletePointsJSONRequestBody, reqEditors ...RequestEditorFn) (*DeletePointsResponse, error)

	// SetPayload request with any body
	SetPayloadWithBodyWithResponse(ctx context.Context, collectionName string, params *SetPayloadParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*SetPayloadResponse, error)

	SetPayloadWithResponse(ctx context.Context, collectionName string, params *SetPayloadParams, body SetPayloadJSONRequestBody, reqEditors ...RequestEditorFn) (*SetPayloadResponse, error)

	// OverwritePayload request with any body
	OverwritePayloadWithBodyWithResponse(ctx context.Context, collectionName string, params *OverwritePayloadParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*OverwritePayloadResponse, error)

	OverwritePayloadWithResponse(ctx context.Context, collectionName string, params *OverwritePayloadParams, body OverwritePayloadJSONRequestBody, reqEditors ...RequestEditorFn) (*OverwritePayloadResponse, error)

	// ClearPayload request with any body
	ClearPayloadWithBodyWithResponse(ctx context.Context, collectionName string, params *ClearPayloadParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*ClearPayloadResponse, error)

	ClearPayloadWithResponse(ctx context.Context, collectionName string, params *ClearPayloadParams, body ClearPayloadJSONRequestBody, reqEditors ...RequestEditorFn) (*ClearPayloadResponse, error)

	// DeletePayload request with any body
	DeletePayloadWithBodyWithResponse(ctx context.Context, collectionName string, params *DeletePayloadParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*DeletePayloadResponse, error)

	DeletePayloadWithResponse(ctx context.Context, collectionName string, params *DeletePayloadParams, body DeletePayloadJSONRequestBody, reqEditors ...RequestEditorFn) (*DeletePayloadResponse, error)

	// RecommendPoints request with any body
	RecommendPointsWithBodyWithResponse(ctx context.Context, collectionName string, params *RecommendPointsParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*RecommendPointsResponse, error)

	RecommendPointsWithResponse(ctx context.Context, collectionName string, params *RecommendPointsParams, body RecommendPointsJSONRequestBody, reqEditors ...RequestEditorFn) (*RecommendPointsResponse, error)

	// RecommendBatchPoints request with any body
	RecommendBatchPointsWithBodyWithResponse(ctx context.Context, collectionName string, params *RecommendBatchPointsParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*RecommendBatchPointsResponse, error)

	RecommendBatchPointsWithResponse(ctx context.Context, collectionName string, params *RecommendBatchPointsParams, body RecommendBatchPointsJSONRequestBody, reqEditors ...RequestEditorFn) (*RecommendBatchPointsResponse, error)

	// ScrollPoints request with any body
	ScrollPointsWithBodyWithResponse(ctx context.Context, collectionName string, params *ScrollPointsParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*ScrollPointsResponse, error)

	ScrollPointsWithResponse(ctx context.Context, collectionName string, params *ScrollPointsParams, body ScrollPointsJSONRequestBody, reqEditors ...RequestEditorFn) (*ScrollPointsResponse, error)

	// SearchPoints request with any body
	SearchPointsWithBodyWithResponse(ctx context.Context, collectionName string, params *SearchPointsParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*SearchPointsResponse, error)

	SearchPointsWithResponse(ctx context.Context, collectionName string, params *SearchPointsParams, body SearchPointsJSONRequestBody, reqEditors ...RequestEditorFn) (*SearchPointsResponse, error)

	// SearchBatchPoints request with any body
	SearchBatchPointsWithBodyWithResponse(ctx context.Context, collectionName string, params *SearchBatchPointsParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*SearchBatchPointsResponse, error)

	SearchBatchPointsWithResponse(ctx context.Context, collectionName string, params *SearchBatchPointsParams, body SearchBatchPointsJSONRequestBody, reqEditors ...RequestEditorFn) (*SearchBatchPointsResponse, error)

	// GetPoint request
	GetPointWithResponse(ctx context.Context, collectionName string, id ExtendedPointId, params *GetPointParams, reqEditors ...RequestEditorFn) (*GetPointResponse, error)

	// ListSnapshots request
	ListSnapshotsWithResponse(ctx context.Context, collectionName string, reqEditors ...RequestEditorFn) (*ListSnapshotsResponse, error)

	// CreateSnapshot request
	CreateSnapshotWithResponse(ctx context.Context, collectionName string, reqEditors ...RequestEditorFn) (*CreateSnapshotResponse, error)

	// RecoverFromSnapshot request with any body
	RecoverFromSnapshotWithBodyWithResponse(ctx context.Context, collectionName string, params *RecoverFromSnapshotParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*RecoverFromSnapshotResponse, error)

	RecoverFromSnapshotWithResponse(ctx context.Context, collectionName string, params *RecoverFromSnapshotParams, body RecoverFromSnapshotJSONRequestBody, reqEditors ...RequestEditorFn) (*RecoverFromSnapshotResponse, error)

	// DeleteSnapshot request
	DeleteSnapshotWithResponse(ctx context.Context, collectionName string, snapshotName string, reqEditors ...RequestEditorFn) (*DeleteSnapshotResponse, error)

	// GetSnapshot request
	GetSnapshotWithResponse(ctx context.Context, collectionName string, snapshotName string, reqEditors ...RequestEditorFn) (*GetSnapshotResponse, error)

	// GetLocks request
	GetLocksWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*GetLocksResponse, error)

	// PostLocks request with any body
	PostLocksWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*PostLocksResponse, error)

	PostLocksWithResponse(ctx context.Context, body PostLocksJSONRequestBody, reqEditors ...RequestEditorFn) (*PostLocksResponse, error)

	// Metrics request
	MetricsWithResponse(ctx context.Context, params *MetricsParams, reqEditors ...RequestEditorFn) (*MetricsResponse, error)

	// ListFullSnapshots request
	ListFullSnapshotsWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ListFullSnapshotsResponse, error)

	// CreateFullSnapshot request
	CreateFullSnapshotWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*CreateFullSnapshotResponse, error)

	// DeleteFullSnapshot request
	DeleteFullSnapshotWithResponse(ctx context.Context, snapshotName string, reqEditors ...RequestEditorFn) (*DeleteFullSnapshotResponse, error)

	// GetFullSnapshot request
	GetFullSnapshotWithResponse(ctx context.Context, snapshotName string, reqEditors ...RequestEditorFn) (*GetFullSnapshotResponse, error)

	// Telemetry request
	TelemetryWithResponse(ctx context.Context, params *TelemetryParams, reqEditors ...RequestEditorFn) (*TelemetryResponse, error)
}

ClientWithResponsesInterface is the interface specification for the client with responses above.

type ClusterConfigTelemetry

type ClusterConfigTelemetry struct {
	Consensus     ConsensusConfigTelemetry `json:"consensus"`
	GrpcTimeoutMs uint64                   `json:"grpc_timeout_ms"`
	P2p           P2pConfigTelemetry       `json:"p2p"`
}

ClusterConfigTelemetry defines model for ClusterConfigTelemetry.

type ClusterOperations

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

ClusterOperations defines model for ClusterOperations.

func (ClusterOperations) AsAbortTransferOperation

func (t ClusterOperations) AsAbortTransferOperation() (AbortTransferOperation, error)

AsAbortTransferOperation returns the union data inside the ClusterOperations as a AbortTransferOperation

func (ClusterOperations) AsDropReplicaOperation

func (t ClusterOperations) AsDropReplicaOperation() (DropReplicaOperation, error)

AsDropReplicaOperation returns the union data inside the ClusterOperations as a DropReplicaOperation

func (ClusterOperations) AsMoveShardOperation

func (t ClusterOperations) AsMoveShardOperation() (MoveShardOperation, error)

AsMoveShardOperation returns the union data inside the ClusterOperations as a MoveShardOperation

func (ClusterOperations) AsReplicateShardOperation

func (t ClusterOperations) AsReplicateShardOperation() (ReplicateShardOperation, error)

AsReplicateShardOperation returns the union data inside the ClusterOperations as a ReplicateShardOperation

func (*ClusterOperations) FromAbortTransferOperation

func (t *ClusterOperations) FromAbortTransferOperation(v AbortTransferOperation) error

FromAbortTransferOperation overwrites any union data inside the ClusterOperations as the provided AbortTransferOperation

func (*ClusterOperations) FromDropReplicaOperation

func (t *ClusterOperations) FromDropReplicaOperation(v DropReplicaOperation) error

FromDropReplicaOperation overwrites any union data inside the ClusterOperations as the provided DropReplicaOperation

func (*ClusterOperations) FromMoveShardOperation

func (t *ClusterOperations) FromMoveShardOperation(v MoveShardOperation) error

FromMoveShardOperation overwrites any union data inside the ClusterOperations as the provided MoveShardOperation

func (*ClusterOperations) FromReplicateShardOperation

func (t *ClusterOperations) FromReplicateShardOperation(v ReplicateShardOperation) error

FromReplicateShardOperation overwrites any union data inside the ClusterOperations as the provided ReplicateShardOperation

func (ClusterOperations) MarshalJSON

func (t ClusterOperations) MarshalJSON() ([]byte, error)

func (*ClusterOperations) MergeAbortTransferOperation

func (t *ClusterOperations) MergeAbortTransferOperation(v AbortTransferOperation) error

MergeAbortTransferOperation performs a merge with any union data inside the ClusterOperations, using the provided AbortTransferOperation

func (*ClusterOperations) MergeDropReplicaOperation

func (t *ClusterOperations) MergeDropReplicaOperation(v DropReplicaOperation) error

MergeDropReplicaOperation performs a merge with any union data inside the ClusterOperations, using the provided DropReplicaOperation

func (*ClusterOperations) MergeMoveShardOperation

func (t *ClusterOperations) MergeMoveShardOperation(v MoveShardOperation) error

MergeMoveShardOperation performs a merge with any union data inside the ClusterOperations, using the provided MoveShardOperation

func (*ClusterOperations) MergeReplicateShardOperation

func (t *ClusterOperations) MergeReplicateShardOperation(v ReplicateShardOperation) error

MergeReplicateShardOperation performs a merge with any union data inside the ClusterOperations, using the provided ReplicateShardOperation

func (*ClusterOperations) UnmarshalJSON

func (t *ClusterOperations) UnmarshalJSON(b []byte) error

type ClusterStatus

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

ClusterStatus Information about current cluster status and structure

func (ClusterStatus) AsClusterStatus0

func (t ClusterStatus) AsClusterStatus0() (ClusterStatus0, error)

AsClusterStatus0 returns the union data inside the ClusterStatus as a ClusterStatus0

func (ClusterStatus) AsClusterStatus1

func (t ClusterStatus) AsClusterStatus1() (ClusterStatus1, error)

AsClusterStatus1 returns the union data inside the ClusterStatus as a ClusterStatus1

func (*ClusterStatus) FromClusterStatus0

func (t *ClusterStatus) FromClusterStatus0(v ClusterStatus0) error

FromClusterStatus0 overwrites any union data inside the ClusterStatus as the provided ClusterStatus0

func (*ClusterStatus) FromClusterStatus1

func (t *ClusterStatus) FromClusterStatus1(v ClusterStatus1) error

FromClusterStatus1 overwrites any union data inside the ClusterStatus as the provided ClusterStatus1

func (ClusterStatus) MarshalJSON

func (t ClusterStatus) MarshalJSON() ([]byte, error)

func (*ClusterStatus) MergeClusterStatus0

func (t *ClusterStatus) MergeClusterStatus0(v ClusterStatus0) error

MergeClusterStatus0 performs a merge with any union data inside the ClusterStatus, using the provided ClusterStatus0

func (*ClusterStatus) MergeClusterStatus1

func (t *ClusterStatus) MergeClusterStatus1(v ClusterStatus1) error

MergeClusterStatus1 performs a merge with any union data inside the ClusterStatus, using the provided ClusterStatus1

func (*ClusterStatus) UnmarshalJSON

func (t *ClusterStatus) UnmarshalJSON(b []byte) error

type ClusterStatus0

type ClusterStatus0 struct {
	Status ClusterStatus `json:"status"`
}

ClusterStatus0 defines model for .

type ClusterStatus1

type ClusterStatus1 struct {
	// ConsensusThreadStatus Information about current consensus thread status
	ConsensusThreadStatus ConsensusThreadStatus `json:"consensus_thread_status"`

	// MessageSendFailures Consequent failures of message send operations in consensus by peer address. On the first success to send to that peer - entry is removed from this hashmap.
	MessageSendFailures map[string]MessageSendErrors `json:"message_send_failures"`

	// PeerId ID of this peer
	PeerId uint64 `json:"peer_id"`

	// Peers Peers composition of the cluster with main information
	Peers map[string]PeerInfo `json:"peers"`

	// RaftInfo Summary information about the current raft state
	RaftInfo RaftInfo      `json:"raft_info"`
	Status   ClusterStatus `json:"status"`
}

ClusterStatus1 Description of enabled cluster

type ClusterStatusResponse

type ClusterStatusResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		// Result Information about current cluster status and structure
		Result *ClusterStatus `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseClusterStatusResponse

func ParseClusterStatusResponse(rsp *http.Response) (*ClusterStatusResponse, error)

ParseClusterStatusResponse parses an HTTP response from a ClusterStatusWithResponse call

func (ClusterStatusResponse) Status

func (r ClusterStatusResponse) Status() string

Status returns HTTPResponse.Status

func (ClusterStatusResponse) StatusCode

func (r ClusterStatusResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type ClusterStatusTelemetry

type ClusterStatusTelemetry struct {
	Commit uint64 `json:"commit"`

	// ConsensusThreadStatus Information about current consensus thread status
	ConsensusThreadStatus ConsensusThreadStatus        `json:"consensus_thread_status"`
	IsVoter               bool                         `json:"is_voter"`
	NumberOfPeers         uint                         `json:"number_of_peers"`
	PeerId                *uint64                      `json:"peer_id"`
	PendingOperations     uint                         `json:"pending_operations"`
	Role                  *ClusterStatusTelemetry_Role `json:"role,omitempty"`
	Term                  uint64                       `json:"term"`
}

ClusterStatusTelemetry defines model for ClusterStatusTelemetry.

type ClusterStatusTelemetryRole1

type ClusterStatusTelemetryRole1 = interface{}

ClusterStatusTelemetryRole1 defines model for .

type ClusterStatusTelemetry_Role

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

ClusterStatusTelemetry_Role defines model for ClusterStatusTelemetry.Role.

func (ClusterStatusTelemetry_Role) AsClusterStatusTelemetryRole1

func (t ClusterStatusTelemetry_Role) AsClusterStatusTelemetryRole1() (ClusterStatusTelemetryRole1, error)

AsClusterStatusTelemetryRole1 returns the union data inside the ClusterStatusTelemetry_Role as a ClusterStatusTelemetryRole1

func (ClusterStatusTelemetry_Role) AsStateRole

func (t ClusterStatusTelemetry_Role) AsStateRole() (StateRole, error)

AsStateRole returns the union data inside the ClusterStatusTelemetry_Role as a StateRole

func (*ClusterStatusTelemetry_Role) FromClusterStatusTelemetryRole1

func (t *ClusterStatusTelemetry_Role) FromClusterStatusTelemetryRole1(v ClusterStatusTelemetryRole1) error

FromClusterStatusTelemetryRole1 overwrites any union data inside the ClusterStatusTelemetry_Role as the provided ClusterStatusTelemetryRole1

func (*ClusterStatusTelemetry_Role) FromStateRole

func (t *ClusterStatusTelemetry_Role) FromStateRole(v StateRole) error

FromStateRole overwrites any union data inside the ClusterStatusTelemetry_Role as the provided StateRole

func (ClusterStatusTelemetry_Role) MarshalJSON

func (t ClusterStatusTelemetry_Role) MarshalJSON() ([]byte, error)

func (*ClusterStatusTelemetry_Role) MergeClusterStatusTelemetryRole1

func (t *ClusterStatusTelemetry_Role) MergeClusterStatusTelemetryRole1(v ClusterStatusTelemetryRole1) error

MergeClusterStatusTelemetryRole1 performs a merge with any union data inside the ClusterStatusTelemetry_Role, using the provided ClusterStatusTelemetryRole1

func (*ClusterStatusTelemetry_Role) MergeStateRole

func (t *ClusterStatusTelemetry_Role) MergeStateRole(v StateRole) error

MergeStateRole performs a merge with any union data inside the ClusterStatusTelemetry_Role, using the provided StateRole

func (*ClusterStatusTelemetry_Role) UnmarshalJSON

func (t *ClusterStatusTelemetry_Role) UnmarshalJSON(b []byte) error

type ClusterTelemetry

type ClusterTelemetry struct {
	Config  *ClusterTelemetry_Config `json:"config,omitempty"`
	Enabled bool                     `json:"enabled"`
	Status  *ClusterTelemetry_Status `json:"status,omitempty"`
}

ClusterTelemetry defines model for ClusterTelemetry.

type ClusterTelemetryConfig1

type ClusterTelemetryConfig1 = interface{}

ClusterTelemetryConfig1 defines model for .

type ClusterTelemetryStatus1

type ClusterTelemetryStatus1 = interface{}

ClusterTelemetryStatus1 defines model for .

type ClusterTelemetry_Config

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

ClusterTelemetry_Config defines model for ClusterTelemetry.Config.

func (ClusterTelemetry_Config) AsClusterConfigTelemetry

func (t ClusterTelemetry_Config) AsClusterConfigTelemetry() (ClusterConfigTelemetry, error)

AsClusterConfigTelemetry returns the union data inside the ClusterTelemetry_Config as a ClusterConfigTelemetry

func (ClusterTelemetry_Config) AsClusterTelemetryConfig1

func (t ClusterTelemetry_Config) AsClusterTelemetryConfig1() (ClusterTelemetryConfig1, error)

AsClusterTelemetryConfig1 returns the union data inside the ClusterTelemetry_Config as a ClusterTelemetryConfig1

func (*ClusterTelemetry_Config) FromClusterConfigTelemetry

func (t *ClusterTelemetry_Config) FromClusterConfigTelemetry(v ClusterConfigTelemetry) error

FromClusterConfigTelemetry overwrites any union data inside the ClusterTelemetry_Config as the provided ClusterConfigTelemetry

func (*ClusterTelemetry_Config) FromClusterTelemetryConfig1

func (t *ClusterTelemetry_Config) FromClusterTelemetryConfig1(v ClusterTelemetryConfig1) error

FromClusterTelemetryConfig1 overwrites any union data inside the ClusterTelemetry_Config as the provided ClusterTelemetryConfig1

func (ClusterTelemetry_Config) MarshalJSON

func (t ClusterTelemetry_Config) MarshalJSON() ([]byte, error)

func (*ClusterTelemetry_Config) MergeClusterConfigTelemetry

func (t *ClusterTelemetry_Config) MergeClusterConfigTelemetry(v ClusterConfigTelemetry) error

MergeClusterConfigTelemetry performs a merge with any union data inside the ClusterTelemetry_Config, using the provided ClusterConfigTelemetry

func (*ClusterTelemetry_Config) MergeClusterTelemetryConfig1

func (t *ClusterTelemetry_Config) MergeClusterTelemetryConfig1(v ClusterTelemetryConfig1) error

MergeClusterTelemetryConfig1 performs a merge with any union data inside the ClusterTelemetry_Config, using the provided ClusterTelemetryConfig1

func (*ClusterTelemetry_Config) UnmarshalJSON

func (t *ClusterTelemetry_Config) UnmarshalJSON(b []byte) error

type ClusterTelemetry_Status

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

ClusterTelemetry_Status defines model for ClusterTelemetry.Status.

func (ClusterTelemetry_Status) AsClusterStatusTelemetry

func (t ClusterTelemetry_Status) AsClusterStatusTelemetry() (ClusterStatusTelemetry, error)

AsClusterStatusTelemetry returns the union data inside the ClusterTelemetry_Status as a ClusterStatusTelemetry

func (ClusterTelemetry_Status) AsClusterTelemetryStatus1

func (t ClusterTelemetry_Status) AsClusterTelemetryStatus1() (ClusterTelemetryStatus1, error)

AsClusterTelemetryStatus1 returns the union data inside the ClusterTelemetry_Status as a ClusterTelemetryStatus1

func (*ClusterTelemetry_Status) FromClusterStatusTelemetry

func (t *ClusterTelemetry_Status) FromClusterStatusTelemetry(v ClusterStatusTelemetry) error

FromClusterStatusTelemetry overwrites any union data inside the ClusterTelemetry_Status as the provided ClusterStatusTelemetry

func (*ClusterTelemetry_Status) FromClusterTelemetryStatus1

func (t *ClusterTelemetry_Status) FromClusterTelemetryStatus1(v ClusterTelemetryStatus1) error

FromClusterTelemetryStatus1 overwrites any union data inside the ClusterTelemetry_Status as the provided ClusterTelemetryStatus1

func (ClusterTelemetry_Status) MarshalJSON

func (t ClusterTelemetry_Status) MarshalJSON() ([]byte, error)

func (*ClusterTelemetry_Status) MergeClusterStatusTelemetry

func (t *ClusterTelemetry_Status) MergeClusterStatusTelemetry(v ClusterStatusTelemetry) error

MergeClusterStatusTelemetry performs a merge with any union data inside the ClusterTelemetry_Status, using the provided ClusterStatusTelemetry

func (*ClusterTelemetry_Status) MergeClusterTelemetryStatus1

func (t *ClusterTelemetry_Status) MergeClusterTelemetryStatus1(v ClusterTelemetryStatus1) error

MergeClusterTelemetryStatus1 performs a merge with any union data inside the ClusterTelemetry_Status, using the provided ClusterTelemetryStatus1

func (*ClusterTelemetry_Status) UnmarshalJSON

func (t *ClusterTelemetry_Status) UnmarshalJSON(b []byte) error

type CollectionClusterInfo

type CollectionClusterInfo struct {
	// LocalShards Local shards
	LocalShards []LocalShardInfo `json:"local_shards"`

	// PeerId ID of this peer
	PeerId uint64 `json:"peer_id"`

	// RemoteShards Remote shards
	RemoteShards []RemoteShardInfo `json:"remote_shards"`

	// ShardCount Total number of shards
	ShardCount uint `json:"shard_count"`

	// ShardTransfers Shard transfers
	ShardTransfers []ShardTransferInfo `json:"shard_transfers"`
}

CollectionClusterInfo Current clustering distribution for the collection

type CollectionClusterInfoResponse

type CollectionClusterInfoResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		// Result Current clustering distribution for the collection
		Result *CollectionClusterInfo `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseCollectionClusterInfoResponse

func ParseCollectionClusterInfoResponse(rsp *http.Response) (*CollectionClusterInfoResponse, error)

ParseCollectionClusterInfoResponse parses an HTTP response from a CollectionClusterInfoWithResponse call

func (CollectionClusterInfoResponse) Status

Status returns HTTPResponse.Status

func (CollectionClusterInfoResponse) StatusCode

func (r CollectionClusterInfoResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type CollectionConfig

type CollectionConfig struct {
	// HnswConfig Config of HNSW index
	HnswConfig         HnswConfig                           `json:"hnsw_config"`
	OptimizerConfig    OptimizersConfig                     `json:"optimizer_config"`
	Params             CollectionParams                     `json:"params"`
	QuantizationConfig *CollectionConfig_QuantizationConfig `json:"quantization_config,omitempty"`
	WalConfig          WalConfig                            `json:"wal_config"`
}

CollectionConfig defines model for CollectionConfig.

type CollectionConfigQuantizationConfig1

type CollectionConfigQuantizationConfig1 = interface{}

CollectionConfigQuantizationConfig1 defines model for .

type CollectionConfig_QuantizationConfig

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

CollectionConfig_QuantizationConfig defines model for CollectionConfig.QuantizationConfig.

func (CollectionConfig_QuantizationConfig) AsCollectionConfigQuantizationConfig1

func (t CollectionConfig_QuantizationConfig) AsCollectionConfigQuantizationConfig1() (CollectionConfigQuantizationConfig1, error)

AsCollectionConfigQuantizationConfig1 returns the union data inside the CollectionConfig_QuantizationConfig as a CollectionConfigQuantizationConfig1

func (CollectionConfig_QuantizationConfig) AsQuantizationConfig

func (t CollectionConfig_QuantizationConfig) AsQuantizationConfig() (QuantizationConfig, error)

AsQuantizationConfig returns the union data inside the CollectionConfig_QuantizationConfig as a QuantizationConfig

func (*CollectionConfig_QuantizationConfig) FromCollectionConfigQuantizationConfig1

func (t *CollectionConfig_QuantizationConfig) FromCollectionConfigQuantizationConfig1(v CollectionConfigQuantizationConfig1) error

FromCollectionConfigQuantizationConfig1 overwrites any union data inside the CollectionConfig_QuantizationConfig as the provided CollectionConfigQuantizationConfig1

func (*CollectionConfig_QuantizationConfig) FromQuantizationConfig

func (t *CollectionConfig_QuantizationConfig) FromQuantizationConfig(v QuantizationConfig) error

FromQuantizationConfig overwrites any union data inside the CollectionConfig_QuantizationConfig as the provided QuantizationConfig

func (CollectionConfig_QuantizationConfig) MarshalJSON

func (t CollectionConfig_QuantizationConfig) MarshalJSON() ([]byte, error)

func (*CollectionConfig_QuantizationConfig) MergeCollectionConfigQuantizationConfig1

func (t *CollectionConfig_QuantizationConfig) MergeCollectionConfigQuantizationConfig1(v CollectionConfigQuantizationConfig1) error

MergeCollectionConfigQuantizationConfig1 performs a merge with any union data inside the CollectionConfig_QuantizationConfig, using the provided CollectionConfigQuantizationConfig1

func (*CollectionConfig_QuantizationConfig) MergeQuantizationConfig

func (t *CollectionConfig_QuantizationConfig) MergeQuantizationConfig(v QuantizationConfig) error

MergeQuantizationConfig performs a merge with any union data inside the CollectionConfig_QuantizationConfig, using the provided QuantizationConfig

func (*CollectionConfig_QuantizationConfig) UnmarshalJSON

func (t *CollectionConfig_QuantizationConfig) UnmarshalJSON(b []byte) error

type CollectionDescription

type CollectionDescription struct {
	Name string `json:"name"`
}

CollectionDescription defines model for CollectionDescription.

type CollectionInfo

type CollectionInfo struct {
	Config CollectionConfig `json:"config"`

	// IndexedVectorsCount Number of indexed vectors in the collection. Indexed vectors in large segments are faster to query, as it is stored in vector index (HNSW)
	IndexedVectorsCount uint `json:"indexed_vectors_count"`

	// OptimizerStatus Current state of the collection
	OptimizerStatus OptimizersStatus `json:"optimizer_status"`

	// PayloadSchema Types of stored payload
	PayloadSchema map[string]PayloadIndexInfo `json:"payload_schema"`

	// PointsCount Number of points (vectors + payloads) in collection Each point could be accessed by unique id
	PointsCount uint `json:"points_count"`

	// SegmentsCount Number of segments in collection. Each segment has independent vector as payload indexes
	SegmentsCount uint `json:"segments_count"`

	// Status Current state of the collection. `Green` - all good. `Yellow` - optimization is running, `Red` - some operations failed and was not recovered
	Status CollectionStatus `json:"status"`

	// VectorsCount Number of vectors in collection All vectors in collection are available for querying Calculated as `points_count x vectors_per_point` Where `vectors_per_point` is a number of named vectors in schema
	VectorsCount uint `json:"vectors_count"`
}

CollectionInfo Current statistics and configuration of the collection

type CollectionParams

type CollectionParams struct {
	// OnDiskPayload If true - point's payload will not be stored in memory. It will be read from the disk every time it is requested. This setting saves RAM by (slightly) increasing the response time. Note: those payload values that are involved in filtering and are indexed - remain in RAM.
	OnDiskPayload *bool `json:"on_disk_payload,omitempty"`

	// ReplicationFactor Number of replicas for each shard
	ReplicationFactor *uint32 `json:"replication_factor,omitempty"`

	// ShardNumber Number of shards the collection has
	ShardNumber *uint32 `json:"shard_number,omitempty"`

	// Vectors Vector params separator for single and multiple vector modes Single mode:
	//
	// { "size": 128, "distance": "Cosine" }
	//
	// or multiple mode:
	//
	// { "default": { "size": 128, "distance": "Cosine" } }
	Vectors VectorsConfig `json:"vectors"`

	// WriteConsistencyFactor Defines how many replicas should apply the operation for us to consider it successful. Increasing this number will make the collection more resilient to inconsistencies, but will also make it fail if not enough replicas are available. Does not have any performance impact.
	WriteConsistencyFactor *uint32 `json:"write_consistency_factor,omitempty"`
}

CollectionParams defines model for CollectionParams.

type CollectionParamsDiff

type CollectionParamsDiff struct {
	// ReplicationFactor Number of replicas for each shard
	ReplicationFactor *uint32 `json:"replication_factor"`

	// WriteConsistencyFactor Minimal number successful responses from replicas to consider operation successful
	WriteConsistencyFactor *uint32 `json:"write_consistency_factor"`
}

CollectionParamsDiff defines model for CollectionParamsDiff.

type CollectionStatus

type CollectionStatus string

CollectionStatus Current state of the collection. `Green` - all good. `Yellow` - optimization is running, `Red` - some operations failed and was not recovered

const (
	Green  CollectionStatus = "green"
	Red    CollectionStatus = "red"
	Yellow CollectionStatus = "yellow"
)

Defines values for CollectionStatus.

type CollectionTelemetry

type CollectionTelemetry struct {
	Config     CollectionConfig      `json:"config"`
	Id         string                `json:"id"`
	InitTimeMs uint64                `json:"init_time_ms"`
	Shards     []ReplicaSetTelemetry `json:"shards"`
	Transfers  []ShardTransferInfo   `json:"transfers"`
}

CollectionTelemetry defines model for CollectionTelemetry.

type CollectionTelemetryEnum

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

CollectionTelemetryEnum defines model for CollectionTelemetryEnum.

func (CollectionTelemetryEnum) AsCollectionTelemetry

func (t CollectionTelemetryEnum) AsCollectionTelemetry() (CollectionTelemetry, error)

AsCollectionTelemetry returns the union data inside the CollectionTelemetryEnum as a CollectionTelemetry

func (CollectionTelemetryEnum) AsCollectionsAggregatedTelemetry

func (t CollectionTelemetryEnum) AsCollectionsAggregatedTelemetry() (CollectionsAggregatedTelemetry, error)

AsCollectionsAggregatedTelemetry returns the union data inside the CollectionTelemetryEnum as a CollectionsAggregatedTelemetry

func (*CollectionTelemetryEnum) FromCollectionTelemetry

func (t *CollectionTelemetryEnum) FromCollectionTelemetry(v CollectionTelemetry) error

FromCollectionTelemetry overwrites any union data inside the CollectionTelemetryEnum as the provided CollectionTelemetry

func (*CollectionTelemetryEnum) FromCollectionsAggregatedTelemetry

func (t *CollectionTelemetryEnum) FromCollectionsAggregatedTelemetry(v CollectionsAggregatedTelemetry) error

FromCollectionsAggregatedTelemetry overwrites any union data inside the CollectionTelemetryEnum as the provided CollectionsAggregatedTelemetry

func (CollectionTelemetryEnum) MarshalJSON

func (t CollectionTelemetryEnum) MarshalJSON() ([]byte, error)

func (*CollectionTelemetryEnum) MergeCollectionTelemetry

func (t *CollectionTelemetryEnum) MergeCollectionTelemetry(v CollectionTelemetry) error

MergeCollectionTelemetry performs a merge with any union data inside the CollectionTelemetryEnum, using the provided CollectionTelemetry

func (*CollectionTelemetryEnum) MergeCollectionsAggregatedTelemetry

func (t *CollectionTelemetryEnum) MergeCollectionsAggregatedTelemetry(v CollectionsAggregatedTelemetry) error

MergeCollectionsAggregatedTelemetry performs a merge with any union data inside the CollectionTelemetryEnum, using the provided CollectionsAggregatedTelemetry

func (*CollectionTelemetryEnum) UnmarshalJSON

func (t *CollectionTelemetryEnum) UnmarshalJSON(b []byte) error

type CollectionsAggregatedTelemetry

type CollectionsAggregatedTelemetry struct {
	// OptimizersStatus Current state of the collection
	OptimizersStatus OptimizersStatus `json:"optimizers_status"`
	Params           CollectionParams `json:"params"`
	Vectors          uint             `json:"vectors"`
}

CollectionsAggregatedTelemetry defines model for CollectionsAggregatedTelemetry.

type CollectionsAliasesResponse

type CollectionsAliasesResponse struct {
	Aliases []AliasDescription `json:"aliases"`
}

CollectionsAliasesResponse defines model for CollectionsAliasesResponse.

type CollectionsResponse

type CollectionsResponse struct {
	Collections []CollectionDescription `json:"collections"`
}

CollectionsResponse defines model for CollectionsResponse.

type CollectionsTelemetry

type CollectionsTelemetry struct {
	Collections         *[]CollectionTelemetryEnum `json:"collections"`
	NumberOfCollections uint                       `json:"number_of_collections"`
}

CollectionsTelemetry defines model for CollectionsTelemetry.

type Condition

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

Condition defines model for Condition.

func (Condition) AsFieldCondition

func (t Condition) AsFieldCondition() (FieldCondition, error)

AsFieldCondition returns the union data inside the Condition as a FieldCondition

func (Condition) AsFilter

func (t Condition) AsFilter() (Filter, error)

AsFilter returns the union data inside the Condition as a Filter

func (Condition) AsHasIdCondition

func (t Condition) AsHasIdCondition() (HasIdCondition, error)

AsHasIdCondition returns the union data inside the Condition as a HasIdCondition

func (Condition) AsIsEmptyCondition

func (t Condition) AsIsEmptyCondition() (IsEmptyCondition, error)

AsIsEmptyCondition returns the union data inside the Condition as a IsEmptyCondition

func (*Condition) FromFieldCondition

func (t *Condition) FromFieldCondition(v FieldCondition) error

FromFieldCondition overwrites any union data inside the Condition as the provided FieldCondition

func (*Condition) FromFilter

func (t *Condition) FromFilter(v Filter) error

FromFilter overwrites any union data inside the Condition as the provided Filter

func (*Condition) FromHasIdCondition

func (t *Condition) FromHasIdCondition(v HasIdCondition) error

FromHasIdCondition overwrites any union data inside the Condition as the provided HasIdCondition

func (*Condition) FromIsEmptyCondition

func (t *Condition) FromIsEmptyCondition(v IsEmptyCondition) error

FromIsEmptyCondition overwrites any union data inside the Condition as the provided IsEmptyCondition

func (Condition) MarshalJSON

func (t Condition) MarshalJSON() ([]byte, error)

func (*Condition) MergeFieldCondition

func (t *Condition) MergeFieldCondition(v FieldCondition) error

MergeFieldCondition performs a merge with any union data inside the Condition, using the provided FieldCondition

func (*Condition) MergeFilter

func (t *Condition) MergeFilter(v Filter) error

MergeFilter performs a merge with any union data inside the Condition, using the provided Filter

func (*Condition) MergeHasIdCondition

func (t *Condition) MergeHasIdCondition(v HasIdCondition) error

MergeHasIdCondition performs a merge with any union data inside the Condition, using the provided HasIdCondition

func (*Condition) MergeIsEmptyCondition

func (t *Condition) MergeIsEmptyCondition(v IsEmptyCondition) error

MergeIsEmptyCondition performs a merge with any union data inside the Condition, using the provided IsEmptyCondition

func (*Condition) UnmarshalJSON

func (t *Condition) UnmarshalJSON(b []byte) error

type ConsensusConfigTelemetry

type ConsensusConfigTelemetry struct {
	BootstrapTimeoutSec uint64 `json:"bootstrap_timeout_sec"`
	MaxMessageQueueSize uint   `json:"max_message_queue_size"`
	TickPeriodMs        uint64 `json:"tick_period_ms"`
}

ConsensusConfigTelemetry defines model for ConsensusConfigTelemetry.

type ConsensusThreadStatus

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

ConsensusThreadStatus Information about current consensus thread status

func (ConsensusThreadStatus) AsConsensusThreadStatus0

func (t ConsensusThreadStatus) AsConsensusThreadStatus0() (ConsensusThreadStatus0, error)

AsConsensusThreadStatus0 returns the union data inside the ConsensusThreadStatus as a ConsensusThreadStatus0

func (ConsensusThreadStatus) AsConsensusThreadStatus1

func (t ConsensusThreadStatus) AsConsensusThreadStatus1() (ConsensusThreadStatus1, error)

AsConsensusThreadStatus1 returns the union data inside the ConsensusThreadStatus as a ConsensusThreadStatus1

func (ConsensusThreadStatus) AsConsensusThreadStatus2

func (t ConsensusThreadStatus) AsConsensusThreadStatus2() (ConsensusThreadStatus2, error)

AsConsensusThreadStatus2 returns the union data inside the ConsensusThreadStatus as a ConsensusThreadStatus2

func (*ConsensusThreadStatus) FromConsensusThreadStatus0

func (t *ConsensusThreadStatus) FromConsensusThreadStatus0(v ConsensusThreadStatus0) error

FromConsensusThreadStatus0 overwrites any union data inside the ConsensusThreadStatus as the provided ConsensusThreadStatus0

func (*ConsensusThreadStatus) FromConsensusThreadStatus1

func (t *ConsensusThreadStatus) FromConsensusThreadStatus1(v ConsensusThreadStatus1) error

FromConsensusThreadStatus1 overwrites any union data inside the ConsensusThreadStatus as the provided ConsensusThreadStatus1

func (*ConsensusThreadStatus) FromConsensusThreadStatus2

func (t *ConsensusThreadStatus) FromConsensusThreadStatus2(v ConsensusThreadStatus2) error

FromConsensusThreadStatus2 overwrites any union data inside the ConsensusThreadStatus as the provided ConsensusThreadStatus2

func (ConsensusThreadStatus) MarshalJSON

func (t ConsensusThreadStatus) MarshalJSON() ([]byte, error)

func (*ConsensusThreadStatus) MergeConsensusThreadStatus0

func (t *ConsensusThreadStatus) MergeConsensusThreadStatus0(v ConsensusThreadStatus0) error

MergeConsensusThreadStatus0 performs a merge with any union data inside the ConsensusThreadStatus, using the provided ConsensusThreadStatus0

func (*ConsensusThreadStatus) MergeConsensusThreadStatus1

func (t *ConsensusThreadStatus) MergeConsensusThreadStatus1(v ConsensusThreadStatus1) error

MergeConsensusThreadStatus1 performs a merge with any union data inside the ConsensusThreadStatus, using the provided ConsensusThreadStatus1

func (*ConsensusThreadStatus) MergeConsensusThreadStatus2

func (t *ConsensusThreadStatus) MergeConsensusThreadStatus2(v ConsensusThreadStatus2) error

MergeConsensusThreadStatus2 performs a merge with any union data inside the ConsensusThreadStatus, using the provided ConsensusThreadStatus2

func (*ConsensusThreadStatus) UnmarshalJSON

func (t *ConsensusThreadStatus) UnmarshalJSON(b []byte) error

type ConsensusThreadStatus0

type ConsensusThreadStatus0 struct {
	ConsensusThreadStatus ConsensusThreadStatus `json:"consensus_thread_status"`
	LastUpdate            time.Time             `json:"last_update"`
}

ConsensusThreadStatus0 defines model for .

type ConsensusThreadStatus1

type ConsensusThreadStatus1 struct {
	ConsensusThreadStatus ConsensusThreadStatus `json:"consensus_thread_status"`
}

ConsensusThreadStatus1 defines model for .

type ConsensusThreadStatus2

type ConsensusThreadStatus2 struct {
	ConsensusThreadStatus ConsensusThreadStatus `json:"consensus_thread_status"`
	Err                   string                `json:"err"`
}

ConsensusThreadStatus2 defines model for .

type CountPointsJSONRequestBody

type CountPointsJSONRequestBody = CountRequest

CountPointsJSONRequestBody defines body for CountPoints for application/json ContentType.

type CountPointsResponse

type CountPointsResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		Result *CountResult `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseCountPointsResponse

func ParseCountPointsResponse(rsp *http.Response) (*CountPointsResponse, error)

ParseCountPointsResponse parses an HTTP response from a CountPointsWithResponse call

func (CountPointsResponse) Status

func (r CountPointsResponse) Status() string

Status returns HTTPResponse.Status

func (CountPointsResponse) StatusCode

func (r CountPointsResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type CountRequest

type CountRequest struct {
	// Exact If true, count exact number of points. If false, count approximate number of points faster. Approximate count might be unreliable during the indexing process. Default: true
	Exact *bool `json:"exact,omitempty"`

	// Filter Look only for points which satisfies this conditions
	Filter *SearchRequest_Filter `json:"filter,omitempty"`
}

CountRequest Count Request Counts the number of points which satisfy the given filter. If filter is not provided, the count of all points in the collection will be returned.

type CountRequestFilter1

type CountRequestFilter1 = interface{}

CountRequestFilter1 defines model for .

type CountRequest_Filter

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

CountRequest_Filter Look only for points which satisfies this conditions

func (CountRequest_Filter) AsCountRequestFilter1

func (t CountRequest_Filter) AsCountRequestFilter1() (CountRequestFilter1, error)

AsCountRequestFilter1 returns the union data inside the CountRequest_Filter as a CountRequestFilter1

func (CountRequest_Filter) AsFilter

func (t CountRequest_Filter) AsFilter() (Filter, error)

AsFilter returns the union data inside the CountRequest_Filter as a Filter

func (*CountRequest_Filter) FromCountRequestFilter1

func (t *CountRequest_Filter) FromCountRequestFilter1(v CountRequestFilter1) error

FromCountRequestFilter1 overwrites any union data inside the CountRequest_Filter as the provided CountRequestFilter1

func (*CountRequest_Filter) FromFilter

func (t *CountRequest_Filter) FromFilter(v Filter) error

FromFilter overwrites any union data inside the CountRequest_Filter as the provided Filter

func (CountRequest_Filter) MarshalJSON

func (t CountRequest_Filter) MarshalJSON() ([]byte, error)

func (*CountRequest_Filter) MergeCountRequestFilter1

func (t *CountRequest_Filter) MergeCountRequestFilter1(v CountRequestFilter1) error

MergeCountRequestFilter1 performs a merge with any union data inside the CountRequest_Filter, using the provided CountRequestFilter1

func (*CountRequest_Filter) MergeFilter

func (t *CountRequest_Filter) MergeFilter(v Filter) error

MergeFilter performs a merge with any union data inside the CountRequest_Filter, using the provided Filter

func (*CountRequest_Filter) UnmarshalJSON

func (t *CountRequest_Filter) UnmarshalJSON(b []byte) error

type CountResult

type CountResult struct {
	// Count Number of points which satisfy the conditions
	Count uint `json:"count"`
}

CountResult defines model for CountResult.

type CreateAlias

type CreateAlias struct {
	AliasName      string `json:"alias_name"`
	CollectionName string `json:"collection_name"`
}

CreateAlias Create alternative name for a collection. Collection will be available under both names for search, retrieve,

type CreateAliasOperation

type CreateAliasOperation struct {
	// CreateAlias Create alternative name for a collection. Collection will be available under both names for search, retrieve,
	CreateAlias CreateAlias `json:"create_alias"`
}

CreateAliasOperation defines model for CreateAliasOperation.

type CreateCollection

type CreateCollection struct {
	// HnswConfig Custom params for HNSW index. If none - values from service configuration file are used.
	HnswConfig *CreateCollection_HnswConfig `json:"hnsw_config,omitempty"`

	// InitFrom Specify other collection to copy data from.
	InitFrom *CreateCollection_InitFrom `json:"init_from,omitempty"`

	// OnDiskPayload If true - point's payload will not be stored in memory. It will be read from the disk every time it is requested. This setting saves RAM by (slightly) increasing the response time. Note: those payload values that are involved in filtering and are indexed - remain in RAM.
	OnDiskPayload *bool `json:"on_disk_payload"`

	// OptimizersConfig Custom params for Optimizers.  If none - values from service configuration file are used.
	OptimizersConfig *CreateCollection_OptimizersConfig `json:"optimizers_config,omitempty"`

	// QuantizationConfig Quantization parameters. If none - quantization is disabled.
	QuantizationConfig *CreateCollection_QuantizationConfig `json:"quantization_config,omitempty"`

	// ReplicationFactor Number of shards replicas. Default is 1 Minimum is 1
	ReplicationFactor *uint32 `json:"replication_factor"`

	// ShardNumber Number of shards in collection. Default is 1 for standalone, otherwise equal to the number of nodes Minimum is 1
	ShardNumber *uint32 `json:"shard_number"`

	// Vectors Vector params separator for single and multiple vector modes Single mode:
	//
	// { "size": 128, "distance": "Cosine" }
	//
	// or multiple mode:
	//
	// { "default": { "size": 128, "distance": "Cosine" } }
	Vectors VectorsConfig `json:"vectors"`

	// WalConfig Custom params for WAL. If none - values from service configuration file are used.
	WalConfig *CreateCollection_WalConfig `json:"wal_config,omitempty"`

	// WriteConsistencyFactor Defines how many replicas should apply the operation for us to consider it successful. Increasing this number will make the collection more resilient to inconsistencies, but will also make it fail if not enough replicas are available. Does not have any performance impact.
	WriteConsistencyFactor *uint32 `json:"write_consistency_factor"`
}

CreateCollection Operation for creating new collection and (optionally) specify index params

type CreateCollectionHnswConfig1

type CreateCollectionHnswConfig1 = interface{}

CreateCollectionHnswConfig1 defines model for .

type CreateCollectionInitFrom1

type CreateCollectionInitFrom1 = interface{}

CreateCollectionInitFrom1 defines model for .

type CreateCollectionJSONRequestBody

type CreateCollectionJSONRequestBody = CreateCollection

CreateCollectionJSONRequestBody defines body for CreateCollection for application/json ContentType.

type CreateCollectionOptimizersConfig1

type CreateCollectionOptimizersConfig1 = interface{}

CreateCollectionOptimizersConfig1 defines model for .

type CreateCollectionParams

type CreateCollectionParams struct {
	// Timeout Wait for operation commit timeout in seconds.
	// If timeout is reached - request will return with service error.
	Timeout *int `form:"timeout,omitempty" json:"timeout,omitempty"`
}

CreateCollectionParams defines parameters for CreateCollection.

type CreateCollectionQuantizationConfig1

type CreateCollectionQuantizationConfig1 = interface{}

CreateCollectionQuantizationConfig1 defines model for .

type CreateCollectionResponse

type CreateCollectionResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		Result *bool `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseCreateCollectionResponse

func ParseCreateCollectionResponse(rsp *http.Response) (*CreateCollectionResponse, error)

ParseCreateCollectionResponse parses an HTTP response from a CreateCollectionWithResponse call

func (CreateCollectionResponse) Status

func (r CreateCollectionResponse) Status() string

Status returns HTTPResponse.Status

func (CreateCollectionResponse) StatusCode

func (r CreateCollectionResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type CreateCollectionWalConfig1

type CreateCollectionWalConfig1 = interface{}

CreateCollectionWalConfig1 defines model for .

type CreateCollection_HnswConfig

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

CreateCollection_HnswConfig Custom params for HNSW index. If none - values from service configuration file are used.

func (CreateCollection_HnswConfig) AsCreateCollectionHnswConfig1

func (t CreateCollection_HnswConfig) AsCreateCollectionHnswConfig1() (CreateCollectionHnswConfig1, error)

AsCreateCollectionHnswConfig1 returns the union data inside the CreateCollection_HnswConfig as a CreateCollectionHnswConfig1

func (CreateCollection_HnswConfig) AsHnswConfigDiff

func (t CreateCollection_HnswConfig) AsHnswConfigDiff() (HnswConfigDiff, error)

AsHnswConfigDiff returns the union data inside the CreateCollection_HnswConfig as a HnswConfigDiff

func (*CreateCollection_HnswConfig) FromCreateCollectionHnswConfig1

func (t *CreateCollection_HnswConfig) FromCreateCollectionHnswConfig1(v CreateCollectionHnswConfig1) error

FromCreateCollectionHnswConfig1 overwrites any union data inside the CreateCollection_HnswConfig as the provided CreateCollectionHnswConfig1

func (*CreateCollection_HnswConfig) FromHnswConfigDiff

func (t *CreateCollection_HnswConfig) FromHnswConfigDiff(v HnswConfigDiff) error

FromHnswConfigDiff overwrites any union data inside the CreateCollection_HnswConfig as the provided HnswConfigDiff

func (CreateCollection_HnswConfig) MarshalJSON

func (t CreateCollection_HnswConfig) MarshalJSON() ([]byte, error)

func (*CreateCollection_HnswConfig) MergeCreateCollectionHnswConfig1

func (t *CreateCollection_HnswConfig) MergeCreateCollectionHnswConfig1(v CreateCollectionHnswConfig1) error

MergeCreateCollectionHnswConfig1 performs a merge with any union data inside the CreateCollection_HnswConfig, using the provided CreateCollectionHnswConfig1

func (*CreateCollection_HnswConfig) MergeHnswConfigDiff

func (t *CreateCollection_HnswConfig) MergeHnswConfigDiff(v HnswConfigDiff) error

MergeHnswConfigDiff performs a merge with any union data inside the CreateCollection_HnswConfig, using the provided HnswConfigDiff

func (*CreateCollection_HnswConfig) UnmarshalJSON

func (t *CreateCollection_HnswConfig) UnmarshalJSON(b []byte) error

type CreateCollection_InitFrom

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

CreateCollection_InitFrom Specify other collection to copy data from.

func (CreateCollection_InitFrom) AsCreateCollectionInitFrom1

func (t CreateCollection_InitFrom) AsCreateCollectionInitFrom1() (CreateCollectionInitFrom1, error)

AsCreateCollectionInitFrom1 returns the union data inside the CreateCollection_InitFrom as a CreateCollectionInitFrom1

func (CreateCollection_InitFrom) AsInitFrom

func (t CreateCollection_InitFrom) AsInitFrom() (InitFrom, error)

AsInitFrom returns the union data inside the CreateCollection_InitFrom as a InitFrom

func (*CreateCollection_InitFrom) FromCreateCollectionInitFrom1

func (t *CreateCollection_InitFrom) FromCreateCollectionInitFrom1(v CreateCollectionInitFrom1) error

FromCreateCollectionInitFrom1 overwrites any union data inside the CreateCollection_InitFrom as the provided CreateCollectionInitFrom1

func (*CreateCollection_InitFrom) FromInitFrom

func (t *CreateCollection_InitFrom) FromInitFrom(v InitFrom) error

FromInitFrom overwrites any union data inside the CreateCollection_InitFrom as the provided InitFrom

func (CreateCollection_InitFrom) MarshalJSON

func (t CreateCollection_InitFrom) MarshalJSON() ([]byte, error)

func (*CreateCollection_InitFrom) MergeCreateCollectionInitFrom1

func (t *CreateCollection_InitFrom) MergeCreateCollectionInitFrom1(v CreateCollectionInitFrom1) error

MergeCreateCollectionInitFrom1 performs a merge with any union data inside the CreateCollection_InitFrom, using the provided CreateCollectionInitFrom1

func (*CreateCollection_InitFrom) MergeInitFrom

func (t *CreateCollection_InitFrom) MergeInitFrom(v InitFrom) error

MergeInitFrom performs a merge with any union data inside the CreateCollection_InitFrom, using the provided InitFrom

func (*CreateCollection_InitFrom) UnmarshalJSON

func (t *CreateCollection_InitFrom) UnmarshalJSON(b []byte) error

type CreateCollection_OptimizersConfig

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

CreateCollection_OptimizersConfig Custom params for Optimizers. If none - values from service configuration file are used.

func (CreateCollection_OptimizersConfig) AsCreateCollectionOptimizersConfig1

func (t CreateCollection_OptimizersConfig) AsCreateCollectionOptimizersConfig1() (CreateCollectionOptimizersConfig1, error)

AsCreateCollectionOptimizersConfig1 returns the union data inside the CreateCollection_OptimizersConfig as a CreateCollectionOptimizersConfig1

func (CreateCollection_OptimizersConfig) AsOptimizersConfigDiff

func (t CreateCollection_OptimizersConfig) AsOptimizersConfigDiff() (OptimizersConfigDiff, error)

AsOptimizersConfigDiff returns the union data inside the CreateCollection_OptimizersConfig as a OptimizersConfigDiff

func (*CreateCollection_OptimizersConfig) FromCreateCollectionOptimizersConfig1

func (t *CreateCollection_OptimizersConfig) FromCreateCollectionOptimizersConfig1(v CreateCollectionOptimizersConfig1) error

FromCreateCollectionOptimizersConfig1 overwrites any union data inside the CreateCollection_OptimizersConfig as the provided CreateCollectionOptimizersConfig1

func (*CreateCollection_OptimizersConfig) FromOptimizersConfigDiff

func (t *CreateCollection_OptimizersConfig) FromOptimizersConfigDiff(v OptimizersConfigDiff) error

FromOptimizersConfigDiff overwrites any union data inside the CreateCollection_OptimizersConfig as the provided OptimizersConfigDiff

func (CreateCollection_OptimizersConfig) MarshalJSON

func (t CreateCollection_OptimizersConfig) MarshalJSON() ([]byte, error)

func (*CreateCollection_OptimizersConfig) MergeCreateCollectionOptimizersConfig1

func (t *CreateCollection_OptimizersConfig) MergeCreateCollectionOptimizersConfig1(v CreateCollectionOptimizersConfig1) error

MergeCreateCollectionOptimizersConfig1 performs a merge with any union data inside the CreateCollection_OptimizersConfig, using the provided CreateCollectionOptimizersConfig1

func (*CreateCollection_OptimizersConfig) MergeOptimizersConfigDiff

func (t *CreateCollection_OptimizersConfig) MergeOptimizersConfigDiff(v OptimizersConfigDiff) error

MergeOptimizersConfigDiff performs a merge with any union data inside the CreateCollection_OptimizersConfig, using the provided OptimizersConfigDiff

func (*CreateCollection_OptimizersConfig) UnmarshalJSON

func (t *CreateCollection_OptimizersConfig) UnmarshalJSON(b []byte) error

type CreateCollection_QuantizationConfig

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

CreateCollection_QuantizationConfig Quantization parameters. If none - quantization is disabled.

func (CreateCollection_QuantizationConfig) AsCreateCollectionQuantizationConfig1

func (t CreateCollection_QuantizationConfig) AsCreateCollectionQuantizationConfig1() (CreateCollectionQuantizationConfig1, error)

AsCreateCollectionQuantizationConfig1 returns the union data inside the CreateCollection_QuantizationConfig as a CreateCollectionQuantizationConfig1

func (CreateCollection_QuantizationConfig) AsQuantizationConfig

func (t CreateCollection_QuantizationConfig) AsQuantizationConfig() (QuantizationConfig, error)

AsQuantizationConfig returns the union data inside the CreateCollection_QuantizationConfig as a QuantizationConfig

func (*CreateCollection_QuantizationConfig) FromCreateCollectionQuantizationConfig1

func (t *CreateCollection_QuantizationConfig) FromCreateCollectionQuantizationConfig1(v CreateCollectionQuantizationConfig1) error

FromCreateCollectionQuantizationConfig1 overwrites any union data inside the CreateCollection_QuantizationConfig as the provided CreateCollectionQuantizationConfig1

func (*CreateCollection_QuantizationConfig) FromQuantizationConfig

func (t *CreateCollection_QuantizationConfig) FromQuantizationConfig(v QuantizationConfig) error

FromQuantizationConfig overwrites any union data inside the CreateCollection_QuantizationConfig as the provided QuantizationConfig

func (CreateCollection_QuantizationConfig) MarshalJSON

func (t CreateCollection_QuantizationConfig) MarshalJSON() ([]byte, error)

func (*CreateCollection_QuantizationConfig) MergeCreateCollectionQuantizationConfig1

func (t *CreateCollection_QuantizationConfig) MergeCreateCollectionQuantizationConfig1(v CreateCollectionQuantizationConfig1) error

MergeCreateCollectionQuantizationConfig1 performs a merge with any union data inside the CreateCollection_QuantizationConfig, using the provided CreateCollectionQuantizationConfig1

func (*CreateCollection_QuantizationConfig) MergeQuantizationConfig

func (t *CreateCollection_QuantizationConfig) MergeQuantizationConfig(v QuantizationConfig) error

MergeQuantizationConfig performs a merge with any union data inside the CreateCollection_QuantizationConfig, using the provided QuantizationConfig

func (*CreateCollection_QuantizationConfig) UnmarshalJSON

func (t *CreateCollection_QuantizationConfig) UnmarshalJSON(b []byte) error

type CreateCollection_WalConfig

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

CreateCollection_WalConfig Custom params for WAL. If none - values from service configuration file are used.

func (CreateCollection_WalConfig) AsCreateCollectionWalConfig1

func (t CreateCollection_WalConfig) AsCreateCollectionWalConfig1() (CreateCollectionWalConfig1, error)

AsCreateCollectionWalConfig1 returns the union data inside the CreateCollection_WalConfig as a CreateCollectionWalConfig1

func (CreateCollection_WalConfig) AsWalConfigDiff

func (t CreateCollection_WalConfig) AsWalConfigDiff() (WalConfigDiff, error)

AsWalConfigDiff returns the union data inside the CreateCollection_WalConfig as a WalConfigDiff

func (*CreateCollection_WalConfig) FromCreateCollectionWalConfig1

func (t *CreateCollection_WalConfig) FromCreateCollectionWalConfig1(v CreateCollectionWalConfig1) error

FromCreateCollectionWalConfig1 overwrites any union data inside the CreateCollection_WalConfig as the provided CreateCollectionWalConfig1

func (*CreateCollection_WalConfig) FromWalConfigDiff

func (t *CreateCollection_WalConfig) FromWalConfigDiff(v WalConfigDiff) error

FromWalConfigDiff overwrites any union data inside the CreateCollection_WalConfig as the provided WalConfigDiff

func (CreateCollection_WalConfig) MarshalJSON

func (t CreateCollection_WalConfig) MarshalJSON() ([]byte, error)

func (*CreateCollection_WalConfig) MergeCreateCollectionWalConfig1

func (t *CreateCollection_WalConfig) MergeCreateCollectionWalConfig1(v CreateCollectionWalConfig1) error

MergeCreateCollectionWalConfig1 performs a merge with any union data inside the CreateCollection_WalConfig, using the provided CreateCollectionWalConfig1

func (*CreateCollection_WalConfig) MergeWalConfigDiff

func (t *CreateCollection_WalConfig) MergeWalConfigDiff(v WalConfigDiff) error

MergeWalConfigDiff performs a merge with any union data inside the CreateCollection_WalConfig, using the provided WalConfigDiff

func (*CreateCollection_WalConfig) UnmarshalJSON

func (t *CreateCollection_WalConfig) UnmarshalJSON(b []byte) error

type CreateFieldIndex

type CreateFieldIndex struct {
	FieldName   string                        `json:"field_name"`
	FieldSchema *CreateFieldIndex_FieldSchema `json:"field_schema,omitempty"`
}

CreateFieldIndex defines model for CreateFieldIndex.

type CreateFieldIndexFieldSchema1

type CreateFieldIndexFieldSchema1 = interface{}

CreateFieldIndexFieldSchema1 defines model for .

type CreateFieldIndexJSONRequestBody

type CreateFieldIndexJSONRequestBody = CreateFieldIndex

CreateFieldIndexJSONRequestBody defines body for CreateFieldIndex for application/json ContentType.

type CreateFieldIndexParams

type CreateFieldIndexParams struct {
	// Wait If true, wait for changes to actually happen
	Wait *bool `form:"wait,omitempty" json:"wait,omitempty"`

	// Ordering define ordering guarantees for the operation
	Ordering *WriteOrdering `form:"ordering,omitempty" json:"ordering,omitempty"`
}

CreateFieldIndexParams defines parameters for CreateFieldIndex.

type CreateFieldIndexResponse

type CreateFieldIndexResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		Result *UpdateResult `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseCreateFieldIndexResponse

func ParseCreateFieldIndexResponse(rsp *http.Response) (*CreateFieldIndexResponse, error)

ParseCreateFieldIndexResponse parses an HTTP response from a CreateFieldIndexWithResponse call

func (CreateFieldIndexResponse) Status

func (r CreateFieldIndexResponse) Status() string

Status returns HTTPResponse.Status

func (CreateFieldIndexResponse) StatusCode

func (r CreateFieldIndexResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type CreateFieldIndex_FieldSchema

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

CreateFieldIndex_FieldSchema defines model for CreateFieldIndex.FieldSchema.

func (CreateFieldIndex_FieldSchema) AsCreateFieldIndexFieldSchema1

func (t CreateFieldIndex_FieldSchema) AsCreateFieldIndexFieldSchema1() (CreateFieldIndexFieldSchema1, error)

AsCreateFieldIndexFieldSchema1 returns the union data inside the CreateFieldIndex_FieldSchema as a CreateFieldIndexFieldSchema1

func (CreateFieldIndex_FieldSchema) AsPayloadFieldSchema

func (t CreateFieldIndex_FieldSchema) AsPayloadFieldSchema() (PayloadFieldSchema, error)

AsPayloadFieldSchema returns the union data inside the CreateFieldIndex_FieldSchema as a PayloadFieldSchema

func (*CreateFieldIndex_FieldSchema) FromCreateFieldIndexFieldSchema1

func (t *CreateFieldIndex_FieldSchema) FromCreateFieldIndexFieldSchema1(v CreateFieldIndexFieldSchema1) error

FromCreateFieldIndexFieldSchema1 overwrites any union data inside the CreateFieldIndex_FieldSchema as the provided CreateFieldIndexFieldSchema1

func (*CreateFieldIndex_FieldSchema) FromPayloadFieldSchema

func (t *CreateFieldIndex_FieldSchema) FromPayloadFieldSchema(v PayloadFieldSchema) error

FromPayloadFieldSchema overwrites any union data inside the CreateFieldIndex_FieldSchema as the provided PayloadFieldSchema

func (CreateFieldIndex_FieldSchema) MarshalJSON

func (t CreateFieldIndex_FieldSchema) MarshalJSON() ([]byte, error)

func (*CreateFieldIndex_FieldSchema) MergeCreateFieldIndexFieldSchema1

func (t *CreateFieldIndex_FieldSchema) MergeCreateFieldIndexFieldSchema1(v CreateFieldIndexFieldSchema1) error

MergeCreateFieldIndexFieldSchema1 performs a merge with any union data inside the CreateFieldIndex_FieldSchema, using the provided CreateFieldIndexFieldSchema1

func (*CreateFieldIndex_FieldSchema) MergePayloadFieldSchema

func (t *CreateFieldIndex_FieldSchema) MergePayloadFieldSchema(v PayloadFieldSchema) error

MergePayloadFieldSchema performs a merge with any union data inside the CreateFieldIndex_FieldSchema, using the provided PayloadFieldSchema

func (*CreateFieldIndex_FieldSchema) UnmarshalJSON

func (t *CreateFieldIndex_FieldSchema) UnmarshalJSON(b []byte) error

type CreateFullSnapshotResponse

type CreateFullSnapshotResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		Result *SnapshotDescription `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseCreateFullSnapshotResponse

func ParseCreateFullSnapshotResponse(rsp *http.Response) (*CreateFullSnapshotResponse, error)

ParseCreateFullSnapshotResponse parses an HTTP response from a CreateFullSnapshotWithResponse call

func (CreateFullSnapshotResponse) Status

Status returns HTTPResponse.Status

func (CreateFullSnapshotResponse) StatusCode

func (r CreateFullSnapshotResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type CreateSnapshotResponse

type CreateSnapshotResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		Result *SnapshotDescription `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseCreateSnapshotResponse

func ParseCreateSnapshotResponse(rsp *http.Response) (*CreateSnapshotResponse, error)

ParseCreateSnapshotResponse parses an HTTP response from a CreateSnapshotWithResponse call

func (CreateSnapshotResponse) Status

func (r CreateSnapshotResponse) Status() string

Status returns HTTPResponse.Status

func (CreateSnapshotResponse) StatusCode

func (r CreateSnapshotResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DeleteAlias

type DeleteAlias struct {
	AliasName string `json:"alias_name"`
}

DeleteAlias Delete alias if exists

type DeleteAliasOperation

type DeleteAliasOperation struct {
	// DeleteAlias Delete alias if exists
	DeleteAlias DeleteAlias `json:"delete_alias"`
}

DeleteAliasOperation Delete alias if exists

type DeleteCollectionParams

type DeleteCollectionParams struct {
	// Timeout Wait for operation commit timeout in seconds.
	// If timeout is reached - request will return with service error.
	Timeout *int `form:"timeout,omitempty" json:"timeout,omitempty"`
}

DeleteCollectionParams defines parameters for DeleteCollection.

type DeleteCollectionResponse

type DeleteCollectionResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		Result *bool `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseDeleteCollectionResponse

func ParseDeleteCollectionResponse(rsp *http.Response) (*DeleteCollectionResponse, error)

ParseDeleteCollectionResponse parses an HTTP response from a DeleteCollectionWithResponse call

func (DeleteCollectionResponse) Status

func (r DeleteCollectionResponse) Status() string

Status returns HTTPResponse.Status

func (DeleteCollectionResponse) StatusCode

func (r DeleteCollectionResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DeleteFieldIndexParams

type DeleteFieldIndexParams struct {
	// Wait If true, wait for changes to actually happen
	Wait *bool `form:"wait,omitempty" json:"wait,omitempty"`

	// Ordering define ordering guarantees for the operation
	Ordering *WriteOrdering `form:"ordering,omitempty" json:"ordering,omitempty"`
}

DeleteFieldIndexParams defines parameters for DeleteFieldIndex.

type DeleteFieldIndexResponse

type DeleteFieldIndexResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		Result *UpdateResult `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseDeleteFieldIndexResponse

func ParseDeleteFieldIndexResponse(rsp *http.Response) (*DeleteFieldIndexResponse, error)

ParseDeleteFieldIndexResponse parses an HTTP response from a DeleteFieldIndexWithResponse call

func (DeleteFieldIndexResponse) Status

func (r DeleteFieldIndexResponse) Status() string

Status returns HTTPResponse.Status

func (DeleteFieldIndexResponse) StatusCode

func (r DeleteFieldIndexResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DeleteFullSnapshotResponse

type DeleteFullSnapshotResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		Result *bool `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseDeleteFullSnapshotResponse

func ParseDeleteFullSnapshotResponse(rsp *http.Response) (*DeleteFullSnapshotResponse, error)

ParseDeleteFullSnapshotResponse parses an HTTP response from a DeleteFullSnapshotWithResponse call

func (DeleteFullSnapshotResponse) Status

Status returns HTTPResponse.Status

func (DeleteFullSnapshotResponse) StatusCode

func (r DeleteFullSnapshotResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DeletePayload

type DeletePayload struct {
	// Filter Deletes values from points that satisfy this filter condition
	Filter *DeletePayload_Filter `json:"filter,omitempty"`

	// Keys List of payload keys to remove from payload
	Keys []string `json:"keys"`

	// Points Deletes values from each point in this list
	Points *[]ExtendedPointId `json:"points"`
}

DeletePayload defines model for DeletePayload.

type DeletePayloadFilter1

type DeletePayloadFilter1 = interface{}

DeletePayloadFilter1 defines model for .

type DeletePayloadJSONRequestBody

type DeletePayloadJSONRequestBody = DeletePayload

DeletePayloadJSONRequestBody defines body for DeletePayload for application/json ContentType.

type DeletePayloadParams

type DeletePayloadParams struct {
	// Wait If true, wait for changes to actually happen
	Wait *bool `form:"wait,omitempty" json:"wait,omitempty"`

	// Ordering define ordering guarantees for the operation
	Ordering *WriteOrdering `form:"ordering,omitempty" json:"ordering,omitempty"`
}

DeletePayloadParams defines parameters for DeletePayload.

type DeletePayloadResponse

type DeletePayloadResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		Result *UpdateResult `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseDeletePayloadResponse

func ParseDeletePayloadResponse(rsp *http.Response) (*DeletePayloadResponse, error)

ParseDeletePayloadResponse parses an HTTP response from a DeletePayloadWithResponse call

func (DeletePayloadResponse) Status

func (r DeletePayloadResponse) Status() string

Status returns HTTPResponse.Status

func (DeletePayloadResponse) StatusCode

func (r DeletePayloadResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DeletePayload_Filter

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

DeletePayload_Filter Deletes values from points that satisfy this filter condition

func (DeletePayload_Filter) AsDeletePayloadFilter1

func (t DeletePayload_Filter) AsDeletePayloadFilter1() (DeletePayloadFilter1, error)

AsDeletePayloadFilter1 returns the union data inside the DeletePayload_Filter as a DeletePayloadFilter1

func (DeletePayload_Filter) AsFilter

func (t DeletePayload_Filter) AsFilter() (Filter, error)

AsFilter returns the union data inside the DeletePayload_Filter as a Filter

func (*DeletePayload_Filter) FromDeletePayloadFilter1

func (t *DeletePayload_Filter) FromDeletePayloadFilter1(v DeletePayloadFilter1) error

FromDeletePayloadFilter1 overwrites any union data inside the DeletePayload_Filter as the provided DeletePayloadFilter1

func (*DeletePayload_Filter) FromFilter

func (t *DeletePayload_Filter) FromFilter(v Filter) error

FromFilter overwrites any union data inside the DeletePayload_Filter as the provided Filter

func (DeletePayload_Filter) MarshalJSON

func (t DeletePayload_Filter) MarshalJSON() ([]byte, error)

func (*DeletePayload_Filter) MergeDeletePayloadFilter1

func (t *DeletePayload_Filter) MergeDeletePayloadFilter1(v DeletePayloadFilter1) error

MergeDeletePayloadFilter1 performs a merge with any union data inside the DeletePayload_Filter, using the provided DeletePayloadFilter1

func (*DeletePayload_Filter) MergeFilter

func (t *DeletePayload_Filter) MergeFilter(v Filter) error

MergeFilter performs a merge with any union data inside the DeletePayload_Filter, using the provided Filter

func (*DeletePayload_Filter) UnmarshalJSON

func (t *DeletePayload_Filter) UnmarshalJSON(b []byte) error

type DeletePointsJSONRequestBody

type DeletePointsJSONRequestBody = PointsSelector

DeletePointsJSONRequestBody defines body for DeletePoints for application/json ContentType.

type DeletePointsParams

type DeletePointsParams struct {
	// Wait If true, wait for changes to actually happen
	Wait *bool `form:"wait,omitempty" json:"wait,omitempty"`

	// Ordering define ordering guarantees for the operation
	Ordering *WriteOrdering `form:"ordering,omitempty" json:"ordering,omitempty"`
}

DeletePointsParams defines parameters for DeletePoints.

type DeletePointsResponse

type DeletePointsResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		Result *UpdateResult `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseDeletePointsResponse

func ParseDeletePointsResponse(rsp *http.Response) (*DeletePointsResponse, error)

ParseDeletePointsResponse parses an HTTP response from a DeletePointsWithResponse call

func (DeletePointsResponse) Status

func (r DeletePointsResponse) Status() string

Status returns HTTPResponse.Status

func (DeletePointsResponse) StatusCode

func (r DeletePointsResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DeleteSnapshotResponse

type DeleteSnapshotResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		Result *bool `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseDeleteSnapshotResponse

func ParseDeleteSnapshotResponse(rsp *http.Response) (*DeleteSnapshotResponse, error)

ParseDeleteSnapshotResponse parses an HTTP response from a DeleteSnapshotWithResponse call

func (DeleteSnapshotResponse) Status

func (r DeleteSnapshotResponse) Status() string

Status returns HTTPResponse.Status

func (DeleteSnapshotResponse) StatusCode

func (r DeleteSnapshotResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type Distance

type Distance string

Distance Type of internal tags, build from payload Distance function types used to compare vectors

const (
	Cosine Distance = "Cosine"
	Dot    Distance = "Dot"
	Euclid Distance = "Euclid"
)

Defines values for Distance.

type DropReplicaOperation

type DropReplicaOperation struct {
	DropReplica Replica `json:"drop_replica"`
}

DropReplicaOperation defines model for DropReplicaOperation.

type ErrorResponse

type ErrorResponse struct {
	Result *map[string]interface{} `json:"result"`
	Status *struct {
		// Error Description of the occurred error.
		Error *string `json:"error,omitempty"`
	} `json:"status,omitempty"`

	// Time Time spent to process this request
	Time *float32 `json:"time,omitempty"`
}

ErrorResponse defines model for ErrorResponse.

type ExtendedPointId

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

ExtendedPointId Type, used for specifying point ID in user interface

func (ExtendedPointId) AsExtendedPointId0

func (t ExtendedPointId) AsExtendedPointId0() (ExtendedPointId0, error)

AsExtendedPointId0 returns the union data inside the ExtendedPointId as a ExtendedPointId0

func (ExtendedPointId) AsExtendedPointId1

func (t ExtendedPointId) AsExtendedPointId1() (ExtendedPointId1, error)

AsExtendedPointId1 returns the union data inside the ExtendedPointId as a ExtendedPointId1

func (*ExtendedPointId) FromExtendedPointId0

func (t *ExtendedPointId) FromExtendedPointId0(v ExtendedPointId0) error

FromExtendedPointId0 overwrites any union data inside the ExtendedPointId as the provided ExtendedPointId0

func (*ExtendedPointId) FromExtendedPointId1

func (t *ExtendedPointId) FromExtendedPointId1(v ExtendedPointId1) error

FromExtendedPointId1 overwrites any union data inside the ExtendedPointId as the provided ExtendedPointId1

func (ExtendedPointId) MarshalJSON

func (t ExtendedPointId) MarshalJSON() ([]byte, error)

func (*ExtendedPointId) MergeExtendedPointId0

func (t *ExtendedPointId) MergeExtendedPointId0(v ExtendedPointId0) error

MergeExtendedPointId0 performs a merge with any union data inside the ExtendedPointId, using the provided ExtendedPointId0

func (*ExtendedPointId) MergeExtendedPointId1

func (t *ExtendedPointId) MergeExtendedPointId1(v ExtendedPointId1) error

MergeExtendedPointId1 performs a merge with any union data inside the ExtendedPointId, using the provided ExtendedPointId1

func (*ExtendedPointId) UnmarshalJSON

func (t *ExtendedPointId) UnmarshalJSON(b []byte) error

type ExtendedPointId0

type ExtendedPointId0 = uint64

ExtendedPointId0 defines model for .

type ExtendedPointId1

type ExtendedPointId1 = openapi_types.UUID

ExtendedPointId1 defines model for .

type FieldCondition

type FieldCondition struct {
	// GeoBoundingBox Check if points geo location lies in a given area
	GeoBoundingBox *FieldCondition_GeoBoundingBox `json:"geo_bounding_box,omitempty"`

	// GeoRadius Check if geo point is within a given radius
	GeoRadius *FieldCondition_GeoRadius `json:"geo_radius,omitempty"`

	// Key Payload key
	Key string `json:"key"`

	// Match Check if point has field with a given value
	Match *FieldCondition_Match `json:"match,omitempty"`

	// Range Check if points value lies in a given range
	Range *FieldCondition_Range `json:"range,omitempty"`

	// ValuesCount Check number of values of the field
	ValuesCount *FieldCondition_ValuesCount `json:"values_count,omitempty"`
}

FieldCondition All possible payload filtering conditions

type FieldConditionGeoBoundingBox1

type FieldConditionGeoBoundingBox1 = interface{}

FieldConditionGeoBoundingBox1 defines model for .

type FieldConditionGeoRadius1

type FieldConditionGeoRadius1 = interface{}

FieldConditionGeoRadius1 defines model for .

type FieldConditionMatch1

type FieldConditionMatch1 = interface{}

FieldConditionMatch1 defines model for .

type FieldConditionRange1

type FieldConditionRange1 = interface{}

FieldConditionRange1 defines model for .

type FieldConditionValuesCount1

type FieldConditionValuesCount1 = interface{}

FieldConditionValuesCount1 defines model for .

type FieldCondition_GeoBoundingBox

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

FieldCondition_GeoBoundingBox Check if points geo location lies in a given area

func (FieldCondition_GeoBoundingBox) AsFieldConditionGeoBoundingBox1

func (t FieldCondition_GeoBoundingBox) AsFieldConditionGeoBoundingBox1() (FieldConditionGeoBoundingBox1, error)

AsFieldConditionGeoBoundingBox1 returns the union data inside the FieldCondition_GeoBoundingBox as a FieldConditionGeoBoundingBox1

func (FieldCondition_GeoBoundingBox) AsGeoBoundingBox

func (t FieldCondition_GeoBoundingBox) AsGeoBoundingBox() (GeoBoundingBox, error)

AsGeoBoundingBox returns the union data inside the FieldCondition_GeoBoundingBox as a GeoBoundingBox

func (*FieldCondition_GeoBoundingBox) FromFieldConditionGeoBoundingBox1

func (t *FieldCondition_GeoBoundingBox) FromFieldConditionGeoBoundingBox1(v FieldConditionGeoBoundingBox1) error

FromFieldConditionGeoBoundingBox1 overwrites any union data inside the FieldCondition_GeoBoundingBox as the provided FieldConditionGeoBoundingBox1

func (*FieldCondition_GeoBoundingBox) FromGeoBoundingBox

func (t *FieldCondition_GeoBoundingBox) FromGeoBoundingBox(v GeoBoundingBox) error

FromGeoBoundingBox overwrites any union data inside the FieldCondition_GeoBoundingBox as the provided GeoBoundingBox

func (FieldCondition_GeoBoundingBox) MarshalJSON

func (t FieldCondition_GeoBoundingBox) MarshalJSON() ([]byte, error)

func (*FieldCondition_GeoBoundingBox) MergeFieldConditionGeoBoundingBox1

func (t *FieldCondition_GeoBoundingBox) MergeFieldConditionGeoBoundingBox1(v FieldConditionGeoBoundingBox1) error

MergeFieldConditionGeoBoundingBox1 performs a merge with any union data inside the FieldCondition_GeoBoundingBox, using the provided FieldConditionGeoBoundingBox1

func (*FieldCondition_GeoBoundingBox) MergeGeoBoundingBox

func (t *FieldCondition_GeoBoundingBox) MergeGeoBoundingBox(v GeoBoundingBox) error

MergeGeoBoundingBox performs a merge with any union data inside the FieldCondition_GeoBoundingBox, using the provided GeoBoundingBox

func (*FieldCondition_GeoBoundingBox) UnmarshalJSON

func (t *FieldCondition_GeoBoundingBox) UnmarshalJSON(b []byte) error

type FieldCondition_GeoRadius

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

FieldCondition_GeoRadius Check if geo point is within a given radius

func (FieldCondition_GeoRadius) AsFieldConditionGeoRadius1

func (t FieldCondition_GeoRadius) AsFieldConditionGeoRadius1() (FieldConditionGeoRadius1, error)

AsFieldConditionGeoRadius1 returns the union data inside the FieldCondition_GeoRadius as a FieldConditionGeoRadius1

func (FieldCondition_GeoRadius) AsGeoRadius

func (t FieldCondition_GeoRadius) AsGeoRadius() (GeoRadius, error)

AsGeoRadius returns the union data inside the FieldCondition_GeoRadius as a GeoRadius

func (*FieldCondition_GeoRadius) FromFieldConditionGeoRadius1

func (t *FieldCondition_GeoRadius) FromFieldConditionGeoRadius1(v FieldConditionGeoRadius1) error

FromFieldConditionGeoRadius1 overwrites any union data inside the FieldCondition_GeoRadius as the provided FieldConditionGeoRadius1

func (*FieldCondition_GeoRadius) FromGeoRadius

func (t *FieldCondition_GeoRadius) FromGeoRadius(v GeoRadius) error

FromGeoRadius overwrites any union data inside the FieldCondition_GeoRadius as the provided GeoRadius

func (FieldCondition_GeoRadius) MarshalJSON

func (t FieldCondition_GeoRadius) MarshalJSON() ([]byte, error)

func (*FieldCondition_GeoRadius) MergeFieldConditionGeoRadius1

func (t *FieldCondition_GeoRadius) MergeFieldConditionGeoRadius1(v FieldConditionGeoRadius1) error

MergeFieldConditionGeoRadius1 performs a merge with any union data inside the FieldCondition_GeoRadius, using the provided FieldConditionGeoRadius1

func (*FieldCondition_GeoRadius) MergeGeoRadius

func (t *FieldCondition_GeoRadius) MergeGeoRadius(v GeoRadius) error

MergeGeoRadius performs a merge with any union data inside the FieldCondition_GeoRadius, using the provided GeoRadius

func (*FieldCondition_GeoRadius) UnmarshalJSON

func (t *FieldCondition_GeoRadius) UnmarshalJSON(b []byte) error

type FieldCondition_Match

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

FieldCondition_Match Check if point has field with a given value

func (FieldCondition_Match) AsFieldConditionMatch1

func (t FieldCondition_Match) AsFieldConditionMatch1() (FieldConditionMatch1, error)

AsFieldConditionMatch1 returns the union data inside the FieldCondition_Match as a FieldConditionMatch1

func (FieldCondition_Match) AsMatch

func (t FieldCondition_Match) AsMatch() (Match, error)

AsMatch returns the union data inside the FieldCondition_Match as a Match

func (*FieldCondition_Match) FromFieldConditionMatch1

func (t *FieldCondition_Match) FromFieldConditionMatch1(v FieldConditionMatch1) error

FromFieldConditionMatch1 overwrites any union data inside the FieldCondition_Match as the provided FieldConditionMatch1

func (*FieldCondition_Match) FromMatch

func (t *FieldCondition_Match) FromMatch(v Match) error

FromMatch overwrites any union data inside the FieldCondition_Match as the provided Match

func (FieldCondition_Match) MarshalJSON

func (t FieldCondition_Match) MarshalJSON() ([]byte, error)

func (*FieldCondition_Match) MergeFieldConditionMatch1

func (t *FieldCondition_Match) MergeFieldConditionMatch1(v FieldConditionMatch1) error

MergeFieldConditionMatch1 performs a merge with any union data inside the FieldCondition_Match, using the provided FieldConditionMatch1

func (*FieldCondition_Match) MergeMatch

func (t *FieldCondition_Match) MergeMatch(v Match) error

MergeMatch performs a merge with any union data inside the FieldCondition_Match, using the provided Match

func (*FieldCondition_Match) UnmarshalJSON

func (t *FieldCondition_Match) UnmarshalJSON(b []byte) error

type FieldCondition_Range

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

FieldCondition_Range Check if points value lies in a given range

func (FieldCondition_Range) AsFieldConditionRange1

func (t FieldCondition_Range) AsFieldConditionRange1() (FieldConditionRange1, error)

AsFieldConditionRange1 returns the union data inside the FieldCondition_Range as a FieldConditionRange1

func (FieldCondition_Range) AsRange

func (t FieldCondition_Range) AsRange() (Range, error)

AsRange returns the union data inside the FieldCondition_Range as a Range

func (*FieldCondition_Range) FromFieldConditionRange1

func (t *FieldCondition_Range) FromFieldConditionRange1(v FieldConditionRange1) error

FromFieldConditionRange1 overwrites any union data inside the FieldCondition_Range as the provided FieldConditionRange1

func (*FieldCondition_Range) FromRange

func (t *FieldCondition_Range) FromRange(v Range) error

FromRange overwrites any union data inside the FieldCondition_Range as the provided Range

func (FieldCondition_Range) MarshalJSON

func (t FieldCondition_Range) MarshalJSON() ([]byte, error)

func (*FieldCondition_Range) MergeFieldConditionRange1

func (t *FieldCondition_Range) MergeFieldConditionRange1(v FieldConditionRange1) error

MergeFieldConditionRange1 performs a merge with any union data inside the FieldCondition_Range, using the provided FieldConditionRange1

func (*FieldCondition_Range) MergeRange

func (t *FieldCondition_Range) MergeRange(v Range) error

MergeRange performs a merge with any union data inside the FieldCondition_Range, using the provided Range

func (*FieldCondition_Range) UnmarshalJSON

func (t *FieldCondition_Range) UnmarshalJSON(b []byte) error

type FieldCondition_ValuesCount

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

FieldCondition_ValuesCount Check number of values of the field

func (FieldCondition_ValuesCount) AsFieldConditionValuesCount1

func (t FieldCondition_ValuesCount) AsFieldConditionValuesCount1() (FieldConditionValuesCount1, error)

AsFieldConditionValuesCount1 returns the union data inside the FieldCondition_ValuesCount as a FieldConditionValuesCount1

func (FieldCondition_ValuesCount) AsValuesCount

func (t FieldCondition_ValuesCount) AsValuesCount() (ValuesCount, error)

AsValuesCount returns the union data inside the FieldCondition_ValuesCount as a ValuesCount

func (*FieldCondition_ValuesCount) FromFieldConditionValuesCount1

func (t *FieldCondition_ValuesCount) FromFieldConditionValuesCount1(v FieldConditionValuesCount1) error

FromFieldConditionValuesCount1 overwrites any union data inside the FieldCondition_ValuesCount as the provided FieldConditionValuesCount1

func (*FieldCondition_ValuesCount) FromValuesCount

func (t *FieldCondition_ValuesCount) FromValuesCount(v ValuesCount) error

FromValuesCount overwrites any union data inside the FieldCondition_ValuesCount as the provided ValuesCount

func (FieldCondition_ValuesCount) MarshalJSON

func (t FieldCondition_ValuesCount) MarshalJSON() ([]byte, error)

func (*FieldCondition_ValuesCount) MergeFieldConditionValuesCount1

func (t *FieldCondition_ValuesCount) MergeFieldConditionValuesCount1(v FieldConditionValuesCount1) error

MergeFieldConditionValuesCount1 performs a merge with any union data inside the FieldCondition_ValuesCount, using the provided FieldConditionValuesCount1

func (*FieldCondition_ValuesCount) MergeValuesCount

func (t *FieldCondition_ValuesCount) MergeValuesCount(v ValuesCount) error

MergeValuesCount performs a merge with any union data inside the FieldCondition_ValuesCount, using the provided ValuesCount

func (*FieldCondition_ValuesCount) UnmarshalJSON

func (t *FieldCondition_ValuesCount) UnmarshalJSON(b []byte) error

type Filter

type Filter struct {
	// Must All conditions must match
	Must *[]Condition `json:"must"`

	// MustNot All conditions must NOT match
	MustNot *[]Condition `json:"must_not"`

	// Should At least one of those conditions should match
	Should *[]Condition `json:"should"`
}

Filter defines model for Filter.

type FilterSelector

type FilterSelector struct {
	Filter Filter `json:"filter"`
}

FilterSelector defines model for FilterSelector.

type GeoBoundingBox

type GeoBoundingBox struct {
	// BottomRight Geo point payload schema
	BottomRight GeoPoint `json:"bottom_right"`

	// TopLeft Geo point payload schema
	TopLeft GeoPoint `json:"top_left"`
}

GeoBoundingBox Geo filter request

Matches coordinates inside the rectangle, described by coordinates of lop-left and bottom-right edges

type GeoPoint

type GeoPoint struct {
	Lat float64 `json:"lat"`
	Lon float64 `json:"lon"`
}

GeoPoint Geo point payload schema

type GeoRadius

type GeoRadius struct {
	// Center Geo point payload schema
	Center GeoPoint `json:"center"`

	// Radius Radius of the area in meters
	Radius float64 `json:"radius"`
}

GeoRadius Geo filter request

Matches coordinates inside the circle of `radius` and center with coordinates `center`

type GetCollectionAliasesResponse

type GetCollectionAliasesResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		Result *CollectionsAliasesResponse `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseGetCollectionAliasesResponse

func ParseGetCollectionAliasesResponse(rsp *http.Response) (*GetCollectionAliasesResponse, error)

ParseGetCollectionAliasesResponse parses an HTTP response from a GetCollectionAliasesWithResponse call

func (GetCollectionAliasesResponse) Status

Status returns HTTPResponse.Status

func (GetCollectionAliasesResponse) StatusCode

func (r GetCollectionAliasesResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetCollectionResponse

type GetCollectionResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		// Result Current statistics and configuration of the collection
		Result *CollectionInfo `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseGetCollectionResponse

func ParseGetCollectionResponse(rsp *http.Response) (*GetCollectionResponse, error)

ParseGetCollectionResponse parses an HTTP response from a GetCollectionWithResponse call

func (GetCollectionResponse) Status

func (r GetCollectionResponse) Status() string

Status returns HTTPResponse.Status

func (GetCollectionResponse) StatusCode

func (r GetCollectionResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetCollectionsAliasesResponse

type GetCollectionsAliasesResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		Result *CollectionsAliasesResponse `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseGetCollectionsAliasesResponse

func ParseGetCollectionsAliasesResponse(rsp *http.Response) (*GetCollectionsAliasesResponse, error)

ParseGetCollectionsAliasesResponse parses an HTTP response from a GetCollectionsAliasesWithResponse call

func (GetCollectionsAliasesResponse) Status

Status returns HTTPResponse.Status

func (GetCollectionsAliasesResponse) StatusCode

func (r GetCollectionsAliasesResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetCollectionsResponse

type GetCollectionsResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		Result *CollectionsResponse `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseGetCollectionsResponse

func ParseGetCollectionsResponse(rsp *http.Response) (*GetCollectionsResponse, error)

ParseGetCollectionsResponse parses an HTTP response from a GetCollectionsWithResponse call

func (GetCollectionsResponse) Status

func (r GetCollectionsResponse) Status() string

Status returns HTTPResponse.Status

func (GetCollectionsResponse) StatusCode

func (r GetCollectionsResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetFullSnapshotResponse

type GetFullSnapshotResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON4XX      *ErrorResponse
	JSONDefault  *ErrorResponse
}

func ParseGetFullSnapshotResponse

func ParseGetFullSnapshotResponse(rsp *http.Response) (*GetFullSnapshotResponse, error)

ParseGetFullSnapshotResponse parses an HTTP response from a GetFullSnapshotWithResponse call

func (GetFullSnapshotResponse) Status

func (r GetFullSnapshotResponse) Status() string

Status returns HTTPResponse.Status

func (GetFullSnapshotResponse) StatusCode

func (r GetFullSnapshotResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetLocksResponse

type GetLocksResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		Result *LocksOption `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseGetLocksResponse

func ParseGetLocksResponse(rsp *http.Response) (*GetLocksResponse, error)

ParseGetLocksResponse parses an HTTP response from a GetLocksWithResponse call

func (GetLocksResponse) Status

func (r GetLocksResponse) Status() string

Status returns HTTPResponse.Status

func (GetLocksResponse) StatusCode

func (r GetLocksResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetPointParams

type GetPointParams struct {
	// Consistency Define read consistency guarantees for the operation
	Consistency *ReadConsistency `form:"consistency,omitempty" json:"consistency,omitempty"`
}

GetPointParams defines parameters for GetPoint.

type GetPointResponse

type GetPointResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		// Result Point data
		Result *Record `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseGetPointResponse

func ParseGetPointResponse(rsp *http.Response) (*GetPointResponse, error)

ParseGetPointResponse parses an HTTP response from a GetPointWithResponse call

func (GetPointResponse) Status

func (r GetPointResponse) Status() string

Status returns HTTPResponse.Status

func (GetPointResponse) StatusCode

func (r GetPointResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetPointResponseSC

type GetPointResponseSC struct {
	Result GetPointResult `json:"result"`
}

type GetPointResult

type GetPointResult struct {
	ID      uuid.UUID              `json:"id"`
	Payload map[string]interface{} `json:"payload"`
	Vector  GetPointVector         `json:"vector"`
}

Type for GetPoint response

type GetPointVector

type GetPointVector struct {
	Image []float32 `json:"image"`
}

Type for vector result

type GetPointsJSONRequestBody

type GetPointsJSONRequestBody = PointRequest

GetPointsJSONRequestBody defines body for GetPoints for application/json ContentType.

type GetPointsParams

type GetPointsParams struct {
	// Consistency Define read consistency guarantees for the operation
	Consistency *ReadConsistency `form:"consistency,omitempty" json:"consistency,omitempty"`
}

GetPointsParams defines parameters for GetPoints.

type GetPointsResponse

type GetPointsResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		Result *[]Record `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseGetPointsResponse

func ParseGetPointsResponse(rsp *http.Response) (*GetPointsResponse, error)

ParseGetPointsResponse parses an HTTP response from a GetPointsWithResponse call

func (GetPointsResponse) Status

func (r GetPointsResponse) Status() string

Status returns HTTPResponse.Status

func (GetPointsResponse) StatusCode

func (r GetPointsResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetSnapshotResponse

type GetSnapshotResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON4XX      *ErrorResponse
	JSONDefault  *ErrorResponse
}

func ParseGetSnapshotResponse

func ParseGetSnapshotResponse(rsp *http.Response) (*GetSnapshotResponse, error)

ParseGetSnapshotResponse parses an HTTP response from a GetSnapshotWithResponse call

func (GetSnapshotResponse) Status

func (r GetSnapshotResponse) Status() string

Status returns HTTPResponse.Status

func (GetSnapshotResponse) StatusCode

func (r GetSnapshotResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GrpcTelemetry

type GrpcTelemetry struct {
	Responses map[string]OperationDurationStatistics `json:"responses"`
}

GrpcTelemetry defines model for GrpcTelemetry.

type HasIdCondition

type HasIdCondition struct {
	HasId []ExtendedPointId `json:"has_id"`
}

HasIdCondition ID-based filtering condition

type HnswConfig

type HnswConfig struct {
	// EfConstruct Number of neighbours to consider during the index building. Larger the value - more accurate the search, more time required to build index.
	EfConstruct uint `json:"ef_construct"`

	// FullScanThreshold Minimal size (in KiloBytes) of vectors for additional payload-based indexing. If payload chunk is smaller than `full_scan_threshold_kb` additional indexing won't be used - in this case full-scan search should be preferred by query planner and additional indexing is not required. Note: 1Kb = 1 vector of size 256
	FullScanThreshold uint `json:"full_scan_threshold"`

	// M Number of edges per node in the index graph. Larger the value - more accurate the search, more space required.
	M uint `json:"m"`

	// MaxIndexingThreads Number of parallel threads used for background index building. If 0 - auto selection.
	MaxIndexingThreads *uint `json:"max_indexing_threads,omitempty"`

	// OnDisk Store HNSW index on disk. If set to false, index will be stored in RAM. Default: false
	OnDisk *bool `json:"on_disk"`

	// PayloadM Custom M param for hnsw graph built for payload index. If not set, default M will be used.
	PayloadM *uint `json:"payload_m"`
}

HnswConfig Config of HNSW index

type HnswConfigDiff

type HnswConfigDiff struct {
	// EfConstruct Number of neighbours to consider during the index building. Larger the value - more accurate the search, more time required to build index.
	EfConstruct *uint `json:"ef_construct"`

	// FullScanThreshold Minimal size (in KiloBytes) of vectors for additional payload-based indexing. If payload chunk is smaller than `full_scan_threshold_kb` additional indexing won't be used - in this case full-scan search should be preferred by query planner and additional indexing is not required. Note: 1Kb = 1 vector of size 256
	FullScanThreshold *uint `json:"full_scan_threshold"`

	// M Number of edges per node in the index graph. Larger the value - more accurate the search, more space required.
	M *uint `json:"m"`

	// MaxIndexingThreads Number of parallel threads used for background index building. If 0 - auto selection.
	MaxIndexingThreads *uint `json:"max_indexing_threads"`

	// OnDisk Store HNSW index on disk. If set to false, index will be stored in RAM. Default: false
	OnDisk *bool `json:"on_disk"`

	// PayloadM Custom M param for additional payload-aware HNSW links. If not set, default M will be used.
	PayloadM *uint `json:"payload_m"`
}

HnswConfigDiff defines model for HnswConfigDiff.

type HttpRequestDoer

type HttpRequestDoer interface {
	Do(req *http.Request) (*http.Response, error)
}

Doer performs HTTP requests.

The standard http.Client implements this interface.

type Indexes

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

Indexes Vector index configuration of the segment

func (Indexes) AsIndexes0

func (t Indexes) AsIndexes0() (Indexes0, error)

AsIndexes0 returns the union data inside the Indexes as a Indexes0

func (Indexes) AsIndexes1

func (t Indexes) AsIndexes1() (Indexes1, error)

AsIndexes1 returns the union data inside the Indexes as a Indexes1

func (*Indexes) FromIndexes0

func (t *Indexes) FromIndexes0(v Indexes0) error

FromIndexes0 overwrites any union data inside the Indexes as the provided Indexes0

func (*Indexes) FromIndexes1

func (t *Indexes) FromIndexes1(v Indexes1) error

FromIndexes1 overwrites any union data inside the Indexes as the provided Indexes1

func (Indexes) MarshalJSON

func (t Indexes) MarshalJSON() ([]byte, error)

func (*Indexes) MergeIndexes0

func (t *Indexes) MergeIndexes0(v Indexes0) error

MergeIndexes0 performs a merge with any union data inside the Indexes, using the provided Indexes0

func (*Indexes) MergeIndexes1

func (t *Indexes) MergeIndexes1(v Indexes1) error

MergeIndexes1 performs a merge with any union data inside the Indexes, using the provided Indexes1

func (*Indexes) UnmarshalJSON

func (t *Indexes) UnmarshalJSON(b []byte) error

type Indexes0

type Indexes0 struct {
	Options map[string]interface{} `json:"options"`
	Type    Indexes                `json:"type"`
}

Indexes0 Do not use any index, scan whole vector collection during search. Guarantee 100% precision, but may be time consuming on large collections.

type Indexes1

type Indexes1 struct {
	// Options Config of HNSW index
	Options HnswConfig `json:"options"`
	Type    Indexes    `json:"type"`
}

Indexes1 Use filterable HNSW index for approximate search. Is very fast even on a very huge collections, but require additional space to store index and additional time to build it.

type InitFrom

type InitFrom struct {
	Collection string `json:"collection"`
}

InitFrom Operation for creating new collection and (optionally) specify index params

type IsEmptyCondition

type IsEmptyCondition struct {
	// IsEmpty Payload field
	IsEmpty PayloadField `json:"is_empty"`
}

IsEmptyCondition Select points with empty payload for a specified field

type ListFullSnapshotsResponse

type ListFullSnapshotsResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		Result *[]SnapshotDescription `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseListFullSnapshotsResponse

func ParseListFullSnapshotsResponse(rsp *http.Response) (*ListFullSnapshotsResponse, error)

ParseListFullSnapshotsResponse parses an HTTP response from a ListFullSnapshotsWithResponse call

func (ListFullSnapshotsResponse) Status

func (r ListFullSnapshotsResponse) Status() string

Status returns HTTPResponse.Status

func (ListFullSnapshotsResponse) StatusCode

func (r ListFullSnapshotsResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type ListSnapshotsResponse

type ListSnapshotsResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		Result *[]SnapshotDescription `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseListSnapshotsResponse

func ParseListSnapshotsResponse(rsp *http.Response) (*ListSnapshotsResponse, error)

ParseListSnapshotsResponse parses an HTTP response from a ListSnapshotsWithResponse call

func (ListSnapshotsResponse) Status

func (r ListSnapshotsResponse) Status() string

Status returns HTTPResponse.Status

func (ListSnapshotsResponse) StatusCode

func (r ListSnapshotsResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type LocalShardInfo

type LocalShardInfo struct {
	// PointsCount Number of points in the shard
	PointsCount uint `json:"points_count"`

	// ShardId Local shard id
	ShardId uint32 `json:"shard_id"`

	// State State of the single shard within a replica set.
	State ReplicaState `json:"state"`
}

LocalShardInfo defines model for LocalShardInfo.

type LocalShardTelemetry

type LocalShardTelemetry struct {
	Optimizations OptimizerTelemetry `json:"optimizations"`
	Segments      []SegmentTelemetry `json:"segments"`
	VariantName   *string            `json:"variant_name"`
}

LocalShardTelemetry defines model for LocalShardTelemetry.

type LocksOption

type LocksOption struct {
	ErrorMessage *string `json:"error_message"`
	Write        bool    `json:"write"`
}

LocksOption defines model for LocksOption.

type LookupLocation

type LookupLocation struct {
	// Collection Name of the collection used for lookup
	Collection string `json:"collection"`

	// Vector Optional name of the vector field within the collection. If not provided, the default vector field will be used.
	Vector *string `json:"vector"`
}

LookupLocation Defines a location to use for looking up the vector. Specifies collection and vector field name.

type Match

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

Match Match filter request

func (Match) AsMatchAny

func (t Match) AsMatchAny() (MatchAny, error)

AsMatchAny returns the union data inside the Match as a MatchAny

func (Match) AsMatchText

func (t Match) AsMatchText() (MatchText, error)

AsMatchText returns the union data inside the Match as a MatchText

func (Match) AsMatchValue

func (t Match) AsMatchValue() (MatchValue, error)

AsMatchValue returns the union data inside the Match as a MatchValue

func (*Match) FromMatchAny

func (t *Match) FromMatchAny(v MatchAny) error

FromMatchAny overwrites any union data inside the Match as the provided MatchAny

func (*Match) FromMatchText

func (t *Match) FromMatchText(v MatchText) error

FromMatchText overwrites any union data inside the Match as the provided MatchText

func (*Match) FromMatchValue

func (t *Match) FromMatchValue(v MatchValue) error

FromMatchValue overwrites any union data inside the Match as the provided MatchValue

func (Match) MarshalJSON

func (t Match) MarshalJSON() ([]byte, error)

func (*Match) MergeMatchAny

func (t *Match) MergeMatchAny(v MatchAny) error

MergeMatchAny performs a merge with any union data inside the Match, using the provided MatchAny

func (*Match) MergeMatchText

func (t *Match) MergeMatchText(v MatchText) error

MergeMatchText performs a merge with any union data inside the Match, using the provided MatchText

func (*Match) MergeMatchValue

func (t *Match) MergeMatchValue(v MatchValue) error

MergeMatchValue performs a merge with any union data inside the Match, using the provided MatchValue

func (*Match) UnmarshalJSON

func (t *Match) UnmarshalJSON(b []byte) error

type MatchAny

type MatchAny struct {
	Any AnyVariants `json:"any"`
}

MatchAny Exact match on any of the given values

type MatchText

type MatchText struct {
	Text string `json:"text"`
}

MatchText Full-text match of the strings.

type MatchValue

type MatchValue struct {
	Value ValueVariants `json:"value"`
}

MatchValue Exact match of the given value

type MessageSendErrors

type MessageSendErrors struct {
	Count       uint    `json:"count"`
	LatestError *string `json:"latest_error"`
}

MessageSendErrors Message send failures for a particular peer

type MetricsParams

type MetricsParams struct {
	// Anonymize If true, anonymize result
	Anonymize *bool `form:"anonymize,omitempty" json:"anonymize,omitempty"`
}

MetricsParams defines parameters for Metrics.

type MetricsResponse

type MetricsResponse struct {
	Body         []byte
	HTTPResponse *http.Response
}

func ParseMetricsResponse

func ParseMetricsResponse(rsp *http.Response) (*MetricsResponse, error)

ParseMetricsResponse parses an HTTP response from a MetricsWithResponse call

func (MetricsResponse) Status

func (r MetricsResponse) Status() string

Status returns HTTPResponse.Status

func (MetricsResponse) StatusCode

func (r MetricsResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type MoveShard

type MoveShard struct {
	FromPeerId uint64 `json:"from_peer_id"`
	ShardId    uint32 `json:"shard_id"`
	ToPeerId   uint64 `json:"to_peer_id"`
}

MoveShard defines model for MoveShard.

type MoveShardOperation

type MoveShardOperation struct {
	MoveShard MoveShard `json:"move_shard"`
}

MoveShardOperation defines model for MoveShardOperation.

type NamedVector

type NamedVector struct {
	// Name Name of vector data
	Name string `json:"name"`

	// Vector Vector data
	Vector []float32 `json:"vector"`
}

NamedVector Vector data with name

type NamedVectorStruct

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

NamedVectorStruct Vector data separator for named and unnamed modes Unanmed mode:

{ "vector": [1.0, 2.0, 3.0] }

or named mode:

{ "vector": { "vector": [1.0, 2.0, 3.0], "name": "image-embeddings" } }

func (NamedVectorStruct) AsNamedVector

func (t NamedVectorStruct) AsNamedVector() (NamedVector, error)

AsNamedVector returns the union data inside the NamedVectorStruct as a NamedVector

func (NamedVectorStruct) AsNamedVectorStruct0

func (t NamedVectorStruct) AsNamedVectorStruct0() (NamedVectorStruct0, error)

AsNamedVectorStruct0 returns the union data inside the NamedVectorStruct as a NamedVectorStruct0

func (*NamedVectorStruct) FromNamedVector

func (t *NamedVectorStruct) FromNamedVector(v NamedVector) error

FromNamedVector overwrites any union data inside the NamedVectorStruct as the provided NamedVector

func (*NamedVectorStruct) FromNamedVectorStruct0

func (t *NamedVectorStruct) FromNamedVectorStruct0(v NamedVectorStruct0) error

FromNamedVectorStruct0 overwrites any union data inside the NamedVectorStruct as the provided NamedVectorStruct0

func (NamedVectorStruct) MarshalJSON

func (t NamedVectorStruct) MarshalJSON() ([]byte, error)

func (*NamedVectorStruct) MergeNamedVector

func (t *NamedVectorStruct) MergeNamedVector(v NamedVector) error

MergeNamedVector performs a merge with any union data inside the NamedVectorStruct, using the provided NamedVector

func (*NamedVectorStruct) MergeNamedVectorStruct0

func (t *NamedVectorStruct) MergeNamedVectorStruct0(v NamedVectorStruct0) error

MergeNamedVectorStruct0 performs a merge with any union data inside the NamedVectorStruct, using the provided NamedVectorStruct0

func (*NamedVectorStruct) UnmarshalJSON

func (t *NamedVectorStruct) UnmarshalJSON(b []byte) error

type NamedVectorStruct0

type NamedVectorStruct0 = []float32

NamedVectorStruct0 defines model for .

type Number

type Number interface {
	constraints.Integer | constraints.Float
}

type OperationDurationStatistics

type OperationDurationStatistics struct {
	AvgDurationMicros *float32 `json:"avg_duration_micros"`
	Count             uint     `json:"count"`
	FailCount         *uint    `json:"fail_count,omitempty"`
	MaxDurationMicros *float32 `json:"max_duration_micros"`
	MinDurationMicros *float32 `json:"min_duration_micros"`
}

OperationDurationStatistics defines model for OperationDurationStatistics.

type OptimizerTelemetry

type OptimizerTelemetry struct {
	Optimizations OperationDurationStatistics `json:"optimizations"`

	// Status Current state of the collection
	Status OptimizersStatus `json:"status"`
}

OptimizerTelemetry defines model for OptimizerTelemetry.

type OptimizersConfig

type OptimizersConfig struct {
	// DefaultSegmentNumber Target amount of segments optimizer will try to keep. Real amount of segments may vary depending on multiple parameters: - Amount of stored points - Current write RPS
	//
	// It is recommended to select default number of segments as a factor of the number of search threads, so that each segment would be handled evenly by one of the threads If `default_segment_number = 0`, will be automatically selected by the number of available CPUs
	DefaultSegmentNumber uint `json:"default_segment_number"`

	// DeletedThreshold The minimal fraction of deleted vectors in a segment, required to perform segment optimization
	DeletedThreshold float64 `json:"deleted_threshold"`

	// FlushIntervalSec Minimum interval between forced flushes.
	FlushIntervalSec uint64 `json:"flush_interval_sec"`

	// IndexingThreshold Maximum size (in KiloBytes) of vectors allowed for plain index. Default value based on <https://github.com/google-research/google-research/blob/master/scann/docs/algorithms.md> Note: 1Kb = 1 vector of size 256
	IndexingThreshold uint `json:"indexing_threshold"`

	// MaxOptimizationThreads Maximum available threads for optimization workers
	MaxOptimizationThreads uint `json:"max_optimization_threads"`

	// MaxSegmentSize Do not create segments larger this size (in KiloBytes). Large segments might require disproportionately long indexation times, therefore it makes sense to limit the size of segments.
	//
	// If indexation speed have more priority for your - make this parameter lower. If search speed is more important - make this parameter higher. Note: 1Kb = 1 vector of size 256 If not set, will be automatically selected considering the number of available CPUs.
	MaxSegmentSize *uint `json:"max_segment_size"`

	// MemmapThreshold Maximum size (in KiloBytes) of vectors to store in-memory per segment. Segments larger than this threshold will be stored as read-only memmaped file. To enable memmap storage, lower the threshold Note: 1Kb = 1 vector of size 256 If not set, mmap will not be used.
	MemmapThreshold *uint `json:"memmap_threshold"`

	// VacuumMinVectorNumber The minimal number of vectors in a segment, required to perform segment optimization
	VacuumMinVectorNumber uint `json:"vacuum_min_vector_number"`
}

OptimizersConfig defines model for OptimizersConfig.

type OptimizersConfigDiff

type OptimizersConfigDiff struct {
	// DefaultSegmentNumber Target amount of segments optimizer will try to keep. Real amount of segments may vary depending on multiple parameters: - Amount of stored points - Current write RPS
	//
	// It is recommended to select default number of segments as a factor of the number of search threads, so that each segment would be handled evenly by one of the threads If `default_segment_number = 0`, will be automatically selected by the number of available CPUs
	DefaultSegmentNumber *uint `json:"default_segment_number"`

	// DeletedThreshold The minimal fraction of deleted vectors in a segment, required to perform segment optimization
	DeletedThreshold *float64 `json:"deleted_threshold"`

	// FlushIntervalSec Minimum interval between forced flushes.
	FlushIntervalSec *uint64 `json:"flush_interval_sec"`

	// IndexingThreshold Maximum size (in KiloBytes) of vectors allowed for plain index. Default value based on <https://github.com/google-research/google-research/blob/master/scann/docs/algorithms.md> Note: 1Kb = 1 vector of size 256
	IndexingThreshold *uint `json:"indexing_threshold"`

	// MaxOptimizationThreads Maximum available threads for optimization workers
	MaxOptimizationThreads *uint `json:"max_optimization_threads"`

	// MaxSegmentSize Do not create segments larger this size (in KiloBytes). Large segments might require disproportionately long indexation times, therefore it makes sense to limit the size of segments.
	//
	// If indexation speed have more priority for your - make this parameter lower. If search speed is more important - make this parameter higher. Note: 1Kb = 1 vector of size 256
	MaxSegmentSize *uint `json:"max_segment_size"`

	// MemmapThreshold Maximum size (in KiloBytes) of vectors to store in-memory per segment. Segments larger than this threshold will be stored as read-only memmaped file. To enable memmap storage, lower the threshold Note: 1Kb = 1 vector of size 256
	MemmapThreshold *uint `json:"memmap_threshold"`

	// VacuumMinVectorNumber The minimal number of vectors in a segment, required to perform segment optimization
	VacuumMinVectorNumber *uint `json:"vacuum_min_vector_number"`
}

OptimizersConfigDiff defines model for OptimizersConfigDiff.

type OptimizersStatus

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

OptimizersStatus Current state of the collection

func (OptimizersStatus) AsOptimizersStatus0

func (t OptimizersStatus) AsOptimizersStatus0() (OptimizersStatus0, error)

AsOptimizersStatus0 returns the union data inside the OptimizersStatus as a OptimizersStatus0

func (OptimizersStatus) AsOptimizersStatus1

func (t OptimizersStatus) AsOptimizersStatus1() (OptimizersStatus1, error)

AsOptimizersStatus1 returns the union data inside the OptimizersStatus as a OptimizersStatus1

func (*OptimizersStatus) FromOptimizersStatus0

func (t *OptimizersStatus) FromOptimizersStatus0(v OptimizersStatus0) error

FromOptimizersStatus0 overwrites any union data inside the OptimizersStatus as the provided OptimizersStatus0

func (*OptimizersStatus) FromOptimizersStatus1

func (t *OptimizersStatus) FromOptimizersStatus1(v OptimizersStatus1) error

FromOptimizersStatus1 overwrites any union data inside the OptimizersStatus as the provided OptimizersStatus1

func (OptimizersStatus) MarshalJSON

func (t OptimizersStatus) MarshalJSON() ([]byte, error)

func (*OptimizersStatus) MergeOptimizersStatus0

func (t *OptimizersStatus) MergeOptimizersStatus0(v OptimizersStatus0) error

MergeOptimizersStatus0 performs a merge with any union data inside the OptimizersStatus, using the provided OptimizersStatus0

func (*OptimizersStatus) MergeOptimizersStatus1

func (t *OptimizersStatus) MergeOptimizersStatus1(v OptimizersStatus1) error

MergeOptimizersStatus1 performs a merge with any union data inside the OptimizersStatus, using the provided OptimizersStatus1

func (*OptimizersStatus) UnmarshalJSON

func (t *OptimizersStatus) UnmarshalJSON(b []byte) error

type OptimizersStatus0

type OptimizersStatus0 string

OptimizersStatus0 Optimizers are reporting as expected

const (
	Ok OptimizersStatus0 = "ok"
)

Defines values for OptimizersStatus0.

type OptimizersStatus1

type OptimizersStatus1 struct {
	Error string `json:"error"`
}

OptimizersStatus1 Something wrong happened with optimizers

type OverwritePayloadJSONRequestBody

type OverwritePayloadJSONRequestBody = SetPayload

OverwritePayloadJSONRequestBody defines body for OverwritePayload for application/json ContentType.

type OverwritePayloadParams

type OverwritePayloadParams struct {
	// Wait If true, wait for changes to actually happen
	Wait *bool `form:"wait,omitempty" json:"wait,omitempty"`

	// Ordering define ordering guarantees for the operation
	Ordering *WriteOrdering `form:"ordering,omitempty" json:"ordering,omitempty"`
}

OverwritePayloadParams defines parameters for OverwritePayload.

type OverwritePayloadResponse

type OverwritePayloadResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		Result *UpdateResult `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseOverwritePayloadResponse

func ParseOverwritePayloadResponse(rsp *http.Response) (*OverwritePayloadResponse, error)

ParseOverwritePayloadResponse parses an HTTP response from a OverwritePayloadWithResponse call

func (OverwritePayloadResponse) Status

func (r OverwritePayloadResponse) Status() string

Status returns HTTPResponse.Status

func (OverwritePayloadResponse) StatusCode

func (r OverwritePayloadResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type P2pConfigTelemetry

type P2pConfigTelemetry struct {
	ConnectionPoolSize uint `json:"connection_pool_size"`
}

P2pConfigTelemetry defines model for P2pConfigTelemetry.

type Payload

type Payload map[string]interface{}

Payload defines model for Payload.

type PayloadField

type PayloadField struct {
	// Key Payload field name
	Key string `json:"key"`
}

PayloadField Payload field

type PayloadFieldSchema

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

PayloadFieldSchema defines model for PayloadFieldSchema.

func (PayloadFieldSchema) AsPayloadSchemaParams

func (t PayloadFieldSchema) AsPayloadSchemaParams() (PayloadSchemaParams, error)

AsPayloadSchemaParams returns the union data inside the PayloadFieldSchema as a PayloadSchemaParams

func (PayloadFieldSchema) AsPayloadSchemaType

func (t PayloadFieldSchema) AsPayloadSchemaType() (PayloadSchemaType, error)

AsPayloadSchemaType returns the union data inside the PayloadFieldSchema as a PayloadSchemaType

func (*PayloadFieldSchema) FromPayloadSchemaParams

func (t *PayloadFieldSchema) FromPayloadSchemaParams(v PayloadSchemaParams) error

FromPayloadSchemaParams overwrites any union data inside the PayloadFieldSchema as the provided PayloadSchemaParams

func (*PayloadFieldSchema) FromPayloadSchemaType

func (t *PayloadFieldSchema) FromPayloadSchemaType(v PayloadSchemaType) error

FromPayloadSchemaType overwrites any union data inside the PayloadFieldSchema as the provided PayloadSchemaType

func (PayloadFieldSchema) MarshalJSON

func (t PayloadFieldSchema) MarshalJSON() ([]byte, error)

func (*PayloadFieldSchema) MergePayloadSchemaParams

func (t *PayloadFieldSchema) MergePayloadSchemaParams(v PayloadSchemaParams) error

MergePayloadSchemaParams performs a merge with any union data inside the PayloadFieldSchema, using the provided PayloadSchemaParams

func (*PayloadFieldSchema) MergePayloadSchemaType

func (t *PayloadFieldSchema) MergePayloadSchemaType(v PayloadSchemaType) error

MergePayloadSchemaType performs a merge with any union data inside the PayloadFieldSchema, using the provided PayloadSchemaType

func (*PayloadFieldSchema) UnmarshalJSON

func (t *PayloadFieldSchema) UnmarshalJSON(b []byte) error

type PayloadIndexInfo

type PayloadIndexInfo struct {
	// DataType All possible names of payload types
	DataType PayloadSchemaType        `json:"data_type"`
	Params   *PayloadIndexInfo_Params `json:"params,omitempty"`

	// Points Number of points indexed with this index
	Points uint `json:"points"`
}

PayloadIndexInfo Display payload field type & index information

type PayloadIndexInfoParams1

type PayloadIndexInfoParams1 = interface{}

PayloadIndexInfoParams1 defines model for .

type PayloadIndexInfo_Params

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

PayloadIndexInfo_Params defines model for PayloadIndexInfo.Params.

func (PayloadIndexInfo_Params) AsPayloadIndexInfoParams1

func (t PayloadIndexInfo_Params) AsPayloadIndexInfoParams1() (PayloadIndexInfoParams1, error)

AsPayloadIndexInfoParams1 returns the union data inside the PayloadIndexInfo_Params as a PayloadIndexInfoParams1

func (PayloadIndexInfo_Params) AsPayloadSchemaParams

func (t PayloadIndexInfo_Params) AsPayloadSchemaParams() (PayloadSchemaParams, error)

AsPayloadSchemaParams returns the union data inside the PayloadIndexInfo_Params as a PayloadSchemaParams

func (*PayloadIndexInfo_Params) FromPayloadIndexInfoParams1

func (t *PayloadIndexInfo_Params) FromPayloadIndexInfoParams1(v PayloadIndexInfoParams1) error

FromPayloadIndexInfoParams1 overwrites any union data inside the PayloadIndexInfo_Params as the provided PayloadIndexInfoParams1

func (*PayloadIndexInfo_Params) FromPayloadSchemaParams

func (t *PayloadIndexInfo_Params) FromPayloadSchemaParams(v PayloadSchemaParams) error

FromPayloadSchemaParams overwrites any union data inside the PayloadIndexInfo_Params as the provided PayloadSchemaParams

func (PayloadIndexInfo_Params) MarshalJSON

func (t PayloadIndexInfo_Params) MarshalJSON() ([]byte, error)

func (*PayloadIndexInfo_Params) MergePayloadIndexInfoParams1

func (t *PayloadIndexInfo_Params) MergePayloadIndexInfoParams1(v PayloadIndexInfoParams1) error

MergePayloadIndexInfoParams1 performs a merge with any union data inside the PayloadIndexInfo_Params, using the provided PayloadIndexInfoParams1

func (*PayloadIndexInfo_Params) MergePayloadSchemaParams

func (t *PayloadIndexInfo_Params) MergePayloadSchemaParams(v PayloadSchemaParams) error

MergePayloadSchemaParams performs a merge with any union data inside the PayloadIndexInfo_Params, using the provided PayloadSchemaParams

func (*PayloadIndexInfo_Params) UnmarshalJSON

func (t *PayloadIndexInfo_Params) UnmarshalJSON(b []byte) error

type PayloadIndexTelemetry

type PayloadIndexTelemetry struct {
	FieldName           *string `json:"field_name"`
	HistogramBucketSize *uint   `json:"histogram_bucket_size"`
	PointsCount         uint    `json:"points_count"`
	PointsValuesCount   uint    `json:"points_values_count"`
}

PayloadIndexTelemetry defines model for PayloadIndexTelemetry.

type PayloadSchemaParams

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

PayloadSchemaParams Payload type with parameters

func (PayloadSchemaParams) AsTextIndexParams

func (t PayloadSchemaParams) AsTextIndexParams() (TextIndexParams, error)

AsTextIndexParams returns the union data inside the PayloadSchemaParams as a TextIndexParams

func (*PayloadSchemaParams) FromTextIndexParams

func (t *PayloadSchemaParams) FromTextIndexParams(v TextIndexParams) error

FromTextIndexParams overwrites any union data inside the PayloadSchemaParams as the provided TextIndexParams

func (PayloadSchemaParams) MarshalJSON

func (t PayloadSchemaParams) MarshalJSON() ([]byte, error)

func (*PayloadSchemaParams) MergeTextIndexParams

func (t *PayloadSchemaParams) MergeTextIndexParams(v TextIndexParams) error

MergeTextIndexParams performs a merge with any union data inside the PayloadSchemaParams, using the provided TextIndexParams

func (*PayloadSchemaParams) UnmarshalJSON

func (t *PayloadSchemaParams) UnmarshalJSON(b []byte) error

type PayloadSchemaType

type PayloadSchemaType string

PayloadSchemaType All possible names of payload types

const (
	PayloadSchemaTypeFloat   PayloadSchemaType = "float"
	PayloadSchemaTypeGeo     PayloadSchemaType = "geo"
	PayloadSchemaTypeInteger PayloadSchemaType = "integer"
	PayloadSchemaTypeKeyword PayloadSchemaType = "keyword"
	PayloadSchemaTypeText    PayloadSchemaType = "text"
	PayloadSchemaTypeBool    PayloadSchemaType = "bool"
)

Defines values for PayloadSchemaType.

type PayloadSelector

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

PayloadSelector Specifies how to treat payload selector

func (PayloadSelector) AsPayloadSelectorExclude

func (t PayloadSelector) AsPayloadSelectorExclude() (PayloadSelectorExclude, error)

AsPayloadSelectorExclude returns the union data inside the PayloadSelector as a PayloadSelectorExclude

func (PayloadSelector) AsPayloadSelectorInclude

func (t PayloadSelector) AsPayloadSelectorInclude() (PayloadSelectorInclude, error)

AsPayloadSelectorInclude returns the union data inside the PayloadSelector as a PayloadSelectorInclude

func (*PayloadSelector) FromPayloadSelectorExclude

func (t *PayloadSelector) FromPayloadSelectorExclude(v PayloadSelectorExclude) error

FromPayloadSelectorExclude overwrites any union data inside the PayloadSelector as the provided PayloadSelectorExclude

func (*PayloadSelector) FromPayloadSelectorInclude

func (t *PayloadSelector) FromPayloadSelectorInclude(v PayloadSelectorInclude) error

FromPayloadSelectorInclude overwrites any union data inside the PayloadSelector as the provided PayloadSelectorInclude

func (PayloadSelector) MarshalJSON

func (t PayloadSelector) MarshalJSON() ([]byte, error)

func (*PayloadSelector) MergePayloadSelectorExclude

func (t *PayloadSelector) MergePayloadSelectorExclude(v PayloadSelectorExclude) error

MergePayloadSelectorExclude performs a merge with any union data inside the PayloadSelector, using the provided PayloadSelectorExclude

func (*PayloadSelector) MergePayloadSelectorInclude

func (t *PayloadSelector) MergePayloadSelectorInclude(v PayloadSelectorInclude) error

MergePayloadSelectorInclude performs a merge with any union data inside the PayloadSelector, using the provided PayloadSelectorInclude

func (*PayloadSelector) UnmarshalJSON

func (t *PayloadSelector) UnmarshalJSON(b []byte) error

type PayloadSelectorExclude

type PayloadSelectorExclude struct {
	// Exclude Exclude this fields from returning payload
	Exclude []string `json:"exclude"`
}

PayloadSelectorExclude defines model for PayloadSelectorExclude.

type PayloadSelectorInclude

type PayloadSelectorInclude struct {
	// Include Only include this payload keys
	Include []string `json:"include"`
}

PayloadSelectorInclude defines model for PayloadSelectorInclude.

type PayloadStorageType

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

PayloadStorageType Type of payload storage

func (PayloadStorageType) AsPayloadStorageType0

func (t PayloadStorageType) AsPayloadStorageType0() (PayloadStorageType0, error)

AsPayloadStorageType0 returns the union data inside the PayloadStorageType as a PayloadStorageType0

func (PayloadStorageType) AsPayloadStorageType1

func (t PayloadStorageType) AsPayloadStorageType1() (PayloadStorageType1, error)

AsPayloadStorageType1 returns the union data inside the PayloadStorageType as a PayloadStorageType1

func (*PayloadStorageType) FromPayloadStorageType0

func (t *PayloadStorageType) FromPayloadStorageType0(v PayloadStorageType0) error

FromPayloadStorageType0 overwrites any union data inside the PayloadStorageType as the provided PayloadStorageType0

func (*PayloadStorageType) FromPayloadStorageType1

func (t *PayloadStorageType) FromPayloadStorageType1(v PayloadStorageType1) error

FromPayloadStorageType1 overwrites any union data inside the PayloadStorageType as the provided PayloadStorageType1

func (PayloadStorageType) MarshalJSON

func (t PayloadStorageType) MarshalJSON() ([]byte, error)

func (*PayloadStorageType) MergePayloadStorageType0

func (t *PayloadStorageType) MergePayloadStorageType0(v PayloadStorageType0) error

MergePayloadStorageType0 performs a merge with any union data inside the PayloadStorageType, using the provided PayloadStorageType0

func (*PayloadStorageType) MergePayloadStorageType1

func (t *PayloadStorageType) MergePayloadStorageType1(v PayloadStorageType1) error

MergePayloadStorageType1 performs a merge with any union data inside the PayloadStorageType, using the provided PayloadStorageType1

func (*PayloadStorageType) UnmarshalJSON

func (t *PayloadStorageType) UnmarshalJSON(b []byte) error

type PayloadStorageType0

type PayloadStorageType0 struct {
	Type PayloadStorageType `json:"type"`
}

PayloadStorageType0 defines model for .

type PayloadStorageType1

type PayloadStorageType1 struct {
	Type PayloadStorageType `json:"type"`
}

PayloadStorageType1 defines model for .

type PeerInfo

type PeerInfo struct {
	Uri string `json:"uri"`
}

PeerInfo Information of a peer in the cluster

type PointIdsList

type PointIdsList struct {
	Points []ExtendedPointId `json:"points"`
}

PointIdsList defines model for PointIdsList.

type PointInsertOperations

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

PointInsertOperations defines model for PointInsertOperations.

func (PointInsertOperations) AsPointsBatch

func (t PointInsertOperations) AsPointsBatch() (PointsBatch, error)

AsPointsBatch returns the union data inside the PointInsertOperations as a PointsBatch

func (PointInsertOperations) AsPointsList

func (t PointInsertOperations) AsPointsList() (PointsList, error)

AsPointsList returns the union data inside the PointInsertOperations as a PointsList

func (*PointInsertOperations) FromPointsBatch

func (t *PointInsertOperations) FromPointsBatch(v PointsBatch) error

FromPointsBatch overwrites any union data inside the PointInsertOperations as the provided PointsBatch

func (*PointInsertOperations) FromPointsList

func (t *PointInsertOperations) FromPointsList(v PointsList) error

FromPointsList overwrites any union data inside the PointInsertOperations as the provided PointsList

func (PointInsertOperations) MarshalJSON

func (t PointInsertOperations) MarshalJSON() ([]byte, error)

func (*PointInsertOperations) MergePointsBatch

func (t *PointInsertOperations) MergePointsBatch(v PointsBatch) error

MergePointsBatch performs a merge with any union data inside the PointInsertOperations, using the provided PointsBatch

func (*PointInsertOperations) MergePointsList

func (t *PointInsertOperations) MergePointsList(v PointsList) error

MergePointsList performs a merge with any union data inside the PointInsertOperations, using the provided PointsList

func (*PointInsertOperations) UnmarshalJSON

func (t *PointInsertOperations) UnmarshalJSON(b []byte) error

type PointRequest

type PointRequest struct {
	// Ids Look for points with ids
	Ids []ExtendedPointId `json:"ids"`

	// WithPayload Select which payload to return with the response. Default: All
	WithPayload *PointRequest_WithPayload `json:"with_payload,omitempty"`

	// WithVector Options for specifying which vector to include
	WithVector *WithVector `json:"with_vector,omitempty"`
}

PointRequest defines model for PointRequest.

type PointRequestWithPayload1

type PointRequestWithPayload1 = interface{}

PointRequestWithPayload1 defines model for .

type PointRequest_WithPayload

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

PointRequest_WithPayload Select which payload to return with the response. Default: All

func (PointRequest_WithPayload) AsPointRequestWithPayload1

func (t PointRequest_WithPayload) AsPointRequestWithPayload1() (PointRequestWithPayload1, error)

AsPointRequestWithPayload1 returns the union data inside the PointRequest_WithPayload as a PointRequestWithPayload1

func (PointRequest_WithPayload) AsWithPayloadInterface

func (t PointRequest_WithPayload) AsWithPayloadInterface() (WithPayloadInterface, error)

AsWithPayloadInterface returns the union data inside the PointRequest_WithPayload as a WithPayloadInterface

func (*PointRequest_WithPayload) FromPointRequestWithPayload1

func (t *PointRequest_WithPayload) FromPointRequestWithPayload1(v PointRequestWithPayload1) error

FromPointRequestWithPayload1 overwrites any union data inside the PointRequest_WithPayload as the provided PointRequestWithPayload1

func (*PointRequest_WithPayload) FromWithPayloadInterface

func (t *PointRequest_WithPayload) FromWithPayloadInterface(v WithPayloadInterface) error

FromWithPayloadInterface overwrites any union data inside the PointRequest_WithPayload as the provided WithPayloadInterface

func (PointRequest_WithPayload) MarshalJSON

func (t PointRequest_WithPayload) MarshalJSON() ([]byte, error)

func (*PointRequest_WithPayload) MergePointRequestWithPayload1

func (t *PointRequest_WithPayload) MergePointRequestWithPayload1(v PointRequestWithPayload1) error

MergePointRequestWithPayload1 performs a merge with any union data inside the PointRequest_WithPayload, using the provided PointRequestWithPayload1

func (*PointRequest_WithPayload) MergeWithPayloadInterface

func (t *PointRequest_WithPayload) MergeWithPayloadInterface(v WithPayloadInterface) error

MergeWithPayloadInterface performs a merge with any union data inside the PointRequest_WithPayload, using the provided WithPayloadInterface

func (*PointRequest_WithPayload) UnmarshalJSON

func (t *PointRequest_WithPayload) UnmarshalJSON(b []byte) error

type PointStruct

type PointStruct struct {
	// Id Type, used for specifying point ID in user interface
	Id ExtendedPointId `json:"id"`

	// Payload Payload values (optional)
	Payload *PointStruct_Payload `json:"payload,omitempty"`

	// Vector Full vector data per point separator with single and multiple vector modes
	Vector VectorStruct `json:"vector"`
}

PointStruct defines model for PointStruct.

type PointStructPayload1

type PointStructPayload1 = interface{}

PointStructPayload1 defines model for .

type PointStruct_Payload

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

PointStruct_Payload Payload values (optional)

func (PointStruct_Payload) AsPayload

func (t PointStruct_Payload) AsPayload() (Payload, error)

AsPayload returns the union data inside the PointStruct_Payload as a Payload

func (PointStruct_Payload) AsPointStructPayload1

func (t PointStruct_Payload) AsPointStructPayload1() (PointStructPayload1, error)

AsPointStructPayload1 returns the union data inside the PointStruct_Payload as a PointStructPayload1

func (*PointStruct_Payload) FromPayload

func (t *PointStruct_Payload) FromPayload(v Payload) error

FromPayload overwrites any union data inside the PointStruct_Payload as the provided Payload

func (*PointStruct_Payload) FromPointStructPayload1

func (t *PointStruct_Payload) FromPointStructPayload1(v PointStructPayload1) error

FromPointStructPayload1 overwrites any union data inside the PointStruct_Payload as the provided PointStructPayload1

func (PointStruct_Payload) MarshalJSON

func (t PointStruct_Payload) MarshalJSON() ([]byte, error)

func (*PointStruct_Payload) MergePayload

func (t *PointStruct_Payload) MergePayload(v Payload) error

MergePayload performs a merge with any union data inside the PointStruct_Payload, using the provided Payload

func (*PointStruct_Payload) MergePointStructPayload1

func (t *PointStruct_Payload) MergePointStructPayload1(v PointStructPayload1) error

MergePointStructPayload1 performs a merge with any union data inside the PointStruct_Payload, using the provided PointStructPayload1

func (*PointStruct_Payload) UnmarshalJSON

func (t *PointStruct_Payload) UnmarshalJSON(b []byte) error

type PointsBatch

type PointsBatch struct {
	Batch Batch `json:"batch"`
}

PointsBatch defines model for PointsBatch.

type PointsList

type PointsList struct {
	Points []PointStruct `json:"points"`
}

PointsList defines model for PointsList.

type PointsSelector

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

PointsSelector defines model for PointsSelector.

func (PointsSelector) AsFilterSelector

func (t PointsSelector) AsFilterSelector() (FilterSelector, error)

AsFilterSelector returns the union data inside the PointsSelector as a FilterSelector

func (PointsSelector) AsPointIdsList

func (t PointsSelector) AsPointIdsList() (PointIdsList, error)

AsPointIdsList returns the union data inside the PointsSelector as a PointIdsList

func (*PointsSelector) FromFilterSelector

func (t *PointsSelector) FromFilterSelector(v FilterSelector) error

FromFilterSelector overwrites any union data inside the PointsSelector as the provided FilterSelector

func (*PointsSelector) FromPointIdsList

func (t *PointsSelector) FromPointIdsList(v PointIdsList) error

FromPointIdsList overwrites any union data inside the PointsSelector as the provided PointIdsList

func (PointsSelector) MarshalJSON

func (t PointsSelector) MarshalJSON() ([]byte, error)

func (*PointsSelector) MergeFilterSelector

func (t *PointsSelector) MergeFilterSelector(v FilterSelector) error

MergeFilterSelector performs a merge with any union data inside the PointsSelector, using the provided FilterSelector

func (*PointsSelector) MergePointIdsList

func (t *PointsSelector) MergePointIdsList(v PointIdsList) error

MergePointIdsList performs a merge with any union data inside the PointsSelector, using the provided PointIdsList

func (*PointsSelector) UnmarshalJSON

func (t *PointsSelector) UnmarshalJSON(b []byte) error

type PostLocksJSONRequestBody

type PostLocksJSONRequestBody = LocksOption

PostLocksJSONRequestBody defines body for PostLocks for application/json ContentType.

type PostLocksResponse

type PostLocksResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		Result *LocksOption `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParsePostLocksResponse

func ParsePostLocksResponse(rsp *http.Response) (*PostLocksResponse, error)

ParsePostLocksResponse parses an HTTP response from a PostLocksWithResponse call

func (PostLocksResponse) Status

func (r PostLocksResponse) Status() string

Status returns HTTPResponse.Status

func (PostLocksResponse) StatusCode

func (r PostLocksResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type QResponse

type QResponse struct {
	Result []QResponseResult `json:"result"`
	Status string            `json:"status"`
	Time   float32           `json:"time"`
	Next   *uint             `json:"next,omitempty"`
}

type QResponseResult

type QResponseResult struct {
	Id      string                 `json:"id"`
	Version int                    `json:"version"`
	Score   float32                `json:"score"`
	Payload QResponseResultPayload `json:"payload,omitempty"`
}

type QResponseResultPayload

type QResponseResultPayload struct {
	CreatedAt         int64                          `json:"created_at"`
	ImagePath         string                         `json:"image_path"`
	UpscaledImagePath string                         `json:"upscaled_image_path,omitempty"`
	GalleryStatus     generationoutput.GalleryStatus `json:"gallery_status"`
	IsFavorited       bool                           `json:"is_favorited"`
	Prompt            string                         `json:"prompt"`
	GenerationID      string                         `json:"generation_id"`
}

type QdrantClient

type QdrantClient struct {
	ActiveUrl string

	Client         *ClientWithResponses
	Doer           HttpRequestDoer
	Ctx            context.Context
	CollectionName string
	// contains filtered or unexported fields
}

func NewQdrantClient

func NewQdrantClient(ctx context.Context) (*QdrantClient, error)

func (*QdrantClient) BatchUpsert

func (q *QdrantClient) BatchUpsert(payload []map[string]interface{}, noRetry bool) error

Upsert

func (*QdrantClient) Count

func (q *QdrantClient) Count(noRetry bool) (uint, error)

Count

func (*QdrantClient) CountWithFilters

func (q *QdrantClient) CountWithFilters(filters *SearchRequest_Filter, noRetry bool) (uint, error)

Count with filters

func (*QdrantClient) CreateAllIndexes

func (q *QdrantClient) CreateAllIndexes() error

func (*QdrantClient) CreateCollectionIfNotExists

func (q *QdrantClient) CreateCollectionIfNotExists(noRetry bool) error

Creates our app collection if it doesnt exist

func (*QdrantClient) CreateIndex

func (q *QdrantClient) CreateIndex(fieldName string, schemaType PayloadSchemaType, noRetry bool) error

func (*QdrantClient) DeleteAllIDs

func (q *QdrantClient) DeleteAllIDs(ids []uuid.UUID, noRetry bool) error

func (*QdrantClient) DeleteById

func (q *QdrantClient) DeleteById(id uuid.UUID, noRetry bool) error

func (*QdrantClient) DeleteIndex

func (q *QdrantClient) DeleteIndex(fieldName string, noRetry bool) error

func (*QdrantClient) GetCollections

func (q *QdrantClient) GetCollections(noRetry bool) (*CollectionsResponse, error)

Get all collections in qdrant

func (*QdrantClient) GetIndexedPayloadFields

func (q *QdrantClient) GetIndexedPayloadFields(noRetry bool) ([]string, error)

Get list of fields with index

func (*QdrantClient) GetPoint

func (q *QdrantClient) GetPoint(id uuid.UUID, noRetry bool) (*GetPointResponseSC, error)

Get vectors for an ID

func (*QdrantClient) Query

func (q *QdrantClient) Query(embedding []float32, noRetry bool) (*QResponse, error)

Query

func (*QdrantClient) QueryGenerations

func (q *QdrantClient) QueryGenerations(embedding []float32, per_page int, offset *uint, scoreThreshold *float32, oversampling *float32, filters *SearchRequest_Filter, withPayload bool, noRetry bool) (*QResponse, error)

Public gallery search

func (QdrantClient) RoundTrip

func (q QdrantClient) RoundTrip(r *http.Request) (*http.Response, error)

func (*QdrantClient) SetPayload

func (q *QdrantClient) SetPayload(payload map[string]interface{}, ids []uuid.UUID, noRetry bool) error

Set payload on points

func (*QdrantClient) Upsert

func (q *QdrantClient) Upsert(id uuid.UUID, payload map[string]interface{}, imageEmbedding []float32, noRetry bool) error

Upsert

type QuantizationConfig

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

QuantizationConfig defines model for QuantizationConfig.

func (QuantizationConfig) AsScalarQuantization

func (t QuantizationConfig) AsScalarQuantization() (ScalarQuantization, error)

AsScalarQuantization returns the union data inside the QuantizationConfig as a ScalarQuantization

func (*QuantizationConfig) FromBinaryQuantization

func (t *QuantizationConfig) FromBinaryQuantization(v BinaryQuantization) error

func (*QuantizationConfig) FromScalarQuantization

func (t *QuantizationConfig) FromScalarQuantization(v ScalarQuantization) error

FromScalarQuantization overwrites any union data inside the QuantizationConfig as the provided ScalarQuantization

func (QuantizationConfig) MarshalJSON

func (t QuantizationConfig) MarshalJSON() ([]byte, error)

func (*QuantizationConfig) MergeScalarQuantization

func (t *QuantizationConfig) MergeScalarQuantization(v ScalarQuantization) error

MergeScalarQuantization performs a merge with any union data inside the QuantizationConfig, using the provided ScalarQuantization

func (*QuantizationConfig) UnmarshalJSON

func (t *QuantizationConfig) UnmarshalJSON(b []byte) error

type QuantizationSearchParams

type QuantizationSearchParams struct {
	// Ignore If true, quantized vectors are ignored. Default is false.
	Ignore *bool `json:"ignore,omitempty"`

	// Rescore If true, use original vectors to re-score top-k results. Might require more time in case if original vectors are stored on disk. Default is false.
	Rescore *bool `json:"rescore,omitempty"`

	Oversampling *float32 `json:"oversampling,omitempty"`
}

QuantizationSearchParams Additional parameters of the search

type RaftInfo

type RaftInfo struct {
	// Commit The index of the latest committed (finalized) operation that this peer is aware of.
	Commit uint64 `json:"commit"`

	// IsVoter Is this peer a voter or a learner
	IsVoter bool `json:"is_voter"`

	// Leader Leader of the current term
	Leader *uint64 `json:"leader"`

	// PendingOperations Number of consensus operations pending to be applied on this peer
	PendingOperations uint `json:"pending_operations"`

	// Role Role of this peer in the current term
	Role *RaftInfo_Role `json:"role,omitempty"`

	// Term Raft divides time into terms of arbitrary length, each beginning with an election. If a candidate wins the election, it remains the leader for the rest of the term. The term number increases monotonically. Each server stores the current term number which is also exchanged in every communication.
	Term uint64 `json:"term"`
}

RaftInfo Summary information about the current raft state

type RaftInfoRole1

type RaftInfoRole1 = interface{}

RaftInfoRole1 defines model for .

type RaftInfo_Role

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

RaftInfo_Role Role of this peer in the current term

func (RaftInfo_Role) AsRaftInfoRole1

func (t RaftInfo_Role) AsRaftInfoRole1() (RaftInfoRole1, error)

AsRaftInfoRole1 returns the union data inside the RaftInfo_Role as a RaftInfoRole1

func (RaftInfo_Role) AsStateRole

func (t RaftInfo_Role) AsStateRole() (StateRole, error)

AsStateRole returns the union data inside the RaftInfo_Role as a StateRole

func (*RaftInfo_Role) FromRaftInfoRole1

func (t *RaftInfo_Role) FromRaftInfoRole1(v RaftInfoRole1) error

FromRaftInfoRole1 overwrites any union data inside the RaftInfo_Role as the provided RaftInfoRole1

func (*RaftInfo_Role) FromStateRole

func (t *RaftInfo_Role) FromStateRole(v StateRole) error

FromStateRole overwrites any union data inside the RaftInfo_Role as the provided StateRole

func (RaftInfo_Role) MarshalJSON

func (t RaftInfo_Role) MarshalJSON() ([]byte, error)

func (*RaftInfo_Role) MergeRaftInfoRole1

func (t *RaftInfo_Role) MergeRaftInfoRole1(v RaftInfoRole1) error

MergeRaftInfoRole1 performs a merge with any union data inside the RaftInfo_Role, using the provided RaftInfoRole1

func (*RaftInfo_Role) MergeStateRole

func (t *RaftInfo_Role) MergeStateRole(v StateRole) error

MergeStateRole performs a merge with any union data inside the RaftInfo_Role, using the provided StateRole

func (*RaftInfo_Role) UnmarshalJSON

func (t *RaftInfo_Role) UnmarshalJSON(b []byte) error

type Range

type Range struct {
	// Gt point.key > range.gt
	Gt *float64 `json:"gt"`

	// Gte point.key >= range.gte
	Gte *float64 `json:"gte"`

	// Lt point.key < range.lt
	Lt *float64 `json:"lt"`

	// Lte point.key <= range.lte
	Lte *float64 `json:"lte"`
}

Range Range filter request

type ReadConsistency

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

ReadConsistency Read consistency parameter

Defines how many replicas should be queried to get the result

* `N` - send N random request and return points, which present on all of them

* `majority` - send N/2+1 random request and return points, which present on all of them

* `quorum` - send requests to all nodes and return points which present on majority of them

* `all` - send requests to all nodes and return points which present on all of them

Default value is `Factor(1)`

func (ReadConsistency) AsReadConsistency0

func (t ReadConsistency) AsReadConsistency0() (ReadConsistency0, error)

AsReadConsistency0 returns the union data inside the ReadConsistency as a ReadConsistency0

func (ReadConsistency) AsReadConsistencyType

func (t ReadConsistency) AsReadConsistencyType() (ReadConsistencyType, error)

AsReadConsistencyType returns the union data inside the ReadConsistency as a ReadConsistencyType

func (*ReadConsistency) FromReadConsistency0

func (t *ReadConsistency) FromReadConsistency0(v ReadConsistency0) error

FromReadConsistency0 overwrites any union data inside the ReadConsistency as the provided ReadConsistency0

func (*ReadConsistency) FromReadConsistencyType

func (t *ReadConsistency) FromReadConsistencyType(v ReadConsistencyType) error

FromReadConsistencyType overwrites any union data inside the ReadConsistency as the provided ReadConsistencyType

func (ReadConsistency) MarshalJSON

func (t ReadConsistency) MarshalJSON() ([]byte, error)

func (*ReadConsistency) MergeReadConsistency0

func (t *ReadConsistency) MergeReadConsistency0(v ReadConsistency0) error

MergeReadConsistency0 performs a merge with any union data inside the ReadConsistency, using the provided ReadConsistency0

func (*ReadConsistency) MergeReadConsistencyType

func (t *ReadConsistency) MergeReadConsistencyType(v ReadConsistencyType) error

MergeReadConsistencyType performs a merge with any union data inside the ReadConsistency, using the provided ReadConsistencyType

func (*ReadConsistency) UnmarshalJSON

func (t *ReadConsistency) UnmarshalJSON(b []byte) error

type ReadConsistency0

type ReadConsistency0 = uint

ReadConsistency0 defines model for .

type ReadConsistencyType

type ReadConsistencyType string

ReadConsistencyType * `majority` - send N/2+1 random request and return points, which present on all of them

* `quorum` - send requests to all nodes and return points which present on majority of nodes

* `all` - send requests to all nodes and return points which present on all nodes

const (
	All      ReadConsistencyType = "all"
	Majority ReadConsistencyType = "majority"
	Quorum   ReadConsistencyType = "quorum"
)

Defines values for ReadConsistencyType.

type RecommendBatchPointsJSONRequestBody

type RecommendBatchPointsJSONRequestBody = RecommendRequestBatch

RecommendBatchPointsJSONRequestBody defines body for RecommendBatchPoints for application/json ContentType.

type RecommendBatchPointsParams

type RecommendBatchPointsParams struct {
	// Consistency Define read consistency guarantees for the operation
	Consistency *ReadConsistency `form:"consistency,omitempty" json:"consistency,omitempty"`
}

RecommendBatchPointsParams defines parameters for RecommendBatchPoints.

type RecommendBatchPointsResponse

type RecommendBatchPointsResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		Result *[][]ScoredPoint `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseRecommendBatchPointsResponse

func ParseRecommendBatchPointsResponse(rsp *http.Response) (*RecommendBatchPointsResponse, error)

ParseRecommendBatchPointsResponse parses an HTTP response from a RecommendBatchPointsWithResponse call

func (RecommendBatchPointsResponse) Status

Status returns HTTPResponse.Status

func (RecommendBatchPointsResponse) StatusCode

func (r RecommendBatchPointsResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type RecommendPointsJSONRequestBody

type RecommendPointsJSONRequestBody = RecommendRequest

RecommendPointsJSONRequestBody defines body for RecommendPoints for application/json ContentType.

type RecommendPointsParams

type RecommendPointsParams struct {
	// Consistency Define read consistency guarantees for the operation
	Consistency *ReadConsistency `form:"consistency,omitempty" json:"consistency,omitempty"`
}

RecommendPointsParams defines parameters for RecommendPoints.

type RecommendPointsResponse

type RecommendPointsResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		Result *[]ScoredPoint `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseRecommendPointsResponse

func ParseRecommendPointsResponse(rsp *http.Response) (*RecommendPointsResponse, error)

ParseRecommendPointsResponse parses an HTTP response from a RecommendPointsWithResponse call

func (RecommendPointsResponse) Status

func (r RecommendPointsResponse) Status() string

Status returns HTTPResponse.Status

func (RecommendPointsResponse) StatusCode

func (r RecommendPointsResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type RecommendRequest

type RecommendRequest struct {
	// Filter Look only for points which satisfies this conditions
	Filter *RecommendRequest_Filter `json:"filter,omitempty"`

	// Limit Max number of result to return
	Limit uint `json:"limit"`

	// LookupFrom The location used to lookup vectors. If not specified - use current collection. Note: the other collection should have the same vector size as the current collection
	LookupFrom *RecommendRequest_LookupFrom `json:"lookup_from,omitempty"`

	// Negative Try to avoid vectors like this
	Negative *[]ExtendedPointId `json:"negative,omitempty"`

	// Offset Offset of the first result to return. May be used to paginate results. Note: large offset values may cause performance issues.
	Offset *uint `json:"offset,omitempty"`

	// Params Additional search params
	Params *RecommendRequest_Params `json:"params,omitempty"`

	// Positive Look for vectors closest to those
	Positive []ExtendedPointId `json:"positive"`

	// ScoreThreshold Define a minimal score threshold for the result. If defined, less similar results will not be returned. Score of the returned result might be higher or smaller than the threshold depending on the Distance function used. E.g. for cosine similarity only higher scores will be returned.
	ScoreThreshold *float32 `json:"score_threshold"`

	// Using Define which vector to use for recommendation, if not specified - try to use default vector
	Using *RecommendRequest_Using `json:"using,omitempty"`

	// WithPayload Select which payload to return with the response. Default: None
	WithPayload *RecommendRequest_WithPayload `json:"with_payload,omitempty"`

	// WithVector Whether to return the point vector with the result?
	WithVector *RecommendRequest_WithVector `json:"with_vector,omitempty"`
}

RecommendRequest Recommendation request. Provides positive and negative examples of the vectors, which are already stored in the collection.

Service should look for the points which are closer to positive examples and at the same time further to negative examples. The concrete way of how to compare negative and positive distances is up to implementation in `segment` crate.

type RecommendRequestBatch

type RecommendRequestBatch struct {
	Searches []RecommendRequest `json:"searches"`
}

RecommendRequestBatch defines model for RecommendRequestBatch.

type RecommendRequestFilter1

type RecommendRequestFilter1 = interface{}

RecommendRequestFilter1 defines model for .

type RecommendRequestLookupFrom1

type RecommendRequestLookupFrom1 = interface{}

RecommendRequestLookupFrom1 defines model for .

type RecommendRequestParams1

type RecommendRequestParams1 = interface{}

RecommendRequestParams1 defines model for .

type RecommendRequestUsing1

type RecommendRequestUsing1 = interface{}

RecommendRequestUsing1 defines model for .

type RecommendRequestWithPayload1

type RecommendRequestWithPayload1 = interface{}

RecommendRequestWithPayload1 defines model for .

type RecommendRequestWithVector1

type RecommendRequestWithVector1 = interface{}

RecommendRequestWithVector1 defines model for .

type RecommendRequest_Filter

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

RecommendRequest_Filter Look only for points which satisfies this conditions

func (RecommendRequest_Filter) AsFilter

func (t RecommendRequest_Filter) AsFilter() (Filter, error)

AsFilter returns the union data inside the RecommendRequest_Filter as a Filter

func (RecommendRequest_Filter) AsRecommendRequestFilter1

func (t RecommendRequest_Filter) AsRecommendRequestFilter1() (RecommendRequestFilter1, error)

AsRecommendRequestFilter1 returns the union data inside the RecommendRequest_Filter as a RecommendRequestFilter1

func (*RecommendRequest_Filter) FromFilter

func (t *RecommendRequest_Filter) FromFilter(v Filter) error

FromFilter overwrites any union data inside the RecommendRequest_Filter as the provided Filter

func (*RecommendRequest_Filter) FromRecommendRequestFilter1

func (t *RecommendRequest_Filter) FromRecommendRequestFilter1(v RecommendRequestFilter1) error

FromRecommendRequestFilter1 overwrites any union data inside the RecommendRequest_Filter as the provided RecommendRequestFilter1

func (RecommendRequest_Filter) MarshalJSON

func (t RecommendRequest_Filter) MarshalJSON() ([]byte, error)

func (*RecommendRequest_Filter) MergeFilter

func (t *RecommendRequest_Filter) MergeFilter(v Filter) error

MergeFilter performs a merge with any union data inside the RecommendRequest_Filter, using the provided Filter

func (*RecommendRequest_Filter) MergeRecommendRequestFilter1

func (t *RecommendRequest_Filter) MergeRecommendRequestFilter1(v RecommendRequestFilter1) error

MergeRecommendRequestFilter1 performs a merge with any union data inside the RecommendRequest_Filter, using the provided RecommendRequestFilter1

func (*RecommendRequest_Filter) UnmarshalJSON

func (t *RecommendRequest_Filter) UnmarshalJSON(b []byte) error

type RecommendRequest_LookupFrom

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

RecommendRequest_LookupFrom The location used to lookup vectors. If not specified - use current collection. Note: the other collection should have the same vector size as the current collection

func (RecommendRequest_LookupFrom) AsLookupLocation

func (t RecommendRequest_LookupFrom) AsLookupLocation() (LookupLocation, error)

AsLookupLocation returns the union data inside the RecommendRequest_LookupFrom as a LookupLocation

func (RecommendRequest_LookupFrom) AsRecommendRequestLookupFrom1

func (t RecommendRequest_LookupFrom) AsRecommendRequestLookupFrom1() (RecommendRequestLookupFrom1, error)

AsRecommendRequestLookupFrom1 returns the union data inside the RecommendRequest_LookupFrom as a RecommendRequestLookupFrom1

func (*RecommendRequest_LookupFrom) FromLookupLocation

func (t *RecommendRequest_LookupFrom) FromLookupLocation(v LookupLocation) error

FromLookupLocation overwrites any union data inside the RecommendRequest_LookupFrom as the provided LookupLocation

func (*RecommendRequest_LookupFrom) FromRecommendRequestLookupFrom1

func (t *RecommendRequest_LookupFrom) FromRecommendRequestLookupFrom1(v RecommendRequestLookupFrom1) error

FromRecommendRequestLookupFrom1 overwrites any union data inside the RecommendRequest_LookupFrom as the provided RecommendRequestLookupFrom1

func (RecommendRequest_LookupFrom) MarshalJSON

func (t RecommendRequest_LookupFrom) MarshalJSON() ([]byte, error)

func (*RecommendRequest_LookupFrom) MergeLookupLocation

func (t *RecommendRequest_LookupFrom) MergeLookupLocation(v LookupLocation) error

MergeLookupLocation performs a merge with any union data inside the RecommendRequest_LookupFrom, using the provided LookupLocation

func (*RecommendRequest_LookupFrom) MergeRecommendRequestLookupFrom1

func (t *RecommendRequest_LookupFrom) MergeRecommendRequestLookupFrom1(v RecommendRequestLookupFrom1) error

MergeRecommendRequestLookupFrom1 performs a merge with any union data inside the RecommendRequest_LookupFrom, using the provided RecommendRequestLookupFrom1

func (*RecommendRequest_LookupFrom) UnmarshalJSON

func (t *RecommendRequest_LookupFrom) UnmarshalJSON(b []byte) error

type RecommendRequest_Params

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

RecommendRequest_Params Additional search params

func (RecommendRequest_Params) AsRecommendRequestParams1

func (t RecommendRequest_Params) AsRecommendRequestParams1() (RecommendRequestParams1, error)

AsRecommendRequestParams1 returns the union data inside the RecommendRequest_Params as a RecommendRequestParams1

func (RecommendRequest_Params) AsSearchParams

func (t RecommendRequest_Params) AsSearchParams() (SearchParams, error)

AsSearchParams returns the union data inside the RecommendRequest_Params as a SearchParams

func (*RecommendRequest_Params) FromRecommendRequestParams1

func (t *RecommendRequest_Params) FromRecommendRequestParams1(v RecommendRequestParams1) error

FromRecommendRequestParams1 overwrites any union data inside the RecommendRequest_Params as the provided RecommendRequestParams1

func (*RecommendRequest_Params) FromSearchParams

func (t *RecommendRequest_Params) FromSearchParams(v SearchParams) error

FromSearchParams overwrites any union data inside the RecommendRequest_Params as the provided SearchParams

func (RecommendRequest_Params) MarshalJSON

func (t RecommendRequest_Params) MarshalJSON() ([]byte, error)

func (*RecommendRequest_Params) MergeRecommendRequestParams1

func (t *RecommendRequest_Params) MergeRecommendRequestParams1(v RecommendRequestParams1) error

MergeRecommendRequestParams1 performs a merge with any union data inside the RecommendRequest_Params, using the provided RecommendRequestParams1

func (*RecommendRequest_Params) MergeSearchParams

func (t *RecommendRequest_Params) MergeSearchParams(v SearchParams) error

MergeSearchParams performs a merge with any union data inside the RecommendRequest_Params, using the provided SearchParams

func (*RecommendRequest_Params) UnmarshalJSON

func (t *RecommendRequest_Params) UnmarshalJSON(b []byte) error

type RecommendRequest_Using

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

RecommendRequest_Using Define which vector to use for recommendation, if not specified - try to use default vector

func (RecommendRequest_Using) AsRecommendRequestUsing1

func (t RecommendRequest_Using) AsRecommendRequestUsing1() (RecommendRequestUsing1, error)

AsRecommendRequestUsing1 returns the union data inside the RecommendRequest_Using as a RecommendRequestUsing1

func (RecommendRequest_Using) AsUsingVector

func (t RecommendRequest_Using) AsUsingVector() (UsingVector, error)

AsUsingVector returns the union data inside the RecommendRequest_Using as a UsingVector

func (*RecommendRequest_Using) FromRecommendRequestUsing1

func (t *RecommendRequest_Using) FromRecommendRequestUsing1(v RecommendRequestUsing1) error

FromRecommendRequestUsing1 overwrites any union data inside the RecommendRequest_Using as the provided RecommendRequestUsing1

func (*RecommendRequest_Using) FromUsingVector

func (t *RecommendRequest_Using) FromUsingVector(v UsingVector) error

FromUsingVector overwrites any union data inside the RecommendRequest_Using as the provided UsingVector

func (RecommendRequest_Using) MarshalJSON

func (t RecommendRequest_Using) MarshalJSON() ([]byte, error)

func (*RecommendRequest_Using) MergeRecommendRequestUsing1

func (t *RecommendRequest_Using) MergeRecommendRequestUsing1(v RecommendRequestUsing1) error

MergeRecommendRequestUsing1 performs a merge with any union data inside the RecommendRequest_Using, using the provided RecommendRequestUsing1

func (*RecommendRequest_Using) MergeUsingVector

func (t *RecommendRequest_Using) MergeUsingVector(v UsingVector) error

MergeUsingVector performs a merge with any union data inside the RecommendRequest_Using, using the provided UsingVector

func (*RecommendRequest_Using) UnmarshalJSON

func (t *RecommendRequest_Using) UnmarshalJSON(b []byte) error

type RecommendRequest_WithPayload

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

RecommendRequest_WithPayload Select which payload to return with the response. Default: None

func (RecommendRequest_WithPayload) AsRecommendRequestWithPayload1

func (t RecommendRequest_WithPayload) AsRecommendRequestWithPayload1() (RecommendRequestWithPayload1, error)

AsRecommendRequestWithPayload1 returns the union data inside the RecommendRequest_WithPayload as a RecommendRequestWithPayload1

func (RecommendRequest_WithPayload) AsWithPayloadInterface

func (t RecommendRequest_WithPayload) AsWithPayloadInterface() (WithPayloadInterface, error)

AsWithPayloadInterface returns the union data inside the RecommendRequest_WithPayload as a WithPayloadInterface

func (*RecommendRequest_WithPayload) FromRecommendRequestWithPayload1

func (t *RecommendRequest_WithPayload) FromRecommendRequestWithPayload1(v RecommendRequestWithPayload1) error

FromRecommendRequestWithPayload1 overwrites any union data inside the RecommendRequest_WithPayload as the provided RecommendRequestWithPayload1

func (*RecommendRequest_WithPayload) FromWithPayloadInterface

func (t *RecommendRequest_WithPayload) FromWithPayloadInterface(v WithPayloadInterface) error

FromWithPayloadInterface overwrites any union data inside the RecommendRequest_WithPayload as the provided WithPayloadInterface

func (RecommendRequest_WithPayload) MarshalJSON

func (t RecommendRequest_WithPayload) MarshalJSON() ([]byte, error)

func (*RecommendRequest_WithPayload) MergeRecommendRequestWithPayload1

func (t *RecommendRequest_WithPayload) MergeRecommendRequestWithPayload1(v RecommendRequestWithPayload1) error

MergeRecommendRequestWithPayload1 performs a merge with any union data inside the RecommendRequest_WithPayload, using the provided RecommendRequestWithPayload1

func (*RecommendRequest_WithPayload) MergeWithPayloadInterface

func (t *RecommendRequest_WithPayload) MergeWithPayloadInterface(v WithPayloadInterface) error

MergeWithPayloadInterface performs a merge with any union data inside the RecommendRequest_WithPayload, using the provided WithPayloadInterface

func (*RecommendRequest_WithPayload) UnmarshalJSON

func (t *RecommendRequest_WithPayload) UnmarshalJSON(b []byte) error

type RecommendRequest_WithVector

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

RecommendRequest_WithVector Whether to return the point vector with the result?

func (RecommendRequest_WithVector) AsRecommendRequestWithVector1

func (t RecommendRequest_WithVector) AsRecommendRequestWithVector1() (RecommendRequestWithVector1, error)

AsRecommendRequestWithVector1 returns the union data inside the RecommendRequest_WithVector as a RecommendRequestWithVector1

func (RecommendRequest_WithVector) AsWithVector

func (t RecommendRequest_WithVector) AsWithVector() (WithVector, error)

AsWithVector returns the union data inside the RecommendRequest_WithVector as a WithVector

func (*RecommendRequest_WithVector) FromRecommendRequestWithVector1

func (t *RecommendRequest_WithVector) FromRecommendRequestWithVector1(v RecommendRequestWithVector1) error

FromRecommendRequestWithVector1 overwrites any union data inside the RecommendRequest_WithVector as the provided RecommendRequestWithVector1

func (*RecommendRequest_WithVector) FromWithVector

func (t *RecommendRequest_WithVector) FromWithVector(v WithVector) error

FromWithVector overwrites any union data inside the RecommendRequest_WithVector as the provided WithVector

func (RecommendRequest_WithVector) MarshalJSON

func (t RecommendRequest_WithVector) MarshalJSON() ([]byte, error)

func (*RecommendRequest_WithVector) MergeRecommendRequestWithVector1

func (t *RecommendRequest_WithVector) MergeRecommendRequestWithVector1(v RecommendRequestWithVector1) error

MergeRecommendRequestWithVector1 performs a merge with any union data inside the RecommendRequest_WithVector, using the provided RecommendRequestWithVector1

func (*RecommendRequest_WithVector) MergeWithVector

func (t *RecommendRequest_WithVector) MergeWithVector(v WithVector) error

MergeWithVector performs a merge with any union data inside the RecommendRequest_WithVector, using the provided WithVector

func (*RecommendRequest_WithVector) UnmarshalJSON

func (t *RecommendRequest_WithVector) UnmarshalJSON(b []byte) error

type Record

type Record struct {
	// Id Type, used for specifying point ID in user interface
	Id ExtendedPointId `json:"id"`

	// Payload Payload - values assigned to the point
	Payload *Record_Payload `json:"payload,omitempty"`

	// Vector Vector of the point
	Vector *Record_Vector `json:"vector,omitempty"`
}

Record Point data

type RecordPayload1

type RecordPayload1 = interface{}

RecordPayload1 defines model for .

type RecordVector1

type RecordVector1 = interface{}

RecordVector1 defines model for .

type Record_Payload

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

Record_Payload Payload - values assigned to the point

func (Record_Payload) AsPayload

func (t Record_Payload) AsPayload() (Payload, error)

AsPayload returns the union data inside the Record_Payload as a Payload

func (Record_Payload) AsRecordPayload1

func (t Record_Payload) AsRecordPayload1() (RecordPayload1, error)

AsRecordPayload1 returns the union data inside the Record_Payload as a RecordPayload1

func (*Record_Payload) FromPayload

func (t *Record_Payload) FromPayload(v Payload) error

FromPayload overwrites any union data inside the Record_Payload as the provided Payload

func (*Record_Payload) FromRecordPayload1

func (t *Record_Payload) FromRecordPayload1(v RecordPayload1) error

FromRecordPayload1 overwrites any union data inside the Record_Payload as the provided RecordPayload1

func (Record_Payload) MarshalJSON

func (t Record_Payload) MarshalJSON() ([]byte, error)

func (*Record_Payload) MergePayload

func (t *Record_Payload) MergePayload(v Payload) error

MergePayload performs a merge with any union data inside the Record_Payload, using the provided Payload

func (*Record_Payload) MergeRecordPayload1

func (t *Record_Payload) MergeRecordPayload1(v RecordPayload1) error

MergeRecordPayload1 performs a merge with any union data inside the Record_Payload, using the provided RecordPayload1

func (*Record_Payload) UnmarshalJSON

func (t *Record_Payload) UnmarshalJSON(b []byte) error

type Record_Vector

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

Record_Vector Vector of the point

func (Record_Vector) AsRecordVector1

func (t Record_Vector) AsRecordVector1() (RecordVector1, error)

AsRecordVector1 returns the union data inside the Record_Vector as a RecordVector1

func (Record_Vector) AsVectorStruct

func (t Record_Vector) AsVectorStruct() (VectorStruct, error)

AsVectorStruct returns the union data inside the Record_Vector as a VectorStruct

func (*Record_Vector) FromRecordVector1

func (t *Record_Vector) FromRecordVector1(v RecordVector1) error

FromRecordVector1 overwrites any union data inside the Record_Vector as the provided RecordVector1

func (*Record_Vector) FromVectorStruct

func (t *Record_Vector) FromVectorStruct(v VectorStruct) error

FromVectorStruct overwrites any union data inside the Record_Vector as the provided VectorStruct

func (Record_Vector) MarshalJSON

func (t Record_Vector) MarshalJSON() ([]byte, error)

func (*Record_Vector) MergeRecordVector1

func (t *Record_Vector) MergeRecordVector1(v RecordVector1) error

MergeRecordVector1 performs a merge with any union data inside the Record_Vector, using the provided RecordVector1

func (*Record_Vector) MergeVectorStruct

func (t *Record_Vector) MergeVectorStruct(v VectorStruct) error

MergeVectorStruct performs a merge with any union data inside the Record_Vector, using the provided VectorStruct

func (*Record_Vector) UnmarshalJSON

func (t *Record_Vector) UnmarshalJSON(b []byte) error

type RecoverCurrentPeerResponse

type RecoverCurrentPeerResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		Result *bool `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseRecoverCurrentPeerResponse

func ParseRecoverCurrentPeerResponse(rsp *http.Response) (*RecoverCurrentPeerResponse, error)

ParseRecoverCurrentPeerResponse parses an HTTP response from a RecoverCurrentPeerWithResponse call

func (RecoverCurrentPeerResponse) Status

Status returns HTTPResponse.Status

func (RecoverCurrentPeerResponse) StatusCode

func (r RecoverCurrentPeerResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type RecoverFromSnapshotJSONRequestBody

type RecoverFromSnapshotJSONRequestBody = SnapshotRecover

RecoverFromSnapshotJSONRequestBody defines body for RecoverFromSnapshot for application/json ContentType.

type RecoverFromSnapshotParams

type RecoverFromSnapshotParams struct {
	// Wait If true, wait for changes to actually happen. If false - let changes happen in background. Default is true.
	Wait *bool `form:"wait,omitempty" json:"wait,omitempty"`
}

RecoverFromSnapshotParams defines parameters for RecoverFromSnapshot.

type RecoverFromSnapshotResponse

type RecoverFromSnapshotResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		Result *bool `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseRecoverFromSnapshotResponse

func ParseRecoverFromSnapshotResponse(rsp *http.Response) (*RecoverFromSnapshotResponse, error)

ParseRecoverFromSnapshotResponse parses an HTTP response from a RecoverFromSnapshotWithResponse call

func (RecoverFromSnapshotResponse) Status

Status returns HTTPResponse.Status

func (RecoverFromSnapshotResponse) StatusCode

func (r RecoverFromSnapshotResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type RemoteShardInfo

type RemoteShardInfo struct {
	// PeerId Remote peer id
	PeerId uint64 `json:"peer_id"`

	// ShardId Remote shard id
	ShardId uint32 `json:"shard_id"`

	// State State of the single shard within a replica set.
	State ReplicaState `json:"state"`
}

RemoteShardInfo defines model for RemoteShardInfo.

type RemoteShardTelemetry

type RemoteShardTelemetry struct {
	PeerId   *uint64                     `json:"peer_id"`
	Searches OperationDurationStatistics `json:"searches"`
	ShardId  uint32                      `json:"shard_id"`
	Updates  OperationDurationStatistics `json:"updates"`
}

RemoteShardTelemetry defines model for RemoteShardTelemetry.

type RemovePeerParams

type RemovePeerParams struct {
	// Force If true - removes peer even if it has shards/replicas on it.
	Force *bool `form:"force,omitempty" json:"force,omitempty"`
}

RemovePeerParams defines parameters for RemovePeer.

type RemovePeerResponse

type RemovePeerResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		Result *bool `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseRemovePeerResponse

func ParseRemovePeerResponse(rsp *http.Response) (*RemovePeerResponse, error)

ParseRemovePeerResponse parses an HTTP response from a RemovePeerWithResponse call

func (RemovePeerResponse) Status

func (r RemovePeerResponse) Status() string

Status returns HTTPResponse.Status

func (RemovePeerResponse) StatusCode

func (r RemovePeerResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type RenameAlias

type RenameAlias struct {
	NewAliasName string `json:"new_alias_name"`
	OldAliasName string `json:"old_alias_name"`
}

RenameAlias Change alias to a new one

type RenameAliasOperation

type RenameAliasOperation struct {
	// RenameAlias Change alias to a new one
	RenameAlias RenameAlias `json:"rename_alias"`
}

RenameAliasOperation Change alias to a new one

type Replica

type Replica struct {
	PeerId  uint64 `json:"peer_id"`
	ShardId uint32 `json:"shard_id"`
}

Replica defines model for Replica.

type ReplicaSetTelemetry

type ReplicaSetTelemetry struct {
	Id              uint32                     `json:"id"`
	Local           *ReplicaSetTelemetry_Local `json:"local,omitempty"`
	Remote          []RemoteShardTelemetry     `json:"remote"`
	ReplicateStates map[string]ReplicaState    `json:"replicate_states"`
}

ReplicaSetTelemetry defines model for ReplicaSetTelemetry.

type ReplicaSetTelemetryLocal1

type ReplicaSetTelemetryLocal1 = interface{}

ReplicaSetTelemetryLocal1 defines model for .

type ReplicaSetTelemetry_Local

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

ReplicaSetTelemetry_Local defines model for ReplicaSetTelemetry.Local.

func (ReplicaSetTelemetry_Local) AsLocalShardTelemetry

func (t ReplicaSetTelemetry_Local) AsLocalShardTelemetry() (LocalShardTelemetry, error)

AsLocalShardTelemetry returns the union data inside the ReplicaSetTelemetry_Local as a LocalShardTelemetry

func (ReplicaSetTelemetry_Local) AsReplicaSetTelemetryLocal1

func (t ReplicaSetTelemetry_Local) AsReplicaSetTelemetryLocal1() (ReplicaSetTelemetryLocal1, error)

AsReplicaSetTelemetryLocal1 returns the union data inside the ReplicaSetTelemetry_Local as a ReplicaSetTelemetryLocal1

func (*ReplicaSetTelemetry_Local) FromLocalShardTelemetry

func (t *ReplicaSetTelemetry_Local) FromLocalShardTelemetry(v LocalShardTelemetry) error

FromLocalShardTelemetry overwrites any union data inside the ReplicaSetTelemetry_Local as the provided LocalShardTelemetry

func (*ReplicaSetTelemetry_Local) FromReplicaSetTelemetryLocal1

func (t *ReplicaSetTelemetry_Local) FromReplicaSetTelemetryLocal1(v ReplicaSetTelemetryLocal1) error

FromReplicaSetTelemetryLocal1 overwrites any union data inside the ReplicaSetTelemetry_Local as the provided ReplicaSetTelemetryLocal1

func (ReplicaSetTelemetry_Local) MarshalJSON

func (t ReplicaSetTelemetry_Local) MarshalJSON() ([]byte, error)

func (*ReplicaSetTelemetry_Local) MergeLocalShardTelemetry

func (t *ReplicaSetTelemetry_Local) MergeLocalShardTelemetry(v LocalShardTelemetry) error

MergeLocalShardTelemetry performs a merge with any union data inside the ReplicaSetTelemetry_Local, using the provided LocalShardTelemetry

func (*ReplicaSetTelemetry_Local) MergeReplicaSetTelemetryLocal1

func (t *ReplicaSetTelemetry_Local) MergeReplicaSetTelemetryLocal1(v ReplicaSetTelemetryLocal1) error

MergeReplicaSetTelemetryLocal1 performs a merge with any union data inside the ReplicaSetTelemetry_Local, using the provided ReplicaSetTelemetryLocal1

func (*ReplicaSetTelemetry_Local) UnmarshalJSON

func (t *ReplicaSetTelemetry_Local) UnmarshalJSON(b []byte) error

type ReplicaState

type ReplicaState string

ReplicaState State of the single shard within a replica set.

const (
	Active       ReplicaState = "Active"
	Dead         ReplicaState = "Dead"
	Initializing ReplicaState = "Initializing"
	Listener     ReplicaState = "Listener"
	Partial      ReplicaState = "Partial"
)

Defines values for ReplicaState.

type ReplicateShardOperation

type ReplicateShardOperation struct {
	ReplicateShard MoveShard `json:"replicate_shard"`
}

ReplicateShardOperation defines model for ReplicateShardOperation.

type RequestEditorFn

type RequestEditorFn func(ctx context.Context, req *http.Request) error

RequestEditorFn is the function signature for the RequestEditor callback function

type RequestsTelemetry

type RequestsTelemetry struct {
	Grpc GrpcTelemetry   `json:"grpc"`
	Rest WebApiTelemetry `json:"rest"`
}

RequestsTelemetry defines model for RequestsTelemetry.

type RunningEnvironmentTelemetry

type RunningEnvironmentTelemetry struct {
	Cores               *uint   `json:"cores"`
	CpuFlags            string  `json:"cpu_flags"`
	DiskSize            *uint   `json:"disk_size"`
	Distribution        *string `json:"distribution"`
	DistributionVersion *string `json:"distribution_version"`
	IsDocker            bool    `json:"is_docker"`
	RamSize             *uint   `json:"ram_size"`
}

RunningEnvironmentTelemetry defines model for RunningEnvironmentTelemetry.

type SCIsEmpty

type SCIsEmpty struct {
	Key string `json:"key,omitempty"`
}

type SCMatchCondition

type SCMatchCondition struct {
	Key     string     `json:"key,omitempty"`
	Match   *SCValue   `json:"match,omitempty"`
	IsEmpty *SCIsEmpty `json:"is_empty,omitempty"`
	// { has_id: [1, 2, 3, 3]}
	HasId []uuid.UUID `json:"has_id,omitempty"`
	// ! TODO Interface since we can't embed a generic struct?
	Range interface{} `json:"range,omitempty"`
	// We can also have a nested condition
	// { must: [ { key: "name", match: { value: "John" } } ] }
	Must    []SCMatchCondition `json:"must,omitempty"`
	MustNot []SCMatchCondition `json:"must_not,omitempty"`
	Should  []SCMatchCondition `json:"should,omitempty"`
}

type SCRange

type SCRange[T Number] struct {
	Key string `json:"key,omitempty"`
	Gt  *T     `json:"gt,omitempty"`
	Gte *T     `json:"gte,omitempty"`
	Lt  *T     `json:"lt,omitempty"`
	Lte *T     `json:"lte,omitempty"`
}

type SCValue

type SCValue struct {
	Value interface{} `json:"value"`
}

SearchRequest_Filter Look only for points which satisfies this conditions

type ScalarQuantization

type ScalarQuantization struct {
	Scalar ScalarQuantizationConfig `json:"scalar"`
}

ScalarQuantization defines model for ScalarQuantization.

type ScalarQuantizationConfig

type ScalarQuantizationConfig struct {
	// AlwaysRam If true - quantized vectors always will be stored in RAM, ignoring the config of main storage
	AlwaysRam *bool `json:"always_ram"`

	// Quantile Quantile for quantization. Expected value range in (0, 1.0]. If not set - use the whole range of values
	Quantile *float32   `json:"quantile"`
	Type     ScalarType `json:"type"`
}

ScalarQuantizationConfig defines model for ScalarQuantizationConfig.

type ScalarType

type ScalarType string

ScalarType defines model for ScalarType.

const (
	Int8 ScalarType = "int8"
)

Defines values for ScalarType.

type ScoredPoint

type ScoredPoint struct {
	// Id Type, used for specifying point ID in user interface
	Id ExtendedPointId `json:"id"`

	// Payload Payload - values assigned to the point
	Payload *ScoredPoint_Payload `json:"payload,omitempty"`

	// Score Points vector distance to the query vector
	Score float32 `json:"score"`

	// Vector Vector of the point
	Vector *ScoredPoint_Vector `json:"vector,omitempty"`

	// Version Point version
	Version uint64 `json:"version"`
}

ScoredPoint Search result

type ScoredPointPayload1

type ScoredPointPayload1 = interface{}

ScoredPointPayload1 defines model for .

type ScoredPointVector1

type ScoredPointVector1 = interface{}

ScoredPointVector1 defines model for .

type ScoredPoint_Payload

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

ScoredPoint_Payload Payload - values assigned to the point

func (ScoredPoint_Payload) AsPayload

func (t ScoredPoint_Payload) AsPayload() (Payload, error)

AsPayload returns the union data inside the ScoredPoint_Payload as a Payload

func (ScoredPoint_Payload) AsScoredPointPayload1

func (t ScoredPoint_Payload) AsScoredPointPayload1() (ScoredPointPayload1, error)

AsScoredPointPayload1 returns the union data inside the ScoredPoint_Payload as a ScoredPointPayload1

func (*ScoredPoint_Payload) FromPayload

func (t *ScoredPoint_Payload) FromPayload(v Payload) error

FromPayload overwrites any union data inside the ScoredPoint_Payload as the provided Payload

func (*ScoredPoint_Payload) FromScoredPointPayload1

func (t *ScoredPoint_Payload) FromScoredPointPayload1(v ScoredPointPayload1) error

FromScoredPointPayload1 overwrites any union data inside the ScoredPoint_Payload as the provided ScoredPointPayload1

func (ScoredPoint_Payload) MarshalJSON

func (t ScoredPoint_Payload) MarshalJSON() ([]byte, error)

func (*ScoredPoint_Payload) MergePayload

func (t *ScoredPoint_Payload) MergePayload(v Payload) error

MergePayload performs a merge with any union data inside the ScoredPoint_Payload, using the provided Payload

func (*ScoredPoint_Payload) MergeScoredPointPayload1

func (t *ScoredPoint_Payload) MergeScoredPointPayload1(v ScoredPointPayload1) error

MergeScoredPointPayload1 performs a merge with any union data inside the ScoredPoint_Payload, using the provided ScoredPointPayload1

func (*ScoredPoint_Payload) UnmarshalJSON

func (t *ScoredPoint_Payload) UnmarshalJSON(b []byte) error

type ScoredPoint_Vector

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

ScoredPoint_Vector Vector of the point

func (ScoredPoint_Vector) AsScoredPointVector1

func (t ScoredPoint_Vector) AsScoredPointVector1() (ScoredPointVector1, error)

AsScoredPointVector1 returns the union data inside the ScoredPoint_Vector as a ScoredPointVector1

func (ScoredPoint_Vector) AsVectorStruct

func (t ScoredPoint_Vector) AsVectorStruct() (VectorStruct, error)

AsVectorStruct returns the union data inside the ScoredPoint_Vector as a VectorStruct

func (*ScoredPoint_Vector) FromScoredPointVector1

func (t *ScoredPoint_Vector) FromScoredPointVector1(v ScoredPointVector1) error

FromScoredPointVector1 overwrites any union data inside the ScoredPoint_Vector as the provided ScoredPointVector1

func (*ScoredPoint_Vector) FromVectorStruct

func (t *ScoredPoint_Vector) FromVectorStruct(v VectorStruct) error

FromVectorStruct overwrites any union data inside the ScoredPoint_Vector as the provided VectorStruct

func (ScoredPoint_Vector) MarshalJSON

func (t ScoredPoint_Vector) MarshalJSON() ([]byte, error)

func (*ScoredPoint_Vector) MergeScoredPointVector1

func (t *ScoredPoint_Vector) MergeScoredPointVector1(v ScoredPointVector1) error

MergeScoredPointVector1 performs a merge with any union data inside the ScoredPoint_Vector, using the provided ScoredPointVector1

func (*ScoredPoint_Vector) MergeVectorStruct

func (t *ScoredPoint_Vector) MergeVectorStruct(v VectorStruct) error

MergeVectorStruct performs a merge with any union data inside the ScoredPoint_Vector, using the provided VectorStruct

func (*ScoredPoint_Vector) UnmarshalJSON

func (t *ScoredPoint_Vector) UnmarshalJSON(b []byte) error

type ScrollPointsJSONRequestBody

type ScrollPointsJSONRequestBody = ScrollRequest

ScrollPointsJSONRequestBody defines body for ScrollPoints for application/json ContentType.

type ScrollPointsParams

type ScrollPointsParams struct {
	// Consistency Define read consistency guarantees for the operation
	Consistency *ReadConsistency `form:"consistency,omitempty" json:"consistency,omitempty"`
}

ScrollPointsParams defines parameters for ScrollPoints.

type ScrollPointsResponse

type ScrollPointsResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		// Result Result of the points read request
		Result *ScrollResult `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseScrollPointsResponse

func ParseScrollPointsResponse(rsp *http.Response) (*ScrollPointsResponse, error)

ParseScrollPointsResponse parses an HTTP response from a ScrollPointsWithResponse call

func (ScrollPointsResponse) Status

func (r ScrollPointsResponse) Status() string

Status returns HTTPResponse.Status

func (ScrollPointsResponse) StatusCode

func (r ScrollPointsResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type ScrollRequest

type ScrollRequest struct {
	// Filter Look only for points which satisfies this conditions. If not provided - all points.
	Filter *ScrollRequest_Filter `json:"filter,omitempty"`

	// Limit Page size. Default: 10
	Limit *uint `json:"limit"`

	// Offset Start ID to read points from.
	Offset *ScrollRequest_Offset `json:"offset,omitempty"`

	// WithPayload Select which payload to return with the response. Default: All
	WithPayload *ScrollRequest_WithPayload `json:"with_payload,omitempty"`

	// WithVector Options for specifying which vector to include
	WithVector *WithVector `json:"with_vector,omitempty"`
}

ScrollRequest Scroll request - paginate over all points which matches given condition

type ScrollRequestFilter1

type ScrollRequestFilter1 = interface{}

ScrollRequestFilter1 defines model for .

type ScrollRequestOffset1

type ScrollRequestOffset1 = interface{}

ScrollRequestOffset1 defines model for .

type ScrollRequestWithPayload1

type ScrollRequestWithPayload1 = interface{}

ScrollRequestWithPayload1 defines model for .

type ScrollRequest_Filter

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

ScrollRequest_Filter Look only for points which satisfies this conditions. If not provided - all points.

func (ScrollRequest_Filter) AsFilter

func (t ScrollRequest_Filter) AsFilter() (Filter, error)

AsFilter returns the union data inside the ScrollRequest_Filter as a Filter

func (ScrollRequest_Filter) AsScrollRequestFilter1

func (t ScrollRequest_Filter) AsScrollRequestFilter1() (ScrollRequestFilter1, error)

AsScrollRequestFilter1 returns the union data inside the ScrollRequest_Filter as a ScrollRequestFilter1

func (*ScrollRequest_Filter) FromFilter

func (t *ScrollRequest_Filter) FromFilter(v Filter) error

FromFilter overwrites any union data inside the ScrollRequest_Filter as the provided Filter

func (*ScrollRequest_Filter) FromScrollRequestFilter1

func (t *ScrollRequest_Filter) FromScrollRequestFilter1(v ScrollRequestFilter1) error

FromScrollRequestFilter1 overwrites any union data inside the ScrollRequest_Filter as the provided ScrollRequestFilter1

func (ScrollRequest_Filter) MarshalJSON

func (t ScrollRequest_Filter) MarshalJSON() ([]byte, error)

func (*ScrollRequest_Filter) MergeFilter

func (t *ScrollRequest_Filter) MergeFilter(v Filter) error

MergeFilter performs a merge with any union data inside the ScrollRequest_Filter, using the provided Filter

func (*ScrollRequest_Filter) MergeScrollRequestFilter1

func (t *ScrollRequest_Filter) MergeScrollRequestFilter1(v ScrollRequestFilter1) error

MergeScrollRequestFilter1 performs a merge with any union data inside the ScrollRequest_Filter, using the provided ScrollRequestFilter1

func (*ScrollRequest_Filter) UnmarshalJSON

func (t *ScrollRequest_Filter) UnmarshalJSON(b []byte) error

type ScrollRequest_Offset

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

ScrollRequest_Offset Start ID to read points from.

func (ScrollRequest_Offset) AsExtendedPointId

func (t ScrollRequest_Offset) AsExtendedPointId() (ExtendedPointId, error)

AsExtendedPointId returns the union data inside the ScrollRequest_Offset as a ExtendedPointId

func (ScrollRequest_Offset) AsScrollRequestOffset1

func (t ScrollRequest_Offset) AsScrollRequestOffset1() (ScrollRequestOffset1, error)

AsScrollRequestOffset1 returns the union data inside the ScrollRequest_Offset as a ScrollRequestOffset1

func (*ScrollRequest_Offset) FromExtendedPointId

func (t *ScrollRequest_Offset) FromExtendedPointId(v ExtendedPointId) error

FromExtendedPointId overwrites any union data inside the ScrollRequest_Offset as the provided ExtendedPointId

func (*ScrollRequest_Offset) FromScrollRequestOffset1

func (t *ScrollRequest_Offset) FromScrollRequestOffset1(v ScrollRequestOffset1) error

FromScrollRequestOffset1 overwrites any union data inside the ScrollRequest_Offset as the provided ScrollRequestOffset1

func (ScrollRequest_Offset) MarshalJSON

func (t ScrollRequest_Offset) MarshalJSON() ([]byte, error)

func (*ScrollRequest_Offset) MergeExtendedPointId

func (t *ScrollRequest_Offset) MergeExtendedPointId(v ExtendedPointId) error

MergeExtendedPointId performs a merge with any union data inside the ScrollRequest_Offset, using the provided ExtendedPointId

func (*ScrollRequest_Offset) MergeScrollRequestOffset1

func (t *ScrollRequest_Offset) MergeScrollRequestOffset1(v ScrollRequestOffset1) error

MergeScrollRequestOffset1 performs a merge with any union data inside the ScrollRequest_Offset, using the provided ScrollRequestOffset1

func (*ScrollRequest_Offset) UnmarshalJSON

func (t *ScrollRequest_Offset) UnmarshalJSON(b []byte) error

type ScrollRequest_WithPayload

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

ScrollRequest_WithPayload Select which payload to return with the response. Default: All

func (ScrollRequest_WithPayload) AsScrollRequestWithPayload1

func (t ScrollRequest_WithPayload) AsScrollRequestWithPayload1() (ScrollRequestWithPayload1, error)

AsScrollRequestWithPayload1 returns the union data inside the ScrollRequest_WithPayload as a ScrollRequestWithPayload1

func (ScrollRequest_WithPayload) AsWithPayloadInterface

func (t ScrollRequest_WithPayload) AsWithPayloadInterface() (WithPayloadInterface, error)

AsWithPayloadInterface returns the union data inside the ScrollRequest_WithPayload as a WithPayloadInterface

func (*ScrollRequest_WithPayload) FromScrollRequestWithPayload1

func (t *ScrollRequest_WithPayload) FromScrollRequestWithPayload1(v ScrollRequestWithPayload1) error

FromScrollRequestWithPayload1 overwrites any union data inside the ScrollRequest_WithPayload as the provided ScrollRequestWithPayload1

func (*ScrollRequest_WithPayload) FromWithPayloadInterface

func (t *ScrollRequest_WithPayload) FromWithPayloadInterface(v WithPayloadInterface) error

FromWithPayloadInterface overwrites any union data inside the ScrollRequest_WithPayload as the provided WithPayloadInterface

func (ScrollRequest_WithPayload) MarshalJSON

func (t ScrollRequest_WithPayload) MarshalJSON() ([]byte, error)

func (*ScrollRequest_WithPayload) MergeScrollRequestWithPayload1

func (t *ScrollRequest_WithPayload) MergeScrollRequestWithPayload1(v ScrollRequestWithPayload1) error

MergeScrollRequestWithPayload1 performs a merge with any union data inside the ScrollRequest_WithPayload, using the provided ScrollRequestWithPayload1

func (*ScrollRequest_WithPayload) MergeWithPayloadInterface

func (t *ScrollRequest_WithPayload) MergeWithPayloadInterface(v WithPayloadInterface) error

MergeWithPayloadInterface performs a merge with any union data inside the ScrollRequest_WithPayload, using the provided WithPayloadInterface

func (*ScrollRequest_WithPayload) UnmarshalJSON

func (t *ScrollRequest_WithPayload) UnmarshalJSON(b []byte) error

type ScrollResult

type ScrollResult struct {
	// NextPageOffset Offset which should be used to retrieve a next page result
	NextPageOffset *ScrollResult_NextPageOffset `json:"next_page_offset,omitempty"`

	// Points List of retrieved points
	Points []Record `json:"points"`
}

ScrollResult Result of the points read request

type ScrollResultNextPageOffset1

type ScrollResultNextPageOffset1 = interface{}

ScrollResultNextPageOffset1 defines model for .

type ScrollResult_NextPageOffset

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

ScrollResult_NextPageOffset Offset which should be used to retrieve a next page result

func (ScrollResult_NextPageOffset) AsExtendedPointId

func (t ScrollResult_NextPageOffset) AsExtendedPointId() (ExtendedPointId, error)

AsExtendedPointId returns the union data inside the ScrollResult_NextPageOffset as a ExtendedPointId

func (ScrollResult_NextPageOffset) AsScrollResultNextPageOffset1

func (t ScrollResult_NextPageOffset) AsScrollResultNextPageOffset1() (ScrollResultNextPageOffset1, error)

AsScrollResultNextPageOffset1 returns the union data inside the ScrollResult_NextPageOffset as a ScrollResultNextPageOffset1

func (*ScrollResult_NextPageOffset) FromExtendedPointId

func (t *ScrollResult_NextPageOffset) FromExtendedPointId(v ExtendedPointId) error

FromExtendedPointId overwrites any union data inside the ScrollResult_NextPageOffset as the provided ExtendedPointId

func (*ScrollResult_NextPageOffset) FromScrollResultNextPageOffset1

func (t *ScrollResult_NextPageOffset) FromScrollResultNextPageOffset1(v ScrollResultNextPageOffset1) error

FromScrollResultNextPageOffset1 overwrites any union data inside the ScrollResult_NextPageOffset as the provided ScrollResultNextPageOffset1

func (ScrollResult_NextPageOffset) MarshalJSON

func (t ScrollResult_NextPageOffset) MarshalJSON() ([]byte, error)

func (*ScrollResult_NextPageOffset) MergeExtendedPointId

func (t *ScrollResult_NextPageOffset) MergeExtendedPointId(v ExtendedPointId) error

MergeExtendedPointId performs a merge with any union data inside the ScrollResult_NextPageOffset, using the provided ExtendedPointId

func (*ScrollResult_NextPageOffset) MergeScrollResultNextPageOffset1

func (t *ScrollResult_NextPageOffset) MergeScrollResultNextPageOffset1(v ScrollResultNextPageOffset1) error

MergeScrollResultNextPageOffset1 performs a merge with any union data inside the ScrollResult_NextPageOffset, using the provided ScrollResultNextPageOffset1

func (*ScrollResult_NextPageOffset) UnmarshalJSON

func (t *ScrollResult_NextPageOffset) UnmarshalJSON(b []byte) error

type SearchBatchPointsJSONRequestBody

type SearchBatchPointsJSONRequestBody = SearchRequestBatch

SearchBatchPointsJSONRequestBody defines body for SearchBatchPoints for application/json ContentType.

type SearchBatchPointsParams

type SearchBatchPointsParams struct {
	// Consistency Define read consistency guarantees for the operation
	Consistency *ReadConsistency `form:"consistency,omitempty" json:"consistency,omitempty"`
}

SearchBatchPointsParams defines parameters for SearchBatchPoints.

type SearchBatchPointsResponse

type SearchBatchPointsResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		Result *[][]ScoredPoint `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseSearchBatchPointsResponse

func ParseSearchBatchPointsResponse(rsp *http.Response) (*SearchBatchPointsResponse, error)

ParseSearchBatchPointsResponse parses an HTTP response from a SearchBatchPointsWithResponse call

func (SearchBatchPointsResponse) Status

func (r SearchBatchPointsResponse) Status() string

Status returns HTTPResponse.Status

func (SearchBatchPointsResponse) StatusCode

func (r SearchBatchPointsResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type SearchParams

type SearchParams struct {
	// Exact Search without approximation. If set to true, search may run long but with exact results.
	Exact *bool `json:"exact,omitempty"`

	// HnswEf Params relevant to HNSW index /// Size of the beam in a beam-search. Larger the value - more accurate the result, more time required for search.
	HnswEf *uint `json:"hnsw_ef"`

	// Quantization Quantization params
	Quantization *SearchParams_Quantization `json:"quantization,omitempty"`
}

SearchParams Additional parameters of the search

type SearchParamsQuantization1

type SearchParamsQuantization1 = interface{}

SearchParamsQuantization1 defines model for .

type SearchParams_Quantization

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

SearchParams_Quantization Quantization params

func (SearchParams_Quantization) AsQuantizationSearchParams

func (t SearchParams_Quantization) AsQuantizationSearchParams() (QuantizationSearchParams, error)

AsQuantizationSearchParams returns the union data inside the SearchParams_Quantization as a QuantizationSearchParams

func (SearchParams_Quantization) AsSearchParamsQuantization1

func (t SearchParams_Quantization) AsSearchParamsQuantization1() (SearchParamsQuantization1, error)

AsSearchParamsQuantization1 returns the union data inside the SearchParams_Quantization as a SearchParamsQuantization1

func (*SearchParams_Quantization) FromQuantizationSearchParams

func (t *SearchParams_Quantization) FromQuantizationSearchParams(v QuantizationSearchParams) error

FromQuantizationSearchParams overwrites any union data inside the SearchParams_Quantization as the provided QuantizationSearchParams

func (*SearchParams_Quantization) FromSearchParamsQuantization1

func (t *SearchParams_Quantization) FromSearchParamsQuantization1(v SearchParamsQuantization1) error

FromSearchParamsQuantization1 overwrites any union data inside the SearchParams_Quantization as the provided SearchParamsQuantization1

func (SearchParams_Quantization) MarshalJSON

func (t SearchParams_Quantization) MarshalJSON() ([]byte, error)

func (*SearchParams_Quantization) MergeQuantizationSearchParams

func (t *SearchParams_Quantization) MergeQuantizationSearchParams(v QuantizationSearchParams) error

MergeQuantizationSearchParams performs a merge with any union data inside the SearchParams_Quantization, using the provided QuantizationSearchParams

func (*SearchParams_Quantization) MergeSearchParamsQuantization1

func (t *SearchParams_Quantization) MergeSearchParamsQuantization1(v SearchParamsQuantization1) error

MergeSearchParamsQuantization1 performs a merge with any union data inside the SearchParams_Quantization, using the provided SearchParamsQuantization1

func (*SearchParams_Quantization) UnmarshalJSON

func (t *SearchParams_Quantization) UnmarshalJSON(b []byte) error

type SearchPointsJSONRequestBody

type SearchPointsJSONRequestBody = SearchRequest

SearchPointsJSONRequestBody defines body for SearchPoints for application/json ContentType.

type SearchPointsParams

type SearchPointsParams struct {
	// Consistency Define read consistency guarantees for the operation
	Consistency *ReadConsistency `form:"consistency,omitempty" json:"consistency,omitempty"`
}

SearchPointsParams defines parameters for SearchPoints.

type SearchPointsResponse

type SearchPointsResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		Result *[]ScoredPoint `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseSearchPointsResponse

func ParseSearchPointsResponse(rsp *http.Response) (*SearchPointsResponse, error)

ParseSearchPointsResponse parses an HTTP response from a SearchPointsWithResponse call

func (SearchPointsResponse) Status

func (r SearchPointsResponse) Status() string

Status returns HTTPResponse.Status

func (SearchPointsResponse) StatusCode

func (r SearchPointsResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type SearchRequest

type SearchRequest struct {
	// Filter Look only for points which satisfies this conditions
	Filter *SearchRequest_Filter `json:"filter,omitempty"`

	// Limit Max number of result to return
	Limit uint `json:"limit"`

	// Offset Offset of the first result to return. May be used to paginate results. Note: large offset values may cause performance issues.
	Offset *uint `json:"offset,omitempty"`

	// Params Additional search params
	Params *SearchRequest_Params `json:"params,omitempty"`

	// ScoreThreshold Define a minimal score threshold for the result. If defined, less similar results will not be returned. Score of the returned result might be higher or smaller than the threshold depending on the Distance function used. E.g. for cosine similarity only higher scores will be returned.
	ScoreThreshold *float32 `json:"score_threshold"`

	// Vector Vector data separator for named and unnamed modes Unanmed mode:
	//
	// { "vector": [1.0, 2.0, 3.0] }
	//
	// or named mode:
	//
	// { "vector": { "vector": [1.0, 2.0, 3.0], "name": "image-embeddings" } }
	Vector NamedVectorStruct `json:"vector"`

	// WithPayload Select which payload to return with the response. Default: None
	WithPayload bool `json:"with_payload,omitempty"`

	// WithVector Whether to return the point vector with the result?
	WithVector *SearchRequest_WithVector `json:"with_vector,omitempty"`
}

SearchRequest Search request. Holds all conditions and parameters for the search of most similar points by vector similarity given the filtering restrictions.

type SearchRequestBatch

type SearchRequestBatch struct {
	Searches []SearchRequest `json:"searches"`
}

SearchRequestBatch defines model for SearchRequestBatch.

type SearchRequestFilter1

type SearchRequestFilter1 = interface{}

SearchRequestFilter1 defines model for .

type SearchRequestParams1

type SearchRequestParams1 = interface{}

SearchRequestParams1 defines model for .

type SearchRequestWithPayload1

type SearchRequestWithPayload1 = interface{}

SearchRequestWithPayload1 defines model for .

type SearchRequestWithVector1

type SearchRequestWithVector1 = interface{}

SearchRequestWithVector1 defines model for .

type SearchRequest_Filter

type SearchRequest_Filter struct {
	Must    []SCMatchCondition `json:"must,omitempty"`
	MustNot []SCMatchCondition `json:"must_not,omitempty"`
	Should  []SCMatchCondition `json:"should,omitempty"`
}

type SearchRequest_Params

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

SearchRequest_Params Additional search params

func (SearchRequest_Params) AsSearchParams

func (t SearchRequest_Params) AsSearchParams() (SearchParams, error)

AsSearchParams returns the union data inside the SearchRequest_Params as a SearchParams

func (SearchRequest_Params) AsSearchRequestParams1

func (t SearchRequest_Params) AsSearchRequestParams1() (SearchRequestParams1, error)

AsSearchRequestParams1 returns the union data inside the SearchRequest_Params as a SearchRequestParams1

func (*SearchRequest_Params) FromSearchParams

func (t *SearchRequest_Params) FromSearchParams(v SearchParams) error

FromSearchParams overwrites any union data inside the SearchRequest_Params as the provided SearchParams

func (*SearchRequest_Params) FromSearchRequestParams1

func (t *SearchRequest_Params) FromSearchRequestParams1(v SearchRequestParams1) error

FromSearchRequestParams1 overwrites any union data inside the SearchRequest_Params as the provided SearchRequestParams1

func (SearchRequest_Params) MarshalJSON

func (t SearchRequest_Params) MarshalJSON() ([]byte, error)

func (*SearchRequest_Params) MergeSearchParams

func (t *SearchRequest_Params) MergeSearchParams(v SearchParams) error

MergeSearchParams performs a merge with any union data inside the SearchRequest_Params, using the provided SearchParams

func (*SearchRequest_Params) MergeSearchRequestParams1

func (t *SearchRequest_Params) MergeSearchRequestParams1(v SearchRequestParams1) error

MergeSearchRequestParams1 performs a merge with any union data inside the SearchRequest_Params, using the provided SearchRequestParams1

func (*SearchRequest_Params) UnmarshalJSON

func (t *SearchRequest_Params) UnmarshalJSON(b []byte) error

type SearchRequest_WithPayload

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

SearchRequest_WithPayload Select which payload to return with the response. Default: None

func (SearchRequest_WithPayload) AsSearchRequestWithPayload1

func (t SearchRequest_WithPayload) AsSearchRequestWithPayload1() (SearchRequestWithPayload1, error)

AsSearchRequestWithPayload1 returns the union data inside the SearchRequest_WithPayload as a SearchRequestWithPayload1

func (SearchRequest_WithPayload) AsWithPayloadInterface

func (t SearchRequest_WithPayload) AsWithPayloadInterface() (WithPayloadInterface, error)

AsWithPayloadInterface returns the union data inside the SearchRequest_WithPayload as a WithPayloadInterface

func (*SearchRequest_WithPayload) FromSearchRequestWithPayload1

func (t *SearchRequest_WithPayload) FromSearchRequestWithPayload1(v SearchRequestWithPayload1) error

FromSearchRequestWithPayload1 overwrites any union data inside the SearchRequest_WithPayload as the provided SearchRequestWithPayload1

func (*SearchRequest_WithPayload) FromWithPayloadInterface

func (t *SearchRequest_WithPayload) FromWithPayloadInterface(v WithPayloadInterface) error

FromWithPayloadInterface overwrites any union data inside the SearchRequest_WithPayload as the provided WithPayloadInterface

func (SearchRequest_WithPayload) MarshalJSON

func (t SearchRequest_WithPayload) MarshalJSON() ([]byte, error)

func (*SearchRequest_WithPayload) MergeSearchRequestWithPayload1

func (t *SearchRequest_WithPayload) MergeSearchRequestWithPayload1(v SearchRequestWithPayload1) error

MergeSearchRequestWithPayload1 performs a merge with any union data inside the SearchRequest_WithPayload, using the provided SearchRequestWithPayload1

func (*SearchRequest_WithPayload) MergeWithPayloadInterface

func (t *SearchRequest_WithPayload) MergeWithPayloadInterface(v WithPayloadInterface) error

MergeWithPayloadInterface performs a merge with any union data inside the SearchRequest_WithPayload, using the provided WithPayloadInterface

func (*SearchRequest_WithPayload) UnmarshalJSON

func (t *SearchRequest_WithPayload) UnmarshalJSON(b []byte) error

type SearchRequest_WithVector

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

SearchRequest_WithVector Whether to return the point vector with the result?

func (SearchRequest_WithVector) AsSearchRequestWithVector1

func (t SearchRequest_WithVector) AsSearchRequestWithVector1() (SearchRequestWithVector1, error)

AsSearchRequestWithVector1 returns the union data inside the SearchRequest_WithVector as a SearchRequestWithVector1

func (SearchRequest_WithVector) AsWithVector

func (t SearchRequest_WithVector) AsWithVector() (WithVector, error)

AsWithVector returns the union data inside the SearchRequest_WithVector as a WithVector

func (*SearchRequest_WithVector) FromSearchRequestWithVector1

func (t *SearchRequest_WithVector) FromSearchRequestWithVector1(v SearchRequestWithVector1) error

FromSearchRequestWithVector1 overwrites any union data inside the SearchRequest_WithVector as the provided SearchRequestWithVector1

func (*SearchRequest_WithVector) FromWithVector

func (t *SearchRequest_WithVector) FromWithVector(v WithVector) error

FromWithVector overwrites any union data inside the SearchRequest_WithVector as the provided WithVector

func (SearchRequest_WithVector) MarshalJSON

func (t SearchRequest_WithVector) MarshalJSON() ([]byte, error)

func (*SearchRequest_WithVector) MergeSearchRequestWithVector1

func (t *SearchRequest_WithVector) MergeSearchRequestWithVector1(v SearchRequestWithVector1) error

MergeSearchRequestWithVector1 performs a merge with any union data inside the SearchRequest_WithVector, using the provided SearchRequestWithVector1

func (*SearchRequest_WithVector) MergeWithVector

func (t *SearchRequest_WithVector) MergeWithVector(v WithVector) error

MergeWithVector performs a merge with any union data inside the SearchRequest_WithVector, using the provided WithVector

func (*SearchRequest_WithVector) UnmarshalJSON

func (t *SearchRequest_WithVector) UnmarshalJSON(b []byte) error

type SegmentConfig

type SegmentConfig struct {
	// Index Vector index configuration of the segment
	Index Indexes `json:"index"`

	// PayloadStorageType Type of payload storage
	PayloadStorageType *PayloadStorageType `json:"payload_storage_type,omitempty"`

	// QuantizationConfig Quantization parameters. If none - quantization is disabled.
	QuantizationConfig *SegmentConfig_QuantizationConfig `json:"quantization_config,omitempty"`

	// StorageType Type of vector storage
	StorageType StorageType                 `json:"storage_type"`
	VectorData  map[string]VectorDataConfig `json:"vector_data"`
}

SegmentConfig defines model for SegmentConfig.

type SegmentConfigQuantizationConfig1

type SegmentConfigQuantizationConfig1 = interface{}

SegmentConfigQuantizationConfig1 defines model for .

type SegmentConfig_QuantizationConfig

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

SegmentConfig_QuantizationConfig Quantization parameters. If none - quantization is disabled.

func (SegmentConfig_QuantizationConfig) AsQuantizationConfig

func (t SegmentConfig_QuantizationConfig) AsQuantizationConfig() (QuantizationConfig, error)

AsQuantizationConfig returns the union data inside the SegmentConfig_QuantizationConfig as a QuantizationConfig

func (SegmentConfig_QuantizationConfig) AsSegmentConfigQuantizationConfig1

func (t SegmentConfig_QuantizationConfig) AsSegmentConfigQuantizationConfig1() (SegmentConfigQuantizationConfig1, error)

AsSegmentConfigQuantizationConfig1 returns the union data inside the SegmentConfig_QuantizationConfig as a SegmentConfigQuantizationConfig1

func (*SegmentConfig_QuantizationConfig) FromQuantizationConfig

func (t *SegmentConfig_QuantizationConfig) FromQuantizationConfig(v QuantizationConfig) error

FromQuantizationConfig overwrites any union data inside the SegmentConfig_QuantizationConfig as the provided QuantizationConfig

func (*SegmentConfig_QuantizationConfig) FromSegmentConfigQuantizationConfig1

func (t *SegmentConfig_QuantizationConfig) FromSegmentConfigQuantizationConfig1(v SegmentConfigQuantizationConfig1) error

FromSegmentConfigQuantizationConfig1 overwrites any union data inside the SegmentConfig_QuantizationConfig as the provided SegmentConfigQuantizationConfig1

func (SegmentConfig_QuantizationConfig) MarshalJSON

func (t SegmentConfig_QuantizationConfig) MarshalJSON() ([]byte, error)

func (*SegmentConfig_QuantizationConfig) MergeQuantizationConfig

func (t *SegmentConfig_QuantizationConfig) MergeQuantizationConfig(v QuantizationConfig) error

MergeQuantizationConfig performs a merge with any union data inside the SegmentConfig_QuantizationConfig, using the provided QuantizationConfig

func (*SegmentConfig_QuantizationConfig) MergeSegmentConfigQuantizationConfig1

func (t *SegmentConfig_QuantizationConfig) MergeSegmentConfigQuantizationConfig1(v SegmentConfigQuantizationConfig1) error

MergeSegmentConfigQuantizationConfig1 performs a merge with any union data inside the SegmentConfig_QuantizationConfig, using the provided SegmentConfigQuantizationConfig1

func (*SegmentConfig_QuantizationConfig) UnmarshalJSON

func (t *SegmentConfig_QuantizationConfig) UnmarshalJSON(b []byte) error

type SegmentInfo

type SegmentInfo struct {
	DiskUsageBytes    uint                        `json:"disk_usage_bytes"`
	IndexSchema       map[string]PayloadIndexInfo `json:"index_schema"`
	IsAppendable      bool                        `json:"is_appendable"`
	NumDeletedVectors uint                        `json:"num_deleted_vectors"`
	NumPoints         uint                        `json:"num_points"`
	NumVectors        uint                        `json:"num_vectors"`
	RamUsageBytes     uint                        `json:"ram_usage_bytes"`

	// SegmentType Type of segment
	SegmentType SegmentType `json:"segment_type"`
}

SegmentInfo Aggregated information about segment

type SegmentTelemetry

type SegmentTelemetry struct {
	Config SegmentConfig `json:"config"`

	// Info Aggregated information about segment
	Info                SegmentInfo                    `json:"info"`
	PayloadFieldIndices []PayloadIndexTelemetry        `json:"payload_field_indices"`
	VectorIndexSearches []VectorIndexSearchesTelemetry `json:"vector_index_searches"`
}

SegmentTelemetry defines model for SegmentTelemetry.

type SegmentType

type SegmentType string

SegmentType Type of segment

const (
	Indexed SegmentType = "indexed"
	Plain   SegmentType = "plain"
	Special SegmentType = "special"
)

Defines values for SegmentType.

type SetPayload

type SetPayload struct {
	// Filter Assigns payload to each point that satisfy this filter condition
	Filter  *SetPayload_Filter `json:"filter,omitempty"`
	Payload Payload            `json:"payload"`

	// Points Assigns payload to each point in this list
	Points *[]ExtendedPointId `json:"points"`
}

SetPayload defines model for SetPayload.

type SetPayloadFilter1

type SetPayloadFilter1 = interface{}

SetPayloadFilter1 defines model for .

type SetPayloadJSONRequestBody

type SetPayloadJSONRequestBody = SetPayload

SetPayloadJSONRequestBody defines body for SetPayload for application/json ContentType.

type SetPayloadParams

type SetPayloadParams struct {
	// Wait If true, wait for changes to actually happen
	Wait *bool `form:"wait,omitempty" json:"wait,omitempty"`

	// Ordering define ordering guarantees for the operation
	Ordering *WriteOrdering `form:"ordering,omitempty" json:"ordering,omitempty"`
}

SetPayloadParams defines parameters for SetPayload.

type SetPayloadResponse

type SetPayloadResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		Result *UpdateResult `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseSetPayloadResponse

func ParseSetPayloadResponse(rsp *http.Response) (*SetPayloadResponse, error)

ParseSetPayloadResponse parses an HTTP response from a SetPayloadWithResponse call

func (SetPayloadResponse) Status

func (r SetPayloadResponse) Status() string

Status returns HTTPResponse.Status

func (SetPayloadResponse) StatusCode

func (r SetPayloadResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type SetPayload_Filter

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

SetPayload_Filter Assigns payload to each point that satisfy this filter condition

func (SetPayload_Filter) AsFilter

func (t SetPayload_Filter) AsFilter() (Filter, error)

AsFilter returns the union data inside the SetPayload_Filter as a Filter

func (SetPayload_Filter) AsSetPayloadFilter1

func (t SetPayload_Filter) AsSetPayloadFilter1() (SetPayloadFilter1, error)

AsSetPayloadFilter1 returns the union data inside the SetPayload_Filter as a SetPayloadFilter1

func (*SetPayload_Filter) FromFilter

func (t *SetPayload_Filter) FromFilter(v Filter) error

FromFilter overwrites any union data inside the SetPayload_Filter as the provided Filter

func (*SetPayload_Filter) FromSetPayloadFilter1

func (t *SetPayload_Filter) FromSetPayloadFilter1(v SetPayloadFilter1) error

FromSetPayloadFilter1 overwrites any union data inside the SetPayload_Filter as the provided SetPayloadFilter1

func (SetPayload_Filter) MarshalJSON

func (t SetPayload_Filter) MarshalJSON() ([]byte, error)

func (*SetPayload_Filter) MergeFilter

func (t *SetPayload_Filter) MergeFilter(v Filter) error

MergeFilter performs a merge with any union data inside the SetPayload_Filter, using the provided Filter

func (*SetPayload_Filter) MergeSetPayloadFilter1

func (t *SetPayload_Filter) MergeSetPayloadFilter1(v SetPayloadFilter1) error

MergeSetPayloadFilter1 performs a merge with any union data inside the SetPayload_Filter, using the provided SetPayloadFilter1

func (*SetPayload_Filter) UnmarshalJSON

func (t *SetPayload_Filter) UnmarshalJSON(b []byte) error

type ShardTransferInfo

type ShardTransferInfo struct {
	From    uint64 `json:"from"`
	ShardId uint32 `json:"shard_id"`

	// Sync If `true` transfer is a synchronization of a replicas If `false` transfer is a moving of a shard from one peer to another
	Sync bool   `json:"sync"`
	To   uint64 `json:"to"`
}

ShardTransferInfo defines model for ShardTransferInfo.

type SnapshotDescription

type SnapshotDescription struct {
	CreationTime *string `json:"creation_time"`
	Name         string  `json:"name"`
	Size         uint64  `json:"size"`
}

SnapshotDescription defines model for SnapshotDescription.

type SnapshotPriority

type SnapshotPriority string

SnapshotPriority Defines source of truth for snapshot recovery `Snapshot` means - prefer snapshot data over the current state `Replica` means - prefer existing data over the snapshot

const (
	SnapshotPriorityReplica  SnapshotPriority = "replica"
	SnapshotPrioritySnapshot SnapshotPriority = "snapshot"
)

Defines values for SnapshotPriority.

type SnapshotRecover

type SnapshotRecover struct {
	// Location Examples: - URL `http://localhost:8080/collections/my_collection/snapshots/my_snapshot` - Local path `file:///qdrant/snapshots/test_collection-2022-08-04-10-49-10.snapshot`
	Location string `json:"location"`

	// Priority Defines which data should be used as a source of truth if there are other replicas in the cluster. If set to `Snapshot`, the snapshot will be used as a source of truth, and the current state will be overwritten. If set to `Replica`, the current state will be used as a source of truth, and after recovery if will be synchronized with the snapshot.
	Priority *SnapshotRecover_Priority `json:"priority,omitempty"`
}

SnapshotRecover defines model for SnapshotRecover.

type SnapshotRecoverPriority1

type SnapshotRecoverPriority1 = interface{}

SnapshotRecoverPriority1 defines model for .

type SnapshotRecover_Priority

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

SnapshotRecover_Priority Defines which data should be used as a source of truth if there are other replicas in the cluster. If set to `Snapshot`, the snapshot will be used as a source of truth, and the current state will be overwritten. If set to `Replica`, the current state will be used as a source of truth, and after recovery if will be synchronized with the snapshot.

func (SnapshotRecover_Priority) AsSnapshotPriority

func (t SnapshotRecover_Priority) AsSnapshotPriority() (SnapshotPriority, error)

AsSnapshotPriority returns the union data inside the SnapshotRecover_Priority as a SnapshotPriority

func (SnapshotRecover_Priority) AsSnapshotRecoverPriority1

func (t SnapshotRecover_Priority) AsSnapshotRecoverPriority1() (SnapshotRecoverPriority1, error)

AsSnapshotRecoverPriority1 returns the union data inside the SnapshotRecover_Priority as a SnapshotRecoverPriority1

func (*SnapshotRecover_Priority) FromSnapshotPriority

func (t *SnapshotRecover_Priority) FromSnapshotPriority(v SnapshotPriority) error

FromSnapshotPriority overwrites any union data inside the SnapshotRecover_Priority as the provided SnapshotPriority

func (*SnapshotRecover_Priority) FromSnapshotRecoverPriority1

func (t *SnapshotRecover_Priority) FromSnapshotRecoverPriority1(v SnapshotRecoverPriority1) error

FromSnapshotRecoverPriority1 overwrites any union data inside the SnapshotRecover_Priority as the provided SnapshotRecoverPriority1

func (SnapshotRecover_Priority) MarshalJSON

func (t SnapshotRecover_Priority) MarshalJSON() ([]byte, error)

func (*SnapshotRecover_Priority) MergeSnapshotPriority

func (t *SnapshotRecover_Priority) MergeSnapshotPriority(v SnapshotPriority) error

MergeSnapshotPriority performs a merge with any union data inside the SnapshotRecover_Priority, using the provided SnapshotPriority

func (*SnapshotRecover_Priority) MergeSnapshotRecoverPriority1

func (t *SnapshotRecover_Priority) MergeSnapshotRecoverPriority1(v SnapshotRecoverPriority1) error

MergeSnapshotRecoverPriority1 performs a merge with any union data inside the SnapshotRecover_Priority, using the provided SnapshotRecoverPriority1

func (*SnapshotRecover_Priority) UnmarshalJSON

func (t *SnapshotRecover_Priority) UnmarshalJSON(b []byte) error

type StateRole

type StateRole string

StateRole Role of the peer in the consensus

const (
	Candidate    StateRole = "Candidate"
	Follower     StateRole = "Follower"
	Leader       StateRole = "Leader"
	PreCandidate StateRole = "PreCandidate"
)

Defines values for StateRole.

type StorageType

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

StorageType Type of vector storage

func (StorageType) AsStorageType0

func (t StorageType) AsStorageType0() (StorageType0, error)

AsStorageType0 returns the union data inside the StorageType as a StorageType0

func (StorageType) AsStorageType1

func (t StorageType) AsStorageType1() (StorageType1, error)

AsStorageType1 returns the union data inside the StorageType as a StorageType1

func (*StorageType) FromStorageType0

func (t *StorageType) FromStorageType0(v StorageType0) error

FromStorageType0 overwrites any union data inside the StorageType as the provided StorageType0

func (*StorageType) FromStorageType1

func (t *StorageType) FromStorageType1(v StorageType1) error

FromStorageType1 overwrites any union data inside the StorageType as the provided StorageType1

func (StorageType) MarshalJSON

func (t StorageType) MarshalJSON() ([]byte, error)

func (*StorageType) MergeStorageType0

func (t *StorageType) MergeStorageType0(v StorageType0) error

MergeStorageType0 performs a merge with any union data inside the StorageType, using the provided StorageType0

func (*StorageType) MergeStorageType1

func (t *StorageType) MergeStorageType1(v StorageType1) error

MergeStorageType1 performs a merge with any union data inside the StorageType, using the provided StorageType1

func (*StorageType) UnmarshalJSON

func (t *StorageType) UnmarshalJSON(b []byte) error

type StorageType0

type StorageType0 struct {
	Type StorageType `json:"type"`
}

StorageType0 defines model for .

type StorageType1

type StorageType1 struct {
	Type StorageType `json:"type"`
}

StorageType1 defines model for .

type TelemetryData

type TelemetryData struct {
	App         AppBuildTelemetry    `json:"app"`
	Cluster     ClusterTelemetry     `json:"cluster"`
	Collections CollectionsTelemetry `json:"collections"`
	Id          string               `json:"id"`
	Requests    RequestsTelemetry    `json:"requests"`
}

TelemetryData defines model for TelemetryData.

type TelemetryParams

type TelemetryParams struct {
	// Anonymize If true, anonymize result
	Anonymize *bool `form:"anonymize,omitempty" json:"anonymize,omitempty"`
}

TelemetryParams defines parameters for Telemetry.

type TelemetryResponse

type TelemetryResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		Result *[]TelemetryData `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseTelemetryResponse

func ParseTelemetryResponse(rsp *http.Response) (*TelemetryResponse, error)

ParseTelemetryResponse parses an HTTP response from a TelemetryWithResponse call

func (TelemetryResponse) Status

func (r TelemetryResponse) Status() string

Status returns HTTPResponse.Status

func (TelemetryResponse) StatusCode

func (r TelemetryResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type TextIndexParams

type TextIndexParams struct {
	// Lowercase If true, lowercase all tokens. Default: true
	Lowercase   *bool          `json:"lowercase"`
	MaxTokenLen *uint          `json:"max_token_len"`
	MinTokenLen *uint          `json:"min_token_len"`
	Tokenizer   *TokenizerType `json:"tokenizer,omitempty"`
	Type        TextIndexType  `json:"type"`
}

TextIndexParams defines model for TextIndexParams.

type TextIndexType

type TextIndexType string

TextIndexType defines model for TextIndexType.

const (
	TextIndexTypeText TextIndexType = "text"
)

Defines values for TextIndexType.

type TokenizerType

type TokenizerType string

TokenizerType defines model for TokenizerType.

const (
	Prefix     TokenizerType = "prefix"
	Whitespace TokenizerType = "whitespace"
	Word       TokenizerType = "word"
)

Defines values for TokenizerType.

type UpdateAliasesJSONRequestBody

type UpdateAliasesJSONRequestBody = ChangeAliasesOperation

UpdateAliasesJSONRequestBody defines body for UpdateAliases for application/json ContentType.

type UpdateAliasesParams

type UpdateAliasesParams struct {
	// Timeout Wait for operation commit timeout in seconds.
	// If timeout is reached - request will return with service error.
	Timeout *int `form:"timeout,omitempty" json:"timeout,omitempty"`
}

UpdateAliasesParams defines parameters for UpdateAliases.

type UpdateAliasesResponse

type UpdateAliasesResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		Result *bool `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseUpdateAliasesResponse

func ParseUpdateAliasesResponse(rsp *http.Response) (*UpdateAliasesResponse, error)

ParseUpdateAliasesResponse parses an HTTP response from a UpdateAliasesWithResponse call

func (UpdateAliasesResponse) Status

func (r UpdateAliasesResponse) Status() string

Status returns HTTPResponse.Status

func (UpdateAliasesResponse) StatusCode

func (r UpdateAliasesResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type UpdateCollection

type UpdateCollection struct {
	// OptimizersConfig Custom params for Optimizers.  If none - values from service configuration file are used. This operation is blocking, it will only proceed ones all current optimizations are complete
	OptimizersConfig *UpdateCollection_OptimizersConfig `json:"optimizers_config,omitempty"`

	// Params Collection base params.  If none - values from service configuration file are used.
	Params *UpdateCollection_Params `json:"params,omitempty"`
}

UpdateCollection Operation for updating parameters of the existing collection

type UpdateCollectionClusterJSONRequestBody

type UpdateCollectionClusterJSONRequestBody = ClusterOperations

UpdateCollectionClusterJSONRequestBody defines body for UpdateCollectionCluster for application/json ContentType.

type UpdateCollectionClusterParams

type UpdateCollectionClusterParams struct {
	// Timeout Wait for operation commit timeout in seconds.
	// If timeout is reached - request will return with service error.
	Timeout *int `form:"timeout,omitempty" json:"timeout,omitempty"`
}

UpdateCollectionClusterParams defines parameters for UpdateCollectionCluster.

type UpdateCollectionClusterResponse

type UpdateCollectionClusterResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		Result *bool `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseUpdateCollectionClusterResponse

func ParseUpdateCollectionClusterResponse(rsp *http.Response) (*UpdateCollectionClusterResponse, error)

ParseUpdateCollectionClusterResponse parses an HTTP response from a UpdateCollectionClusterWithResponse call

func (UpdateCollectionClusterResponse) Status

Status returns HTTPResponse.Status

func (UpdateCollectionClusterResponse) StatusCode

func (r UpdateCollectionClusterResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type UpdateCollectionJSONRequestBody

type UpdateCollectionJSONRequestBody = UpdateCollection

UpdateCollectionJSONRequestBody defines body for UpdateCollection for application/json ContentType.

type UpdateCollectionOptimizersConfig1

type UpdateCollectionOptimizersConfig1 = interface{}

UpdateCollectionOptimizersConfig1 defines model for .

type UpdateCollectionParams

type UpdateCollectionParams struct {
	// Timeout Wait for operation commit timeout in seconds.
	// If timeout is reached - request will return with service error.
	Timeout *int `form:"timeout,omitempty" json:"timeout,omitempty"`
}

UpdateCollectionParams defines parameters for UpdateCollection.

type UpdateCollectionParams1

type UpdateCollectionParams1 = interface{}

UpdateCollectionParams1 defines model for .

type UpdateCollectionResponse

type UpdateCollectionResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		Result *bool `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseUpdateCollectionResponse

func ParseUpdateCollectionResponse(rsp *http.Response) (*UpdateCollectionResponse, error)

ParseUpdateCollectionResponse parses an HTTP response from a UpdateCollectionWithResponse call

func (UpdateCollectionResponse) Status

func (r UpdateCollectionResponse) Status() string

Status returns HTTPResponse.Status

func (UpdateCollectionResponse) StatusCode

func (r UpdateCollectionResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type UpdateCollection_OptimizersConfig

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

UpdateCollection_OptimizersConfig Custom params for Optimizers. If none - values from service configuration file are used. This operation is blocking, it will only proceed ones all current optimizations are complete

func (UpdateCollection_OptimizersConfig) AsOptimizersConfigDiff

func (t UpdateCollection_OptimizersConfig) AsOptimizersConfigDiff() (OptimizersConfigDiff, error)

AsOptimizersConfigDiff returns the union data inside the UpdateCollection_OptimizersConfig as a OptimizersConfigDiff

func (UpdateCollection_OptimizersConfig) AsUpdateCollectionOptimizersConfig1

func (t UpdateCollection_OptimizersConfig) AsUpdateCollectionOptimizersConfig1() (UpdateCollectionOptimizersConfig1, error)

AsUpdateCollectionOptimizersConfig1 returns the union data inside the UpdateCollection_OptimizersConfig as a UpdateCollectionOptimizersConfig1

func (*UpdateCollection_OptimizersConfig) FromOptimizersConfigDiff

func (t *UpdateCollection_OptimizersConfig) FromOptimizersConfigDiff(v OptimizersConfigDiff) error

FromOptimizersConfigDiff overwrites any union data inside the UpdateCollection_OptimizersConfig as the provided OptimizersConfigDiff

func (*UpdateCollection_OptimizersConfig) FromUpdateCollectionOptimizersConfig1

func (t *UpdateCollection_OptimizersConfig) FromUpdateCollectionOptimizersConfig1(v UpdateCollectionOptimizersConfig1) error

FromUpdateCollectionOptimizersConfig1 overwrites any union data inside the UpdateCollection_OptimizersConfig as the provided UpdateCollectionOptimizersConfig1

func (UpdateCollection_OptimizersConfig) MarshalJSON

func (t UpdateCollection_OptimizersConfig) MarshalJSON() ([]byte, error)

func (*UpdateCollection_OptimizersConfig) MergeOptimizersConfigDiff

func (t *UpdateCollection_OptimizersConfig) MergeOptimizersConfigDiff(v OptimizersConfigDiff) error

MergeOptimizersConfigDiff performs a merge with any union data inside the UpdateCollection_OptimizersConfig, using the provided OptimizersConfigDiff

func (*UpdateCollection_OptimizersConfig) MergeUpdateCollectionOptimizersConfig1

func (t *UpdateCollection_OptimizersConfig) MergeUpdateCollectionOptimizersConfig1(v UpdateCollectionOptimizersConfig1) error

MergeUpdateCollectionOptimizersConfig1 performs a merge with any union data inside the UpdateCollection_OptimizersConfig, using the provided UpdateCollectionOptimizersConfig1

func (*UpdateCollection_OptimizersConfig) UnmarshalJSON

func (t *UpdateCollection_OptimizersConfig) UnmarshalJSON(b []byte) error

type UpdateCollection_Params

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

UpdateCollection_Params Collection base params. If none - values from service configuration file are used.

func (UpdateCollection_Params) AsCollectionParamsDiff

func (t UpdateCollection_Params) AsCollectionParamsDiff() (CollectionParamsDiff, error)

AsCollectionParamsDiff returns the union data inside the UpdateCollection_Params as a CollectionParamsDiff

func (UpdateCollection_Params) AsUpdateCollectionParams1

func (t UpdateCollection_Params) AsUpdateCollectionParams1() (UpdateCollectionParams1, error)

AsUpdateCollectionParams1 returns the union data inside the UpdateCollection_Params as a UpdateCollectionParams1

func (*UpdateCollection_Params) FromCollectionParamsDiff

func (t *UpdateCollection_Params) FromCollectionParamsDiff(v CollectionParamsDiff) error

FromCollectionParamsDiff overwrites any union data inside the UpdateCollection_Params as the provided CollectionParamsDiff

func (*UpdateCollection_Params) FromUpdateCollectionParams1

func (t *UpdateCollection_Params) FromUpdateCollectionParams1(v UpdateCollectionParams1) error

FromUpdateCollectionParams1 overwrites any union data inside the UpdateCollection_Params as the provided UpdateCollectionParams1

func (UpdateCollection_Params) MarshalJSON

func (t UpdateCollection_Params) MarshalJSON() ([]byte, error)

func (*UpdateCollection_Params) MergeCollectionParamsDiff

func (t *UpdateCollection_Params) MergeCollectionParamsDiff(v CollectionParamsDiff) error

MergeCollectionParamsDiff performs a merge with any union data inside the UpdateCollection_Params, using the provided CollectionParamsDiff

func (*UpdateCollection_Params) MergeUpdateCollectionParams1

func (t *UpdateCollection_Params) MergeUpdateCollectionParams1(v UpdateCollectionParams1) error

MergeUpdateCollectionParams1 performs a merge with any union data inside the UpdateCollection_Params, using the provided UpdateCollectionParams1

func (*UpdateCollection_Params) UnmarshalJSON

func (t *UpdateCollection_Params) UnmarshalJSON(b []byte) error

type UpdateResult

type UpdateResult struct {
	// OperationId Sequential number of the operation
	OperationId uint64 `json:"operation_id"`

	// Status `Acknowledged` - Request is saved to WAL and will be process in a queue. `Completed` - Request is completed, changes are actual.
	Status UpdateStatus `json:"status"`
}

UpdateResult defines model for UpdateResult.

type UpdateStatus

type UpdateStatus string

UpdateStatus `Acknowledged` - Request is saved to WAL and will be process in a queue. `Completed` - Request is completed, changes are actual.

const (
	Acknowledged UpdateStatus = "acknowledged"
	Completed    UpdateStatus = "completed"
)

Defines values for UpdateStatus.

type UpsertPointsJSONRequestBody

type UpsertPointsJSONRequestBody = PointInsertOperations

UpsertPointsJSONRequestBody defines body for UpsertPoints for application/json ContentType.

type UpsertPointsParams

type UpsertPointsParams struct {
	// Wait If true, wait for changes to actually happen
	Wait *bool `form:"wait,omitempty" json:"wait,omitempty"`

	// Ordering define ordering guarantees for the operation
	Ordering *WriteOrdering `form:"ordering,omitempty" json:"ordering,omitempty"`
}

UpsertPointsParams defines parameters for UpsertPoints.

type UpsertPointsResponse

type UpsertPointsResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		Result *UpdateResult `json:"result,omitempty"`

		// Time Time spent to process this request
		Time *float32 `json:"time,omitempty"`
	}
	JSON4XX     *ErrorResponse
	JSONDefault *ErrorResponse
}

func ParseUpsertPointsResponse

func ParseUpsertPointsResponse(rsp *http.Response) (*UpsertPointsResponse, error)

ParseUpsertPointsResponse parses an HTTP response from a UpsertPointsWithResponse call

func (UpsertPointsResponse) Status

func (r UpsertPointsResponse) Status() string

Status returns HTTPResponse.Status

func (UpsertPointsResponse) StatusCode

func (r UpsertPointsResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type UsingVector

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

UsingVector defines model for UsingVector.

func (UsingVector) AsUsingVector0

func (t UsingVector) AsUsingVector0() (UsingVector0, error)

AsUsingVector0 returns the union data inside the UsingVector as a UsingVector0

func (*UsingVector) FromUsingVector0

func (t *UsingVector) FromUsingVector0(v UsingVector0) error

FromUsingVector0 overwrites any union data inside the UsingVector as the provided UsingVector0

func (UsingVector) MarshalJSON

func (t UsingVector) MarshalJSON() ([]byte, error)

func (*UsingVector) MergeUsingVector0

func (t *UsingVector) MergeUsingVector0(v UsingVector0) error

MergeUsingVector0 performs a merge with any union data inside the UsingVector, using the provided UsingVector0

func (*UsingVector) UnmarshalJSON

func (t *UsingVector) UnmarshalJSON(b []byte) error

type UsingVector0

type UsingVector0 = string

UsingVector0 defines model for .

type ValueVariants

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

ValueVariants defines model for ValueVariants.

func (ValueVariants) AsValueVariants0

func (t ValueVariants) AsValueVariants0() (ValueVariants0, error)

AsValueVariants0 returns the union data inside the ValueVariants as a ValueVariants0

func (ValueVariants) AsValueVariants1

func (t ValueVariants) AsValueVariants1() (ValueVariants1, error)

AsValueVariants1 returns the union data inside the ValueVariants as a ValueVariants1

func (ValueVariants) AsValueVariants2

func (t ValueVariants) AsValueVariants2() (ValueVariants2, error)

AsValueVariants2 returns the union data inside the ValueVariants as a ValueVariants2

func (*ValueVariants) FromValueVariants0

func (t *ValueVariants) FromValueVariants0(v ValueVariants0) error

FromValueVariants0 overwrites any union data inside the ValueVariants as the provided ValueVariants0

func (*ValueVariants) FromValueVariants1

func (t *ValueVariants) FromValueVariants1(v ValueVariants1) error

FromValueVariants1 overwrites any union data inside the ValueVariants as the provided ValueVariants1

func (*ValueVariants) FromValueVariants2

func (t *ValueVariants) FromValueVariants2(v ValueVariants2) error

FromValueVariants2 overwrites any union data inside the ValueVariants as the provided ValueVariants2

func (ValueVariants) MarshalJSON

func (t ValueVariants) MarshalJSON() ([]byte, error)

func (*ValueVariants) MergeValueVariants0

func (t *ValueVariants) MergeValueVariants0(v ValueVariants0) error

MergeValueVariants0 performs a merge with any union data inside the ValueVariants, using the provided ValueVariants0

func (*ValueVariants) MergeValueVariants1

func (t *ValueVariants) MergeValueVariants1(v ValueVariants1) error

MergeValueVariants1 performs a merge with any union data inside the ValueVariants, using the provided ValueVariants1

func (*ValueVariants) MergeValueVariants2

func (t *ValueVariants) MergeValueVariants2(v ValueVariants2) error

MergeValueVariants2 performs a merge with any union data inside the ValueVariants, using the provided ValueVariants2

func (*ValueVariants) UnmarshalJSON

func (t *ValueVariants) UnmarshalJSON(b []byte) error

type ValueVariants0

type ValueVariants0 = string

ValueVariants0 defines model for .

type ValueVariants1

type ValueVariants1 = int64

ValueVariants1 defines model for .

type ValueVariants2

type ValueVariants2 = bool

ValueVariants2 defines model for .

type ValuesCount

type ValuesCount struct {
	// Gt point.key.length() > values_count.gt
	Gt *uint `json:"gt"`

	// Gte point.key.length() >= values_count.gte
	Gte *uint `json:"gte"`

	// Lt point.key.length() < values_count.lt
	Lt *uint `json:"lt"`

	// Lte point.key.length() <= values_count.lte
	Lte *uint `json:"lte"`
}

ValuesCount Values count filter request

type VectorDataConfig

type VectorDataConfig struct {
	// Distance Type of internal tags, build from payload Distance function types used to compare vectors
	Distance Distance `json:"distance"`

	// Size Size of a vectors used
	Size uint `json:"size"`
}

VectorDataConfig Config of single vector data storage

type VectorIndexSearchesTelemetry

type VectorIndexSearchesTelemetry struct {
	FilteredExact            OperationDurationStatistics `json:"filtered_exact"`
	FilteredLargeCardinality OperationDurationStatistics `json:"filtered_large_cardinality"`
	FilteredPlain            OperationDurationStatistics `json:"filtered_plain"`
	FilteredSmallCardinality OperationDurationStatistics `json:"filtered_small_cardinality"`
	IndexName                *string                     `json:"index_name"`
	UnfilteredExact          OperationDurationStatistics `json:"unfiltered_exact"`
	UnfilteredHnsw           OperationDurationStatistics `json:"unfiltered_hnsw"`
	UnfilteredPlain          OperationDurationStatistics `json:"unfiltered_plain"`
}

VectorIndexSearchesTelemetry defines model for VectorIndexSearchesTelemetry.

type VectorParams

type VectorParams struct {
	// Distance Type of internal tags, build from payload Distance function types used to compare vectors
	Distance Distance `json:"distance"`

	// Size Size of a vectors used
	Size uint64 `json:"size"`

	OnDisk *bool `json:"on_disk,omitempty"`
}

VectorParams Params of single vector data storage

type VectorStruct

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

VectorStruct Full vector data per point separator with single and multiple vector modes

func (VectorStruct) AsVectorStruct0

func (t VectorStruct) AsVectorStruct0() (VectorStruct0, error)

AsVectorStruct0 returns the union data inside the VectorStruct as a VectorStruct0

func (VectorStruct) AsVectorStruct1

func (t VectorStruct) AsVectorStruct1() (VectorStruct1, error)

AsVectorStruct1 returns the union data inside the VectorStruct as a VectorStruct1

func (*VectorStruct) FromVectorStruct0

func (t *VectorStruct) FromVectorStruct0(v VectorStruct0) error

FromVectorStruct0 overwrites any union data inside the VectorStruct as the provided VectorStruct0

func (*VectorStruct) FromVectorStruct1

func (t *VectorStruct) FromVectorStruct1(v VectorStruct1) error

FromVectorStruct1 overwrites any union data inside the VectorStruct as the provided VectorStruct1

func (VectorStruct) MarshalJSON

func (t VectorStruct) MarshalJSON() ([]byte, error)

func (*VectorStruct) MergeVectorStruct0

func (t *VectorStruct) MergeVectorStruct0(v VectorStruct0) error

MergeVectorStruct0 performs a merge with any union data inside the VectorStruct, using the provided VectorStruct0

func (*VectorStruct) MergeVectorStruct1

func (t *VectorStruct) MergeVectorStruct1(v VectorStruct1) error

MergeVectorStruct1 performs a merge with any union data inside the VectorStruct, using the provided VectorStruct1

func (*VectorStruct) UnmarshalJSON

func (t *VectorStruct) UnmarshalJSON(b []byte) error

type VectorStruct0

type VectorStruct0 = []float32

VectorStruct0 defines model for .

type VectorStruct1

type VectorStruct1 map[string][]float32

VectorStruct1 defines model for .

type VectorsConfig

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

VectorsConfig Vector params separator for single and multiple vector modes Single mode:

{ "size": 128, "distance": "Cosine" }

or multiple mode:

{ "default": { "size": 128, "distance": "Cosine" } }

func (VectorsConfig) AsVectorParams

func (t VectorsConfig) AsVectorParams() (VectorParams, error)

AsVectorParams returns the union data inside the VectorsConfig as a VectorParams

func (VectorsConfig) AsVectorsConfig1

func (t VectorsConfig) AsVectorsConfig1() (VectorsConfig1, error)

AsVectorsConfig1 returns the union data inside the VectorsConfig as a VectorsConfig1

func (*VectorsConfig) FromVectorParams

func (t *VectorsConfig) FromVectorParams(v VectorParams) error

FromVectorParams overwrites any union data inside the VectorsConfig as the provided VectorParams

func (*VectorsConfig) FromVectorsConfig1

func (t *VectorsConfig) FromVectorsConfig1(v VectorsConfig1) error

FromVectorsConfig1 overwrites any union data inside the VectorsConfig as the provided VectorsConfig1

func (VectorsConfig) MarshalJSON

func (t VectorsConfig) MarshalJSON() ([]byte, error)

func (*VectorsConfig) MergeVectorParams

func (t *VectorsConfig) MergeVectorParams(v VectorParams) error

MergeVectorParams performs a merge with any union data inside the VectorsConfig, using the provided VectorParams

func (*VectorsConfig) MergeVectorsConfig1

func (t *VectorsConfig) MergeVectorsConfig1(v VectorsConfig1) error

MergeVectorsConfig1 performs a merge with any union data inside the VectorsConfig, using the provided VectorsConfig1

func (*VectorsConfig) UnmarshalJSON

func (t *VectorsConfig) UnmarshalJSON(b []byte) error

type VectorsConfig1

type VectorsConfig1 map[string]VectorParams

VectorsConfig1 defines model for .

type WalConfig

type WalConfig struct {
	// WalCapacityMb Size of a single WAL segment in MB
	WalCapacityMb uint `json:"wal_capacity_mb"`

	// WalSegmentsAhead Number of WAL segments to create ahead of actually used ones
	WalSegmentsAhead uint `json:"wal_segments_ahead"`
}

WalConfig defines model for WalConfig.

type WalConfigDiff

type WalConfigDiff struct {
	// WalCapacityMb Size of a single WAL segment in MB
	WalCapacityMb *uint `json:"wal_capacity_mb"`

	// WalSegmentsAhead Number of WAL segments to create ahead of actually used ones
	WalSegmentsAhead *uint `json:"wal_segments_ahead"`
}

WalConfigDiff defines model for WalConfigDiff.

type WebApiTelemetry

type WebApiTelemetry struct {
	Responses map[string]map[string]OperationDurationStatistics `json:"responses"`
}

WebApiTelemetry defines model for WebApiTelemetry.

type WithPayloadInterface

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

WithPayloadInterface Options for specifying which payload to include or not

func (WithPayloadInterface) AsPayloadSelector

func (t WithPayloadInterface) AsPayloadSelector() (PayloadSelector, error)

AsPayloadSelector returns the union data inside the WithPayloadInterface as a PayloadSelector

func (WithPayloadInterface) AsWithPayloadInterface0

func (t WithPayloadInterface) AsWithPayloadInterface0() (WithPayloadInterface0, error)

AsWithPayloadInterface0 returns the union data inside the WithPayloadInterface as a WithPayloadInterface0

func (WithPayloadInterface) AsWithPayloadInterface1

func (t WithPayloadInterface) AsWithPayloadInterface1() (WithPayloadInterface1, error)

AsWithPayloadInterface1 returns the union data inside the WithPayloadInterface as a WithPayloadInterface1

func (*WithPayloadInterface) FromPayloadSelector

func (t *WithPayloadInterface) FromPayloadSelector(v PayloadSelector) error

FromPayloadSelector overwrites any union data inside the WithPayloadInterface as the provided PayloadSelector

func (*WithPayloadInterface) FromWithPayloadInterface0

func (t *WithPayloadInterface) FromWithPayloadInterface0(v WithPayloadInterface0) error

FromWithPayloadInterface0 overwrites any union data inside the WithPayloadInterface as the provided WithPayloadInterface0

func (*WithPayloadInterface) FromWithPayloadInterface1

func (t *WithPayloadInterface) FromWithPayloadInterface1(v WithPayloadInterface1) error

FromWithPayloadInterface1 overwrites any union data inside the WithPayloadInterface as the provided WithPayloadInterface1

func (WithPayloadInterface) MarshalJSON

func (t WithPayloadInterface) MarshalJSON() ([]byte, error)

func (*WithPayloadInterface) MergePayloadSelector

func (t *WithPayloadInterface) MergePayloadSelector(v PayloadSelector) error

MergePayloadSelector performs a merge with any union data inside the WithPayloadInterface, using the provided PayloadSelector

func (*WithPayloadInterface) MergeWithPayloadInterface0

func (t *WithPayloadInterface) MergeWithPayloadInterface0(v WithPayloadInterface0) error

MergeWithPayloadInterface0 performs a merge with any union data inside the WithPayloadInterface, using the provided WithPayloadInterface0

func (*WithPayloadInterface) MergeWithPayloadInterface1

func (t *WithPayloadInterface) MergeWithPayloadInterface1(v WithPayloadInterface1) error

MergeWithPayloadInterface1 performs a merge with any union data inside the WithPayloadInterface, using the provided WithPayloadInterface1

func (*WithPayloadInterface) UnmarshalJSON

func (t *WithPayloadInterface) UnmarshalJSON(b []byte) error

type WithPayloadInterface0

type WithPayloadInterface0 = bool

WithPayloadInterface0 If `true` - return all payload, If `false` - do not return payload

type WithPayloadInterface1

type WithPayloadInterface1 = []string

WithPayloadInterface1 Specify which fields to return

type WithVector

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

WithVector Options for specifying which vector to include

func (WithVector) AsWithVector0

func (t WithVector) AsWithVector0() (WithVector0, error)

AsWithVector0 returns the union data inside the WithVector as a WithVector0

func (WithVector) AsWithVector1

func (t WithVector) AsWithVector1() (WithVector1, error)

AsWithVector1 returns the union data inside the WithVector as a WithVector1

func (*WithVector) FromWithVector0

func (t *WithVector) FromWithVector0(v WithVector0) error

FromWithVector0 overwrites any union data inside the WithVector as the provided WithVector0

func (*WithVector) FromWithVector1

func (t *WithVector) FromWithVector1(v WithVector1) error

FromWithVector1 overwrites any union data inside the WithVector as the provided WithVector1

func (WithVector) MarshalJSON

func (t WithVector) MarshalJSON() ([]byte, error)

func (*WithVector) MergeWithVector0

func (t *WithVector) MergeWithVector0(v WithVector0) error

MergeWithVector0 performs a merge with any union data inside the WithVector, using the provided WithVector0

func (*WithVector) MergeWithVector1

func (t *WithVector) MergeWithVector1(v WithVector1) error

MergeWithVector1 performs a merge with any union data inside the WithVector, using the provided WithVector1

func (*WithVector) UnmarshalJSON

func (t *WithVector) UnmarshalJSON(b []byte) error

type WithVector0

type WithVector0 = bool

WithVector0 If `true` - return all vector, If `false` - do not return vector

type WithVector1

type WithVector1 = []string

WithVector1 Specify which vector to return

type WriteOrdering

type WriteOrdering string

WriteOrdering Defines write ordering guarantees for collection operations

* `weak` - write operations may be reordered, works faster, default

* `medium` - write operations go through dynamically selected leader, may be inconsistent for a short period of time in case of leader change

* `strong` - Write operations go through the permanent leader, consistent, but may be unavailable if leader is down

const (
	Medium WriteOrdering = "medium"
	Strong WriteOrdering = "strong"
	Weak   WriteOrdering = "weak"
)

Defines values for WriteOrdering.

Jump to

Keyboard shortcuts

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