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-2025, 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, NVIDIA CORPORATION. All rights reserved.
Index ¶
- Constants
- Variables
- func InitSDM(config *cmn.Config, compression string)
- 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) IsFree() 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) Renew(trname string, recvCB transport.RecvObj, owt cmn.OWT, extra Extra) *DM
- 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) 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) ListenSmapChanged()
- func (sb *Streams) ReopenPeerStream(dstID string) error
- func (sb *Streams) Resync()
- 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 Args ¶
type Args struct {
Extra *transport.Extra // additional parameters
Net string // one of cmn.KnownNetworks, empty defaults to cmn.NetIntraData
Trname string // transport endpoint name
Ntype int // core.Target (0) by default
Multiplier int // so-many TCP connections per Rx endpoint, with round-robin
ManualResync bool // auto-resync by default
}
type DM ¶ added in v1.3.28
type DM struct {
// contains filtered or unexported fields
}
func (*DM) RegRecv ¶ added in v1.3.28
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 {
RecvAck transport.RecvObj
Config *cmn.Config
Compression string
Multiplier int
SizePDU int32
MaxHdrSize int32
}
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 and unregisters the bundle from Smap listeners; graceful=true blocks until all pending objects get completed (for "completion", see transport/README.md)
func (*Streams) ListenSmapChanged ¶
func (sb *Streams) ListenSmapChanged()
keep streams to => (clustered nodes as per rxNodeType) in sync at all times
func (*Streams) ReopenPeerStream ¶ added in v1.4.1
renew stream (or streams) to a given peer
func (*Streams) Resync ¶
func (sb *Streams) Resync()
Resync streams asynchronously is a slowpath; is called under lock; NOTE: calls stream.Stop()
Source Files