helpers

Documentation

Index

• func Hash(in []byte) []byte
• func MeasureLatency(ctx context.Context, ip net.IP, logger Logger) (result time.Duration)
• type AddrInfo
  • func CopyAddrInfo(addrInfo AddrInfo) *AddrInfo
• type Logger
• type ReconnectableStream
  • func NewReconnectableStream(logger Logger, newFunc func() (Stream, error)) *ReconnectableStream
  • func (stream *ReconnectableStream) Connect()
• type Stream

Functions

func Hash

func Hash(in []byte) []byte

func MeasureLatency

func MeasureLatency(ctx context.Context, ip net.IP, logger Logger) (result time.Duration)

Types

type AddrInfo

type AddrInfo = peer.AddrInfo

func CopyAddrInfo

func CopyAddrInfo(addrInfo AddrInfo) *AddrInfo

type Logger

type Logger interface {
	Error(...interface{})
	Infof(string, ...interface{})
	Debugf(string, ...interface{})
}

type ReconnectableStream

type ReconnectableStream struct {
	Stream
	// contains filtered or unexported fields
}

func NewReconnectableStream

func NewReconnectableStream(logger Logger, newFunc func() (Stream, error)) *ReconnectableStream

func (*ReconnectableStream) Connect

func (stream *ReconnectableStream) Connect()

type Stream

type Stream = network.Stream