-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathevent.go
663 lines (617 loc) · 27.8 KB
/
event.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
// File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
package orb
import (
"context"
"errors"
"fmt"
"net/http"
"net/url"
"time"
"github.com/orbcorp/orb-go/internal/apijson"
"github.com/orbcorp/orb-go/internal/apiquery"
"github.com/orbcorp/orb-go/internal/param"
"github.com/orbcorp/orb-go/internal/requestconfig"
"github.com/orbcorp/orb-go/option"
)
// EventService contains methods and other services that help with interacting with
// the orb API.
//
// Note, unlike clients, this service does not read variables from the environment
// automatically. You should not instantiate this service directly, and instead use
// the [NewEventService] method instead.
type EventService struct {
Options []option.RequestOption
Backfills *EventBackfillService
Volume *EventVolumeService
}
// NewEventService generates a new service that applies the given options to each
// request. These options are applied after the parent client's options (if there
// is one), and before any request-specific options.
func NewEventService(opts ...option.RequestOption) (r *EventService) {
r = &EventService{}
r.Options = opts
r.Backfills = NewEventBackfillService(opts...)
r.Volume = NewEventVolumeService(opts...)
return
}
// This endpoint is used to amend a single usage event with a given `event_id`.
// `event_id` refers to the `idempotency_key` passed in during ingestion. The event
// will maintain its existing `event_id` after the amendment.
//
// This endpoint will mark the existing event as ignored, and Orb will only use the
// new event passed in the body of this request as the source of truth for that
// `event_id`. Note that a single event can be amended any number of times, so the
// same event can be overwritten in subsequent calls to this endpoint. Only a
// single event with a given `event_id` will be considered the source of truth at
// any given time.
//
// This is a powerful and audit-safe mechanism to retroactively update a single
// event in cases where you need to:
//
// - update an event with new metadata as you iterate on your pricing model
// - update an event based on the result of an external API call (e.g. call to a
// payment gateway succeeded or failed)
//
// This amendment API is always audit-safe. The process will still retain the
// original event, though it will be ignored for billing calculations. For auditing
// and data fidelity purposes, Orb never overwrites or permanently deletes ingested
// usage data.
//
// ## Request validation
//
// - The `timestamp` of the new event must match the `timestamp` of the existing
// event already ingested. As with ingestion, all timestamps must be sent in
// ISO8601 format with UTC timezone offset.
// - The `customer_id` or `external_customer_id` of the new event must match the
// `customer_id` or `external_customer_id` of the existing event already
// ingested. Exactly one of `customer_id` and `external_customer_id` should be
// specified, and similar to ingestion, the ID must identify a Customer resource
// within Orb. Unlike ingestion, for event amendment, we strictly enforce that
// the Customer must be in the Orb system, even during the initial integration
// period. We do not allow updating the `Customer` an event is associated with.
// - Orb does not accept an `idempotency_key` with the event in this endpoint,
// since this request is by design idempotent. On retryable errors, you should
// retry the request and assume the amendment operation has not succeeded until
// receipt of a 2xx.
// - The event's `timestamp` must fall within the customer's current subscription's
// billing period, or within the grace period of the customer's current
// subscription's previous billing period.
// - By default, no more than 100 events can be amended for a single customer in a
// 100 day period. For higher volume updates, consider using the
// [event backfill](create-backfill) endpoint.
func (r *EventService) Update(ctx context.Context, eventID string, body EventUpdateParams, opts ...option.RequestOption) (res *EventUpdateResponse, err error) {
opts = append(r.Options[:], opts...)
if eventID == "" {
err = errors.New("missing required event_id parameter")
return
}
path := fmt.Sprintf("events/%s", eventID)
err = requestconfig.ExecuteNewRequest(ctx, http.MethodPut, path, body, &res, opts...)
return
}
// This endpoint is used to deprecate a single usage event with a given `event_id`.
// `event_id` refers to the `idempotency_key` passed in during ingestion.
//
// This endpoint will mark the existing event as ignored. Note that if you attempt
// to re-ingest an event with the same `event_id` as a deprecated event, Orb will
// return an error.
//
// This is a powerful and audit-safe mechanism to retroactively deprecate a single
// event in cases where you need to:
//
// - no longer bill for an event that was improperly reported
// - no longer bill for an event based on the result of an external API call (e.g.
// call to a payment gateway failed and the user should not be billed)
//
// If you want to only change specific properties of an event, but keep the event
// as part of the billing calculation, use the [Amend single event](amend-event)
// endpoint instead.
//
// This API is always audit-safe. The process will still retain the deprecated
// event, though it will be ignored for billing calculations. For auditing and data
// fidelity purposes, Orb never overwrites or permanently deletes ingested usage
// data.
//
// ## Request validation
//
// - Orb does not accept an `idempotency_key` with the event in this endpoint,
// since this request is by design idempotent. On retryable errors, you should
// retry the request and assume the deprecation operation has not succeeded until
// receipt of a 2xx.
// - The event's `timestamp` must fall within the customer's current subscription's
// billing period, or within the grace period of the customer's current
// subscription's previous billing period. Orb does not allow deprecating events
// for billing periods that have already invoiced customers.
// - The `customer_id` or the `external_customer_id` of the original event
// ingestion request must identify a Customer resource within Orb, even if this
// event was ingested during the initial integration period. We do not allow
// deprecating events for customers not in the Orb system.
// - By default, no more than 100 events can be deprecated for a single customer in
// a 100 day period. For higher volume updates, consider using the
// [event backfill](create-backfill) endpoint.
func (r *EventService) Deprecate(ctx context.Context, eventID string, opts ...option.RequestOption) (res *EventDeprecateResponse, err error) {
opts = append(r.Options[:], opts...)
if eventID == "" {
err = errors.New("missing required event_id parameter")
return
}
path := fmt.Sprintf("events/%s/deprecate", eventID)
err = requestconfig.ExecuteNewRequest(ctx, http.MethodPut, path, nil, &res, opts...)
return
}
// Orb's event ingestion model and API is designed around two core principles:
//
// 1. **Data fidelity**: The accuracy of your billing model depends on a robust
// foundation of events. Orb's API protocol encourages usage patterns that
// ensure that your data is consistently complete and correct.
// 2. **Fast integration**: Sending events into Orb requires no tedious setup steps
// or explicit field schema for your event shape, making it instant to start
// streaming in usage in real-time.
//
// ## Event shape
//
// Events are the starting point for all usage calculations in the system, and are
// simple at their core:
//
// ```ts
//
// {
// // customer_id and external_customer_id are used to
// // attribute usage to a given Customer. Exactly one of these
// // should be specified in a given ingestion event.
//
// // `customer_id` is the Orb generated identifier for the Customer,
// // which is returned from the Create customer API call.
// customer_id: string,
//
// // external_customer_id is an alternate identifier which is associated
// // with a Customer at creation time. This is treated as an alias for
// // customer_id, and is usually set to an identifier native to your system.
// external_customer_id: string,
//
// // A string name identifying the event, usually a usage
// // action. By convention, this should not contain any whitespace.
// event_name: string,
//
// // An ISO 8601 format date with no timezone offset.
// // This should represent the time that usage occurred
// // and is important to attribute usage to a given
// // billing period. See the notes below on determining the timestamp.
// // e.g. 2020-12-09T16:09:53Z
// timestamp: string,
//
// // A unique value, generated by the client, that is
// // used to de-duplicate events.
// // Exactly one event with a given
// // idempotency key will be ingested, which allows for
// // safe request retries.
// idempotency_key: string
//
// // Optional custom metadata to attach to the event.
// // This might include a numeric value used for aggregation,
// // or a string/boolean value used for filtering.
// // The schema of this dictionary need not be pre-declared, and
// // properties can be added at any time.
// properties: {
// [key: string]?: string | number | boolean,
// },
// }
//
// ```
//
// ## Required fields
//
// Because events streamed to Orb are meant to be as flexible as possible, there
// are only a few required fields in every event.
//
// - We recommend that `idempotency_key` are unique strings that you generated with
// V4 UUIDs, but only require that they uniquely identify an event (i.e. don’t
// collide).
// - The `timestamp` field in the event body will be used to determine which
// billable period a given event falls into. For example, with a monthly billing
// cycle starting from the first of December, Orb will calculate metrics based on
// events that fall into the range
// `12-01 00:00:00 <= timestamp < 01-01 00:00:00`.
//
// ## Logging metadata
//
// Orb allows tagging events with metadata using a flexible properties dictionary.
// Since Orb does not enforce a rigid schema for this field-set, key-value pairs
// can be added dynamically as your events evolve.
//
// This dictionary can be helpful for a wide variety of use cases:
//
// - Numeric properties on events like `compute_time_ms` can later be inputs to our
// flexible query engine to determine usage.
// - Logging a region or cluster with each event can help you provide customers
// more granular visibility into their usage.
//
// We encourage logging this metadata with an eye towards future use cases to
// ensure full coverage for historical data. The datatype of the value in the
// properties dictionary is important for metric creation from an event source.
// Values that you wish to numerically aggregate should be of numeric type in the
// event.
//
// ## Determining event timestamp
//
// For cases where usage is being reported in real time as it is occurring,
// timestamp should correspond to the time that usage occurred.
//
// In cases where usage is reported in aggregate for a historical timeframe at a
// regular interval, we recommend setting the event `timestamp` to the midpoint of
// the interval. As an example, if you have an hourly reporter that sends data once
// an hour for the previous hour of usage, setting the `timestamp` to the half-hour
// mark will ensure that the usage is counted within the correct period.
//
// Note that other time-related fields (e.g. time elapsed) can be added to the
// properties dictionary as necessary.
//
// In cases where usage is reported in aggregate for a historical timeframe, the
// timestamp must be within the grace period set for your account. Events with
// `timestamp < current_time - grace_period` will not be accepted as a valid event,
// and will throw validation errors. Enforcing the grace period enables Orb to
// accurately map usage to the correct billing cycle and ensure that all usage is
// billed for in the corresponding billing period.
//
// In general, Orb does not expect events with future dated timestamps. In cases
// where the timestamp is at least 24 hours ahead of the current time, the event
// will not be accepted as a valid event, and will throw validation errors.
//
// ## Event validation
//
// Orb’s validation ensures that you recognize errors in your events as quickly as
// possible, and the API provides informative error messages to help you fix
// problems quickly.
//
// We validate the following:
//
// - Exactly one of `customer_id` and `external_customer_id` should be specified.
// - If the `customer_id` is specified, the customer in Orb must exist.
// - If the `external_customer_id` is specified, the customer in Orb does not need
// to exist. Events will be attributed to any future customers with the
// `external_customer_id` on subscription creation.
// - `timestamp` must conform to ISO 8601 and represent a timestamp at most 1 hour
// in the future. This timestamp should be sent in UTC timezone (no timezone
// offset).
//
// ## Idempotency and retry semantics
//
// Orb's idempotency guarantees allow you to implement safe retry logic in the
// event of network or machine failures, ensuring data fidelity. Each event in the
// request payload is associated with an idempotency key, and Orb guarantees that a
// single idempotency key will be successfully ingested at most once. Note that
// when Orb encounters events with duplicate idempotency keys and differing event
// bodies in a batch of events, the entire batch will be rejected.
//
// - Successful responses return a 200 HTTP status code. The response contains
// information about previously processed events.
// - Requests that return a `4xx` HTTP status code indicate a payload error and
// contain at least one event with a validation failure. An event with a
// validation failure can be re-sent to the ingestion endpoint (after the payload
// is fixed) with the original idempotency key since that key is not marked as
// processed.
// - Requests that return a `5xx` HTTP status code indicate a server-side failure.
// These requests should be retried in their entirety.
//
// ## API usage and limits
//
// The ingestion API is designed made for real-time streaming ingestion and
// architected for high throughput. Even if events are later deemed unnecessary or
// filtered out, we encourage you to log them to Orb if they may be relevant to
// billing calculations in the future.
//
// To take advantage of the real-time features of the Orb platform and avoid any
// chance of dropped events by producers, we recommend reporting events to Orb
// frequently. Optionally, events can also be briefly aggregated at the source, as
// this API accepts an array of event bodies.
//
// Orb does not currently enforce a hard rate-limit for API usage or a maximum
// request payload size, but please give us a heads up if you’re changing either of
// these factors by an order of magnitude from initial setup.
//
// ## Testing in debug mode
//
// The ingestion API supports a debug mode, which returns additional verbose output
// to indicate which event idempotency keys were newly ingested or duplicates from
// previous requests. To enable this mode, mark `debug=true` as a query parameter.
//
// If `debug=true` is not specified, the response will only contain
// `validation_failed`. Orb will still honor the idempotency guarantees set
// [here](../guides/events-and-metrics/event-ingestion#event-volume-and-concurrency)
// in all cases.
//
// We strongly recommend that you only use debug mode as part of testing your
// initial Orb integration. Once you're ready to switch to production, disable
// debug mode to take advantage of improved performance and maximal throughput.
//
// #### Example: ingestion response with `debug=true`
//
// ```json
//
// {
// "debug": {
// "duplicate": [],
// "ingested": ["B7E83HDMfJPAunXW", "SJs5DQJ3TnwSqEZE", "8SivfDsNKwCeAXim"]
// },
// "validation_failed": []
// }
//
// ```
//
// #### Example: ingestion response with `debug=false`
//
// ```json
//
// {
// "validation_failed": []
// }
//
// ```
func (r *EventService) Ingest(ctx context.Context, params EventIngestParams, opts ...option.RequestOption) (res *EventIngestResponse, err error) {
opts = append(r.Options[:], opts...)
path := "ingest"
err = requestconfig.ExecuteNewRequest(ctx, http.MethodPost, path, params, &res, opts...)
return
}
// This endpoint returns a filtered set of events for an account in a
// [paginated list format](../reference/pagination).
//
// Note that this is a `POST` endpoint rather than a `GET` endpoint because it
// employs a JSON body for search criteria rather than query parameters, allowing
// for a more flexible search syntax.
//
// Note that a search criteria _must_ be specified. Currently, Orb supports the
// following criteria:
//
// - `event_ids`: This is an explicit array of IDs to filter by. Note that an
// event's ID is the `idempotency_key` that was originally used for ingestion.
//
// By default, Orb will not throw a `404` if no events matched, Orb will return an
// empty array for `data` instead.
func (r *EventService) Search(ctx context.Context, body EventSearchParams, opts ...option.RequestOption) (res *EventSearchResponse, err error) {
opts = append(r.Options[:], opts...)
path := "events/search"
err = requestconfig.ExecuteNewRequest(ctx, http.MethodPost, path, body, &res, opts...)
return
}
type EventUpdateResponse struct {
// event_id of the amended event, if successfully ingested
Amended string `json:"amended,required"`
JSON eventUpdateResponseJSON `json:"-"`
}
// eventUpdateResponseJSON contains the JSON metadata for the struct
// [EventUpdateResponse]
type eventUpdateResponseJSON struct {
Amended apijson.Field
raw string
ExtraFields map[string]apijson.Field
}
func (r *EventUpdateResponse) UnmarshalJSON(data []byte) (err error) {
return apijson.UnmarshalRoot(data, r)
}
func (r eventUpdateResponseJSON) RawJSON() string {
return r.raw
}
type EventDeprecateResponse struct {
// event_id of the deprecated event, if successfully updated
Deprecated string `json:"deprecated,required"`
JSON eventDeprecateResponseJSON `json:"-"`
}
// eventDeprecateResponseJSON contains the JSON metadata for the struct
// [EventDeprecateResponse]
type eventDeprecateResponseJSON struct {
Deprecated apijson.Field
raw string
ExtraFields map[string]apijson.Field
}
func (r *EventDeprecateResponse) UnmarshalJSON(data []byte) (err error) {
return apijson.UnmarshalRoot(data, r)
}
func (r eventDeprecateResponseJSON) RawJSON() string {
return r.raw
}
type EventIngestResponse struct {
// Contains all failing validation events. In the case of a 200, this array will
// always be empty. This field will always be present.
ValidationFailed []EventIngestResponseValidationFailed `json:"validation_failed,required"`
// Optional debug information (only present when debug=true is passed to the
// endpoint). Contains ingested and duplicate event idempotency keys.
Debug EventIngestResponseDebug `json:"debug,nullable"`
JSON eventIngestResponseJSON `json:"-"`
}
// eventIngestResponseJSON contains the JSON metadata for the struct
// [EventIngestResponse]
type eventIngestResponseJSON struct {
ValidationFailed apijson.Field
Debug apijson.Field
raw string
ExtraFields map[string]apijson.Field
}
func (r *EventIngestResponse) UnmarshalJSON(data []byte) (err error) {
return apijson.UnmarshalRoot(data, r)
}
func (r eventIngestResponseJSON) RawJSON() string {
return r.raw
}
type EventIngestResponseValidationFailed struct {
// The passed idempotency_key corresponding to the validation_errors
IdempotencyKey string `json:"idempotency_key,required"`
// An array of strings corresponding to validation failures for this
// idempotency_key.
ValidationErrors []string `json:"validation_errors,required"`
JSON eventIngestResponseValidationFailedJSON `json:"-"`
}
// eventIngestResponseValidationFailedJSON contains the JSON metadata for the
// struct [EventIngestResponseValidationFailed]
type eventIngestResponseValidationFailedJSON struct {
IdempotencyKey apijson.Field
ValidationErrors apijson.Field
raw string
ExtraFields map[string]apijson.Field
}
func (r *EventIngestResponseValidationFailed) UnmarshalJSON(data []byte) (err error) {
return apijson.UnmarshalRoot(data, r)
}
func (r eventIngestResponseValidationFailedJSON) RawJSON() string {
return r.raw
}
// Optional debug information (only present when debug=true is passed to the
// endpoint). Contains ingested and duplicate event idempotency keys.
type EventIngestResponseDebug struct {
Duplicate []string `json:"duplicate,required"`
Ingested []string `json:"ingested,required"`
JSON eventIngestResponseDebugJSON `json:"-"`
}
// eventIngestResponseDebugJSON contains the JSON metadata for the struct
// [EventIngestResponseDebug]
type eventIngestResponseDebugJSON struct {
Duplicate apijson.Field
Ingested apijson.Field
raw string
ExtraFields map[string]apijson.Field
}
func (r *EventIngestResponseDebug) UnmarshalJSON(data []byte) (err error) {
return apijson.UnmarshalRoot(data, r)
}
func (r eventIngestResponseDebugJSON) RawJSON() string {
return r.raw
}
type EventSearchResponse struct {
Data []EventSearchResponseData `json:"data,required"`
JSON eventSearchResponseJSON `json:"-"`
}
// eventSearchResponseJSON contains the JSON metadata for the struct
// [EventSearchResponse]
type eventSearchResponseJSON struct {
Data apijson.Field
raw string
ExtraFields map[string]apijson.Field
}
func (r *EventSearchResponse) UnmarshalJSON(data []byte) (err error) {
return apijson.UnmarshalRoot(data, r)
}
func (r eventSearchResponseJSON) RawJSON() string {
return r.raw
}
// The [Event](../guides/core-concepts.mdx#event) resource represents a usage event
// that has been created for a customer. Events are the core of Orb's usage-based
// billing model, and are used to calculate the usage charges for a given billing
// period.
type EventSearchResponseData struct {
// A unique value, generated by the client, that is used to de-duplicate events.
// Exactly one event with a given idempotency key will be ingested, which allows
// for safe request retries.
ID string `json:"id,required"`
// The Orb Customer identifier
CustomerID string `json:"customer_id,required,nullable"`
// A boolean indicating whether the event is currently deprecated.
Deprecated bool `json:"deprecated,required"`
// A name to meaningfully identify the action or event type.
EventName string `json:"event_name,required"`
// An alias for the Orb customer, whose mapping is specified when creating the
// customer
ExternalCustomerID string `json:"external_customer_id,required,nullable"`
// A dictionary of custom properties. Values in this dictionary must be numeric,
// boolean, or strings. Nested dictionaries are disallowed.
Properties interface{} `json:"properties,required"`
// An ISO 8601 format date with no timezone offset (i.e. UTC). This should
// represent the time that usage was recorded, and is particularly important to
// attribute usage to a given billing period.
Timestamp time.Time `json:"timestamp,required" format:"date-time"`
JSON eventSearchResponseDataJSON `json:"-"`
}
// eventSearchResponseDataJSON contains the JSON metadata for the struct
// [EventSearchResponseData]
type eventSearchResponseDataJSON struct {
ID apijson.Field
CustomerID apijson.Field
Deprecated apijson.Field
EventName apijson.Field
ExternalCustomerID apijson.Field
Properties apijson.Field
Timestamp apijson.Field
raw string
ExtraFields map[string]apijson.Field
}
func (r *EventSearchResponseData) UnmarshalJSON(data []byte) (err error) {
return apijson.UnmarshalRoot(data, r)
}
func (r eventSearchResponseDataJSON) RawJSON() string {
return r.raw
}
type EventUpdateParams struct {
// A name to meaningfully identify the action or event type.
EventName param.Field[string] `json:"event_name,required"`
// A dictionary of custom properties. Values in this dictionary must be numeric,
// boolean, or strings. Nested dictionaries are disallowed.
Properties param.Field[interface{}] `json:"properties,required"`
// An ISO 8601 format date with no timezone offset (i.e. UTC). This should
// represent the time that usage was recorded, and is particularly important to
// attribute usage to a given billing period.
Timestamp param.Field[time.Time] `json:"timestamp,required" format:"date-time"`
// The Orb Customer identifier
CustomerID param.Field[string] `json:"customer_id"`
// An alias for the Orb customer, whose mapping is specified when creating the
// customer
ExternalCustomerID param.Field[string] `json:"external_customer_id"`
}
func (r EventUpdateParams) MarshalJSON() (data []byte, err error) {
return apijson.MarshalRoot(r)
}
type EventIngestParams struct {
Events param.Field[[]EventIngestParamsEvent] `json:"events,required"`
// If this ingestion request is part of a backfill, this parameter ties the
// ingested events to the backfill
BackfillID param.Field[string] `query:"backfill_id"`
// Flag to enable additional debug information in the endpoint response
Debug param.Field[bool] `query:"debug"`
}
func (r EventIngestParams) MarshalJSON() (data []byte, err error) {
return apijson.MarshalRoot(r)
}
// URLQuery serializes [EventIngestParams]'s query parameters as `url.Values`.
func (r EventIngestParams) URLQuery() (v url.Values) {
return apiquery.MarshalWithSettings(r, apiquery.QuerySettings{
ArrayFormat: apiquery.ArrayQueryFormatBrackets,
NestedFormat: apiquery.NestedQueryFormatBrackets,
})
}
type EventIngestParamsEvent struct {
// A name to meaningfully identify the action or event type.
EventName param.Field[string] `json:"event_name,required"`
// A unique value, generated by the client, that is used to de-duplicate events.
// Exactly one event with a given idempotency key will be ingested, which allows
// for safe request retries.
IdempotencyKey param.Field[string] `json:"idempotency_key,required"`
// A dictionary of custom properties. Values in this dictionary must be numeric,
// boolean, or strings. Nested dictionaries are disallowed.
Properties param.Field[interface{}] `json:"properties,required"`
// An ISO 8601 format date with no timezone offset (i.e. UTC). This should
// represent the time that usage was recorded, and is particularly important to
// attribute usage to a given billing period.
Timestamp param.Field[time.Time] `json:"timestamp,required" format:"date-time"`
// The Orb Customer identifier
CustomerID param.Field[string] `json:"customer_id"`
// An alias for the Orb customer, whose mapping is specified when creating the
// customer
ExternalCustomerID param.Field[string] `json:"external_customer_id"`
}
func (r EventIngestParamsEvent) MarshalJSON() (data []byte, err error) {
return apijson.MarshalRoot(r)
}
type EventSearchParams struct {
// This is an explicit array of IDs to filter by. Note that an event's ID is the
// idempotency_key that was originally used for ingestion, and this only supports
// events that have not been amended. Values in this array will be treated case
// sensitively.
EventIDs param.Field[[]string] `json:"event_ids,required"`
// The end of the timeframe, exclusive, in which to search events. If not
// specified, the current time is used.
TimeframeEnd param.Field[time.Time] `json:"timeframe_end" format:"date-time"`
// The start of the timeframe, inclusive, in which to search events. If not
// specified, the one week ago is used.
TimeframeStart param.Field[time.Time] `json:"timeframe_start" format:"date-time"`
}
func (r EventSearchParams) MarshalJSON() (data []byte, err error) {
return apijson.MarshalRoot(r)
}