Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

aznamespaces

package module

Go to main page

Versions in this module

v1

v1.0.0

Jun 11, 2024

Changes in this version

+ type AcknowledgeEventsOptions struct

+ type AcknowledgeEventsResponse struct

+ type AcknowledgeEventsResult struct

+ FailedLockTokens []FailedLockToken

+ SucceededLockTokens []string

+ func (a *AcknowledgeEventsResult) UnmarshalJSON(data []byte) error

+ func (a AcknowledgeEventsResult) MarshalJSON() ([]byte, error)

type Error

+ Message *string

+ type ReceiveEventsOptions struct

+ MaxEvents *int32

+ MaxWaitTime *int32

+ type ReceiveEventsResponse struct

+ type ReceiveEventsResult struct

+ Details []ReceiveDetails

+ func (r *ReceiveEventsResult) UnmarshalJSON(data []byte) error

+ func (r ReceiveEventsResult) MarshalJSON() ([]byte, error)

+ type ReceiverClient struct

+ func NewReceiverClient(endpoint string, topic string, subscription string, ...) (*ReceiverClient, error)

+ func NewReceiverClientWithSharedKeyCredential(endpoint string, topic string, subscription string, ...) (*ReceiverClient, error)

+ func (client *ReceiverClient) AcknowledgeEvents(ctx context.Context, lockTokens []string, options *AcknowledgeEventsOptions) (AcknowledgeEventsResponse, error)

+ func (client *ReceiverClient) ReceiveEvents(ctx context.Context, options *ReceiveEventsOptions) (ReceiveEventsResponse, error)

+ func (client *ReceiverClient) RejectEvents(ctx context.Context, lockTokens []string, options *RejectEventsOptions) (RejectEventsResponse, error)

+ func (client *ReceiverClient) ReleaseEvents(ctx context.Context, lockTokens []string, options *ReleaseEventsOptions) (ReleaseEventsResponse, error)

+ func (client *ReceiverClient) RenewEventLocks(ctx context.Context, lockTokens []string, options *RenewEventLocksOptions) (RenewEventLocksResponse, error)

+ type ReceiverClientOptions struct

+ type RejectEventsOptions struct

+ type RejectEventsResponse struct

+ type RejectEventsResult struct

+ FailedLockTokens []FailedLockToken

+ SucceededLockTokens []string

+ func (r *RejectEventsResult) UnmarshalJSON(data []byte) error

+ func (r RejectEventsResult) MarshalJSON() ([]byte, error)

type ReleaseDelay

+ const ReleaseDelayNoDelay

+ const ReleaseDelayOneHour

+ const ReleaseDelayOneMinute

+ const ReleaseDelayTenMinutes

+ const ReleaseDelayTenSeconds

+ type ReleaseEventsOptions struct

+ ReleaseDelayInSeconds *ReleaseDelay

+ type ReleaseEventsResponse struct

+ type ReleaseEventsResult struct

+ FailedLockTokens []FailedLockToken

+ SucceededLockTokens []string

+ func (r *ReleaseEventsResult) UnmarshalJSON(data []byte) error

+ func (r ReleaseEventsResult) MarshalJSON() ([]byte, error)

+ type RenewEventLocksOptions struct

+ type RenewEventLocksResponse struct

+ type RenewEventLocksResult struct

+ FailedLockTokens []FailedLockToken

+ SucceededLockTokens []string

+ func (r *RenewEventLocksResult) UnmarshalJSON(data []byte) error

+ func (r RenewEventLocksResult) MarshalJSON() ([]byte, error)

+ type SendEventOptions struct

+ type SendEventResponse struct

+ type SendEventsOptions struct

+ type SendEventsResponse struct

+ type SenderClient struct

+ func NewSenderClient(endpoint string, topic string, cred azcore.TokenCredential, ...) (*SenderClient, error)

+ func NewSenderClientWithSharedKeyCredential(endpoint string, topic string, keyCred *azcore.KeyCredential, ...) (*SenderClient, error)

+ func (client *SenderClient) SendEvent(ctx context.Context, event *messaging.CloudEvent, options *SendEventOptions) (SendEventResponse, error)

+ func (client *SenderClient) SendEvents(ctx context.Context, events []*messaging.CloudEvent, ...) (SendEventsResponse, error)

+ type SenderClientOptions struct

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)