README
Tr
JsonHttpClient
Tr
JsonHttpClientProvider
Tr
ProtobufHttpClient
Tr
ProtobufHttpClientProvider
Tr
SpanContextExtractable
Tr
SpanExporter
Tr
SpanProcessor
- ::to_protobufAttributeValue::to_protobuf
- ::containsAttributes::contains
- ::copyAttributes::copy
- ::eachAttributes::each
- ::emptyAttributes::empty
- ::getAttributes::get
- ::get_boolAttributes::get_bool
- ::get_doubleAttributes::get_double
- ::get_intAttributes::get_int
- ::get_stringAttributes::get_string
- ::is_emptyAttributes::is_empty
- ::mergeAttributes::merge
- ::newAttributes::new
- ::setAttributes::set
- ::sizeAttributes::size
- ::to_protobufAttributes::to_protobuf
- ::with_boolAttributes::with_bool
- ::with_doubleAttributes::with_double
- ::with_intAttributes::with_int
- ::with_stringAttributes::with_string
- ::newBatchExporter::new
- ::startBatchExporter::start
- ::enable_debug_logBatchExporterOptions::enable_debug_log
- ::with_export_timeout_millisBatchExporterOptions::with_export_timeout_millis
- ::with_max_export_batch_sizeBatchExporterOptions::with_max_export_batch_size
- ::with_max_queue_sizeBatchExporterOptions::with_max_queue_size
- ::with_schedule_delay_millisBatchExporterOptions::with_schedule_delay_millis
- ::with_set_timeoutBatchExporterOptions::with_set_timeout
- ::newBatchSpanProcessor::new
- ::startBatchSpanProcessor::start
- ::enable_debug_logBatchSpanProcessorOptions::enable_debug_log
- ::with_export_timeout_millisBatchSpanProcessorOptions::with_export_timeout_millis
- ::with_max_export_batch_sizeBatchSpanProcessorOptions::with_max_export_batch_size
- ::with_max_queue_sizeBatchSpanProcessorOptions::with_max_queue_size
- ::with_schedule_delay_millisBatchSpanProcessorOptions::with_schedule_delay_millis
- ::with_set_timeoutBatchSpanProcessorOptions::with_set_timeout
- ::containsContext::contains
- ::emptyContext::empty
- ::getContext::get
- ::get_boolContext::get_bool
- ::get_doubleContext::get_double
- ::get_intContext::get_int
- ::get_stringContext::get_string
- ::newContext::new
- ::sizeContext::size
- ::with_boolContext::with_bool
- ::with_doubleContext::with_double
- ::with_intContext::with_int
- ::with_stringContext::with_string
T
ContextValue
T
ExportAdapter
- ::http_statusHttpError::http_status
- ::invalid_responseHttpError::invalid_response
- ::is_retryableHttpError::is_retryable
- ::networkHttpError::network
- ::requestHttpError::request
- ::securityHttpError::security
- ::timeoutHttpError::timeout
- ::newHttpJsonSendAdaptor::new
- ::newHttpProtobufSendAdaptor::new
T
HttpRequest
T
HttpResponse
T
InternalLogger
- ::export_spansOTLPExporter::export_spans
- ::export_spans_by_json_http_clientOTLPExporter::export_spans_by_json_http_client
- ::export_spans_by_protobuf_http_clientOTLPExporter::export_spans_by_protobuf_http_client
- ::newOTLPExporter::new
- ::shutdownOTLPExporter::shutdown
- ::defaultOTLPExporterOptions::default
- ::enable_debug_logOTLPExporterOptions::enable_debug_log
- ::http_jsonOTLPExporterOptions::http_json
- ::http_protobufOTLPExporterOptions::http_protobuf
- ::stdoutOTLPExporterOptions::stdout
T
OtlpResourceSpan
- ::from_mapOtlpResourceSpans::from_map
- ::from_spansOtlpResourceSpans::from_spans
T
OtlpScope
T
OtlpScopeSpan
- ::export_spansPrettyPrintExporter::export_spans
- ::newPrettyPrintExporter::new
- ::shutdownPrettyPrintExporter::shutdown
- ::containsResource::contains
- ::emptyResource::empty
- ::getResource::get
- ::get_boolResource::get_bool
- ::get_doubleResource::get_double
- ::get_intResource::get_int
- ::get_stringResource::get_string
- ::mergeResource::merge
- ::newResource::new
- ::sizeResource::size
- ::to_protobufResource::to_protobuf
- ::with_boolResource::with_bool
- ::with_doubleResource::with_double
- ::with_intResource::with_int
- ::with_stringResource::with_string
- ::add_eventSpan::add_event
- ::add_linkSpan::add_link
- ::contextSpan::context
- ::durationSpan::duration
- ::endSpan::end
- ::is_endedSpan::is_ended
- ::newSpan::new
- ::set_attributeSpan::set_attribute
- ::set_statusSpan::set_status
- ::to_protobufSpan::to_protobuf
- ::attributeSpanBuilder::attribute
- ::attributesSpanBuilder::attributes
- ::kindSpanBuilder::kind
- ::newSpanBuilder::new
- ::parentSpanBuilder::parent
- ::startSpanBuilder::start
- ::start_time_nsSpanBuilder::start_time_ns
- ::is_sampledSpanContext::is_sampled
- ::is_validSpanContext::is_valid
- ::newSpanContext::new
- ::newSpanEvent::new
- ::to_protobufSpanEvent::to_protobuf
- ::is_validSpanID::is_valid
- ::newSpanID::new
- ::to_stringSpanID::to_string
T
SpanKind
- ::from_span_contextSpanLink::from_span_context
- ::to_protobufSpanLink::to_protobuf
T
SpanStatus
- ::newStdoutSendAdaptor::new
- ::is_sampledTraceFlags::is_sampled
- ::sampledTraceFlags::sampled
- ::is_validTraceID::is_valid
- ::newTraceID::new
- ::to_stringTraceID::to_string
- ::deleteTraceState::delete
- ::getTraceState::get
- ::insertTraceState::insert
- ::parseTraceState::parse
- ::to_http_headerTraceState::to_http_header
- ::to_mapTraceState::to_map
- ::nameTracer::name
- ::newTracer::new
- ::span_eventTracer::span_event
- ::start_spanTracer::start_span
- ::versionTracer::version
- ::with_optionsTracer::with_options
- ::newTracerIdentifier::new
- ::defaultTracerOptions::default
- ::with_current_time_fnTracerOptions::with_current_time_fn
- ::with_span_id_generatorTracerOptions::with_span_id_generator
- ::with_span_on_endTracerOptions::with_span_on_end
- ::with_span_on_startTracerOptions::with_span_on_start
- ::with_trace_id_generatorTracerOptions::with_trace_id_generator
- ::force_flushTracerProvider::force_flush
- ::globalTracerProvider::global
- ::newTracerProvider::new
- ::set_globalTracerProvider::set_global
- ::shutdownTracerProvider::shutdown
- ::tracerTracerProvider::tracer
- ::with_span_processorsTracerProvider::with_span_processors
V
add_header
V
char_to_int
V
current_time_nanos
V
generate_span_id
V
generate_trace_id
V
hex_to_bytes
V
json_http_client_provider
V
make_headers_map
V
protobuf_http_client_provider
V
rand_by_current_time
V
service_instance_id
V
service_name
V
service_namespace
V
service_version
V
spans_to_resource_spans_json
V
spans_to_resource_spans_protobuf_bytes
V
suspend

moonbit_otel

otel

opentelemetry

tracing

metrics

logging

Download zip

Author

ryota0624

Version

0.1.0

License

Apache-2.0

Repository

github.com/ryota0624/moonbit_otel

Last updated

7 months ago

Downloads

Dependencies

#ryota0624/moonbit_otel

Moonbit Otel

https://opentelemetry.io/ に沿った計装を行うためのMoonBit用ライブラリです。

#support

Traces	Metrics	Logs
In Development	Not Yet	Not Yet

JsonHttpClient

source

pub(open) trait JsonHttpClient {
  async http_post_json(Self, url : String, body : String, headers : Map[String, String]) -> Result[HttpResponse, HttpError]
}

JsonHttpClientProvider

source

pub(open) trait JsonHttpClientProvider {
  get_json_client(Self) -> &JsonHttpClient
}

ProtobufHttpClient

source

pub(open) trait ProtobufHttpClient {
  async http_post_protobuf(Self, url : String, body : Bytes, headers : Map[String, String]) -> Result[HttpResponse, HttpError]
}

ProtobufHttpClientProvider

source

pub(open) trait ProtobufHttpClientProvider {
  get_protobuf_client(Self) -> &ProtobufHttpClient
}

SpanContextExtractable

source

pub trait SpanContextExtractable {
  as_span_context(Self) -> SpanContext
}

SpanExporter

source

pub(open) trait SpanExporter {
  async export_spans(Self, Array[Span]) -> Unit
  async shutdown(Self) -> Unit
  enable_batch_export(self : Self, options? : BatchExporterOptions) -> BatchExporter = _
}

SpanProcessor

source

pub trait SpanProcessor {
  on_span_start(Self, span : Span) -> Unit
  on_span_end(Self, span : Span) -> Unit
  async shutdown(Self) -> Unit
  async force_flush(Self) -> Unit
}

AttributeValue

source

pub(all) enum AttributeValue {
  String(String)
  Int(Int)
  Bool(Bool)
  Double(Double)
}

impl Eq for AttributeValue

impl Show for AttributeValue

AttributeValue::to_protobuf

source

fn AttributeValue::to_protobuf(self : AttributeValue) -> @ryota0624/opentelemetry_proto_mbt/opentelemetry/proto/common/v1.AnyValue
AnyValue

Attributes

source

pub struct Attributes {
  map : Map[String, AttributeValue]
}

impl Default for Attributes

Attributes::contains

source

fn Attributes::contains(self : Attributes, key : String) -> Bool

Attributes::copy

source

fn Attributes::copy(self : Attributes) -> Attributes

Attributes::each

source

fn Attributes::each(self : Attributes, f : (String, AttributeValue) -> Unit) -> Unit

Attributes::empty

source

fn Attributes::empty() -> Attributes

Attributes::get

source

fn Attributes::get(self : Attributes, key : String) -> AttributeValue?

Attributes::get_bool

source

fn Attributes::get_bool(self : Attributes, key : String) -> Bool?

Attributes::get_double

source

fn Attributes::get_double(self : Attributes, key : String) -> Double?

Attributes::get_int

source

fn Attributes::get_int(self : Attributes, key : String) -> Int?

Attributes::get_string

source

fn Attributes::get_string(self : Attributes, key : String) -> String?

Attributes::is_empty

source

fn Attributes::is_empty(self : Attributes) -> Bool

Attributes::merge

source

fn Attributes::merge(self : Attributes, other : Attributes) -> Attributes

Attributes::new

source

fn Attributes::new() -> Attributes

Attributes::set

source

fn Attributes::set(self : Attributes, key : String, value : AttributeValue) -> Attributes

Attributes::size

source

fn Attributes::size(self : Attributes) -> Int

Attributes::to_protobuf

source

fn Attributes::to_protobuf(self : Attributes) -> Array[@ryota0624/opentelemetry_proto_mbt/opentelemetry/proto/common/v1.KeyValue
KeyValue]

Attributes::with_bool

source

fn Attributes::with_bool(self : Attributes, key : String, value : Bool) -> Attributes

Attributes::with_double

source

fn Attributes::with_double(self : Attributes, key : String, value : Double) -> Attributes

Attributes::with_int

source

fn Attributes::with_int(self : Attributes, key : String, value : Int) -> Attributes

Attributes::with_string

source

fn Attributes::with_string(self : Attributes, key : String, value : String) -> Attributes

BatchExporter

source

pub struct BatchExporter {
  // private fields
}

impl SpanExporter for BatchExporter

BatchExporter::new

source

fn BatchExporter::new(exporter : &SpanExporter, options? : BatchExporterOptions) -> BatchExporter

BatchExporter::start

source

async fn BatchExporter::start(self : BatchExporter) -> Unit

BatchExporterOptions

source

pub struct BatchExporterOptions {
  max_queue_size : Int
  schedule_delay_millis : Int
  export_timeout_millis : Int
  max_export_batch_size : Int
  set_timeout : async (Int, async () -> Unit noraise) -> Unit
  logger_factory : () -> InternalLogger
}

impl Default for BatchExporterOptions

BatchExporterOptions::enable_debug_log

source

fn BatchExporterOptions::enable_debug_log(self : BatchExporterOptions, print : (&Show) -> Unit) -> BatchExporterOptions

BatchExporterOptions::with_export_timeout_millis

source

fn BatchExporterOptions::with_export_timeout_millis(self : BatchExporterOptions, millis : Int) -> BatchExporterOptions

BatchExporterOptions::with_max_export_batch_size

source

fn BatchExporterOptions::with_max_export_batch_size(self : BatchExporterOptions, size : Int) -> BatchExporterOptions

BatchExporterOptions::with_max_queue_size

source

fn BatchExporterOptions::with_max_queue_size(self : BatchExporterOptions, size : Int) -> BatchExporterOptions

BatchExporterOptions::with_schedule_delay_millis

source

fn BatchExporterOptions::with_schedule_delay_millis(self : BatchExporterOptions, millis : Int) -> BatchExporterOptions

BatchExporterOptions::with_set_timeout

source

fn BatchExporterOptions::with_set_timeout(self : BatchExporterOptions, set_timeout : async (Int, async () -> Unit noraise) -> Unit) -> BatchExporterOptions

BatchSpanProcessor

source

pub struct BatchSpanProcessor {
  // private fields
}

impl SpanProcessor for BatchSpanProcessor

async fn force_flush(self : BatchSpanProcessor) -> Unit

source

fn on_span_end(self : BatchSpanProcessor, span : Span) -> Unit

source

fn on_span_start(_ : BatchSpanProcessor, _ : Span) -> Unit

source

async fn shutdown(self : BatchSpanProcessor) -> Unit

source

BatchSpanProcessor::new

source

fn BatchSpanProcessor::new(exporter : &SpanExporter, options? : BatchSpanProcessorOptions) -> BatchSpanProcessor

BatchSpanProcessor::start

source

async fn BatchSpanProcessor::start(self : BatchSpanProcessor) -> Unit

BatchSpanProcessorOptions

source

pub struct BatchSpanProcessorOptions {
  max_queue_size : Int
  schedule_delay_millis : Int
  export_timeout_millis : Int
  max_export_batch_size : Int
  set_timeout : async (Int, async () -> Unit noraise) -> Unit
  logger_factory : () -> InternalLogger
}

impl Default for BatchSpanProcessorOptions

BatchSpanProcessorOptions::enable_debug_log

source

fn BatchSpanProcessorOptions::enable_debug_log(self : BatchSpanProcessorOptions, print : (&Show) -> Unit) -> BatchSpanProcessorOptions

BatchSpanProcessorOptions::with_export_timeout_millis

source

fn BatchSpanProcessorOptions::with_export_timeout_millis(self : BatchSpanProcessorOptions, millis : Int) -> BatchSpanProcessorOptions

BatchSpanProcessorOptions::with_max_export_batch_size

source

fn BatchSpanProcessorOptions::with_max_export_batch_size(self : BatchSpanProcessorOptions, size : Int) -> BatchSpanProcessorOptions

BatchSpanProcessorOptions::with_max_queue_size

source

fn BatchSpanProcessorOptions::with_max_queue_size(self : BatchSpanProcessorOptions, size : Int) -> BatchSpanProcessorOptions

BatchSpanProcessorOptions::with_schedule_delay_millis

source

fn BatchSpanProcessorOptions::with_schedule_delay_millis(self : BatchSpanProcessorOptions, millis : Int) -> BatchSpanProcessorOptions

BatchSpanProcessorOptions::with_set_timeout

source

fn BatchSpanProcessorOptions::with_set_timeout(self : BatchSpanProcessorOptions, set_timeout : async (Int, async () -> Unit noraise) -> Unit) -> BatchSpanProcessorOptions

Context

source

type Context

Context::contains

source

fn Context::contains(self : Context, key : String) -> Bool

Context::empty

source

fn Context::empty() -> Context

Context::get

source

fn Context::get(self : Context, key : String) -> ContextValue?

Context::get_bool

source

fn Context::get_bool(self : Context, key : String) -> Bool?

Context::get_double

source

fn Context::get_double(self : Context, key : String) -> Double?

Context::get_int

source

fn Context::get_int(self : Context, key : String) -> Int?

Context::get_string

source

fn Context::get_string(self : Context, key : String) -> String?

Context::new

source

fn Context::new() -> Context

Context::size

source

fn Context::size(self : Context) -> Int

Context::with_bool

source

fn Context::with_bool(self : Context, key : String, value : Bool) -> Context

Context::with_double

source

fn Context::with_double(self : Context, key : String, value : Double) -> Context

Context::with_int

source

fn Context::with_int(self : Context, key : String, value : Int) -> Context

Context::with_string

source

fn Context::with_string(self : Context, key : String, value : String) -> Context

ContextValue

source

type ContextValue

impl Eq for ContextValue

impl Show for ContextValue

ExportAdapter

source

pub(all) enum ExportAdapter {
  HttpJson(HttpJsonSendAdaptor)
  HttpProtobuf(HttpProtobufSendAdaptor)
  Stdout(StdoutSendAdaptor)
}

HttpError

source

pub(all) enum HttpError {
  NetworkError(String)
  RequestError(String)
  HttpStatusError(Int, String)
  InvalidResponse(String)
  TimeoutError(String)
  SecurityError(String)
}

impl Show for HttpError

HttpError::http_status

source

fn HttpError::http_status(status_code : Int, body : String) -> HttpError

HttpError::invalid_response

source

fn HttpError::invalid_response(message : String) -> HttpError

HttpError::is_retryable

source

fn HttpError::is_retryable(self : HttpError) -> Bool

HttpError::network

source

fn HttpError::network(message : String) -> HttpError

HttpError::request

source

fn HttpError::request(message : String) -> HttpError

HttpError::security

source

fn HttpError::security(message : String) -> HttpError

HttpError::timeout

source

fn HttpError::timeout(message : String) -> HttpError

HttpJsonSendAdaptor

source

pub(all) struct HttpJsonSendAdaptor {
  client_provider : &JsonHttpClientProvider
  endpoint : String
  headers : Map[String, String]
}

HttpJsonSendAdaptor::new

source

fn HttpJsonSendAdaptor::new(client_provider : &JsonHttpClientProvider, endpoint? : String, headers? : Map[String, String]) -> HttpJsonSendAdaptor

HttpProtobufSendAdaptor

source

pub(all) struct HttpProtobufSendAdaptor {
  client_provider : &ProtobufHttpClientProvider
  endpoint : String
  headers : Map[String, String]
}

HttpProtobufSendAdaptor::new

source

fn HttpProtobufSendAdaptor::new(client_provider : &ProtobufHttpClientProvider, endpoint? : String, headers? : Map[String, String]) -> HttpProtobufSendAdaptor

HttpRequest

source

pub(all) struct HttpRequest {
  url : String
  http_method : String
  headers : Map[String, String]
  body : String
}

impl ToJson for HttpRequest

impl FromJson for HttpRequest

HttpResponse

source

pub(all) struct HttpResponse {
  status_code : Int
  body : String
  error_code : Int?
}

impl ToJson for HttpResponse

impl FromJson for HttpResponse

InternalLogger

source

type InternalLogger

OTLPExporter

source

pub struct OTLPExporter {
  config : OTLPExporterOptions
  // private fields
}

impl SpanExporter for OTLPExporter

OTLPExporter::export_spans

source

async fn OTLPExporter::export_spans(self : OTLPExporter, spans : Array[Span]) -> Unit

OTLPExporter::export_spans_by_json_http_client

source

async fn OTLPExporter::export_spans_by_json_http_client(self : OTLPExporter, json_body : String, http_client : &JsonHttpClient, http_adaptor : HttpJsonSendAdaptor, spans : Array[Span]) -> Unit

OTLPExporter::export_spans_by_protobuf_http_client

source

async fn OTLPExporter::export_spans_by_protobuf_http_client(self : OTLPExporter, protobuf_body : Bytes, http_client : &ProtobufHttpClient, http_adaptor : HttpProtobufSendAdaptor, spans : Array[Span]) -> Unit

OTLPExporter::new

source

fn OTLPExporter::new(config : OTLPExporterOptions) -> OTLPExporter

OTLPExporter::shutdown

source

fn OTLPExporter::shutdown(self : OTLPExporter) -> Unit

OTLPExporterOptions

source

pub struct OTLPExporterOptions {
  logger_factory : () -> InternalLogger
  export_adapter : ExportAdapter
}

OTLPExporterOptions::default

source

fn OTLPExporterOptions::default(export_adapter : ExportAdapter) -> OTLPExporterOptions

OTLPExporterOptions::enable_debug_log

source

fn OTLPExporterOptions::enable_debug_log(self : OTLPExporterOptions, print~ : (&Show) -> Unit) -> OTLPExporterOptions

OTLPExporterOptions::http_json

source

fn OTLPExporterOptions::http_json(client_provider : &JsonHttpClientProvider, endpoint? : String, headers? : Map[String, String]) -> OTLPExporterOptions

OTLPExporterOptions::http_protobuf

source

fn OTLPExporterOptions::http_protobuf(client_provider : &ProtobufHttpClientProvider, endpoint? : String, headers? : Map[String, String]) -> OTLPExporterOptions

OTLPExporterOptions::stdout

source

fn OTLPExporterOptions::stdout(print : (String) -> Unit) -> OTLPExporterOptions

OtlpResourceSpan

source

pub struct OtlpResourceSpan {
  resource : Resource
  scope_spans : Array[OtlpScopeSpan]
  schemaUrl : String?
}

impl ToJson for OtlpResourceSpan

OtlpResourceSpans

source

pub struct OtlpResourceSpans {
  resource_spans : Array[OtlpResourceSpan]
}

impl ToJson for OtlpResourceSpans

OtlpResourceSpans::from_map

source

fn OtlpResourceSpans::from_map(map : Map[Resource, Map[TracerIdentifier, Array[Span]]]) -> OtlpResourceSpans

OtlpResourceSpans::from_spans

source

fn OtlpResourceSpans::from_spans(spans : Array[Span]) -> OtlpResourceSpans

OtlpScope

source

pub struct OtlpScope {
  name : String
  version : String
}

impl ToJson for OtlpScope

OtlpScopeSpan

source

pub struct OtlpScopeSpan {
  scope : OtlpScope
  spans : Array[Span]
  schema_url : String?
}

impl ToJson for OtlpScopeSpan

PrettyPrintExporter

source

pub struct PrettyPrintExporter {
  print_fn : (String) -> Unit
}

impl SpanExporter for PrettyPrintExporter

PrettyPrintExporter::export_spans

source

fn PrettyPrintExporter::export_spans(self : PrettyPrintExporter, spans : Array[Span]) -> Unit

PrettyPrintExporter::new

source

fn PrettyPrintExporter::new(print : (String) -> Unit) -> PrettyPrintExporter

PrettyPrintExporter::shutdown

source

fn PrettyPrintExporter::shutdown(self : PrettyPrintExporter) -> Unit

Resource

source

pub struct Resource {
  attributes : Attributes
}

impl Eq for Resource

impl Hash for Resource

impl ToJson for Resource

Resource::contains

source

fn Resource::contains(self : Resource, key : String) -> Bool

Resource::empty

source

fn Resource::empty() -> Resource

Resource::get

source

fn Resource::get(self : Resource, key : String) -> AttributeValue?

Resource::get_bool

source

fn Resource::get_bool(self : Resource, key : String) -> Bool?

Resource::get_double

source

fn Resource::get_double(self : Resource, key : String) -> Double?

Resource::get_int

source

fn Resource::get_int(self : Resource, key : String) -> Int?

Resource::get_string

source

fn Resource::get_string(self : Resource, key : String) -> String?

Resource::merge

source

fn Resource::merge(self : Resource, other : Resource) -> Resource

Resource::new

source

fn Resource::new() -> Resource

Resource::size

source

fn Resource::size(self : Resource) -> Int

Resource::to_protobuf

source

fn Resource::to_protobuf(self : Resource) -> @ryota0624/opentelemetry_proto_mbt/opentelemetry/proto/resource/v1.Resource
Resource

Resource::with_bool

source

fn Resource::with_bool(self : Resource, key : String, value : Bool) -> Resource

Resource::with_double

source

fn Resource::with_double(self : Resource, key : String, value : Double) -> Resource

Resource::with_int

source

fn Resource::with_int(self : Resource, key : String, value : Int) -> Resource

Resource::with_string

source

fn Resource::with_string(self : Resource, key : String, value : String) -> Resource

Span

source

pub struct Span {
  traceId : TraceID
  spanId : SpanID
  trace_state : TraceState
  parent_span_id : SpanID?
  trace_flags : TraceFlags
  name : String
  kind : SpanKind
  start_time_unix_nano : Int64
  end_time_unix_nano : Int64?
  attributes : Attributes
  dropped_attributes_count : Int
  events : Array[SpanEvent]
  links : Array[SpanLink]
  dropped_events_count : Int
  status : SpanStatus
  resource : Resource
  tracer_identifier : TracerIdentifier
  on_end : (Span) -> Unit?
}

impl SpanContextExtractable for Span

Span::add_event

source

fn Span::add_event(self : Span, event : SpanEvent) -> Span

Span::add_link

source

fn Span::add_link(self : Span, linked_context : SpanContext, attributes? : Attributes) -> Span

Span::context

source

fn Span::context(self : Span) -> SpanContext

Span::duration

source

fn Span::duration(self : Span) -> Int64?

Span::end

source

fn Span::end(self : Span, end_time_ns? : Int64) -> Span

Span::is_ended

source

fn Span::is_ended(self : Span) -> Bool

Span::new

source

fn Span::new(context : SpanContext, name : String, kind : SpanKind, start_time : Int64, resource : Resource, tracer_identifier : TracerIdentifier, parent_span_id : SpanID?, on_end? : (Span) -> Unit) -> Span

Span::set_attribute

source

fn Span::set_attribute(self : Span, key : String, value : AttributeValue) -> Span

Span::set_status

source

fn Span::set_status(self : Span, status : SpanStatus) -> Span

Span::to_protobuf

source

fn Span::to_protobuf(self : Span) -> @ryota0624/opentelemetry_proto_mbt/opentelemetry/proto/trace/v1.Span
Span

SpanBuilder

source

pub struct SpanBuilder {
  // private fields
}

SpanBuilder::attribute

source

fn SpanBuilder::attribute(self : SpanBuilder, key : String, value : AttributeValue) -> SpanBuilder

SpanBuilder::attributes

source

fn SpanBuilder::attributes(self : SpanBuilder, attributes : Attributes) -> SpanBuilder

SpanBuilder::kind

source

fn SpanBuilder::kind(self : SpanBuilder, kind : SpanKind) -> SpanBuilder

SpanBuilder::new

source

fn SpanBuilder::new(name : String, resource : Resource, tracer_identifier : TracerIdentifier, tracer_options : TracerOptions) -> SpanBuilder

SpanBuilder::parent

source

fn SpanBuilder::parent(self : SpanBuilder, parent : &SpanContextExtractable) -> SpanBuilder

SpanBuilder::start

source

fn SpanBuilder::start(self : SpanBuilder) -> Span

SpanBuilder::start_time_ns

source

fn SpanBuilder::start_time_ns(self : SpanBuilder, start_time : Int64) -> SpanBuilder

SpanContext

source

pub struct SpanContext {
  trace_id : TraceID
  span_id : SpanID
  trace_flags : TraceFlags
  is_remote : Bool
}

impl ToJson for SpanContext

impl SpanContextExtractable for SpanContext

SpanContext::is_sampled

source

fn SpanContext::is_sampled(self : SpanContext) -> Bool

SpanContext::is_valid

source

fn SpanContext::is_valid(self : SpanContext) -> Bool

SpanContext::new

source

fn SpanContext::new(trace_id : TraceID, span_id : SpanID, trace_flags : TraceFlags, is_remote : Bool) -> SpanContext

SpanEvent

source

pub struct SpanEvent {
  name : String
  timestamp : Int64
  attributes : Attributes
}

impl ToJson for SpanEvent

SpanEvent::new

source

fn SpanEvent::new(name : String, attributes : Attributes, timestamp? : Int64) -> SpanEvent

SpanEvent::to_protobuf

source

fn SpanEvent::to_protobuf(self : SpanEvent) -> @ryota0624/opentelemetry_proto_mbt/opentelemetry/proto/trace/v1.Span_Event
Span_Event

SpanID

source

pub struct SpanID {
  value : String
}

impl Eq for SpanID

impl Show for SpanID

SpanID::is_valid

source

fn SpanID::is_valid(self : SpanID) -> Bool

SpanID::new

source

fn SpanID::new(value : String) -> SpanID

SpanID::to_string

source

fn SpanID::to_string(self : SpanID) -> String

SpanKind

source

pub(all) enum SpanKind {
  Unspecified
  Internal
  Server
  Client
  Producer
  Consumer
}

impl Eq for SpanKind

impl Show for SpanKind

impl ToJson for SpanKind

SpanLink

source

pub struct SpanLink {
  trace_id : TraceID
  span_id : SpanID
  trace_state : TraceState
  trace_flags : TraceFlags
  attributes : Attributes
}

impl ToJson for SpanLink

SpanLink::from_span_context

source

fn SpanLink::from_span_context(context : SpanContext, trace_state : TraceState, attributes : Attributes) -> SpanLink

SpanLink::to_protobuf

source

fn SpanLink::to_protobuf(self : SpanLink) -> @ryota0624/opentelemetry_proto_mbt/opentelemetry/proto/trace/v1.Span_Link
Span_Link

SpanStatus

source

pub(all) enum SpanStatus {
  Unset
  Ok
  Error
}

impl Eq for SpanStatus

impl Show for SpanStatus

impl ToJson for SpanStatus

StdoutSendAdaptor

source

pub(all) struct StdoutSendAdaptor {
  print : (String) -> Unit
}

StdoutSendAdaptor::new

source

fn StdoutSendAdaptor::new(print : (String) -> Unit) -> StdoutSendAdaptor

TraceFlags

source

pub struct TraceFlags {
  // private fields
}

impl Eq for TraceFlags

impl Show for TraceFlags

TraceFlags::is_sampled

source

fn TraceFlags::is_sampled(self : TraceFlags) -> Bool

TraceFlags::sampled

source

fn TraceFlags::sampled() -> TraceFlags

TraceID

source

pub struct TraceID {
  value : String
}

impl Eq for TraceID

impl Show for TraceID

TraceID::is_valid

source

fn TraceID::is_valid(self : TraceID) -> Bool

TraceID::new

source

fn TraceID::new(value : String) -> TraceID

TraceID::to_string

source

fn TraceID::to_string(self : TraceID) -> String

TraceState

source

pub struct TraceState {
  // private fields
}

impl Eq for TraceState

impl Show for TraceState

TraceState::delete

source

fn TraceState::delete(self : TraceState, key : String) -> TraceState

TraceState::get

source

fn TraceState::get(self : TraceState, key : String) -> String?

TraceState::insert

source

fn TraceState::insert(self : TraceState, key : String, value : String) -> TraceState

TraceState::parse

source

fn TraceState::parse(value : String) -> TraceState raise

TraceState::to_http_header

source

fn TraceState::to_http_header(self : TraceState) -> String

TraceState::to_map

source

fn TraceState::to_map(self : TraceState) -> Map[String, String]

Tracer

source

pub struct Tracer {
  identifier : TracerIdentifier
  resource : Resource
  options : TracerOptions
}

Tracer::name

source

fn Tracer::name(self : Tracer) -> String

Tracer::new

source

fn Tracer::new(name : String, version : String, resource : Resource) -> Tracer

Tracer::span_event

source

fn Tracer::span_event(self : Tracer, name : String, attributes? : Attributes, event_time? : Int64?) -> SpanEvent

Tracer::start_span

source

fn Tracer::start_span(self : Tracer, name : String, kind? : SpanKind, parent? : &SpanContextExtractable, attributes? : Attributes) -> Span

Tracer::version

source

fn Tracer::version(self : Tracer) -> String

Tracer::with_options

source

fn Tracer::with_options(name : String, version : String, resource : Resource, options : TracerOptions) -> Tracer

TracerIdentifier

source

pub struct TracerIdentifier {
  name : String
  version : String
}

impl Eq for TracerIdentifier

impl Hash for TracerIdentifier

TracerIdentifier::new

source

fn TracerIdentifier::new(name : String, version : String) -> TracerIdentifier

TracerOptions

source

pub struct TracerOptions {
  trace_id_generator : () -> TraceID
  span_id_generator : () -> SpanID
  get_current_time_nanos : () -> Int64
  span_on_start : (Span) -> Unit
  span_on_end : (Span) -> Unit
}

TracerOptions::default

source

fn TracerOptions::default(rand? : @moonbitlang/core/random.Rand
Rand) -> TracerOptions

TracerOptions::with_current_time_fn

source

fn TracerOptions::with_current_time_fn(self : TracerOptions, time_fn : () -> Int64) -> TracerOptions

TracerOptions::with_span_id_generator

source

fn TracerOptions::with_span_id_generator(self : TracerOptions, generator : () -> SpanID) -> TracerOptions

TracerOptions::with_span_on_end

source

fn TracerOptions::with_span_on_end(self : TracerOptions, on_end_fn : (Span) -> Unit) -> TracerOptions

TracerOptions::with_span_on_start

source

fn TracerOptions::with_span_on_start(self : TracerOptions, on_start_fn : (Span) -> Unit) -> TracerOptions

TracerOptions::with_trace_id_generator

source

fn TracerOptions::with_trace_id_generator(self : TracerOptions, generator : () -> TraceID) -> TracerOptions

TracerProvider

source

pub struct TracerProvider {
  tracer_factory : (TracerOptions) -> Tracer
  span_processors : Array[&SpanProcessor]
  options : TracerOptions
}

TracerProvider::force_flush

source

async fn TracerProvider::force_flush(self : TracerProvider) -> Unit

TracerProvider::global

source

fn TracerProvider::global() -> TracerProvider

get global TracerProvider

TracerProvider::new

source

fn TracerProvider::new(name : String, version : String, resource : Resource, options? : TracerOptions, processors? : Array[&SpanProcessor]) -> TracerProvider

TracerProvider::set_global

source

fn TracerProvider::set_global(provider : TracerProvider) -> Unit

set global TracerProvider

TracerProvider::shutdown

source

async fn TracerProvider::shutdown(self : TracerProvider) -> Unit

TracerProvider::tracer

source

fn TracerProvider::tracer(self : TracerProvider) -> Tracer

get Tracer from TracerProvider

TracerProvider::with_span_processors

source

fn TracerProvider::with_span_processors(self : TracerProvider, processors : Array[&SpanProcessor]) -> TracerProvider

add_header

source

fn add_header(headers : Map[String, String], key : String, value : String) -> Map[String, String]

char_to_int

source

fn char_to_int(c : Char) -> Int?

current_time_nanos

source

fn current_time_nanos() -> Int64

generate_span_id

source

fn generate_span_id(rand : @moonbitlang/core/random.Rand
Rand) -> SpanID

generate_trace_id

source

fn generate_trace_id(rand : @moonbitlang/core/random.Rand
Rand) -> TraceID

hex_to_bytes

source

fn hex_to_bytes(hex : String) -> Bytes?

json_http_client_provider

source

fn json_http_client_provider() -> &JsonHttpClientProvider

make_headers_map

source

fn make_headers_map() -> Map[String, String]

protobuf_http_client_provider

source

fn protobuf_http_client_provider() -> &ProtobufHttpClientProvider

rand_by_current_time

source

fn rand_by_current_time() -> @moonbitlang/core/random.Rand
Rand

service_instance_id

source

let service_instance_id : String

service_name

source

let service_name : String

service_namespace

source

let service_namespace : String

service_version

source

let service_version : String

spans_to_resource_spans_json

source

fn spans_to_resource_spans_json(spans : Array[Span]) -> String

spans_to_resource_spans_protobuf_bytes

source

fn spans_to_resource_spans_protobuf_bytes(spans : Array[Span]) -> Bytes raise

suspend

source

async fn[T, E : Error] suspend(f : ((T) -> Unit, (E) -> Unit) -> Unit) -> T raise E

Source Files

Site source Report issue Packages Build queue Skills Statistics

moonbit_otel

#ryota0624/moonbit_otel

#support

#JsonHttpClient

#JsonHttpClientProvider

#ProtobufHttpClient

#ProtobufHttpClientProvider

#SpanContextExtractable

#SpanExporter

#SpanProcessor

#AttributeValue

#AttributeValue::to_protobuf

#Attributes

#Attributes::contains

#Attributes::copy

#Attributes::each

#Attributes::empty

#Attributes::get

#Attributes::get_bool

#Attributes::get_double

#Attributes::get_int

#Attributes::get_string

#Attributes::is_empty

#Attributes::merge

#Attributes::new

#Attributes::set

#Attributes::size

#Attributes::to_protobuf

#Attributes::with_bool

#Attributes::with_double

#Attributes::with_int

#Attributes::with_string

#BatchExporter

#BatchExporter::new

#BatchExporter::start

#BatchExporterOptions

#BatchExporterOptions::enable_debug_log

#BatchExporterOptions::with_export_timeout_millis

#BatchExporterOptions::with_max_export_batch_size

#BatchExporterOptions::with_max_queue_size

#BatchExporterOptions::with_schedule_delay_millis

#BatchExporterOptions::with_set_timeout

#BatchSpanProcessor

#BatchSpanProcessor::new

#BatchSpanProcessor::start

#BatchSpanProcessorOptions

#BatchSpanProcessorOptions::enable_debug_log

#BatchSpanProcessorOptions::with_export_timeout_millis

#BatchSpanProcessorOptions::with_max_export_batch_size

#BatchSpanProcessorOptions::with_max_queue_size

#BatchSpanProcessorOptions::with_schedule_delay_millis

#BatchSpanProcessorOptions::with_set_timeout

#Context

#Context::contains

#Context::empty

#Context::get

#Context::get_bool

#Context::get_double

#Context::get_int

#Context::get_string

#Context::new

#Context::size

#Context::with_bool

#Context::with_double

#Context::with_int

#Context::with_string

#ContextValue

#ExportAdapter

#HttpError

#HttpError::http_status

#HttpError::invalid_response

#HttpError::is_retryable

#HttpError::network

#HttpError::request

#HttpError::security

#HttpError::timeout

#HttpJsonSendAdaptor

#HttpJsonSendAdaptor::new

#HttpProtobufSendAdaptor

#HttpProtobufSendAdaptor::new

JsonHttpClient

JsonHttpClientProvider

ProtobufHttpClient

ProtobufHttpClientProvider

SpanContextExtractable

SpanExporter

SpanProcessor

AttributeValue

AttributeValue::to_protobuf

Attributes

Attributes::contains

Attributes::copy

Attributes::each

Attributes::empty

Attributes::get

Attributes::get_bool

Attributes::get_double

Attributes::get_int

Attributes::get_string

Attributes::is_empty

Attributes::merge

Attributes::new

Attributes::set

Attributes::size

Attributes::to_protobuf

Attributes::with_bool

Attributes::with_double

Attributes::with_int

Attributes::with_string

BatchExporter

BatchExporter::new

BatchExporter::start

BatchExporterOptions

BatchExporterOptions::enable_debug_log

BatchExporterOptions::with_export_timeout_millis

BatchExporterOptions::with_max_export_batch_size

BatchExporterOptions::with_max_queue_size

BatchExporterOptions::with_schedule_delay_millis

BatchExporterOptions::with_set_timeout

BatchSpanProcessor

BatchSpanProcessor::new

BatchSpanProcessor::start

BatchSpanProcessorOptions

BatchSpanProcessorOptions::enable_debug_log

BatchSpanProcessorOptions::with_export_timeout_millis

BatchSpanProcessorOptions::with_max_export_batch_size

BatchSpanProcessorOptions::with_max_queue_size

BatchSpanProcessorOptions::with_schedule_delay_millis

BatchSpanProcessorOptions::with_set_timeout

Context

Context::contains

Context::empty

Context::get

Context::get_bool

Context::get_double

Context::get_int

Context::get_string

Context::new

Context::size

Context::with_bool

Context::with_double

Context::with_int

Context::with_string

ContextValue

ExportAdapter

HttpError

HttpError::http_status

HttpError::invalid_response

HttpError::is_retryable

HttpError::network

HttpError::request

HttpError::security

HttpError::timeout

HttpJsonSendAdaptor

HttpJsonSendAdaptor::new

HttpProtobufSendAdaptor

HttpProtobufSendAdaptor::new

HttpRequest

HttpResponse

InternalLogger