clients

package
v1.24.10 Latest Latest
Warning

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

Go to latest
Published: Apr 19, 2024 License: BSD-3-Clause Imports: 27 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewReplicationClient

func NewReplicationClient(httpClient *http.Client) replica.Client

Types

type ClusterBackups

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

func NewClusterBackups

func NewClusterBackups(client *http.Client) *ClusterBackups

func (*ClusterBackups) Abort

func (c *ClusterBackups) Abort(_ context.Context,
	host string, req *backup.AbortRequest,
) error

func (*ClusterBackups) CanCommit

func (c *ClusterBackups) CanCommit(ctx context.Context,
	host string, req *backup.Request,
) (*backup.CanCommitResponse, error)

func (*ClusterBackups) Commit

func (c *ClusterBackups) Commit(ctx context.Context,
	host string, req *backup.StatusRequest,
) error

func (*ClusterBackups) Status

type ClusterClassifications

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

func NewClusterClassifications

func NewClusterClassifications(httpClient *http.Client) *ClusterClassifications

func (*ClusterClassifications) AbortTransaction

func (c *ClusterClassifications) AbortTransaction(ctx context.Context, host string,
	tx *cluster.Transaction,
) error

func (*ClusterClassifications) CommitTransaction

func (c *ClusterClassifications) CommitTransaction(ctx context.Context, host string,
	tx *cluster.Transaction,
) error

func (*ClusterClassifications) OpenTransaction

func (c *ClusterClassifications) OpenTransaction(ctx context.Context, host string,
	tx *cluster.Transaction,
) error

type ClusterSchema

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

func NewClusterSchema

func NewClusterSchema(httpClient *http.Client) *ClusterSchema

func (*ClusterSchema) AbortTransaction

func (c *ClusterSchema) AbortTransaction(ctx context.Context, host string,
	tx *cluster.Transaction,
) error

func (*ClusterSchema) CommitTransaction

func (c *ClusterSchema) CommitTransaction(ctx context.Context, host string,
	tx *cluster.Transaction,
) error

func (*ClusterSchema) OpenTransaction

func (c *ClusterSchema) OpenTransaction(ctx context.Context, host string,
	tx *cluster.Transaction,
) error

type RemoteIndex

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

func NewRemoteIndex

func NewRemoteIndex(httpClient *http.Client) *RemoteIndex

func (*RemoteIndex) Aggregate

func (c *RemoteIndex) Aggregate(ctx context.Context, hostName, index,
	shard string, params aggregation.Params,
) (*aggregation.Result, error)

func (*RemoteIndex) BatchAddReferences

func (c *RemoteIndex) BatchAddReferences(ctx context.Context, hostName, indexName,
	shardName string, refs objects.BatchReferences,
) []error

func (*RemoteIndex) BatchPutObjects

func (c *RemoteIndex) BatchPutObjects(ctx context.Context, hostName, indexName,
	shardName string, objs []*storobj.Object, _ *additional.ReplicationProperties,
) []error

func (*RemoteIndex) CreateShard

func (c *RemoteIndex) CreateShard(ctx context.Context,
	hostName, indexName, shardName string,
) error

func (*RemoteIndex) DeleteObject

func (c *RemoteIndex) DeleteObject(ctx context.Context, hostName, indexName,
	shardName string, id strfmt.UUID,
) error

func (*RemoteIndex) DeleteObjectBatch

func (c *RemoteIndex) DeleteObjectBatch(ctx context.Context, hostName, indexName, shardName string,
	uuids []strfmt.UUID, dryRun bool,
) objects.BatchSimpleObjects

func (*RemoteIndex) Exists

func (c *RemoteIndex) Exists(ctx context.Context, hostName, indexName,
	shardName string, id strfmt.UUID,
) (bool, error)

func (*RemoteIndex) FindUUIDs added in v1.22.8

func (c *RemoteIndex) FindUUIDs(ctx context.Context, hostName, indexName,
	shardName string, filters *filters.LocalFilter,
) ([]strfmt.UUID, error)

func (*RemoteIndex) GetObject

func (c *RemoteIndex) GetObject(ctx context.Context, hostName, indexName,
	shardName string, id strfmt.UUID, selectProps search.SelectProperties,
	additional additional.Properties,
) (*storobj.Object, error)

func (*RemoteIndex) GetShardQueueSize added in v1.22.0

func (c *RemoteIndex) GetShardQueueSize(ctx context.Context,
	hostName, indexName, shardName string,
) (int64, error)

func (*RemoteIndex) GetShardStatus

func (c *RemoteIndex) GetShardStatus(ctx context.Context,
	hostName, indexName, shardName string,
) (string, error)

func (*RemoteIndex) IncreaseReplicationFactor

func (c *RemoteIndex) IncreaseReplicationFactor(ctx context.Context,
	hostName, indexName string, dist scaler.ShardDist,
) error

func (*RemoteIndex) MergeObject

func (c *RemoteIndex) MergeObject(ctx context.Context, hostName, indexName,
	shardName string, mergeDoc objects.MergeDocument,
) error

func (*RemoteIndex) MultiGetObjects

func (c *RemoteIndex) MultiGetObjects(ctx context.Context, hostName, indexName,
	shardName string, ids []strfmt.UUID,
) ([]*storobj.Object, error)

func (*RemoteIndex) PutFile

func (c *RemoteIndex) PutFile(ctx context.Context, hostName, indexName,
	shardName, fileName string, payload io.ReadSeekCloser,
) error

func (*RemoteIndex) PutObject

func (c *RemoteIndex) PutObject(ctx context.Context, hostName, indexName,
	shardName string, obj *storobj.Object,
) error

func (*RemoteIndex) ReInitShard

func (c *RemoteIndex) ReInitShard(ctx context.Context,
	hostName, indexName, shardName string,
) error

func (*RemoteIndex) SearchShard

func (c *RemoteIndex) SearchShard(ctx context.Context, host, index, shard string,
	vector []float32,
	targetVector string,
	limit int,
	filters *filters.LocalFilter,
	keywordRanking *searchparams.KeywordRanking,
	sort []filters.Sort,
	cursor *filters.Cursor,
	groupBy *searchparams.GroupBy,
	additional additional.Properties,
) ([]*storobj.Object, []float32, error)

func (*RemoteIndex) UpdateShardStatus

func (c *RemoteIndex) UpdateShardStatus(ctx context.Context, hostName, indexName, shardName,
	targetStatus string,
) error

type RemoteNode

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

func NewRemoteNode

func NewRemoteNode(httpClient *http.Client) *RemoteNode

func (*RemoteNode) GetNodeStatus

func (c *RemoteNode) GetNodeStatus(ctx context.Context, hostName, className, output string) (*models.NodeStatus, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL