Versions in this module Expand all Collapse all v1 v1.0.0 Apr 2, 2024 v0 v0.1.0 Mar 5, 2024 Changes in this version + type Client struct + func NewClient(endpoint string, tokenCredential azcore.TokenCredential, ...) (*Client, error) + func NewClientWithSAS(endpoint string, sasCred *azcore.SASCredential, options *ClientOptions) (*Client, error) + func NewClientWithSharedKeyCredential(endpoint string, keyCred *azcore.KeyCredential, options *ClientOptions) (*Client, error) + func (client *Client) PublishCloudEvents(ctx context.Context, events []messaging.CloudEvent, ...) (PublishCloudEventsResponse, error) + func (client *Client) PublishCustomEventEvents(ctx context.Context, events []any, options *PublishCustomEventEventsOptions) (PublishCustomEventEventsResponse, error) + func (client *Client) PublishEvents(ctx context.Context, events []Event, options *PublishEventsOptions) (PublishEventsResponse, error) + type ClientOptions struct + type Event struct + Data any + DataVersion *string + EventTime *time.Time + EventType *string + ID *string + MetadataVersion *string + Subject *string + Topic *string + func (e *Event) UnmarshalJSON(data []byte) error + func (e Event) MarshalJSON() ([]byte, error) + type PublishCloudEventsOptions struct + AegChannelName *string + type PublishCloudEventsResponse struct + type PublishCustomEventEventsOptions struct + type PublishCustomEventEventsResponse struct + type PublishEventsOptions struct + type PublishEventsResponse struct