oci-go-sdk: github.com/oracle/oci-go-sdk/streaming Index | Files

package streaming

import "github.com/oracle/oci-go-sdk/streaming"

Index

Package Files

change_connect_harness_compartment_details.go change_connect_harness_compartment_request_response.go change_stream_compartment_details.go change_stream_compartment_request_response.go change_stream_pool_compartment_details.go change_stream_pool_compartment_request_response.go connect_harness.go connect_harness_summary.go consumer_commit_request_response.go consumer_heartbeat_request_response.go create_connect_harness_details.go create_connect_harness_request_response.go create_cursor_details.go create_cursor_request_response.go create_group_cursor_details.go create_group_cursor_request_response.go create_stream_details.go create_stream_pool_details.go create_stream_pool_request_response.go create_stream_request_response.go cursor.go custom_encryption_key.go custom_encryption_key_details.go delete_connect_harness_request_response.go delete_stream_pool_request_response.go delete_stream_request_response.go get_connect_harness_request_response.go get_group_request_response.go get_messages_request_response.go get_stream_pool_request_response.go get_stream_request_response.go group.go kafka_settings.go list_connect_harnesses_request_response.go list_stream_pools_request_response.go list_streams_request_response.go message.go partition_reservation.go private_endpoint_details.go private_endpoint_settings.go put_messages_details.go put_messages_details_entry.go put_messages_request_response.go put_messages_result.go put_messages_result_entry.go stream.go stream_pool.go stream_pool_summary.go stream_summary.go streaming_stream_client.go streaming_streamadmin_client.go update_connect_harness_details.go update_connect_harness_request_response.go update_group_details.go update_group_request_response.go update_stream_details.go update_stream_pool_details.go update_stream_pool_request_response.go update_stream_request_response.go

type ChangeConnectHarnessCompartmentDetails Uses

type ChangeConnectHarnessCompartmentDetails struct {

    // The OCID (https://docs.cloud.oracle.com/Content/General/Concepts/identifiers.htm) of the compartment
    // into which the resource should be moved.
    CompartmentId *string `mandatory:"true" json:"compartmentId"`
}

ChangeConnectHarnessCompartmentDetails Detailed representation of a change connect harness compartment operation.

func (ChangeConnectHarnessCompartmentDetails) String Uses

func (m ChangeConnectHarnessCompartmentDetails) String() string

type ChangeConnectHarnessCompartmentRequest Uses

type ChangeConnectHarnessCompartmentRequest struct {

    // The OCID of the connect harness.
    ConnectHarnessId *string `mandatory:"true" contributesTo:"path" name:"connectHarnessId"`

    // The connect harness will be moved into the compartment specified within this entity.
    ChangeConnectHarnessCompartmentDetails `contributesTo:"body"`

    // For optimistic concurrency control. In the PUT or DELETE call for a resource, set the if-match parameter to the value of the etag from a previous GET or POST response for that resource. The resource will be updated or deleted only if the etag you provide matches the resource's current etag value.
    IfMatch *string `mandatory:"false" contributesTo:"header" name:"if-match"`

    // The unique Oracle-assigned identifier for the request. If you need to contact Oracle about a
    // particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

ChangeConnectHarnessCompartmentRequest wrapper for the ChangeConnectHarnessCompartment operation

func (ChangeConnectHarnessCompartmentRequest) HTTPRequest Uses

func (request ChangeConnectHarnessCompartmentRequest) HTTPRequest(method, path string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (ChangeConnectHarnessCompartmentRequest) RetryPolicy Uses

func (request ChangeConnectHarnessCompartmentRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (ChangeConnectHarnessCompartmentRequest) String Uses

func (request ChangeConnectHarnessCompartmentRequest) String() string

type ChangeConnectHarnessCompartmentResponse Uses

type ChangeConnectHarnessCompartmentResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about
    // a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`
}

ChangeConnectHarnessCompartmentResponse wrapper for the ChangeConnectHarnessCompartment operation

func (ChangeConnectHarnessCompartmentResponse) HTTPResponse Uses

func (response ChangeConnectHarnessCompartmentResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (ChangeConnectHarnessCompartmentResponse) String Uses

func (response ChangeConnectHarnessCompartmentResponse) String() string

type ChangeStreamCompartmentDetails Uses

type ChangeStreamCompartmentDetails struct {

    // The OCID (https://docs.cloud.oracle.com/Content/General/Concepts/identifiers.htm) of the compartment
    // into which the resource should be moved.
    CompartmentId *string `mandatory:"true" json:"compartmentId"`
}

ChangeStreamCompartmentDetails Detailed representation of a change stream compartment operation.

func (ChangeStreamCompartmentDetails) String Uses

func (m ChangeStreamCompartmentDetails) String() string

type ChangeStreamCompartmentRequest Uses

type ChangeStreamCompartmentRequest struct {

    // The OCID of the stream.
    StreamId *string `mandatory:"true" contributesTo:"path" name:"streamId"`

    // The stream will be moved into the compartment specified within this entity.
    ChangeStreamCompartmentDetails `contributesTo:"body"`

    // For optimistic concurrency control. In the PUT or DELETE call for a resource, set the if-match parameter to the value of the etag from a previous GET or POST response for that resource. The resource will be updated or deleted only if the etag you provide matches the resource's current etag value.
    IfMatch *string `mandatory:"false" contributesTo:"header" name:"if-match"`

    // The unique Oracle-assigned identifier for the request. If you need to contact Oracle about a
    // particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

ChangeStreamCompartmentRequest wrapper for the ChangeStreamCompartment operation

func (ChangeStreamCompartmentRequest) HTTPRequest Uses

func (request ChangeStreamCompartmentRequest) HTTPRequest(method, path string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (ChangeStreamCompartmentRequest) RetryPolicy Uses

func (request ChangeStreamCompartmentRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (ChangeStreamCompartmentRequest) String Uses

func (request ChangeStreamCompartmentRequest) String() string

type ChangeStreamCompartmentResponse Uses

type ChangeStreamCompartmentResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about
    // a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`
}

ChangeStreamCompartmentResponse wrapper for the ChangeStreamCompartment operation

func (ChangeStreamCompartmentResponse) HTTPResponse Uses

func (response ChangeStreamCompartmentResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (ChangeStreamCompartmentResponse) String Uses

func (response ChangeStreamCompartmentResponse) String() string

type ChangeStreamPoolCompartmentDetails Uses

type ChangeStreamPoolCompartmentDetails struct {

    // The OCID (https://docs.cloud.oracle.com/Content/General/Concepts/identifiers.htm) of the compartment
    // into which the resource should be moved.
    CompartmentId *string `mandatory:"true" json:"compartmentId"`
}

ChangeStreamPoolCompartmentDetails Detailed representation of a change stream pool compartment operation.

func (ChangeStreamPoolCompartmentDetails) String Uses

func (m ChangeStreamPoolCompartmentDetails) String() string

type ChangeStreamPoolCompartmentRequest Uses

type ChangeStreamPoolCompartmentRequest struct {

    // The OCID of the stream pool.
    StreamPoolId *string `mandatory:"true" contributesTo:"path" name:"streamPoolId"`

    // The stream pool will be moved into the compartment specified within this entity.
    ChangeStreamPoolCompartmentDetails `contributesTo:"body"`

    // For optimistic concurrency control. In the PUT or DELETE call for a resource, set the if-match parameter to the value of the etag from a previous GET or POST response for that resource. The resource will be updated or deleted only if the etag you provide matches the resource's current etag value.
    IfMatch *string `mandatory:"false" contributesTo:"header" name:"if-match"`

    // The unique Oracle-assigned identifier for the request. If you need to contact Oracle about a
    // particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

ChangeStreamPoolCompartmentRequest wrapper for the ChangeStreamPoolCompartment operation

func (ChangeStreamPoolCompartmentRequest) HTTPRequest Uses

func (request ChangeStreamPoolCompartmentRequest) HTTPRequest(method, path string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (ChangeStreamPoolCompartmentRequest) RetryPolicy Uses

func (request ChangeStreamPoolCompartmentRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (ChangeStreamPoolCompartmentRequest) String Uses

func (request ChangeStreamPoolCompartmentRequest) String() string

type ChangeStreamPoolCompartmentResponse Uses

type ChangeStreamPoolCompartmentResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about
    // a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`
}

ChangeStreamPoolCompartmentResponse wrapper for the ChangeStreamPoolCompartment operation

func (ChangeStreamPoolCompartmentResponse) HTTPResponse Uses

func (response ChangeStreamPoolCompartmentResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (ChangeStreamPoolCompartmentResponse) String Uses

func (response ChangeStreamPoolCompartmentResponse) String() string

type ConnectHarness Uses

type ConnectHarness struct {

    // The name of the connect harness. Avoid entering confidential information.
    // Example: `JDBCConnector`
    Name *string `mandatory:"true" json:"name"`

    // The OCID of the connect harness.
    Id  *string `mandatory:"true" json:"id"`

    // The OCID of the compartment that contains the connect harness.
    CompartmentId *string `mandatory:"true" json:"compartmentId"`

    // The current state of the connect harness.
    LifecycleState ConnectHarnessLifecycleStateEnum `mandatory:"true" json:"lifecycleState"`

    // The date and time the connect harness was created, expressed in in RFC 3339 (https://tools.ietf.org/rfc/rfc3339) timestamp format.
    // Example: `2018-04-20T00:00:07.405Z`
    TimeCreated *common.SDKTime `mandatory:"true" json:"timeCreated"`

    // Any additional details about the current state of the connect harness.
    LifecycleStateDetails *string `mandatory:"false" json:"lifecycleStateDetails"`

    // Free-form tags for this resource. Each tag is a simple key-value pair with no predefined name, type, or namespace. Exists for cross-compatibility only.
    // For more information, see Resource Tags (https://docs.cloud.oracle.com/Content/General/Concepts/resourcetags.htm).
    // Example: `{"Department": "Finance"}`
    FreeformTags map[string]string `mandatory:"false" json:"freeformTags"`

    // Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see Resource Tags (https://docs.cloud.oracle.com/Content/General/Concepts/resourcetags.htm).
    // Example: `{"Operations": {"CostCenter": "42"}}'
    DefinedTags map[string]map[string]interface{} `mandatory:"false" json:"definedTags"`
}

ConnectHarness Detailed representation of a connect harness.

func (ConnectHarness) String Uses

func (m ConnectHarness) String() string

type ConnectHarnessLifecycleStateEnum Uses

type ConnectHarnessLifecycleStateEnum string

ConnectHarnessLifecycleStateEnum Enum with underlying type: string

const (
    ConnectHarnessLifecycleStateCreating ConnectHarnessLifecycleStateEnum = "CREATING"
    ConnectHarnessLifecycleStateActive   ConnectHarnessLifecycleStateEnum = "ACTIVE"
    ConnectHarnessLifecycleStateDeleting ConnectHarnessLifecycleStateEnum = "DELETING"
    ConnectHarnessLifecycleStateDeleted  ConnectHarnessLifecycleStateEnum = "DELETED"
    ConnectHarnessLifecycleStateFailed   ConnectHarnessLifecycleStateEnum = "FAILED"
    ConnectHarnessLifecycleStateUpdating ConnectHarnessLifecycleStateEnum = "UPDATING"
)

Set of constants representing the allowable values for ConnectHarnessLifecycleStateEnum

func GetConnectHarnessLifecycleStateEnumValues Uses

func GetConnectHarnessLifecycleStateEnumValues() []ConnectHarnessLifecycleStateEnum

GetConnectHarnessLifecycleStateEnumValues Enumerates the set of values for ConnectHarnessLifecycleStateEnum

type ConnectHarnessSummary Uses

type ConnectHarnessSummary struct {

    // The name of the connect harness.
    // Example: `TelemetryEvents`
    Name *string `mandatory:"true" json:"name"`

    // The OCID of the connect harness.
    Id  *string `mandatory:"true" json:"id"`

    // The OCID of the compartment that contains the connect harness.
    CompartmentId *string `mandatory:"true" json:"compartmentId"`

    // The current state of the connect harness.
    LifecycleState ConnectHarnessSummaryLifecycleStateEnum `mandatory:"true" json:"lifecycleState"`

    // The date and time the connect harness was created, expressed in RFC 3339 (https://tools.ietf.org/rfc/rfc3339) timestamp format.
    // Example: `2018-04-20T00:00:07.405Z`
    TimeCreated *common.SDKTime `mandatory:"true" json:"timeCreated"`

    // Free-form tags for this resource. Each tag is a simple key-value pair that is applied with no predefined name, type, or namespace. Exists for cross-compatibility only.
    // For more information, see Resource Tags (https://docs.cloud.oracle.com/Content/General/Concepts/resourcetags.htm).
    // Example: `{"Department": "Finance"}`
    FreeformTags map[string]string `mandatory:"false" json:"freeformTags"`

    // Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see Resource Tags (https://docs.cloud.oracle.com/Content/General/Concepts/resourcetags.htm).
    // Example: `{"Operations": {"CostCenter": "42"}}`
    DefinedTags map[string]map[string]interface{} `mandatory:"false" json:"definedTags"`
}

ConnectHarnessSummary Summary representation of a ConnectHarness.

func (ConnectHarnessSummary) String Uses

func (m ConnectHarnessSummary) String() string

type ConnectHarnessSummaryLifecycleStateEnum Uses

type ConnectHarnessSummaryLifecycleStateEnum string

ConnectHarnessSummaryLifecycleStateEnum Enum with underlying type: string

const (
    ConnectHarnessSummaryLifecycleStateCreating ConnectHarnessSummaryLifecycleStateEnum = "CREATING"
    ConnectHarnessSummaryLifecycleStateActive   ConnectHarnessSummaryLifecycleStateEnum = "ACTIVE"
    ConnectHarnessSummaryLifecycleStateDeleting ConnectHarnessSummaryLifecycleStateEnum = "DELETING"
    ConnectHarnessSummaryLifecycleStateDeleted  ConnectHarnessSummaryLifecycleStateEnum = "DELETED"
    ConnectHarnessSummaryLifecycleStateFailed   ConnectHarnessSummaryLifecycleStateEnum = "FAILED"
    ConnectHarnessSummaryLifecycleStateUpdating ConnectHarnessSummaryLifecycleStateEnum = "UPDATING"
)

Set of constants representing the allowable values for ConnectHarnessSummaryLifecycleStateEnum

func GetConnectHarnessSummaryLifecycleStateEnumValues Uses

func GetConnectHarnessSummaryLifecycleStateEnumValues() []ConnectHarnessSummaryLifecycleStateEnum

GetConnectHarnessSummaryLifecycleStateEnumValues Enumerates the set of values for ConnectHarnessSummaryLifecycleStateEnum

type ConsumerCommitRequest Uses

type ConsumerCommitRequest struct {

    // The OCID of the stream.
    StreamId *string `mandatory:"true" contributesTo:"path" name:"streamId"`

    // The group-cursor representing the offsets of the group. This cursor is retrieved from the CreateGroupCursor API call.
    Cursor *string `mandatory:"true" contributesTo:"query" name:"cursor"`

    // The unique Oracle-assigned identifier for the request. If you need to contact Oracle about a
    // particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

ConsumerCommitRequest wrapper for the ConsumerCommit operation

func (ConsumerCommitRequest) HTTPRequest Uses

func (request ConsumerCommitRequest) HTTPRequest(method, path string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (ConsumerCommitRequest) RetryPolicy Uses

func (request ConsumerCommitRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (ConsumerCommitRequest) String Uses

func (request ConsumerCommitRequest) String() string

type ConsumerCommitResponse Uses

type ConsumerCommitResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // The Cursor instance
    Cursor `presentIn:"body"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about
    // a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`
}

ConsumerCommitResponse wrapper for the ConsumerCommit operation

func (ConsumerCommitResponse) HTTPResponse Uses

func (response ConsumerCommitResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (ConsumerCommitResponse) String Uses

func (response ConsumerCommitResponse) String() string

type ConsumerHeartbeatRequest Uses

type ConsumerHeartbeatRequest struct {

    // The OCID of the stream.
    StreamId *string `mandatory:"true" contributesTo:"path" name:"streamId"`

    // The group-cursor representing the offsets of the group. This cursor is retrieved from the CreateGroupCursor API call.
    Cursor *string `mandatory:"true" contributesTo:"query" name:"cursor"`

    // The unique Oracle-assigned identifier for the request. If you need to contact Oracle about a
    // particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

ConsumerHeartbeatRequest wrapper for the ConsumerHeartbeat operation

func (ConsumerHeartbeatRequest) HTTPRequest Uses

func (request ConsumerHeartbeatRequest) HTTPRequest(method, path string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (ConsumerHeartbeatRequest) RetryPolicy Uses

func (request ConsumerHeartbeatRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (ConsumerHeartbeatRequest) String Uses

func (request ConsumerHeartbeatRequest) String() string

type ConsumerHeartbeatResponse Uses

type ConsumerHeartbeatResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // The Cursor instance
    Cursor `presentIn:"body"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about
    // a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`
}

ConsumerHeartbeatResponse wrapper for the ConsumerHeartbeat operation

func (ConsumerHeartbeatResponse) HTTPResponse Uses

func (response ConsumerHeartbeatResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (ConsumerHeartbeatResponse) String Uses

func (response ConsumerHeartbeatResponse) String() string

type CreateConnectHarnessDetails Uses

type CreateConnectHarnessDetails struct {

    // The name of the connect harness. Avoid entering confidential information.
    // Example: `JDBCConnector`
    Name *string `mandatory:"true" json:"name"`

    // The OCID of the compartment that contains the connect harness.
    CompartmentId *string `mandatory:"true" json:"compartmentId"`

    // Free-form tags for this resource. Each tag is a simple key-value pair that is applied with no predefined name, type, or namespace. Exists for cross-compatibility only.
    // For more information, see Resource Tags (https://docs.cloud.oracle.com/Content/General/Concepts/resourcetags.htm).
    // Example: `{"Department": "Finance"}`
    FreeformTags map[string]string `mandatory:"false" json:"freeformTags"`

    // Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see Resource Tags (https://docs.cloud.oracle.com/Content/General/Concepts/resourcetags.htm).
    // Example: `{"Operations": {"CostCenter": "42"}}`
    DefinedTags map[string]map[string]interface{} `mandatory:"false" json:"definedTags"`
}

CreateConnectHarnessDetails Object used to create a connect harness.

func (CreateConnectHarnessDetails) String Uses

func (m CreateConnectHarnessDetails) String() string

type CreateConnectHarnessRequest Uses

type CreateConnectHarnessRequest struct {

    // The connect harness to create.
    CreateConnectHarnessDetails `contributesTo:"body"`

    // The unique Oracle-assigned identifier for the request. If you need to contact Oracle about a
    // particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // A token that uniquely identifies a request so it can be retried in case of a timeout or server error without risk of executing that same action again. Retry tokens expire after 24 hours, but can be invalidated before then due to conflicting operations (for example, if a resource has been deleted and purged from the system, then a retry of the original creation request may be rejected).
    OpcRetryToken *string `mandatory:"false" contributesTo:"header" name:"opc-retry-token"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

CreateConnectHarnessRequest wrapper for the CreateConnectHarness operation

func (CreateConnectHarnessRequest) HTTPRequest Uses

func (request CreateConnectHarnessRequest) HTTPRequest(method, path string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (CreateConnectHarnessRequest) RetryPolicy Uses

func (request CreateConnectHarnessRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (CreateConnectHarnessRequest) String Uses

func (request CreateConnectHarnessRequest) String() string

type CreateConnectHarnessResponse Uses

type CreateConnectHarnessResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // The ConnectHarness instance
    ConnectHarness `presentIn:"body"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about
    // a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`

    // For optimistic concurrency control. See `if-match`.
    Etag *string `presentIn:"header" name:"etag"`
}

CreateConnectHarnessResponse wrapper for the CreateConnectHarness operation

func (CreateConnectHarnessResponse) HTTPResponse Uses

func (response CreateConnectHarnessResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (CreateConnectHarnessResponse) String Uses

func (response CreateConnectHarnessResponse) String() string

type CreateCursorDetails Uses

type CreateCursorDetails struct {

    // The partition to get messages from.
    Partition *string `mandatory:"true" json:"partition"`

    // The type of cursor, which determines the starting point from which the stream will be consumed:
    // - `AFTER_OFFSET:` The partition position immediately following the offset you specify. (Offsets are assigned when you successfully append a message to a partition in a stream.)
    // - `AT_OFFSET:` The exact partition position indicated by the offset you specify.
    // - `AT_TIME:` A specific point in time.
    // - `LATEST:` The most recent message in the partition that was added after the cursor was created.
    // - `TRIM_HORIZON:` The oldest message in the partition that is within the retention period window.
    Type CreateCursorDetailsTypeEnum `mandatory:"true" json:"type"`

    // The offset to consume from if the cursor type is `AT_OFFSET` or `AFTER_OFFSET`.
    Offset *int64 `mandatory:"false" json:"offset"`

    // The time to consume from if the cursor type is `AT_TIME`, expressed in RFC 3339 (https://tools.ietf.org/rfc/rfc3339) timestamp format.
    Time *common.SDKTime `mandatory:"false" json:"time"`
}

CreateCursorDetails Object used to create a cursor to consume messages in a stream.

func (CreateCursorDetails) String Uses

func (m CreateCursorDetails) String() string

type CreateCursorDetailsTypeEnum Uses

type CreateCursorDetailsTypeEnum string

CreateCursorDetailsTypeEnum Enum with underlying type: string

const (
    CreateCursorDetailsTypeAfterOffset CreateCursorDetailsTypeEnum = "AFTER_OFFSET"
    CreateCursorDetailsTypeAtOffset    CreateCursorDetailsTypeEnum = "AT_OFFSET"
    CreateCursorDetailsTypeAtTime      CreateCursorDetailsTypeEnum = "AT_TIME"
    CreateCursorDetailsTypeLatest      CreateCursorDetailsTypeEnum = "LATEST"
    CreateCursorDetailsTypeTrimHorizon CreateCursorDetailsTypeEnum = "TRIM_HORIZON"
)

Set of constants representing the allowable values for CreateCursorDetailsTypeEnum

func GetCreateCursorDetailsTypeEnumValues Uses

func GetCreateCursorDetailsTypeEnumValues() []CreateCursorDetailsTypeEnum

GetCreateCursorDetailsTypeEnumValues Enumerates the set of values for CreateCursorDetailsTypeEnum

type CreateCursorRequest Uses

type CreateCursorRequest struct {

    // The OCID of the stream.
    StreamId *string `mandatory:"true" contributesTo:"path" name:"streamId"`

    // The information used to create the cursor.
    CreateCursorDetails `contributesTo:"body"`

    // The unique Oracle-assigned identifier for the request. If you need to contact Oracle about a
    // particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

CreateCursorRequest wrapper for the CreateCursor operation

func (CreateCursorRequest) HTTPRequest Uses

func (request CreateCursorRequest) HTTPRequest(method, path string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (CreateCursorRequest) RetryPolicy Uses

func (request CreateCursorRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (CreateCursorRequest) String Uses

func (request CreateCursorRequest) String() string

type CreateCursorResponse Uses

type CreateCursorResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // The Cursor instance
    Cursor `presentIn:"body"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about
    // a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`
}

CreateCursorResponse wrapper for the CreateCursor operation

func (CreateCursorResponse) HTTPResponse Uses

func (response CreateCursorResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (CreateCursorResponse) String Uses

func (response CreateCursorResponse) String() string

type CreateGroupCursorDetails Uses

type CreateGroupCursorDetails struct {

    // The type of the cursor. This value is only used when the group is created.
    Type CreateGroupCursorDetailsTypeEnum `mandatory:"true" json:"type"`

    // Name of the consumer group.
    GroupName *string `mandatory:"true" json:"groupName"`

    // The time to consume from if type is AT_TIME.
    Time *common.SDKTime `mandatory:"false" json:"time"`

    // A unique identifier for the instance joining the consumer group. If an instanceName is not provided, a UUID will be generated and used.
    InstanceName *string `mandatory:"false" json:"instanceName"`

    // The amount of a consumer instance inactivity time, before partition reservations are released.
    TimeoutInMs *int `mandatory:"false" json:"timeoutInMs"`

    // When using consumer-groups, the default commit-on-get behaviour can be overriden by setting this value to false.
    // If disabled, a consumer must manually commit their cursors.
    CommitOnGet *bool `mandatory:"false" json:"commitOnGet"`
}

CreateGroupCursorDetails Object used to create a group cursor.

func (CreateGroupCursorDetails) String Uses

func (m CreateGroupCursorDetails) String() string

type CreateGroupCursorDetailsTypeEnum Uses

type CreateGroupCursorDetailsTypeEnum string

CreateGroupCursorDetailsTypeEnum Enum with underlying type: string

const (
    CreateGroupCursorDetailsTypeAtTime      CreateGroupCursorDetailsTypeEnum = "AT_TIME"
    CreateGroupCursorDetailsTypeLatest      CreateGroupCursorDetailsTypeEnum = "LATEST"
    CreateGroupCursorDetailsTypeTrimHorizon CreateGroupCursorDetailsTypeEnum = "TRIM_HORIZON"
)

Set of constants representing the allowable values for CreateGroupCursorDetailsTypeEnum

func GetCreateGroupCursorDetailsTypeEnumValues Uses

func GetCreateGroupCursorDetailsTypeEnumValues() []CreateGroupCursorDetailsTypeEnum

GetCreateGroupCursorDetailsTypeEnumValues Enumerates the set of values for CreateGroupCursorDetailsTypeEnum

type CreateGroupCursorRequest Uses

type CreateGroupCursorRequest struct {

    // The OCID of the stream.
    StreamId *string `mandatory:"true" contributesTo:"path" name:"streamId"`

    // The information used to create the cursor.
    CreateGroupCursorDetails `contributesTo:"body"`

    // The unique Oracle-assigned identifier for the request. If you need to contact Oracle about a
    // particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

CreateGroupCursorRequest wrapper for the CreateGroupCursor operation

func (CreateGroupCursorRequest) HTTPRequest Uses

func (request CreateGroupCursorRequest) HTTPRequest(method, path string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (CreateGroupCursorRequest) RetryPolicy Uses

func (request CreateGroupCursorRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (CreateGroupCursorRequest) String Uses

func (request CreateGroupCursorRequest) String() string

type CreateGroupCursorResponse Uses

type CreateGroupCursorResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // The Cursor instance
    Cursor `presentIn:"body"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about
    // a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`
}

CreateGroupCursorResponse wrapper for the CreateGroupCursor operation

func (CreateGroupCursorResponse) HTTPResponse Uses

func (response CreateGroupCursorResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (CreateGroupCursorResponse) String Uses

func (response CreateGroupCursorResponse) String() string

type CreateStreamDetails Uses

type CreateStreamDetails struct {

    // The name of the stream. Avoid entering confidential information.
    // Example: `TelemetryEvents`
    Name *string `mandatory:"true" json:"name"`

    // The number of partitions in the stream.
    Partitions *int `mandatory:"true" json:"partitions"`

    // The OCID of the compartment that contains the stream.
    CompartmentId *string `mandatory:"false" json:"compartmentId"`

    // The OCID of the stream pool that contains the stream.
    StreamPoolId *string `mandatory:"false" json:"streamPoolId"`

    // The retention period of the stream, in hours. Accepted values are between 24 and 168 (7 days).
    // If not specified, the stream will have a retention period of 24 hours.
    RetentionInHours *int `mandatory:"false" json:"retentionInHours"`

    // Free-form tags for this resource. Each tag is a simple key-value pair that is applied with no predefined name, type, or namespace. Exists for cross-compatibility only.
    // For more information, see Resource Tags (https://docs.cloud.oracle.com/Content/General/Concepts/resourcetags.htm).
    // Example: `{"Department": "Finance"}`
    FreeformTags map[string]string `mandatory:"false" json:"freeformTags"`

    // Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see Resource Tags (https://docs.cloud.oracle.com/Content/General/Concepts/resourcetags.htm).
    // Example: `{"Operations": {"CostCenter": "42"}}`
    DefinedTags map[string]map[string]interface{} `mandatory:"false" json:"definedTags"`
}

CreateStreamDetails Object used to create a stream.

func (CreateStreamDetails) String Uses

func (m CreateStreamDetails) String() string

type CreateStreamPoolDetails Uses

type CreateStreamPoolDetails struct {

    // The OCID of the compartment that contains the stream.
    CompartmentId *string `mandatory:"true" json:"compartmentId"`

    // The name of the stream pool. Avoid entering confidential information.
    // Example: `MyStreamPool`
    Name *string `mandatory:"true" json:"name"`

    KafkaSettings *KafkaSettings `mandatory:"false" json:"kafkaSettings"`

    CustomEncryptionKeyDetails *CustomEncryptionKeyDetails `mandatory:"false" json:"customEncryptionKeyDetails"`

    PrivateEndpointDetails *PrivateEndpointDetails `mandatory:"false" json:"privateEndpointDetails"`

    // Free-form tags for this resource. Each tag is a simple key-value pair that is applied with no predefined name, type, or namespace. Exists for cross-compatibility only.
    // For more information, see Resource Tags (https://docs.cloud.oracle.com/Content/General/Concepts/resourcetags.htm).
    // Example: `{"Department": "Finance"}`
    FreeformTags map[string]string `mandatory:"false" json:"freeformTags"`

    // Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see Resource Tags (https://docs.cloud.oracle.com/Content/General/Concepts/resourcetags.htm).
    // Example: `{"Operations": {"CostCenter": "42"}}`
    DefinedTags map[string]map[string]interface{} `mandatory:"false" json:"definedTags"`
}

CreateStreamPoolDetails Object used to create a stream pool.

func (CreateStreamPoolDetails) String Uses

func (m CreateStreamPoolDetails) String() string

type CreateStreamPoolRequest Uses

type CreateStreamPoolRequest struct {

    // The stream pool to create.
    CreateStreamPoolDetails `contributesTo:"body"`

    // The unique Oracle-assigned identifier for the request. If you need to contact Oracle about a
    // particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // A token that uniquely identifies a request so it can be retried in case of a timeout or server error without risk of executing that same action again. Retry tokens expire after 24 hours, but can be invalidated before then due to conflicting operations (for example, if a resource has been deleted and purged from the system, then a retry of the original creation request may be rejected).
    OpcRetryToken *string `mandatory:"false" contributesTo:"header" name:"opc-retry-token"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

CreateStreamPoolRequest wrapper for the CreateStreamPool operation

func (CreateStreamPoolRequest) HTTPRequest Uses

func (request CreateStreamPoolRequest) HTTPRequest(method, path string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (CreateStreamPoolRequest) RetryPolicy Uses

func (request CreateStreamPoolRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (CreateStreamPoolRequest) String Uses

func (request CreateStreamPoolRequest) String() string

type CreateStreamPoolResponse Uses

type CreateStreamPoolResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // The StreamPool instance
    StreamPool `presentIn:"body"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about
    // a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`

    // For optimistic concurrency control. See `if-match`.
    Etag *string `presentIn:"header" name:"etag"`
}

CreateStreamPoolResponse wrapper for the CreateStreamPool operation

func (CreateStreamPoolResponse) HTTPResponse Uses

func (response CreateStreamPoolResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (CreateStreamPoolResponse) String Uses

func (response CreateStreamPoolResponse) String() string

type CreateStreamRequest Uses

type CreateStreamRequest struct {

    // The stream to create.
    CreateStreamDetails `contributesTo:"body"`

    // The unique Oracle-assigned identifier for the request. If you need to contact Oracle about a
    // particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

CreateStreamRequest wrapper for the CreateStream operation

func (CreateStreamRequest) HTTPRequest Uses

func (request CreateStreamRequest) HTTPRequest(method, path string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (CreateStreamRequest) RetryPolicy Uses

func (request CreateStreamRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (CreateStreamRequest) String Uses

func (request CreateStreamRequest) String() string

type CreateStreamResponse Uses

type CreateStreamResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // The Stream instance
    Stream `presentIn:"body"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about
    // a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`

    // For optimistic concurrency control. See `if-match`.
    Etag *string `presentIn:"header" name:"etag"`
}

CreateStreamResponse wrapper for the CreateStream operation

func (CreateStreamResponse) HTTPResponse Uses

func (response CreateStreamResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (CreateStreamResponse) String Uses

func (response CreateStreamResponse) String() string

type Cursor Uses

type Cursor struct {

    // The cursor to pass to the `GetMessages` operation.
    Value *string `mandatory:"true" json:"value"`
}

Cursor A cursor that indicates the position in the stream from which you want to begin consuming messages and which is required by the GetMessages operation.

func (Cursor) String Uses

func (m Cursor) String() string

type CustomEncryptionKey Uses

type CustomEncryptionKey struct {

    // Custom Encryption Key (Master Key) ocid.
    KmsKeyId *string `mandatory:"false" json:"kmsKeyId"`

    // Life cycle State of the custom key
    KeyState CustomEncryptionKeyKeyStateEnum `mandatory:"false" json:"keyState,omitempty"`
}

CustomEncryptionKey Custom Encryption Key which will be used for encryption by all the streams in the pool.

func (CustomEncryptionKey) String Uses

func (m CustomEncryptionKey) String() string

type CustomEncryptionKeyDetails Uses

type CustomEncryptionKeyDetails struct {

    // Custom Encryption Key (Master Key) ocid.
    KmsKeyId *string `mandatory:"true" json:"kmsKeyId"`
}

CustomEncryptionKeyDetails The OCID of the custom encryption key to be used or deleted if currently being used.

func (CustomEncryptionKeyDetails) String Uses

func (m CustomEncryptionKeyDetails) String() string

type CustomEncryptionKeyKeyStateEnum Uses

type CustomEncryptionKeyKeyStateEnum string

CustomEncryptionKeyKeyStateEnum Enum with underlying type: string

const (
    CustomEncryptionKeyKeyStateActive   CustomEncryptionKeyKeyStateEnum = "ACTIVE"
    CustomEncryptionKeyKeyStateCreating CustomEncryptionKeyKeyStateEnum = "CREATING"
    CustomEncryptionKeyKeyStateDeleting CustomEncryptionKeyKeyStateEnum = "DELETING"
    CustomEncryptionKeyKeyStateNone     CustomEncryptionKeyKeyStateEnum = "NONE"
    CustomEncryptionKeyKeyStateFailed   CustomEncryptionKeyKeyStateEnum = "FAILED"
    CustomEncryptionKeyKeyStateUpdating CustomEncryptionKeyKeyStateEnum = "UPDATING"
)

Set of constants representing the allowable values for CustomEncryptionKeyKeyStateEnum

func GetCustomEncryptionKeyKeyStateEnumValues Uses

func GetCustomEncryptionKeyKeyStateEnumValues() []CustomEncryptionKeyKeyStateEnum

GetCustomEncryptionKeyKeyStateEnumValues Enumerates the set of values for CustomEncryptionKeyKeyStateEnum

type DeleteConnectHarnessRequest Uses

type DeleteConnectHarnessRequest struct {

    // The OCID of the connect harness.
    ConnectHarnessId *string `mandatory:"true" contributesTo:"path" name:"connectHarnessId"`

    // The unique Oracle-assigned identifier for the request. If you need to contact Oracle about a
    // particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // For optimistic concurrency control. In the PUT or DELETE call for a resource, set the if-match parameter to the value of the etag from a previous GET or POST response for that resource. The resource will be updated or deleted only if the etag you provide matches the resource's current etag value.
    IfMatch *string `mandatory:"false" contributesTo:"header" name:"if-match"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

DeleteConnectHarnessRequest wrapper for the DeleteConnectHarness operation

func (DeleteConnectHarnessRequest) HTTPRequest Uses

func (request DeleteConnectHarnessRequest) HTTPRequest(method, path string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (DeleteConnectHarnessRequest) RetryPolicy Uses

func (request DeleteConnectHarnessRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (DeleteConnectHarnessRequest) String Uses

func (request DeleteConnectHarnessRequest) String() string

type DeleteConnectHarnessResponse Uses

type DeleteConnectHarnessResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about
    // a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`
}

DeleteConnectHarnessResponse wrapper for the DeleteConnectHarness operation

func (DeleteConnectHarnessResponse) HTTPResponse Uses

func (response DeleteConnectHarnessResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (DeleteConnectHarnessResponse) String Uses

func (response DeleteConnectHarnessResponse) String() string

type DeleteStreamPoolRequest Uses

type DeleteStreamPoolRequest struct {

    // The OCID of the stream pool.
    StreamPoolId *string `mandatory:"true" contributesTo:"path" name:"streamPoolId"`

    // The unique Oracle-assigned identifier for the request. If you need to contact Oracle about a
    // particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // For optimistic concurrency control. In the PUT or DELETE call for a resource, set the if-match parameter to the value of the etag from a previous GET or POST response for that resource. The resource will be updated or deleted only if the etag you provide matches the resource's current etag value.
    IfMatch *string `mandatory:"false" contributesTo:"header" name:"if-match"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

DeleteStreamPoolRequest wrapper for the DeleteStreamPool operation

func (DeleteStreamPoolRequest) HTTPRequest Uses

func (request DeleteStreamPoolRequest) HTTPRequest(method, path string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (DeleteStreamPoolRequest) RetryPolicy Uses

func (request DeleteStreamPoolRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (DeleteStreamPoolRequest) String Uses

func (request DeleteStreamPoolRequest) String() string

type DeleteStreamPoolResponse Uses

type DeleteStreamPoolResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about
    // a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`
}

DeleteStreamPoolResponse wrapper for the DeleteStreamPool operation

func (DeleteStreamPoolResponse) HTTPResponse Uses

func (response DeleteStreamPoolResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (DeleteStreamPoolResponse) String Uses

func (response DeleteStreamPoolResponse) String() string

type DeleteStreamRequest Uses

type DeleteStreamRequest struct {

    // The OCID of the stream.
    StreamId *string `mandatory:"true" contributesTo:"path" name:"streamId"`

    // The unique Oracle-assigned identifier for the request. If you need to contact Oracle about a
    // particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // For optimistic concurrency control. In the PUT or DELETE call for a resource, set the if-match parameter to the value of the etag from a previous GET or POST response for that resource. The resource will be updated or deleted only if the etag you provide matches the resource's current etag value.
    IfMatch *string `mandatory:"false" contributesTo:"header" name:"if-match"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

DeleteStreamRequest wrapper for the DeleteStream operation

func (DeleteStreamRequest) HTTPRequest Uses

func (request DeleteStreamRequest) HTTPRequest(method, path string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (DeleteStreamRequest) RetryPolicy Uses

func (request DeleteStreamRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (DeleteStreamRequest) String Uses

func (request DeleteStreamRequest) String() string

type DeleteStreamResponse Uses

type DeleteStreamResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about
    // a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`
}

DeleteStreamResponse wrapper for the DeleteStream operation

func (DeleteStreamResponse) HTTPResponse Uses

func (response DeleteStreamResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (DeleteStreamResponse) String Uses

func (response DeleteStreamResponse) String() string

type GetConnectHarnessRequest Uses

type GetConnectHarnessRequest struct {

    // The OCID of the connect harness.
    ConnectHarnessId *string `mandatory:"true" contributesTo:"path" name:"connectHarnessId"`

    // The unique Oracle-assigned identifier for the request. If you need to contact Oracle about a
    // particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

GetConnectHarnessRequest wrapper for the GetConnectHarness operation

func (GetConnectHarnessRequest) HTTPRequest Uses

func (request GetConnectHarnessRequest) HTTPRequest(method, path string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (GetConnectHarnessRequest) RetryPolicy Uses

func (request GetConnectHarnessRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (GetConnectHarnessRequest) String Uses

func (request GetConnectHarnessRequest) String() string

type GetConnectHarnessResponse Uses

type GetConnectHarnessResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // The ConnectHarness instance
    ConnectHarness `presentIn:"body"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about
    // a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`

    // For optimistic concurrency control. See `if-match`.
    Etag *string `presentIn:"header" name:"etag"`
}

GetConnectHarnessResponse wrapper for the GetConnectHarness operation

func (GetConnectHarnessResponse) HTTPResponse Uses

func (response GetConnectHarnessResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (GetConnectHarnessResponse) String Uses

func (response GetConnectHarnessResponse) String() string

type GetGroupRequest Uses

type GetGroupRequest struct {

    // The OCID of the stream.
    StreamId *string `mandatory:"true" contributesTo:"path" name:"streamId"`

    // The name of the consumer group.
    GroupName *string `mandatory:"true" contributesTo:"path" name:"groupName"`

    // The unique Oracle-assigned identifier for the request. If you need to contact Oracle about a
    // particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

GetGroupRequest wrapper for the GetGroup operation

func (GetGroupRequest) HTTPRequest Uses

func (request GetGroupRequest) HTTPRequest(method, path string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (GetGroupRequest) RetryPolicy Uses

func (request GetGroupRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (GetGroupRequest) String Uses

func (request GetGroupRequest) String() string

type GetGroupResponse Uses

type GetGroupResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // The Group instance
    Group `presentIn:"body"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about
    // a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`
}

GetGroupResponse wrapper for the GetGroup operation

func (GetGroupResponse) HTTPResponse Uses

func (response GetGroupResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (GetGroupResponse) String Uses

func (response GetGroupResponse) String() string

type GetMessagesRequest Uses

type GetMessagesRequest struct {

    // The OCID of the stream.
    StreamId *string `mandatory:"true" contributesTo:"path" name:"streamId"`

    // The cursor used to consume the stream.
    Cursor *string `mandatory:"true" contributesTo:"query" name:"cursor"`

    // The maximum number of messages to return. You can specify any value up to 10000. By default, the service returns as many messages as possible.
    // Consider your average message size to help avoid exceeding throughput on the stream.
    Limit *int `mandatory:"false" contributesTo:"query" name:"limit"`

    // The unique Oracle-assigned identifier for the request. If you need to contact Oracle about a
    // particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

GetMessagesRequest wrapper for the GetMessages operation

func (GetMessagesRequest) HTTPRequest Uses

func (request GetMessagesRequest) HTTPRequest(method, path string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (GetMessagesRequest) RetryPolicy Uses

func (request GetMessagesRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (GetMessagesRequest) String Uses

func (request GetMessagesRequest) String() string

type GetMessagesResponse Uses

type GetMessagesResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // The []Message instance
    Items []Message `presentIn:"body"`

    // The cursor to use to get the next batch of messages.
    OpcNextCursor *string `presentIn:"header" name:"opc-next-cursor"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about
    // a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`
}

GetMessagesResponse wrapper for the GetMessages operation

func (GetMessagesResponse) HTTPResponse Uses

func (response GetMessagesResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (GetMessagesResponse) String Uses

func (response GetMessagesResponse) String() string

type GetStreamPoolRequest Uses

type GetStreamPoolRequest struct {

    // The OCID of the stream pool.
    StreamPoolId *string `mandatory:"true" contributesTo:"path" name:"streamPoolId"`

    // The unique Oracle-assigned identifier for the request. If you need to contact Oracle about a
    // particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

GetStreamPoolRequest wrapper for the GetStreamPool operation

func (GetStreamPoolRequest) HTTPRequest Uses

func (request GetStreamPoolRequest) HTTPRequest(method, path string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (GetStreamPoolRequest) RetryPolicy Uses

func (request GetStreamPoolRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (GetStreamPoolRequest) String Uses

func (request GetStreamPoolRequest) String() string

type GetStreamPoolResponse Uses

type GetStreamPoolResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // The StreamPool instance
    StreamPool `presentIn:"body"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about
    // a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`

    // For optimistic concurrency control. See `if-match`.
    Etag *string `presentIn:"header" name:"etag"`
}

GetStreamPoolResponse wrapper for the GetStreamPool operation

func (GetStreamPoolResponse) HTTPResponse Uses

func (response GetStreamPoolResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (GetStreamPoolResponse) String Uses

func (response GetStreamPoolResponse) String() string

type GetStreamRequest Uses

type GetStreamRequest struct {

    // The OCID of the stream.
    StreamId *string `mandatory:"true" contributesTo:"path" name:"streamId"`

    // The unique Oracle-assigned identifier for the request. If you need to contact Oracle about a
    // particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

GetStreamRequest wrapper for the GetStream operation

func (GetStreamRequest) HTTPRequest Uses

func (request GetStreamRequest) HTTPRequest(method, path string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (GetStreamRequest) RetryPolicy Uses

func (request GetStreamRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (GetStreamRequest) String Uses

func (request GetStreamRequest) String() string

type GetStreamResponse Uses

type GetStreamResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // The Stream instance
    Stream `presentIn:"body"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about
    // a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`

    // For optimistic concurrency control. See `if-match`.
    Etag *string `presentIn:"header" name:"etag"`
}

GetStreamResponse wrapper for the GetStream operation

func (GetStreamResponse) HTTPResponse Uses

func (response GetStreamResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (GetStreamResponse) String Uses

func (response GetStreamResponse) String() string

type Group Uses

type Group struct {

    // The streamId for which the group exists.
    StreamId *string `mandatory:"true" json:"streamId"`

    // The name of the consumer group.
    GroupName *string `mandatory:"true" json:"groupName"`

    // An array of the partition reservations of a group.
    Reservations []PartitionReservation `mandatory:"false" json:"reservations"`
}

Group Represents the current state of a consumer group, including partition reservations and committed offsets.

func (Group) String Uses

func (m Group) String() string

type KafkaSettings Uses

type KafkaSettings struct {

    // Bootstrap servers.
    BootstrapServers *string `mandatory:"false" json:"bootstrapServers"`

    // Enable auto creation of topic on the server.
    AutoCreateTopicsEnable *bool `mandatory:"false" json:"autoCreateTopicsEnable"`

    // The number of hours to keep a log file before deleting it (in hours).
    LogRetentionHours *int `mandatory:"false" json:"logRetentionHours"`

    // The default number of log partitions per topic.
    NumPartitions *int `mandatory:"false" json:"numPartitions"`
}

KafkaSettings Settings for the Kafka compatibility layer.

func (KafkaSettings) String Uses

func (m KafkaSettings) String() string

type ListConnectHarnessesRequest Uses

type ListConnectHarnessesRequest struct {

    // The OCID of the compartment.
    CompartmentId *string `mandatory:"true" contributesTo:"query" name:"compartmentId"`

    // A filter to return only resources that match the given ID exactly.
    Id  *string `mandatory:"false" contributesTo:"query" name:"id"`

    // A filter to return only resources that match the given name exactly.
    Name *string `mandatory:"false" contributesTo:"query" name:"name"`

    // The maximum number of items to return. The value must be between 1 and 50. The default is 10.
    Limit *int `mandatory:"false" contributesTo:"query" name:"limit"`

    // The page at which to start retrieving results.
    Page *string `mandatory:"false" contributesTo:"query" name:"page"`

    // The field to sort by. You can provide no more than one sort order. By default, `TIMECREATED` sorts results in descending order and `NAME` sorts results in ascending order.
    SortBy ListConnectHarnessesSortByEnum `mandatory:"false" contributesTo:"query" name:"sortBy" omitEmpty:"true"`

    // The sort order to use, either 'asc' or 'desc'.
    SortOrder ListConnectHarnessesSortOrderEnum `mandatory:"false" contributesTo:"query" name:"sortOrder" omitEmpty:"true"`

    // A filter to only return resources that match the given lifecycle state. The state value is case-insensitive.
    LifecycleState ConnectHarnessSummaryLifecycleStateEnum `mandatory:"false" contributesTo:"query" name:"lifecycleState" omitEmpty:"true"`

    // The unique Oracle-assigned identifier for the request. If you need to contact Oracle about a
    // particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

ListConnectHarnessesRequest wrapper for the ListConnectHarnesses operation

func (ListConnectHarnessesRequest) HTTPRequest Uses

func (request ListConnectHarnessesRequest) HTTPRequest(method, path string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (ListConnectHarnessesRequest) RetryPolicy Uses

func (request ListConnectHarnessesRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (ListConnectHarnessesRequest) String Uses

func (request ListConnectHarnessesRequest) String() string

type ListConnectHarnessesResponse Uses

type ListConnectHarnessesResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // A list of []ConnectHarnessSummary instances
    Items []ConnectHarnessSummary `presentIn:"body"`

    // For list pagination. When this header appears in the response, additional pages of results remain. For important details about how pagination works, see List Pagination (https://docs.cloud.oracle.com/iaas/Content/API/Concepts/usingapi.htm#nine).
    OpcNextPage *string `presentIn:"header" name:"opc-next-page"`

    // For list pagination. When this header appears in the response, previous pages of results exist. For important details about how pagination works, see List Pagination (https://docs.cloud.oracle.com/iaas/Content/API/Concepts/usingapi.htm#nine).
    OpcPrevPage *string `presentIn:"header" name:"opc-prev-page"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about
    // a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`
}

ListConnectHarnessesResponse wrapper for the ListConnectHarnesses operation

func (ListConnectHarnessesResponse) HTTPResponse Uses

func (response ListConnectHarnessesResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (ListConnectHarnessesResponse) String Uses

func (response ListConnectHarnessesResponse) String() string

type ListConnectHarnessesSortByEnum Uses

type ListConnectHarnessesSortByEnum string

ListConnectHarnessesSortByEnum Enum with underlying type: string

const (
    ListConnectHarnessesSortByName        ListConnectHarnessesSortByEnum = "NAME"
    ListConnectHarnessesSortByTimecreated ListConnectHarnessesSortByEnum = "TIMECREATED"
)

Set of constants representing the allowable values for ListConnectHarnessesSortByEnum

func GetListConnectHarnessesSortByEnumValues Uses

func GetListConnectHarnessesSortByEnumValues() []ListConnectHarnessesSortByEnum

GetListConnectHarnessesSortByEnumValues Enumerates the set of values for ListConnectHarnessesSortByEnum

type ListConnectHarnessesSortOrderEnum Uses

type ListConnectHarnessesSortOrderEnum string

ListConnectHarnessesSortOrderEnum Enum with underlying type: string

const (
    ListConnectHarnessesSortOrderAsc  ListConnectHarnessesSortOrderEnum = "ASC"
    ListConnectHarnessesSortOrderDesc ListConnectHarnessesSortOrderEnum = "DESC"
)

Set of constants representing the allowable values for ListConnectHarnessesSortOrderEnum

func GetListConnectHarnessesSortOrderEnumValues Uses

func GetListConnectHarnessesSortOrderEnumValues() []ListConnectHarnessesSortOrderEnum

GetListConnectHarnessesSortOrderEnumValues Enumerates the set of values for ListConnectHarnessesSortOrderEnum

type ListStreamPoolsRequest Uses

type ListStreamPoolsRequest struct {

    // The OCID of the compartment.
    CompartmentId *string `mandatory:"true" contributesTo:"query" name:"compartmentId"`

    // A filter to return only resources that match the given ID exactly.
    Id  *string `mandatory:"false" contributesTo:"query" name:"id"`

    // A filter to return only resources that match the given name exactly.
    Name *string `mandatory:"false" contributesTo:"query" name:"name"`

    // The maximum number of items to return. The value must be between 1 and 50. The default is 10.
    Limit *int `mandatory:"false" contributesTo:"query" name:"limit"`

    // The page at which to start retrieving results.
    Page *string `mandatory:"false" contributesTo:"query" name:"page"`

    // The field to sort by. You can provide no more than one sort order. By default, `TIMECREATED` sorts results in descending order and `NAME` sorts results in ascending order.
    SortBy ListStreamPoolsSortByEnum `mandatory:"false" contributesTo:"query" name:"sortBy" omitEmpty:"true"`

    // The sort order to use, either 'asc' or 'desc'.
    SortOrder ListStreamPoolsSortOrderEnum `mandatory:"false" contributesTo:"query" name:"sortOrder" omitEmpty:"true"`

    // A filter to only return resources that match the given lifecycle state. The state value is case-insensitive.
    LifecycleState StreamPoolSummaryLifecycleStateEnum `mandatory:"false" contributesTo:"query" name:"lifecycleState" omitEmpty:"true"`

    // The unique Oracle-assigned identifier for the request. If you need to contact Oracle about a
    // particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

ListStreamPoolsRequest wrapper for the ListStreamPools operation

func (ListStreamPoolsRequest) HTTPRequest Uses

func (request ListStreamPoolsRequest) HTTPRequest(method, path string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (ListStreamPoolsRequest) RetryPolicy Uses

func (request ListStreamPoolsRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (ListStreamPoolsRequest) String Uses

func (request ListStreamPoolsRequest) String() string

type ListStreamPoolsResponse Uses

type ListStreamPoolsResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // A list of []StreamPoolSummary instances
    Items []StreamPoolSummary `presentIn:"body"`

    // For list pagination. When this header appears in the response, additional pages of results remain. For important details about how pagination works, see List Pagination (https://docs.cloud.oracle.com/iaas/Content/API/Concepts/usingapi.htm#nine).
    OpcNextPage *string `presentIn:"header" name:"opc-next-page"`

    // For list pagination. When this header appears in the response, previous pages of results exist. For important details about how pagination works, see List Pagination (https://docs.cloud.oracle.com/iaas/Content/API/Concepts/usingapi.htm#nine).
    OpcPrevPage *string `presentIn:"header" name:"opc-prev-page"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about
    // a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`
}

ListStreamPoolsResponse wrapper for the ListStreamPools operation

func (ListStreamPoolsResponse) HTTPResponse Uses

func (response ListStreamPoolsResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (ListStreamPoolsResponse) String Uses

func (response ListStreamPoolsResponse) String() string

type ListStreamPoolsSortByEnum Uses

type ListStreamPoolsSortByEnum string

ListStreamPoolsSortByEnum Enum with underlying type: string

const (
    ListStreamPoolsSortByName        ListStreamPoolsSortByEnum = "NAME"
    ListStreamPoolsSortByTimecreated ListStreamPoolsSortByEnum = "TIMECREATED"
)

Set of constants representing the allowable values for ListStreamPoolsSortByEnum

func GetListStreamPoolsSortByEnumValues Uses

func GetListStreamPoolsSortByEnumValues() []ListStreamPoolsSortByEnum

GetListStreamPoolsSortByEnumValues Enumerates the set of values for ListStreamPoolsSortByEnum

type ListStreamPoolsSortOrderEnum Uses

type ListStreamPoolsSortOrderEnum string

ListStreamPoolsSortOrderEnum Enum with underlying type: string

const (
    ListStreamPoolsSortOrderAsc  ListStreamPoolsSortOrderEnum = "ASC"
    ListStreamPoolsSortOrderDesc ListStreamPoolsSortOrderEnum = "DESC"
)

Set of constants representing the allowable values for ListStreamPoolsSortOrderEnum

func GetListStreamPoolsSortOrderEnumValues Uses

func GetListStreamPoolsSortOrderEnumValues() []ListStreamPoolsSortOrderEnum

GetListStreamPoolsSortOrderEnumValues Enumerates the set of values for ListStreamPoolsSortOrderEnum

type ListStreamsRequest Uses

type ListStreamsRequest struct {

    // The OCID of the compartment. Is exclusive with the `streamPoolId` parameter. One of them is required.
    CompartmentId *string `mandatory:"false" contributesTo:"query" name:"compartmentId"`

    // The OCID of the stream pool. Is exclusive with the `compartmentId` parameter. One of them is required.
    StreamPoolId *string `mandatory:"false" contributesTo:"query" name:"streamPoolId"`

    // A filter to return only resources that match the given ID exactly.
    Id  *string `mandatory:"false" contributesTo:"query" name:"id"`

    // A filter to return only resources that match the given name exactly.
    Name *string `mandatory:"false" contributesTo:"query" name:"name"`

    // The maximum number of items to return. The value must be between 1 and 50. The default is 10.
    Limit *int `mandatory:"false" contributesTo:"query" name:"limit"`

    // The page at which to start retrieving results.
    Page *string `mandatory:"false" contributesTo:"query" name:"page"`

    // The field to sort by. You can provide no more than one sort order. By default, `TIMECREATED` sorts results in descending order and `NAME` sorts results in ascending order.
    SortBy ListStreamsSortByEnum `mandatory:"false" contributesTo:"query" name:"sortBy" omitEmpty:"true"`

    // The sort order to use, either 'asc' or 'desc'.
    SortOrder ListStreamsSortOrderEnum `mandatory:"false" contributesTo:"query" name:"sortOrder" omitEmpty:"true"`

    // A filter to only return resources that match the given lifecycle state. The state value is case-insensitive.
    LifecycleState StreamLifecycleStateEnum `mandatory:"false" contributesTo:"query" name:"lifecycleState" omitEmpty:"true"`

    // The unique Oracle-assigned identifier for the request. If you need to contact Oracle about a
    // particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

ListStreamsRequest wrapper for the ListStreams operation

func (ListStreamsRequest) HTTPRequest Uses

func (request ListStreamsRequest) HTTPRequest(method, path string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (ListStreamsRequest) RetryPolicy Uses

func (request ListStreamsRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (ListStreamsRequest) String Uses

func (request ListStreamsRequest) String() string

type ListStreamsResponse Uses

type ListStreamsResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // A list of []StreamSummary instances
    Items []StreamSummary `presentIn:"body"`

    // For list pagination. When this header appears in the response, additional pages of results remain. For important details about how pagination works, see List Pagination (https://docs.cloud.oracle.com/iaas/Content/API/Concepts/usingapi.htm#nine).
    OpcNextPage *string `presentIn:"header" name:"opc-next-page"`

    // For list pagination. When this header appears in the response, previous pages of results exist. For important details about how pagination works, see List Pagination (https://docs.cloud.oracle.com/iaas/Content/API/Concepts/usingapi.htm#nine).
    OpcPrevPage *string `presentIn:"header" name:"opc-prev-page"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about
    // a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`
}

ListStreamsResponse wrapper for the ListStreams operation

func (ListStreamsResponse) HTTPResponse Uses

func (response ListStreamsResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (ListStreamsResponse) String Uses

func (response ListStreamsResponse) String() string

type ListStreamsSortByEnum Uses

type ListStreamsSortByEnum string

ListStreamsSortByEnum Enum with underlying type: string

const (
    ListStreamsSortByName        ListStreamsSortByEnum = "NAME"
    ListStreamsSortByTimecreated ListStreamsSortByEnum = "TIMECREATED"
)

Set of constants representing the allowable values for ListStreamsSortByEnum

func GetListStreamsSortByEnumValues Uses

func GetListStreamsSortByEnumValues() []ListStreamsSortByEnum

GetListStreamsSortByEnumValues Enumerates the set of values for ListStreamsSortByEnum

type ListStreamsSortOrderEnum Uses

type ListStreamsSortOrderEnum string

ListStreamsSortOrderEnum Enum with underlying type: string

const (
    ListStreamsSortOrderAsc  ListStreamsSortOrderEnum = "ASC"
    ListStreamsSortOrderDesc ListStreamsSortOrderEnum = "DESC"
)

Set of constants representing the allowable values for ListStreamsSortOrderEnum

func GetListStreamsSortOrderEnumValues Uses

func GetListStreamsSortOrderEnumValues() []ListStreamsSortOrderEnum

GetListStreamsSortOrderEnumValues Enumerates the set of values for ListStreamsSortOrderEnum

type Message Uses

type Message struct {

    // The name of the stream that the message belongs to.
    Stream *string `mandatory:"true" json:"stream"`

    // The ID of the partition where the message is stored.
    Partition *string `mandatory:"true" json:"partition"`

    // The key associated with the message, expressed as a byte array.
    Key []byte `mandatory:"true" json:"key"`

    // The value associated with the message, expressed as a byte array.
    Value []byte `mandatory:"true" json:"value"`

    // The offset of the message, which uniquely identifies it within the partition.
    Offset *int64 `mandatory:"true" json:"offset"`

    // The timestamp indicating when the server appended the message to the stream.
    Timestamp *common.SDKTime `mandatory:"true" json:"timestamp"`
}

Message A message in a stream.

func (Message) String Uses

func (m Message) String() string

type PartitionReservation Uses

type PartitionReservation struct {

    // The partition for which the reservation applies.
    Partition *string `mandatory:"false" json:"partition"`

    // The latest offset which has been committed for this partition.
    CommittedOffset *int64 `mandatory:"false" json:"committedOffset"`

    // The consumer instance which currently has the partition reserved.
    ReservedInstance *string `mandatory:"false" json:"reservedInstance"`

    // A timestamp when the current reservation expires.
    TimeReservedUntil *common.SDKTime `mandatory:"false" json:"timeReservedUntil"`
}

PartitionReservation Represents the state of a single partition reservation.

func (PartitionReservation) String Uses

func (m PartitionReservation) String() string

type PrivateEndpointDetails Uses

type PrivateEndpointDetails struct {

    // If specified, the stream pool will be private and only accessible from inside that subnet.
    // Producing-to and consuming-from a stream inside a private stream pool can also only be done from inside the subnet.
    // That value cannot be changed.
    SubnetId *string `mandatory:"false" json:"subnetId"`

    // The optional private IP you want to be associated with your private stream pool.
    // That parameter can only be specified when the subnetId parameter is set. It cannot be changed.
    // The private IP needs to be part of the CIDR range of the specified subnetId or the creation will fail.
    // If not specified a random IP inside the subnet will be chosen.
    // After the stream pool is created, a custom FQDN, pointing to this private IP, is created.
    // The FQDN is then used to access the service instead of the private IP.
    PrivateEndpointIp *string `mandatory:"false" json:"privateEndpointIp"`

    // The optional list of network security groups to be used with the private endpoint of the stream pool.
    // That value cannot be changed.
    NsgIds []string `mandatory:"false" json:"nsgIds"`
}

PrivateEndpointDetails Optional parameters if a private stream pool is requested.

func (PrivateEndpointDetails) String Uses

func (m PrivateEndpointDetails) String() string

type PrivateEndpointSettings Uses

type PrivateEndpointSettings struct {

    // The subnet id from which the private stream pool can be accessed.
    // Trying to access the streams from another network location will result in an error.
    SubnetId *string `mandatory:"false" json:"subnetId"`

    // The private IP associated with the stream pool in the associated subnetId.
    // The stream pool's FQDN resolves to that IP and should be used - instead of the private IP - in order to not trigger any TLS issues.
    PrivateEndpointIp *string `mandatory:"false" json:"privateEndpointIp"`

    // The optional list of network security groups that are associated with the private endpoint of the stream pool.
    NsgIds []string `mandatory:"false" json:"nsgIds"`
}

PrivateEndpointSettings Optional settings if the stream pool is private.

func (PrivateEndpointSettings) String Uses

func (m PrivateEndpointSettings) String() string

type PutMessagesDetails Uses

type PutMessagesDetails struct {

    // The array of messages to put into a stream.
    Messages []PutMessagesDetailsEntry `mandatory:"true" json:"messages"`
}

PutMessagesDetails Object that represents an array of messages to emit to a stream.

func (PutMessagesDetails) String Uses

func (m PutMessagesDetails) String() string

type PutMessagesDetailsEntry Uses

type PutMessagesDetailsEntry struct {

    // The message, expressed as a byte array up to 1 MiB in size.
    Value []byte `mandatory:"true" json:"value"`

    // The key of the message, expressed as a byte array up to 256 bytes in size. Messages with the same key are stored in the same partition.
    Key []byte `mandatory:"false" json:"key"`
}

PutMessagesDetailsEntry Object that represents a message to emit to a stream.

func (PutMessagesDetailsEntry) String Uses

func (m PutMessagesDetailsEntry) String() string

type PutMessagesRequest Uses

type PutMessagesRequest struct {

    // The OCID of the stream.
    StreamId *string `mandatory:"true" contributesTo:"path" name:"streamId"`

    // Array of messages to put into the stream.
    PutMessagesDetails `contributesTo:"body"`

    // The unique Oracle-assigned identifier for the request. If you need to contact Oracle about a
    // particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

PutMessagesRequest wrapper for the PutMessages operation

func (PutMessagesRequest) HTTPRequest Uses

func (request PutMessagesRequest) HTTPRequest(method, path string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (PutMessagesRequest) RetryPolicy Uses

func (request PutMessagesRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (PutMessagesRequest) String Uses

func (request PutMessagesRequest) String() string

type PutMessagesResponse Uses

type PutMessagesResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // The PutMessagesResult instance
    PutMessagesResult `presentIn:"body"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about
    // a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`
}

PutMessagesResponse wrapper for the PutMessages operation

func (PutMessagesResponse) HTTPResponse Uses

func (response PutMessagesResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (PutMessagesResponse) String Uses

func (response PutMessagesResponse) String() string

type PutMessagesResult Uses

type PutMessagesResult struct {

    // The number of messages that failed to be added to the stream.
    Failures *int `mandatory:"true" json:"failures"`

    // An array of items representing the result of each message.
    // The order is guaranteed to be the same as in the `PutMessagesDetails` object.
    // If a message was successfully appended to the stream, the entry includes the `offset`, `partition`, and `timestamp`.
    // If a message failed to be appended to the stream, the entry includes the `error` and `errorMessage`.
    Entries []PutMessagesResultEntry `mandatory:"true" json:"entries"`
}

PutMessagesResult The response to a PutMessages request. It indicates the number of failed messages as well as an array of results for successful and failed messages.

func (PutMessagesResult) String Uses

func (m PutMessagesResult) String() string

type PutMessagesResultEntry Uses

type PutMessagesResultEntry struct {

    // The ID of the partition where the message was stored.
    Partition *string `mandatory:"false" json:"partition"`

    // The offset of the message in the partition.
    Offset *int64 `mandatory:"false" json:"offset"`

    // The timestamp indicating when the server appended the message to the stream.
    Timestamp *common.SDKTime `mandatory:"false" json:"timestamp"`

    // The error code, in case the message was not successfully appended to the stream.
    Error *string `mandatory:"false" json:"error"`

    // A human-readable error message associated with the error code.
    ErrorMessage *string `mandatory:"false" json:"errorMessage"`
}

PutMessagesResultEntry Represents the result of a PutMessages request, whether it was successful or not. If a message was successfully appended to the stream, the entry includes the `offset`, `partition`, and `timestamp`. If the message failed to be appended to the stream, the entry includes the `error` and `errorMessage`.

func (PutMessagesResultEntry) String Uses

func (m PutMessagesResultEntry) String() string

type Stream Uses

type Stream struct {

    // The name of the stream. Avoid entering confidential information.
    // Example: `TelemetryEvents`
    Name *string `mandatory:"true" json:"name"`

    // The OCID of the stream.
    Id  *string `mandatory:"true" json:"id"`

    // The number of partitions in the stream.
    Partitions *int `mandatory:"true" json:"partitions"`

    // The retention period of the stream, in hours. This property is read-only.
    RetentionInHours *int `mandatory:"true" json:"retentionInHours"`

    // The OCID of the stream.
    CompartmentId *string `mandatory:"true" json:"compartmentId"`

    // The OCID of the stream pool that contains the stream.
    StreamPoolId *string `mandatory:"true" json:"streamPoolId"`

    // The current state of the stream.
    LifecycleState StreamLifecycleStateEnum `mandatory:"true" json:"lifecycleState"`

    // The date and time the stream was created, expressed in in RFC 3339 (https://tools.ietf.org/rfc/rfc3339) timestamp format.
    // Example: `2018-04-20T00:00:07.405Z`
    TimeCreated *common.SDKTime `mandatory:"true" json:"timeCreated"`

    // The endpoint to use when creating the StreamClient to consume or publish messages in the stream.
    // If the associated stream pool is private, the endpoint is also private and can only be accessed from inside the stream pool's associated subnet.
    MessagesEndpoint *string `mandatory:"true" json:"messagesEndpoint"`

    // Any additional details about the current state of the stream.
    LifecycleStateDetails *string `mandatory:"false" json:"lifecycleStateDetails"`

    // Free-form tags for this resource. Each tag is a simple key-value pair with no predefined name, type, or namespace. Exists for cross-compatibility only.
    // For more information, see Resource Tags (https://docs.cloud.oracle.com/Content/General/Concepts/resourcetags.htm).
    // Example: `{"Department": "Finance"}`
    FreeformTags map[string]string `mandatory:"false" json:"freeformTags"`

    // Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see Resource Tags (https://docs.cloud.oracle.com/Content/General/Concepts/resourcetags.htm).
    // Example: `{"Operations": {"CostCenter": "42"}}'
    DefinedTags map[string]map[string]interface{} `mandatory:"false" json:"definedTags"`
}

Stream Detailed representation of a stream, including all its partitions.

func (Stream) String Uses

func (m Stream) String() string

type StreamAdminClient Uses

type StreamAdminClient struct {
    common.BaseClient
    // contains filtered or unexported fields
}

StreamAdminClient a client for StreamAdmin

func NewStreamAdminClientWithConfigurationProvider Uses

func NewStreamAdminClientWithConfigurationProvider(configProvider common.ConfigurationProvider) (client StreamAdminClient, err error)

NewStreamAdminClientWithConfigurationProvider Creates a new default StreamAdmin client with the given configuration provider. the configuration provider will be used for the default signer as well as reading the region

func NewStreamAdminClientWithOboToken Uses

func NewStreamAdminClientWithOboToken(configProvider common.ConfigurationProvider, oboToken string) (client StreamAdminClient, err error)

NewStreamAdminClientWithOboToken Creates a new default StreamAdmin client with the given configuration provider. The obotoken will be added to default headers and signed; the configuration provider will be used for the signer

as well as reading the region

func (StreamAdminClient) ChangeConnectHarnessCompartment Uses

func (client StreamAdminClient) ChangeConnectHarnessCompartment(ctx context.Context, request ChangeConnectHarnessCompartmentRequest) (response ChangeConnectHarnessCompartmentResponse, err error)

ChangeConnectHarnessCompartment Moves a resource into a different compartment. When provided, If-Match is checked against ETag values of the resource.

func (StreamAdminClient) ChangeStreamCompartment Uses

func (client StreamAdminClient) ChangeStreamCompartment(ctx context.Context, request ChangeStreamCompartmentRequest) (response ChangeStreamCompartmentResponse, err error)

ChangeStreamCompartment Moves a resource into a different compartment. When provided, If-Match is checked against ETag values of the resource. The stream will also be moved into the default stream pool in the destination compartment.

func (StreamAdminClient) ChangeStreamPoolCompartment Uses

func (client StreamAdminClient) ChangeStreamPoolCompartment(ctx context.Context, request ChangeStreamPoolCompartmentRequest) (response ChangeStreamPoolCompartmentResponse, err error)

ChangeStreamPoolCompartment Moves a resource into a different compartment. When provided, If-Match is checked against ETag values of the resource.

func (*StreamAdminClient) ConfigurationProvider Uses

func (client *StreamAdminClient) ConfigurationProvider() *common.ConfigurationProvider

ConfigurationProvider the ConfigurationProvider used in this client, or null if none set

func (StreamAdminClient) CreateConnectHarness Uses

func (client StreamAdminClient) CreateConnectHarness(ctx context.Context, request CreateConnectHarnessRequest) (response CreateConnectHarnessResponse, err error)

CreateConnectHarness Starts the provisioning of a new connect harness. To track the progress of the provisioning, you can periodically call ConnectHarness object tells you its current state.

func (StreamAdminClient) CreateStream Uses

func (client StreamAdminClient) CreateStream(ctx context.Context, request CreateStreamRequest) (response CreateStreamResponse, err error)

CreateStream Starts the provisioning of a new stream. The stream will be created in the given compartment id or stream pool id, depending on which parameter is specified. Compartment id and stream pool id cannot be specified at the same time. To track the progress of the provisioning, you can periodically call GetStream. In the response, the `lifecycleState` parameter of the Stream object tells you its current state.

func (StreamAdminClient) CreateStreamPool Uses

func (client StreamAdminClient) CreateStreamPool(ctx context.Context, request CreateStreamPoolRequest) (response CreateStreamPoolResponse, err error)

CreateStreamPool Starts the provisioning of a new stream pool. To track the progress of the provisioning, you can periodically call GetStreamPool. In the response, the `lifecycleState` parameter of the object tells you its current state.

func (StreamAdminClient) DeleteConnectHarness Uses

func (client StreamAdminClient) DeleteConnectHarness(ctx context.Context, request DeleteConnectHarnessRequest) (response DeleteConnectHarnessResponse, err error)

DeleteConnectHarness Deletes a connect harness and its content. Connect harness contents are deleted immediately. The service retains records of the connect harness itself for 90 days after deletion. The `lifecycleState` parameter of the `ConnectHarness` object changes to `DELETING` and the connect harness becomes inaccessible for read or write operations. To verify that a connect harness has been deleted, make a GetConnectHarness request. If the call returns the connect harness's lifecycle state as `DELETED`, then the connect harness has been deleted. If the call returns a "404 Not Found" error, that means all records of the connect harness have been deleted.

func (StreamAdminClient) DeleteStream Uses

func (client StreamAdminClient) DeleteStream(ctx context.Context, request DeleteStreamRequest) (response DeleteStreamResponse, err error)

DeleteStream Deletes a stream and its content. Stream contents are deleted immediately. The service retains records of the stream itself for 90 days after deletion. The `lifecycleState` parameter of the `Stream` object changes to `DELETING` and the stream becomes inaccessible for read or write operations. To verify that a stream has been deleted, make a GetStream request. If the call returns the stream's lifecycle state as `DELETED`, then the stream has been deleted. If the call returns a "404 Not Found" error, that means all records of the stream have been deleted.

func (StreamAdminClient) DeleteStreamPool Uses

func (client StreamAdminClient) DeleteStreamPool(ctx context.Context, request DeleteStreamPoolRequest) (response DeleteStreamPoolResponse, err error)

DeleteStreamPool Deletes a stream pool. All containing streams will also be deleted. The default stream pool of a compartment cannot be deleted.

func (StreamAdminClient) GetConnectHarness Uses

func (client StreamAdminClient) GetConnectHarness(ctx context.Context, request GetConnectHarnessRequest) (response GetConnectHarnessResponse, err error)

GetConnectHarness Gets detailed information about a connect harness.

func (StreamAdminClient) GetStream Uses

func (client StreamAdminClient) GetStream(ctx context.Context, request GetStreamRequest) (response GetStreamResponse, err error)

GetStream Gets detailed information about a stream, including the number of partitions.

func (StreamAdminClient) GetStreamPool Uses

func (client StreamAdminClient) GetStreamPool(ctx context.Context, request GetStreamPoolRequest) (response GetStreamPoolResponse, err error)

GetStreamPool Gets detailed information about the stream pool, such as Kafka settings.

func (StreamAdminClient) ListConnectHarnesses Uses

func (client StreamAdminClient) ListConnectHarnesses(ctx context.Context, request ListConnectHarnessesRequest) (response ListConnectHarnessesResponse, err error)

ListConnectHarnesses Lists the connectharness.

func (StreamAdminClient) ListStreamPools Uses

func (client StreamAdminClient) ListStreamPools(ctx context.Context, request ListStreamPoolsRequest) (response ListStreamPoolsResponse, err error)

ListStreamPools List the stream pools for a given compartment ID.

func (StreamAdminClient) ListStreams Uses

func (client StreamAdminClient) ListStreams(ctx context.Context, request ListStreamsRequest) (response ListStreamsResponse, err error)

ListStreams Lists the streams in the given compartment id. If the compartment id is specified, it will list streams in the compartment, regardless of their stream pool. If the stream pool id is specified, the action will be scoped to that stream pool. The compartment id and stream pool id cannot be specified at the same time.

func (*StreamAdminClient) SetRegion Uses

func (client *StreamAdminClient) SetRegion(region string)

SetRegion overrides the region of this client.

func (StreamAdminClient) UpdateConnectHarness Uses

func (client StreamAdminClient) UpdateConnectHarness(ctx context.Context, request UpdateConnectHarnessRequest) (response UpdateConnectHarnessResponse, err error)

UpdateConnectHarness Updates the tags applied to the connect harness.

func (StreamAdminClient) UpdateStream Uses

func (client StreamAdminClient) UpdateStream(ctx context.Context, request UpdateStreamRequest) (response UpdateStreamResponse, err error)

UpdateStream Updates the stream. Only specified values will be updated.

func (StreamAdminClient) UpdateStreamPool Uses

func (client StreamAdminClient) UpdateStreamPool(ctx context.Context, request UpdateStreamPoolRequest) (response UpdateStreamPoolResponse, err error)

UpdateStreamPool Updates the specified stream pool.

type StreamClient Uses

type StreamClient struct {
    common.BaseClient
    // contains filtered or unexported fields
}

StreamClient a client for Stream

func NewStreamClientWithConfigurationProvider Uses

func NewStreamClientWithConfigurationProvider(configProvider common.ConfigurationProvider, endpoint string) (client StreamClient, err error)

NewStreamClientWithConfigurationProvider Creates a new default Stream client with the given configuration provider. the configuration provider will be used for the default signer

func NewStreamClientWithOboToken Uses

func NewStreamClientWithOboToken(configProvider common.ConfigurationProvider, oboToken string, endpoint string) (client StreamClient, err error)

NewStreamClientWithOboToken Creates a new default Stream client with the given configuration provider. The obotoken will be added to default headers and signed; the configuration provider will be used for the signer

func (*StreamClient) ConfigurationProvider Uses

func (client *StreamClient) ConfigurationProvider() *common.ConfigurationProvider

ConfigurationProvider the ConfigurationProvider used in this client, or null if none set

func (StreamClient) ConsumerCommit Uses

func (client StreamClient) ConsumerCommit(ctx context.Context, request ConsumerCommitRequest) (response ConsumerCommitResponse, err error)

ConsumerCommit Provides a mechanism to manually commit offsets, if not using commit-on-get consumer semantics. This commits offsets assicated with the provided cursor, extends the timeout on each of the affected partitions, and returns an updated cursor.

func (StreamClient) ConsumerHeartbeat Uses

func (client StreamClient) ConsumerHeartbeat(ctx context.Context, request ConsumerHeartbeatRequest) (response ConsumerHeartbeatResponse, err error)

ConsumerHeartbeat Allows long-running processes to extend the timeout on partitions reserved by a consumer instance.

func (StreamClient) CreateCursor Uses

func (client StreamClient) CreateCursor(ctx context.Context, request CreateCursorRequest) (response CreateCursorResponse, err error)

CreateCursor Creates a cursor. Cursors are used to consume a stream, starting from a specific point in the partition and going forward from there. You can create a cursor based on an offset, a time, the trim horizon, or the most recent message in the stream. As the oldest message inside the retention period boundary, using the trim horizon effectively lets you consume all messages in the stream. A cursor based on the most recent message allows consumption of only messages that are added to the stream after you create the cursor. Cursors expire five minutes after you receive them from the service.

func (StreamClient) CreateGroupCursor Uses

func (client StreamClient) CreateGroupCursor(ctx context.Context, request CreateGroupCursorRequest) (response CreateGroupCursorResponse, err error)

CreateGroupCursor Creates a group-cursor.

func (StreamClient) GetGroup Uses

func (client StreamClient) GetGroup(ctx context.Context, request GetGroupRequest) (response GetGroupResponse, err error)

GetGroup Returns the current state of a consumer group.

func (StreamClient) GetMessages Uses

func (client StreamClient) GetMessages(ctx context.Context, request GetMessagesRequest) (response GetMessagesResponse, err error)

GetMessages Returns messages from the specified stream using the specified cursor as the starting point for consumption. By default, the number of messages returned is undefined, but the service returns as many as possible. To get messages, you must first obtain a cursor using the CreateCursor operation. In the response, retrieve the value of the 'opc-next-cursor' header to pass as a parameter to get the next batch of messages in the stream.

func (StreamClient) PutMessages Uses

func (client StreamClient) PutMessages(ctx context.Context, request PutMessagesRequest) (response PutMessagesResponse, err error)

PutMessages Emits messages to a stream. There's no limit to the number of messages in a request, but the total size of a message or request must be 1 MiB or less. The service calculates the partition ID from the message key and stores messages that share a key on the same partition. If a message does not contain a key or if the key is null, the service generates a message key for you. The partition ID cannot be passed as a parameter.

func (StreamClient) UpdateGroup Uses

func (client StreamClient) UpdateGroup(ctx context.Context, request UpdateGroupRequest) (response UpdateGroupResponse, err error)

UpdateGroup Forcefully changes the current location of a group as a whole; reseting processing location of all consumers to a particular location in the stream.

type StreamLifecycleStateEnum Uses

type StreamLifecycleStateEnum string

StreamLifecycleStateEnum Enum with underlying type: string

const (
    StreamLifecycleStateCreating StreamLifecycleStateEnum = "CREATING"
    StreamLifecycleStateActive   StreamLifecycleStateEnum = "ACTIVE"
    StreamLifecycleStateDeleting StreamLifecycleStateEnum = "DELETING"
    StreamLifecycleStateDeleted  StreamLifecycleStateEnum = "DELETED"
    StreamLifecycleStateFailed   StreamLifecycleStateEnum = "FAILED"
    StreamLifecycleStateUpdating StreamLifecycleStateEnum = "UPDATING"
)

Set of constants representing the allowable values for StreamLifecycleStateEnum

func GetStreamLifecycleStateEnumValues Uses

func GetStreamLifecycleStateEnumValues() []StreamLifecycleStateEnum

GetStreamLifecycleStateEnumValues Enumerates the set of values for StreamLifecycleStateEnum

type StreamPool Uses

type StreamPool struct {

    // The OCID of the stream pool.
    Id  *string `mandatory:"true" json:"id"`

    // Compartment OCID that the pool belongs to.
    CompartmentId *string `mandatory:"true" json:"compartmentId"`

    // The name of the stream pool.
    Name *string `mandatory:"true" json:"name"`

    // The current state of the stream pool.
    LifecycleState StreamPoolLifecycleStateEnum `mandatory:"true" json:"lifecycleState"`

    // The date and time the stream pool was created, expressed in in RFC 3339 (https://tools.ietf.org/rfc/rfc3339) timestamp format.
    // Example: `2018-04-20T00:00:07.405Z`
    TimeCreated *common.SDKTime `mandatory:"true" json:"timeCreated"`

    KafkaSettings *KafkaSettings `mandatory:"true" json:"kafkaSettings"`

    CustomEncryptionKey *CustomEncryptionKey `mandatory:"true" json:"customEncryptionKey"`

    // Any additional details about the current state of the stream.
    LifecycleStateDetails *string `mandatory:"false" json:"lifecycleStateDetails"`

    // True if the stream pool is private, false otherwise.
    // If the stream pool is private, the streams inside the stream pool can only be accessed from inside the associated subnetId.
    IsPrivate *bool `mandatory:"false" json:"isPrivate"`

    // The FQDN used to access the streams inside the stream pool (same FQDN as the messagesEndpoint attribute of a Stream object).
    // If the stream pool is private, the FQDN is customized and can only be accessed from inside the associated subnetId, otherwise the FQDN is publicly resolvable.
    // Depending on which protocol you attempt to use, you need to either prepend https or append the Kafka port.
    EndpointFqdn *string `mandatory:"false" json:"endpointFqdn"`

    PrivateEndpointSettings *PrivateEndpointSettings `mandatory:"false" json:"privateEndpointSettings"`

    // Free-form tags for this resource. Each tag is a simple key-value pair with no predefined name, type, or namespace. Exists for cross-compatibility only.
    // For more information, see Resource Tags (https://docs.cloud.oracle.com/Content/General/Concepts/resourcetags.htm).
    // Example: `{"Department": "Finance"}`
    FreeformTags map[string]string `mandatory:"false" json:"freeformTags"`

    // Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see Resource Tags (https://docs.cloud.oracle.com/Content/General/Concepts/resourcetags.htm).
    // Example: `{"Operations": {"CostCenter": "42"}}'
    DefinedTags map[string]map[string]interface{} `mandatory:"false" json:"definedTags"`
}

StreamPool The details of a stream pool.

func (StreamPool) String Uses

func (m StreamPool) String() string

type StreamPoolLifecycleStateEnum Uses

type StreamPoolLifecycleStateEnum string

StreamPoolLifecycleStateEnum Enum with underlying type: string

const (
    StreamPoolLifecycleStateCreating StreamPoolLifecycleStateEnum = "CREATING"
    StreamPoolLifecycleStateActive   StreamPoolLifecycleStateEnum = "ACTIVE"
    StreamPoolLifecycleStateDeleting StreamPoolLifecycleStateEnum = "DELETING"
    StreamPoolLifecycleStateDeleted  StreamPoolLifecycleStateEnum = "DELETED"
    StreamPoolLifecycleStateFailed   StreamPoolLifecycleStateEnum = "FAILED"
    StreamPoolLifecycleStateUpdating StreamPoolLifecycleStateEnum = "UPDATING"
)

Set of constants representing the allowable values for StreamPoolLifecycleStateEnum

func GetStreamPoolLifecycleStateEnumValues Uses

func GetStreamPoolLifecycleStateEnumValues() []StreamPoolLifecycleStateEnum

GetStreamPoolLifecycleStateEnumValues Enumerates the set of values for StreamPoolLifecycleStateEnum

type StreamPoolSummary Uses

type StreamPoolSummary struct {

    // The OCID of the stream pool.
    Id  *string `mandatory:"true" json:"id"`

    // Compartment OCID that the pool belongs to.
    CompartmentId *string `mandatory:"true" json:"compartmentId"`

    // The name of the stream pool.
    Name *string `mandatory:"true" json:"name"`

    // The current state of the stream pool.
    LifecycleState StreamPoolSummaryLifecycleStateEnum `mandatory:"true" json:"lifecycleState"`

    // The date and time the stream pool was created, expressed in in RFC 3339 (https://tools.ietf.org/rfc/rfc3339) timestamp format.
    // Example: `2018-04-20T00:00:07.405Z`
    TimeCreated *common.SDKTime `mandatory:"true" json:"timeCreated"`

    // True if the stream pool is private, false otherwise.
    // The associated endpoint and subnetId of a private stream pool can be retrieved through the GetStreamPool API.
    IsPrivate *bool `mandatory:"false" json:"isPrivate"`

    // Free-form tags for this resource. Each tag is a simple key-value pair that is applied with no predefined name, type, or namespace. Exists for cross-compatibility only.
    // For more information, see Resource Tags (https://docs.cloud.oracle.com/Content/General/Concepts/resourcetags.htm).
    // Example: `{"Department": "Finance"}`
    FreeformTags map[string]string `mandatory:"false" json:"freeformTags"`

    // Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see Resource Tags (https://docs.cloud.oracle.com/Content/General/Concepts/resourcetags.htm).
    // Example: `{"Operations": {"CostCenter": "42"}}`
    DefinedTags map[string]map[string]interface{} `mandatory:"false" json:"definedTags"`
}

StreamPoolSummary The summary representation of a stream pool.

func (StreamPoolSummary) String Uses

func (m StreamPoolSummary) String() string

type StreamPoolSummaryLifecycleStateEnum Uses

type StreamPoolSummaryLifecycleStateEnum string

StreamPoolSummaryLifecycleStateEnum Enum with underlying type: string

const (
    StreamPoolSummaryLifecycleStateCreating StreamPoolSummaryLifecycleStateEnum = "CREATING"
    StreamPoolSummaryLifecycleStateActive   StreamPoolSummaryLifecycleStateEnum = "ACTIVE"
    StreamPoolSummaryLifecycleStateDeleting StreamPoolSummaryLifecycleStateEnum = "DELETING"
    StreamPoolSummaryLifecycleStateDeleted  StreamPoolSummaryLifecycleStateEnum = "DELETED"
    StreamPoolSummaryLifecycleStateFailed   StreamPoolSummaryLifecycleStateEnum = "FAILED"
    StreamPoolSummaryLifecycleStateUpdating StreamPoolSummaryLifecycleStateEnum = "UPDATING"
)

Set of constants representing the allowable values for StreamPoolSummaryLifecycleStateEnum

func GetStreamPoolSummaryLifecycleStateEnumValues Uses

func GetStreamPoolSummaryLifecycleStateEnumValues() []StreamPoolSummaryLifecycleStateEnum

GetStreamPoolSummaryLifecycleStateEnumValues Enumerates the set of values for StreamPoolSummaryLifecycleStateEnum

type StreamSummary Uses

type StreamSummary struct {

    // The name of the stream.
    // Example: `TelemetryEvents`
    Name *string `mandatory:"true" json:"name"`

    // The OCID of the stream.
    Id  *string `mandatory:"true" json:"id"`

    // The number of partitions in the stream.
    Partitions *int `mandatory:"true" json:"partitions"`

    // The OCID of the compartment that contains the stream.
    CompartmentId *string `mandatory:"true" json:"compartmentId"`

    // The OCID of the stream pool that contains the stream.
    StreamPoolId *string `mandatory:"true" json:"streamPoolId"`

    // The current state of the stream.
    LifecycleState StreamSummaryLifecycleStateEnum `mandatory:"true" json:"lifecycleState"`

    // The date and time the stream was created, expressed in RFC 3339 (https://tools.ietf.org/rfc/rfc3339) timestamp format.
    // Example: `2018-04-20T00:00:07.405Z`
    TimeCreated *common.SDKTime `mandatory:"true" json:"timeCreated"`

    // The endpoint to use when creating the StreamClient to consume or publish messages in the stream.
    // If the associated stream pool is private, the endpoint is also private and can only be accessed from inside the stream pool's associated subnet.
    MessagesEndpoint *string `mandatory:"true" json:"messagesEndpoint"`

    // Free-form tags for this resource. Each tag is a simple key-value pair that is applied with no predefined name, type, or namespace. Exists for cross-compatibility only.
    // For more information, see Resource Tags (https://docs.cloud.oracle.com/Content/General/Concepts/resourcetags.htm).
    // Example: `{"Department": "Finance"}`
    FreeformTags map[string]string `mandatory:"false" json:"freeformTags"`

    // Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see Resource Tags (https://docs.cloud.oracle.com/Content/General/Concepts/resourcetags.htm).
    // Example: `{"Operations": {"CostCenter": "42"}}`
    DefinedTags map[string]map[string]interface{} `mandatory:"false" json:"definedTags"`
}

StreamSummary Summary representation of a stream.

func (StreamSummary) String Uses

func (m StreamSummary) String() string

type StreamSummaryLifecycleStateEnum Uses

type StreamSummaryLifecycleStateEnum string

StreamSummaryLifecycleStateEnum Enum with underlying type: string

const (
    StreamSummaryLifecycleStateCreating StreamSummaryLifecycleStateEnum = "CREATING"
    StreamSummaryLifecycleStateActive   StreamSummaryLifecycleStateEnum = "ACTIVE"
    StreamSummaryLifecycleStateDeleting StreamSummaryLifecycleStateEnum = "DELETING"
    StreamSummaryLifecycleStateDeleted  StreamSummaryLifecycleStateEnum = "DELETED"
    StreamSummaryLifecycleStateFailed   StreamSummaryLifecycleStateEnum = "FAILED"
    StreamSummaryLifecycleStateUpdating StreamSummaryLifecycleStateEnum = "UPDATING"
)

Set of constants representing the allowable values for StreamSummaryLifecycleStateEnum

func GetStreamSummaryLifecycleStateEnumValues Uses

func GetStreamSummaryLifecycleStateEnumValues() []StreamSummaryLifecycleStateEnum

GetStreamSummaryLifecycleStateEnumValues Enumerates the set of values for StreamSummaryLifecycleStateEnum

type UpdateConnectHarnessDetails Uses

type UpdateConnectHarnessDetails struct {

    // Free-form tags for this resource. Each tag is a simple key-value pair that is applied with no predefined name, type, or namespace. Exists for cross-compatibility only.
    // For more information, see Resource Tags (https://docs.cloud.oracle.com/Content/General/Concepts/resourcetags.htm).
    // Example: `{"Department": "Finance"}`
    FreeformTags map[string]string `mandatory:"false" json:"freeformTags"`

    // Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see Resource Tags (https://docs.cloud.oracle.com/Content/General/Concepts/resourcetags.htm).
    // Example: `{"Operations": {"CostCenter": "42"}}`
    DefinedTags map[string]map[string]interface{} `mandatory:"false" json:"definedTags"`
}

UpdateConnectHarnessDetails Object used to update a connect harness.

func (UpdateConnectHarnessDetails) String Uses

func (m UpdateConnectHarnessDetails) String() string

type UpdateConnectHarnessRequest Uses

type UpdateConnectHarnessRequest struct {

    // The OCID of the connect harness.
    ConnectHarnessId *string `mandatory:"true" contributesTo:"path" name:"connectHarnessId"`

    // The connect harness is updated with the tags provided.
    UpdateConnectHarnessDetails `contributesTo:"body"`

    // The unique Oracle-assigned identifier for the request. If you need to contact Oracle about a
    // particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // For optimistic concurrency control. In the PUT or DELETE call for a resource, set the if-match parameter to the value of the etag from a previous GET or POST response for that resource. The resource will be updated or deleted only if the etag you provide matches the resource's current etag value.
    IfMatch *string `mandatory:"false" contributesTo:"header" name:"if-match"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

UpdateConnectHarnessRequest wrapper for the UpdateConnectHarness operation

func (UpdateConnectHarnessRequest) HTTPRequest Uses

func (request UpdateConnectHarnessRequest) HTTPRequest(method, path string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (UpdateConnectHarnessRequest) RetryPolicy Uses

func (request UpdateConnectHarnessRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (UpdateConnectHarnessRequest) String Uses

func (request UpdateConnectHarnessRequest) String() string

type UpdateConnectHarnessResponse Uses

type UpdateConnectHarnessResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // The ConnectHarness instance
    ConnectHarness `presentIn:"body"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about
    // a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`

    // For optimistic concurrency control. See `if-match`.
    Etag *string `presentIn:"header" name:"etag"`
}

UpdateConnectHarnessResponse wrapper for the UpdateConnectHarness operation

func (UpdateConnectHarnessResponse) HTTPResponse Uses

func (response UpdateConnectHarnessResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (UpdateConnectHarnessResponse) String Uses

func (response UpdateConnectHarnessResponse) String() string

type UpdateGroupDetails Uses

type UpdateGroupDetails struct {

    // The type of the cursor.
    Type UpdateGroupDetailsTypeEnum `mandatory:"false" json:"type,omitempty"`

    // The time to consume from if type is AT_TIME.
    Time *common.SDKTime `mandatory:"false" json:"time"`
}

UpdateGroupDetails Request body for operationally managing a group.

func (UpdateGroupDetails) String Uses

func (m UpdateGroupDetails) String() string

type UpdateGroupDetailsTypeEnum Uses

type UpdateGroupDetailsTypeEnum string

UpdateGroupDetailsTypeEnum Enum with underlying type: string

const (
    UpdateGroupDetailsTypeAtTime      UpdateGroupDetailsTypeEnum = "AT_TIME"
    UpdateGroupDetailsTypeLatest      UpdateGroupDetailsTypeEnum = "LATEST"
    UpdateGroupDetailsTypeTrimHorizon UpdateGroupDetailsTypeEnum = "TRIM_HORIZON"
)

Set of constants representing the allowable values for UpdateGroupDetailsTypeEnum

func GetUpdateGroupDetailsTypeEnumValues Uses

func GetUpdateGroupDetailsTypeEnumValues() []UpdateGroupDetailsTypeEnum

GetUpdateGroupDetailsTypeEnumValues Enumerates the set of values for UpdateGroupDetailsTypeEnum

type UpdateGroupRequest Uses

type UpdateGroupRequest struct {

    // The OCID of the stream.
    StreamId *string `mandatory:"true" contributesTo:"path" name:"streamId"`

    // The name of the consumer group.
    GroupName *string `mandatory:"true" contributesTo:"path" name:"groupName"`

    // The information used to modify the group.
    UpdateGroupDetails `contributesTo:"body"`

    // The unique Oracle-assigned identifier for the request. If you need to contact Oracle about a
    // particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

UpdateGroupRequest wrapper for the UpdateGroup operation

func (UpdateGroupRequest) HTTPRequest Uses

func (request UpdateGroupRequest) HTTPRequest(method, path string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (UpdateGroupRequest) RetryPolicy Uses

func (request UpdateGroupRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (UpdateGroupRequest) String Uses

func (request UpdateGroupRequest) String() string

type UpdateGroupResponse Uses

type UpdateGroupResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about
    // a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`
}

UpdateGroupResponse wrapper for the UpdateGroup operation

func (UpdateGroupResponse) HTTPResponse Uses

func (response UpdateGroupResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (UpdateGroupResponse) String Uses

func (response UpdateGroupResponse) String() string

type UpdateStreamDetails Uses

type UpdateStreamDetails struct {

    // The OCID (https://docs.cloud.oracle.com/Content/General/Concepts/identifiers.htm) of the stream pool where the stream should be moved.
    StreamPoolId *string `mandatory:"false" json:"streamPoolId"`

    // Free-form tags for this resource. Each tag is a simple key-value pair that is applied with no predefined name, type, or namespace. Exists for cross-compatibility only.
    // For more information, see Resource Tags (https://docs.cloud.oracle.com/Content/General/Concepts/resourcetags.htm).
    // Example: `{"Department": "Finance"}`
    FreeformTags map[string]string `mandatory:"false" json:"freeformTags"`

    // Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see Resource Tags (https://docs.cloud.oracle.com/Content/General/Concepts/resourcetags.htm).
    // Example: `{"Operations": {"CostCenter": "42"}}`
    DefinedTags map[string]map[string]interface{} `mandatory:"false" json:"definedTags"`
}

UpdateStreamDetails Object used to update a stream.

func (UpdateStreamDetails) String Uses

func (m UpdateStreamDetails) String() string

type UpdateStreamPoolDetails Uses

type UpdateStreamPoolDetails struct {
    Name *string `mandatory:"false" json:"name"`

    KafkaSettings *KafkaSettings `mandatory:"false" json:"kafkaSettings"`

    CustomEncryptionKeyDetails *CustomEncryptionKeyDetails `mandatory:"false" json:"customEncryptionKeyDetails"`

    // Free-form tags for this resource. Each tag is a simple key-value pair that is applied with no predefined name, type, or namespace. Exists for cross-compatibility only.
    // For more information, see Resource Tags (https://docs.cloud.oracle.com/Content/General/Concepts/resourcetags.htm).
    // Example: `{"Department": "Finance"}`
    FreeformTags map[string]string `mandatory:"false" json:"freeformTags"`

    // Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see Resource Tags (https://docs.cloud.oracle.com/Content/General/Concepts/resourcetags.htm).
    // Example: `{"Operations": {"CostCenter": "42"}}`
    DefinedTags map[string]map[string]interface{} `mandatory:"false" json:"definedTags"`
}

UpdateStreamPoolDetails Object used to update the stream pool's details.

func (UpdateStreamPoolDetails) String Uses

func (m UpdateStreamPoolDetails) String() string

type UpdateStreamPoolRequest Uses

type UpdateStreamPoolRequest struct {

    // The OCID of the stream pool.
    StreamPoolId *string `mandatory:"true" contributesTo:"path" name:"streamPoolId"`

    // The pool is updated with the provided fields.
    UpdateStreamPoolDetails `contributesTo:"body"`

    // The unique Oracle-assigned identifier for the request. If you need to contact Oracle about a
    // particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // For optimistic concurrency control. In the PUT or DELETE call for a resource, set the if-match parameter to the value of the etag from a previous GET or POST response for that resource. The resource will be updated or deleted only if the etag you provide matches the resource's current etag value.
    IfMatch *string `mandatory:"false" contributesTo:"header" name:"if-match"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

UpdateStreamPoolRequest wrapper for the UpdateStreamPool operation

func (UpdateStreamPoolRequest) HTTPRequest Uses

func (request UpdateStreamPoolRequest) HTTPRequest(method, path string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (UpdateStreamPoolRequest) RetryPolicy Uses

func (request UpdateStreamPoolRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (UpdateStreamPoolRequest) String Uses

func (request UpdateStreamPoolRequest) String() string

type UpdateStreamPoolResponse Uses

type UpdateStreamPoolResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // The StreamPool instance
    StreamPool `presentIn:"body"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about
    // a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`

    // For optimistic concurrency control. See `if-match`.
    Etag *string `presentIn:"header" name:"etag"`
}

UpdateStreamPoolResponse wrapper for the UpdateStreamPool operation

func (UpdateStreamPoolResponse) HTTPResponse Uses

func (response UpdateStreamPoolResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (UpdateStreamPoolResponse) String Uses

func (response UpdateStreamPoolResponse) String() string

type UpdateStreamRequest Uses

type UpdateStreamRequest struct {

    // The OCID of the stream.
    StreamId *string `mandatory:"true" contributesTo:"path" name:"streamId"`

    // The stream is updated with the values provided.
    UpdateStreamDetails `contributesTo:"body"`

    // The unique Oracle-assigned identifier for the request. If you need to contact Oracle about a
    // particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // For optimistic concurrency control. In the PUT or DELETE call for a resource, set the if-match parameter to the value of the etag from a previous GET or POST response for that resource. The resource will be updated or deleted only if the etag you provide matches the resource's current etag value.
    IfMatch *string `mandatory:"false" contributesTo:"header" name:"if-match"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

UpdateStreamRequest wrapper for the UpdateStream operation

func (UpdateStreamRequest) HTTPRequest Uses

func (request UpdateStreamRequest) HTTPRequest(method, path string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (UpdateStreamRequest) RetryPolicy Uses

func (request UpdateStreamRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (UpdateStreamRequest) String Uses

func (request UpdateStreamRequest) String() string

type UpdateStreamResponse Uses

type UpdateStreamResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // The Stream instance
    Stream `presentIn:"body"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about
    // a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`

    // For optimistic concurrency control. See `if-match`.
    Etag *string `presentIn:"header" name:"etag"`
}

UpdateStreamResponse wrapper for the UpdateStream operation

func (UpdateStreamResponse) HTTPResponse Uses

func (response UpdateStreamResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (UpdateStreamResponse) String Uses

func (response UpdateStreamResponse) String() string

Package streaming imports 4 packages (graph) and is imported by 2 packages. Updated 2020-04-22. Refresh now. Tools for package owners.