Documentation
¶
Overview ¶
Package bundle provides multi-streaming transport with the functionality to dynamically (un)register receive endpoints, establish long-lived flows, and more.
- Copyright (c) 2018-2026, NVIDIA CORPORATION. All rights reserved.
Package bundle provides multi-streaming transport with the functionality to dynamically (un)register receive endpoints, establish long-lived flows, and more.
- Copyright (c) 2018-2026, NVIDIA CORPORATION. All rights reserved.
Package bundle provides multi-streaming transport with the functionality to dynamically (un)register receive endpoints, establish long-lived flows, and more.
- Copyright (c) 2025-2026, NVIDIA CORPORATION. All rights reserved.
Index ¶
- Constants
- Variables
- func IsErrDestinationMissing(e error) bool
- type Args
- type DM
- func (dm *DM) ACK(hdr *transport.ObjHdr, cb transport.SentCB, tsi *meta.Snode) error
- func (dm *DM) Abort()
- func (dm *DM) Bcast(obj *transport.Obj, roc cos.ReadOpenCloser) error
- func (dm *DM) Close(err error)
- func (dm *DM) IsOpen() bool
- func (dm *DM) NetC() string
- func (dm *DM) NetD() string
- func (dm *DM) Notif(hdr *transport.ObjHdr) error
- func (dm *DM) OWT() cmn.OWT
- func (dm *DM) Open()
- func (dm *DM) RegRecv() error
- func (dm *DM) Send(obj *transport.Obj, roc cos.ReadOpenCloser, tsi *meta.Snode, ...) (err error)
- func (dm *DM) SetXact(xctn core.Xact)
- func (dm *DM) Smap() *meta.Smap
- func (dm *DM) String() string
- func (dm *DM) UnregRecv()
- type ErrDestinationMissing
- type Extra
- type Streams
- func (sb *Streams) Abort()
- func (sb *Streams) Close(gracefully bool)
- func (sb *Streams) ReopenPeerStream(dstID string) error
- func (sb *Streams) Send(obj *transport.Obj, roc cos.ReadOpenCloser, nodes ...*meta.Snode) error
- func (sb *Streams) Smap() *meta.Smap
- func (sb *Streams) String() string
- func (sb *Streams) Trname() string
- func (sb *Streams) UsePDU() bool
Constants ¶
const SDMName = "shared-dm"
constant (until and if multiple instances)
Variables ¶
var SDM sharedDM
global
Functions ¶
func IsErrDestinationMissing ¶ added in v1.3.19
Types ¶
type DM ¶ added in v1.3.28
type DM struct {
Extra // (embed)
// contains filtered or unexported fields
}
data mover is an easy-to-use stream bundle
func (*DM) RegRecv ¶ added in v1.3.28
RegRecv: register user's receive-data (and, optionally, receive-ack) wrappers.
type ErrDestinationMissing ¶ added in v1.3.19
type ErrDestinationMissing struct {
// contains filtered or unexported fields
}
func (*ErrDestinationMissing) Error ¶ added in v1.3.19
func (e *ErrDestinationMissing) Error() string
type Extra ¶
type Extra struct {
// generic knobs { multiplier, burst, ... } from the parent xaction
cmn.XactConf
// extra
RecvAck transport.RecvObj
Config *cmn.Config
Smap *meta.Smap // TODO -- FIXME: xactions to pass
SizePDU int32
MaxHdrSize int32
SkipGenericStats bool // if true, DM does not auto-increment In/OutObjs - caller does
}
additional (and optional) params for new data mover instance
type Streams ¶
type Streams struct {
// contains filtered or unexported fields
}
func (*Streams) Close ¶
Close closes all contained streams; graceful=true blocks until all pending objects get completed (for "completion", see transport/README.md)
func (*Streams) ReopenPeerStream ¶ added in v1.4.1
renew stream (or streams) to a given peer in the same Smap "epoch"
Source Files