View Source Kvasir.Event (kvasir v0.0.18)

Link to this section Summary

Types

t()

Functions

decode(topic, event, opts \\ [])

See Kvasir.Event.Encoding.decode/3.

describe(event)

encode(event)

See Kvasir.Event.Encoding.encode/1.

encode(topic, event, opts \\ [])

See Kvasir.Event.Encoding.encode/3.

event(type)

event(type, list)

event?(event)

field(name, type \\ :string, opts \\ [])

id(event)

key(arg1)

on_error(arg1)

partition(map)

property(caller, name, type, opts)

set_key(e, key)

Set a key for an event.

set_key_type(e, type)

Set a key type for an event.

set_offset(e, offset)

Set an offset for an event.

set_partition(e, partition)

Set a partition for an event.

set_source(e, source)

Set a source for an event.

set_timestamp(e, timestamp)

Set a timestamp for an event.

set_topic(e, topic)

Set a topic for an event.

sub_key(arg1)

timestamp(arg1)

type(event)

upgrade(version, list)

version(version, updated \\ nil)

Link to this section Types

t()

@type t() :: struct()

Link to this section Functions

decode(topic, event, opts \\ [])

See Kvasir.Event.Encoding.decode/3.

describe(event)

encode(event)

See Kvasir.Event.Encoding.encode/1.

encode(topic, event, opts \\ [])

See Kvasir.Event.Encoding.encode/3.

event(type)

(macro)

event(type, list)

(macro)

event?(event)

@spec event?(any()) :: boolean()

field(name, type \\ :string, opts \\ [])

(macro)

id(event)

@spec id(t()) :: term()

key(arg1)

@spec key(t()) :: term()

on_error(arg1)

@spec on_error(t()) :: :halt | :skip

partition(map)

@spec partition(t()) :: non_neg_integer()

property(caller, name, type, opts)

set_key(e, key)

@spec set_key(t(), term()) :: t()

Set a key for an event.

set_key_type(e, type)

@spec set_key_type(t(), module()) :: t()

Set a key type for an event.

set_offset(e, offset)

@spec set_offset(t(), term()) :: t()

Set an offset for an event.

set_partition(e, partition)

@spec set_partition(t(), term()) :: t()

Set a partition for an event.

set_source(e, source)

@spec set_source(t(), module()) :: t()

Set a source for an event.

set_timestamp(e, timestamp)

@spec set_timestamp(t(), UTCDateTime.t()) :: t()

Set a timestamp for an event.

set_topic(e, topic)

@spec set_topic(t(), term()) :: t()

Set a topic for an event.

sub_key(arg1)

@spec sub_key(t()) :: term()

timestamp(arg1)

@spec timestamp(t()) :: UTCDateTime.t()

type(event)

@spec type(t()) :: String.t() | nil

upgrade(version, list)

(macro)

version(version, updated \\ nil)

(macro)

Settings View Source Kvasir.Event (kvasir v0.0.18)

Link to this section Summary

Types

Functions

Link to this section Types

t()

Link to this section Functions

decode(topic, event, opts \\ [])

describe(event)

encode(event)

encode(topic, event, opts \\ [])

event(type)

event(type, list)

event?(event)

field(name, type \\ :string, opts \\ [])

id(event)

key(arg1)

on_error(arg1)

partition(map)

property(caller, name, type, opts)

set_key(e, key)

set_key_type(e, type)

set_offset(e, offset)

set_partition(e, partition)

set_source(e, source)

set_timestamp(e, timestamp)

set_topic(e, topic)

sub_key(arg1)

timestamp(arg1)

type(event)

upgrade(version, list)

version(version, updated \\ nil)

View Source Kvasir.Event (kvasir v0.0.18)