Module Cephalopod_models.Com_Atproto_Label_SubscribeLabels

lexicon "com.atproto.label.subscribeLabels"

def main

type main_msg = [
  1. | `Com_atproto_label_subscribelabels_labels of Types.com_atproto_label_subscribelabels_labels
  2. | `Com_atproto_label_subscribelabels_info of Types.com_atproto_label_subscribelabels_info
  3. | `Other of Cephalopod_dasl.Value.t
    (*

    Non closed union

    *)
]
val show_main_msg : main_msg -> Ppx_deriving_runtime.string
val main_msg_nsid_of_fragment : string -> string

Turn a fragment (in header) into a full nsid

val main_msg_of_value : type_tag:string -> main_msg Cephalopod_dasl.Value.Util.conv
val main_msg_to_value : main_msg -> Cephalopod_dasl.Value.t
type main_params = {
  1. cursor : int64 option;
    (*

    The last known event seq number to backfill from.

    *)
}
val show_main_params : main_params -> Ppx_deriving_runtime.string
val make_main_params : ?cursor:int64 -> unit -> main_params
val main_params_of_value : main_params Cephalopod_dasl.Value.Util.conv
val main_params_to_value : main_params -> Cephalopod_dasl.Value.t
type main_error = [
  1. | `FutureCursor
]
val show_main_error : main_error -> Ppx_deriving_runtime.string

Subscribe to stream of labels (and negations). Public endpoint implemented by mod services. Uses same sequencing scheme as repo event stream.

def labels

def info

type nonrec info = Types.com_atproto_label_subscribelabels_info = {
  1. name : string;
    (*

    known values: "OutdatedCursor"

    *)
  2. message : string option;
}