A B C D E G H I L M N O P R S T V
All Classes All Packages

A

AERON - com.aitusoftware.aether.Aether.Transport

aeronClient() - Method in class com.aitusoftware.aether.transport.CounterSnapshotPublisher.Context

aeronClient() - Method in class com.aitusoftware.aether.transport.CounterSnapshotSubscriber.Context

aeronClient(Aeron) - Method in class com.aitusoftware.aether.transport.CounterSnapshotPublisher.Context

aeronClient(Aeron) - Method in class com.aitusoftware.aether.transport.CounterSnapshotSubscriber.Context

aeronDirectoryName() - Method in class com.aitusoftware.aether.Aether.Context

aeronDirectoryName() - Method in class com.aitusoftware.aether.transport.CounterSnapshotPublisher.Context

aeronDirectoryName() - Method in class com.aitusoftware.aether.transport.CounterSnapshotSubscriber.Context

aeronDirectoryName(String) - Method in class com.aitusoftware.aether.Aether.Context

aeronDirectoryName(String) - Method in class com.aitusoftware.aether.transport.CounterSnapshotPublisher.Context

aeronDirectoryName(String) - Method in class com.aitusoftware.aether.transport.CounterSnapshotSubscriber.Context

AeronStatOutputParser - Class in com.aitusoftware.aether.parse

AeronStatOutputParser() - Constructor for class com.aitusoftware.aether.parse.AeronStatOutputParser

Aether - Class in com.aitusoftware.aether

Agent used to read Aeron counters and publish snapshots to the configured CounterSnapshotListener.

Aether.Configuration - Class in com.aitusoftware.aether

Aether.Context - Class in com.aitusoftware.aether

Configuration context.

Aether.Mode - Enum in com.aitusoftware.aether

Aether.MonitoringLocation - Class in com.aitusoftware.aether

Aether.ThreadingMode - Enum in com.aitusoftware.aether

Aether.Transport - Enum in com.aitusoftware.aether

aetherChannel() - Method in class com.aitusoftware.aether.transport.CounterSnapshotPublisher.Context

aetherChannel() - Method in class com.aitusoftware.aether.transport.CounterSnapshotSubscriber.Context

aetherChannel(String) - Method in class com.aitusoftware.aether.transport.CounterSnapshotPublisher.Context

aetherChannel(String) - Method in class com.aitusoftware.aether.transport.CounterSnapshotSubscriber.Context

aetherStreamId() - Method in class com.aitusoftware.aether.transport.CounterSnapshotPublisher.Context

aetherStreamId() - Method in class com.aitusoftware.aether.transport.CounterSnapshotSubscriber.Context

aetherStreamId(int) - Method in class com.aitusoftware.aether.transport.CounterSnapshotPublisher.Context

aetherStreamId(int) - Method in class com.aitusoftware.aether.transport.CounterSnapshotSubscriber.Context

B

backPressureEvents() - Method in class com.aitusoftware.aether.model.PublisherCounterSet

backPressureEvents(long) - Method in class com.aitusoftware.aether.model.PublisherCounterSet

buffered() - Method in class com.aitusoftware.aether.model.PublisherCounterSet

bytesReceived() - Method in class com.aitusoftware.aether.model.SystemCounters

bytesReceived(long) - Method in class com.aitusoftware.aether.model.SystemCounters

bytesSent() - Method in class com.aitusoftware.aether.model.SystemCounters

bytesSent(long) - Method in class com.aitusoftware.aether.model.SystemCounters

C

CallerOwned - Annotation Type in com.aitusoftware.aether.annotation

Marker interface to show that a parameter is owned by the caller of the method.

channel() - Method in class com.aitusoftware.aether.model.PublisherCounterSet

channel() - Method in class com.aitusoftware.aether.model.SubscriberCounterSet

ChannelSessionKey - Class in com.aitusoftware.aether.model

Describes a participant in a message flow.

ChannelSessionKey(String, String, int, int) - Constructor for class com.aitusoftware.aether.model.ChannelSessionKey

ChannelStatus - Class in com.aitusoftware.aether.model

ChannelStatus() - Constructor for class com.aitusoftware.aether.model.ChannelStatus

ChannelType - Enum in com.aitusoftware.aether.model

clientTimeouts() - Method in class com.aitusoftware.aether.model.SystemCounters

clientTimeouts(long) - Method in class com.aitusoftware.aether.model.SystemCounters

close() - Method in class com.aitusoftware.aether.Aether

close() - Method in class com.aitusoftware.aether.transport.CounterSnapshotPublisher

close() - Method in class com.aitusoftware.aether.transport.CounterSnapshotSubscriber

com.aitusoftware.aether - package com.aitusoftware.aether

com.aitusoftware.aether.aggregation - package com.aitusoftware.aether.aggregation

com.aitusoftware.aether.annotation - package com.aitusoftware.aether.annotation

com.aitusoftware.aether.event - package com.aitusoftware.aether.event

com.aitusoftware.aether.model - package com.aitusoftware.aether.model

com.aitusoftware.aether.parse - package com.aitusoftware.aether.parse

com.aitusoftware.aether.transport - package com.aitusoftware.aether.transport

Configuration() - Constructor for class com.aitusoftware.aether.Aether.Configuration

ConsolePrinter - Class in com.aitusoftware.aether.event

ConsolePrinter() - Constructor for class com.aitusoftware.aether.event.ConsolePrinter

consumeRates(RateConsumer) - Method in class com.aitusoftware.aether.aggregation.StreamRate

Context() - Constructor for class com.aitusoftware.aether.Aether.Context

Context() - Constructor for class com.aitusoftware.aether.transport.CounterSnapshotPublisher.Context

Context() - Constructor for class com.aitusoftware.aether.transport.CounterSnapshotSubscriber.Context

copy() - Method in class com.aitusoftware.aether.model.PublisherCounterSet

copy() - Method in class com.aitusoftware.aether.model.SubscriberCounterSet

copyInto(SystemCounters) - Method in class com.aitusoftware.aether.model.SystemCounters

CounterEventHandler - Class in com.aitusoftware.aether.event

CounterEventHandler(CounterRepository<PublisherCounterSet>, CounterRepository<SubscriberCounterSet>, CounterSnapshotListener, EpochClock) - Constructor for class com.aitusoftware.aether.event.CounterEventHandler

CounterRepository<T extends SessionKeyed> - Class in com.aitusoftware.aether.event

CounterRepository(Supplier<T>) - Constructor for class com.aitusoftware.aether.event.CounterRepository

counterSnapshotListener() - Method in class com.aitusoftware.aether.Aether.Context

counterSnapshotListener() - Method in class com.aitusoftware.aether.transport.CounterSnapshotSubscriber.Context

counterSnapshotListener(CounterSnapshotListener) - Method in class com.aitusoftware.aether.Aether.Context

counterSnapshotListener(CounterSnapshotListener) - Method in class com.aitusoftware.aether.transport.CounterSnapshotSubscriber.Context

CounterSnapshotListener - Interface in com.aitusoftware.aether.event

Defines a listener to snapshots of a MediaDriver's counters.

CounterSnapshotPublisher - Class in com.aitusoftware.aether.transport

An implementation of CounterSnapshotListener that publishes to an Aeron Publication.

CounterSnapshotPublisher() - Constructor for class com.aitusoftware.aether.transport.CounterSnapshotPublisher

Construct a new publisher using runtime configuration.

CounterSnapshotPublisher(CounterSnapshotPublisher.Context) - Constructor for class com.aitusoftware.aether.transport.CounterSnapshotPublisher

Construct a new publisher from the supplied context.

CounterSnapshotPublisher.Context - Class in com.aitusoftware.aether.transport

Configuration context.

CounterSnapshotSubscriber - Class in com.aitusoftware.aether.transport

A listener to data published by a CounterSnapshotPublisher.

CounterSnapshotSubscriber() - Constructor for class com.aitusoftware.aether.transport.CounterSnapshotSubscriber

Creates a new subscriber using runtime configuration.

CounterSnapshotSubscriber(CounterSnapshotSubscriber.Context) - Constructor for class com.aitusoftware.aether.transport.CounterSnapshotSubscriber

Creates a new subscriber from the supplied context.

CounterSnapshotSubscriber.Context - Class in com.aitusoftware.aether.transport

Configuration context.

CounterValueListener - Interface in com.aitusoftware.aether.event

D

doWork() - Method in class com.aitusoftware.aether.Aether

doWork() - Method in class com.aitusoftware.aether.transport.CounterSnapshotSubscriber

Poll the Aeron Subscription.

E

equals(Object) - Method in class com.aitusoftware.aether.event.StreamKey

equals(Object) - Method in class com.aitusoftware.aether.model.ChannelSessionKey

errors() - Method in class com.aitusoftware.aether.model.SystemCounters

errors(long) - Method in class com.aitusoftware.aether.model.SystemCounters

G

getChannel() - Method in class com.aitusoftware.aether.event.StreamKey

Returns the channel.

getChannel() - Method in class com.aitusoftware.aether.model.ChannelSessionKey

getConnectionsByStream() - Method in class com.aitusoftware.aether.event.SystemSnapshot

Returns a tree-like structure identifying participants in individual message flows.

getDuration() - Method in class com.aitusoftware.aether.aggregation.RateBucket

getDurationUnit() - Method in class com.aitusoftware.aether.aggregation.RateBucket

getLabel() - Method in class com.aitusoftware.aether.model.ChannelSessionKey

getPublisherCounterSet(ChannelSessionKey) - Method in class com.aitusoftware.aether.event.SystemSnapshot

Returns the publisher counters associated with a particular publisher.

getSessionId() - Method in class com.aitusoftware.aether.model.ChannelSessionKey

getStreamId() - Method in class com.aitusoftware.aether.event.StreamKey

Returns the streamId.

getStreamId() - Method in class com.aitusoftware.aether.model.ChannelSessionKey

getSubscriberCounterSet(ChannelSessionKey) - Method in class com.aitusoftware.aether.event.SystemSnapshot

Returns the subscriber counters associated with a particular subscriber.

getSystemCounters() - Method in class com.aitusoftware.aether.event.SystemSnapshot

Returns system counters keyed by MediaDriver label.

H

hashCode() - Method in class com.aitusoftware.aether.event.StreamKey

hashCode() - Method in class com.aitusoftware.aether.model.ChannelSessionKey

I

incompleteData() - Method in class com.aitusoftware.aether.model.SubscriberCounterSet

inflight(PublisherCounterSet) - Method in class com.aitusoftware.aether.model.SubscriberCounterSet

INVOKER - com.aitusoftware.aether.Aether.ThreadingMode

L

launch(Aether.Context) - Static method in class com.aitusoftware.aether.Aether

Launches an Aether agent with the provided configuration context.

launchEmbeddedMediaDriver() - Method in class com.aitusoftware.aether.Aether.Context

launchEmbeddedMediaDriver(boolean) - Method in class com.aitusoftware.aether.Aether.Context

LOCAL - com.aitusoftware.aether.Aether.Mode

LOCAL - com.aitusoftware.aether.Aether.Transport

M

main(String[]) - Static method in class com.aitusoftware.aether.Aether

Main method to start an Aether agent.

mode() - Static method in class com.aitusoftware.aether.Aether.Configuration

mode() - Method in class com.aitusoftware.aether.Aether.Context

mode(Aether.Mode) - Method in class com.aitusoftware.aether.Aether.Context

MODE_PROPERTY_NAME - Static variable in class com.aitusoftware.aether.Aether.Configuration

MONITORING_LOCATIONS_PROPERTY_NAME - Static variable in class com.aitusoftware.aether.Aether.Configuration

MonitoringLocation(String, String) - Constructor for class com.aitusoftware.aether.Aether.MonitoringLocation

monitoringLocations() - Static method in class com.aitusoftware.aether.Aether.Configuration

monitoringLocations() - Method in class com.aitusoftware.aether.Aether.Context

monitoringLocations(List<Aether.MonitoringLocation>) - Method in class com.aitusoftware.aether.Aether.Context

N

naksReceived() - Method in class com.aitusoftware.aether.model.SystemCounters

naksReceived(long) - Method in class com.aitusoftware.aether.model.SystemCounters

naksSent() - Method in class com.aitusoftware.aether.model.SystemCounters

naksSent(long) - Method in class com.aitusoftware.aether.model.SystemCounters

O

onAggregateRate(long, TimeUnit, long) - Method in interface com.aitusoftware.aether.aggregation.RateConsumer

onCounterEvent(int, int, CharSequence, int, int, long, long) - Method in class com.aitusoftware.aether.event.CounterEventHandler

onCounterEvent(int, int, CharSequence, int, int, long, long) - Method in interface com.aitusoftware.aether.event.CounterValueListener

onEndOfBatch(String) - Method in class com.aitusoftware.aether.event.CounterEventHandler

onEndOfBatch(String) - Method in interface com.aitusoftware.aether.event.CounterValueListener

onFragment(DirectBuffer, int, int, Header) - Method in class com.aitusoftware.aether.transport.CounterSnapshotSubscriber

onSnapshot(String, long, List<PublisherCounterSet>, List<SubscriberCounterSet>, SystemCounters) - Method in class com.aitusoftware.aether.event.ConsolePrinter

onSnapshot(String, long, List<PublisherCounterSet>, List<SubscriberCounterSet>, SystemCounters) - Method in interface com.aitusoftware.aether.event.CounterSnapshotListener

Called when a complete snapshot of the counters has been built.

onSnapshot(String, long, List<PublisherCounterSet>, List<SubscriberCounterSet>, SystemCounters) - Method in class com.aitusoftware.aether.event.RateMonitor

onSnapshot(String, long, List<PublisherCounterSet>, List<SubscriberCounterSet>, SystemCounters) - Method in class com.aitusoftware.aether.event.SystemSnapshot

Called when a complete snapshot of the counters has been built.

onSnapshot(String, long, List<PublisherCounterSet>, List<SubscriberCounterSet>, SystemCounters) - Method in class com.aitusoftware.aether.transport.CounterSnapshotPublisher

Called when a complete snapshot of the counters has been built.

P

parse(InputStream) - Method in class com.aitusoftware.aether.parse.AeronStatOutputParser

PUBLISHER - com.aitusoftware.aether.Aether.Mode

PUBLISHER - com.aitusoftware.aether.model.ChannelType

publisherBufferRemaining() - Method in class com.aitusoftware.aether.model.PublisherCounterSet

PublisherCounterSet - Class in com.aitusoftware.aether.model

Models counters associated with a publisher.

PublisherCounterSet() - Constructor for class com.aitusoftware.aether.model.PublisherCounterSet

publisherLimit() - Method in class com.aitusoftware.aether.model.PublisherCounterSet

publisherLimit(long) - Method in class com.aitusoftware.aether.model.PublisherCounterSet

publisherPosition() - Method in class com.aitusoftware.aether.model.PublisherCounterSet

publisherPosition(long) - Method in class com.aitusoftware.aether.model.PublisherCounterSet

publisherRates() - Method in class com.aitusoftware.aether.event.RateMonitor

R

RateBucket - Class in com.aitusoftware.aether.aggregation

RateBucket(long, TimeUnit) - Constructor for class com.aitusoftware.aether.aggregation.RateBucket

RateConsumer - Interface in com.aitusoftware.aether.aggregation

RateMonitor - Class in com.aitusoftware.aether.event

RateMonitor(List<RateBucket>) - Constructor for class com.aitusoftware.aether.event.RateMonitor

receiverHighWaterMark() - Method in class com.aitusoftware.aether.model.SubscriberCounterSet

receiverHighWaterMark(long) - Method in class com.aitusoftware.aether.model.SubscriberCounterSet

receiverPosition() - Method in class com.aitusoftware.aether.model.SubscriberCounterSet

receiverPosition(long) - Method in class com.aitusoftware.aether.model.SubscriberCounterSet

reset(CharSequence, int, int) - Method in class com.aitusoftware.aether.model.PublisherCounterSet

Sets the relevant fields on this entity.

reset(CharSequence, int, int) - Method in interface com.aitusoftware.aether.model.SessionKeyed

Sets the relevant fields on this entity.

reset(CharSequence, int, int) - Method in class com.aitusoftware.aether.model.SubscriberCounterSet

Sets the relevant fields on this entity.

roleName() - Method in class com.aitusoftware.aether.Aether

S

senderLimit() - Method in class com.aitusoftware.aether.model.PublisherCounterSet

senderLimit(long) - Method in class com.aitusoftware.aether.model.PublisherCounterSet

senderPosition() - Method in class com.aitusoftware.aether.model.PublisherCounterSet

senderPosition(long) - Method in class com.aitusoftware.aether.model.PublisherCounterSet

sessionId() - Method in class com.aitusoftware.aether.model.PublisherCounterSet

sessionId() - Method in class com.aitusoftware.aether.model.SubscriberCounterSet

sessionId(int) - Method in class com.aitusoftware.aether.model.PublisherCounterSet

sessionId(int) - Method in class com.aitusoftware.aether.model.SubscriberCounterSet

SessionKeyed - Interface in com.aitusoftware.aether.model

Interface describing an entity that can be identified by channel, streamId, and sessionId.

streamId() - Method in class com.aitusoftware.aether.model.PublisherCounterSet

streamId() - Method in class com.aitusoftware.aether.model.SubscriberCounterSet

StreamKey - Class in com.aitusoftware.aether.event

Represents a single data stream, identified by channel and streamId.

streamPosition(long, long) - Method in class com.aitusoftware.aether.aggregation.StreamRate

StreamRate - Class in com.aitusoftware.aether.aggregation

StreamRate(List<RateBucket>) - Constructor for class com.aitusoftware.aether.aggregation.StreamRate

SUBSCRIBER - com.aitusoftware.aether.Aether.Mode

SUBSCRIBER - com.aitusoftware.aether.model.ChannelType

subscriberCount() - Method in class com.aitusoftware.aether.model.SubscriberCounterSet

SubscriberCounterSet - Class in com.aitusoftware.aether.model

Models counters associated with a subscriber.

SubscriberCounterSet() - Constructor for class com.aitusoftware.aether.model.SubscriberCounterSet

subscriberPosition(long, long) - Method in class com.aitusoftware.aether.model.SubscriberCounterSet

subscriberPositions() - Method in class com.aitusoftware.aether.model.SubscriberCounterSet

SystemCounters - Class in com.aitusoftware.aether.model

Models counters associated with a MediaDriver.

SystemCounters() - Constructor for class com.aitusoftware.aether.model.SystemCounters

SystemSnapshot - Class in com.aitusoftware.aether.event

Maintains an aggregate view over multiple MediaDriver snapshots.

SystemSnapshot() - Constructor for class com.aitusoftware.aether.event.SystemSnapshot

T

THREADED - com.aitusoftware.aether.Aether.ThreadingMode

threadingMode() - Method in class com.aitusoftware.aether.Aether.Context

threadingMode(Aether.ThreadingMode) - Method in class com.aitusoftware.aether.Aether.Context

toString() - Method in class com.aitusoftware.aether.model.SystemCounters

transport() - Static method in class com.aitusoftware.aether.Aether.Configuration

transport() - Method in class com.aitusoftware.aether.Aether.Context

transport(Aether.Transport) - Method in class com.aitusoftware.aether.Aether.Context

TRANSPORT_PROPERTY_NAME - Static variable in class com.aitusoftware.aether.Aether.Configuration

V

valueOf(String) - Static method in enum com.aitusoftware.aether.Aether.Mode

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.aitusoftware.aether.Aether.ThreadingMode

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.aitusoftware.aether.Aether.Transport

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.aitusoftware.aether.model.ChannelType

Returns the enum constant of this type with the specified name.

values() - Static method in enum com.aitusoftware.aether.Aether.Mode

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.aitusoftware.aether.Aether.ThreadingMode

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.aitusoftware.aether.Aether.Transport

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.aitusoftware.aether.model.ChannelType

Returns an array containing the constants of this enum type, in the order they are declared.

A B C D E G H I L M N O P R S T V
All Classes All Packages