/*
* Copyright 2008-present MongoDB, Inc.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package com.mongodb.session;
import com.mongodb.ClientSessionOptions;
import com.mongodb.ServerAddress;
import com.mongodb.annotations.NotThreadSafe;
import com.mongodb.lang.Nullable;
import org.bson.BsonDocument;
import org.bson.BsonTimestamp;
import java.io.Closeable;
A client session.
See Also: @mongodb.server.release 3.6 Since: 3.6
/**
* A client session.
*
* @mongodb.server.release 3.6
* @since 3.6
* @see ClientSessionOptions
*/
@NotThreadSafe
public interface ClientSession extends Closeable {
Get the server address of the pinned mongos on this session.
For internal use only.
Returns: the server address of the pinned mongos @mongodb.server.release 4.2 Since: 3.11
/**
* Get the server address of the pinned mongos on this session.
* For internal use only.
*
* @return the server address of the pinned mongos
* @mongodb.server.release 4.2
* @since 3.11
*/
@Nullable
ServerAddress getPinnedServerAddress();
Set the server address of the pinned mongos.
For internal use only.
Params: - address – the server address to pin
@mongodb.server.release 4.2 Since: 3.11
/**
* Set the server address of the pinned mongos.
* For internal use only.
*
* @param address the server address to pin
* @mongodb.server.release 4.2
* @since 3.11
*/
void setPinnedServerAddress(ServerAddress address);
Get the recovery token from the latest outcome in a sharded transaction.
For internal use only.
Returns: the recovery token @mongodb.server.release 4.2 Since: 3.11
/**
* Get the recovery token from the latest outcome in a sharded transaction.
* For internal use only.
*
* @return the recovery token
* @mongodb.server.release 4.2
* @since 3.11
*/
@Nullable
BsonDocument getRecoveryToken();
Set the recovery token.
For internal use only.
Params: - recoveryToken – the recovery token
@mongodb.server.release 4.2 Since: 3.11
/**
* Set the recovery token.
* For internal use only.
*
* @param recoveryToken the recovery token
* @mongodb.server.release 4.2
* @since 3.11
*/
void setRecoveryToken(BsonDocument recoveryToken);
Get the options for this session.
Returns: the options, which may not be null
/**
* Get the options for this session.
*
* @return the options, which may not be null
*/
ClientSessionOptions getOptions();
Returns true if operations in this session must be causally consistent
Returns: whether operations in this session must be causally consistent.
/**
* Returns true if operations in this session must be causally consistent
*
* @return whether operations in this session must be causally consistent.
*/
boolean isCausallyConsistent();
Gets the originator for the session.
Important because sessions must only be used by their own originator.
Returns: the sessions originator
/**
* Gets the originator for the session.
*
* <p>
* Important because sessions must only be used by their own originator.
* </p>
*
* @return the sessions originator
*/
Object getOriginator();
Returns: the server session
/**
*
* @return the server session
*/
ServerSession getServerSession();
Gets the operation time of the last operation executed in this session.
Returns: the operation time
/**
* Gets the operation time of the last operation executed in this session.
*
* @return the operation time
*/
BsonTimestamp getOperationTime();
Set the operation time of the last operation executed in this session.
Params: - operationTime – the operation time
/**
* Set the operation time of the last operation executed in this session.
*
* @param operationTime the operation time
*/
void advanceOperationTime(BsonTimestamp operationTime);
Params: - clusterTime – the cluster time to advance to
/**
* @param clusterTime the cluster time to advance to
*/
void advanceClusterTime(BsonDocument clusterTime);
Returns: the latest cluster time seen by this session
/**
* @return the latest cluster time seen by this session
*/
BsonDocument getClusterTime();
@Override
void close();
}