Package io.confluent.telemetry.api.events

Class Event

java.lang.Object

io.confluent.telemetry.api.events.Event

public class Event
extends Object

This class is a mutable builder for Cloudevent V1 . The default implementation is immutable and we need to be able to add metadata in the events pipeline. This class is not threadsafe.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	APPLICATION_JSON
static final String	APPLICATION_PROTOBUF
static final String	APPLICATION_X_PROTOBUF

Constructor Summary

Constructors

Constructor	Description
Event()

Method Summary

Modifier and Type	Method	Description
Optional<byte[]>	data()
String	dataContentType()
Optional<URI>	dataSchema()
String	extension(String name)
Set<String>	extensionNames()
String	id()
static boolean	isValidExtensionName(String name)	Validates the extension name as defined in CloudEvents spec.
Event	setData(String contentType, byte[] data)
Event	setData(String contentType, URI dataSchema, byte[] data)
Event	setExtension(String name, String value)
Event	setId(String id)
Event	setSource(String source)
Event	setSubject(String subject)
Event	setTime(OffsetDateTime time)
Event	setType(String type)
URI	source()
String	subject()
OffsetDateTime	time()
String	toString()
String	type()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

APPLICATION_PROTOBUF

public static final String APPLICATION_PROTOBUF

See Also:

• Constant Field Values

APPLICATION_X_PROTOBUF

public static final String APPLICATION_X_PROTOBUF

See Also:

• Constant Field Values

APPLICATION_JSON

public static final String APPLICATION_JSON

See Also:

• Constant Field Values

Constructor Details

Event

public Event()

Method Details

type

public String type()

source

public URI source()

subject

public String subject()

id

public String id()

time

public OffsetDateTime time()

data

public Optional<byte[]> data()

dataContentType

public String dataContentType()

dataSchema

public Optional<URI> dataSchema()

extension

public String extension(String name)

extensionNames

public Set<String> extensionNames()

setType

public Event setType(String type)

setSource

public Event setSource(String source)

setSubject

public Event setSubject(String subject)

setId

public Event setId(String id)

setTime

public Event setTime(OffsetDateTime time)

setData

public Event setData(String contentType,
 URI dataSchema,
 byte[] data)

setData

public Event setData(String contentType,
 byte[] data)

setExtension

public Event setExtension(String name,
 String value)

isValidExtensionName

public static boolean isValidExtensionName(String name)

Validates the extension name as defined in CloudEvents spec.

Parameters:

name - the extension name

Returns:

true if extension name is valid, false otherwise

See Also:

• attribute-naming-convention

toString

public String toString()

Overrides:

toString in class Object