public class ChronicleTcp extends Object
Modifier and Type | Field and Description |
---|---|
static int |
ACK_LEN |
static long |
ACTION_QUERY |
static long |
ACTION_SUBMIT |
static long |
ACTION_SUBMIT_NOACK |
static long |
ACTION_SUBSCRIBE |
static long |
ACTION_UNSUBSCRIBE |
static long |
ACTION_WITH_MAPPING |
static long |
BUSY_WAIT_TIME_NS |
static int |
HEADER_SIZE |
static long |
IDX_ACK |
static long |
IDX_NONE |
static long |
IDX_NOT_SUPPORTED |
static long |
IDX_TO_END |
static long |
IDX_TO_START |
static int |
IN_SYNC_LEN |
static int |
INITIAL_BUFFER_SIZE |
static int |
NACK_LEN |
static int |
PADDED_LEN |
static int |
SYNC_IDX_LEN |
Constructor and Description |
---|
ChronicleTcp() |
Modifier and Type | Method and Description |
---|---|
static long |
address(ByteBuffer buffer) |
static String |
connectionName(String name,
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder builder) |
static String |
connectionName(String name,
InetSocketAddress bindAddress,
InetSocketAddress connectAddress) |
static ByteBuffer |
createBuffer(int minSize) |
static ByteBuffer |
createBuffer(int minSize,
ByteOrder byteOrder) |
static ByteBuffer |
createBufferOfSize(int size) |
static ByteBuffer |
createBufferOfSize(int size,
ByteOrder byteOrder) |
static boolean |
hasCapacityOf(ByteBuffer buffer,
int size) |
static boolean |
isLocalhost(InetSocketAddress address) |
static int |
minBufferSize(int minSize) |
public static final long BUSY_WAIT_TIME_NS
public static final int HEADER_SIZE
public static final int INITIAL_BUFFER_SIZE
public static final int IN_SYNC_LEN
public static final int PADDED_LEN
public static final int SYNC_IDX_LEN
public static final int ACK_LEN
public static final int NACK_LEN
public static final long ACTION_SUBSCRIBE
public static final long ACTION_UNSUBSCRIBE
public static final long ACTION_QUERY
public static final long ACTION_SUBMIT
public static final long ACTION_SUBMIT_NOACK
public static final long ACTION_WITH_MAPPING
public static final long IDX_NONE
public static final long IDX_TO_START
public static final long IDX_TO_END
public static final long IDX_ACK
public static final long IDX_NOT_SUPPORTED
public static ByteBuffer createBufferOfSize(int size)
public static ByteBuffer createBufferOfSize(int size, ByteOrder byteOrder)
public static ByteBuffer createBuffer(int minSize)
public static ByteBuffer createBuffer(int minSize, ByteOrder byteOrder)
public static int minBufferSize(int minSize)
public static String connectionName(String name, InetSocketAddress bindAddress, InetSocketAddress connectAddress)
public static String connectionName(String name, ChronicleQueueBuilder.ReplicaChronicleQueueBuilder builder)
public static long address(@NotNull ByteBuffer buffer)
public static boolean hasCapacityOf(ByteBuffer buffer, int size)
public static boolean isLocalhost(@NotNull InetSocketAddress address)
Copyright © 2017. All rights reserved.