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.