dialer

Documentation

Index

• Variables
• type Dialer
  • func NewDialer(le *logrus.Entry, tptDialer transport.TransportDialer, opts *DialerOpts, ...) *Dialer
  • func (d *Dialer) Execute(ctx context.Context) error
• type DialerOpts
  • func (m *DialerOpts) CloneMessageVT() proto.Message
  • func (m *DialerOpts) CloneVT() *DialerOpts
  • func (*DialerOpts) Descriptor() ([]byte, []int)
  • func (this *DialerOpts) EqualMessageVT(thatMsg proto.Message) bool
  • func (this *DialerOpts) EqualVT(that *DialerOpts) bool
  • func (x *DialerOpts) GetAddress() string
  • func (x *DialerOpts) GetBackoff() *backoff.Backoff
  • func (m *DialerOpts) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *DialerOpts) MarshalToVT(dAtA []byte) (int, error)
  • func (m *DialerOpts) MarshalVT() (dAtA []byte, err error)
  • func (*DialerOpts) ProtoMessage()
  • func (x *DialerOpts) ProtoReflect() protoreflect.Message
  • func (x *DialerOpts) Reset()
  • func (m *DialerOpts) SizeVT() (n int)
  • func (x *DialerOpts) String() string
  • func (m *DialerOpts) UnmarshalVT(dAtA []byte) error

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_dialer_dialer_proto protoreflect.FileDescriptor

Types

type Dialer

type Dialer struct {
	// contains filtered or unexported fields
}

Dialer manages a transport dialer.

func NewDialer

func NewDialer(
	le *logrus.Entry,
	tptDialer transport.TransportDialer,
	opts *DialerOpts,
	peerID peer.ID,
	address string,
) *Dialer

NewDialer constructs a new Dialer

func (*Dialer) Execute

func (d *Dialer) Execute(ctx context.Context) error

Execute executes the dialer, with backoff.

type DialerOpts

type DialerOpts struct {

	// Address is the address of the peer, in the format expected by the transport.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// Backoff is the dialing backoff configuration.
	// Can be empty.
	Backoff *backoff.Backoff `protobuf:"bytes,2,opt,name=backoff,proto3" json:"backoff,omitempty"`
	// contains filtered or unexported fields
}

DialerOpts contains options relating to dialing a statically configured peer.

func (*DialerOpts) CloneMessageVT

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

func (*DialerOpts) CloneVT

func (m *DialerOpts) CloneVT() *DialerOpts

func (*DialerOpts) Descriptor

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

Deprecated: Use DialerOpts.ProtoReflect.Descriptor instead.

func (*DialerOpts) EqualMessageVT

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

func (*DialerOpts) EqualVT

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

func (*DialerOpts) GetAddress

func (x *DialerOpts) GetAddress() string

func (*DialerOpts) GetBackoff

func (x *DialerOpts) GetBackoff() *backoff.Backoff

func (*DialerOpts) MarshalToSizedBufferVT

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

func (*DialerOpts) MarshalToVT

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

func (*DialerOpts) MarshalVT

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

func (*DialerOpts) ProtoMessage

func (*DialerOpts) ProtoMessage()

func (*DialerOpts) ProtoReflect

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

func (*DialerOpts) Reset

func (x *DialerOpts) Reset()

func (*DialerOpts) SizeVT

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

func (*DialerOpts) String

func (x *DialerOpts) String() string

func (*DialerOpts) UnmarshalVT

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