Versions in this module Expand all Collapse all v0 v0.4.1 Mar 5, 2024 Changes in this version + type AcknowledgeCloudEventsOptions struct + type AcknowledgeCloudEventsResponse struct + type AcknowledgeResult struct + FailedLockTokens []FailedLockToken + SucceededLockTokens []string + func (a *AcknowledgeResult) UnmarshalJSON(data []byte) error + func (a AcknowledgeResult) MarshalJSON() ([]byte, error) + type BrokerProperties struct + DeliveryCount *int32 + LockToken *string + func (b *BrokerProperties) UnmarshalJSON(data []byte) error + func (b BrokerProperties) MarshalJSON() ([]byte, error) + type Client struct + func NewClientWithSharedKeyCredential(endpoint string, keyCred *azcore.KeyCredential, options *ClientOptions) (*Client, error) + func (client *Client) AcknowledgeCloudEvents(ctx context.Context, topicName string, eventSubscriptionName string, ...) (AcknowledgeCloudEventsResponse, error) + func (client *Client) PublishCloudEvent(ctx context.Context, topicName string, event messaging.CloudEvent, ...) (PublishCloudEventResponse, error) + func (client *Client) PublishCloudEvents(ctx context.Context, topicName string, events []messaging.CloudEvent, ...) (PublishCloudEventsResponse, error) + func (client *Client) ReceiveCloudEvents(ctx context.Context, topicName string, eventSubscriptionName string, ...) (ReceiveCloudEventsResponse, error) + func (client *Client) RejectCloudEvents(ctx context.Context, topicName string, eventSubscriptionName string, ...) (RejectCloudEventsResponse, error) + func (client *Client) ReleaseCloudEvents(ctx context.Context, topicName string, eventSubscriptionName string, ...) (ReleaseCloudEventsResponse, error) + func (client *Client) RenewCloudEventLocks(ctx context.Context, topicName string, eventSubscriptionName string, ...) (RenewCloudEventLocksResponse, error) + type ClientOptions struct + type Error struct + Code *string + func (e *Error) Error() string + func (e *Error) UnmarshalJSON(data []byte) error + func (e Error) MarshalJSON() ([]byte, error) + type FailedLockToken struct + Error *Error + LockToken *string + func (f *FailedLockToken) UnmarshalJSON(data []byte) error + func (f FailedLockToken) MarshalJSON() ([]byte, error) + type PublishCloudEventOptions struct + type PublishCloudEventResponse struct + type PublishCloudEventsOptions struct + type PublishCloudEventsResponse struct + type ReceiveCloudEventsOptions struct + MaxEvents *int32 + MaxWaitTime *int32 + type ReceiveCloudEventsResponse struct + type ReceiveDetails struct + BrokerProperties *BrokerProperties + Event messaging.CloudEvent + func (r *ReceiveDetails) UnmarshalJSON(data []byte) error + func (r ReceiveDetails) MarshalJSON() ([]byte, error) + type ReceiveResult struct + Value []ReceiveDetails + func (r *ReceiveResult) UnmarshalJSON(data []byte) error + func (r ReceiveResult) MarshalJSON() ([]byte, error) + type RejectCloudEventsOptions struct + type RejectCloudEventsResponse struct + type RejectResult struct + FailedLockTokens []FailedLockToken + SucceededLockTokens []string + func (r *RejectResult) UnmarshalJSON(data []byte) error + func (r RejectResult) MarshalJSON() ([]byte, error) + type ReleaseCloudEventsOptions struct + ReleaseDelayInSeconds *ReleaseDelay + type ReleaseCloudEventsResponse struct + type ReleaseDelay int32 + const ReleaseDelayBy0Seconds + const ReleaseDelayBy10Seconds + const ReleaseDelayBy3600Seconds + const ReleaseDelayBy600Seconds + const ReleaseDelayBy60Seconds + func PossibleReleaseDelayValues() []ReleaseDelay + type ReleaseResult struct + FailedLockTokens []FailedLockToken + SucceededLockTokens []string + func (r *ReleaseResult) UnmarshalJSON(data []byte) error + func (r ReleaseResult) MarshalJSON() ([]byte, error) + type RenewCloudEventLocksOptions struct + type RenewCloudEventLocksResponse struct + type RenewCloudEventLocksResult struct + FailedLockTokens []FailedLockToken + SucceededLockTokens []string + func (r *RenewCloudEventLocksResult) UnmarshalJSON(data []byte) error + func (r RenewCloudEventLocksResult) MarshalJSON() ([]byte, error)