Versions in this module Expand all Collapse all v37 v37.0.0 Mar 23, 2021 Changes in this version + type ChangeConnectHarnessCompartmentDetails struct + CompartmentId *string + func (m ChangeConnectHarnessCompartmentDetails) String() string + type ChangeConnectHarnessCompartmentRequest struct + ConnectHarnessId *string + IfMatch *string + OpcRequestId *string + RequestMetadata common.RequestMetadata + func (request ChangeConnectHarnessCompartmentRequest) HTTPRequest(method, path string) (http.Request, error) + func (request ChangeConnectHarnessCompartmentRequest) RetryPolicy() *common.RetryPolicy + func (request ChangeConnectHarnessCompartmentRequest) String() string + type ChangeConnectHarnessCompartmentResponse struct + OpcRequestId *string + RawResponse *http.Response + func (response ChangeConnectHarnessCompartmentResponse) HTTPResponse() *http.Response + func (response ChangeConnectHarnessCompartmentResponse) String() string + type ChangeStreamCompartmentDetails struct + CompartmentId *string + func (m ChangeStreamCompartmentDetails) String() string + type ChangeStreamCompartmentRequest struct + IfMatch *string + OpcRequestId *string + RequestMetadata common.RequestMetadata + StreamId *string + func (request ChangeStreamCompartmentRequest) HTTPRequest(method, path string) (http.Request, error) + func (request ChangeStreamCompartmentRequest) RetryPolicy() *common.RetryPolicy + func (request ChangeStreamCompartmentRequest) String() string + type ChangeStreamCompartmentResponse struct + OpcRequestId *string + RawResponse *http.Response + func (response ChangeStreamCompartmentResponse) HTTPResponse() *http.Response + func (response ChangeStreamCompartmentResponse) String() string + type ChangeStreamPoolCompartmentDetails struct + CompartmentId *string + func (m ChangeStreamPoolCompartmentDetails) String() string + type ChangeStreamPoolCompartmentRequest struct + IfMatch *string + OpcRequestId *string + RequestMetadata common.RequestMetadata + StreamPoolId *string + func (request ChangeStreamPoolCompartmentRequest) HTTPRequest(method, path string) (http.Request, error) + func (request ChangeStreamPoolCompartmentRequest) RetryPolicy() *common.RetryPolicy + func (request ChangeStreamPoolCompartmentRequest) String() string + type ChangeStreamPoolCompartmentResponse struct + OpcRequestId *string + RawResponse *http.Response + func (response ChangeStreamPoolCompartmentResponse) HTTPResponse() *http.Response + func (response ChangeStreamPoolCompartmentResponse) String() string + type ConnectHarness struct + CompartmentId *string + DefinedTags map[string]map[string]interface{} + FreeformTags map[string]string + Id *string + LifecycleState ConnectHarnessLifecycleStateEnum + LifecycleStateDetails *string + Name *string + TimeCreated *common.SDKTime + func (m ConnectHarness) String() string + type ConnectHarnessLifecycleStateEnum string + const ConnectHarnessLifecycleStateActive + const ConnectHarnessLifecycleStateCreating + const ConnectHarnessLifecycleStateDeleted + const ConnectHarnessLifecycleStateDeleting + const ConnectHarnessLifecycleStateFailed + const ConnectHarnessLifecycleStateUpdating + func GetConnectHarnessLifecycleStateEnumValues() []ConnectHarnessLifecycleStateEnum + type ConnectHarnessSummary struct + CompartmentId *string + DefinedTags map[string]map[string]interface{} + FreeformTags map[string]string + Id *string + LifecycleState ConnectHarnessSummaryLifecycleStateEnum + Name *string + TimeCreated *common.SDKTime + func (m ConnectHarnessSummary) String() string + type ConnectHarnessSummaryLifecycleStateEnum string + const ConnectHarnessSummaryLifecycleStateActive + const ConnectHarnessSummaryLifecycleStateCreating + const ConnectHarnessSummaryLifecycleStateDeleted + const ConnectHarnessSummaryLifecycleStateDeleting + const ConnectHarnessSummaryLifecycleStateFailed + const ConnectHarnessSummaryLifecycleStateUpdating + func GetConnectHarnessSummaryLifecycleStateEnumValues() []ConnectHarnessSummaryLifecycleStateEnum + type ConsumerCommitRequest struct + Cursor *string + OpcRequestId *string + RequestMetadata common.RequestMetadata + StreamId *string + func (request ConsumerCommitRequest) HTTPRequest(method, path string) (http.Request, error) + func (request ConsumerCommitRequest) RetryPolicy() *common.RetryPolicy + func (request ConsumerCommitRequest) String() string + type ConsumerCommitResponse struct + OpcRequestId *string + RawResponse *http.Response + func (response ConsumerCommitResponse) HTTPResponse() *http.Response + func (response ConsumerCommitResponse) String() string + type ConsumerHeartbeatRequest struct + Cursor *string + OpcRequestId *string + RequestMetadata common.RequestMetadata + StreamId *string + func (request ConsumerHeartbeatRequest) HTTPRequest(method, path string) (http.Request, error) + func (request ConsumerHeartbeatRequest) RetryPolicy() *common.RetryPolicy + func (request ConsumerHeartbeatRequest) String() string + type ConsumerHeartbeatResponse struct + OpcRequestId *string + RawResponse *http.Response + func (response ConsumerHeartbeatResponse) HTTPResponse() *http.Response + func (response ConsumerHeartbeatResponse) String() string + type CreateConnectHarnessDetails struct + CompartmentId *string + DefinedTags map[string]map[string]interface{} + FreeformTags map[string]string + Name *string + func (m CreateConnectHarnessDetails) String() string + type CreateConnectHarnessRequest struct + OpcRequestId *string + OpcRetryToken *string + RequestMetadata common.RequestMetadata + func (request CreateConnectHarnessRequest) HTTPRequest(method, path string) (http.Request, error) + func (request CreateConnectHarnessRequest) RetryPolicy() *common.RetryPolicy + func (request CreateConnectHarnessRequest) String() string + type CreateConnectHarnessResponse struct + Etag *string + OpcRequestId *string + RawResponse *http.Response + func (response CreateConnectHarnessResponse) HTTPResponse() *http.Response + func (response CreateConnectHarnessResponse) String() string + type CreateCursorDetails struct + Offset *int64 + Partition *string + Time *common.SDKTime + Type CreateCursorDetailsTypeEnum + func (m CreateCursorDetails) String() string + type CreateCursorDetailsTypeEnum string + const CreateCursorDetailsTypeAfterOffset + const CreateCursorDetailsTypeAtOffset + const CreateCursorDetailsTypeAtTime + const CreateCursorDetailsTypeLatest + const CreateCursorDetailsTypeTrimHorizon + func GetCreateCursorDetailsTypeEnumValues() []CreateCursorDetailsTypeEnum + type CreateCursorRequest struct + OpcRequestId *string + RequestMetadata common.RequestMetadata + StreamId *string + func (request CreateCursorRequest) HTTPRequest(method, path string) (http.Request, error) + func (request CreateCursorRequest) RetryPolicy() *common.RetryPolicy + func (request CreateCursorRequest) String() string + type CreateCursorResponse struct + OpcRequestId *string + RawResponse *http.Response + func (response CreateCursorResponse) HTTPResponse() *http.Response + func (response CreateCursorResponse) String() string + type CreateGroupCursorDetails struct + CommitOnGet *bool + GroupName *string + InstanceName *string + Time *common.SDKTime + TimeoutInMs *int + Type CreateGroupCursorDetailsTypeEnum + func (m CreateGroupCursorDetails) String() string + type CreateGroupCursorDetailsTypeEnum string + const CreateGroupCursorDetailsTypeAtTime + const CreateGroupCursorDetailsTypeLatest + const CreateGroupCursorDetailsTypeTrimHorizon + func GetCreateGroupCursorDetailsTypeEnumValues() []CreateGroupCursorDetailsTypeEnum + type CreateGroupCursorRequest struct + OpcRequestId *string + RequestMetadata common.RequestMetadata + StreamId *string + func (request CreateGroupCursorRequest) HTTPRequest(method, path string) (http.Request, error) + func (request CreateGroupCursorRequest) RetryPolicy() *common.RetryPolicy + func (request CreateGroupCursorRequest) String() string + type CreateGroupCursorResponse struct + OpcRequestId *string + RawResponse *http.Response + func (response CreateGroupCursorResponse) HTTPResponse() *http.Response + func (response CreateGroupCursorResponse) String() string + type CreateStreamDetails struct + CompartmentId *string + DefinedTags map[string]map[string]interface{} + FreeformTags map[string]string + Name *string + Partitions *int + RetentionInHours *int + StreamPoolId *string + func (m CreateStreamDetails) String() string + type CreateStreamPoolDetails struct + CompartmentId *string + CustomEncryptionKeyDetails *CustomEncryptionKeyDetails + DefinedTags map[string]map[string]interface{} + FreeformTags map[string]string + KafkaSettings *KafkaSettings + Name *string + PrivateEndpointDetails *PrivateEndpointDetails + func (m CreateStreamPoolDetails) String() string + type CreateStreamPoolRequest struct + OpcRequestId *string + OpcRetryToken *string + RequestMetadata common.RequestMetadata + func (request CreateStreamPoolRequest) HTTPRequest(method, path string) (http.Request, error) + func (request CreateStreamPoolRequest) RetryPolicy() *common.RetryPolicy + func (request CreateStreamPoolRequest) String() string + type CreateStreamPoolResponse struct + Etag *string + OpcRequestId *string + RawResponse *http.Response + func (response CreateStreamPoolResponse) HTTPResponse() *http.Response + func (response CreateStreamPoolResponse) String() string + type CreateStreamRequest struct + OpcRequestId *string + RequestMetadata common.RequestMetadata + func (request CreateStreamRequest) HTTPRequest(method, path string) (http.Request, error) + func (request CreateStreamRequest) RetryPolicy() *common.RetryPolicy + func (request CreateStreamRequest) String() string + type CreateStreamResponse struct + Etag *string + OpcRequestId *string + RawResponse *http.Response + func (response CreateStreamResponse) HTTPResponse() *http.Response + func (response CreateStreamResponse) String() string + type Cursor struct + Value *string + func (m Cursor) String() string + type CustomEncryptionKey struct + KeyState CustomEncryptionKeyKeyStateEnum + KmsKeyId *string + func (m CustomEncryptionKey) String() string + type CustomEncryptionKeyDetails struct + KmsKeyId *string + func (m CustomEncryptionKeyDetails) String() string + type CustomEncryptionKeyKeyStateEnum string + const CustomEncryptionKeyKeyStateActive + const CustomEncryptionKeyKeyStateCreating + const CustomEncryptionKeyKeyStateDeleting + const CustomEncryptionKeyKeyStateFailed + const CustomEncryptionKeyKeyStateNone + const CustomEncryptionKeyKeyStateUpdating + func GetCustomEncryptionKeyKeyStateEnumValues() []CustomEncryptionKeyKeyStateEnum + type DeleteConnectHarnessRequest struct + ConnectHarnessId *string + IfMatch *string + OpcRequestId *string + RequestMetadata common.RequestMetadata + func (request DeleteConnectHarnessRequest) HTTPRequest(method, path string) (http.Request, error) + func (request DeleteConnectHarnessRequest) RetryPolicy() *common.RetryPolicy + func (request DeleteConnectHarnessRequest) String() string + type DeleteConnectHarnessResponse struct + OpcRequestId *string + RawResponse *http.Response + func (response DeleteConnectHarnessResponse) HTTPResponse() *http.Response + func (response DeleteConnectHarnessResponse) String() string + type DeleteStreamPoolRequest struct + IfMatch *string + OpcRequestId *string + RequestMetadata common.RequestMetadata + StreamPoolId *string + func (request DeleteStreamPoolRequest) HTTPRequest(method, path string) (http.Request, error) + func (request DeleteStreamPoolRequest) RetryPolicy() *common.RetryPolicy + func (request DeleteStreamPoolRequest) String() string + type DeleteStreamPoolResponse struct + OpcRequestId *string + RawResponse *http.Response + func (response DeleteStreamPoolResponse) HTTPResponse() *http.Response + func (response DeleteStreamPoolResponse) String() string + type DeleteStreamRequest struct + IfMatch *string + OpcRequestId *string + RequestMetadata common.RequestMetadata + StreamId *string + func (request DeleteStreamRequest) HTTPRequest(method, path string) (http.Request, error) + func (request DeleteStreamRequest) RetryPolicy() *common.RetryPolicy + func (request DeleteStreamRequest) String() string + type DeleteStreamResponse struct + OpcRequestId *string + RawResponse *http.Response + func (response DeleteStreamResponse) HTTPResponse() *http.Response + func (response DeleteStreamResponse) String() string + type GetConnectHarnessRequest struct + ConnectHarnessId *string + OpcRequestId *string + RequestMetadata common.RequestMetadata + func (request GetConnectHarnessRequest) HTTPRequest(method, path string) (http.Request, error) + func (request GetConnectHarnessRequest) RetryPolicy() *common.RetryPolicy + func (request GetConnectHarnessRequest) String() string + type GetConnectHarnessResponse struct + Etag *string + OpcRequestId *string + RawResponse *http.Response + func (response GetConnectHarnessResponse) HTTPResponse() *http.Response + func (response GetConnectHarnessResponse) String() string + type GetGroupRequest struct + GroupName *string + OpcRequestId *string + RequestMetadata common.RequestMetadata + StreamId *string + func (request GetGroupRequest) HTTPRequest(method, path string) (http.Request, error) + func (request GetGroupRequest) RetryPolicy() *common.RetryPolicy + func (request GetGroupRequest) String() string + type GetGroupResponse struct + OpcRequestId *string + RawResponse *http.Response + func (response GetGroupResponse) HTTPResponse() *http.Response + func (response GetGroupResponse) String() string + type GetMessagesRequest struct + Cursor *string + Limit *int + OpcRequestId *string + RequestMetadata common.RequestMetadata + StreamId *string + func (request GetMessagesRequest) HTTPRequest(method, path string) (http.Request, error) + func (request GetMessagesRequest) RetryPolicy() *common.RetryPolicy + func (request GetMessagesRequest) String() string + type GetMessagesResponse struct + Items []Message + OpcNextCursor *string + OpcRequestId *string + RawResponse *http.Response + func (response GetMessagesResponse) HTTPResponse() *http.Response + func (response GetMessagesResponse) String() string + type GetStreamPoolRequest struct + OpcRequestId *string + RequestMetadata common.RequestMetadata + StreamPoolId *string + func (request GetStreamPoolRequest) HTTPRequest(method, path string) (http.Request, error) + func (request GetStreamPoolRequest) RetryPolicy() *common.RetryPolicy + func (request GetStreamPoolRequest) String() string + type GetStreamPoolResponse struct + Etag *string + OpcRequestId *string + RawResponse *http.Response + func (response GetStreamPoolResponse) HTTPResponse() *http.Response + func (response GetStreamPoolResponse) String() string + type GetStreamRequest struct + OpcRequestId *string + RequestMetadata common.RequestMetadata + StreamId *string + func (request GetStreamRequest) HTTPRequest(method, path string) (http.Request, error) + func (request GetStreamRequest) RetryPolicy() *common.RetryPolicy + func (request GetStreamRequest) String() string + type GetStreamResponse struct + Etag *string + OpcRequestId *string + RawResponse *http.Response + func (response GetStreamResponse) HTTPResponse() *http.Response + func (response GetStreamResponse) String() string + type Group struct + GroupName *string + Reservations []PartitionReservation + StreamId *string + func (m Group) String() string + type KafkaSettings struct + AutoCreateTopicsEnable *bool + BootstrapServers *string + LogRetentionHours *int + NumPartitions *int + func (m KafkaSettings) String() string + type ListConnectHarnessesRequest struct + CompartmentId *string + Id *string + LifecycleState ConnectHarnessSummaryLifecycleStateEnum + Limit *int + Name *string + OpcRequestId *string + Page *string + RequestMetadata common.RequestMetadata + SortBy ListConnectHarnessesSortByEnum + SortOrder ListConnectHarnessesSortOrderEnum + func (request ListConnectHarnessesRequest) HTTPRequest(method, path string) (http.Request, error) + func (request ListConnectHarnessesRequest) RetryPolicy() *common.RetryPolicy + func (request ListConnectHarnessesRequest) String() string + type ListConnectHarnessesResponse struct + Items []ConnectHarnessSummary + OpcNextPage *string + OpcPrevPage *string + OpcRequestId *string + RawResponse *http.Response + func (response ListConnectHarnessesResponse) HTTPResponse() *http.Response + func (response ListConnectHarnessesResponse) String() string + type ListConnectHarnessesSortByEnum string + const ListConnectHarnessesSortByName + const ListConnectHarnessesSortByTimecreated + func GetListConnectHarnessesSortByEnumValues() []ListConnectHarnessesSortByEnum + type ListConnectHarnessesSortOrderEnum string + const ListConnectHarnessesSortOrderAsc + const ListConnectHarnessesSortOrderDesc + func GetListConnectHarnessesSortOrderEnumValues() []ListConnectHarnessesSortOrderEnum + type ListStreamPoolsRequest struct + CompartmentId *string + Id *string + LifecycleState StreamPoolSummaryLifecycleStateEnum + Limit *int + Name *string + OpcRequestId *string + Page *string + RequestMetadata common.RequestMetadata + SortBy ListStreamPoolsSortByEnum + SortOrder ListStreamPoolsSortOrderEnum + func (request ListStreamPoolsRequest) HTTPRequest(method, path string) (http.Request, error) + func (request ListStreamPoolsRequest) RetryPolicy() *common.RetryPolicy + func (request ListStreamPoolsRequest) String() string + type ListStreamPoolsResponse struct + Items []StreamPoolSummary + OpcNextPage *string + OpcPrevPage *string + OpcRequestId *string + RawResponse *http.Response + func (response ListStreamPoolsResponse) HTTPResponse() *http.Response + func (response ListStreamPoolsResponse) String() string + type ListStreamPoolsSortByEnum string + const ListStreamPoolsSortByName + const ListStreamPoolsSortByTimecreated + func GetListStreamPoolsSortByEnumValues() []ListStreamPoolsSortByEnum + type ListStreamPoolsSortOrderEnum string + const ListStreamPoolsSortOrderAsc + const ListStreamPoolsSortOrderDesc + func GetListStreamPoolsSortOrderEnumValues() []ListStreamPoolsSortOrderEnum + type ListStreamsRequest struct + CompartmentId *string + Id *string + LifecycleState StreamLifecycleStateEnum + Limit *int + Name *string + OpcRequestId *string + Page *string + RequestMetadata common.RequestMetadata + SortBy ListStreamsSortByEnum + SortOrder ListStreamsSortOrderEnum + StreamPoolId *string + func (request ListStreamsRequest) HTTPRequest(method, path string) (http.Request, error) + func (request ListStreamsRequest) RetryPolicy() *common.RetryPolicy + func (request ListStreamsRequest) String() string + type ListStreamsResponse struct + Items []StreamSummary + OpcNextPage *string + OpcPrevPage *string + OpcRequestId *string + RawResponse *http.Response + func (response ListStreamsResponse) HTTPResponse() *http.Response + func (response ListStreamsResponse) String() string + type ListStreamsSortByEnum string + const ListStreamsSortByName + const ListStreamsSortByTimecreated + func GetListStreamsSortByEnumValues() []ListStreamsSortByEnum + type ListStreamsSortOrderEnum string + const ListStreamsSortOrderAsc + const ListStreamsSortOrderDesc + func GetListStreamsSortOrderEnumValues() []ListStreamsSortOrderEnum + type Message struct + Key []byte + Offset *int64 + Partition *string + Stream *string + Timestamp *common.SDKTime + Value []byte + func (m Message) String() string + type PartitionReservation struct + CommittedOffset *int64 + Partition *string + ReservedInstance *string + TimeReservedUntil *common.SDKTime + func (m PartitionReservation) String() string + type PrivateEndpointDetails struct + NsgIds []string + PrivateEndpointIp *string + SubnetId *string + func (m PrivateEndpointDetails) String() string + type PrivateEndpointSettings struct + NsgIds []string + PrivateEndpointIp *string + SubnetId *string + func (m PrivateEndpointSettings) String() string + type PutMessagesDetails struct + Messages []PutMessagesDetailsEntry + func (m PutMessagesDetails) String() string + type PutMessagesDetailsEntry struct + Key []byte + Value []byte + func (m PutMessagesDetailsEntry) String() string + type PutMessagesRequest struct + OpcRequestId *string + RequestMetadata common.RequestMetadata + StreamId *string + func (request PutMessagesRequest) HTTPRequest(method, path string) (http.Request, error) + func (request PutMessagesRequest) RetryPolicy() *common.RetryPolicy + func (request PutMessagesRequest) String() string + type PutMessagesResponse struct + OpcRequestId *string + RawResponse *http.Response + func (response PutMessagesResponse) HTTPResponse() *http.Response + func (response PutMessagesResponse) String() string + type PutMessagesResult struct + Entries []PutMessagesResultEntry + Failures *int + func (m PutMessagesResult) String() string + type PutMessagesResultEntry struct + Error *string + ErrorMessage *string + Offset *int64 + Partition *string + Timestamp *common.SDKTime + func (m PutMessagesResultEntry) String() string + type Stream struct + CompartmentId *string + DefinedTags map[string]map[string]interface{} + FreeformTags map[string]string + Id *string + LifecycleState StreamLifecycleStateEnum + LifecycleStateDetails *string + MessagesEndpoint *string + Name *string + Partitions *int + RetentionInHours *int + StreamPoolId *string + TimeCreated *common.SDKTime + func (m Stream) String() string + type StreamAdminClient struct + func NewStreamAdminClientWithConfigurationProvider(configProvider common.ConfigurationProvider) (client StreamAdminClient, err error) + func NewStreamAdminClientWithOboToken(configProvider common.ConfigurationProvider, oboToken string) (client StreamAdminClient, err error) + func (client *StreamAdminClient) ConfigurationProvider() *common.ConfigurationProvider + func (client *StreamAdminClient) SetRegion(region string) + func (client StreamAdminClient) ChangeConnectHarnessCompartment(ctx context.Context, request ChangeConnectHarnessCompartmentRequest) (response ChangeConnectHarnessCompartmentResponse, err error) + func (client StreamAdminClient) ChangeStreamCompartment(ctx context.Context, request ChangeStreamCompartmentRequest) (response ChangeStreamCompartmentResponse, err error) + func (client StreamAdminClient) ChangeStreamPoolCompartment(ctx context.Context, request ChangeStreamPoolCompartmentRequest) (response ChangeStreamPoolCompartmentResponse, err error) + func (client StreamAdminClient) CreateConnectHarness(ctx context.Context, request CreateConnectHarnessRequest) (response CreateConnectHarnessResponse, err error) + func (client StreamAdminClient) CreateStream(ctx context.Context, request CreateStreamRequest) (response CreateStreamResponse, err error) + func (client StreamAdminClient) CreateStreamPool(ctx context.Context, request CreateStreamPoolRequest) (response CreateStreamPoolResponse, err error) + func (client StreamAdminClient) DeleteConnectHarness(ctx context.Context, request DeleteConnectHarnessRequest) (response DeleteConnectHarnessResponse, err error) + func (client StreamAdminClient) DeleteStream(ctx context.Context, request DeleteStreamRequest) (response DeleteStreamResponse, err error) + func (client StreamAdminClient) DeleteStreamPool(ctx context.Context, request DeleteStreamPoolRequest) (response DeleteStreamPoolResponse, err error) + func (client StreamAdminClient) GetConnectHarness(ctx context.Context, request GetConnectHarnessRequest) (response GetConnectHarnessResponse, err error) + func (client StreamAdminClient) GetStream(ctx context.Context, request GetStreamRequest) (response GetStreamResponse, err error) + func (client StreamAdminClient) GetStreamPool(ctx context.Context, request GetStreamPoolRequest) (response GetStreamPoolResponse, err error) + func (client StreamAdminClient) ListConnectHarnesses(ctx context.Context, request ListConnectHarnessesRequest) (response ListConnectHarnessesResponse, err error) + func (client StreamAdminClient) ListStreamPools(ctx context.Context, request ListStreamPoolsRequest) (response ListStreamPoolsResponse, err error) + func (client StreamAdminClient) ListStreams(ctx context.Context, request ListStreamsRequest) (response ListStreamsResponse, err error) + func (client StreamAdminClient) UpdateConnectHarness(ctx context.Context, request UpdateConnectHarnessRequest) (response UpdateConnectHarnessResponse, err error) + func (client StreamAdminClient) UpdateStream(ctx context.Context, request UpdateStreamRequest) (response UpdateStreamResponse, err error) + func (client StreamAdminClient) UpdateStreamPool(ctx context.Context, request UpdateStreamPoolRequest) (response UpdateStreamPoolResponse, err error) + type StreamClient struct + func NewStreamClientWithConfigurationProvider(configProvider common.ConfigurationProvider, endpoint string) (client StreamClient, err error) + func NewStreamClientWithOboToken(configProvider common.ConfigurationProvider, oboToken string, endpoint string) (client StreamClient, err error) + func (client *StreamClient) ConfigurationProvider() *common.ConfigurationProvider + func (client StreamClient) ConsumerCommit(ctx context.Context, request ConsumerCommitRequest) (response ConsumerCommitResponse, err error) + func (client StreamClient) ConsumerHeartbeat(ctx context.Context, request ConsumerHeartbeatRequest) (response ConsumerHeartbeatResponse, err error) + func (client StreamClient) CreateCursor(ctx context.Context, request CreateCursorRequest) (response CreateCursorResponse, err error) + func (client StreamClient) CreateGroupCursor(ctx context.Context, request CreateGroupCursorRequest) (response CreateGroupCursorResponse, err error) + func (client StreamClient) GetGroup(ctx context.Context, request GetGroupRequest) (response GetGroupResponse, err error) + func (client StreamClient) GetMessages(ctx context.Context, request GetMessagesRequest) (response GetMessagesResponse, err error) + func (client StreamClient) PutMessages(ctx context.Context, request PutMessagesRequest) (response PutMessagesResponse, err error) + func (client StreamClient) UpdateGroup(ctx context.Context, request UpdateGroupRequest) (response UpdateGroupResponse, err error) + type StreamLifecycleStateEnum string + const StreamLifecycleStateActive + const StreamLifecycleStateCreating + const StreamLifecycleStateDeleted + const StreamLifecycleStateDeleting + const StreamLifecycleStateFailed + const StreamLifecycleStateUpdating + func GetStreamLifecycleStateEnumValues() []StreamLifecycleStateEnum + type StreamPool struct + CompartmentId *string + CustomEncryptionKey *CustomEncryptionKey + DefinedTags map[string]map[string]interface{} + EndpointFqdn *string + FreeformTags map[string]string + Id *string + IsPrivate *bool + KafkaSettings *KafkaSettings + LifecycleState StreamPoolLifecycleStateEnum + LifecycleStateDetails *string + Name *string + PrivateEndpointSettings *PrivateEndpointSettings + TimeCreated *common.SDKTime + func (m StreamPool) String() string + type StreamPoolLifecycleStateEnum string + const StreamPoolLifecycleStateActive + const StreamPoolLifecycleStateCreating + const StreamPoolLifecycleStateDeleted + const StreamPoolLifecycleStateDeleting + const StreamPoolLifecycleStateFailed + const StreamPoolLifecycleStateUpdating + func GetStreamPoolLifecycleStateEnumValues() []StreamPoolLifecycleStateEnum + type StreamPoolSummary struct + CompartmentId *string + DefinedTags map[string]map[string]interface{} + FreeformTags map[string]string + Id *string + IsPrivate *bool + LifecycleState StreamPoolSummaryLifecycleStateEnum + Name *string + TimeCreated *common.SDKTime + func (m StreamPoolSummary) String() string + type StreamPoolSummaryLifecycleStateEnum string + const StreamPoolSummaryLifecycleStateActive + const StreamPoolSummaryLifecycleStateCreating + const StreamPoolSummaryLifecycleStateDeleted + const StreamPoolSummaryLifecycleStateDeleting + const StreamPoolSummaryLifecycleStateFailed + const StreamPoolSummaryLifecycleStateUpdating + func GetStreamPoolSummaryLifecycleStateEnumValues() []StreamPoolSummaryLifecycleStateEnum + type StreamSummary struct + CompartmentId *string + DefinedTags map[string]map[string]interface{} + FreeformTags map[string]string + Id *string + LifecycleState StreamSummaryLifecycleStateEnum + MessagesEndpoint *string + Name *string + Partitions *int + StreamPoolId *string + TimeCreated *common.SDKTime + func (m StreamSummary) String() string + type StreamSummaryLifecycleStateEnum string + const StreamSummaryLifecycleStateActive + const StreamSummaryLifecycleStateCreating + const StreamSummaryLifecycleStateDeleted + const StreamSummaryLifecycleStateDeleting + const StreamSummaryLifecycleStateFailed + const StreamSummaryLifecycleStateUpdating + func GetStreamSummaryLifecycleStateEnumValues() []StreamSummaryLifecycleStateEnum + type UpdateConnectHarnessDetails struct + DefinedTags map[string]map[string]interface{} + FreeformTags map[string]string + func (m UpdateConnectHarnessDetails) String() string + type UpdateConnectHarnessRequest struct + ConnectHarnessId *string + IfMatch *string + OpcRequestId *string + RequestMetadata common.RequestMetadata + func (request UpdateConnectHarnessRequest) HTTPRequest(method, path string) (http.Request, error) + func (request UpdateConnectHarnessRequest) RetryPolicy() *common.RetryPolicy + func (request UpdateConnectHarnessRequest) String() string + type UpdateConnectHarnessResponse struct + Etag *string + OpcRequestId *string + RawResponse *http.Response + func (response UpdateConnectHarnessResponse) HTTPResponse() *http.Response + func (response UpdateConnectHarnessResponse) String() string + type UpdateGroupDetails struct + Time *common.SDKTime + Type UpdateGroupDetailsTypeEnum + func (m UpdateGroupDetails) String() string + type UpdateGroupDetailsTypeEnum string + const UpdateGroupDetailsTypeAtTime + const UpdateGroupDetailsTypeLatest + const UpdateGroupDetailsTypeTrimHorizon + func GetUpdateGroupDetailsTypeEnumValues() []UpdateGroupDetailsTypeEnum + type UpdateGroupRequest struct + GroupName *string + OpcRequestId *string + RequestMetadata common.RequestMetadata + StreamId *string + func (request UpdateGroupRequest) HTTPRequest(method, path string) (http.Request, error) + func (request UpdateGroupRequest) RetryPolicy() *common.RetryPolicy + func (request UpdateGroupRequest) String() string + type UpdateGroupResponse struct + OpcRequestId *string + RawResponse *http.Response + func (response UpdateGroupResponse) HTTPResponse() *http.Response + func (response UpdateGroupResponse) String() string + type UpdateStreamDetails struct + DefinedTags map[string]map[string]interface{} + FreeformTags map[string]string + StreamPoolId *string + func (m UpdateStreamDetails) String() string + type UpdateStreamPoolDetails struct + CustomEncryptionKeyDetails *CustomEncryptionKeyDetails + DefinedTags map[string]map[string]interface{} + FreeformTags map[string]string + KafkaSettings *KafkaSettings + Name *string + func (m UpdateStreamPoolDetails) String() string + type UpdateStreamPoolRequest struct + IfMatch *string + OpcRequestId *string + RequestMetadata common.RequestMetadata + StreamPoolId *string + func (request UpdateStreamPoolRequest) HTTPRequest(method, path string) (http.Request, error) + func (request UpdateStreamPoolRequest) RetryPolicy() *common.RetryPolicy + func (request UpdateStreamPoolRequest) String() string + type UpdateStreamPoolResponse struct + Etag *string + OpcRequestId *string + RawResponse *http.Response + func (response UpdateStreamPoolResponse) HTTPResponse() *http.Response + func (response UpdateStreamPoolResponse) String() string + type UpdateStreamRequest struct + IfMatch *string + OpcRequestId *string + RequestMetadata common.RequestMetadata + StreamId *string + func (request UpdateStreamRequest) HTTPRequest(method, path string) (http.Request, error) + func (request UpdateStreamRequest) RetryPolicy() *common.RetryPolicy + func (request UpdateStreamRequest) String() string + type UpdateStreamResponse struct + Etag *string + OpcRequestId *string + RawResponse *http.Response + func (response UpdateStreamResponse) HTTPResponse() *http.Response + func (response UpdateStreamResponse) String() string Other modules containing this package github.com/oracle/oci-go-sdk github.com/oracle/oci-go-sdk/v25 github.com/oracle/oci-go-sdk/v26 github.com/oracle/oci-go-sdk/v27 github.com/oracle/oci-go-sdk/v28 github.com/oracle/oci-go-sdk/v29 github.com/oracle/oci-go-sdk/v30 github.com/oracle/oci-go-sdk/v31 github.com/oracle/oci-go-sdk/v32 github.com/oracle/oci-go-sdk/v33 github.com/oracle/oci-go-sdk/v34 github.com/oracle/oci-go-sdk/v35 github.com/oracle/oci-go-sdk/v36 github.com/oracle/oci-go-sdk/v38 github.com/oracle/oci-go-sdk/v39 github.com/oracle/oci-go-sdk/v40 github.com/oracle/oci-go-sdk/v41 github.com/oracle/oci-go-sdk/v42 github.com/oracle/oci-go-sdk/v43 github.com/oracle/oci-go-sdk/v44 github.com/oracle/oci-go-sdk/v45 github.com/oracle/oci-go-sdk/v46 github.com/oracle/oci-go-sdk/v47 github.com/oracle/oci-go-sdk/v48 github.com/oracle/oci-go-sdk/v49 github.com/oracle/oci-go-sdk/v50 github.com/oracle/oci-go-sdk/v51 github.com/oracle/oci-go-sdk/v52 github.com/oracle/oci-go-sdk/v53 github.com/oracle/oci-go-sdk/v54 github.com/oracle/oci-go-sdk/v55 github.com/oracle/oci-go-sdk/v56 github.com/oracle/oci-go-sdk/v57 github.com/oracle/oci-go-sdk/v58 github.com/oracle/oci-go-sdk/v59 github.com/oracle/oci-go-sdk/v60 github.com/oracle/oci-go-sdk/v61 github.com/oracle/oci-go-sdk/v62 github.com/oracle/oci-go-sdk/v63 github.com/oracle/oci-go-sdk/v64 github.com/oracle/oci-go-sdk/v65
Go to main page