kane

v0.7.0-beta

kane v0.7.0-beta Kane.Subscription

Link to this section Summary

Types

s()

Functions

ack(sub, messages)
create(sub)
data(subscription, atom)
data(subscription, atom, options)
delete(name)
find(name)

Find a subscription by name. The name can be either a short name (my-subscription) or the fully-qualified name (projects/my-project/subscriptions/my-subscription)

full_name(name)
path(name, kind)
pull(sub, options \\ [])
stream(sub, options \\ [])
strip!(name)

Link to this section Types

Link to this type

s() 
s() :: %Kane.Subscription{ack_deadline: term(), name: binary(), topic: term()}

Link to this section Functions

Link to this function

ack(sub, messages)

Link to this function

create(sub)

Link to this function

data(subscription, atom)

Link to this function

data(subscription, atom, options)

Link to this function

delete(name)

Link to this function

find(name) 
find(String.s()) :: {:ok, s()} | Error.s()

Find a subscription by name. The name can be either a short name (my-subscription) or the fully-qualified name (projects/my-project/subscriptions/my-subscription)

Link to this function

full_name(name)

Link to this function

path(name, kind)

Link to this function

pull(sub, options \\ [])

Link to this function

stream(sub, options \\ [])

Link to this function

strip!(name)