pconn

Documentation

Index

• Variables
• type Link
• type Opts
  • func (m *Opts) CloneMessageVT() proto.Message
  • func (m *Opts) CloneVT() *Opts
  • func (*Opts) Descriptor() ([]byte, []int)
  • func (this *Opts) EqualMessageVT(thatMsg proto.Message) bool
  • func (this *Opts) EqualVT(that *Opts) bool
  • func (x *Opts) GetQuic() *quic.Opts
  • func (x *Opts) GetVerbose() bool
  • func (m *Opts) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *Opts) MarshalToVT(dAtA []byte) (int, error)
  • func (m *Opts) MarshalVT() (dAtA []byte, err error)
  • func (*Opts) ProtoMessage()
  • func (x *Opts) ProtoReflect() protoreflect.Message
  • func (x *Opts) Reset()
  • func (m *Opts) SizeVT() (n int)
  • func (x *Opts) String() string
  • func (m *Opts) UnmarshalVT(dAtA []byte) error
• type Transport
  • func NewTransport(ctx context.Context, le *logrus.Entry, privKey crypto.PrivKey, ...) (*Transport, error)
  • func (t *Transport) Close() error
  • func (t *Transport) Execute(ctx context.Context) error
  • func (t *Transport) GetPeerDialer(ctx context.Context, peerID peer.ID) (*dialer.DialerOpts, error)
  • func (t *Transport) GetPeerID() peer.ID

Variables

var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)

var File_github_com_aperturerobotics_bifrost_transport_common_pconn_pconn_proto protoreflect.FileDescriptor

Types

type Link

type Link = transport_quic.Link

Link is a Quic-based connection/link backed by a packet connection.

type Opts

type Opts struct {

	// Quic are the quic protocol options.
	Quic *quic.Opts `protobuf:"bytes,1,opt,name=quic,proto3" json:"quic,omitempty"`
	// Verbose turns on verbose debug logging.
	Verbose bool `protobuf:"varint,2,opt,name=verbose,proto3" json:"verbose,omitempty"`
	// contains filtered or unexported fields
}

Opts are extra options for the packet conn.

func (*Opts) CloneMessageVT

func (m *Opts) CloneMessageVT() proto.Message

func (*Opts) CloneVT

func (m *Opts) CloneVT() *Opts

func (*Opts) Descriptor

func (*Opts) Descriptor() ([]byte, []int)

Deprecated: Use Opts.ProtoReflect.Descriptor instead.

func (*Opts) EqualMessageVT

func (this *Opts) EqualMessageVT(thatMsg proto.Message) bool

func (*Opts) EqualVT

func (this *Opts) EqualVT(that *Opts) bool

func (*Opts) GetQuic

func (x *Opts) GetQuic() *quic.Opts

func (*Opts) GetVerbose

func (x *Opts) GetVerbose() bool

func (*Opts) MarshalToSizedBufferVT

func (m *Opts) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Opts) MarshalToVT

func (m *Opts) MarshalToVT(dAtA []byte) (int, error)

func (*Opts) MarshalVT

func (m *Opts) MarshalVT() (dAtA []byte, err error)

func (*Opts) ProtoMessage

func (*Opts) ProtoMessage()

func (*Opts) ProtoReflect

func (x *Opts) ProtoReflect() protoreflect.Message

func (*Opts) Reset

func (x *Opts) Reset()

func (*Opts) SizeVT

func (m *Opts) SizeVT() (n int)

func (*Opts) String

func (x *Opts) String() string

func (*Opts) UnmarshalVT

func (m *Opts) UnmarshalVT(dAtA []byte) error

type Transport

type Transport struct {
	// Transport is the underlying quic transport
	*transport_quic.Transport
	// contains filtered or unexported fields
}

Transport implements a bifrost transport with a Quic-based packet conn. Transport UUIDs are deterministic and based on the LocalAddr() of the pconn.

func NewTransport

func NewTransport(
	ctx context.Context,
	le *logrus.Entry,
	privKey crypto.PrivKey,
	tc transport.TransportHandler,
	opts *Opts,

	uuid uint64,

	pc net.PacketConn,

	addrParser func(addr string) (net.Addr, error),

	staticPeerMap map[string]*dialer.DialerOpts,
) (*Transport, error)

NewTransport constructs a new packet-conn based transport.

func (*Transport) Close

func (t *Transport) Close() error

Close closes the transport, returning any errors closing.

func (*Transport) Execute

func (t *Transport) Execute(ctx context.Context) error

Execute executes the transport as configured, returning any fatal error.

func (*Transport) GetPeerDialer

func (t *Transport) GetPeerDialer(ctx context.Context, peerID peer.ID) (*dialer.DialerOpts, error)

GetPeerDialer returns the dialing information for a peer. Called when resolving EstablishLink. Return nil, nil to indicate not found or unavailable.

func (*Transport) GetPeerID

func (t *Transport) GetPeerID() peer.ID

GetPeerID returns the peer ID.