wrap

type Disconnector interface {
	OnDisconnect(ctx context.Context, p peer.ID)
}

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

type Notifee interface {
	DialStarted(trpt string, raddr ma.Multiaddr, p peer.ID, start time.Time)
	DialEnded(trpt string, raddr ma.Multiaddr, p peer.ID, start time.Time, end time.Time, err error)
}

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

type QuicTransport struct {
	*Notifier
	// contains filtered or unexported fields
}

type RPCSendMessageEndedEvent struct {
	QueryID    uuid.UUID
	RemotePeer peer.ID
	StartedAt  time.Time
	EndedAt    time.Time
	Message    *pb.Message
	Error      error
}

type RPCSendMessageStartedEvent struct {
	QueryID    uuid.UUID
	RemotePeer peer.ID
	StartedAt  time.Time
	Message    *pb.Message
}

type RPCSendRequestEndedEvent struct {
	QueryID    uuid.UUID
	RemotePeer peer.ID
	StartedAt  time.Time
	EndedAt    time.Time
	Request    *pb.Message
	Response   *pb.Message
	Error      error
}

type RPCSendRequestStartedEvent struct {
	QueryID    uuid.UUID
	RemotePeer peer.ID
	StartedAt  time.Time
	Request    *pb.Message
}

type TCPTransport struct {
	*Notifier
	// contains filtered or unexported fields
}

type WSTransport struct {
	*Notifier
	// contains filtered or unexported fields
}