connection

type Config struct {
	Version          int32
	MinRemoteVersion int32
	Services         uint64
	UserAgent        string
	StartHeight      int32
	Relay            bool
}

type Conn interface {
	// Name/address of the endpoint we're connected to.
	Endpoint() string

	// Write to this channel to send messages on the connection.
	WriteChannel() chan<- Message

	// Connection failed to set up and should not be used or closed. Only
	// initial errors will set this, later errors will come through
	// the channel provided to Run().
	Error() error

	// Start the operation of a connected connection. Errors and received
	// messages will be passed on the provided channel. The caller can
	// safely close the channel after Close() returns.
	Run(chan<- Message)

	// Close connection. Blocks until it's done, specifically it's safe to
	// close the channel provided to Run() when this call returns. Only
	// call when connected, ie. when Error() == nil.
	Close()

	MostRecentActivity() time.Time
}

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

type Message struct {
	Endpoint string
	Type     string
	Data     []byte
	// contains filtered or unexported fields
}