clients

package
v1.18.0-rc.0 Latest Latest
Warning

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

 Go to latest Published: Mar 1, 2023 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 

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

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 retryClient

func NewRemoteIndex 

func NewRemoteIndex(httpClient *http.Client) *RemoteIndex

func (*RemoteIndex) Aggregate 

func (c *RemoteIndex) Aggregate(ctx context.Context, hostName, indexName,
	shardName 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,
	docIDs []uint64, 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) FindDocIDs 

func (c *RemoteIndex) FindDocIDs(ctx context.Context, hostName, indexName,
	shardName string, filters *filters.LocalFilter,
) ([]uint64, 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) 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, hostName, indexName,
	shardName string, vector []float32, limit int, filters *filters.LocalFilter,
	keywordRanking *searchparams.KeywordRanking, sort []filters.Sort,
	cursor *filters.Cursor, 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 string,
) (*models.NodeStatus, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.