Versions in this module Expand all Collapse all v0 v0.0.1 Oct 7, 2025 Changes in this version + var ErrClosed = errors.New("libfabric client: closed") + type Client struct + func Connect(cfg Config) (*Client, error) + func Dial(cfg Config) (*Client, error) + func (c *Client) Close() error + func (c *Client) DefaultPeer() fi.Address + func (c *Client) LocalAddress() ([]byte, error) + func (c *Client) Receive(ctx context.Context, buf []byte) (int, error) + func (c *Client) ReceiveAsync(buf []byte) (*ReceiveFuture, error) + func (c *Client) ReceiveFrom(ctx context.Context, buf []byte) (int, fi.Address, error) + func (c *Client) RegisterPeer(addr []byte, setDefault bool) (fi.Address, error) + func (c *Client) RegisterReceiveHandler(handler ReceiveHandler) func() + func (c *Client) RegisterSendHandler(handler SendHandler) func() + func (c *Client) Send(ctx context.Context, payload []byte) error + func (c *Client) SendAsync(payload []byte) (*SendFuture, error) + func (c *Client) SendTo(ctx context.Context, dest fi.Address, payload []byte) error + func (c *Client) SendToAsync(payload []byte, dest fi.Address) (*SendFuture, error) + func (c *Client) SetDefaultPeer(addr fi.Address) + func (c *Client) Stats() Stats + type Config struct + EndpointType fi.EndpointType + Logger Logger + MRPoolAccess fi.MRAccessFlag + MRPoolCapacity int + MRPoolSize int + Metrics MetricHook + Node string + Provider string + Service string + StructuredLogger StructuredLogger + Timeout time.Duration + Tracer Tracer + type Listener struct + func Listen(cfg ListenerConfig) (*Listener, error) + func (l *Listener) Accept(ctx context.Context) (*Client, error) + func (l *Listener) Addr() ([]byte, error) + func (l *Listener) Close() error + type ListenerConfig struct + Logger Logger + Metrics MetricHook + Node string + Provider string + Service string + StructuredLogger StructuredLogger + Tracer Tracer + type Logger interface + Debugf func(format string, args ...any) + type MetricHook interface + DispatcherCQError func(kind string, err error, attrs map[string]string) + DispatcherStarted func(attrs map[string]string) + DispatcherStopped func(attrs map[string]string) + ReceiveCompleted func(attrs map[string]string) + ReceiveFailed func(err error, attrs map[string]string) + SendCompleted func(attrs map[string]string) + SendFailed func(err error, attrs map[string]string) + type OTelMetrics struct + func NewOTelMetrics(opts OTelMetricsOptions) (*OTelMetrics, error) + func (o *OTelMetrics) DispatcherCQError(kind string, _ error, attrs map[string]string) + func (o *OTelMetrics) DispatcherStarted(attrs map[string]string) + func (o *OTelMetrics) DispatcherStopped(attrs map[string]string) + func (o *OTelMetrics) ReceiveCompleted(attrs map[string]string) + func (o *OTelMetrics) ReceiveFailed(_ error, attrs map[string]string) + func (o *OTelMetrics) SendCompleted(attrs map[string]string) + func (o *OTelMetrics) SendFailed(_ error, attrs map[string]string) + type OTelMetricsOptions struct + InstrumentationName string + InstrumentationVersion string + Meter metric.Meter + MeterProvider metric.MeterProvider + type OperationError struct + Data uint64 + Errno fi.Errno + Flags uint64 + Kind OperationKind + Length uint64 + ProviderErr int + Tag uint64 + func (e OperationError) Error() string + func (e OperationError) Unwrap() error + type OperationKind int + const OperationReceive + const OperationSend + func (k OperationKind) String() string + type PrometheusMetrics struct + func NewPrometheusMetrics(opts PrometheusMetricsOptions) (*PrometheusMetrics, error) + func (p *PrometheusMetrics) DispatcherCQError(kind string, _ error, attrs map[string]string) + func (p *PrometheusMetrics) DispatcherStarted(attrs map[string]string) + func (p *PrometheusMetrics) DispatcherStopped(attrs map[string]string) + func (p *PrometheusMetrics) ReceiveCompleted(attrs map[string]string) + func (p *PrometheusMetrics) ReceiveFailed(_ error, attrs map[string]string) + func (p *PrometheusMetrics) SendCompleted(attrs map[string]string) + func (p *PrometheusMetrics) SendFailed(_ error, attrs map[string]string) + type PrometheusMetricsOptions struct + ConstLabels prometheus.Labels + Namespace string + Registerer prometheus.Registerer + Subsystem string + type ReceiveCompletion struct + Err error + Payload []byte + Source fi.Address + type ReceiveFuture struct + func (f *ReceiveFuture) Await(ctx context.Context) (int, error) + func (f *ReceiveFuture) Buffer() []byte + func (f *ReceiveFuture) Done() <-chan struct{} + func (f *ReceiveFuture) OnComplete(fn func(int, error)) + func (f *ReceiveFuture) Source() fi.Address + type ReceiveHandler func(ReceiveCompletion) + type SendCompletion struct + Err error + Size int + type SendFuture struct + func (f *SendFuture) Await(ctx context.Context) error + func (f *SendFuture) Done() <-chan struct{} + func (f *SendFuture) OnComplete(fn func(error)) + type SendHandler func(SendCompletion) + type Span interface + AddEvent func(name string, attrs ...TraceAttribute) + End func(err error) + RecordError func(err error) + type Stats struct + ReceiveErrored uint64 + ReceiveMatched uint64 + ReceivePosted uint64 + SendCompleted uint64 + SendErrored uint64 + SendPosted uint64 + type StructuredLogger interface + Debugw func(msg string, keyvals ...any) + type TraceAttribute struct + Key string + Value any + type Tracer interface + StartSpan func(name string, attrs ...TraceAttribute) Span
Go to main page