View Source Electric.Shapes.Api (electric v1.0.0-beta.19)

@type options() :: [
  inspector: {module(), [term()]},
  pg_id: binary(),
  registry: atom(),
  shape_cache: {module(), [term()]},
  stack_events_registry: atom(),
  stack_id: binary(),
  storage: {module(), [term()]},
  persistent_kv: term(),
  allow_shape_deletion: boolean(),
  long_poll_timeout: integer(),
  max_age: integer(),
  stack_ready_timeout: integer(),
  stale_age: integer(),
  encoder: atom()
]

t()

@type t() :: %Electric.Shapes.Api{
  allow_shape_deletion: term(),
  configured: term(),
  encoder: term(),
  inspector: term(),
  long_poll_timeout: term(),
  max_age: term(),
  persistent_kv: term(),
  pg_id: term(),
  registry: term(),
  shape_cache: term(),
  stack_events_registry: term(),
  stack_id: term(),
  stack_ready_timeout: term(),
  stale_age: term(),
  storage: term()
}

Functions

configure(opts)

configure!(opts)

delete_shape(request)

@spec delete_shape(Electric.Shapes.Api.Request.t()) ::
  Electric.Shapes.Api.Response.t()

encode_message(api, message)

@spec encode_message(t() | Electric.Shapes.Api.Request.t(), term()) :: Enum.t()

plug_opts(opts)

schema(arg1)

serve_shape_log(request)

@spec serve_shape_log(Electric.Shapes.Api.Request.t()) ::
  Electric.Shapes.Api.Response.t()

Return shape log data.

stack_id(arg1)

@spec stack_id(t() | Electric.Shapes.Api.Request.t()) :: String.t()

validate(api, params)

@spec validate(t(), %{required(atom() | binary()) => term()}) ::
  {:ok, Electric.Shapes.Api.Request.t()}
  | {:error, Electric.Shapes.Api.Response.t()}

Validate the parameters for the request.

Options:

seek: boolean() - (default: true) once validated should we load the shape's latest offset information.
load: boolean() - (default: true) validate and optionallly create a shape based on the handle and shape parameters.

validate_for_delete(api, params)

@spec validate_for_delete(t(), %{required(atom() | binary()) => term()}) ::
  {:ok, Electric.Shapes.Api.Request.t()}
  | {:error, Electric.Shapes.Api.Response.t()}