package transport import "time" type Transport interface { Send(data []byte) error Receive(timeout time.Duration) ([]byte, error) Close() error }