kane

v1.0.0

kane v1.0.0 Kane.Message

Link to this section Summary

Types

message_data()
t()

Functions

from_subscription!(map)
publish(kane, message, topic)

Link to this section Types

Link to this type

message_data() 
message_data() :: binary() | Jason.Encoder.t()

Link to this type

t() 
t() :: %Kane.Message{
  ack_id: String.t() | nil,
  attributes: Map.t(),
  data: message_data(),
  id: String.t() | nil,
  publish_time: String.t() | nil
}

Link to this section Functions

Link to this function

from_subscription!(map) 
from_subscription!(payload :: map()) :: t()

Link to this function

publish(kane, message, topic) 
publish(
  Kane.t(),
  messages :: message_data() | t() | [t()],
  topic :: String.t() | Kane.Topic.t()
) :: {:ok, t() | [t()]} | Kane.Client.error()