FilesExpand file tree

main

/

Event.java

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

74 lines (68 loc) · 2.47 KB

main

/

Event.java

Copy path

Top

File metadata and controls

• Code
• Blame

74 lines (68 loc) · 2.47 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

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

package com.hook0.client;

import java.time.OffsetDateTime;

import java.util.Map;

import java.util.UUID;

/**

* An event to send to Hook0.

*

* <p>{@code eventId} is the caller's to set when it already has one to key the event on. Left as {@code null}, the

* client mints a UUIDv7, sends it and answers it — which is what lets it repeat a request without risking a second copy

* of the event being ingested and delivered to every subscriber.

*

* @param eventType the type of the event, as the application declares it

* @param payload what the event carries

* @param payloadContentType how to read the payload

* @param labels what Hook0 routes the event by

* @param metadata anything else worth carrying, or {@code null}

* @param occurredAt when the event happened, or {@code null} for the current moment

* @param eventId what to key the event on, or {@code null} to let the client choose

*/

public record Event(

String eventType,

String payload,

String payloadContentType,

Map<String, String> labels,

Map<String, String> metadata,

OffsetDateTime occurredAt,

UUID eventId) {

/**

* The event, with nothing beyond what the API requires.

*

* @param eventType the type of the event

* @param payload what the event carries

* @param payloadContentType how to read the payload

* @param labels what Hook0 routes the event by

* @return the event to send

*/

public static Event of(

String eventType, String payload, String payloadContentType, Map<String, String> labels) {

return new Event(eventType, payload, payloadContentType, labels, null, null, null);

}

/**

* The same event, carrying that metadata.

*

* @param chosen what else to carry

* @return the event with it

*/

public Event withMetadata(Map<String, String> chosen) {

return new Event(eventType, payload, payloadContentType, labels, chosen, occurredAt, eventId);

}

/**

* The same event, saying it happened then.

*

* @param chosen when the event happened

* @return the event with that moment

*/

public Event withOccurredAt(OffsetDateTime chosen) {

return new Event(eventType, payload, payloadContentType, labels, metadata, chosen, eventId);

}

/**

* The same event, keyed on that identifier.

*

* @param chosen what to key the event on

* @return the event with that identifier

*/

public Event withEventId(UUID chosen) {

return new Event(eventType, payload, payloadContentType, labels, metadata, occurredAt, chosen);

}

}