azeventgrid

package module

Go to main page

Versions in this module

v0

deprecated

v0.5.0

Mar 27, 2024

v0.4.0

Nov 28, 2023

Changes in this version

type Client

+ func (client *Client) PublishCloudEvent(ctx context.Context, topicName string, event messaging.CloudEvent, ...) (PublishCloudEventResponse, error)

+ func (client *Client) RenewCloudEventLocks(ctx context.Context, topicName string, eventSubscriptionName string, ...) (RenewCloudEventLocksResponse, error)

+ 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

+ Error *Error

+ type PublishCloudEventOptions struct

+ type PublishCloudEventResponse struct

type ReleaseCloudEventsOptions

+ ReleaseDelayInSeconds *ReleaseDelay

+ type ReleaseDelay int32

+ const ReleaseDelayBy0Seconds

+ const ReleaseDelayBy10Seconds

+ const ReleaseDelayBy3600Seconds

+ const ReleaseDelayBy600Seconds

+ const ReleaseDelayBy60Seconds

+ func PossibleReleaseDelayValues() []ReleaseDelay

+ 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)

v0.3.0

Oct 17, 2023

v0.2.0

Sep 12, 2023

v0.1.0

Jul 12, 2023

Changes in this version

+ type AcknowledgeCloudEventsOptions struct

+ type AcknowledgeCloudEventsResponse struct

+ type AcknowledgeOptions struct

+ LockTokens []string

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

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

+ 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, key string, options *ClientOptions) (*Client, error)

+ func (client *Client) AcknowledgeCloudEvents(ctx context.Context, topicName string, eventSubscriptionName string, ...) (AcknowledgeCloudEventsResponse, 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)

+ type ClientOptions struct

+ type FailedLockToken struct

+ ErrorCode *string

+ ErrorDescription *string

+ LockToken *string

+ func (f *FailedLockToken) UnmarshalJSON(data []byte) error

+ func (f FailedLockToken) MarshalJSON() ([]byte, error)

+ 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 RejectOptions struct

+ LockTokens []string

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

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

+ type RejectResult struct

+ FailedLockTokens []FailedLockToken

+ SucceededLockTokens []string

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

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

+ type ReleaseCloudEventsOptions struct

+ type ReleaseCloudEventsResponse struct

+ type ReleaseOptions struct

+ LockTokens []string

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

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

+ type ReleaseResult struct

+ FailedLockTokens []FailedLockToken

+ SucceededLockTokens []string

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

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL