Streaming

oci.streaming.StreamAdminClient	Use the Streaming API to produce and consume messages, create streams and stream pools, and manage related items.
oci.streaming.StreamClient	Use the Streaming API to produce and consume messages, create streams and stream pools, and manage related items.
oci.streaming.StreamAdminClientCompositeOperations	This class provides a wrapper around StreamAdminClient and offers convenience methods for operations that would otherwise need to be chained together.
oci.streaming.StreamClientCompositeOperations	This class provides a wrapper around StreamClient and offers convenience methods for operations that would otherwise need to be chained together.

Models

oci.streaming.models.ChangeConnectHarnessCompartmentDetails	Detailed representation of a change connect harness compartment operation.
oci.streaming.models.ChangeStreamCompartmentDetails	Detailed representation of a change stream compartment operation.
oci.streaming.models.ChangeStreamPoolCompartmentDetails	Detailed representation of a change stream pool compartment operation.
oci.streaming.models.ConnectHarness	Detailed representation of a connect harness.
oci.streaming.models.ConnectHarnessSummary	Summary representation of a ConnectHarness.
oci.streaming.models.CreateConnectHarnessDetails	Object used to create a connect harness.
oci.streaming.models.CreateCursorDetails	Object used to create a cursor to consume messages in a stream.
oci.streaming.models.CreateGroupCursorDetails	Object used to create a group cursor.
oci.streaming.models.CreateStreamDetails	Object used to create a stream.
oci.streaming.models.CreateStreamPoolDetails	Object used to create a stream pool.
oci.streaming.models.Cursor	A cursor that indicates the position in the stream from which you want to begin consuming messages and which is required by the get_messages() operation.
oci.streaming.models.CustomEncryptionKey	Custom Encryption Key which will be used for encryption by all the streams in the pool.
oci.streaming.models.CustomEncryptionKeyDetails	The OCID of the custom encryption key to be used or deleted if currently being used.
oci.streaming.models.Group	Represents the current state of a consumer group, including partition reservations and committed offsets.
oci.streaming.models.KafkaSettings	Settings for the Kafka compatibility layer.
oci.streaming.models.Message	A message in a stream.
oci.streaming.models.PartitionReservation	Represents the state of a single partition reservation.
oci.streaming.models.PrivateEndpointDetails	Optional parameters if a private stream pool is requested.
oci.streaming.models.PrivateEndpointSettings	Optional settings if the stream pool is private.
oci.streaming.models.PutMessagesDetails	Object that represents an array of messages to emit to a stream.
oci.streaming.models.PutMessagesDetailsEntry	Object that represents a message to emit to a stream.
oci.streaming.models.PutMessagesResult	The response to a put_messages() request.
oci.streaming.models.PutMessagesResultEntry	Represents the result of a put_messages() request, whether it was successful or not.
oci.streaming.models.Stream	Detailed representation of a stream, including all its partitions.
oci.streaming.models.StreamPool	The details of a stream pool.
oci.streaming.models.StreamPoolSummary	The summary representation of a stream pool.
oci.streaming.models.StreamSummary	Summary representation of a stream.
oci.streaming.models.UpdateConnectHarnessDetails	Object used to update a connect harness.
oci.streaming.models.UpdateGroupDetails	Request body for operationally managing a group.
oci.streaming.models.UpdateStreamDetails	Object used to update a stream.
oci.streaming.models.UpdateStreamPoolDetails	Object used to update the stream pool’s details.