Page Index - RichardHightower/jnats GitHub Wiki
282 page(s) in this GitHub Wiki:
- Home
- io.nats.client.utils
- CoverageServerPool
- CloseOnUpgradeAttempt
- RunProxy
- @Override
- private void runImpl() throws IOException
- private void proxy(Socket client)
- private void transferTo(Socket from, Socket to, String description)
- private Socket handshake(Socket client) throws IOException
- ResourceUtils
- public static List resourceAsLines(String fileName)
- Method Name: resourceAsLines
- Description:
- Parameters:
- Return Type:
- Steps:
- public static String resourceAsString(String fileName)
- Method: resourceAsString
- Parameters
- Return Value
- Steps:
- Exception Handling
- io.nats.examples.stan
- StanRandom
- public static void main(String[] args)
- StanExit
- public static void main(String[] args)
- StanTime
- public static void main(String[] args)
- io.nats.examples
- NatsReply
- public static void main(String[] args)
- ExampleArgs
- public void parse(String[] args, Trail trail, String usageString)
- private void handleTrailingArg(Trail trail, String arg)
- private void handleKeyedArg(String key, String value)
- public void displayBanner()
- private void _banner(String label, int value, boolean unlimited)
- private static void usageThenExit(String usageString)
- NatsSubDispatch
- public static void main(String[] args)
- ConnectTime
- public static Options createOptions(String server) throws Exception
- Method: createOptions(String server)
- Step 1: Initialize the Options.Builder object
- Step 2: Set the connection and error listeners
- Step 3: Configure authentication (optional)
- Step 4: Build and return the Options object
- public static void main(String[] args)
- ExampleUtils
- public static Options createExampleOptions(String server, boolean allowReconnect, ErrorListener el, ConnectionListener cl)
- Method: createExampleOptions
- Description:
- Parameters:
- Return Type:
- Steps:
- public static ExampleArgs optionalServer(String[] args, String usageString)
- public static ExampleArgs expectSubjectAndMessage(String[] args, String usageString)
- public static ExampleArgs expectSubjectAndMsgCount(String[] args, String usageString)
- public static ExampleArgs expectSubjectQueueAndMsgCount(String[] args, String usageString)
- public static void sleep(long millis)
- public static void sleepRandom(long millis)
- public static String randomString(int length)
- NatsSub
- public static void main(String[] args)
- NatsReqFuture
- public static void main(String[] args)
- ExampleAuthHandler
- public byte[] sign(byte[] nonce)
- Method Sign - Description
- NatsReq
- public static void main(String[] args)
- ReportNoResponders
- public static void main(String[] args) throws IOException
- NatsPubMany
- NatsPubMany
- public static void main(String[] args)
- io.nats.examples.jetstream
- NatsJsUtils
- public static void exitIfStreamExists(JetStreamManagement jsm, String streamName) throws IOException, JetStreamApiException
- public static void exitIfStreamNotExists(Connection nc, String streamName) throws IOException, JetStreamApiException
- public static StreamInfo createOrReplaceStream(JetStreamManagement jsm, String streamName, StorageType storageType, String... subjects) throws IOException, JetStreamApiException
- public static StreamInfo createStream(JetStreamManagement jsm, String streamName, StorageType storageType, String... subjects) throws IOException, JetStreamApiException
- public static StreamInfo createStreamOrUpdateSubjects(JetStreamManagement jsm, String streamName, StorageType storageType, String... subjects) throws IOException, JetStreamApiException
- // ----------------------------------------------------------------------------------------------------
- Method: publish
- Parameters
- Exceptions
- Steps
- public static void publish(JetStream js, String subject, String prefix, int count, int msgSize, boolean verbose) throws IOException, JetStreamApiException
- public static byte[] makeData(String prefix, int msgSize, boolean verbose, int x)
- Method: makeData
- Step 1
- Step 2
- Step 3
- Step 4
- Step 5
- Step 6
- public static long extractId(String data)
- public static long extractId(byte[] data)
- Method Description: extractId
- Steps:
- public static Thread publishInBackground(JetStream js, String subject, String prefix, int count, long delay)
- // ----------------------------------------------------------------------------------------------------
- Method: readMessagesAck
- Parameters:
- Return type:
- Steps:
- Exceptions:
- public static List readMessagesAck(JetStreamSubscription sub, boolean verbose, Duration nextMessageTimeout) throws InterruptedException
- // ----------------------------------------------------------------------------------------------------
- public static void printObject(Object o, String... subObjectNames)
- // ----------------------------------------------------------------------------------------------------
- Method: report
- Parameters
- Steps
- Example Usage
- public static List report(Iterator list)
- // ----------------------------------------------------------------------------------------------------
- Method: countJs
- Steps:
- Example Usage:
- public static int count408s(List messages)
- Method: count408s
- Parameters:
- Return Value:
- Steps:
- public static void createCleanMemStream(JetStreamManagement jsm, String stream, String... subs) throws IOException, JetStreamApiException
- public static void createCleanFileStream(JetStreamManagement jsm, String stream, String... subs) throws IOException, JetStreamApiException
- NatsJsPullSubExpiresIn
- public static void main(String[] args)
- NatsJsPushSubBasicSync
- public static void main(String[] args)
- NatsJsPullSubIterateUseCases
- public static void main(String[] args)
- NatsJsPubAsync2
- public static void main(String[] args)
- Helper
- NatsJsPushSubFilterSubject
- public static void main(String[] args)
- Description of the main method in class io.nats.examples.jetstream.NatsJsPushSubFilterSubject
- NatsJsPullSubExpiresInUseCases
- public static void main(String[] args)
- NatsJsPullSubNoWaitUseCases
- public static void main(String[] args)
- NatsJsPullSubMultipleWorkers
- public static void main(String[] args)
- NatsJsPushSubFlowControl
- public static void main(String[] args)
- NatsJsManageStreams
- public static void main(String[] args)
- NatsJsPushSubQueueDurable
- public static void main(String[] args)
- NatsJsPushSubAsyncQueueDurable
- public static void main(String[] args)
- NatsJsMirrorSubUseCases
- public static void main(String[] args)
- NatsJsPullSubBatchSizeUseCases
- public static void main(String[] args)
- Step-by-Step Description of the main Method
- NatsJsPushSubBindDurable
- public static void main(String[] args)
- NatsJsPubAsync
- public static void main(String[] args)
- NatsJsPullSubBatchSize
- public static void main(String[] args)
- NatsJsPullSubFetch
- public static void main(String[] args)
- NatsKeyValueFull
- NatsKeyValueFull
- public static void main(String[] args)
- NatsJsManageConsumers
- public static void main(String[] args)
- NatsJsPullSubFetchUseCases
- public static void main(String[] args)
- main method in class io.nats.examples.jetstream.NatsJsPullSubFetchUseCases
- Step 0: Initialize the subscription and pull
- Step 1: There are no messages yet
- Step 2: Publish 10 messages
- Step 3: Publish 20 messages
- Step 4: Get the rest of the publish
- Step 5: Publish 5 messages
- Step 6: Publish 15 messages
- Step 7: There are 5 messages left
- Step 8: Fetch but don't ack
- Step 9: Fetch the messages not acked
- NatsJsPubWithOptionsUseCases
- public static void main(String[] args)
- NatsJsPushSubBasicAsync
- public static void main(String[] args)
- NatsJsPubVersusCorePub
- public static void main(String[] args)
- NatsJsPub
- public static void main(String[] args)
- Description of the main method in class io.nats.examples.jetstream.NatsJsPub:
- NatsJsPushSubDeliverSubject
- public static void main(String[] args)
- private static void printMessage(String label, Message msg)
- NatsJsPullSubIterate
- public static void main(String[] args)
- NatsJsPrefix
- public static void main(String[] args)
- private static void readMessages(Connection nc, JetStream js, String subject) throws InterruptedException, IOException, JetStreamApiException, TimeoutException
- io.nats.examples.benchmark
- Sample
- public double throughput()
- public long rate()
- Utils
- public static String humanBytes(double bytes)
- Method Description: humanBytes
- Step by Step Description:
- public static List msgsPerClient(int numMsgs, int numClients)
- NatsBench2
- Options prepareOptions(boolean secure) throws NoSuchAlgorithmException
- public void runTest(String title, int pubCount, int subCount) throws Exception
- void installShutdownHook()
- private void parseArgs(String[] args)
- private static Properties loadProperties(String configPath)
- public static void main(String[] args)
- NatsBench
- Options prepareOptions(boolean secure) throws NoSuchAlgorithmException
- public void runTest(String title, int pubCount, int subCount) throws Exception
- void installShutdownHook()
- private void parseArgs(String[] args)
- private static Properties loadProperties(String configPath)
- Method: loadProperties
- Description
- Parameters
- Return Value
- Steps
- public static void main(String[] args)
- Benchmark
- public final void close()
- public final String report()
- public final String csv()
- String csvLines(SampleGroup grp, String prefix)
- JsPublishInRoundsBench
- public static void main(String[] args)
- private static Arguments readArgs(String[] args)
- SampleGroup
- public void addSample(Sample stat)
- public long minRate()
- public long maxRate()
- public long avgRate()
- public double stdDev()
- Method: stdDev()
- Step 1: Calculate the Average Rate
- Step 2: Calculate the Sum of Squared Differences
- Step 3: Calculate the Variance
- Step 4: Calculate the Standard Deviation
- Return Value
- all
- Please reload this page
- io_nats_client
- Please reload this page
- io_nats_client_api
- Please reload this page
- io_nats_client_impl
- Please reload this page
- io_nats_client_support
- Please reload this page
- io_nats_client_utils
- Please reload this page
- io_nats_examples
- Please reload this page
- io_nats_examples_autobench
- Please reload this page
- io_nats_examples_benchmark
- Please reload this page
- io_nats_examples_jetstream
- Please reload this page
- io_nats_examples_jetstream_simple
- Please reload this page
- io_nats_examples_service
- Please reload this page
- io_nats_examples_stability
- Please reload this page
- io_nats_examples_stan
- Please reload this page
- io_nats_service
- Please reload this page