21 #ifndef KINETIC_CPP_CLIENT_BLOCKING_KINETIC_CONNECTION_H_
22 #define KINETIC_CPP_CLIENT_BLOCKING_KINETIC_CONNECTION_H_
24 #include "kinetic/blocking_kinetic_connection_interface.h"
25 #include "kinetic/nonblocking_kinetic_connection.h"
33 unique_ptr<NonblockingKineticConnection> nonblocking_connection,
34 unsigned int network_timeout_seconds);
45 const shared_ptr<const string> key,
46 unique_ptr<KineticRecord>& record);
48 KineticStatus Get(
const string& key, unique_ptr<KineticRecord>& record);
51 const shared_ptr<const string> key,
52 unique_ptr<string>& actual_key,
53 unique_ptr<KineticRecord>& record);
57 unique_ptr<string>& actual_key,
58 unique_ptr<KineticRecord>& record);
61 unique_ptr<string>& actual_key,
62 unique_ptr<KineticRecord>& record);
65 unique_ptr<string>& actual_key,
66 unique_ptr<KineticRecord>& record);
69 unique_ptr<string>& version);
71 KineticStatus GetVersion(
const string& key, unique_ptr<string>& version);
73 KineticStatus GetKeyRange(
const shared_ptr<const string> start_key,
74 bool start_key_inclusive,
75 const shared_ptr<const string> end_key,
76 bool end_key_inclusive,
79 unique_ptr<vector<string>>& keys);
82 bool start_key_inclusive,
83 const string& end_key,
84 bool end_key_inclusive,
87 unique_ptr<vector<string>>& keys);
90 bool start_key_inclusive,
91 const shared_ptr<const string> end_key,
92 bool end_key_inclusive,
93 unsigned int frame_size);
96 bool start_key_inclusive,
97 const string& end_key,
98 bool end_key_inclusive,
99 unsigned int frame_size);
102 const shared_ptr<const string> current_version, WriteMode mode,
103 const shared_ptr<const KineticRecord> record,
104 PersistMode persistMode);
107 const string& current_version, WriteMode mode,
109 PersistMode persistMode);
112 const shared_ptr<const string> current_version, WriteMode mode,
113 const shared_ptr<const KineticRecord> record);
116 const string& current_version, WriteMode mode,
120 const shared_ptr<const string> version, WriteMode mode, PersistMode persistMode);
122 KineticStatus Delete(
const string& key,
const string& version,
123 WriteMode mode, PersistMode persistMode);
126 const shared_ptr<const string> version, WriteMode mode);
128 KineticStatus Delete(
const string& key,
const string& version, WriteMode mode);
132 KineticStatus GetLog(
const vector<Command_GetLog_Type>& types, unique_ptr<DriveLog>& drive_log);
135 unique_ptr<vector<KineticStatus>>& operation_statuses);
137 KineticStatus P2PPush(
const shared_ptr<const P2PPushRequest> push_request,
138 unique_ptr<vector<KineticStatus>>& operation_statuses);
141 KineticStatus UpdateFirmware(
const shared_ptr<const string> new_firmware);
142 KineticStatus SetACLs(
const shared_ptr<
const list<ACL>> acls);
144 KineticStatus SetErasePIN(
const shared_ptr<const string> new_pin,
145 const shared_ptr<const string> current_pin = make_shared<string>());
146 KineticStatus SetErasePIN(
const string& new_pin,
const string& current_pin);
147 KineticStatus SetLockPIN(
const shared_ptr<const string> new_pin,
148 const shared_ptr<const string> current_pin = make_shared<string>());
149 KineticStatus SetLockPIN(
const string& new_pin,
const string& current_pin);
161 KineticStatus RunOperation(shared_ptr<BlockingCallbackState> callback, HandlerKey handler_key);
166 unique_ptr<NonblockingKineticConnection> nonblocking_connection_;
167 const unsigned int network_timeout_seconds_;
173 #endif // KINETIC_CPP_CLIENT_BLOCKING_KINETIC_CONNECTION_H_
Represents a collection of P2P operations.
void SetClientClusterVersion(int64_t cluster_version)
If the drive has a non-zero cluster version, requests will fail unless the developer tells the client...
Indicates whether a Kinetic operation (get, put, security, etc) put succeeded or failed. Unlike Status it provides details like whether the failure resulted from a version or an HMAC error.
Encapsulates a single value stored in a Kinetic drive and the associated metadata.