MCPcopy
hub / github.com/weaviate/weaviate / WClient

Interface WClient

usecases/replica/transport.go:94–109  ·  view source on GitHub ↗

WClient is the client used to write to replicas

Source from the content-addressed store, hash-verified

92
93// WClient is the client used to write to replicas
94type WClient interface {
95 PutObject(ctx context.Context, host, index, shard, requestID string,
96 obj *storobj.Object, schemaVersion uint64) (SimpleResponse, error)
97 DeleteObject(ctx context.Context, host, index, shard, requestID string,
98 id strfmt.UUID, deletionTime time.Time, schemaVersion uint64) (SimpleResponse, error)
99 PutObjects(ctx context.Context, host, index, shard, requestID string,
100 objs []*storobj.Object, schemaVersion uint64) (SimpleResponse, error)
101 MergeObject(ctx context.Context, host, index, shard, requestID string,
102 mergeDoc *objects.MergeDocument, schemaVersion uint64) (SimpleResponse, error)
103 DeleteObjects(ctx context.Context, host, index, shard, requestID string,
104 uuids []strfmt.UUID, deletionTime time.Time, dryRun bool, schemaVersion uint64) (SimpleResponse, error)
105 AddReferences(ctx context.Context, host, index, shard, requestID string,
106 refs []objects.BatchReference, schemaVersion uint64) (SimpleResponse, error)
107 Commit(ctx context.Context, host, index, shard, requestID string, resp interface{}) error
108 Abort(ctx context.Context, host, index, shard, requestID string) (SimpleResponse, error)
109}
110
111// RClient is the client used to read from remote replicas
112type RClient interface {

Callers 28

Test_coordinatorPushFunction · 0.65
PutObjectMethod · 0.65
TestReplicatorPutObjectFunction · 0.65
putMetaMethod · 0.65
DeleteObjectMethod · 0.65
PutObjectsMethod · 0.65
TestReplicatorPutObjectsFunction · 0.65
Test_MergeObjectFunction · 0.65

Implementers 11

MockWClientusecases/replica/mock_w_client.go
MockWClient_Expecterusecases/replica/mock_w_client.go
fakeReplicationClientusecases/classification/integrationtes
ReplicationServiceadapters/handlers/rest/clusterapi/grpc
replicationServiceClientadapters/handlers/rest/clusterapi/grpc
UnimplementedReplicationServiceServeradapters/handlers/rest/clusterapi/grpc
FakeReplicationClientadapters/repos/db/fakes_for_tests.go
replicationClientadapters/clients/replication.go
grpcReplicationClientadapters/clients/replication_grpc.go
switchReplicationClientadapters/clients/replication_mixed.go
fakeGRPCReplicationServeradapters/clients/replication_grpc_test

Calls

no outgoing calls

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…