Skip to content

Commit

Permalink
feat: added broadcast method for sending events
Browse files Browse the repository at this point in the history
  • Loading branch information
subomi committed Oct 3, 2024
1 parent 0c32a43 commit daaa03d
Showing 1 changed file with 21 additions and 0 deletions.
21 changes: 21 additions & 0 deletions event.go
Original file line number Diff line number Diff line change
Expand Up @@ -33,6 +33,13 @@ type CreateFanoutEventRequest struct {
Data json.RawMessage `json:"data"`
}

type CreateBroadcastEventRequest struct {
EventType string `json:"event_type"`
CustomHeaders map[string]string `json:"custom_headers"`
IdempotencyKey string `json:"idempotency_key"`
Data json.RawMessage `json:"data"`
}

type CreateDynamicEventRequest struct {
Endpoint string `json:"endpoint"`
Subscription string `json:"subscription"`
Expand Down Expand Up @@ -120,6 +127,20 @@ func (e *Event) FanoutEvent(ctx context.Context, body *CreateFanoutEventRequest)
return nil
}

func (e *Event) BroadcastEvent(ctx context.Context, body *CreateBroadcastEventRequest) error {
url, err := addOptions(e.generateUrl()+"/broadcast", nil)
if err != nil {
return err
}

err = postJSON(ctx, e.client, url, body, nil)
if err != nil {
return err
}

return nil
}

func (e *Event) Find(ctx context.Context, eventID string) (*EventResponse, error) {
url, err := addOptions(e.generateUrl()+"/"+eventID, nil)
if err != nil {
Expand Down

0 comments on commit daaa03d

Please sign in to comment.